订单报价-封控异常处理--插入数据

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

@@ -25,6 +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 LocalDateTime poundAuditTime;          // 磅单审核通过时间
     private Integer riskType;                      // 风控标识：1同步失败 2结算打回
     private String riskRemark;                     // 风控失败原因

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

@@ -79,6 +79,10 @@ public class OrderChildBrokerMqHandlerServiceImpl implements OrderChildBrokerMqH
             settlementOrderChildRisk.setDriverMobile(orderChild.getDriverMobile());
             settlementOrderChildRisk.setGoodsName(orderChild.getGoodsName());
             settlementOrderChildRisk.setInvoiceType(settlementOwnerDetail.getInvoiceType());
+            // 如果有发票配置，则更新
+            if (Objects.nonNull(settlementOwnerDetail.getInvoiceConfigType())) {
+                settlementOrderChildRisk.setInvoiceConfigType(settlementOwnerDetail.getInvoiceConfigType());
+            }
             settlementOrderChildRisk.setPoundAuditTime(settlementOwnerDetail.getPoundAuditTime());
             settlementOrderChildRisk.setRiskType(SettlementOrderChildRiskEnum.RiskType.SETTLE_FAIL.getCode());
             settlementOrderChildRisk.setRiskRemark("同步无车承运异常");

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

@@ -365,6 +365,10 @@ public class SettlementMqHandlerServiceImpl implements SettlementMqHandlerServic
                 settlementOrderChildRisk.setDriverMobile(orderChild.getDriverMobile());
                 settlementOrderChildRisk.setGoodsName(orderChild.getGoodsName());
                 settlementOrderChildRisk.setInvoiceType(settlementOwnerDetail.getInvoiceType());
+                // 防止历史数据不存在
+                if (Objects.nonNull(settlementOwnerDetail.getInvoiceConfigType())) {
+                    settlementOrderChildRisk.setInvoiceConfigType(settlementOwnerDetail.getInvoiceConfigType());
+                }
                 settlementOrderChildRisk.setPoundAuditTime(settlementOwnerDetail.getPoundAuditTime());
                 settlementOrderChildRisk.setRiskType(SettlementOrderChildRiskEnum.RiskType.SYNC_FAIL.getCode());
                 settlementOrderChildRisk.setRiskRemark(result.getSyncMsg());
@@ -474,6 +478,10 @@ public class SettlementMqHandlerServiceImpl implements SettlementMqHandlerServic
             settlementOrderChildRisk.setDriverMobile(orderChild.getDriverMobile());
             settlementOrderChildRisk.setGoodsName(orderChild.getGoodsName());
             settlementOrderChildRisk.setInvoiceType(settlementOwnerDetail.getInvoiceType());
+            // 防止历史数据没有出现报错
+            if (Objects.nonNull(settlementOwnerDetail.getInvoiceConfigType())) {
+                settlementOrderChildRisk.setInvoiceConfigType(settlementOwnerDetail.getInvoiceConfigType());
+            }
             settlementOrderChildRisk.setPoundAuditTime(settlementOwnerDetail.getPoundAuditTime());
             settlementOrderChildRisk.setRiskType(SettlementOrderChildRiskEnum.RiskType.SYNC_FAIL.getCode());
             settlementOrderChildRisk.setRiskRemark(result.getSyncMsg());
@@ -551,6 +559,10 @@ public class SettlementMqHandlerServiceImpl implements SettlementMqHandlerServic
             settlementOrderChildRisk.setDriverMobile(orderChild.getDriverMobile());
             settlementOrderChildRisk.setGoodsName(orderChild.getGoodsName());
             settlementOrderChildRisk.setInvoiceType(settlementOwnerDetail.getInvoiceType());
+            // 防止历史数据没有出现报错
+            if (Objects.nonNull(settlementOwnerDetail.getInvoiceConfigType())) {
+                settlementDriverDetail.setInvoiceConfigType(settlementOwnerDetail.getInvoiceConfigType());
+            }
             settlementOrderChildRisk.setPoundAuditTime(settlementOwnerDetail.getPoundAuditTime());
             settlementOrderChildRisk.setRiskType(SettlementOrderChildRiskEnum.RiskType.SYNC_FAIL.getCode());
             settlementOrderChildRisk.setRiskRemark(result.getSyncMsg());
@@ -592,6 +604,10 @@ public class SettlementMqHandlerServiceImpl implements SettlementMqHandlerServic
             settlementOrderChildRisk.setDriverMobile(orderChild.getDriverMobile());
             settlementOrderChildRisk.setGoodsName(orderChild.getGoodsName());
             settlementOrderChildRisk.setInvoiceType(settlementOwnerDetail.getInvoiceType());
+            // 防止历史数据没有出现报错
+            if (Objects.nonNull(settlementOwnerDetail.getInvoiceConfigType())) {
+                settlementOrderChildRisk.setInvoiceConfigType(settlementOwnerDetail.getInvoiceConfigType());
+            }
             settlementOrderChildRisk.setPoundAuditTime(settlementOwnerDetail.getPoundAuditTime());
             settlementOrderChildRisk.setRiskType(SettlementOrderChildRiskEnum.RiskType.SETTLE_FAIL.getCode());
             settlementOrderChildRisk.setRiskRemark(result.getSettleMsg());