Commit 58af55b3 by huangfusuper

1. 修正脚本运行命令替换

parent 12f04a8c
...@@ -3,6 +3,7 @@ package com.byit.service.impl; ...@@ -3,6 +3,7 @@ package com.byit.service.impl;
import cn.hutool.http.HttpUtil; import cn.hutool.http.HttpUtil;
import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.byit.dto.executor.RunParamWrapped;
import com.byit.dto.personalise.JavaJobConfDTO; import com.byit.dto.personalise.JavaJobConfDTO;
import com.byit.dto.plugin.JavaTask; import com.byit.dto.plugin.JavaTask;
import com.byit.dto.plugin.RunLog; import com.byit.dto.plugin.RunLog;
...@@ -80,11 +81,15 @@ public class ApiNodeServiceImpl implements ApiNodeService { ...@@ -80,11 +81,15 @@ public class ApiNodeServiceImpl implements ApiNodeService {
JobTaskSchedule schedule = new JobTaskSchedule(); JobTaskSchedule schedule = new JobTaskSchedule();
String runParam = runNode.getRunParam();
RunParamWrapped runParamWrapped = new RunParamWrapped();
runParamWrapped.setPrivateParam(runParam);
schedule.setNodeId(Integer.valueOf(runNode.getNodeId())); schedule.setNodeId(Integer.valueOf(runNode.getNodeId()));
schedule.setRunId(runId); schedule.setRunId(runId);
schedule.setNodeName(runNode.getNodeName()); schedule.setNodeName(runNode.getNodeName());
schedule.setIsVirtual(NodePropertyEnum.ISNOT_VIRTUAL.getCode()); schedule.setIsVirtual(NodePropertyEnum.ISNOT_VIRTUAL.getCode());
schedule.setRunParam(runNode.getRunParam()); schedule.setRunParam(JSON.toJSONString(runParamWrapped));
schedule.setRunCommand(runNode.getRunCmd()); schedule.setRunCommand(runNode.getRunCmd());
schedule.setRunSource(runNode.getRunSource()); schedule.setRunSource(runNode.getRunSource());
schedule.setScriptUrls(runNode.getScriptUrl()); schedule.setScriptUrls(runNode.getScriptUrl());
......
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