修正立即运行报错

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

@@ -19,6 +19,7 @@ import com.byit.util.GetRegConfig;
 import com.byit.util.SpringUtil;
 import io.netty.util.Timeout;
 import io.netty.util.TimerTask;
+import org.apache.commons.lang3.StringUtils;
 
 import java.util.Date;
 import java.util.List;
@@ -52,14 +53,20 @@ public class JavaTaskJobTask implements TimerTask {
         PluginRpcRequestPacket request = new PluginRpcRequestPacket();
         String param = javaTask.getParam();
         String personalise = javaTask.getPersonalise();
+        String hasRelatedFlow = "1";
         JavaJobConfDTO javaJobConfDTO = JSON.parseObject(personalise, JavaJobConfDTO.class);
-        String hasRelatedFlow = javaJobConfDTO.getHasRelatedFlow();
+        if(javaJobConfDTO != null && StringUtils.isNoneBlank(javaJobConfDTO.getHasRelatedFlow())){
+            hasRelatedFlow = javaJobConfDTO.getHasRelatedFlow();
+        }
+
+
         //保存到日志
         Integer logId = saveLog(javaTask);
         GetRegConfig getRegConfig = SpringUtil.getBean(GetRegConfig.class);
         TreeSet<String> gatewayConf = getRegConfig.getGatewayConf();
+        String finalHasRelatedFlow = hasRelatedFlow;
         List<String> callUrlList = gatewayConf.stream().map(callbackIp -> {
-            if("2".equals(hasRelatedFlow)){
+            if("2".equals(finalHasRelatedFlow)){
                 return String.format("%s%s%s", HTTP_PRE, callbackIp, HTTP_SUFFIX_FLOW);
             }else{
                 return String.format("%s%s%s", HTTP_PRE, callbackIp, HTTP_SUFFIX);