Commit c9974922 by huangfusuper

使用工作流名称开启工作流

parent c8f9f543
...@@ -90,9 +90,9 @@ public class JavaNodeExecutorTask implements TimerTask { ...@@ -90,9 +90,9 @@ public class JavaNodeExecutorTask implements TimerTask {
TreeSet<String> gatewayConf = getRegConfig.getGatewayConf(); TreeSet<String> gatewayConf = getRegConfig.getGatewayConf();
List<String> callUrlList = gatewayConf.stream().map(callbackIp -> { List<String> callUrlList = gatewayConf.stream().map(callbackIp -> {
if("2".equals(hasRelatedFlow)){ if("2".equals(hasRelatedFlow)){
return String.format("%s%s%s", HTTP_PRE, callbackIp, HTTP_SUFFIX);
}else{
return String.format("%s%s%s", HTTP_PRE, callbackIp, HTTP_SUFFIX_FLOW); return String.format("%s%s%s", HTTP_PRE, callbackIp, HTTP_SUFFIX_FLOW);
}else{
return String.format("%s%s%s", HTTP_PRE, callbackIp, HTTP_SUFFIX);
} }
}).collect(Collectors.toList()); }).collect(Collectors.toList());
......
...@@ -60,9 +60,9 @@ public class JavaTaskJobTask implements TimerTask { ...@@ -60,9 +60,9 @@ public class JavaTaskJobTask implements TimerTask {
TreeSet<String> gatewayConf = getRegConfig.getGatewayConf(); TreeSet<String> gatewayConf = getRegConfig.getGatewayConf();
List<String> callUrlList = gatewayConf.stream().map(callbackIp -> { List<String> callUrlList = gatewayConf.stream().map(callbackIp -> {
if("2".equals(hasRelatedFlow)){ if("2".equals(hasRelatedFlow)){
return String.format("%s%s%s", HTTP_PRE, callbackIp, HTTP_SUFFIX);
}else{
return String.format("%s%s%s", HTTP_PRE, callbackIp, HTTP_SUFFIX_FLOW); return String.format("%s%s%s", HTTP_PRE, callbackIp, HTTP_SUFFIX_FLOW);
}else{
return String.format("%s%s%s", HTTP_PRE, callbackIp, HTTP_SUFFIX);
} }
}).collect(Collectors.toList()); }).collect(Collectors.toList());
......
...@@ -29,7 +29,7 @@ public class JavaJobConfDTO implements Serializable { ...@@ -29,7 +29,7 @@ public class JavaJobConfDTO implements Serializable {
*/ */
private TimeUnit timeUnit; private TimeUnit timeUnit;
/** /**
* 是否关联工作流 关联1 不关联 2 * 是否关联工作流 1 不追加 2 追加
*/ */
private String hasRelatedFlow = "2"; private String hasRelatedFlow;
} }
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