缺票登记 提交

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

@@ -153,8 +153,8 @@ public class KylinOrderTicketsServiceImpl extends ServiceImpl<KylinOrderTicketsM
             String timeStart = ticketData.getTimeStart(); // 普通开售时间
             String timeEnd = ticketData.getTimeEnd(); // 购票停售时间
             String timeExpressEnd = ticketData.getTimeEndExpress(); // 快递停售时间
-//            boolean isMember = feignAdamBaseClient.isMember(uid).getData();//获取是否是会员
-            boolean isMember = true;
+            boolean isMember = feignAdamBaseClient.isMember(uid).getData();//获取是否是会员
+//            boolean isMember = true;
             int memberType; //会员状态 不需要判断会员 1判断会员逻辑 2会员专属
             if (ticketData.getIsExclusive() == 1) {
                 memberType = 2;
@@ -290,10 +290,10 @@ public class KylinOrderTicketsServiceImpl extends ServiceImpl<KylinOrderTicketsM
         orderTickets.setOrderTicketsId(orderTicketId);
         orderTickets.setUserId(uid);
         Map token = CurrentUtil.getTokenClaims();
-//        orderTickets.setUserName(StringUtils.defaultString(((String) token.get("nickname")), ""));
-//        orderTickets.setUserMobile(StringUtils.defaultString(((String) token.get("mobile")), ""));
-        orderTickets.setUserName("");
-        orderTickets.setUserMobile("");
+        orderTickets.setUserName(StringUtils.defaultString(((String) token.get("nickname")), ""));
+        orderTickets.setUserMobile(StringUtils.defaultString(((String) token.get("mobile")), ""));
+//        orderTickets.setUserName("");
+//        orderTickets.setUserMobile("");
         orderTickets.setPerformanceTitle(performanceData.getTitle());
         orderTickets.setOrderCode(IDGenerator.ticketOrderCode(orderTicketId));
         orderTickets.setPayCode("");
@@ -492,7 +492,6 @@ public class KylinOrderTicketsServiceImpl extends ServiceImpl<KylinOrderTicketsM
         LinkedList<Object[]> sqlsDataA = new LinkedList<Object[]>();
         sqlsDataA.add(orderTickets.getAddObject());
 
-        //少mq
         if (payOrderParam.getPayType().equals("alipay") && payOrderParam.getDeviceFrom().equals("wap")) {
             payResultVo.setShowUrl(payOrderParam.getShowUrl());
             payResultVo.setReturnUrl(payOrderParam.getReturnUrl() + orderTicketId);
@@ -842,6 +841,7 @@ public class KylinOrderTicketsServiceImpl extends ServiceImpl<KylinOrderTicketsM
     @Override
     public boolean checkOrderTime(String userId) {
         List<OrderScriptDto> dtoData = orderTicketsMapper.orderScriptDto(userId);
+        LinkedList<String> sqls = new LinkedList<>();
 
         for (OrderScriptDto item : dtoData) {
             if (!RedisLockUtil.tryLock("order_lock:" + item.getOrderCode(), 30, 240)) {
@@ -879,10 +879,16 @@ public class KylinOrderTicketsServiceImpl extends ServiceImpl<KylinOrderTicketsM
                         dataUtils.changeBuyInfo(items.getUserId(), items.getEnterIdCode(), items.getPerformanceId(), items.getTicketId(), -1);
                     }
 
-                    rabbitTemplate.convertAndSend(MQConst.EXCHANGES_LIQUIDNET_SQL, MQConst.ROUTING_KEY_SQL,
-                            SqlMapping.get("kylin_order_ticket.close", orderTickets.getCloseOrderObject()));
-                    rabbitTemplate.convertAndSend(MQConst.EXCHANGES_LIQUIDNET_SQL, MQConst.ROUTING_KEY_SQL,
-                            SqlMapping.get("kylin_order_ticket_status.close", orderTicketStatus.getCloseOrderObject()));
+                    //TODO MQ代操作
+                    sqls.add(SqlMapping.get("kylin_order_ticket.close"));
+                    LinkedList<Object[]> sqlsDataA = new LinkedList<>();
+                    sqlsDataA.add(orderTickets.getCloseOrderObject());
+
+                    sqls.add(SqlMapping.get("kylin_order_ticket_status.close"));
+                    LinkedList<Object[]> sqlsDataB = new LinkedList<>();
+                    sqlsDataA.add(orderTickets.getCloseOrderObject());
+
+                    rabbitTemplate.convertAndSend(MQConst.EXCHANGES_LIQUIDNET_SQL, MQConst.ROUTING_KEY_SQL, SqlMapping.gets(sqls,sqlsDataA,sqlsDataB));
 
                 } catch (Exception e) {
                     lock.unlock();

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

@@ -17,4 +17,4 @@ kylin_order_ticket.synPay=UPDATE  kylin_order_tickets SET payment_type = ? ,pay_
 kylin_order_ticket.close=UPDATE  kylin_order_tickets SET updated_at = ? WHERE order_tickets_id = ? 
 
 # ----------------------------------------------------
-kylin_lack_register.insert=INSERT INTO `kylin_lack_registers`(`lack_registers_id` ,`performance_id` ,`ticket_id` ,`user_id` ,`user_name` ,`user_mobile` ,`send_status` ,`ip_address` ,`created_at` ,)VALUES(? ,? ,? ,? ,? ,? ,? ,? ,?);
+kylin_lack_register.insert=INSERT INTO `kylin_lack_registers`(`lack_registers_id` ,`performance_id` ,`ticket_id` ,`user_id` ,`user_name` ,`user_mobile` ,`send_status` ,`ip_address` ,`created_at`)VALUES(? ,? ,? ,? ,? ,? ,? ,? ,?);