Commit 02a69ae9 by huangfu

java节点扩展配置

parent 74eb75a4
...@@ -54,6 +54,9 @@ public class JavaParamWrappedCallback implements TaskRunTheLifeCycleCallback { ...@@ -54,6 +54,9 @@ public class JavaParamWrappedCallback implements TaskRunTheLifeCycleCallback {
if(runRecording != null) { if(runRecording != null) {
String extendedConfiguration = runRecording.getExtendedConfiguration(); String extendedConfiguration = runRecording.getExtendedConfiguration();
FlowExtendedConfiguration flowExtendedConfiguration = JSON.parseObject(extendedConfiguration, FlowExtendedConfiguration.class); FlowExtendedConfiguration flowExtendedConfiguration = JSON.parseObject(extendedConfiguration, FlowExtendedConfiguration.class);
if (flowExtendedConfiguration == null) {
flowExtendedConfiguration = new FlowExtendedConfiguration();
}
String publicParam = flowExtendedConfiguration.getPublicParam(); String publicParam = flowExtendedConfiguration.getPublicParam();
Map<String,String> publicMap = JSON.parseObject(publicParam, Map.class); Map<String,String> publicMap = JSON.parseObject(publicParam, Map.class);
...@@ -63,12 +66,13 @@ public class JavaParamWrappedCallback implements TaskRunTheLifeCycleCallback { ...@@ -63,12 +66,13 @@ public class JavaParamWrappedCallback implements TaskRunTheLifeCycleCallback {
runParamWrapped.setPublicParamMap(publicMap); runParamWrapped.setPublicParamMap(publicMap);
jobTaskSchedule.setExtendedConfiguration(JSON.toJSONString(flowExtendedConfiguration));
} }
String runParam = jobTaskSchedule.getRunParam(); String runParam = jobTaskSchedule.getRunParam();
runParamWrapped.setPrivateParam(runParam); runParamWrapped.setPrivateParam(runParam);
jobTaskSchedule.setRunParam(JSON.toJSONString(runParamWrapped)); jobTaskSchedule.setRunParam(JSON.toJSONString(runParamWrapped));
} }
} }
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