Просмотр исходного кода

解决es没有删除临时目录的问题

wukai 1 год назад
Родитель
Сommit
94fa2fa114

+ 7 - 0
sync-out/src/main/java/com/jjt/out/service/impl/OutEsServiceImpl.java

@@ -13,6 +13,7 @@ import com.jjt.out.domain.OutProcessInfo;
 import com.jjt.out.service.IOutEsService;
 import com.jjt.out.service.IOutProcessInfoService;
 import com.jjt.system.service.ISysConfigService;
+import org.apache.commons.io.FileUtils;
 import org.apache.http.HttpEntity;
 import org.apache.http.HttpHost;
 import org.apache.http.entity.ContentType;
@@ -163,6 +164,12 @@ public class OutEsServiceImpl extends OutBaseService implements IOutEsService {
         CompressZip.zip(targetDir, zipFile);
         //打包文件--end
 
+        try {
+            //删除临时文件
+            FileUtils.deleteDirectory(targetDir);
+        } catch (IOException ignored) {
+        }
+
         //生成描述json文件--start
         String descName = syncDir + "sync-99-" + time + ".json";
         GenerateJsonFile.generate(zipFile.toPath(), descName, zipName, SyncType.es);