|
@@ -606,7 +606,12 @@ public class MsgUtil implements ApplicationContextAware {
|
|
|
*/
|
|
|
public void addPriorityList(TaskNode taskNode){
|
|
|
logger.warn("进入优先级集合判断");
|
|
|
-
|
|
|
+ //临时
|
|
|
+ Object priorityLock = msgUtil.redis_get("PRIORITY_LOCK");
|
|
|
+ if(priorityLock !=null && "2".equals(priorityLock.toString())){
|
|
|
+ logger.warn("不添加优先级集合");
|
|
|
+ return;
|
|
|
+ }
|
|
|
List<TaskNodePriorityDto> taskNodePriorityDtoList = null;
|
|
|
Object priorityList = msgUtil.redis_get("PRIORITY_LIST");
|
|
|
if(Objects.isNull(priorityList) || StringUtil.isEmpty(priorityList.toString())){
|