Merge branch 'refs/heads/v26.5_optimize_20240918' into release

performance-api/src/main/java/com/clx/performance/param/app/OrderChildLoadAndUnloadAgainParam.java

@@ -22,13 +22,14 @@ public class OrderChildLoadAndUnloadAgainParam extends PositionParam {
     private String childNo;
 
     @ApiModelProperty(value = "装货毛重（单位吨）", example = "2.46")
-    @NotNull
     private BigDecimal loadRough;
 
     @ApiModelProperty(value = "装货皮重（单位吨）", example = "1.23")
-    @NotNull
     private BigDecimal loadTare;
 
+    @ApiModelProperty(value = "装货净重（单位吨）", example = "1.23")
+    private BigDecimal loadNet;
+
     @ApiModelProperty(value = "磅单图片列表")
     @NotEmpty(message = "请上传磅单照片")
     private List<String> loadImageList;

performance-api/src/main/java/com/clx/performance/param/app/OrderChildLoadParam.java

@@ -7,7 +7,6 @@ import lombok.Setter;
 
 import javax.validation.constraints.NotBlank;
 import javax.validation.constraints.NotEmpty;
-import javax.validation.constraints.NotNull;
 import java.math.BigDecimal;
 import java.util.List;
 
@@ -21,13 +20,14 @@ public class OrderChildLoadParam extends PositionParam {
     private String childNo;
 
     @ApiModelProperty(value = "装货毛重（单位吨）", example = "2.46")
-    @NotNull
     private BigDecimal loadRough;
 
     @ApiModelProperty(value = "装货皮重（单位吨）", example = "1.23")
-    @NotNull
     private BigDecimal loadTare;
 
+    @ApiModelProperty(value = "装货净重（单位吨）", example = "1.23")
+    private BigDecimal loadNet;
+
     @ApiModelProperty(value = "磅单图片列表")
     @NotEmpty(message = "请上传磅单照片")
     private List<String> loadImageList;

performance-api/src/main/java/com/clx/performance/param/app/OrderChildUnloadParam.java

@@ -25,6 +25,9 @@ public class OrderChildUnloadParam extends PositionParam {
     @ApiModelProperty(value = "卸货皮重（单位吨）", example = "1.23")
     private BigDecimal unloadTare;
 
+    @ApiModelProperty(value = "卸货净重（单位吨）", example = "1.23")
+    private BigDecimal unloadNet;
+
     @ApiModelProperty(value = "磅单图片列表")
     @NotEmpty(message = "请上传磅单照片")
     private List<String> unloadImageList;

performance-api/src/main/java/com/clx/performance/vo/mq/settle/SettlementDriverSettleMqParam.java

+package com.clx.performance.vo.mq.settle;
+
+import lombok.*;
+
+@Setter
+@Getter
+@ToString
+@NoArgsConstructor
+public class SettlementDriverSettleMqParam {
+
+    private String childNo;             //运单编号
+
+}

performance-api/src/main/java/com/clx/performance/vo/mq/settle/SettlementOrderChildRiskAddMqParam.java

+package com.clx.performance.vo.mq.settle;
+
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.Setter;
+import lombok.ToString;
+
+@Setter
+@Getter
+@ToString
+@NoArgsConstructor
+public class SettlementOrderChildRiskAddMqParam {
+
+    private Integer id;             //id
+
+}

performance-web/src/main/java/com/clx/performance/config/RabbitSettlementConfig.java

@@ -87,7 +87,7 @@ public class RabbitSettlementConfig {
     }
 
     /**
-     * 结算
+     * 货主结算
      */
     @Bean
     public Queue settlementSettleQueue() {
@@ -98,6 +98,20 @@ public class RabbitSettlementConfig {
         return BindingBuilder.bind(settlementSettleQueue()).to(settlementDefaultExchange())
                 .with(RabbitKeySettlementConstants.SETTLEMENT_SETTLE_ROUTING_KEY);
     }
+
+    /**
+     * 车主结算
+     */
+    @Bean
+    public Queue settlementDriverSettlementQueue() {
+        return new Queue(RabbitKeySettlementConstants.SETTLEMENT_DRIVER_SETTLE_QUEUE);
+    }
+    @Bean
+    public Binding settlementDriverSettlementQueueBinding() {
+        return BindingBuilder.bind(settlementDriverSettlementQueue()).to(settlementDefaultExchange())
+                .with(RabbitKeySettlementConstants.SETTLEMENT_DRIVER_SETTLE_ROUTING_KEY);
+    }
+
     /**
      * 支付状态
      */
@@ -123,6 +137,18 @@ public class RabbitSettlementConfig {
                 .with(RabbitKeySettlementConstants.SETTLEMENT_INVOICE_STATUS_SYNC_ROUTING_KEY);
     }
 
+    /**
+     * 风控新增
+     */
+    @Bean
+    public Queue settlementRiskAddQueue() {
+        return new Queue(RabbitKeySettlementConstants.SETTLEMENT_RISK_ADD_QUEUE);
+    }
+    @Bean
+    public Binding settlementRiskAddQueueBinding() {
+        return BindingBuilder.bind(settlementRiskAddQueue()).to(settlementDefaultExchange())
+                .with(RabbitKeySettlementConstants.SETTLEMENT_RISK_ADD_ROUTING_KEY);
+    }
     /**
      * 风控处理
      */

performance-web/src/main/java/com/clx/performance/constant/RabbitKeySettlementConstants.java

@@ -52,10 +52,17 @@ public class RabbitKeySettlementConstants {
     public static final String SETTLEMENT_INVOICE_TYPE_SYNC_ROUTING_KEY = PREFIX +"settlementInvoiceType.sync"+QUEUE_ROUTING_KEY;
 
     /**
-     * 结算
+     * 货主结算
      */
     public static final String SETTLEMENT_SETTLE_QUEUE = PREFIX +"settlement.settle"+QUEUE;
     public static final String SETTLEMENT_SETTLE_ROUTING_KEY = PREFIX +"settlement.settle"+QUEUE_ROUTING_KEY;
+
+    /**
+     * 车主结算
+     */
+    public static final String SETTLEMENT_DRIVER_SETTLE_QUEUE = PREFIX +"settlementDriver.settle"+QUEUE;
+    public static final String SETTLEMENT_DRIVER_SETTLE_ROUTING_KEY = PREFIX +"settlementDriver.settle"+QUEUE_ROUTING_KEY;
+
     /**
      * 开票状态同步
      */
@@ -68,6 +75,12 @@ public class RabbitKeySettlementConstants {
     public static final String SETTLEMENT_PAY_STATUS_SYNC_QUEUE = PREFIX +"settlementPayStatus.sync"+QUEUE;
     public static final String SETTLEMENT_PAY_STATUS_SYNC_ROUTING_KEY = PREFIX +"settlementPayStatus.sync"+QUEUE_ROUTING_KEY;
 
+    /**
+     * 风控新增
+     */
+    public static final String SETTLEMENT_RISK_ADD_QUEUE = PREFIX +"settlementRisk.add"+QUEUE;
+    public static final String SETTLEMENT_RISK_ADD_ROUTING_KEY = PREFIX +"settlementRisk.add"+QUEUE_ROUTING_KEY;
+
     /**
      * 风控处理
      */

performance-web/src/main/java/com/clx/performance/dao/impl/settle/SettlementDriverDaoImpl.java

@@ -8,8 +8,6 @@ import com.clx.performance.dao.settle.SettlementDriverDao;
 import com.clx.performance.enums.loan.OwnerLoanRecordEnum;
 import com.clx.performance.mapper.settle.SettlementDriverMapper;
 import com.clx.performance.model.settle.SettlementDriver;
-import com.clx.performance.model.settle.SettlementOrderChildRisk;
-import com.clx.performance.model.settle.SettlementOwner;
 import com.clx.performance.param.pc.driver.PageCarrierSettlementDriverParam;
 import com.msl.common.base.Optional;
 import com.msl.common.dao.impl.BaseDaoImpl;
@@ -18,7 +16,6 @@ import org.springframework.stereotype.Repository;
 
 import java.util.List;
 import java.util.Objects;
-import java.util.Set;
 
 /**
  * @Author: aiqinguo
@@ -38,6 +35,16 @@ public class SettlementDriverDaoImpl extends BaseDaoImpl<SettlementDriverMapper,
         );
     }
 
+    @Override
+    public boolean updateInvoiceCompany(SettlementDriver item) {
+        return update(lUdWrapper()
+                .eq(SettlementDriver::getId, item.getId())
+                .set(SettlementDriver::getInvoicingCompanyId, item.getInvoicingCompanyId())
+                .set(SettlementDriver::getInvoicingCompanyShorterName, item.getInvoicingCompanyShorterName())
+                .set(SettlementDriver::getInvoicingCompanyGroupCode, item.getInvoicingCompanyGroupCode())
+        );
+    }
+
     @Override
     public Optional<SettlementDriver> findBySettlementNo(String settlementNo) {
         return Optional.of(lQrWrapper()

performance-web/src/main/java/com/clx/performance/dao/settle/SettlementDriverDao.java

@@ -20,6 +20,8 @@ public interface SettlementDriverDao extends BaseDao<SettlementDriverMapper, Set
     boolean updatePayStatus(SettlementDriver item);
 
 
+    boolean updateInvoiceCompany(SettlementDriver item);
+
     Optional<SettlementDriver> findBySettlementNo(String settlementNo);
 
     Optional<SettlementDriver> findByChildNo(String childNo);

performance-web/src/main/java/com/clx/performance/event/EventListenerComponent.java

@@ -147,6 +147,10 @@ public class EventListenerComponent {
 
             // 发送mq 结算统计
             settlementMqService.settlementStatistics(settlementDriverDetail.getChildNo());
+
+            // 发送mq 司机结算
+            settlementMqService.settlementDriverSettle(settlementDriverDetail.getChildNo());
+
         } catch (Exception e) {
             throw new ServiceSystemException(PerformanceResultEnum.GET_LOAN_RECORD, e.getMessage());
         } finally {

performance-web/src/main/java/com/clx/performance/listener/settle/SettlementDriverSettlementListener.java

+package com.clx.performance.listener.settle;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.TypeReference;
+import com.clx.performance.common.MqWrapper;
+import com.clx.performance.constant.RabbitKeySettlementConstants;
+import com.clx.performance.service.settle.SettlementMqHandlerService;
+import com.clx.performance.vo.mq.settle.SettlementDriverSettleMqParam;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.amqp.core.Message;
+import org.springframework.amqp.rabbit.annotation.RabbitListener;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+/**
+ * @Author: 艾庆国
+ * @Description: 车主结算 mq
+ * @Date: 2023-10-20 11:45:08
+ * @Version: 1.0
+ */
+@Slf4j
+@Component
+public class SettlementDriverSettlementListener {
+
+    @Autowired
+    private SettlementMqHandlerService settlementMqHandlerService;
+
+    @RabbitListener(queues = RabbitKeySettlementConstants.SETTLEMENT_DRIVER_SETTLE_QUEUE)
+    public void process(Message message) {
+        try{
+            log.info("结算-车主结算, message:{}", new String(message.getBody()));
+            process(JSON.parseObject(new String(message.getBody()), new TypeReference<MqWrapper<SettlementDriverSettleMqParam>>(){}).getData());
+        }catch (Exception e){
+            log.info("结算-车主结算 失败",e);
+        }
+    }
+
+    private void process(SettlementDriverSettleMqParam mq){
+
+        settlementMqHandlerService.settlementDriverSettlement(mq);
+
+    }
+}

performance-web/src/main/java/com/clx/performance/listener/settle/SettlementRiskAddListener.java

+package com.clx.performance.listener.settle;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.TypeReference;
+import com.clx.performance.common.MqWrapper;
+import com.clx.performance.constant.RabbitKeySettlementConstants;
+import com.clx.performance.service.settle.SettlementMqHandlerService;
+import com.clx.performance.vo.mq.settle.SettlementOrderChildRiskAddMqParam;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.exception.ExceptionUtils;
+import org.springframework.amqp.core.Message;
+import org.springframework.amqp.rabbit.annotation.RabbitListener;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+/**
+ * @Author: 艾庆国
+ * @Description: 风控新增 mq
+ * @Date: 2023-10-20 11:45:08
+ * @Version: 1.0
+ */
+@Slf4j
+@Component
+public class SettlementRiskAddListener {
+
+    @Autowired
+    private SettlementMqHandlerService settlementMqHandlerService;
+
+    @RabbitListener(queues = RabbitKeySettlementConstants.SETTLEMENT_RISK_ADD_QUEUE)
+    public void process(Message message) {
+        try{
+            log.info("结算-风控新增, message:{}", new String(message.getBody()));
+            process(JSON.parseObject(new String(message.getBody()), new TypeReference<MqWrapper<SettlementOrderChildRiskAddMqParam>>(){}).getData());
+        }catch (Exception e){
+            log.info("结算-风控新增 失败，msg:{}", ExceptionUtils.getStackTrace(e));
+        }
+    }
+
+    private void process(SettlementOrderChildRiskAddMqParam mq){
+
+        settlementMqHandlerService.riskAdd(mq);
+
+    }
+}

performance-web/src/main/java/com/clx/performance/listener/settle/SettlementSettleListener.java

@@ -14,7 +14,7 @@ import org.springframework.stereotype.Component;
 
 /**
  * @Author: 艾庆国
- * @Description: 结算 mq
+ * @Description: 货主结算 mq
  * @Date: 2023-10-20 11:45:08
  * @Version: 1.0
  */
@@ -28,10 +28,10 @@ public class SettlementSettleListener {
     @RabbitListener(queues = RabbitKeySettlementConstants.SETTLEMENT_SETTLE_QUEUE)
     public void process(Message message) {
         try{
-            log.info("结算-结算, message:{}", new String(message.getBody()));
+            log.info("结算-货主结算, message:{}", new String(message.getBody()));
             process(JSON.parseObject(new String(message.getBody()), new TypeReference<MqWrapper<SettlementSettleMqParam>>(){}).getData());
         }catch (Exception e){
-            log.info("结算-结算 失败",e);
+            log.info("结算-货主结算 失败",e);
         }
     }
 

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

@@ -18,6 +18,7 @@ import com.clx.performance.model.settle.SettlementOwnerDetail;
 import com.clx.performance.service.broker.OrderChildBrokerMqHandlerService;
 import com.clx.performance.service.broker.OrderChildBrokerMqService;
 import com.clx.performance.service.broker.OrderChildBrokerService;
+import com.clx.performance.service.settle.SettlementPostService;
 import com.clx.performance.vo.mq.broker.BrokerOrderChildSyncMqParam;
 import com.clx.performance.vo.mq.broker.BrokerOrderChildUpdateMqParam;
 import lombok.extern.slf4j.Slf4j;
@@ -51,6 +52,9 @@ public class OrderChildBrokerMqHandlerServiceImpl implements OrderChildBrokerMqH
     @Autowired
     private SettlementOrderChildRiskDao settlementOrderChildRiskDao;
 
+    @Autowired
+    private SettlementPostService settlementPostService;
+
     @Transactional(rollbackFor = Exception.class)
     @Override
     public void orderChildSync(BrokerOrderChildSyncMqParam mq) {
@@ -77,6 +81,8 @@ public class OrderChildBrokerMqHandlerServiceImpl implements OrderChildBrokerMqH
             settlementOrderChildRisk.setRiskType(SettlementOrderChildRiskEnum.RiskType.SETTLE_FAIL.getCode());
             settlementOrderChildRisk.setRiskRemark("同步无车承运异常");
             settlementOrderChildRiskDao.saveEntity(settlementOrderChildRisk);
+
+            settlementPostService.riskAdd(settlementOrderChildRisk.getId());
         }
     }
     public void doOrderChildSync(BrokerOrderChildSyncMqParam mq){

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

@@ -6,10 +6,7 @@ import com.clx.performance.common.MqWrapper;
 import com.clx.performance.constant.RabbitKeySettlementConstants;
 import com.clx.performance.service.settle.SettlementMqService;
 import com.clx.performance.vo.mq.*;
-import com.clx.performance.vo.mq.settle.SettlementInvoiceStatusUpdateMqParam;
-import com.clx.performance.vo.mq.settle.SettlementOrderChildRiskProcessMqParam;
-import com.clx.performance.vo.mq.settle.SettlementOwnerDetialInvoiceCompanyUpdateMqParam;
-import com.clx.performance.vo.mq.settle.SettlementPlatformAutoConfirmMqParam;
+import com.clx.performance.vo.mq.settle.*;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.amqp.core.Message;
 import org.springframework.amqp.core.MessageBuilder;
@@ -60,6 +57,19 @@ public class SettlementMqServiceImpl implements SettlementMqService {
                 RabbitKeySettlementConstants.DEFAULT_DELAY_ROUTING_KEY, message);
     }
 
+    @Override
+    public void settlementDriverSettle(String childNo) {
+        SettlementDriverSettleMqParam mq = new SettlementDriverSettleMqParam();
+        mq.setChildNo(childNo);
+        MqDelay delay =
+                new MqDelay<>(RabbitKeySettlementConstants.DEFAULT_EXCHANGE,
+                        RabbitKeySettlementConstants.SETTLEMENT_DRIVER_SETTLE_ROUTING_KEY, new MqWrapper<>(mq));
+        Message message = MessageBuilder.withBody(JSON.toJSONString(new MqWrapper<>(delay)).getBytes()).build();
+        message.getMessageProperties().setExpiration("5000");
+        rabbitTemplate.send(RabbitKeySettlementConstants.DEFAULT_EXCHANGE,
+                RabbitKeySettlementConstants.DEFAULT_DELAY_ROUTING_KEY, message);
+    }
+
 
     @Override
     public void invoiceTypeSync(String childNo) {
@@ -114,6 +124,18 @@ public class SettlementMqServiceImpl implements SettlementMqService {
                 RabbitKeySettlementConstants.DEFAULT_DELAY_ROUTING_KEY, message);
     }
 
+    @Override
+    public void riskAdd(Integer id) {
+        SettlementOrderChildRiskAddMqParam mq = new SettlementOrderChildRiskAddMqParam();
+        mq.setId(id);
+        MqDelay delay = new MqDelay<>(RabbitKeySettlementConstants.DEFAULT_EXCHANGE,
+                RabbitKeySettlementConstants.SETTLEMENT_RISK_ADD_ROUTING_KEY, new MqWrapper<>(mq));
+        Message message = MessageBuilder.withBody(JSON.toJSONString(new MqWrapper<>(delay)).getBytes()).build();
+        message.getMessageProperties().setExpiration("5000");
+        rabbitTemplate.send(RabbitKeySettlementConstants.DEFAULT_EXCHANGE,
+                RabbitKeySettlementConstants.DEFAULT_DELAY_ROUTING_KEY, message);
+    }
+
     @Override
     public void riskProcess(Integer id) {
         SettlementOrderChildRiskProcessMqParam mq = new SettlementOrderChildRiskProcessMqParam();

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

@@ -97,11 +97,6 @@ public class SettlementOrderChildRiskServiceImpl implements SettlementOrderChild
             settlementDriverDetailDao.updateConvertOrdinary(settlementDriverDetail);
 
             settlementOrderChildRisk.setInvoiceType(settlementOwnerDetail.getInvoiceType());
-
-            if (settlementDriver != null) {
-                // 删除结算单
-                settlementDriverDao.deleteByKey(settlementDriver.getId());
-            }
         }
         else {
 

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

@@ -60,4 +60,11 @@ public class SettlementPostServiceImpl implements SettlementPostService {
         }
     }
 
+    @Override
+    public void riskAdd(Integer id) {
+
+        // 发送mq (风控新增)
+        settlementMqService.riskAdd(id);
+    }
+
 }

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

@@ -2,16 +2,14 @@ package com.clx.performance.service.settle;
 
 import com.clx.performance.model.settle.SettlementDriverDetail;
 import com.clx.performance.vo.mq.*;
-import com.clx.performance.vo.mq.settle.SettlementInvoiceStatusUpdateMqParam;
-import com.clx.performance.vo.mq.settle.SettlementOrderChildRiskProcessMqParam;
-import com.clx.performance.vo.mq.settle.SettlementOwnerDetialInvoiceCompanyUpdateMqParam;
-import com.clx.performance.vo.mq.settle.SettlementPlatformAutoConfirmMqParam;
+import com.clx.performance.vo.mq.settle.*;
 
 public interface SettlementMqHandlerService {
 
     void settlementDetailAdd(SettlementDetailAddMqParam mq);
 
     void settlementStatistics(SettlementStatisticsMqParam mq);
+    void settlementDriverSettlement(SettlementDriverSettleMqParam mq);
 
     void settle(SettlementSettleMqParam mq);
 
@@ -27,6 +25,7 @@ public interface SettlementMqHandlerService {
 
     String settlementNoGenerate();
 
+    void riskAdd(SettlementOrderChildRiskAddMqParam mq);
     void riskProcess(SettlementOrderChildRiskProcessMqParam mq);
 
     void invoiceCompanyUpdate(SettlementOwnerDetialInvoiceCompanyUpdateMqParam mq);

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

@@ -6,6 +6,7 @@ public interface SettlementMqService {
 
     void settlementStatistics(String childNo);
     void settlementStatistics(String childNo, Integer type);
+    void settlementDriverSettle(String childNo);
 
     void invoiceTypeSync(String childNo);
 
@@ -15,6 +16,8 @@ public interface SettlementMqService {
 
     void payStatusSync(String childNo);
 
+    void riskAdd(Integer id);
+
     void riskProcess(Integer id);
 
     void updateInvoiceCompany(Integer id);

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

@@ -15,4 +15,6 @@ public interface SettlementPostService {
 
     void updateInvoice(List<String> childNoList);
 
+    void riskAdd(Integer id);
+
 }