临时提交

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

@@ -44,6 +44,7 @@ import java.time.LocalDateTime;
 import java.time.format.DateTimeFormatter;
 import java.util.ArrayList;
 import java.util.HashMap;
+import java.util.LinkedList;
 import java.util.List;
 
 /**
@@ -273,6 +274,8 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
         try {
             // 获取 主键id
             String performanceId = step2Param.getPerformancesId();
+            LinkedList<String> sqls = CollectionUtil.linkedListString();
+            LocalDateTime now = LocalDateTime.now();
             // 获取 当前时间 -> 创建时间
             LocalDateTime createdAt = LocalDateTime.now();
 
@@ -315,15 +318,25 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
                     mapSql.put("rejectTxt", "");
                     mapSql.put("status", performancePartnerVo.getStatus());
                     mapSql.put("updatedAt", createdAt.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
-                    KylinPerformances performances = KylinPerformances.getNew();
-                    performances.setAuditTime(LocalDateTime.now());
-                    performances.setNoticeImage(kylinPerformanceMisVo.getNoticeImage());
-                    performancesMapper.update(performances, Wrappers.lambdaQuery(KylinPerformances.class).eq(KylinPerformances::getPerformancesId, performanceId));
-                    KylinPerformanceStatus performanceStatus = KylinPerformanceStatus.getNew();
-                    performanceStatus.setAuditStatus(performancePartnerVo.getAuditStatus());
-                    performanceStatus.setIsTrueName(step2Param.getIsTrueName());
-                    performanceStatus.setLimitCount(step2Param.getLimitCount());
-                    performanceStatusMapper.update(performanceStatus, Wrappers.lambdaQuery(KylinPerformanceStatus.class).eq(KylinPerformanceStatus::getPerformanceId, performanceId));
+//                    KylinPerformances performances = KylinPerformances.getNew();
+//                    performances.setAuditTime(LocalDateTime.now());
+//                    performances.setNoticeImage(kylinPerformanceMisVo.getNoticeImage());
+                    sqls.add(SqlMapping.get("kylin_performance.updateStep2"));
+                    LinkedList<Object[]> sqlsDataA = CollectionUtil.linkedListObjectArr();
+                    sqlsDataA.add(new Object[]{
+                            now,kylinPerformanceMisVo.getNoticeImage(),performanceId
+                    });
+//                    performancesMapper.update(performances, Wrappers.lambdaQuery(KylinPerformances.class).eq(KylinPerformances::getPerformancesId, performanceId));
+//                    KylinPerformanceStatus performanceStatus = KylinPerformanceStatus.getNew();
+//                    performanceStatus.setAuditStatus(performancePartnerVo.getAuditStatus());
+//                    performanceStatus.setIsTrueName(step2Param.getIsTrueName());
+//                    performanceStatus.setLimitCount(step2Param.getLimitCount());
+                    sqls.add(SqlMapping.get("kylin_performance_status.updateStep2"));
+                    LinkedList<Object[]> sqlsDataB = CollectionUtil.linkedListObjectArr();
+                    sqlsDataA.add(new Object[]{
+                            performancePartnerVo.getAuditStatus(),step2Param.getIsTrueName(),step2Param.getLimitCount(),performanceId
+                    });
+//                    performanceStatusMapper.update(performanceStatus, Wrappers.lambdaQuery(KylinPerformanceStatus.class).eq(KylinPerformanceStatus::getPerformanceId, performanceId));
                     redisMerchantUtils.setPerformanceIsTrueName(performanceId, step2Param.getIsTrueName());
 
                     //提示：票种价格、售票时间、票种购票限制 直接生效 (演出购票限制，购票须知 演出是否实名 票种缺货登记 票种是否电子票 票种是否快递票 票种最低购买张数 票种是否显示二维码)
@@ -340,7 +353,7 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
                                 redisMerchantUtils.changeSurplusExchange(ticketItem.getTicketsId(), changeExchange);
                             }
                             //修改 mysql 库存
-                            KylinTicketStatus inventory = KylinTicketStatus.getNew();
+//                            KylinTicketStatus inventory = KylinTicketStatus.getNew();
                             inventory.setTotalExchange(ticketItem.getTotalExchange());
                             inventory.setTotalGeneral(ticketItem.getTotalGeneral());
                             inventory.setIsTrueName(kylinPerformanceMisVo.getIsTrueName());
@@ -352,9 +365,8 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
                             inventory.setIsShowCode(ticketItem.getIsShowCode());
                             inventory.setMemberLimitCount(null);
                             inventory.setQrCodeShowTime(DateUtil.Formatter.yyyyMMddHHmmss.parse(ticketItem.getQrCodeShowTime()));
-
                             //修改 mysql 售卖时间
-                            KylinTickets ticketSellTime = KylinTickets.getNew();
+//                            KylinTickets ticketSellTime = KylinTickets.getNew();
                             ticketSellTime.setTimeEnd(DateUtil.Formatter.yyyyMMddHHmmss.parse(ticketItem.getTimeEnd()));
                             ticketSellTime.setTimeStart(DateUtil.Formatter.yyyyMMddHHmmss.parse(ticketItem.getTimeStart()));
                             ticketSellTime.setAdvanceMinuteMember(null);
@@ -363,8 +375,10 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
                             //修改 价格
                             ticketSellTime.setPrice(ticketItem.getPrice());
                             ticketSellTime.setPriceDiscountMember(null);
+                            sqls.add(SqlMapping.get("kylin_ticket.updateStep2"));
                             ticketsMapper.update(ticketSellTime, Wrappers.lambdaQuery(KylinTickets.class).eq(KylinTickets::getTicketsId, ticketItem.getTicketsId()));
                             //修改 mysql 购票限购
+                            sqls.add(SqlMapping.get("kylin_ticket_status.updateStep2"));
                             ticketStatusMapper.update(inventory, Wrappers.lambdaQuery(KylinTicketStatus.class).eq(KylinTicketStatus::getTicketId, ticketItem.getTicketsId()));
                         }
                     }

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

@@ -9,3 +9,8 @@ merchant_field_applies.insert=INSERT INTO merchant_field_applies (field_apply_id
 kylin_performances.auditTime=UPDATE kylin_performances SET audit_time = WHERE performances_id = ? and (updated_at <= ? or created_at = ? or updated_at is null)
 #  ----    票种状态修改    ----
 kylin_ticket_status.update_status=UPDATE kylin_ticket_status SET status = ?, updated_at = ? WHERE ticket_id = ? and (updated_at <= ? or created_at = ? or updated_at is null)
+#  ----    演出第二步骤操作    ----
+kylin_performance.updateStep2 =
+kylin_performance_status.updateStep2 =
+kylin_ticket.updateStep2 =
+kylin_ticket_status.updateStep2 =
\ No newline at end of file