超时支付申请退款 mq

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

@@ -56,6 +56,11 @@ public class MQConst {
     public static final String ROUTING_KEY_SQL_ORDER_WITHDRAW = "order.withdraw";
     public static final String QUEUES_SQL_ORDER_WITHDRAW = "queue.sql.order.withdraw";
 
+    //超时支付申请退款
+    public static final String EXCHANGES_LIQUIDNET_SQL_ORDER_OVERTIME_REFUND = "liquidnet.sql.order.overtimeRefund";
+    public static final String ROUTING_KEY_SQL_ORDER_OVERTIME_REFUND = "order.overtimeRefund";
+    public static final String QUEUES_SQL_ORDER_OVERTIME_REFUND = "queue.sql.order.overtimeRefund";
+
     /* -------------------------------------------------------- */
 
     // 验票更新

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

@@ -529,4 +529,14 @@ public class ConsumerProcessor {
         log.info("===   CONSUMER_ORDER_WITHDRAW   ===");
         this.consumerSqlDaoHandler(msg, channel);
     }
+
+    // 超时支付申请退款
+    @RabbitListener(bindings = @QueueBinding(
+            exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_OVERTIME_REFUND), key = MQConst.ROUTING_KEY_SQL_ORDER_OVERTIME_REFUND,
+            value = @Queue(MQConst.QUEUES_SQL_ORDER_OVERTIME_REFUND)
+    ))
+    public void consumerOrderOvertimeRefund(Message msg, Channel channel) {
+        log.info("===   CONSUMER_ORDER_OVERTIME_REFUND   ===");
+        this.consumerSqlDaoHandler(msg, channel);
+    }
 }

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/java/com/liquidnet/service/kylin/service/impl/KylinRefundsStatusServiceImpl.java

@@ -102,8 +102,12 @@ public class KylinRefundsStatusServiceImpl {
         kylinOrderTicketEntitiesVo.setIsPayment(KylinTableStatusConst.ENTITIES_IS_PAYMENT2);
         kylinOrderTicketEntitiesVo.setUpdatedAt(nowTimeStr);
         BasicDBObject entitiesObject = new BasicDBObject("$set", JSON.parse(JsonUtils.toJson(kylinOrderTicketEntitiesVo)));
-        for (String v : ticketEntityIds) {
 
+        LinkedList<Object[]> sqlsDataB = new LinkedList<>();
+        for (String v : ticketEntityIds) {
+            sqlsDataB.add(new Object[]{
+                    entitiesTable.getIsPayment(), entitiesTable.getUpdatedAt(), v
+            });
             /*kylinOrderTicketEntitiesMapper.update(entitiesTable, new UpdateWrapper<KylinOrderTicketEntities>()
                     .eq("order_ticket_entities_id", v));*/
 
@@ -149,12 +153,17 @@ public class KylinRefundsStatusServiceImpl {
         KylinOrderRefundEntities kylinOrderRefundEntities = new KylinOrderRefundEntities();
         kylinOrderRefundEntities.setOrderRefundsId(orderRefundsId);
         kylinOrderRefundEntities.setCreatedAt(LocalDateTime.now());
+        LinkedList<Object[]> sqlsDataD = new LinkedList<>();
         for (int i = 0; i <= ticketEntityIds.size() - 1; i++) {
             String orderRefundsEntitiesId = IDGenerator.nextSnowId();
             kylinOrderRefundEntities.setOrderRefundsEntitiesId(orderRefundsEntitiesId);
             kylinOrderRefundEntities.setRefundPrice(BigDecimal.valueOf(entitiesPrice.get(i)));
             kylinOrderRefundEntities.setOrderTicketEntitiesId(ticketEntityIds.get(i));
 
+            sqlsDataD.add(new Object[]{
+                    kylinOrderRefundEntities.getOrderRefundsEntitiesId(), kylinOrderRefundEntities.getOrderRefundsId(), kylinOrderRefundEntities.getRefundPrice(),
+                    kylinOrderRefundEntities.getOrderTicketEntitiesId(), kylinOrderRefundEntities.getCreatedAt()
+            });
             /*int rowsR = kylinOrderRefundsEntitiesMapper.insert(kylinOrderRefundEntities);*/
 
             KylinOrderRefundEntitiesVo orderRefundEntitiesVo = new KylinOrderRefundEntitiesVo();
@@ -162,6 +171,31 @@ public class KylinRefundsStatusServiceImpl {
             mongoTemplate.insert(orderRefundEntitiesVo,KylinOrderRefundEntitiesVo.class.getSimpleName());
         }
 
+        //mq更改数据库
+        LinkedList<String> sqls = new LinkedList<>();
+        LinkedList<Object[]> sqlsDataA = new LinkedList<>();
+        LinkedList<Object[]> sqlsDataC = new LinkedList<>();
+
+        sqls.add(SqlMapping.get("kylin_order_ticket_status.overtimeRefund"));
+        sqls.add(SqlMapping.get("kylin_order_ticket_entities.overtimeRefund"));
+        sqls.add(SqlMapping.get("kylin_order_refund.overtimeRefund"));
+        sqls.add(SqlMapping.get("kylin_order_refund_entities.overtimeRefund"));
+
+        sqlsDataA.add(new Object[]{
+                orderStatusTable.getStatus(), orderStatusTable.getUpdatedAt(), orderInfo.getOrderTicketsId()
+        });
+
+        sqlsDataC.add(new Object[]{
+                kylinOrderRefunds.getOrderRefundsId(), kylinOrderRefunds.getOrderTicketsId(), kylinOrderRefunds.getOrderRefundCode(),
+                kylinOrderRefunds.getPrice(), kylinOrderRefunds.getPriceExpress(), kylinOrderRefunds.getStatus(),
+                kylinOrderRefunds.getType(), kylinOrderRefunds.getApplicantId(), kylinOrderRefunds.getApplicantName(),
+                kylinOrderRefunds.getApplicantAt(), kylinOrderRefunds.getReason(),
+                kylinOrderRefunds.getRefundCate(), kylinOrderRefunds.getCreatedAt()
+        });
+
+        rabbitTemplate.convertAndSend(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_OVERTIME_REFUND, MQConst.ROUTING_KEY_SQL_ORDER_OVERTIME_REFUND,
+                SqlMapping.gets(sqls, sqlsDataA, sqlsDataB, sqlsDataC, sqlsDataD));
+
         return true;
     }
 

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/resources/sqlmap.properties

@@ -44,5 +44,11 @@ kylin_order_ticket_status.withDraw=UPDATE kylin_order_ticket_status SET status =
 kylin_order_ticket_entities.withDraw=UPDATE kylin_order_ticket_entities SET is_payment = ?,updated_at = ?,sys_damai = 1 WHERE order_id = ? and (updated_at <= ? or created_at = ?)
 kylin_order_refund.withDraw=UPDATE kylin_order_refunds SET status = ? ,updated_at = ?  WHERE order_refunds_id = ?
 
+# ------------------------超时支付申请退款----------------------------
+kylin_order_ticket_status.overtimeRefund=UPDATE kylin_order_ticket_status SET status = ? ,updated_at = ?  WHERE order_id = ?
+kylin_order_ticket_entities.overtimeRefund=UPDATE kylin_order_ticket_entities SET is_payment = ? ,updated_at = ?  WHERE order_ticket_entities_id = ?
+kylin_order_refund.overtimeRefund=INSERT INTO kylin_order_refunds (order_refunds_id,order_tickets_id,order_refund_code,price,price_express,status,type,applicant_id,applicant_name,applicant_at,reason,refund_cate,created_at) VALUES(?,?,?,?,?,?,?,?,?,?,?,?,?)
+kylin_order_refund_entities.overtimeRefund=INSERT INTO kylin_order_refund_entities (order_refunds_entities_id,order_refunds_id,refund_price,order_ticket_entities_id,created_at) VALUES(?,?,?,?,?)
+