增加结算单支付锁

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

@@ -6,4 +6,9 @@ public class RedissonConstants {
     public static final String ORDER_CHILD_SAVE_USER_TRUCK_LOCK = "clx-performance:orderChild:save:userTruck:";
     public static final String ORDER_CHILD_SAVE_ORDER_GOODS_NO_LOCK = "clx-performance:orderChild:save:orderGoodsNo:";
 
+
+    //货主结算单支付锁
+    public static final String SETTLEMENT_OWNER_BATCH_PAY_ID_LOCK = "clx-performance:settlementOwner:batchPay:id:";
+    //货主违约结算单支付锁
+    public static final String BREAK_CONTRACT_SETTLEMENT_OWNER_BATCH_PAY_ID_LOCK = "clx-performance:breakContractSettlementOwner:batchPay:id:";
 }

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

 package com.clx.performance.service.impl.settle;
 
 import com.clx.performance.config.MslPaymentConfig;
+import com.clx.performance.constant.RedissonConstants;
 import com.clx.performance.dao.OrderChildDao;
 import com.clx.performance.dao.OrderGoodsDao;
 import com.clx.performance.dao.settle.SettlementDriverDao;
@@ -31,11 +32,13 @@ import com.clx.performance.service.settle.SettlementLogService;
 import com.clx.performance.service.settle.SettlementMqHandlerService;
 import com.clx.performance.service.settle.SettlementService;
 import com.clx.performance.utils.LocalDateTimeUtils;
+import com.clx.performance.utils.RedisUtil;
 import com.clx.performance.vo.mq.SettlementDetailAddMqParam;
 import com.clx.performance.vo.mq.SettlementDetailInvoiceTypeSyncMqParam;
 import com.clx.user.vo.feign.DriverInfoFeignVo;
 import com.clx.user.vo.feign.OwnerInfoFeignVO;
 import com.msl.common.enums.ResultCodeEnum;
+import com.msl.common.exception.ServiceSystemException;
 import com.msl.common.result.Result;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -46,6 +49,7 @@ import java.math.BigDecimal;
 import java.time.LocalDateTime;
 import java.util.List;
 import java.util.Objects;
+import java.util.UUID;
 
 @Slf4j
 @Service
@@ -91,6 +95,9 @@ public class SettlementMqHandlerServiceImpl implements SettlementMqHandlerServic
     @Autowired
     private OrderChildLogService orderChildLogService;
 
+    @Autowired
+    RedisUtil redisUtil;
+
 
 
     @Override
@@ -206,41 +213,54 @@ public class SettlementMqHandlerServiceImpl implements SettlementMqHandlerServic
      * 车主结算单自动支付
      */
     public String paySettlementDriver(SettlementDriverDetail detail){
-        DriverInfoFeignVo driverInfoFeignVo = driverService.getDriverInfo(detail.getDriverUserNo()).orElseThrow(ResultCodeEnum.FAIL);
-        PayParam noCheckPwd = null ;
-        if(detail.getSettlementFreight().compareTo(BigDecimal.ZERO) > 0){
-            noCheckPwd = PayParam.builder().from(mslPaymentConfig.getTransportWalletCode())
-                    .to(driverInfoFeignVo.getWalletCode())
-                    .figure(detail.getSettlementFreight().intValue())
-                    .tradeNo(detail.getChildNo())
-                    .tradeId(detail.getChildNo())
-                    .pwd("noCheckPwd")
-                    .remark(PayRemarkEnum.toString(PayRemarkEnum.FREIGHT_TO_OWNER.getValue()))
-                    .build();
-        }else{
-            BigDecimal freight = detail.getSettlementFreight().abs();
-            noCheckPwd = PayParam.builder().from(driverInfoFeignVo.getWalletCode())
-                    .to(mslPaymentConfig.getTransportWalletCode())
-                    .figure(freight.intValue())
-                    .tradeNo(detail.getChildNo())
-                    .tradeId(detail.getChildNo())
-                    .pwd("noCheckPwd")
-                    .remark(PayRemarkEnum.toString(PayRemarkEnum.FREIGHT_TO_OWNER.getValue()))
-                    .build();
-        }
-
-        Result result = null;
-        String msg  = null;
+        String uuid = UUID.randomUUID().toString();
+        String key = RedissonConstants.SETTLEMENT_OWNER_BATCH_PAY_ID_LOCK + detail.getId();
         try{
-            result = paymentService.paymentWallet(noCheckPwd);
+            boolean flag = redisUtil.lock(key, uuid);
+            if(!flag){
+                return "获取支付锁失败，操作频繁，请稍后重试";
+            }
+
+            DriverInfoFeignVo driverInfoFeignVo = driverService.getDriverInfo(detail.getDriverUserNo()).orElseThrow(ResultCodeEnum.FAIL);
+            PayParam noCheckPwd = null ;
+            if(detail.getSettlementFreight().compareTo(BigDecimal.ZERO) > 0){
+                noCheckPwd = PayParam.builder().from(mslPaymentConfig.getTransportWalletCode())
+                        .to(driverInfoFeignVo.getWalletCode())
+                        .figure(detail.getSettlementFreight().intValue())
+                        .tradeNo(detail.getChildNo())
+                        .tradeId(detail.getChildNo())
+                        .pwd("noCheckPwd")
+                        .remark(PayRemarkEnum.toString(PayRemarkEnum.FREIGHT_TO_OWNER.getValue()))
+                        .build();
+            }else{
+                BigDecimal freight = detail.getSettlementFreight().abs();
+                noCheckPwd = PayParam.builder().from(driverInfoFeignVo.getWalletCode())
+                        .to(mslPaymentConfig.getTransportWalletCode())
+                        .figure(freight.intValue())
+                        .tradeNo(detail.getChildNo())
+                        .tradeId(detail.getChildNo())
+                        .pwd("noCheckPwd")
+                        .remark(PayRemarkEnum.toString(PayRemarkEnum.FREIGHT_TO_OWNER.getValue()))
+                        .build();
+            }
+
+            Result result = null;
+            String msg  = null;
+            try{
+                result = paymentService.paymentWallet(noCheckPwd);
+            }catch (Exception e){
+                settlementDriverNotify(detail.getChildNo(),0,e.getMessage());
+                msg = e.getMessage();
+            }
+            if(Objects.nonNull(result)){
+                settlementDriverNotify(detail.getChildNo(),0,result.getMsg());
+            }
+            return msg;
         }catch (Exception e){
-            settlementDriverNotify(detail.getChildNo(),0,e.getMessage());
-            msg = e.getMessage();
-        }
-        if(Objects.nonNull(result)){
-            settlementDriverNotify(detail.getChildNo(),0,result.getMsg());
+            //解锁
+            redisUtil.unlock(key,uuid);
+            throw new ServiceSystemException(PerformanceResultEnum.DATA_REPEAT);
         }
-        return msg;
     }
 
     /**