超时支付 上线接口修改

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

@@ -29,6 +29,7 @@ import com.liquidnet.service.kylin.dto.vo.returns.PayResultVo;
 import com.liquidnet.service.kylin.entity.*;
 import com.liquidnet.service.kylin.mapper.KylinOrderTicketEntitiesMapper;
 import com.liquidnet.service.kylin.mapper.KylinOrderTicketsMapper;
+import com.liquidnet.service.kylin.service.IKylinOrderRefundsService;
 import com.liquidnet.service.kylin.service.IKylinOrderTicketsService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.liquidnet.service.kylin.utils.*;
@@ -104,6 +105,8 @@ public class KylinOrderTicketsServiceImpl extends ServiceImpl<KylinOrderTicketsM
     private TaobaoTicketUtils taobaoTicketUtils;
     @Autowired
     private KylinOrderTicketsMapper orderTicketsMapper;
+    @Autowired
+    private OrderRefundsCallbackServiceImpl orderRefundsCallbackService;
 
     ArrayList<Integer> canBuyStatus = new ArrayList() {{
         add(6);
@@ -779,110 +782,114 @@ public class KylinOrderTicketsServiceImpl extends ServiceImpl<KylinOrderTicketsM
         }
 
         LinkedList<String> sqls = new LinkedList<>();
-        LocalDateTime strTime = orderTicketData.getChangeDate();
-
-        //sql
-        KylinOrderTickets orderTickets = new KylinOrderTickets();
-        orderTickets.setOrderTicketsId(orderTicketData.getOrderTicketsId());
-        orderTickets.setPaymentType(syncOrderParam.getPayment_type());
-        orderTickets.setPayCode(syncOrderParam.getCode());
-        orderTickets.setTimePay(timePay);
-        orderTickets.setQrCode(IDGenerator.ticketQrCode(orderTicketData.getOrderTicketsId()));
-        orderTickets.setUpdatedAt(now);
-        sqls.add(SqlMapping.get("kylin_order_ticket.synPay"));
         LinkedList<Object[]> sqlsDataA = new LinkedList<>();
-        sqlsDataA.add(orderTickets.getSynOrderObject(strTime, strTime));
-
-        KylinOrderTicketStatus orderTicketStatus = new KylinOrderTicketStatus();
-        orderTicketStatus.setOrderId(orderTicketData.getOrderTicketsId());
-        orderTicketStatus.setStatus(KylinTableStatusConst.ORDER_STATUS1);
-        orderTicketStatus.setPayStatus(syncOrderParam.getStatus());
-        orderTicketStatus.setUpdatedAt(orderTickets.getUpdatedAt());
-        sqls.add(SqlMapping.get("kylin_order_ticket_status.synPay"));
         LinkedList<Object[]> sqlsDataB = new LinkedList<>();
-        sqlsDataB.add(orderTicketStatus.getSynOrderObject(strTime, strTime));
-
-        sqls.add(SqlMapping.get("kylin_order_ticket_relation.synPay"));
         LinkedList<Object[]> sqlsDataC = new LinkedList<>();
-        sqlsDataC.add(new Object[]{orderTickets.getUpdatedAt(), orderTickets.getOrderTicketsId(), strTime, strTime});
+        LinkedList<Object[]> sqlsDataD = new LinkedList<>();
 
+        LocalDateTime strTime = orderTicketData.getChangeDate();
+
+        KylinOrderTickets orderTickets = new KylinOrderTickets();
+        KylinOrderTicketStatus orderTicketStatus = new KylinOrderTicketStatus();
         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"));
-        LinkedList<Object[]> sqlsDataD = new LinkedList<>();
-        sqlsDataD.add(orderTicketEntities.getSynOrderObject(strTime, strTime));
-
-
-        //vo
-        HashMap<String, Object> orderTicketVo = new HashMap<>();
-        orderTicketVo.put("paymentType", orderTickets.getPaymentType());
-        orderTicketVo.put("payCode", orderTickets.getPayCode());
-        orderTicketVo.put("timePay", orderTickets.getTimePay());
-        orderTicketVo.put("qrCode", orderTickets.getQrCode());
-        orderTicketVo.put("status", KylinTableStatusConst.ORDER_STATUS1);
-        orderTicketVo.put("payStatus", orderTicketStatus.getStatus());
-        orderTicketVo.put("updatedAt", timePay);
-        orderTicketVo.put("changeDate", now);
-        mongoTemplate.getCollection(KylinOrderTicketVo.class.getSimpleName()).updateOne(
-                Query.query(Criteria.where("orderTicketsId").is(orderTickets.getOrderTicketsId())).getQueryObject(),
-                new BasicDBObject("$set", mongoConverter.convertToMongoType(orderTicketVo))
-        );
-
-
-        HashMap<String, Object> orderTicketEntitiesVo = new HashMap<>();
-        orderTicketEntitiesVo.put("isPayment", KylinTableStatusConst.ENTITIES_IS_PAYMENT1);
-        orderTicketEntitiesVo.put("updatedAt", timePay);
-        orderTicketEntitiesVo.put("changeDate", now);
-        mongoTemplate.getCollection(KylinOrderTicketEntitiesVo.class.getSimpleName()).updateMany(
-                Query.query(Criteria.where("orderId").is(orderTickets.getOrderTicketsId())).getQueryObject(),
-                new BasicDBObject("$set", mongoConverter.convertToMongoType(orderTicketEntitiesVo))
-        );
-
-        rabbitTemplate.convertAndSend(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_PAY, MQConst.ROUTING_KEY_SQL_ORDER_PAY,
-                SqlMapping.gets(sqls, sqlsDataA, sqlsDataB, sqlsDataC, sqlsDataD));
-
-        //生成vo redis
-        dataUtils.delOrderTicketRedis(orderTickets.getOrderTicketsId());
-        mongoVoUtils.resetOrderListVo(orderTicketData.getUserId(), 2, orderTicketData.getOrderTicketsId(), null);
-
-        // 发短信
-        KylinPerformanceVo performanceData = dataUtils.getPerformanceVo(orderTicketData.getPerformanceId());
-        KylinTicketTimesVo ticketTimesData = null;
-        KylinTicketVo ticketData = null;
-        for (int x = 0; x < performanceData.getTicketTimeList().size(); x++) {
-            KylinTicketTimesVo timeItem = performanceData.getTicketTimeList().get(x);
-            if (timeItem.getTimeId().equals(orderTicketData.getTimeId())) {
-                ticketTimesData = timeItem;
-                for (int y = 0; y < ticketTimesData.getTicketList().size(); y++) {
-                    KylinTicketVo ticketItem = ticketTimesData.getTicketList().get(y);
-                    if (ticketItem.getTicketsId().equals(orderTicketData.getTicketId())) {
-                        ticketData = ticketItem;
-                        break;
+
+        if(orderTicketData.getStatus()==0){
+            orderTickets.setOrderTicketsId(orderTicketData.getOrderTicketsId());
+            orderTickets.setPaymentType(syncOrderParam.getPayment_type());
+            orderTickets.setPayCode(syncOrderParam.getCode());
+            orderTickets.setTimePay(timePay);
+            orderTickets.setQrCode(IDGenerator.ticketQrCode(orderTicketData.getOrderTicketsId()));
+            orderTickets.setUpdatedAt(now);
+            sqls.add(SqlMapping.get("kylin_order_ticket.synPay"));
+            sqlsDataA.add(orderTickets.getSynOrderObject(strTime, strTime));
+
+            orderTicketStatus.setOrderId(orderTicketData.getOrderTicketsId());
+            orderTicketStatus.setStatus(KylinTableStatusConst.ORDER_STATUS1);
+            orderTicketStatus.setPayStatus(syncOrderParam.getStatus());
+            orderTicketStatus.setUpdatedAt(orderTickets.getUpdatedAt());
+            sqls.add(SqlMapping.get("kylin_order_ticket_status.synPay"));
+            sqlsDataB.add(orderTicketStatus.getSynOrderObject(strTime, strTime));
+
+            sqls.add(SqlMapping.get("kylin_order_ticket_relation.synPay"));
+            sqlsDataC.add(new Object[]{orderTickets.getUpdatedAt(), orderTickets.getOrderTicketsId(), strTime, strTime});
+
+            orderTicketEntities.setOrderId(orderTicketData.getOrderTicketsId());
+            orderTicketEntities.setIsPayment(KylinTableStatusConst.ENTITIES_IS_PAYMENT1);
+            orderTicketEntities.setUpdatedAt(orderTickets.getUpdatedAt());
+            sqls.add(SqlMapping.get("kylin_order_ticket_entities.synPay"));
+            sqlsDataD.add(orderTicketEntities.getSynOrderObject(strTime, strTime));
+
+            //vo
+            HashMap<String, Object> orderTicketVo = new HashMap<>();
+            orderTicketVo.put("paymentType", orderTickets.getPaymentType());
+            orderTicketVo.put("payCode", orderTickets.getPayCode());
+            orderTicketVo.put("timePay", orderTickets.getTimePay());
+            orderTicketVo.put("qrCode", orderTickets.getQrCode());
+            orderTicketVo.put("status", KylinTableStatusConst.ORDER_STATUS1);
+            orderTicketVo.put("payStatus", orderTicketStatus.getStatus());
+            orderTicketVo.put("updatedAt", timePay);
+            orderTicketVo.put("changeDate", now);
+            mongoTemplate.getCollection(KylinOrderTicketVo.class.getSimpleName()).updateOne(
+                    Query.query(Criteria.where("orderTicketsId").is(orderTickets.getOrderTicketsId())).getQueryObject(),
+                    new BasicDBObject("$set", mongoConverter.convertToMongoType(orderTicketVo))
+            );
+
+
+            HashMap<String, Object> orderTicketEntitiesVo = new HashMap<>();
+            orderTicketEntitiesVo.put("isPayment", KylinTableStatusConst.ENTITIES_IS_PAYMENT1);
+            orderTicketEntitiesVo.put("updatedAt", timePay);
+            orderTicketEntitiesVo.put("changeDate", now);
+            mongoTemplate.getCollection(KylinOrderTicketEntitiesVo.class.getSimpleName()).updateMany(
+                    Query.query(Criteria.where("orderId").is(orderTickets.getOrderTicketsId())).getQueryObject(),
+                    new BasicDBObject("$set", mongoConverter.convertToMongoType(orderTicketEntitiesVo))
+            );
+
+            rabbitTemplate.convertAndSend(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_PAY, MQConst.ROUTING_KEY_SQL_ORDER_PAY,
+                    SqlMapping.gets(sqls, sqlsDataA, sqlsDataB, sqlsDataC, sqlsDataD));
+
+            //生成vo redis
+            dataUtils.delOrderTicketRedis(orderTickets.getOrderTicketsId());
+            mongoVoUtils.resetOrderListVo(orderTicketData.getUserId(), 2, orderTicketData.getOrderTicketsId(), null);
+
+            // 发短信
+            KylinPerformanceVo performanceData = dataUtils.getPerformanceVo(orderTicketData.getPerformanceId());
+            KylinTicketTimesVo ticketTimesData = null;
+            KylinTicketVo ticketData = null;
+            for (int x = 0; x < performanceData.getTicketTimeList().size(); x++) {
+                KylinTicketTimesVo timeItem = performanceData.getTicketTimeList().get(x);
+                if (timeItem.getTimeId().equals(orderTicketData.getTimeId())) {
+                    ticketTimesData = timeItem;
+                    for (int y = 0; y < ticketTimesData.getTicketList().size(); y++) {
+                        KylinTicketVo ticketItem = ticketTimesData.getTicketList().get(y);
+                        if (ticketItem.getTicketsId().equals(orderTicketData.getTicketId())) {
+                            ticketData = ticketItem;
+                            break;
+                        }
                     }
+                    break;
                 }
-                break;
             }
-        }
 
-        MessageDataVo dataVo = new MessageDataVo();
-        dataVo.setName(orderTicketData.getPerformanceTitle());
-        String time1 = DateUtil.format(DateUtil.Formatter.yyyyMMddHHmmss.parse(ticketData.getUseStart()), DateUtil.Formatter.yyyy_MM_dd);
-        String time2 = DateUtil.format(DateUtil.Formatter.yyyyMMddHHmmss.parse(performanceData.getTimeStart()), DateUtil.Formatter.HHmm);
-        dataVo.setTime(time1 + " " + time2);
-
-        MessageConfigVo configVo = new MessageConfigVo();
-        configVo.setStatus(true);
-        if (orderTicketData.getGetTicketType().equals("express")) {
-            configVo.setId("SMS_181490473");
-        } else if (orderTicketData.getGetTicketType().equals("electronic")) {
-            configVo.setId(ticketData.getIsShowCode() == 1 ? "SMS_171358560" : "SMS_181500419");
-        }
-        otherUtils.sendMessage(orderTicketData.getUserMobile(), dataVo, configVo, 1);
+            MessageDataVo dataVo = new MessageDataVo();
+            dataVo.setName(orderTicketData.getPerformanceTitle());
+            String time1 = DateUtil.format(DateUtil.Formatter.yyyyMMddHHmmss.parse(ticketData.getUseStart()), DateUtil.Formatter.yyyy_MM_dd);
+            String time2 = DateUtil.format(DateUtil.Formatter.yyyyMMddHHmmss.parse(performanceData.getTimeStart()), DateUtil.Formatter.HHmm);
+            dataVo.setTime(time1 + " " + time2);
+
+            MessageConfigVo configVo = new MessageConfigVo();
+            configVo.setStatus(true);
+            if (orderTicketData.getGetTicketType().equals("express")) {
+                configVo.setId("SMS_181490473");
+            } else if (orderTicketData.getGetTicketType().equals("electronic")) {
+                configVo.setId(ticketData.getIsShowCode() == 1 ? "SMS_171358560" : "SMS_181500419");
+            }
+            otherUtils.sendMessage(orderTicketData.getUserMobile(), dataVo, configVo, 1);
 
-        // 大麦回调
-        sycDamaiOrder(orderTickets.getOrderTicketsId());
+            // 大麦回调
+            sycDamaiOrder(orderTickets.getOrderTicketsId());
+        }else{
+             orderRefundsCallbackService.refundApply(orderTicketData.getOrderTicketsId());
+        }
         redisLockUtil.unlock(lock);
         return "success";
     }