提交 大麦 同步演出 场次 票

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

@@ -507,11 +507,10 @@ public class KylinOrderTicketsServiceImpl extends ServiceImpl<KylinOrderTicketsM
         orderTicketVo.setCreatedAt(orderTickets.getCreatedAt().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
         mongoTemplate.insert(orderTicketVo, KylinOrderTicketVo.class.getSimpleName());
         // 执行sql
-        String s = SqlMapping.gets(sqls, sqlsDataA, sqlsDataB, sqlsDataC, sqlsDataD);
-        System.out.println("ssss:" + s);
+        String sqlData = SqlMapping.gets(sqls, sqlsDataA, sqlsDataB, sqlsDataC, sqlsDataD);
 
         rabbitTemplate.convertAndSend(MQConst.EXCHANGES_LIQUIDNET_SQL, MQConst.ROUTING_KEY_SQL,
-                s);
+                sqlData);
         return ResponseDto.success(payResultVo);
     }
 
@@ -642,7 +641,6 @@ public class KylinOrderTicketsServiceImpl extends ServiceImpl<KylinOrderTicketsM
         }
 
         LinkedList<String> sqls = new LinkedList<>();
-        LinkedList<Object[]> paramsList = new LinkedList<>();
 
         //sql
         KylinOrderTickets orderTickets = new KylinOrderTickets();
@@ -653,7 +651,8 @@ public class KylinOrderTicketsServiceImpl extends ServiceImpl<KylinOrderTicketsM
         orderTickets.setQrCode(IDGenerator.ticketQrCode(orderTicketData.getOrderTicketsId()));
         orderTickets.setUpdatedAt(now);
         sqls.add(SqlMapping.get("kylin_order_ticket.synPay"));
-        paramsList.add(orderTickets.getSynOrderObject());
+        LinkedList<Object[]> sqlsDataA = new LinkedList<Object[]>();
+        sqlsDataA.add(orderTickets.getSynOrderObject());
 
         KylinOrderTicketStatus orderTicketStatus = new KylinOrderTicketStatus();
         orderTicketStatus.setOrderId(orderTicketData.getOrderTicketsId());
@@ -661,14 +660,16 @@ public class KylinOrderTicketsServiceImpl extends ServiceImpl<KylinOrderTicketsM
         orderTicketStatus.setPayStatus(syncOrderParam.getStatus());
         orderTicketStatus.setUpdatedAt(orderTickets.getUpdatedAt());
         sqls.add(SqlMapping.get("kylin_order_ticket_status.synPay"));
-        paramsList.add(orderTicketStatus.getSynOrderObject());
+        LinkedList<Object[]> sqlsDataB = new LinkedList<Object[]>();
+        sqlsDataB.add(orderTicketStatus.getSynOrderObject());
 
         KylinOrderTicketEntities orderTicketEntities = new KylinOrderTicketEntities();
         orderTicketEntities.setOrderId(orderTicketData.getOrderTicketsId());
         orderTicketEntities.setIsPayment(KylinTableStatusConst.ENTITIES_IS_PAYMENT1);
         orderTicketEntities.setUpdatedAt(orderTickets.getUpdatedAt());
         sqls.add(SqlMapping.get("kylin_order_ticket_entities.synPay"));
-        paramsList.add(orderTicketEntities.getSynOrderObject());
+        LinkedList<Object[]> sqlsDataC = new LinkedList<Object[]>();
+        sqlsDataC.add(orderTicketEntities.getSynOrderObject());
 
 
         //vo
@@ -698,8 +699,8 @@ public class KylinOrderTicketsServiceImpl extends ServiceImpl<KylinOrderTicketsM
             dataUtils.delOrderTicketEntitiesRedis(item.getOrderTicketEntitiesId());
         }
 
-//        rabbitTemplate.convertAndSend(MQConst.EXCHANGES_LIQUIDNET_SQL, MQConst.ROUTING_KEY_SQL,
-//                SqlMapping.get(sqls, paramsList));
+        rabbitTemplate.convertAndSend(MQConst.EXCHANGES_LIQUIDNET_SQL, MQConst.ROUTING_KEY_SQL,
+                SqlMapping.gets(sqls, sqlsDataA,sqlsDataB,sqlsDataC));
 
         // 发短信
         return "success";