订单回调 修改队列 改为和创建一起

liquidnet-bus-service/liquidnet-service-merchant/liquidnet-service-merchant-impl/src/main/java/com/liquidnet/service/merchant/service/impl/KylinPerformancesPartnerServiceImpl.java

@@ -327,10 +327,10 @@ public class KylinPerformancesPartnerServiceImpl implements IKylinPerformancesPa
                     mapSql.put("status", performancePartnerVo.getStatus());
                     mapSql.put("updatedAt", now.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
                     sqlsDataA.add(new Object[]{
-                            now, kylinPerformanceMisVo.getNoticeImage(), performanceId
+                            now, kylinPerformanceMisVo.getNoticeImage(), performanceId,now,now
                     });
                     sqlsDataB.add(new Object[]{
-                            performancePartnerVo.getAuditStatus(), step2Param.getIsTrueName(), step2Param.getLimitCount(), performanceId
+                            performancePartnerVo.getAuditStatus(), step2Param.getIsTrueName(), step2Param.getLimitCount(), performanceId,now,now
                     });
                     redisMerchantUtils.setPerformanceIsTrueName(performanceId, step2Param.getIsTrueName());
 
@@ -364,14 +364,14 @@ public class KylinPerformancesPartnerServiceImpl implements IKylinPerformancesPa
                             sqlsDataC.add(new Object[]{
                                     DateUtil.Formatter.yyyyMMddHHmmss.parse(ticketItem.getTimeEnd()), DateUtil.Formatter.yyyyMMddHHmmss.parse(ticketItem.getTimeStart()),
                                     DateUtil.Formatter.yyyyMMddHHmmss.parse(ticketItem.getTimeEndExpress()), kylinPerformanceMisVo.getPayCountdownMinute(),
-                                    ticketItem.getPrice(), ticketItem.getTicketsId()
+                                    ticketItem.getPrice(), ticketItem.getTicketsId(),now,now
                             });
                             //修改 mysql 购票限购、库存
                             sqlsDataD.add(new Object[]{
                                     ticketItem.getTotalExchange(), ticketItem.getTotalGeneral(), kylinPerformanceMisVo.getIsTrueName(),
                                     ticketItem.getLimitCount(), ticketItem.getIsLackRegister(), ticketItem.getIsExpress(),
                                     ticketItem.getIsElectronic(), ticketItem.getCounts(), ticketItem.getIsShowCode(),
-                                    DateUtil.Formatter.yyyyMMddHHmmss.parse(ticketItem.getQrCodeShowTime()), ticketItem.getTicketsId()
+                                    DateUtil.Formatter.yyyyMMddHHmmss.parse(ticketItem.getQrCodeShowTime()), ticketItem.getTicketsId(),now,now
                             });
                         }
                     }
@@ -441,7 +441,7 @@ public class KylinPerformancesPartnerServiceImpl implements IKylinPerformancesPa
             // mysql
             LocalDateTime updatedAt = LocalDateTime.now();
             sqlsDataA.add(new Object[]{
-                    6, updatedAt, performancesId
+                    6, updatedAt, performancesId,updatedAt,updatedAt
             });
             //场次
             List<KylinTicketTimesVo> ticketTimeVo = vo.getTicketTimeList();
@@ -450,7 +450,7 @@ public class KylinPerformancesPartnerServiceImpl implements IKylinPerformancesPa
                 List<KylinTicketVo> ticketVo = ticketTimeItem.getTicketList();
                 for (KylinTicketVo ticketItem : ticketVo) {
                     sqlsDataB.add(new Object[]{
-                            9, updatedAt, ticketItem.getTicketsId()
+                            9, updatedAt, ticketItem.getTicketsId(),updatedAt,updatedAt
                     });
                     KylinTicketPartnerVo ticketPartnerVo = KylinTicketPartnerVo.getNew();
                     ticketPartnerVo.setTicketsId(ticketItem.getTicketsId());
@@ -481,7 +481,7 @@ public class KylinPerformancesPartnerServiceImpl implements IKylinPerformancesPa
                 LocalDateTime updatedAt = LocalDateTime.now();
                 queueUtil.sendMsgByRedis(MQConst.MerchantQueue.SQL_MERCHANT_LINE.getKey(),
                         SqlMapping.get("kylin_performances_status.outLine",
-                                7, updatedAt, performancesId
+                                7, updatedAt, performancesId,updatedAt,updatedAt
                         ));
                 performanceUtils.performanceVoStatus(performancesId);
                 log.info(UserPathDto.setPartnerData("0", "outLinePerformance", "performancesId=" + performancesId, "下线成功"));
@@ -594,6 +594,7 @@ public class KylinPerformancesPartnerServiceImpl implements IKylinPerformancesPa
     public ResponseDto<String> withdraw(String performancesId) {
         try {
             String merchantId = CurrentUtil.getCurrentUid();
+            LocalDateTime now = LocalDateTime.now();
             KylinPerformanceVo vo = redisMerchantUtils.getPerformanceVo(performancesId,merchantId);
             if (vo != null && vo.getAuditStatus() == 0) {
                 PerformancePartnerVo performancePartnerVo = PerformancePartnerVo.getNew();
@@ -602,20 +603,20 @@ public class KylinPerformancesPartnerServiceImpl implements IKylinPerformancesPa
                     performancePartnerVo.setAuditStatus(1);
                     queueUtil.sendMsgByRedis(MQConst.MerchantQueue.SQL_MERCHANT_PERFORMANCE_UPDATE.getKey(),
                             SqlMapping.get("kylin_performances_status.withdraw",
-                                    1, performancesId
+                                    1, performancesId,now,now
                             ));
                 } else if (vo.getAppStatus() == 4 || vo.getAppStatus() == 1) {//未通过审核
                     performancePartnerVo.setAuditStatus(-1);
                     performancePartnerVo.setStatus(0);
                     queueUtil.sendMsgByRedis(MQConst.MerchantQueue.SQL_MERCHANT_PERFORMANCE_UPDATE.getKey(),
                             SqlMapping.get("kylin_performances_status.withdraw2",
-                                    -1, 0, performancesId
+                                    -1, 0, performancesId,now,now
                             ));
                 } else {
                     performancePartnerVo.setAuditStatus(2);
                     queueUtil.sendMsgByRedis(MQConst.MerchantQueue.SQL_MERCHANT_PERFORMANCE_UPDATE.getKey(),
                             SqlMapping.get("kylin_performances_status.withdraw",
-                                    2, performancesId
+                                    2, performancesId,now,now
                             ));
                 }
                 mongoMerchantUtils.updatePerformancePartnerVoById(performancePartnerVo);