修改 pda

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

@@ -173,7 +173,7 @@ public class TempServiceImpl implements IKylinTempService {
         List<KylinOrderTicketEntitiesVo> dataList = mongoTemplate.find(Query.query(Criteria.where("performanceId").is(performance_id).and("ticketId").in(ticket_ids).and("enterIdCode").is(idcode))
                 , KylinOrderTicketEntitiesVo.class, KylinOrderTicketEntitiesVo.class.getSimpleName());
         for (KylinOrderTicketEntitiesVo entitiesVo : dataList) {
-            if (entitiesVo.getEnterIdCode().equals(idcode)) {
+            if (entitiesVo.getEnterIdCode().equals(idcode) && entitiesVo.getIsPayment() == 1) {
                 CheckData vo = CheckData.getNew();
                 vo.setCheck_status(entitiesVo.getStatus());
                 vo.setCheck_time(entitiesVo.getCheckedAt());
@@ -213,7 +213,7 @@ public class TempServiceImpl implements IKylinTempService {
             List<KylinOrderTicketEntitiesVo> dataList = mongoTemplate.find(Query.query(Criteria.where("performanceId").is(performance_id).and("ticketId").in(ticket_ids).and("enterIdCode").is(idcode))
                     , KylinOrderTicketEntitiesVo.class, KylinOrderTicketEntitiesVo.class.getSimpleName());
             for (KylinOrderTicketEntitiesVo entitiesVo : dataList) {
-                if (entitiesVo.getEnterIdCode().equals(idcode)) {
+                if (entitiesVo.getEnterIdCode().equals(idcode) && entitiesVo.getIsPayment() == 1) {
                     CheckData vo = CheckData.getNew();
                     vo.setCheck_status(entitiesVo.getStatus());
                     vo.setCheck_time(entitiesVo.getCheckedAt());
@@ -227,6 +227,7 @@ public class TempServiceImpl implements IKylinTempService {
                     vo.setTicket_use_end(entitiesVo.getUseEnd());
                     vo.setTicket_use_start(entitiesVo.getUseStart());
                     vo.setTicket_type(vo.getTicket_use_end().equalsIgnoreCase(vo.getTicket_use_start()) ? 1 : 0);
+                    vo.setTicket_entity_id(entitiesVo.getOrderTicketEntitiesId());
                     vo.setSelect_status(false);
 
                     KylinPerformanceVo performanceData = dataUtils.getPerformanceVo(performance_id);
@@ -247,8 +248,8 @@ public class TempServiceImpl implements IKylinTempService {
             List<WriteModel<Document>> list = ObjectUtil.getWriteModelDocumentArrayList();
             LinkedList<Object[]> paramsList = CollectionUtil.linkedListObjectArr();
             voList.forEach(r -> {
-                paramsList.add(new Object[]{1, "PDA" + "PDA", LocalDateTime.now(), r.getTicket_entity_id(), remarks});
-                Document updateQuery = Query.query(Criteria.where("performanceId").is(performance_id).and("ticketId").in(ticket_ids).and("enterIdCode").is(idcode)).getQueryObject();
+                paramsList.add(new Object[]{1, "PDA" + "PDA", LocalDateTime.now(), remarks, r.getTicket_entity_id(),});
+                Document updateQuery = Query.query(Criteria.where("orderTicketEntitiesId").in(r.getTicket_entity_id())).getQueryObject();
                 Document updateDoc = new Document("status", 1)
                         .append("checkClient", "PDA")
                         .append("updatedAt", check_time)