...
|
...
|
@@ -3,6 +3,7 @@ package com.tianbo.analysis.task; |
|
|
import com.tianbo.util.Date.DateUtil;
|
|
|
import com.tianbo.util.IO.FileTool;
|
|
|
import com.tianbo.analysis.handle.CustomXmlHandle;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
import org.apache.commons.io.FileUtils;
|
|
|
import org.springframework.beans.factory.annotation.Value;
|
|
|
import org.springframework.scheduling.annotation.Scheduled;
|
...
|
...
|
@@ -15,6 +16,7 @@ import java.util.List; |
|
|
/**
|
|
|
* 回执解析定时任务
|
|
|
*/
|
|
|
@Slf4j
|
|
|
@Component
|
|
|
public class TaskAnalysis {
|
|
|
|
...
|
...
|
@@ -39,25 +41,32 @@ public class TaskAnalysis { |
|
|
String readDir = receptDir + "/" + today;
|
|
|
String backdireByDay = bakupDir + "/" + today;
|
|
|
|
|
|
List<File> files = FileTool.readDirectoryFiles(new File(readDir));
|
|
|
Iterator<File> it = files.iterator();
|
|
|
while(it.hasNext()){
|
|
|
File file = it.next();
|
|
|
try {
|
|
|
//解析
|
|
|
int i = new CustomXmlHandle().handelXmlDocument(file);
|
|
|
//操作成功,则转移剪切解析文件到备份目录,否则转移到error目录备份
|
|
|
if(i>0){
|
|
|
File bakupDirectory = new File(backdireByDay);
|
|
|
FileUtils.moveFileToDirectory(file,bakupDirectory,true);
|
|
|
}else {
|
|
|
try{
|
|
|
List<File> files = FileTool.readDirectoryFiles(new File(readDir));
|
|
|
Iterator<File> it = files.iterator();
|
|
|
while(it.hasNext()){
|
|
|
File file = it.next();
|
|
|
try {
|
|
|
//解析
|
|
|
int i = new CustomXmlHandle().handelXmlDocument(file);
|
|
|
//操作成功,则转移剪切解析文件到备份目录,否则转移到error目录备份
|
|
|
if(i>0){
|
|
|
File bakupDirectory = new File(backdireByDay);
|
|
|
FileUtils.moveFileToDirectory(file,bakupDirectory,true);
|
|
|
}else {
|
|
|
errBak(file);
|
|
|
}
|
|
|
}catch (Exception e){
|
|
|
e.printStackTrace();
|
|
|
log.error("解析回执出错",e);
|
|
|
errBak(file);
|
|
|
}
|
|
|
}catch (Exception e){
|
|
|
e.printStackTrace();
|
|
|
errBak(file);
|
|
|
}
|
|
|
}catch (Exception e){
|
|
|
e.printStackTrace();
|
|
|
log.error("获取目录文件出错",e);
|
|
|
}
|
|
|
|
|
|
}
|
|
|
|
|
|
public void errBak(File file){
|
...
|
...
|
|