执行失败也执行结束周期回调

byit-myth-core/myth-admin-core/src/main/java/com/byit/strategy/instances/RpcCallbackInstanceRunTheLifeCycleCallback.java

@@ -22,6 +22,7 @@ import org.apache.commons.lang3.StringUtils;
 import org.springframework.data.redis.core.StringRedisTemplate;
 import org.springframework.stereotype.Component;
 
+import java.util.HashMap;
 import java.util.Map;
 
 /**
@@ -75,10 +76,13 @@ public class RpcCallbackInstanceRunTheLifeCycleCallback implements InstanceRunTh
         ReturnResult<String> returnResult = (ReturnResult<String>) result;
         //将对应的参数转换为公共参数 修改后的公共参数
         Map<String, String> lifeCyclePublicParam = JSON.parseObject(returnResult.getContent(), Map.class);
+        lifeCyclePublicParam.put("myPublic","huangfu");
         //修改后的公共参数重新保存到实例里面以及redis里面
         flowExtendedConfiguration.setPublicParam(JSON.toJSONString(lifeCyclePublicParam));
         //保存到redis
-        stringRedisTemplate.opsForValue().set(String.format(RedisKeyNameEnum.REDIS_PUBLIC_PARAM_KEY.getKeyName(), runRecording.getRunId(), flowExtendedConfiguration.getFlowEmbedLogo()), JSON.toJSONString(flowExtendedConfiguration));
+        String toJSONString = JSON.toJSONString(flowExtendedConfiguration);
+        stringRedisTemplate.opsForValue().set(String.format(RedisKeyNameEnum.REDIS_PUBLIC_PARAM_KEY.getKeyName(), runRecording.getRunId(), flowExtendedConfiguration.getFlowEmbedLogo()), toJSONString);
+        runRecording.setExtendedConfiguration(toJSONString);
         return runRecording;
     }
 
@@ -145,4 +149,21 @@ public class RpcCallbackInstanceRunTheLifeCycleCallback implements InstanceRunTh
         rpcRequestPacket.setParam(param);
         return rpcRequestPacket;
     }
+
+    public static void main(String[] args) {
+        Map<String,String> publicParam = new HashMap<>(8);
+        publicParam.put("name","张三");
+        publicParam.put("age","12");
+        publicParam.put("sex","男");
+        publicParam.put("class","计算及网路");
+        FlowExtendedConfiguration flowExtendedConfiguration = new FlowExtendedConfiguration();
+        flowExtendedConfiguration.setPublicParam(JSON.toJSONString(publicParam));
+        flowExtendedConfiguration.setFlowEmbedLogo(":main_flow");
+        flowExtendedConfiguration.setRpcEndServerKey("qualityAfterTaskJob");
+        flowExtendedConfiguration.setRpcStartServerKey("qualityBeforeTaskJob");
+
+        System.out.println(JSON.toJSONString(flowExtendedConfiguration));
+        //{"flowEmbedLogo":":main_flow","rpcEndServerKey":"qualityAfterTaskJob","rpcStartServerKey":"qualityBeforeTaskJob"}
+        //{"privateParam":"{\"param\":{},\"placeholder\":{\"biz_date\":\"2020-11-17 09:02:38\",\"jobId\":\"899\",\"now_date\":\"2020-11-17 09:02:38\",\"env\":\"pro\",\"flowId\":\"764\",\"projectId\":\"14\",\"qualityParam\":\"[{\\\"column\\\":\\\"ddmp_data_time\\\",\\\"data\\\":\\\"2020-11-17 09:02:38\\\",\\\"type\\\":\\\"2\\\"}]\",\"status\":\"1\"}}","publicParamMap":{"@type":"java.util.LinkedHashMap","qualityParam":"[{\"column\":\"ddmp_data_time\",\"data\":\"2020-11-17 09:02:38\",\"type\":\"2\"}]"}}
+    }
 }