|
@@ -1562,9 +1562,6 @@ public class TaskNodeServiceImpl extends SuperServiceImpl<TaskNodeMapper, TaskNo
|
|
return R.fail(-5,"节点"+bean.getTaskNodeId()+"已有回调");
|
|
return R.fail(-5,"节点"+bean.getTaskNodeId()+"已有回调");
|
|
}
|
|
}
|
|
|
|
|
|
- //把当前id存放入缓存
|
|
|
|
- msgUtil.redis_set(String.valueOf(repeatKey), String.valueOf(bean.getTaskNodeId()), 1, TimeUnit.HOURS);
|
|
|
|
-
|
|
|
|
// begin add by yejian on 20220503 for yj on 如果排产中先等待排产完成后继续执行(防止重复发送回调)
|
|
// begin add by yejian on 20220503 for yj on 如果排产中先等待排产完成后继续执行(防止重复发送回调)
|
|
while (null != msgUtil.redis_get(YunjianConstant.YUNJIAN_SHEDULE_FLAG)) {
|
|
while (null != msgUtil.redis_get(YunjianConstant.YUNJIAN_SHEDULE_FLAG)) {
|
|
try {
|
|
try {
|
|
@@ -1575,6 +1572,9 @@ public class TaskNodeServiceImpl extends SuperServiceImpl<TaskNodeMapper, TaskNo
|
|
}
|
|
}
|
|
// end add by yejian on 20220503 for yj on 如果排产中先等待排产完成后继续执行
|
|
// end add by yejian on 20220503 for yj on 如果排产中先等待排产完成后继续执行
|
|
|
|
|
|
|
|
+ //把当前id存放入缓存,为后续防止重复回调
|
|
|
|
+ msgUtil.redis_set(String.valueOf(repeatKey), String.valueOf(bean.getTaskNodeId()), 1, TimeUnit.HOURS);
|
|
|
|
+
|
|
|
|
|
|
//接口不让传多余参数,只能从缓存传
|
|
//接口不让传多余参数,只能从缓存传
|
|
String jsonParam = msgUtil.redis_get(YunjianConstant.YUNJIAN_CALLBACK_PARAM + "_" + taskNodeId) == null ? ""
|
|
String jsonParam = msgUtil.redis_get(YunjianConstant.YUNJIAN_CALLBACK_PARAM + "_" + taskNodeId) == null ? ""
|