处理只有子流的情况

byit-myth-core/myth-admin-core/src/main/java/com/byit/strategy/task/java/JavaParamWrappedCallback.java

@@ -44,23 +44,30 @@ public class JavaParamWrappedCallback implements TaskRunTheLifeCycleCallback {
      */
     @Override
     public void postProcessAfterInitialization(JobTaskSchedule jobTaskSchedule) {
+        RunParamWrapped runParamWrapped = new RunParamWrapped();
+
         String runId = jobTaskSchedule.getRunId();
         String flowName = jobTaskSchedule.getFlowName();
         RunRecording runRecording = runRecordingService.findAllByRunIDAndFlowName(runId, flowName);
-        String extendedConfiguration = runRecording.getExtendedConfiguration();
-        FlowExtendedConfiguration flowExtendedConfiguration = JSON.parseObject(extendedConfiguration, FlowExtendedConfiguration.class);
 
-        String publicParam = flowExtendedConfiguration.getPublicParam();
-        Map<String,String> publicMap = JSON.parseObject(publicParam, Map.class);
-        if(publicMap == null) {
-            publicMap = new HashMap<>(8);
+        if(runRecording != null) {
+            String extendedConfiguration = runRecording.getExtendedConfiguration();
+            FlowExtendedConfiguration flowExtendedConfiguration = JSON.parseObject(extendedConfiguration, FlowExtendedConfiguration.class);
+
+            String publicParam = flowExtendedConfiguration.getPublicParam();
+            Map<String,String> publicMap = JSON.parseObject(publicParam, Map.class);
+            if(publicMap == null) {
+                publicMap = new HashMap<>(8);
+            }
+
+
+            runParamWrapped.setPublicParamMap(publicMap);
+
         }
 
         String runParam = jobTaskSchedule.getRunParam();
-
-        RunParamWrapped runParamWrapped = new RunParamWrapped();
         runParamWrapped.setPrivateParam(runParam);
-        runParamWrapped.setPublicParamMap(publicMap);
+
         jobTaskSchedule.setRunParam(JSON.toJSONString(runParamWrapped));
     }
 }