优化了绑定的逻辑

jyzb-biz/src/main/java/com/junmp/jyzb/config/rabbitMQ/TopicRabbitConfig.java

@@ -12,6 +12,7 @@ import org.springframework.context.annotation.Configuration;
 import javax.annotation.Resource;
 import java.util.ArrayList;
 import java.util.List;
+import java.util.concurrent.CompletableFuture;
 
 @Configuration
 public class TopicRabbitConfig {
@@ -39,9 +40,15 @@ public class TopicRabbitConfig {
     // Dynamic creation of queues and bindings for each organization and cabinet
     @Bean
     public List<Binding> createQueuesAndBindings(TopicExchange topicExchange) {
-        List<PubOrg> orgList = pubOrgService.list(new LambdaQueryWrapper<PubOrg>().eq(PubOrg::getStatusFlag, 1));
-        List<Cabinet> cabinetList = cabinetService.list();
-        List<Binding> bindings = new ArrayList<>();
+        CompletableFuture<List<PubOrg>> orgListFuture = CompletableFuture.supplyAsync(() ->
+                pubOrgService.list(new LambdaQueryWrapper<PubOrg>().eq(PubOrg::getDelFlag, 1)));
+
+        CompletableFuture<List<Cabinet>> cabinetListFuture = CompletableFuture.supplyAsync(() ->
+                cabinetService.list());
+
+        List<PubOrg> orgList = orgListFuture.join();
+        List<Cabinet> cabinetList = cabinetListFuture.join();
+          List<Binding> bindings = new ArrayList<>();
 
         for (PubOrg org : orgList) {
             // Create a unique queue for each organization