增加解冻释放保证金处理

performance-web/src/main/java/com/clx/performance/component/ThirdComponent.java

@@ -18,9 +18,14 @@ public class ThirdComponent {
     public static final String TRANSPORT_KEY = "9Y1N5AUP8N2TI359";
 
 
-    public static String encrypt(String param) throws Exception {
+    public static String encrypt(String param){
 
-        HttpDTO httpDTO = EncryptUtil.buildDTO(TRANSPORT_USER, param, TRANSPORT_KEY, System.currentTimeMillis());
+        HttpDTO httpDTO = null;
+        try {
+            httpDTO = EncryptUtil.buildDTO(TRANSPORT_USER, param, TRANSPORT_KEY, System.currentTimeMillis());
+        } catch (GeneralSecurityException e) {
+            throw new RuntimeException(e);
+        }
         return JSONUtil.parse(httpDTO).toString();
 
     }

performance-web/src/main/java/com/clx/performance/controller/pc/transport/TransportSyncController.java

@@ -60,7 +60,8 @@ public class TransportSyncController {
         log.info("payStatusNotify 原始报文：{}", JSONUtil.parse(param));
         String decrypt = ThirdComponent.decrypt(param.getChildNo());
         log.info("payStatusNotify 解密后：{}", decrypt);
-        return Result.ok(decrypt);
+
+        return Result.ok(ThirdComponent.encrypt("success"));
     }
 
 

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

@@ -27,6 +27,7 @@ public class SettlementDriverDetailDaoImpl extends BaseDaoImpl<SettlementDriverD
         return update(lUdWrapper()
                 .eq(SettlementDriverDetail::getId, item.getId())
                 .set(SettlementDriverDetail::getInvoiceType, item.getInvoiceType())
+                .set(SettlementDriverDetail::getPrepayFreight, item.getPrepayFreight())
                 .set(SettlementDriverDetail::getPrepayFreightFlag, item.getPrepayFreightFlag())
         );
     }

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

@@ -13,6 +13,7 @@ import com.clx.performance.component.OrderCancelComponent;
 import com.clx.performance.constant.RabbitKeyConstants;
 import com.clx.performance.dao.OrderChildDao;
 import com.clx.performance.dao.OrderGoodsDao;
+import com.clx.performance.dao.settle.SettlementOwnerDetailDao;
 import com.clx.performance.enums.*;
 import com.clx.performance.extranal.user.DriverService;
 import com.clx.performance.model.OrderChild;
@@ -76,6 +77,8 @@ public class OrderCancelServiceImpl implements OrderCancelService {
 
     private final OrderChildPostService orderChildPostService;
 
+    private final SettlementOwnerDetailDao settlementOwnerDetailDao;
+
 
     @Override
     @Transactional(rollbackFor = Exception.class)
@@ -178,13 +181,16 @@ public class OrderCancelServiceImpl implements OrderCancelService {
 
         }
         //TODO 注意判断普通单还是网运单 普通单类型 1  网运单 2
-
+        Integer invoiceType = settlementOwnerDetailDao.getInvoiceType(orderNo);
         ThawAccountParam thawAccountParam = new ThawAccountParam();
+        if (OwnerAccountEnum.OrderChildTypeStatus.ORDINARY.getCode().equals(invoiceType)) {
+            thawAccountParam.setOrderType(OwnerAccountEnum.OrderChildTypeStatus.ORDINARY.getCode());
+        } else {
+            thawAccountParam.setOrderType(OwnerAccountEnum.OrderChildTypeStatus.NETWORK.getCode());
+        }
         thawAccountParam.setOrderNo(orderNo);
-        thawAccountParam.setOrderType(OwnerAccountEnum.OrderChildTypeStatus.ORDINARY.getCode());
         log.info("执行解冻账户,参数：{}", JSONUtil.parse(thawAccountParam));
         ownerAccountService.ownerAccountThaw(thawAccountParam);
-
         Result<Object> result = orderFeign.updateOrderStatusByOrderNo(orderNo, orderStatusCode);
         if (!result.succeed()) {
             throw new RuntimeException("货主取消订单失败,原因：远程调用取消订单失败");
@@ -337,10 +343,14 @@ public class OrderCancelServiceImpl implements OrderCancelService {
         orderFeign.orderCancelReason(orderCancelReasonParam);
 
         //TODO 注意判断普通单还是网运单 普通单类型 1  网运单 2
-
+        Integer invoiceType = settlementOwnerDetailDao.getInvoiceType(orderNo);
         ThawAccountParam thawAccountParam = new ThawAccountParam();
+        if (OwnerAccountEnum.OrderChildTypeStatus.ORDINARY.getCode().equals(invoiceType)) {
+            thawAccountParam.setOrderType(OwnerAccountEnum.OrderChildTypeStatus.ORDINARY.getCode());
+        } else {
+            thawAccountParam.setOrderType(OwnerAccountEnum.OrderChildTypeStatus.NETWORK.getCode());
+        }
         thawAccountParam.setOrderNo(orderNo);
-        thawAccountParam.setOrderType(OwnerAccountEnum.OrderChildTypeStatus.ORDINARY.getCode());
         log.info("执行解冻账户,参数：{}", JSONUtil.parse(thawAccountParam));
         ownerAccountService.ownerAccountThaw(thawAccountParam);
 
@@ -471,9 +481,14 @@ public class OrderCancelServiceImpl implements OrderCancelService {
         orderFeign.orderCancelReason(orderCancelReasonParam);
 
         //TODO 注意判断普通单还是网运单 普通单类型 1  网运单 2
+        Integer invoiceType = settlementOwnerDetailDao.getInvoiceType(orderNo);
         ThawAccountParam thawAccountParam = new ThawAccountParam();
+        if (OwnerAccountEnum.OrderChildTypeStatus.ORDINARY.getCode().equals(invoiceType)) {
+            thawAccountParam.setOrderType(OwnerAccountEnum.OrderChildTypeStatus.ORDINARY.getCode());
+        } else {
+            thawAccountParam.setOrderType(OwnerAccountEnum.OrderChildTypeStatus.NETWORK.getCode());
+        }
         thawAccountParam.setOrderNo(orderNo);
-        thawAccountParam.setOrderType(OwnerAccountEnum.OrderChildTypeStatus.ORDINARY.getCode());
         log.info("执行解冻账户,参数：{}", JSONUtil.parse(thawAccountParam));
         ownerAccountService.ownerAccountThaw(thawAccountParam);
 

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

@@ -181,7 +181,9 @@ public class SettlementMqHandlerServiceImpl implements SettlementMqHandlerServic
         settlementDriver.setPrepayFreightFlag(detail.getPrepayFreightFlag());
         settlementDriver.setSettlementFreight(detail.getSettlementFreight());
         settlementDriver.setInvoiceType(detail.getInvoiceType());
-        settlementDriver.setSettlementPlatform(String.valueOf(SettlementPlatformEnum.Platform.MSL.getCode()));
+        settlementDriver.setSettlementPlatform(detail.getInvoiceType() == 1 ?
+                        String.valueOf(SettlementPlatformEnum.Platform.WY.getCode()):
+                String.valueOf(SettlementPlatformEnum.Platform.MSL.getCode()));
         if (settlementDriver.getInvoiceType().equals(SettlementOwnerEnum.InvoiceType.ONLINE.getCode())) {
             settlementDriver.setStatus(SettlementDriverEnum.Status.SETTLED.getCode());
         } else {

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

@@ -104,35 +104,36 @@ public class SettlementServiceImpl implements SettlementService {
                 BigDecimal subtract = frozen.subtract(takeOut);
                 if (subtract.compareTo(BigDecimal.ZERO) <= 0) {
                     settlementOwnerDetail.setPrepayFreight(BigDecimal.ZERO);
-                }
-                if (subtract.subtract(ans).compareTo(BigDecimal.ZERO) >= 0) {
-                    OwnerAccount account = ownerAccountDao.getAccountByOwnerUserNoAndAccountType(orderChild.getOwnerUserNo(),
-                            OwnerAccountEnum.AccountTypeStatus.PREPAID_FREIGHT_ACCOUNT.getCode());
-
-                    settlementOwnerDetail.setPrepayFreight(ans);
-                    //生成扣除流水
-                    OwnerRunningWaterRecord runningWaterRecord = new OwnerRunningWaterRecord();
-                    runningWaterRecord.setOwnerUserName(orderChild.getOwnerName());
-                    runningWaterRecord.setMobile(orderChild.getDriverMobile());
-                    runningWaterRecord.setCreateBy("系统");
-                    runningWaterRecord.setOrderId(orderChild.getId());
-                    runningWaterRecord.setOrderNo(orderChild.getOrderNo());
-
-                    runningWaterRecord.setRelationId(null);
-                    runningWaterRecord.setAlterationBalance(ans);
-                    runningWaterRecord.setFrozenBalance(account.getFrozenBalance().subtract(ans));
-                    runningWaterRecord.setUsableBalance(account.getUsableBalance());
-                    runningWaterRecord.setTakeOutBalance(ans);
-                    runningWaterRecord.setAccountBalance(account.getAccountBalance().subtract(ans));
-                    runningWaterRecord.setOwnerUserNo(account.getOwnerUserNo());
-
-                    runningWaterRecord.setAccountType(OwnerAccountEnum.AccountTypeStatus.PREPAID_FREIGHT_ACCOUNT.getCode());
-                    runningWaterRecord.setRunningWaterType(OwnerAccountEnum.RunningWaterStatus.TAKE_OUT.getCode());
-                    runningWaterRecord.setRunningWaterNo(idGenerateSnowFlake.nextId(IdTypeEnum.Type.TAKE_OUT.getCode()));
-                    ownerRunningWaterRecordDao.saveEntity(runningWaterRecord);
                 } else {
-                    settlementOwnerDetail.setPrepayFreight(BigDecimal.ZERO);
+                    if (subtract.subtract(ans).compareTo(BigDecimal.ZERO) >= 0) {
+                        OwnerAccount account = ownerAccountDao.getAccountByOwnerUserNoAndAccountType(orderChild.getOwnerUserNo(),
+                                OwnerAccountEnum.AccountTypeStatus.PREPAID_FREIGHT_ACCOUNT.getCode());
+                        settlementOwnerDetail.setPrepayFreight(ans);
+                        //生成扣除流水
+                        OwnerRunningWaterRecord runningWaterRecord = new OwnerRunningWaterRecord();
+                        runningWaterRecord.setOwnerUserName(orderChild.getOwnerName());
+                        runningWaterRecord.setMobile(orderChild.getDriverMobile());
+                        runningWaterRecord.setCreateBy("系统");
+                        runningWaterRecord.setOrderId(orderChild.getId());
+                        runningWaterRecord.setOrderNo(orderChild.getOrderNo());
+
+                        runningWaterRecord.setRelationId(null);
+                        runningWaterRecord.setAlterationBalance(ans);
+                        runningWaterRecord.setFrozenBalance(account.getFrozenBalance().subtract(ans));
+                        runningWaterRecord.setUsableBalance(account.getUsableBalance());
+                        runningWaterRecord.setTakeOutBalance(ans);
+                        runningWaterRecord.setAccountBalance(account.getAccountBalance().subtract(ans));
+                        runningWaterRecord.setOwnerUserNo(account.getOwnerUserNo());
+
+                        runningWaterRecord.setAccountType(OwnerAccountEnum.AccountTypeStatus.PREPAID_FREIGHT_ACCOUNT.getCode());
+                        runningWaterRecord.setRunningWaterType(OwnerAccountEnum.RunningWaterStatus.TAKE_OUT.getCode());
+                        runningWaterRecord.setRunningWaterNo(idGenerateSnowFlake.nextId(IdTypeEnum.Type.TAKE_OUT.getCode()));
+                        ownerRunningWaterRecordDao.saveEntity(runningWaterRecord);
+                    } else {
+                        settlementOwnerDetail.setPrepayFreight(BigDecimal.ZERO);
+                    }
                 }
+
             } else {
                 settlementDriverDetail.setPrepayFreightFlag(0);
                 invoiceType = SettlementOwnerEnum.InvoiceType.ORDINARY.getCode();