删除场景校验场景计算状态

src/main/java/com/fdkankan/mqcontroller/task/TaskService.java

@@ -82,6 +82,9 @@ public class TaskService {
             return;
         }
         log.info("未分配的mq队列数：{}",mqSendLogs.size());
+        for (MqSendLog mqSendLog : mqSendLogs) {
+            redisUtil.set("mq-wait:queue:num:"+mqSendLog.getNum(),mqSendLog.getNum(),60);
+        }
 
         //设置分配队列
         HashSet<String> numList  = new HashSet<>();
@@ -137,6 +140,10 @@ public class TaskService {
                 checkOpenEcs(mqQueueConfig,msgList);
             }
             sendRabbitMq(msgList,mqMsg.getConsumers() - mqMsg.getMessages_unacknowledged() - mqMsg.getMessages_ready(),mqQueueConfig.getQueueName());
+
+            for (MqSendLog mqSendLog : mqSendLogs) {
+                redisUtil.del("mq-wait:queue:num:"+mqSendLog.getNum());
+            }
         }
 
     }