众安修改更新订单逻辑

tenant/insurance/quotation-zhongan/src/main/java/com/jzg/quotation/zhongan/crawler/entity/response/ZhongAnCrawlerPolicyListResponse.java

@@ -34,7 +34,7 @@ public class ZhongAnCrawlerPolicyListResponse extends ZhongAnCrawlerBaseResponse
             @JsonProperty("maxPage")
             private Integer maxPage;
             @JsonProperty("policyLists")
-            private List<policyListsDto> policyLists;
+            private List<List<policyListsDto>> policyLists;
 
             @NoArgsConstructor
             @Data

tenant/insurance/quotation-zhongan/src/main/java/com/jzg/quotation/zhongan/crawler/service/Impl/ZhongAnCrawlerRequestImpl.java

@@ -569,60 +569,52 @@ public class ZhongAnCrawlerRequestImpl implements ZhongAnCrawlerRequest {
         if (!response.getSuccess()) {
             throw new SystemException(response.getErrorMsg());
         } else {
-            List<ZhongAnCrawlerPolicyListResponse.ValueDTO.DatasDTO.policyListsDto> policyLists = response.getValue().getDatas().getPolicyLists();
+            List<List<ZhongAnCrawlerPolicyListResponse.ValueDTO.DatasDTO.policyListsDto>> policyLists = response.getValue().getDatas().getPolicyLists();
             // 根据订单号获取记录
             String orderNo = zhongAnCrawlerOrder.getOrderNo();
             if (policyLists.size() > 0) {
-                for (ZhongAnCrawlerPolicyListResponse.ValueDTO.DatasDTO.policyListsDto policy : policyLists) {
-                    // 匹配当前订单号
-                    if (orderNo.equals(policy.getOrderNo())) {
-                        if (policy.getInsureTypeCode().equals("2")) {
-                            orderStatusResultVo.setJqApplyNo(policy.getApplyNo());
-                        } else if (policy.getInsureTypeCode().equals("1")) {
-                            orderStatusResultVo.setSyApplyNo(policy.getApplyNo());
-                        }
-                        if (StrUtil.isNotBlank(policy.getManualAuditStatus())) {
-                            // 人工审核通过 待支付
-                            if ("1".equals(policy.getManualAuditStatus()) || "3".equals(policy.getManualAuditStatus()) || "4".equals(policy.getManualAuditStatus())) {
-                                orderStatusResultVo.setOrderStatus(InsOrderStatusEnum.PAY_PENDING);
+                for (List<ZhongAnCrawlerPolicyListResponse.ValueDTO.DatasDTO.policyListsDto> policy : policyLists) {
+                    for (ZhongAnCrawlerPolicyListResponse.ValueDTO.DatasDTO.policyListsDto policyDTO : policy) {
+                        // 匹配当前订单号
+                        if (orderNo.equals(policyDTO.getOrderNo())) {
+                            if (policyDTO.getInsureTypeCode().equals("2")) {
+                                orderStatusResultVo.setJqApplyNo(policyDTO.getApplyNo());
+                            } else if (policyDTO.getInsureTypeCode().equals("1")) {
+                                orderStatusResultVo.setSyApplyNo(policyDTO.getApplyNo());
                             }
-                            // 质检中
-                            if ("2".equals(policy.getManualAuditStatus())) {
-                                orderStatusResultVo.setOrderStatus(InsOrderStatusEnum.STAFF_PROCESS);
+                            if (StrUtil.isNotBlank(policyDTO.getManualAuditStatus())) {
+                                // 人工审核通过 待支付
+                                if ("1".equals(policyDTO.getManualAuditStatus()) || "3".equals(policyDTO.getManualAuditStatus()) || "4".equals(policyDTO.getManualAuditStatus())) {
+                                    orderStatusResultVo.setOrderStatus(InsOrderStatusEnum.PAY_PENDING);
+                                }
+                                // 质检中
+                                if ("2".equals(policyDTO.getManualAuditStatus())) {
+                                    orderStatusResultVo.setOrderStatus(InsOrderStatusEnum.STAFF_PROCESS);
+                                }
                             }
-                        }
-                        // 人工核保
-                        if (StrUtil.isNotBlank(policy.getGreenQuoteStatus())) {
-                            if ("3".equals(policy.getGreenQuoteStatus())) {
-                                orderStatusResultVo.setOrderStatus(InsOrderStatusEnum.AUDIT_FAIL);
-                                // 查看退回原因
-                                ZhongAnCrawlerQueryAccommodationRequest queryAccommodationRequest = new ZhongAnCrawlerQueryAccommodationRequest(zhongAnCrawlerOrder.getQuoteId(), parameters);
-                                ZhongAnCrawlerQueryAccommodationResponse queryAccommodationResponse = zhongAnCrawlerRequestComponent.queryAccommodation(queryAccommodationRequest, headers);
-                                if (queryAccommodationResponse.getSuccess()) {
-                                    ZhongAnCrawlerQueryAccommodationResponse.ValueDTO.DatasDTO.AccommodationDTO accommodationDTO = queryAccommodationResponse.getValue().getDatas().getAccommodation();
-                                    if (accommodationDTO.getErrorCode() != null) {
-                                        orderStatusResultVo.setOrderStatusStr(JSONObject.toJSONString(accommodationDTO.getErrorCode()));
-                                        orderStatusResultVo.setOrderStatus(InsOrderStatusEnum.AUDIT_FAIL);
+                            // 人工核保
+                            if (StrUtil.isNotBlank(policyDTO.getGreenQuoteStatus())) {
+                                if ("3".equals(policyDTO.getGreenQuoteStatus())) {
+                                    orderStatusResultVo.setOrderStatus(InsOrderStatusEnum.AUDIT_FAIL);
+                                    // 查看退回原因
+                                    ZhongAnCrawlerQueryAccommodationRequest queryAccommodationRequest = new ZhongAnCrawlerQueryAccommodationRequest(zhongAnCrawlerOrder.getQuoteId(), parameters);
+                                    ZhongAnCrawlerQueryAccommodationResponse queryAccommodationResponse = zhongAnCrawlerRequestComponent.queryAccommodation(queryAccommodationRequest, headers);
+                                    if (queryAccommodationResponse.getSuccess()) {
+                                        ZhongAnCrawlerQueryAccommodationResponse.ValueDTO.DatasDTO.AccommodationDTO accommodationDTO = queryAccommodationResponse.getValue().getDatas().getAccommodation();
+                                        if (accommodationDTO.getErrorCode() != null) {
+                                            orderStatusResultVo.setOrderStatusStr(JSONObject.toJSONString(accommodationDTO.getErrorCode()));
+                                            orderStatusResultVo.setOrderStatus(InsOrderStatusEnum.AUDIT_FAIL);
+                                        }
                                     }
                                 }
-                            }
-                            //
-                            if ("0".equals(policy.getGreenQuoteStatus())) {
-                                // 查看退回原因
-                                ZhongAnCrawlerQueryAccommodationRequest queryAccommodationRequest = new ZhongAnCrawlerQueryAccommodationRequest(zhongAnCrawlerOrder.getQuoteId(), parameters);
-                                ZhongAnCrawlerQueryAccommodationResponse queryAccommodationResponse = zhongAnCrawlerRequestComponent.queryAccommodation(queryAccommodationRequest, headers);
-                                Long id = queryAccommodationResponse.getValue().getDatas().getAccommodation().getId();
-                                String identityNo = orderStatusVo.getInsOrdersCarUserInfoList().stream()
-                                        .filter(insOrdersCarUserInfo -> insOrdersCarUserInfo.getPolicyPersonType() == 2)
-                                        .findFirst()
-                                        .map(InsOrdersCarUserInfo::getIdentifyNumber)
-                                        .orElse(null);
-                                // 提交通融
-                                ZhongAnCrawlerApplyAccommodationRequest applyAccommodationRequest = new ZhongAnCrawlerApplyAccommodationRequest(id, zhongAnCrawlerOrder.getQuoteId(), identityNo, zhongAnCrawlerOrder.getOrderNo(), parameters);
-                                ZhongAnCrawlerApplyAccommodationResponse applyAccommodationResponse = zhongAnCrawlerRequestComponent.applyAccommodation(applyAccommodationRequest, headers);
-                                if (applyAccommodationResponse.getSuccess()) {
+                                //
+                                if ("0".equals(policyDTO.getGreenQuoteStatus())) {
+                                    // 查看退回原因
+                                    ZhongAnCrawlerQueryAccommodationRequest queryAccommodationRequest = new ZhongAnCrawlerQueryAccommodationRequest(zhongAnCrawlerOrder.getQuoteId(), parameters);
+                                    ZhongAnCrawlerQueryAccommodationResponse queryAccommodationResponse = zhongAnCrawlerRequestComponent.queryAccommodation(queryAccommodationRequest, headers);
+                                    String errorCode = JSONObject.toJSONString(queryAccommodationResponse.getValue().getDatas().getAccommodation().getErrorCode());
+                                    orderStatusResultVo.setOrderStatusStr(errorCode);
                                     orderStatusResultVo.setOrderStatus(InsOrderStatusEnum.STAFF_PROCESS);
-                                    orderStatusResultVo.setOrderStatusStr("提交通融成功");
                                 }
                             }
                         }
@@ -634,24 +626,26 @@ public class ZhongAnCrawlerRequestImpl implements ZhongAnCrawlerRequest {
                 ZhongAnCrawlerPolicyListRequest policyListPayRequest = new ZhongAnCrawlerPolicyListRequest(licenseNo, parameters, "1");
                 ZhongAnCrawlerPolicyListResponse policyListPayResponse = zhongAnCrawlerRequestComponent.policyList(policyListPayRequest, headers);
                 if (policyListPayResponse.getSuccess()) {
-                    List<ZhongAnCrawlerPolicyListResponse.ValueDTO.DatasDTO.policyListsDto> policyPayLists = response.getValue().getDatas().getPolicyLists();
+                    List<List<ZhongAnCrawlerPolicyListResponse.ValueDTO.DatasDTO.policyListsDto>> policyPayLists = response.getValue().getDatas().getPolicyLists();
                     if (policyPayLists.size() == 0) {
                         orderStatusResultVo.setOrderStatus(InsOrderStatusEnum.ORDER_CLOSE);
                         orderStatusResultVo.setErrorMsg("未查询到订单信息");
                     }
                     if (policyPayLists.size() > 0) {
-                        for (ZhongAnCrawlerPolicyListResponse.ValueDTO.DatasDTO.policyListsDto policy : policyPayLists) {
-                            if (orderNo.equals(policy.getOrderNo())) {
-                                // 保单号
-                                switch (policy.getInsureTypeCode()) {
-                                    case "2" -> orderStatusResultVo.setJqPolicyno(policy.getTpPolicyNo());
-                                    case "1" -> orderStatusResultVo.setSyPolicyno(policy.getTpPolicyNo());
-                                    case "3" -> orderStatusResultVo.setJyPolicyno(policy.getTpPolicyNo());
+                        for (List<ZhongAnCrawlerPolicyListResponse.ValueDTO.DatasDTO.policyListsDto> policy : policyPayLists) {
+                            for (ZhongAnCrawlerPolicyListResponse.ValueDTO.DatasDTO.policyListsDto policyDTO : policy) {
+                                if (orderNo.equals(policyDTO.getOrderNo())) {
+                                    // 保单号
+                                    switch (policyDTO.getInsureTypeCode()) {
+                                        case "2" -> orderStatusResultVo.setJqPolicyno(policyDTO.getTpPolicyNo());
+                                        case "1" -> orderStatusResultVo.setSyPolicyno(policyDTO.getTpPolicyNo());
+                                        case "3" -> orderStatusResultVo.setJyPolicyno(policyDTO.getTpPolicyNo());
+                                    }
+                                    orderStatusResultVo.setOrderStatus(InsOrderStatusEnum.UNDERWRITED);
+                                } else {
+                                    orderStatusResultVo.setOrderStatus(InsOrderStatusEnum.ORDER_CLOSE);
+                                    orderStatusResultVo.setOrderStatusStr("订单不存在,或联系运营查询");
                                 }
-                                orderStatusResultVo.setOrderStatus(InsOrderStatusEnum.UNDERWRITED);
-                            } else {
-                                orderStatusResultVo.setOrderStatus(InsOrderStatusEnum.ORDER_CLOSE);
-                                orderStatusResultVo.setOrderStatusStr("订单不存在,或联系运营查询");
                             }
                         }
                     }