作者 朱兆平

文件是否存在判定

@@ -32,12 +32,12 @@ spring: @@ -32,12 +32,12 @@ spring:
32 #eureka主机名,会在控制页面中显示 32 #eureka主机名,会在控制页面中显示
33 #DEV环境关闭注册。 33 #DEV环境关闭注册。
34 features: 34 features:
35 - enabled: true 35 + enabled: false
36 discovery: 36 discovery:
37 - enabled: true 37 + enabled: false
38 service-registry: 38 service-registry:
39 auto-registration: 39 auto-registration:
40 - enabled: true 40 + enabled: false
41 41
42 datasource: 42 datasource:
43 type: com.alibaba.druid.pool.DruidDataSource 43 type: com.alibaba.druid.pool.DruidDataSource
@@ -33,7 +33,7 @@ public class LogWebsockController { @@ -33,7 +33,7 @@ public class LogWebsockController {
33 webSocketSet.add(this); 33 webSocketSet.add(this);
34 addOnlineCount(); 34 addOnlineCount();
35 try { 35 try {
36 - process = Runtime.getRuntime().exec("tail -f logs/imf.log"); 36 + process = Runtime.getRuntime().exec("tail -f logs/log_info.log");
37 inputStream = process.getInputStream(); 37 inputStream = process.getInputStream();
38 IO_Log_Handle thread = new IO_Log_Handle(inputStream, session); 38 IO_Log_Handle thread = new IO_Log_Handle(inputStream, session);
39 thread.start(); 39 thread.start();
@@ -37,31 +37,33 @@ public class TaskAnalysis { @@ -37,31 +37,33 @@ public class TaskAnalysis {
37 @Scheduled(fixedDelay = 20000) 37 @Scheduled(fixedDelay = 20000)
38 public void startTask(){ 38 public void startTask(){
39 String today = DateUtil.getTodayBy_yyyyMMdd(); 39 String today = DateUtil.getTodayBy_yyyyMMdd();
40 - String readDir = receptDir + "\\" + today; 40 + String readDir = receptDir + "/" + today;
  41 +
41 log.info("回执读取目录:"+readDir); 42 log.info("回执读取目录:"+readDir);
42 - String backdireByDay = bakupDir + "\\" + today; 43 + String backdireByDay = bakupDir + "/" + today;
43 44
44 try{ 45 try{
45 - List<File> files = FileTool.readDirectoryFiles(new File(readDir));  
46 - Iterator<File> it = files.iterator();  
47 - while(it.hasNext()){  
48 - File file = it.next();  
49 - try {  
50 - //解析  
51 - int i = new CustomXmlHandle().handelXmlDocument(file);  
52 - //操作成功,则转移剪切解析文件到备份目录,否则转移到error目录备份  
53 - if(i>0){  
54 - File bakupDirectory = new File(backdireByDay);  
55 - FileUtils.moveFileToDirectory(file,bakupDirectory,true);  
56 - }else { 46 + File fileDirectory = new File(readDir);
  47 + List<File> files = FileTool.readDirectoryFiles(fileDirectory);
  48 + Iterator<File> it = files.iterator();
  49 + while(it.hasNext()){
  50 + File file = it.next();
  51 + try {
  52 + //解析
  53 + int i = new CustomXmlHandle().handelXmlDocument(file);
  54 + //操作成功,则转移剪切解析文件到备份目录,否则转移到error目录备份
  55 + if(i>0){
  56 + File bakupDirectory = new File(backdireByDay);
  57 + FileUtils.moveFileToDirectory(file,bakupDirectory,true);
  58 + }else {
  59 + errBak(file);
  60 + }
  61 + }catch (Exception e){
  62 + e.printStackTrace();
  63 + log.error("解析回执出错",e);
57 errBak(file); 64 errBak(file);
58 } 65 }
59 - }catch (Exception e){  
60 - e.printStackTrace();  
61 - log.error("解析回执出错",e);  
62 - errBak(file);  
63 } 66 }
64 - }  
65 }catch (Exception e){ 67 }catch (Exception e){
66 e.printStackTrace(); 68 e.printStackTrace();
67 log.error("获取目录文件出错",e); 69 log.error("获取目录文件出错",e);