超时退款

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

@@ -99,15 +99,11 @@ public class KylinRefundsStatusServiceImpl {
         BasicDBObject entitiesObject = ObjectUtil.cloneBasicDBObject().append("$set", JSON.parse(JsonUtils.toJson(kylinOrderTicketEntitiesVo)));
 
         LinkedList<Object[]> sqlsDataB = ObjectUtil.cloneLinkedListObj();
+        LocalDateTime now1 = LocalDateTime.now();
         for (String v : ticketEntityIds) {
-            Object[] objectB = ObjectUtil.cloneObjectsArray(5);
-            objectB[0] = entitiesTable.getIsPayment();
-            objectB[1] = entitiesTable.getUpdatedAt();
-            objectB[2] = v;
-            LocalDateTime now1 = LocalDateTime.now();
-            objectB[3] = now1;
-            objectB[4] = now1;
-            sqlsDataB.add(objectB);
+            sqlsDataB.add(new Object[]{
+                    entitiesTable.getIsPayment(), entitiesTable.getUpdatedAt(), v, now1, now1
+            });
 
             mongoTemplate.getCollection(KylinOrderTicketEntitiesVo.class.getSimpleName()).updateOne(
                     Query.query(Criteria.where("orderTicketEntitiesId").is(v)).getQueryObject(),
@@ -116,6 +112,7 @@ public class KylinRefundsStatusServiceImpl {
             dataUtils.delOrderTicketEntitiesRedis(v);
         }
 
+        // 生成订单列表缓存
         orderUtils.resetOrderListVo(orderInfo.getUserId(), 2, orderTicketsId, null);
 
         // 退款明细
@@ -143,8 +140,6 @@ public class KylinRefundsStatusServiceImpl {
         }
         kylinOrderRefunds.setCreatedAt(nowTime);
 
-        /*int rows = kylinOrderRefundsMapper.insert(kylinOrderRefunds);*/
-
         KylinOrderRefundsVo orderRefundsVo = KylinOrderRefundsVo.getNew();
         BeanUtils.copyProperties(kylinOrderRefunds, orderRefundsVo);
         mongoTemplate.insert(orderRefundsVo, KylinOrderRefundsVo.class.getSimpleName());
@@ -160,13 +155,10 @@ public class KylinRefundsStatusServiceImpl {
             kylinOrderRefundEntities.setRefundPrice(entitiesPrice.get(i));
             kylinOrderRefundEntities.setOrderTicketEntitiesId(ticketEntityIds.get(i));
 
-            Object[] objectD = ObjectUtil.cloneObjectsArray(5);
-            objectD[0] = kylinOrderRefundEntities.getOrderRefundsEntitiesId();
-            objectD[1] = kylinOrderRefundEntities.getOrderRefundsId();
-            objectD[2] = kylinOrderRefundEntities.getRefundPrice();
-            objectD[3] = kylinOrderRefundEntities.getOrderTicketEntitiesId();
-            objectD[4] = kylinOrderRefundEntities.getCreatedAt();
-            sqlsDataD.add(objectD);
+            sqlsDataD.add(new Object[]{
+                    kylinOrderRefundEntities.getOrderRefundsEntitiesId(), kylinOrderRefundEntities.getOrderRefundsId(), kylinOrderRefundEntities.getRefundPrice(),
+                    kylinOrderRefundEntities.getOrderTicketEntitiesId(), kylinOrderRefundEntities.getCreatedAt()
+            });
 
             KylinOrderRefundEntitiesVo orderRefundEntitiesVo = KylinOrderRefundEntitiesVo.getNew();
             BeanUtils.copyProperties(kylinOrderRefundEntities, orderRefundEntitiesVo);
@@ -185,39 +177,23 @@ public class KylinRefundsStatusServiceImpl {
         sqls.add(SqlMapping.get("kylin_order_refund_entities.overtimeRefund"));
         sqls.add(SqlMapping.get("kylin_order_tickets.overtimeRefund"));
 
-        Object[] objectE = ObjectUtil.cloneObjectsArray(6);
-        objectE[0] = paymentId;
-        objectE[1] = paymentType;
-        objectE[2] = orderStatusTable.getUpdatedAt();
-        objectE[3] = orderInfo.getOrderTicketsId();
-        LocalDateTime now1 = LocalDateTime.now();
-        objectE[4] = now1;
-        objectE[5] = now1;
-        sqlsDataE.add(objectE);
-
-        Object[] objectA = ObjectUtil.cloneObjectsArray(5);
-        objectA[0] = orderStatusTable.getStatus();
-        objectA[1] = orderStatusTable.getUpdatedAt();
-        objectA[2] = orderInfo.getOrderTicketsId();
-        objectA[3] = now1;
-        objectA[4] = now1;
-        sqlsDataA.add(objectA);
-
-        Object[] objectC = ObjectUtil.cloneObjectsArray(13);
-        objectC[0] = kylinOrderRefunds.getOrderRefundsId();
-        objectC[1] = kylinOrderRefunds.getOrderTicketsId();
-        objectC[2] = kylinOrderRefunds.getOrderRefundCode();
-        objectC[3] = kylinOrderRefunds.getPrice();
-        objectC[4] = kylinOrderRefunds.getPriceExpress();
-        objectC[5] = kylinOrderRefunds.getStatus();
-        objectC[6] = kylinOrderRefunds.getType();
-        objectC[7] = kylinOrderRefunds.getApplicantId();
-        objectC[8] = kylinOrderRefunds.getApplicantName();
-        objectC[9] = kylinOrderRefunds.getApplicantAt();
-        objectC[10] = kylinOrderRefunds.getReason();
-        objectC[11] = kylinOrderRefunds.getRefundCate();
-        objectC[12] = kylinOrderRefunds.getCreatedAt();
-        sqlsDataC.add(objectC);
+        sqlsDataE.add(new Object[]{
+                paymentId, paymentType, orderStatusTable.getUpdatedAt(),
+                orderInfo.getOrderTicketsId(), now1, now1
+        });
+
+        sqlsDataA.add(new Object[]{
+                orderStatusTable.getStatus(), orderStatusTable.getUpdatedAt(), orderInfo.getOrderTicketsId(),
+                now1, now1
+        });
+
+        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()
+        });
 
         queueUtils.sendMsgByRedis(MQConst.KylinQueue.SQL_ORDER_OVERTIME_REFUND.getKey(),
                 SqlMapping.gets(sqls, sqlsDataA, sqlsDataB, sqlsDataC, sqlsDataD, sqlsDataE));

liquidnet-bus-service/liquidnet-service-order/liquidnet-service-order-impl/src/main/java/com/liquidnet/service/order/service/impl/OrderRefundOvertimeServiceImpl.java

@@ -44,6 +44,8 @@ public class OrderRefundOvertimeServiceImpl implements IKylinOrderRefundsService
     private String candyUrl;
 
     public Boolean refundApply(String orderTicketsId,String paymentId,String paymentType) {
+        log.info("订单超时支付refundApply-Start：[orderTicketsId=[{}], [paymentId=[{}], paymentType=[{}]",
+                orderTicketsId, paymentId, paymentType);
         KylinOrderTicketVo orderInfo = dataUtils.getOrderTicketVo(orderTicketsId);
         // 快递费 未进行判断
         BigDecimal RefundPriceExpress = orderInfo.getPriceExpress();