开票配置为是--风控系统跳过存储

clx-performance-web/src/main/java/com/clx/performance/model/settle/SettlementOrderChildRisk.java

@@ -25,7 +25,7 @@ public class SettlementOrderChildRisk implements HasKey<Integer> {
     private String driverMobile;                   // 司机手机号
     private String goodsName;                      // 货物名称
     private Integer invoiceType;                   // 开票标识：1网运单 2普通单
-    private Integer invoiceConfigType;             // 开票配置：0否 2是
+    private Integer invoiceConfigType;             // 开票配置：0否 1是
     private LocalDateTime poundAuditTime;          // 磅单审核通过时间
     private Integer riskType;                      // 风控标识：1同步失败 2结算打回
     private String riskRemark;                     // 风控失败原因

clx-performance-web/src/main/java/com/clx/performance/service/impl/broker/OrderChildBrokerMqHandlerServiceImpl.java

 package com.clx.performance.service.impl.broker;
 
+import com.clx.order.enums.QuotationEnum;
+import com.clx.order.feign.InvoicingCompanyFeign;
 import com.clx.order.feign.OrderFeign;
 import com.clx.order.vo.pc.owner.OwnerQuotationDetailVO;
 import com.clx.performance.dao.OrderChildDao;
@@ -63,6 +65,9 @@ public class OrderChildBrokerMqHandlerServiceImpl implements OrderChildBrokerMqH
     @Autowired
     private QuotationService quotationService;
 
+    @Autowired
+    private InvoicingCompanyFeign invoicingCompanyFeign;
+
     @Transactional(rollbackFor = Exception.class)
     @Override
     public void orderChildSync(BrokerOrderChildSyncMqParam mq) {
@@ -92,8 +97,11 @@ public class OrderChildBrokerMqHandlerServiceImpl implements OrderChildBrokerMqH
             settlementOrderChildRisk.setPoundAuditTime(settlementOwnerDetail.getPoundAuditTime());
             settlementOrderChildRisk.setRiskType(SettlementOrderChildRiskEnum.RiskType.SETTLE_FAIL.getCode());
             settlementOrderChildRisk.setRiskRemark("同步无车承运异常");
-            settlementOrderChildRiskDao.saveEntity(settlementOrderChildRisk);
-
+            // 若开票配置为是
+            if (this.invoiceConfigType(orderChild.getOrderNo())) {
+                settlementOrderChildRiskDao.saveEntity(settlementOrderChildRisk);
+                log.info("当前运单的关联的订单开票配置为是，保存对应封控的信息入库");
+            }
             settlementPostService.riskAdd(settlementOrderChildRisk.getId());
         }
     }
@@ -180,4 +188,19 @@ public class OrderChildBrokerMqHandlerServiceImpl implements OrderChildBrokerMqH
 
     }
 
+    /**
+     * 开票配置为是
+     *
+     * @param orderNo
+     * @return
+     */
+    public boolean invoiceConfigType(String orderNo) {
+        // 调用开票配置接口
+        Integer invoiceConfigType = invoicingCompanyFeign.getInvoicingConfigTypeByOrderNo(orderNo).getData();
+        log.info("notInvoiceConfigType invoiceConfigType:{}", invoiceConfigType);
+        // 若开票配置为否
+        return Objects.nonNull(invoiceConfigType) && Objects.equals(invoiceConfigType,
+                QuotationEnum.InvoicingConfigType.YES.getCode());
+    }
+
 }

clx-performance-web/src/main/java/com/clx/performance/service/impl/settle/SettlementMqHandlerServiceImpl.java

@@ -35,6 +35,7 @@ import com.clx.performance.service.PaymentService;
 import com.clx.performance.service.broker.OrderChildBrokerMqService;
 import com.clx.performance.service.broker.OrderChildBrokerService;
 import com.clx.performance.service.impl.UniqueOrderNumService;
+import com.clx.performance.service.impl.broker.OrderChildBrokerMqHandlerServiceImpl;
 import com.clx.performance.service.settle.*;
 import com.clx.performance.utils.LocalDateTimeUtils;
 import com.clx.performance.utils.RedisUtil;
@@ -158,6 +159,9 @@ public class SettlementMqHandlerServiceImpl implements SettlementMqHandlerServic
     @Autowired
     private SettlementPostService settlementPostService;
 
+    @Autowired
+    private OrderChildBrokerMqHandlerServiceImpl orderChildBrokerMqHandlerService;
+
 
     @Override
     @Transactional(rollbackFor = Exception.class)
@@ -372,7 +376,11 @@ public class SettlementMqHandlerServiceImpl implements SettlementMqHandlerServic
                 settlementOrderChildRisk.setPoundAuditTime(settlementOwnerDetail.getPoundAuditTime());
                 settlementOrderChildRisk.setRiskType(SettlementOrderChildRiskEnum.RiskType.SYNC_FAIL.getCode());
                 settlementOrderChildRisk.setRiskRemark(result.getSyncMsg());
-                settlementOrderChildRiskDao.saveEntity(settlementOrderChildRisk);
+                // 若开票配置为是
+                if (orderChildBrokerMqHandlerService.invoiceConfigType(orderChild.getOrderNo())) {
+                    settlementOrderChildRiskDao.saveEntity(settlementOrderChildRisk);
+                    log.info("settlementMqHandlerServiceImpl invoiceTypeSync 当前运单的关联的订单开票配置为是，保存对应封控的信息入库");
+                }
 
                 settlementPostService.riskAdd(settlementOrderChildRisk.getId());
 
@@ -485,7 +493,12 @@ public class SettlementMqHandlerServiceImpl implements SettlementMqHandlerServic
             settlementOrderChildRisk.setPoundAuditTime(settlementOwnerDetail.getPoundAuditTime());
             settlementOrderChildRisk.setRiskType(SettlementOrderChildRiskEnum.RiskType.SYNC_FAIL.getCode());
             settlementOrderChildRisk.setRiskRemark(result.getSyncMsg());
-            settlementOrderChildRiskDao.saveEntity(settlementOrderChildRisk);
+
+            // 若开票配置为是
+            if (orderChildBrokerMqHandlerService.invoiceConfigType(orderChild.getOrderNo())) {
+                settlementOrderChildRiskDao.saveEntity(settlementOrderChildRisk);
+                log.info("settlementMqHandlerServiceImpl invoiceStatusSync 当前运单的关联的订单开票配置为是，保存对应封控的信息入库");
+            }
 
             settlementPostService.riskAdd(settlementOrderChildRisk.getId());
 
@@ -566,7 +579,12 @@ public class SettlementMqHandlerServiceImpl implements SettlementMqHandlerServic
             settlementOrderChildRisk.setPoundAuditTime(settlementOwnerDetail.getPoundAuditTime());
             settlementOrderChildRisk.setRiskType(SettlementOrderChildRiskEnum.RiskType.SYNC_FAIL.getCode());
             settlementOrderChildRisk.setRiskRemark(result.getSyncMsg());
-            settlementOrderChildRiskDao.saveEntity(settlementOrderChildRisk);
+
+            // 若开票配置为是
+            if (orderChildBrokerMqHandlerService.invoiceConfigType(orderChild.getOrderNo())) {
+                settlementOrderChildRiskDao.saveEntity(settlementOrderChildRisk);
+                log.info("settlementMqHandlerServiceImpl payStatusSync 当前运单的关联的订单开票配置为是，保存对应封控的信息入库");
+            }
 
             settlementPostService.riskAdd(settlementOrderChildRisk.getId());
 
@@ -611,7 +629,12 @@ public class SettlementMqHandlerServiceImpl implements SettlementMqHandlerServic
             settlementOrderChildRisk.setPoundAuditTime(settlementOwnerDetail.getPoundAuditTime());
             settlementOrderChildRisk.setRiskType(SettlementOrderChildRiskEnum.RiskType.SETTLE_FAIL.getCode());
             settlementOrderChildRisk.setRiskRemark(result.getSettleMsg());
-            settlementOrderChildRiskDao.saveEntity(settlementOrderChildRisk);
+
+            // 若开票配置为是
+            if (orderChildBrokerMqHandlerService.invoiceConfigType(orderChild.getOrderNo())) {
+                settlementOrderChildRiskDao.saveEntity(settlementOrderChildRisk);
+                log.info("settlementMqHandlerServiceImpl-payStatusSync-结算状态为失败，当前运单的关联的订单开票配置为是，保存对应封控的信息入库");
+            }
 
             settlementPostService.riskAdd(settlementOrderChildRisk.getId());
         }