|
@@ -1270,7 +1270,7 @@ public class TaskNodeServiceImpl extends SuperServiceImpl<TaskNodeMapper, TaskNo
|
|
|
String taskNodeId = bean.getTaskNodeId() == null ? "" : bean.getTaskNodeId().toString();
|
|
|
|
|
|
//接口不让传多余参数,只能从缓存传
|
|
|
- String jsonParam = msgUtil.redis_get(DemoCacheKey.YUNJIAN_CAMP + "_" + YunjianConstant.YUNJIAN_JXS + taskNodeId)==null?"":msgUtil.redis_get(DemoCacheKey.YUNJIAN_CAMP + "_" + YunjianConstant.YUNJIAN_JXS + taskNodeId).toString();
|
|
|
+ String jsonParam = msgUtil.redis_get(YunjianConstant.YUNJIAN_CALLBACK_PARAM+"_" + taskNodeId)==null?"":msgUtil.redis_get(YunjianConstant.YUNJIAN_CALLBACK_PARAM+"_" + taskNodeId).toString();
|
|
|
|
|
|
|
|
|
Object taskInfoObject = msgUtil.redis_get(taskNodeId);
|
|
@@ -1337,8 +1337,8 @@ public class TaskNodeServiceImpl extends SuperServiceImpl<TaskNodeMapper, TaskNo
|
|
|
|
|
|
updateBizStatus(taskNode, task, taskNodeList, lg, callBackJson, r);
|
|
|
|
|
|
- //websocket推送
|
|
|
- msgUtil.pushTask(task);
|
|
|
+ //websocket推送TODO临时注释
|
|
|
+// msgUtil.pushTask(task);
|
|
|
|
|
|
//推送到消息队列
|
|
|
msgUtil.pushToNextMq(taskNode, task, taskNodeList, n, callBackJson);
|