有数上报 功能迁移至 发送MQ

call-back-service/src/main/java/cn/freemud/amp/config/OrderCallBackConfig.java

@@ -35,6 +35,11 @@ public class OrderCallBackConfig {
 
     public static final String INVOICE_QUEUE = "invoice-report-queue";
     public static final String INVOICE_ROUTE_KEY = "invoice-report-queue-routing-key";
+
+    // 腾讯有数上报 & 门店营业开店记录  发送到 ordercenter-order组的 mq中
+    public static final String SEND_YOUSHU_REPORT_QUEUE_ROUTING_KEY="send-youshu-report-queue-routing-key";
+    public static final String SEND_YOUSHU_REPORT_QUEUE="send-youshu-report-queue";
+
     /**
      * 定义基于Fanout 的Exchange。
      * 基于这个代码，也可以非常方便的定义其他的Exchange类型。
@@ -114,4 +119,18 @@ public class OrderCallBackConfig {
     Binding bindingInvoiceQueue(@Qualifier("invoiceQueue") Queue invoiceQueue,@Qualifier("invoiceExchange") Exchange invoiceExchange) {
         return BindingBuilder.bind(invoiceQueue).to(invoiceExchange).with(INVOICE_ROUTE_KEY).noargs();
     }
+
+    /**
+     *  有数上报/ 支付门店 queue 绑定
+     * @return
+     */
+    @Bean(name = "sendWechatReportQueue")
+    public Queue sendWechatReportQueue() {
+        return QueueBuilder.durable(SEND_YOUSHU_REPORT_QUEUE).build();
+    }
+
+    @Bean
+    Binding bindingSendWechatReportQueue(@Qualifier("sendWechatReportQueue") Queue sendWechatReportQueue, @Qualifier("topicExchange") Exchange topicExchange) {
+        return BindingBuilder.bind(sendWechatReportQueue).to(topicExchange).with(SEND_YOUSHU_REPORT_QUEUE_ROUTING_KEY).noargs();
+    }
 }

call-back-service/src/main/java/cn/freemud/amp/service/OrderCallBackMQService.java

@@ -96,7 +96,7 @@ public class OrderCallBackMQService {
         }else{
             revert(body);
         }
-        // 有数订单数据上报
+        // 有数订单数据上报 & 每日下单门店统计
         sendYoushuReportMQ(body);
     }
 
@@ -344,16 +344,20 @@ public class OrderCallBackMQService {
      * @param body
      */
     private void sendYoushuReportMQ(OrderCallBackRequestVo body) {
+        logger.info("send youshu report MQ orderCode:{} queue:{} content:{}", new Object[]{body.getOrderCode(), "send-youshu-report-queue", JSONObject.toJSONString(body.getContent())});
         try {
             if (Objects.isNull(body) || StringUtils.isEmpty(body.getContent())) {
                 return;
             }
-            // 正常变化  订单正向操作
+            // 正常变化  订单正向操作  fisherman 检查下
             if (body.getOperateType() == 1 && "1".equals(body.getMsgType())) {
-
+                Header header = new Header(MQAction.UPDATE.getAction(), "call-back-service-api",
+                        OrderCallBackConfig.SEND_YOUSHU_REPORT_QUEUE_ROUTING_KEY, OrderCallBackConfig.SEND_YOUSHU_REPORT_QUEUE);
+                MQMessage<OrderCallBackRequestVo> message = new MQMessage<>(header, body);
+                mqService.convertAndSend(OrderCallBackConfig.TOPIC_EXCHANGE_NAME, OrderCallBackConfig.SEND_YOUSHU_REPORT_QUEUE_ROUTING_KEY, message);
             }
         }catch (Exception e){
-
+            logger.info("send youshu report MQ ERROR :{}", JSON.toJSONString(e));
         }
     }
 }