项目初始化

datax-modules/data-market-service-parent/data-market-service-mapping/src/main/java/cn/datax/service/data/market/mapping/config/RabbitMqListenerConfig.java

@@ -2,7 +2,9 @@ package cn.datax.service.data.market.mapping.config;
 
 import cn.datax.common.rabbitmq.config.RabbitMqConstant;
 import cn.datax.common.utils.ThrowableUtil;
-import cn.datax.service.data.market.mapping.service.QueueHandlerService;
+import cn.datax.service.data.market.api.entity.DataApiEntity;
+import cn.datax.service.data.market.api.feign.DataApiServiceFeign;
+import cn.datax.service.data.market.mapping.handler.MappingHandlerMapping;
 import com.rabbitmq.client.Channel;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.amqp.core.Message;
@@ -19,12 +21,16 @@ import java.util.Map;
 @Configuration
 public class RabbitMqListenerConfig {
 
-    @Autowired
-    private QueueHandlerService queueHandlerService;
-
     private static String HANDLER_RELEASE = "1";
     private static String HANDLER_CANCEL = "2";
 
+    @Autowired
+    private DataApiServiceFeign dataApiServiceFeign;
+
+    @Autowired
+    private MappingHandlerMapping mappingHandlerMapping;
+
+
     /**
      * api发布与撤销
      * @param map type 1:发布 2:撤销
@@ -40,10 +46,13 @@ public class RabbitMqListenerConfig {
             String id = (String) map.get("id");
             String type = (String) map.get("type");
             log.info("fanoutQueueRelease接收到了：{},{}", id, type);
-            if (HANDLER_RELEASE.equals(type)) {
-                queueHandlerService.handlerRelease(id);
-            } else if (HANDLER_CANCEL.equals(type)) {
-                queueHandlerService.handlerCancel(id);
+            DataApiEntity dataApiEntity = dataApiServiceFeign.getDataApiById(id);
+            if (dataApiEntity != null) {
+                if (HANDLER_RELEASE.equals(type)) {
+                    mappingHandlerMapping.registerMapping(dataApiEntity);
+                } else if (HANDLER_CANCEL.equals(type)) {
+                    mappingHandlerMapping.unregisterMapping(dataApiEntity);
+                }
             }
             // 手动确认
             channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);