Merge remote-tracking branch 'origin/dev' into dev

liquidnet-bus-common/liquidnet-common-mq/src/main/java/com/liquidnet/common/mq/constant/MQConst.java

@@ -46,6 +46,16 @@ public class MQConst {
     public static final String ROUTING_KEY_SQL_ORDER_PAY = "order.pay";
     public static final String QUEUES_SQL_ORDER_PAY = "queue.sql.order.pay";
 
+    //订单申请退款
+    public static final String EXCHANGES_LIQUIDNET_SQL_ORDER_REFUND = "liquidnet.sql.order.refund";
+    public static final String ROUTING_KEY_SQL_ORDER_REFUND = "order.refund";
+    public static final String QUEUES_SQL_ORDER_REFUND = "queue.sql.order.refund";
+
+    //订单申请撤回
+    public static final String EXCHANGES_LIQUIDNET_SQL_ORDER_WITHDRAW = "liquidnet.sql.order.withdraw";
+    public static final String ROUTING_KEY_SQL_ORDER_WITHDRAW = "order.withdraw";
+    public static final String QUEUES_SQL_ORDER_WITHDRAW = "queue.sql.order.withdraw";
+
     /* -------------------------------------------------------- */
 
     // 验票更新

liquidnet-bus-service/liquidnet-service-consumer/src/main/java/com/liquidnet/service/consumer/service/processor/ConsumerProcessor.java

@@ -445,4 +445,88 @@ public class ConsumerProcessor {
         log.info("===   CONSUMER_PERFORMANCE_LACK   ===");
         this.consumerSqlDaoHandler(msg, channel);
     }
+
+    // 申请退款
+    @RabbitListener(bindings = @QueueBinding(
+            exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_REFUND), key = MQConst.ROUTING_KEY_SQL_ORDER_REFUND,
+            value = @Queue(MQConst.QUEUES_SQL_ORDER_REFUND)
+    ))
+    public void consumerOrderRefund(Message msg, Channel channel) {
+        log.info("===   CONSUMER_ORDER_REFUND   ===");
+        this.consumerSqlDaoHandler(msg, channel);
+    }
+    @RabbitListener(bindings = @QueueBinding(
+            exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_REFUND), key = MQConst.ROUTING_KEY_SQL_ORDER_REFUND,
+            value = @Queue(MQConst.QUEUES_SQL_ORDER_REFUND)
+    ))
+    public void consumerOrderRefund1(Message msg, Channel channel) {
+        log.info("===   CONSUMER_ORDER_REFUND   ===");
+        this.consumerSqlDaoHandler(msg, channel);
+    }
+    @RabbitListener(bindings = @QueueBinding(
+            exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_REFUND), key = MQConst.ROUTING_KEY_SQL_ORDER_REFUND,
+            value = @Queue(MQConst.QUEUES_SQL_ORDER_REFUND)
+    ))
+    public void consumerOrderRefund2(Message msg, Channel channel) {
+        log.info("===   CONSUMER_ORDER_REFUND   ===");
+        this.consumerSqlDaoHandler(msg, channel);
+    }
+    @RabbitListener(bindings = @QueueBinding(
+            exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_REFUND), key = MQConst.ROUTING_KEY_SQL_ORDER_REFUND,
+            value = @Queue(MQConst.QUEUES_SQL_ORDER_REFUND)
+    ))
+    public void consumerOrderRefund3(Message msg, Channel channel) {
+        log.info("===   CONSUMER_ORDER_REFUND   ===");
+        this.consumerSqlDaoHandler(msg, channel);
+    }
+    @RabbitListener(bindings = @QueueBinding(
+            exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_REFUND), key = MQConst.ROUTING_KEY_SQL_ORDER_REFUND,
+            value = @Queue(MQConst.QUEUES_SQL_ORDER_REFUND)
+    ))
+    public void consumerOrderRefund4(Message msg, Channel channel) {
+        log.info("===   CONSUMER_ORDER_REFUND   ===");
+        this.consumerSqlDaoHandler(msg, channel);
+    }
+
+    // 申请退款撤回
+    @RabbitListener(bindings = @QueueBinding(
+            exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_WITHDRAW), key = MQConst.ROUTING_KEY_SQL_ORDER_WITHDRAW,
+            value = @Queue(MQConst.QUEUES_SQL_ORDER_WITHDRAW)
+    ))
+    public void consumerOrderRefundWithDraw(Message msg, Channel channel) {
+        log.info("===   CONSUMER_ORDER_WITHDRAW   ===");
+        this.consumerSqlDaoHandler(msg, channel);
+    }
+    @RabbitListener(bindings = @QueueBinding(
+            exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_WITHDRAW), key = MQConst.ROUTING_KEY_SQL_ORDER_WITHDRAW,
+            value = @Queue(MQConst.QUEUES_SQL_ORDER_WITHDRAW)
+    ))
+    public void consumerOrderRefundWithDraw1(Message msg, Channel channel) {
+        log.info("===   CONSUMER_ORDER_WITHDRAW   ===");
+        this.consumerSqlDaoHandler(msg, channel);
+    }
+    @RabbitListener(bindings = @QueueBinding(
+            exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_WITHDRAW), key = MQConst.ROUTING_KEY_SQL_ORDER_WITHDRAW,
+            value = @Queue(MQConst.QUEUES_SQL_ORDER_WITHDRAW)
+    ))
+    public void consumerOrderRefundWithDraw2(Message msg, Channel channel) {
+        log.info("===   CONSUMER_ORDER_WITHDRAW   ===");
+        this.consumerSqlDaoHandler(msg, channel);
+    }
+    @RabbitListener(bindings = @QueueBinding(
+            exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_WITHDRAW), key = MQConst.ROUTING_KEY_SQL_ORDER_WITHDRAW,
+            value = @Queue(MQConst.QUEUES_SQL_ORDER_WITHDRAW)
+    ))
+    public void consumerOrderRefundWithDraw3(Message msg, Channel channel) {
+        log.info("===   CONSUMER_ORDER_WITHDRAW   ===");
+        this.consumerSqlDaoHandler(msg, channel);
+    }
+    @RabbitListener(bindings = @QueueBinding(
+            exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_WITHDRAW), key = MQConst.ROUTING_KEY_SQL_ORDER_WITHDRAW,
+            value = @Queue(MQConst.QUEUES_SQL_ORDER_WITHDRAW)
+    ))
+    public void consumerOrderRefundWithDraw4(Message msg, Channel channel) {
+        log.info("===   CONSUMER_ORDER_WITHDRAW   ===");
+        this.consumerSqlDaoHandler(msg, channel);
+    }
 }