|
@@ -2104,6 +2104,14 @@ public class TaskNodeServiceImpl extends SuperServiceImpl<TaskNodeMapper, TaskNo
|
|
|
*/
|
|
|
public void checkPriorityTask(Storge jqrStorge,boolean zcwFalg){
|
|
|
log.warn("进入优先级判断");
|
|
|
+
|
|
|
+ //临时
|
|
|
+ Object priorityLock = msgUtil.redis_get("PRIORITY_LOCK");
|
|
|
+ if(priorityLock !=null && "2".equals(priorityLock.toString())){
|
|
|
+ log.warn("不进行优先级判断");
|
|
|
+ return;
|
|
|
+ }
|
|
|
+
|
|
|
Object priorityList = msgUtil.redis_get("PRIORITY_LIST");
|
|
|
|
|
|
if(Objects.isNull(priorityList) || StringUtil.isEmpty(priorityList.toString())) return;
|