处理完数据之后删除临时目录下的文件

sync-in/src/main/java/com/jjt/in/service/impl/InProcessServiceImpl.java

@@ -13,6 +13,7 @@ import com.jjt.in.service.IInSyncInfoService;
 import com.jjt.system.service.ISysConfigService;
 import net.lingala.zip4j.ZipFile;
 import org.apache.commons.codec.digest.DigestUtils;
+import org.apache.commons.io.FileUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.stereotype.Service;
@@ -110,6 +111,9 @@ public class InProcessServiceImpl extends InBaseService implements IInProcessSer
                                     CompressZip.unzip(zipFile, targetDir);
                                     String esDir = tmpDir + "es/" + desc.getName().split("\\.")[0].split("-")[2];
                                     esService.parseSyncFile(esDir);
+
+                                    //删除临时目录的解压文件
+                                    FileUtils.deleteDirectory(new File(esDir));
                                     break;
                                 case mongo:
                                     File mongoTargetDir = new File(tmpDir + "mongo/");
@@ -126,7 +130,10 @@ public class InProcessServiceImpl extends InBaseService implements IInProcessSer
                                     }
                                     String mongoDir = tmpDir + "mongo/" + desc.getName().split("\\.")[0].split("-")[2];
                                     boolean isInc = file.getName().indexOf("-78-") != -1;
+                                    log.info("文件名：{}是否增量：{}", file.getName(), isInc);
                                     mongoService.parseSyncFile(mongoDir, isInc);
+                                    //删除临时目录的解压文件
+                                    FileUtils.deleteDirectory(new File(mongoDir));
                                     break;
                                 case mysql:
                                     handleMysqlType(zipFile);