修改 会员审核bug

liquidnet-bus-api/liquidnet-service-kylin-api/src/main/java/com/liquidnet/service/kylin/dto/vo/partner/KylinTicketPartnerVo.java

@@ -114,6 +114,6 @@ public class KylinTicketPartnerVo implements Serializable {
         this.setIsTransfer(0);
         this.setIsExclusive(0);
         this.setSurplusExchange(this.getTotalExchange());
-        this.setSurplusGeneral(this.getTotalExchange());
+        this.setSurplusGeneral(this.getTotalGeneral());
     }
-}
+}
\ No newline at end of file

liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-web/src/main/resources/templates/zhengzai/kylin/performances/memberAudit/edit.html

@@ -129,9 +129,16 @@
 
     function submitHandler() {
         if ($.validate.form()) {
-            $.operate.save(prefix + "/save", $('#form-member-audit').serialize());
+            const auditStatus = document.getElementsByName("status")[0].checked ? 3 : 4;
+            if (4 === auditStatus) {
+                auditRejectTxt = document.getElementsByName("rejectTxt")[0].value;
+            }if (4 === auditStatus && auditRejectTxt === "") {
+                alert("请填写拒绝理由");
+            } else {
+                $.operate.save(prefix + "/save", $('#form-member-audit').serialize());
+            }
         }
     }
 </script>
 </body>
-</html>
+</html>
\ No newline at end of file

liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/kylin/service/impl/KylinPerformancesAdminServiceImpl.java

@@ -156,7 +156,7 @@ public class KylinPerformancesAdminServiceImpl extends ServiceImpl<KylinPerforma
                     mapSql.put("status", 9);
                     mapSql.put("updatedAt", updatedAt.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
                     performanceVoUtils.updatePerformanceMySql(performancesId, mapSql, performanceVoUtils.getPerformanceMisVo(performancesId), updatedAt, auditStatus);
-                    if (sqlStatus.getStatus() >= 6 && sqlStatus.getStatus()!=7) {//若 演出上 则 线判断状态
+                    if (sqlStatus.getStatus() >= 6 && sqlStatus.getStatus() != 7) {//若 演出上 则 线判断状态
                         performanceVoUtils.performanceVoStatus(performancesId);
                     }
                 }
@@ -202,7 +202,7 @@ public class KylinPerformancesAdminServiceImpl extends ServiceImpl<KylinPerforma
     public List<PerformanceAdminListDao> getList(PerformanceAdminListParam performanceAdminListParam) {
         List<PerformanceAdminListDao> newList = new ArrayList();
         try {
-            Map<String ,Object> map = BeanUtil.convertBeanToMap(performanceAdminListParam);
+            Map<String, Object> map = BeanUtil.convertBeanToMap(performanceAdminListParam);
             List<PerformanceAdminListDao> voList = performancesMapper.misPerformanceList(map);
             for (PerformanceAdminListDao item : voList) {
                 item.setStatus(item.getStatus());
@@ -331,13 +331,9 @@ public class KylinPerformancesAdminServiceImpl extends ServiceImpl<KylinPerforma
                 performanceMemberAuditDao.setIsExclusive(1);
             }
         }
-        PerformanceMemberAuditParam memberAuditVo = mongoTemplate.findOne(Query.query(Criteria.where("performancesId").is(performanceId)), PerformanceMemberAuditParam.class, PerformanceMemberAuditParam.class.getSimpleName());
-        if (memberAuditVo != null) {
-            if (memberAuditVo.getStatus() == 1) {
+        boolean isExists = mongoTemplate.exists(Query.query(Criteria.where("status").is(1).and("performancesId").is(performanceId)), PerformanceMemberAuditParam.class, PerformanceMemberAuditParam.class.getSimpleName());
+        if (isExists) {
                 performanceMemberAuditDao.setIsSubmit(1);
-            } else {
-                performanceMemberAuditDao.setIsSubmit(0);
-            }
         } else {
             performanceMemberAuditDao.setIsSubmit(0);
         }
@@ -347,9 +343,14 @@ public class KylinPerformancesAdminServiceImpl extends ServiceImpl<KylinPerforma
     @Override
     public boolean performanceMemberChange(PerformanceMemberAuditParam performanceMemberAuditParam) {
         try {
-            performanceMemberAuditParam.setStatus(1);
-            mongoTemplate.insert(performanceMemberAuditParam, PerformanceMemberAuditParam.class.getSimpleName());
-            return true;
+            boolean isExists = mongoTemplate.exists(Query.query(Criteria.where("status").is(1).and("performancesId").is(performanceMemberAuditParam.getPerformancesId())), PerformanceMemberAuditParam.class, PerformanceMemberAuditParam.class.getSimpleName());
+            if (isExists) {
+                return false;
+            } else {
+                performanceMemberAuditParam.setStatus(1);
+                mongoTemplate.insert(performanceMemberAuditParam, PerformanceMemberAuditParam.class.getSimpleName());
+                return true;
+            }
         } catch (Exception e) {
             return false;
         }
@@ -525,7 +526,7 @@ public class KylinPerformancesAdminServiceImpl extends ServiceImpl<KylinPerforma
     public boolean changeSysDamai(List<SysDamaiParam> params) {
         try {
             LocalDateTime updatedAt = LocalDateTime.now();
-            String performancesId="";
+            String performancesId = "";
             for (SysDamaiParam item : params) {
                 if (item.getStatus() != 0 && item.getStatus() != 1) {
                     return false;
@@ -537,7 +538,7 @@ public class KylinPerformancesAdminServiceImpl extends ServiceImpl<KylinPerforma
                     ticketStatus.setSyncDamai(item.getStatus());
                     ticketStatusMapper.update(ticketStatus, new UpdateWrapper<KylinTicketStatus>().eq("ticket_id", item.getId()));
                 } else if (item.getType().equals("performance")) {
-                    performancesId=item.getId();
+                    performancesId = item.getId();
                     KylinPerformanceStatus performanceStatus = new KylinPerformanceStatus();
                     performanceStatus.setUpdatedAt(updatedAt);
                     performanceStatus.setSyncDamai(item.getStatus());

liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/kylin/utils/PerformanceVoUtils.java

@@ -356,7 +356,6 @@ public class PerformanceVoUtils {
                         dataUtils.setSurplusExchange(tickets.getTicketsId(), ticketStatus.getSurplusExchange());
                         dataUtils.setSurplusGeneral(tickets.getTicketsId(), ticketStatus.getSurplusGeneral());
 
-
                         BasicDBObject objectTicketVo = new BasicDBObject("$set", mongoConverter.convertToMongoType(map));
                         mongoTemplate.getCollection(KylinTicketPartnerVo.class.getSimpleName()).updateOne(
                                 Query.query(Criteria.where("ticketsId").is(ticketItem.getTicketsId())).getQueryObject(),

liquidnet-bus-service/liquidnet-service-consumer/src/main/java/com/liquidnet/service/consumer/service/processor/ConsumerProcessor.java

@@ -118,8 +118,6 @@ public class ConsumerProcessor {
         log.info("===   CONSUMER_ORDER_CREATE   ===");
         this.consumerSqlDaoHandler(msg, channel);
     }
-
-    // 订单创建
     @RabbitListener(bindings = @QueueBinding(
             exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CREADE), key = MQConst.ROUTING_KEY_SQL_ORDER_CREATE,
             value = @Queue(MQConst.QUEUES_SQL_ORDER_CREATE)
@@ -128,8 +126,6 @@ public class ConsumerProcessor {
         log.info("===   CONSUMER_ORDER_CREATE   ===");
         this.consumerSqlDaoHandler(msg, channel);
     }
-
-    // 订单创建
     @RabbitListener(bindings = @QueueBinding(
             exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CREADE), key = MQConst.ROUTING_KEY_SQL_ORDER_CREATE,
             value = @Queue(MQConst.QUEUES_SQL_ORDER_CREATE)
@@ -138,8 +134,6 @@ public class ConsumerProcessor {
         log.info("===   CONSUMER_ORDER_CREATE   ===");
         this.consumerSqlDaoHandler(msg, channel);
     }
-
-    // 订单创建
     @RabbitListener(bindings = @QueueBinding(
             exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CREADE), key = MQConst.ROUTING_KEY_SQL_ORDER_CREATE,
             value = @Queue(MQConst.QUEUES_SQL_ORDER_CREATE)
@@ -148,8 +142,6 @@ public class ConsumerProcessor {
         log.info("===   CONSUMER_ORDER_CREATE   ===");
         this.consumerSqlDaoHandler(msg, channel);
     }
-
-    // 订单创建
     @RabbitListener(bindings = @QueueBinding(
             exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CREADE), key = MQConst.ROUTING_KEY_SQL_ORDER_CREATE,
             value = @Queue(MQConst.QUEUES_SQL_ORDER_CREATE)
@@ -158,6 +150,46 @@ public class ConsumerProcessor {
         log.info("===   CONSUMER_ORDER_CREATE   ===");
         this.consumerSqlDaoHandler(msg, channel);
     }
+    @RabbitListener(bindings = @QueueBinding(
+            exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CREADE), key = MQConst.ROUTING_KEY_SQL_ORDER_CREATE,
+            value = @Queue(MQConst.QUEUES_SQL_ORDER_CREATE)
+    ))
+    public void consumerOrderCreate5(Message msg, Channel channel) {
+        log.info("===   CONSUMER_ORDER_CREATE   ===");
+        this.consumerSqlDaoHandler(msg, channel);
+    }
+    @RabbitListener(bindings = @QueueBinding(
+            exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CREADE), key = MQConst.ROUTING_KEY_SQL_ORDER_CREATE,
+            value = @Queue(MQConst.QUEUES_SQL_ORDER_CREATE)
+    ))
+    public void consumerOrderCreate6(Message msg, Channel channel) {
+        log.info("===   CONSUMER_ORDER_CREATE   ===");
+        this.consumerSqlDaoHandler(msg, channel);
+    }
+    @RabbitListener(bindings = @QueueBinding(
+            exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CREADE), key = MQConst.ROUTING_KEY_SQL_ORDER_CREATE,
+            value = @Queue(MQConst.QUEUES_SQL_ORDER_CREATE)
+    ))
+    public void consumerOrderCreate7(Message msg, Channel channel) {
+        log.info("===   CONSUMER_ORDER_CREATE   ===");
+        this.consumerSqlDaoHandler(msg, channel);
+    }
+    @RabbitListener(bindings = @QueueBinding(
+            exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CREADE), key = MQConst.ROUTING_KEY_SQL_ORDER_CREATE,
+            value = @Queue(MQConst.QUEUES_SQL_ORDER_CREATE)
+    ))
+    public void consumerOrderCreate8(Message msg, Channel channel) {
+        log.info("===   CONSUMER_ORDER_CREATE   ===");
+        this.consumerSqlDaoHandler(msg, channel);
+    }
+    @RabbitListener(bindings = @QueueBinding(
+            exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CREADE), key = MQConst.ROUTING_KEY_SQL_ORDER_CREATE,
+            value = @Queue(MQConst.QUEUES_SQL_ORDER_CREATE)
+    ))
+    public void consumerOrderCreate9(Message msg, Channel channel) {
+        log.info("===   CONSUMER_ORDER_CREATE   ===");
+        this.consumerSqlDaoHandler(msg, channel);
+    }
 
     // 订单再次支付
     @RabbitListener(bindings = @QueueBinding(
@@ -178,7 +210,6 @@ public class ConsumerProcessor {
         log.info("===   CONSUMER_ORDER_CLOSE   ===");
         this.consumerSqlDaoHandler(msg, channel);
     }
-    // 订单关闭
     @RabbitListener(bindings = @QueueBinding(
             exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CLOSE), key = MQConst.ROUTING_KEY_SQL_ORDER_CLOSE,
             value = @Queue(MQConst.QUEUES_SQL_ORDER_CLOSE)
@@ -187,7 +218,6 @@ public class ConsumerProcessor {
         log.info("===   CONSUMER_ORDER_CLOSE   ===");
         this.consumerSqlDaoHandler(msg, channel);
     }
-    // 订单关闭
     @RabbitListener(bindings = @QueueBinding(
             exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CLOSE), key = MQConst.ROUTING_KEY_SQL_ORDER_CLOSE,
             value = @Queue(MQConst.QUEUES_SQL_ORDER_CLOSE)
@@ -196,7 +226,6 @@ public class ConsumerProcessor {
         log.info("===   CONSUMER_ORDER_CLOSE   ===");
         this.consumerSqlDaoHandler(msg, channel);
     }
-    // 订单关闭
     @RabbitListener(bindings = @QueueBinding(
             exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CLOSE), key = MQConst.ROUTING_KEY_SQL_ORDER_CLOSE,
             value = @Queue(MQConst.QUEUES_SQL_ORDER_CLOSE)
@@ -205,7 +234,6 @@ public class ConsumerProcessor {
         log.info("===   CONSUMER_ORDER_CLOSE   ===");
         this.consumerSqlDaoHandler(msg, channel);
     }
-    // 订单关闭
     @RabbitListener(bindings = @QueueBinding(
             exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CLOSE), key = MQConst.ROUTING_KEY_SQL_ORDER_CLOSE,
             value = @Queue(MQConst.QUEUES_SQL_ORDER_CLOSE)
@@ -213,7 +241,7 @@ public class ConsumerProcessor {
     public void consumerOrderClose4(Message msg, Channel channel) {
         log.info("===   CONSUMER_ORDER_CLOSE   ===");
         this.consumerSqlDaoHandler(msg, channel);
-    }// 订单关闭
+    }
     @RabbitListener(bindings = @QueueBinding(
             exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CLOSE), key = MQConst.ROUTING_KEY_SQL_ORDER_CLOSE,
             value = @Queue(MQConst.QUEUES_SQL_ORDER_CLOSE)
@@ -222,6 +250,38 @@ public class ConsumerProcessor {
         log.info("===   CONSUMER_ORDER_CLOSE   ===");
         this.consumerSqlDaoHandler(msg, channel);
     }
+    @RabbitListener(bindings = @QueueBinding(
+            exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CLOSE), key = MQConst.ROUTING_KEY_SQL_ORDER_CLOSE,
+            value = @Queue(MQConst.QUEUES_SQL_ORDER_CLOSE)
+    ))
+    public void consumerOrderClose6(Message msg, Channel channel) {
+        log.info("===   CONSUMER_ORDER_CLOSE   ===");
+        this.consumerSqlDaoHandler(msg, channel);
+    }
+    @RabbitListener(bindings = @QueueBinding(
+            exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CLOSE), key = MQConst.ROUTING_KEY_SQL_ORDER_CLOSE,
+            value = @Queue(MQConst.QUEUES_SQL_ORDER_CLOSE)
+    ))
+    public void consumerOrderClose7(Message msg, Channel channel) {
+        log.info("===   CONSUMER_ORDER_CLOSE   ===");
+        this.consumerSqlDaoHandler(msg, channel);
+    }
+    @RabbitListener(bindings = @QueueBinding(
+            exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CLOSE), key = MQConst.ROUTING_KEY_SQL_ORDER_CLOSE,
+            value = @Queue(MQConst.QUEUES_SQL_ORDER_CLOSE)
+    ))
+    public void consumerOrderClose8(Message msg, Channel channel) {
+        log.info("===   CONSUMER_ORDER_CLOSE   ===");
+        this.consumerSqlDaoHandler(msg, channel);
+    }
+    @RabbitListener(bindings = @QueueBinding(
+            exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CLOSE), key = MQConst.ROUTING_KEY_SQL_ORDER_CLOSE,
+            value = @Queue(MQConst.QUEUES_SQL_ORDER_CLOSE)
+    ))
+    public void consumerOrderClose9(Message msg, Channel channel) {
+        log.info("===   CONSUMER_ORDER_CLOSE   ===");
+        this.consumerSqlDaoHandler(msg, channel);
+    }
 
 
     // 订单支付
@@ -233,6 +293,81 @@ public class ConsumerProcessor {
         log.info("===   CONSUMER_ORDER_PAY   ===");
         this.consumerSqlDaoHandler(msg, channel);
     }
+    @RabbitListener(bindings = @QueueBinding(
+            exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_PAY), key = MQConst.ROUTING_KEY_SQL_ORDER_PAY,
+            value = @Queue(MQConst.QUEUES_SQL_ORDER_PAY)
+    ))
+    public void consumerOrderPay1(Message msg, Channel channel) {
+        log.info("===   CONSUMER_ORDER_PAY   ===");
+        this.consumerSqlDaoHandler(msg, channel);
+    }
+    @RabbitListener(bindings = @QueueBinding(
+            exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_PAY), key = MQConst.ROUTING_KEY_SQL_ORDER_PAY,
+            value = @Queue(MQConst.QUEUES_SQL_ORDER_PAY)
+    ))
+    public void consumerOrderPay2(Message msg, Channel channel) {
+        log.info("===   CONSUMER_ORDER_PAY   ===");
+        this.consumerSqlDaoHandler(msg, channel);
+    }
+    @RabbitListener(bindings = @QueueBinding(
+            exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_PAY), key = MQConst.ROUTING_KEY_SQL_ORDER_PAY,
+            value = @Queue(MQConst.QUEUES_SQL_ORDER_PAY)
+    ))
+    public void consumerOrderPay3(Message msg, Channel channel) {
+        log.info("===   CONSUMER_ORDER_PAY   ===");
+        this.consumerSqlDaoHandler(msg, channel);
+    }
+    @RabbitListener(bindings = @QueueBinding(
+            exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_PAY), key = MQConst.ROUTING_KEY_SQL_ORDER_PAY,
+            value = @Queue(MQConst.QUEUES_SQL_ORDER_PAY)
+    ))
+    public void consumerOrderPay4(Message msg, Channel channel) {
+        log.info("===   CONSUMER_ORDER_PAY   ===");
+        this.consumerSqlDaoHandler(msg, channel);
+    }
+    @RabbitListener(bindings = @QueueBinding(
+            exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_PAY), key = MQConst.ROUTING_KEY_SQL_ORDER_PAY,
+            value = @Queue(MQConst.QUEUES_SQL_ORDER_PAY)
+    ))
+    public void consumerOrderPay5(Message msg, Channel channel) {
+        log.info("===   CONSUMER_ORDER_PAY   ===");
+        this.consumerSqlDaoHandler(msg, channel);
+    }
+    @RabbitListener(bindings = @QueueBinding(
+            exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_PAY), key = MQConst.ROUTING_KEY_SQL_ORDER_PAY,
+            value = @Queue(MQConst.QUEUES_SQL_ORDER_PAY)
+    ))
+    public void consumerOrderPay6(Message msg, Channel channel) {
+        log.info("===   CONSUMER_ORDER_PAY   ===");
+        this.consumerSqlDaoHandler(msg, channel);
+    }
+    @RabbitListener(bindings = @QueueBinding(
+            exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_PAY), key = MQConst.ROUTING_KEY_SQL_ORDER_PAY,
+            value = @Queue(MQConst.QUEUES_SQL_ORDER_PAY)
+    ))
+    public void consumerOrderPay7(Message msg, Channel channel) {
+        log.info("===   CONSUMER_ORDER_PAY   ===");
+        this.consumerSqlDaoHandler(msg, channel);
+    }
+    @RabbitListener(bindings = @QueueBinding(
+            exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_PAY), key = MQConst.ROUTING_KEY_SQL_ORDER_PAY,
+            value = @Queue(MQConst.QUEUES_SQL_ORDER_PAY)
+    ))
+    public void consumerOrderPay8(Message msg, Channel channel) {
+        log.info("===   CONSUMER_ORDER_PAY   ===");
+        this.consumerSqlDaoHandler(msg, channel);
+    }@RabbitListener(bindings = @QueueBinding(
+            exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_PAY), key = MQConst.ROUTING_KEY_SQL_ORDER_PAY,
+            value = @Queue(MQConst.QUEUES_SQL_ORDER_PAY)
+    ))
+    public void consumerOrderPay9(Message msg, Channel channel) {
+        log.info("===   CONSUMER_ORDER_PAY   ===");
+        this.consumerSqlDaoHandler(msg, channel);
+    }
+    @RabbitListener(bindings = @QueueBinding(
+            exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_PAY), key = MQConst.ROUTING_KEY_SQL_ORDER_PAY,
+            value = @Queue(MQConst.QUEUES_SQL_ORDER_PAY)
+    ))
 
     // 缺票登记
     @RabbitListener(bindings = @QueueBinding(

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

@@ -296,7 +296,7 @@ public class KylinTicketsPartnerServiceImpl extends ServiceImpl<KylinTicketsMapp
             LocalDateTime createdAt = LocalDateTime.now();
 
             PerformancePartnerVo performancePartnerVo = mongoTemplate.findOne(Query.query(Criteria.where("performancesId").is(performanceId)), PerformancePartnerVo.class, PerformancePartnerVo.class.getSimpleName());
-            if(performancePartnerVo.getAuditStatus()==1){
+            if(performancePartnerVo.getAuditStatus()==0){
                 return ResponseDto.failure(ErrorMapping.get(20107));
             }
 

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

@@ -95,7 +95,7 @@ public class PerformanceVoTask {
         List<String> performanceIdList = new ArrayList<>();
 
         if (performanceSingleId == null) {
-            List<KylinPerformanceStatus> list = performanceStatusMapper.selectList(new UpdateWrapper<KylinPerformanceStatus>().in("status", 6,8,9));
+            List<KylinPerformanceStatus> list = performanceStatusMapper.selectList(new UpdateWrapper<KylinPerformanceStatus>().in("status", 6, 8, 9));
             for (KylinPerformanceStatus item : list) {
                 performanceIdList.add(item.getPerformanceId());
             }
@@ -146,7 +146,7 @@ public class PerformanceVoTask {
                         }
                     }
 
-                    if(kylinTicketVoItem.getStatus()==7){
+                    if (kylinTicketVoItem.getStatus() == 7) {
                         status = 7;
                     }
 
@@ -171,18 +171,18 @@ public class PerformanceVoTask {
                     }
                 }
             }
-            if(vo.getAppStatus()<=4){
-                appStatus=vo.getAppStatus();
+            if (vo.getAppStatus() <= 4) {
+                appStatus = vo.getAppStatus();
             }
-            if(vo.getAppStatus()==7){
-                appStatus=7;
+            if (vo.getAppStatus() == 7) {
+                appStatus = 7;
             }
             //修改演出状态
             KylinPerformanceStatus changeStatus = new KylinPerformanceStatus();
             changeStatus.setStatus(appStatus);
-            performanceStatusMapper.update(changeStatus,new UpdateWrapper<KylinPerformanceStatus>().eq("performance_id",performancesId));
+            performanceStatusMapper.update(changeStatus, new UpdateWrapper<KylinPerformanceStatus>().eq("performance_id", performancesId));
             vo.setAppStatus(appStatus);
-            dataUtils.updatePerformanceMongo(performancesId,vo);
+            dataUtils.updatePerformanceMongo(performancesId, vo);
         }
     }
 
@@ -361,6 +361,9 @@ public class PerformanceVoTask {
                     ticketStatusMapper.insert(ticketStatus);
                     ticketRelationsMapper.delete(new UpdateWrapper<KylinTicketRelations>().eq("ticket_id", ticketRelations.getTicketId()));
                     ticketRelationsMapper.insert(ticketRelations);
+
+                    dataUtils.setSurplusExchange(tickets.getTicketsId(), ticketStatus.getSurplusExchange());
+                    dataUtils.setSurplusGeneral(tickets.getTicketsId(), ticketStatus.getSurplusGeneral());
                 }
             }
         } catch (Exception e) {
@@ -369,42 +372,42 @@ public class PerformanceVoTask {
     }
 
 
-    public boolean judgeIsAudit(String performanceId){
+    public boolean judgeIsAudit(String performanceId) {
         KylinPerformanceMisVo misVo = getPerformanceMisVo(performanceId);
         KylinPerformanceVo mongoVo = mongoVoUtils.combinePerformanceVoData(performanceId);
-        if(!misVo.getTitle().equals(mongoVo.getTitle())){
+        if (!misVo.getTitle().equals(mongoVo.getTitle())) {
             return true;
-        }else if(!misVo.getType().equals(mongoVo.getType())){
+        } else if (!misVo.getType().equals(mongoVo.getType())) {
             return true;
-        }else if(!misVo.getTimeStart().equals(mongoVo.getTimeStart())){
+        } else if (!misVo.getTimeStart().equals(mongoVo.getTimeStart())) {
             return true;
-        }else if(!misVo.getTimeEnd().equals(mongoVo.getTimeEnd())){
+        } else if (!misVo.getTimeEnd().equals(mongoVo.getTimeEnd())) {
             return true;
-        }else if(!misVo.getFieldId().equals(mongoVo.getFieldId())){
+        } else if (!misVo.getFieldId().equals(mongoVo.getFieldId())) {
             return true;
-        }else if(!misVo.getNotice().equals(mongoVo.getNotice())){
+        } else if (!misVo.getNotice().equals(mongoVo.getNotice())) {
             return true;
-        }else if(!misVo.getDetails().equals(mongoVo.getDetails())){
+        } else if (!misVo.getDetails().equals(mongoVo.getDetails())) {
             return true;
-        }else if(!misVo.getApprovalUrl().equals(mongoVo.getApprovalUrl())){
+        } else if (!misVo.getApprovalUrl().equals(mongoVo.getApprovalUrl())) {
             return true;
-        }else if(!misVo.getPayCountdownMinute().equals(mongoVo.getPayCountdownMinute())){
+        } else if (!misVo.getPayCountdownMinute().equals(mongoVo.getPayCountdownMinute())) {
             return true;
-        }else if(!misVo.getLimitCount().equals(mongoVo.getLimitCount())){
+        } else if (!misVo.getLimitCount().equals(mongoVo.getLimitCount())) {
             return true;
-        } else if(!misVo.getIsTrueName().equals(mongoVo.getIsTrueName())){
+        } else if (!misVo.getIsTrueName().equals(mongoVo.getIsTrueName())) {
             return true;
         }
 
-        boolean exists = mongoTemplate.exists(Query.query(Criteria.where("status").is("-1").and("performancesId").is(performanceId)),KylinTicketTimesPartnerVo.class,KylinTicketTimesPartnerVo.class.getSimpleName());
-        if(exists){
+        boolean exists = mongoTemplate.exists(Query.query(Criteria.where("status").is("-1").and("performancesId").is(performanceId)), KylinTicketTimesPartnerVo.class, KylinTicketTimesPartnerVo.class.getSimpleName());
+        if (exists) {
             return true;
         }
 
-        for (int i = 0;i<misVo.getTicketTimes().size();i++){
+        for (int i = 0; i < misVo.getTicketTimes().size(); i++) {
             TicketTimesTicketCreatePartnerVo times = misVo.getTicketTimes().get(i);
-            boolean exists2 = mongoTemplate.exists(Query.query(Criteria.where("status").is("-2").and("timesId").is(times.getTicketTimesId())),KylinTicketPartnerVo.class,KylinTicketPartnerVo.class.getSimpleName());
-            if(exists2){
+            boolean exists2 = mongoTemplate.exists(Query.query(Criteria.where("status").is("-2").and("timesId").is(times.getTicketTimesId())), KylinTicketPartnerVo.class, KylinTicketPartnerVo.class.getSimpleName());
+            if (exists2) {
                 return true;
             }
         }