调度命令处理

byit-myth-executor/myth-executor-server/src/main/java/com/byit/node/impl/RunScriptProcessingMachine.java

@@ -6,9 +6,11 @@ import com.byit.node.ProcessingNodeChain;
 import com.byit.node.machine.ProcessingMachine;
 import com.byit.process.MythJobProcess;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
 import org.springframework.data.redis.core.StringRedisTemplate;
 import org.springframework.stereotype.Component;
 
+import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.List;
 
@@ -35,12 +37,18 @@ public class RunScriptProcessingMachine implements ProcessingMachine {
     public void executor(ScriptDto scriptDto, ProcessingNodeChain processingNodeChain) {
         try {
             boolean isRunNode = scriptDto.getRunId().contains("REAL:EXEC:");
-            List<String> cmdList = Arrays.asList(scriptDto.getCommand());
+            List<String> cmdList = Arrays.asList(scriptDto.getCommand().split(" "));
+            List<String> newCmdList = new ArrayList<>();
+            cmdList.forEach(cmd ->{
+                if (StringUtils.isNotBlank(cmd)) {
+                    newCmdList.add(cmd);
+                }
+            });
             MythJobProcess mythJobProcess;
             if(isRunNode) {
-                mythJobProcess = new MythJobProcess(cmdList, null, null, scriptDto.getLogId(), stringRedisTemplate);
+                mythJobProcess = new MythJobProcess(newCmdList, null, null, scriptDto.getLogId(), stringRedisTemplate);
             }else {
-                mythJobProcess = new MythJobProcess(cmdList, null, null, scriptDto.getLogId(), null);
+                mythJobProcess = new MythJobProcess(newCmdList, null, null, scriptDto.getLogId(), null);
             }
 
             //保存日志