|
|
@@ -364,9 +364,9 @@ public class ToolbarController {
|
|
|
//重发更新节点日志
|
|
|
|
|
|
//后台缓存处理
|
|
|
- List object = msgUtil.redis_get_list(YunjianConstant.YUNJIAN_SCHEDULE_LIST);
|
|
|
- List scheduleList = (object!=null)?msgUtil.redis_get_list(YunjianConstant.YUNJIAN_SCHEDULE_LIST): org.apache.commons.compress.utils.Lists.newArrayList();
|
|
|
- if(scheduleList.contains(taskNodeId)){
|
|
|
+// List object = msgUtil.redis_get_list(YunjianConstant.YUNJIAN_SCHEDULE_LIST);
|
|
|
+// List scheduleList = (object!=null)?msgUtil.redis_get_list(YunjianConstant.YUNJIAN_SCHEDULE_LIST): org.apache.commons.compress.utils.Lists.newArrayList();
|
|
|
+// if(scheduleList.contains(taskNodeId)){
|
|
|
String repeatKey = taskNode.getId().toString() + taskNode.getTaskId().toString();
|
|
|
String cacheUid = msgUtil.redis_get(repeatKey) == null ? "" : msgUtil.redis_get(repeatKey).toString();
|
|
|
if(StringUtils.isNotEmpty(cacheUid)){
|
|
|
@@ -374,7 +374,7 @@ public class ToolbarController {
|
|
|
}
|
|
|
msgUtil.redis_fuzzy_del(YunjianConstant.YUNJIAN_SCHEDULE_LIST, taskNodeId);
|
|
|
msgUtil.createWarnLog(taskNodeId +"节点执行错误或重复超时已重置", "DataException");
|
|
|
- }
|
|
|
+// }
|
|
|
return success();
|
|
|
}
|
|
|
|