Commit 985fd6a8 by huangfusuper

资源拉取压缩

parent a77e4da9
...@@ -47,4 +47,9 @@ public class ScriptDto implements Serializable { ...@@ -47,4 +47,9 @@ public class ScriptDto implements Serializable {
* 执行结果 * 执行结果
*/ */
private Integer exitCode; private Integer exitCode;
/**
* 临时目录 执行后删除该目录
*/
private String tempDir;
} }
package com.byit.node.impl; package com.byit.node.impl;
import cn.hutool.core.io.FileUtil;
import com.byit.dto.executor.ScriptDto; import com.byit.dto.executor.ScriptDto;
import com.byit.exceptions.ExecutorException; import com.byit.exceptions.ExecutorException;
import com.byit.filesystem.FileSystem; import com.byit.filesystem.FileSystem;
import com.byit.node.ProcessingNodeChain; import com.byit.node.ProcessingNodeChain;
import com.byit.node.machine.ProcessingMachine; import com.byit.node.machine.ProcessingMachine;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import java.io.File;
import java.nio.charset.StandardCharsets; import java.nio.charset.StandardCharsets;
import java.util.HashMap; import java.util.HashMap;
import java.util.Map; import java.util.Map;
...@@ -64,7 +67,9 @@ public class LogDataProcessingMachine implements ProcessingMachine { ...@@ -64,7 +67,9 @@ public class LogDataProcessingMachine implements ProcessingMachine {
e.printStackTrace(); e.printStackTrace();
throw new ExecutorException(e); throw new ExecutorException(e);
} }
if(StringUtils.isNoneBlank(scriptDto.getTempDir())){
FileUtil.del(new File(scriptDto.getTempDir()));
}
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment