全景看看

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

@@ -72,6 +72,8 @@ public class TaskService {
 
         List<MqSendLog> fdkkList = mqSendLogs.stream().filter(e -> "4dkk".equals(e.getType())).collect(Collectors.toList());
         List<MqSendLog> panoList = mqSendLogs.stream().filter(e -> "pano".equals(e.getType())).collect(Collectors.toList());
+        List<MqQueueConfig> queueConfigList = queueConfigService.list();
+        rabbitMqService.getMqMsgMap(queueConfigList);
         if(!fdkkList.isEmpty()){
             sendMqByType(fdkkList,"4dkk");
         }
@@ -101,8 +103,8 @@ public class TaskService {
             mqSendLog.setConfigId(configId);
             numList.add(mqSendLog.getNum());
         }
+
         List<MqQueueConfig> queueConfigList = queueConfigService.getByType(type);
-        rabbitMqService.getMqMsgMap(queueConfigList);
 
         for (MqQueueConfig config : queueConfigList) {
             List<MqSendLog> msgList = mqSendLogs.stream().filter(e -> e.getConfigId().equals(config.getId())).collect(Collectors.toList());