移除作废的mq生产者

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

@@ -36,12 +36,6 @@ 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中
-    @Deprecated
-    public static final String SEND_YOUSHU_REPORT_QUEUE_ROUTING_KEY = "send-youshu-report-queue-routing-key";
-    @Deprecated
-    public static final String SEND_YOUSHU_REPORT_QUEUE = "send-youshu-report-queue";
-
 
     // task-center-order-consumer服务 订单状态处理中心queue
     public static final String ORDER_STATUS_PROCESS_CENTER_QUEUE_ROUTING_KEY = "order_status_process_center_queue-routing-key";
@@ -134,21 +128,6 @@ public class OrderCallBackConfig {
         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();
-    }
-
 
     /**
      * 有数上报/ 支付门店 queue 绑定

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

@@ -63,9 +63,6 @@ public class OrderCallBackMQService {
     @Value("${saas.order.invoice.report.partnerIds}")
     private String invoicePartnerIds;
 
-    @Value("${queue-grace-offline:}")
-    private String queueGraceOffline;
-
 
     private static final String backOrdersChangeOrderStatusConsumerQueue = "program.backorders_change_order_status_consumer_queue";
     private static final String backOrdersNotifyActivityExchange = "program.backorders_notify_activity_exchange";
@@ -105,10 +102,6 @@ public class OrderCallBackMQService {
             revert(body);
         }
 
-        if (!Objects.equals(queueGraceOffline, "1")) {
-            // 有数订单数据上报 & 每日下单门店统计
-            sendYoushuReportMQ(body);
-        }
         //  task-center-order-consumer服务 订单状态处理中心queue 优化原有相同queue代码
         this.sendOrderStatusProcessCenterMQ(body);
 
@@ -382,30 +375,6 @@ public class OrderCallBackMQService {
     }
 
 
-    /**
-     * 有数上报MQ
-     *
-     * @param body
-     */
-    @Deprecated
-    private void sendYoushuReportMQ(OrderCallBackRequestVo body) {
-        try {
-            if (Objects.isNull(body) || StringUtils.isEmpty(body.getContent())) {
-                return;
-            }
-            ApiLog.infoMessage("send sendYoushuReportMQ start orderCode:{} ", body.getOrderCode());
-            // 正常变化  订单正向操作  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);
-                ApiLog.infoMessage("send sendYoushuReportMQ end orderCode:{}", body.getOrderCode());
-            }
-        } catch (Exception e) {
-            ApiLog.infoMessage("send sendYoushuReportMQ Error orderCode:{} e:{}", body.getOrderCode(), ExceptionUtils.getFullStackTrace(e));
-        }
-    }
 
     /**
      * 订单状态公共处理中心 queue