重跑增加操作人

byit-myth-admin/src/main/java/com/byit/service/impl/ApiNodeServiceImpl.java

@@ -82,17 +82,16 @@ public class ApiNodeServiceImpl implements ApiNodeService {
         JobTaskSchedule schedule = new JobTaskSchedule();
         //获取运行参数
         String runParam = runNode.getRunParam();
-        RunParamWrapped runParamWrapped = new RunParamWrapped();
-        //包装公共参数和私有参数
-        runParamWrapped.setPrivateParam(runParam);
-        runParamWrapped.setPublicParamMap(runNode.getPublicParam());
+//        RunParamWrapped runParamWrapped = new RunParamWrapped();
+//        //包装公共参数和私有参数
+//        runParamWrapped.setPrivateParam(runParam);
+//        runParamWrapped.setPublicParamMap(runNode.getPublicParam());
         //开始构建 schedule
-        schedule.setRunParam(JSON.toJSONString(runParamWrapped));
+        schedule.setRunParam(runParam);
         schedule.setNodeId(Integer.valueOf(runNode.getNodeId()));
         schedule.setRunId(runId);
         schedule.setNodeName(runNode.getNodeName());
         schedule.setIsVirtual(NodePropertyEnum.ISNOT_VIRTUAL.getCode());
-        schedule.setRunParam(JSON.toJSONString(runParamWrapped));
         schedule.setRunCommand(runNode.getRunCmd());
         schedule.setNodeDesc(runNode.getHasAddLogToFlow());
         schedule.setRunSource(runNode.getRunSource());
@@ -126,7 +125,6 @@ public class ApiNodeServiceImpl implements ApiNodeService {
         if (NodeTypeEnum.JAVA.getCode().equals(runNode.getJobType())) {
             timerTask = new JavaNodeExecutorTask(schedule);
         }else{
-            schedule.setRunParam(JSON.toJSONString(runParamWrapped));
             timerTask = new ScriptExecutorJobTask(schedule);
         }
         //添加到调度轮