上下线暂时提交

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

@@ -428,11 +428,11 @@ public class KylinPerformancesPartnerServiceImpl implements IKylinPerformancesPa
     public ResponseDto<String> onLinePerformance(String performancesId) {
         try {
             String merchantId = CurrentUtil.getCurrentUid();
-            LinkedList<String> sqls = CollectionUtil.linkedListString();
-            sqls.add(SqlMapping.get("kylin_performances_status.onLine"));
-            sqls.add(SqlMapping.get("kylin_ticket_status.onLine"));
-            LinkedList<Object[]> sqlsDataA = CollectionUtil.linkedListObjectArr();
-            LinkedList<Object[]> sqlsDataB = CollectionUtil.linkedListObjectArr();
+//            LinkedList<String> sqls = CollectionUtil.linkedListString();
+//            sqls.add(SqlMapping.get("kylin_performances_status.onLine"));
+//            sqls.add(SqlMapping.get("kylin_ticket_status.onLine"));
+//            LinkedList<Object[]> sqlsDataA = CollectionUtil.linkedListObjectArr();
+//            LinkedList<Object[]> sqlsDataB = CollectionUtil.linkedListObjectArr();
 
             KylinPerformanceVo vo = redisMerchantUtils.getPerformanceVo(performancesId,merchantId);
             if (!(vo.getAppStatus() == 3 || vo.getAppStatus() == 7)) {
@@ -440,28 +440,32 @@ public class KylinPerformancesPartnerServiceImpl implements IKylinPerformancesPa
             }
             // mysql
             LocalDateTime updatedAt = LocalDateTime.now();
-            sqlsDataA.add(new Object[]{
-                    6, updatedAt, performancesId,updatedAt,updatedAt
-            });
+//            sqlsDataA.add(new Object[]{
+//                    6, updatedAt, performancesId,updatedAt,updatedAt
+//            });
+            vo.setAppStatus(6);
             //场次
             List<KylinTicketTimesVo> ticketTimeVo = vo.getTicketTimeList();
             for (KylinTicketTimesVo ticketTimeItem : ticketTimeVo) {
                 //票
                 List<KylinTicketVo> ticketVo = ticketTimeItem.getTicketList();
                 for (KylinTicketVo ticketItem : ticketVo) {
-                    sqlsDataB.add(new Object[]{
-                            9, updatedAt, ticketItem.getTicketsId(),updatedAt,updatedAt
-                    });
+//                    sqlsDataB.add(new Object[]{
+//                            9, updatedAt, ticketItem.getTicketsId(),updatedAt,updatedAt
+//                    });
                     KylinTicketPartnerVo ticketPartnerVo = KylinTicketPartnerVo.getNew();
+                    ticketItem.setStatus(9);
                     ticketPartnerVo.setTicketsId(ticketItem.getTicketsId());
                     ticketPartnerVo.setStatus(9);
                     ticketPartnerVo.setUpdatedAt(updatedAt.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
                     mongoMerchantUtils.updateSubmitTicketVoById(ticketPartnerVo);
                 }
             }
-            String sqlData = SqlMapping.gets(sqls, sqlsDataA, sqlsDataB);
-            queueUtil.sendMsgByRedis(MQConst.MerchantQueue.SQL_MERCHANT_LINE.getKey(),
-                    sqlData);
+//            String sqlData = SqlMapping.gets(sqls, sqlsDataA, sqlsDataB);
+//            queueUtil.sendMsgByRedis(MQConst.MerchantQueue.SQL_MERCHANT_LINE.getKey(),
+//                    sqlData);
+            mongoMerchantUtils.delPerformanceVo(performancesId);
+            mongoMerchantUtils.insertPerformanceVo(vo);
 //          判断状态
             performanceUtils.performanceVoStatus(performancesId);
             log.info(UserPathDto.setPartnerData("0", "onLinePerformance", "performancesId=" + performancesId, "上线成功"));
@@ -478,11 +482,18 @@ public class KylinPerformancesPartnerServiceImpl implements IKylinPerformancesPa
             String merchantId = CurrentUtil.getCurrentUid();
             KylinPerformanceVo vo = redisMerchantUtils.getPerformanceVo(performancesId,merchantId);
             if (vo.getAppStatus() >= 3 && vo.getAppStatus() != 4 && vo.getAppStatus() != 7) {//未提审||被拒绝   && performanceStatusData.getStatus() != 10
-                LocalDateTime updatedAt = LocalDateTime.now();
-                queueUtil.sendMsgByRedis(MQConst.MerchantQueue.SQL_MERCHANT_LINE.getKey(),
-                        SqlMapping.get("kylin_performances_status.outLine",
-                                7, updatedAt, performancesId,updatedAt,updatedAt
-                        ));
+//                HashMap<String, Object> map = CollectionUtil.mapStringObject();
+//                map.put("status", 7);
+//                map.put("updatedAt", DateUtil.Formatter.yyyyMMddHHmmss.format(LocalDateTime.now()));
+//                mongoMerchantUtils.updatePerformanceVo(map,performancesId);
+                vo.setAppStatus(7);
+                mongoMerchantUtils.delPerformanceVo(performancesId);
+                mongoMerchantUtils.insertPerformanceVo(vo);
+//                LocalDateTime updatedAt = LocalDateTime.now();
+//                queueUtil.sendMsgByRedis(MQConst.MerchantQueue.SQL_MERCHANT_LINE.getKey(),
+//                        SqlMapping.get("kylin_performances_status.outLine",
+//                                7, updatedAt, performancesId,updatedAt,updatedAt
+//                        ));
                 performanceUtils.performanceVoStatus(performancesId);
                 log.info(UserPathDto.setPartnerData("0", "outLinePerformance", "performancesId=" + performancesId, "下线成功"));
                 return ResponseDto.success("下线成功");

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

@@ -175,6 +175,14 @@ public class MongoMerchantUtils {
         return mongoTemplate.insert(data, KylinPerformanceVo.class.getSimpleName());
     }
 
+    public void updatePerformanceVo(HashMap<String, Object> map, String performanceId) {
+        BasicDBObject objectTicketVo = new BasicDBObject("$set", mongoConverter.convertToMongoType(map));
+        mongoTemplate.getCollection(KylinPerformanceVo.class.getSimpleName()).updateOne(
+                Query.query(Criteria.where("performancesId").is(performanceId)).getQueryObject(),
+                objectTicketVo
+        );
+    }
+
     public Object delPerformanceVo(String performanceId) {
         return mongoTemplate.remove(Query.query(Criteria.where("performancesId").is(performanceId)), KylinPerformanceVo.class, KylinPerformanceVo.class.getSimpleName());
     }

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

@@ -126,7 +126,7 @@ public class PerformanceUtils {
                         changeStatus.setSurplusGeneral(surplusGeneral);
                     }
                     sqlsDataA.add(new Object[]{
-                            changeStatus.getStatus(), changeStatus.getSurplusGeneral(), kylinTicketVoItem.getTicketsId()
+                            changeStatus.getStatus(), changeStatus.getSurplusGeneral(), kylinTicketVoItem.getTicketsId(),timeNow,timeNow
                     });
                     kylinTicketVoItem.setStatus(status);
 
@@ -150,7 +150,7 @@ public class PerformanceUtils {
             }
             //修改演出状态
             sqlsDataB.add(new Object[]{
-                    appStatus, performancesId
+                    appStatus, performancesId,timeNow,timeNow
             });
             String sqlData = SqlMapping.gets(sqls, sqlsDataA, sqlsDataB);
             queueUtil.sendMsgByRedis(MQConst.MerchantQueue.SQL_MERCHANT_PERFORMANCE_UPDATE.getKey(),