修改 sql

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

@@ -209,60 +209,65 @@ public class TempServiceImpl implements IKylinTempService {
     @Override
     public ResponseDto<List<CheckData>> checkTicket(String performance_id, String idcode, String remarks, String[] ticket_ids, String check_time) {
         List<CheckData> voList = ObjectUtil.checkDataArrayList();
-        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)) {
-                CheckData vo = CheckData.getNew();
-                vo.setCheck_status(entitiesVo.getStatus());
-                vo.setCheck_time(entitiesVo.getCheckedAt());
-                vo.setEnter_idcode(entitiesVo.getEnterIdCode());
-                vo.setEnter_mobile(entitiesVo.getEnterMobile());
-                vo.setEnter_name(entitiesVo.getEnterName());
-                vo.setTicket_id(entitiesVo.getTicketId());
-                vo.setTicket_name(entitiesVo.getTicketTitle());
-                vo.setTicket_count(1);
-                vo.setTicket_entity_id("");
-                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.setSelect_status(false);
+        try {
+            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)) {
+                    CheckData vo = CheckData.getNew();
+                    vo.setCheck_status(entitiesVo.getStatus());
+                    vo.setCheck_time(entitiesVo.getCheckedAt());
+                    vo.setEnter_idcode(entitiesVo.getEnterIdCode());
+                    vo.setEnter_mobile(entitiesVo.getEnterMobile());
+                    vo.setEnter_name(entitiesVo.getEnterName());
+                    vo.setTicket_id(entitiesVo.getTicketId());
+                    vo.setTicket_name(entitiesVo.getTicketTitle());
+                    vo.setTicket_count(1);
+                    vo.setTicket_entity_id("");
+                    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.setSelect_status(false);
 
-                KylinPerformanceVo performanceData = dataUtils.getPerformanceVo(performance_id);
-                for (int x = 0; x < performanceData.getTicketTimeList().size(); x++) {
-                    KylinTicketTimesVo timeItem = performanceData.getTicketTimeList().get(x);
-                    for (int y = 0; y < timeItem.getTicketList().size(); y++) {
-                        KylinTicketVo ticketItem = timeItem.getTicketList().get(y);
-                        if (ticketItem.getTicketsId().equals(entitiesVo.getTicketId())) {
-                            vo.setTicket_price(ticketItem.getPrice().toString());
-                            break;
+                    KylinPerformanceVo performanceData = dataUtils.getPerformanceVo(performance_id);
+                    for (int x = 0; x < performanceData.getTicketTimeList().size(); x++) {
+                        KylinTicketTimesVo timeItem = performanceData.getTicketTimeList().get(x);
+                        for (int y = 0; y < timeItem.getTicketList().size(); y++) {
+                            KylinTicketVo ticketItem = timeItem.getTicketList().get(y);
+                            if (ticketItem.getTicketsId().equals(entitiesVo.getTicketId())) {
+                                vo.setTicket_price(ticketItem.getPrice().toString());
+                                break;
+                            }
                         }
                     }
+                    voList.add(vo);
                 }
-                voList.add(vo);
             }
-        }
 
-        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();
-            Document updateDoc = new Document("status", 1)
-                    .append("checkClient", "PDA")
-                    .append("updatedAt", check_time)
-                    .append("checkType", "PDA")
-                    .append("checkedAt", check_time)
-                    .append("checkUserId", "PDA");
-            list.add(new UpdateOneModel<>(updateQuery, new Document("$set", updateDoc)));
-        });
-        BulkWriteResult bulkWriteResult = mongoTemplate.getCollection(KylinOrderTicketEntitiesVo.class.getSimpleName()).bulkWrite(list);
-        if (bulkWriteResult.getModifiedCount() > 0) {
-            queueUtils.sendMsgByRedis(MQConst.KylinQueue.SQL_STATION.getKey(),
-                    SqlMapping.get("kylin_order_ticket_entities.update_status_bystation_pad", paramsList));
-        } else {
-            return ResponseDto.success();
+            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();
+                Document updateDoc = new Document("status", 1)
+                        .append("checkClient", "PDA")
+                        .append("updatedAt", check_time)
+                        .append("checkType", "PDA")
+                        .append("checkedAt", check_time)
+                        .append("checkUserId", "PDA");
+                list.add(new UpdateOneModel<>(updateQuery, new Document("$set", updateDoc)));
+            });
+            BulkWriteResult bulkWriteResult = mongoTemplate.getCollection(KylinOrderTicketEntitiesVo.class.getSimpleName()).bulkWrite(list);
+            if (bulkWriteResult.getModifiedCount() > 0) {
+                queueUtils.sendMsgByRedis(MQConst.KylinQueue.SQL_STATION.getKey(),
+                        SqlMapping.get("kylin_order_ticket_entities.update_status_bystation_pad", paramsList));
+            } else {
+                return ResponseDto.success();
+            }
+            return ResponseDto.success(voList);
+        }catch (Exception e){
+            e.printStackTrace();
+            return ResponseDto.success(voList);
         }
-        return ResponseDto.success(voList);
     }
 }