1

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

@@ -86,14 +86,14 @@ public class TaskService {
 
     private void sendMqByType(List<MqSendLog> mqSendLogs,String type){
         //设置分配队列
-        HashSet<String> numList  = new HashSet<>();
+        HashSet<String> contentList  = new HashSet<>();
         for (MqSendLog mqSendLog : mqSendLogs) {
             if(StringUtils.isBlank(mqSendLog.getContent())){
                 mqSendLogService.updateStatus(mqSendLog.getId(),2,null);
                 continue;
             }
             Integer configId = scenePlusService.getQueueConfig(mqSendLog);
-            if(numList.contains(mqSendLog.getNum())){
+            if(contentList.contains(mqSendLog.getContent())){
                 mqSendLogService.updateStatus(mqSendLog.getId(),2,null);
                 continue;
             }
@@ -102,7 +102,7 @@ public class TaskService {
                 continue;
             }
             mqSendLog.setConfigId(configId);
-            numList.add(mqSendLog.getNum());
+            contentList.add(mqSendLog.getContent());
         }
 
         List<MqQueueConfig> queueConfigList = queueConfigService.getByType(type);