Browse Source

增加读取失败文件处理

koul 4 years ago
parent
commit
5ddfcd7847
1 changed files with 10 additions and 1 deletions
  1. 10 1
      src/main/java/com/uas/service/Impl/DownloadServiceImpl.java

+ 10 - 1
src/main/java/com/uas/service/Impl/DownloadServiceImpl.java

@@ -106,7 +106,16 @@ public class DownloadServiceImpl implements DownloadService {
 								sqls = parseXmlFileToSqls(file, statement);
 								sqls = parseXmlFileToSqls(file, statement);
 								String s = file.getName().substring(0, file.getName().indexOf(".")) + ".xml";
 								String s = file.getName().substring(0, file.getName().indexOf(".")) + ".xml";
 								if (sqls == null) {
 								if (sqls == null) {
-									sftp.rename(ftpMap.get("downloadpath").toString() + "/" + s, "goodsreceipt/backup/" + s);
+									if ("N_YITOA_LHCT-SF".equals(depot)||"N_YITOA_LHCT_T-SF".equals(depot)) {
+										Boolean rename = sftp.rename(ftpMap.get("downloadpath").toString() + "/" + s, "goodsreceipt/backup/" + s);
+									}else if ("N_YITOA_LHCT-ZSD".equals(depot)){
+										Boolean rename = sftp.rename(ftpMap.get("downloadpath").toString() + "/" + s, "lhcthkhub/LHCT/reply_fail/" + s);
+									}else if ("LHCT_SZ-ZSD".equals(depot)){
+										Boolean rename = sftp.rename(ftpMap.get("downloadpath").toString() + "/" + s, "lhctdz/reply_fail/" + s);
+									}else {
+										//移动处理完的文件到bak文件夹下
+										client.rename(file.getName(), "bak/" + file.getName());
+									}
 									continue;
 									continue;
 								}
 								}