状态通知接口

lb-app/src/main/java/com/ydd/app/consumer/DelayPushStoreStatusListener.java

@@ -36,13 +36,11 @@ import java.util.concurrent.TimeUnit;
 @RequiredArgsConstructor(onConstructor_ = @Autowired)
 public class DelayPushStoreStatusListener {
 
-    private IAppInfoService iAppInfoService;
-
-    public RedisTemplate redisTemplate;
+    private final IAppInfoService iAppInfoService;
 
     private final RedisCache redisCache;
 
-    @RabbitListener(queues = RabbitConstant.QUEUE_DELAY_PUSH_STORE_STATUS)
+    @RabbitListener(queues = RabbitConstant.QUEUE_DELAY_OPEN_STATUS_NOTIFY)
     @RabbitHandler
     public void pushStoreStatusDelayListener(Object msg) {
         log.info("收到延迟推送状态的消息：{}", msg);

lb-app/src/main/java/com/ydd/app/service/impl/OpenApiNotifyServiceImpl.java

@@ -30,7 +30,7 @@ public class OpenApiNotifyServiceImpl implements OpenApiNotifyService {
         for (int i = 0; i < durations.size(); i++) {
             // 记录推送次数, 超过规定总次数后做处理: 入库或者其他
             storeStatusNotifyVo.setNotifyCount(i);
-            rabbitSender.sendDelay(storeStatusNotifyVo, RabbitConstant.QUEUE_DELAY_PUSH_STORE_STATUS_ROUTING_KEY, durations.get(i) * 1000);
+            rabbitSender.sendDelay(storeStatusNotifyVo, RabbitConstant.QUEUE_DELAY_OPEN_STATUS_NOTIFY_ROUTING_KEY, durations.get(i) * 1000);
         }
     }
 

lb-common/src/main/java/com/ydd/common/constant/RabbitConstant.java

@@ -8,22 +8,13 @@ package com.ydd.common.constant;
 public interface RabbitConstant {
 
     /**
-     * 推送门店状态延迟队列
+     * 开放接口 状态推送延迟队列
      */
-    String QUEUE_DELAY_PUSH_STORE_STATUS = "queue.pushStoreStatus.delay";
-    /**
-     * 推送订单状态延迟队列
-     */
-    String QUEUE_DELAY_PUSH_ORDER_STATUS = "queue.pushOrderStatus.delay";
-
-    /**
-     * 推送门店状态路由
-     */
-    String QUEUE_DELAY_PUSH_STORE_STATUS_ROUTING_KEY = "queue.pushStoreStatus";
+    String QUEUE_DELAY_OPEN_STATUS_NOTIFY = "queue.openStatusNotify.delay";
 
     /**
-     * 推送订单状态路由
+     * 开放接口 状态推送路由
      */
-    String QUEUE_DELAY_PUSH_ORDER_STATUS_ROUTING_KEY = "queue.pushOrderStatus";
+    String QUEUE_DELAY_OPEN_STATUS_NOTIFY_ROUTING_KEY = "queue.openStatusNotify";
 
 }

lb-module/src/main/java/com/ydd/module/config/RabbitConfig.java

@@ -34,15 +34,11 @@ public class RabbitConfig {
         return new Queue(RabbitConfig.QUEUE_DELAY_WAIMAI);
     }
 
-    @Bean(RabbitConstant.QUEUE_DELAY_PUSH_STORE_STATUS)
-    public Queue queuePushStoreStatusDelayMessage() {
-        return new Queue(RabbitConstant.QUEUE_DELAY_PUSH_STORE_STATUS);
+    @Bean(RabbitConstant.QUEUE_DELAY_OPEN_STATUS_NOTIFY)
+    public Queue queueOpenStatusNotifyDelayMessage() {
+        return new Queue(RabbitConstant.QUEUE_DELAY_OPEN_STATUS_NOTIFY);
     }
 
-    @Bean(RabbitConstant.QUEUE_DELAY_PUSH_ORDER_STATUS)
-    public Queue queuePushOrderStatusDelayMessage() {
-        return new Queue(RabbitConstant.QUEUE_DELAY_PUSH_ORDER_STATUS);
-    }
     //创建队列
     @Bean("topic.cancelOrder")
     public Queue cancelOrder() {
@@ -100,13 +96,8 @@ public class RabbitConfig {
     }
 
     @Bean
-    Binding bindingExchangePushStoreStatusDelayMessage(@Qualifier(RabbitConstant.QUEUE_DELAY_PUSH_STORE_STATUS) Queue queue, @Qualifier("delay_exchange")CustomExchange exchange) {
-        return BindingBuilder.bind(queue).to(exchange).with(RabbitConstant.QUEUE_DELAY_PUSH_STORE_STATUS_ROUTING_KEY).noargs();
-    }
-
-    @Bean
-    Binding bindingExchangePushOrderStatusDelayMessage(@Qualifier(RabbitConstant.QUEUE_DELAY_PUSH_ORDER_STATUS) Queue queue, @Qualifier("delay_exchange")CustomExchange exchange) {
-        return BindingBuilder.bind(queue).to(exchange).with(RabbitConstant.QUEUE_DELAY_PUSH_ORDER_STATUS_ROUTING_KEY).noargs();
+    Binding bindingExchangeOpenStatusNotifyDelayMessage(@Qualifier(RabbitConstant.QUEUE_DELAY_OPEN_STATUS_NOTIFY) Queue queue, @Qualifier("delay_exchange")CustomExchange exchange) {
+        return BindingBuilder.bind(queue).to(exchange).with(RabbitConstant.QUEUE_DELAY_OPEN_STATUS_NOTIFY_ROUTING_KEY).noargs();
     }
 
 }