Merge remote-tracking branch 'origin/dev_20260630' into dev_20260630

sckw-common/sckw-common-core/src/main/java/com/sckw/core/model/enums/ParkingChangeStrategyEnum.java

@@ -0,0 +1,51 @@
+package com.sckw.core.model.enums;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
+import java.util.EnumSet;
+
+/**
+ * @author lfdc
+ * @desc 收费策略类型
+ * @date 2023-07-14 14:07:23
+ */
+@Getter
+@AllArgsConstructor
+public enum ParkingChangeStrategyEnum {
+
+    /**
+     * 按吨计费
+     */
+    BY_TON(1, "按吨计费"),
+
+    /**
+     * 按次计费
+     */
+    BY_TIME(2, "按次计费"),
+
+    /**
+     * 按月计费
+     */
+    BY_MONTH(3, "按月计费");
+
+    ;
+
+    private final Integer code;
+
+    private final String desc;
+
+
+    public static String geDesc(Integer status) {
+        if (status == null) {
+            return null;
+        }
+        for (ParkingChangeStrategyEnum carWaybillV1Enum : EnumSet.allOf(ParkingChangeStrategyEnum.class)) {
+            if (carWaybillV1Enum.code.equals(status)) {
+                return carWaybillV1Enum.desc;
+            }
+        }
+        return null;
+    }
+
+}

sckw-modules-api/sckw-transport-api/src/main/java/com/sckw/transport/api/dubbo/ParkingWalletFeeRemoteService.java

@@ -0,0 +1,37 @@
+package com.sckw.transport.api.dubbo;
+
+import com.sckw.transport.api.model.param.ParkingWalletFeeFreezeParam;
+import com.sckw.transport.api.model.vo.ParkingWalletFeeFreezeResult;
+
+import java.math.BigDecimal;
+
+/**
+ * 服务费远程服务
+ */
+public interface ParkingWalletFeeRemoteService {
+
+    /**
+     * 贸易订单下单时应用收费策略并冻结服务费余额
+     *
+     * @param param 冻结参数
+     * @return 收费策略应用结果
+     */
+    ParkingWalletFeeFreezeResult applyChargeStrategyFreeze(ParkingWalletFeeFreezeParam param);
+
+    /**
+     * 贸易订单审核拒绝时解冻服务费并返还余额
+     *
+     * @param param 解冻参数
+     * @return 解冻结果（含采购方服务费余额）
+     */
+    ParkingWalletFeeFreezeResult unfreezeChargeStrategy(ParkingWalletFeeFreezeParam param);
+
+    /**
+     * 查询采购方服务费余额
+     *
+     * @param proEntId 采购方企业id
+     * @param supEntId 供应商企业id
+     * @return 服务费余额
+     */
+    BigDecimal queryServiceFeeBalance(Long proEntId, Long supEntId);
+}

sckw-modules-api/sckw-transport-api/src/main/java/com/sckw/transport/api/model/param/ParkingWalletFeeFreezeParam.java

@@ -0,0 +1,42 @@
+package com.sckw.transport.api.model.param;
+
+import lombok.Data;
+
+import java.io.Serial;
+import java.io.Serializable;
+import java.math.BigDecimal;
+
+/**
+ * 贸易订单服务费冻结参数
+ */
+@Data
+public class ParkingWalletFeeFreezeParam implements Serializable {
+
+    @Serial
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 贸易订单号
+     */
+    private String orderNo;
+
+    /**
+     * 采购方企业id
+     */
+    private Long proEntId;
+
+    /**
+     * 供应商企业id
+     */
+    private Long supEntId;
+
+    /**
+     * 采购数量
+     */
+    private BigDecimal purchaseQuantity;
+
+    /**
+     * 操作人id（Dubbo调用时由订单模块传入）
+     */
+    private Long operatorId;
+}

sckw-modules-api/sckw-transport-api/src/main/java/com/sckw/transport/api/model/vo/ParkingWalletFeeFreezeResult.java

@@ -0,0 +1,42 @@
+package com.sckw.transport.api.model.vo;
+
+import lombok.Data;
+
+import java.io.Serial;
+import java.io.Serializable;
+import java.math.BigDecimal;
+
+/**
+ * 贸易订单服务费冻结结果
+ */
+@Data
+public class ParkingWalletFeeFreezeResult implements Serializable {
+
+    @Serial
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 是否应用收费策略（0-否，1-是）
+     */
+    private Integer applyChargeStrategy;
+
+    /**
+     * 收费策略id
+     */
+    private Long chargeStrategyId;
+
+    /**
+     * 收费策略描述，如10元/吨
+     */
+    private String chargeStrategyDesc;
+
+    /**
+     * 冻结服务费金额
+     */
+    private BigDecimal freezeAmount;
+
+    /**
+     * 采购方服务费余额
+     */
+    private BigDecimal serviceFeeBalance;
+}

sckw-modules/sckw-contract/src/main/java/com/sckw/contract/service/operateService/KwcContractTradeService.java

@@ -2579,18 +2579,25 @@ public class KwcContractTradeService {
             log.debug("供应商登录，使用登录企业ID[{}]和企业类型[{}]进行查询",
                     contractTradeOrderDto.getEntId(), contractTradeOrderDto.getEntType());
         } else if (Objects.equals(LoginUserHolder.getEntTypes(), CooperateTypeEnum.PURCHASER.getCode())) {
-            // 采购商登录时，企业ID从商品表获取，忽略前端传入的企业ID,兼容前端之前可能不会传商品id的情况，增加校验
-            if (Objects.isNull(contractTradeOrderDto.getGoodsId()) && Objects.equals(contractTradeOrderDto.getEntType(), 1)) {
-                throw new BusinessException("商品id不能为空！");
-            }
-            KwpGoods kwpGoods = goodsInfoService.getGoodsById(contractTradeOrderDto.getGoodsId());
-            if (Objects.isNull(kwpGoods) || Objects.isNull(kwpGoods.getEntId())) {
-                throw new BusinessException("商品不存在或商品企业信息缺失！");
+            if (Objects.equals(contractTradeOrderDto.getEntType(), CooperateTypeEnum.PURCHASER.getCode())){
+                // 采购商登录时，前端传入的企业ID和类型为采购商，直接使用前端传入的企业ID和类型
+                log.debug("采购商登录，前端传入的企业类型为采购商，使用前端传入的企业ID[{}]和企业类型[{}]进行查询",
+                        contractTradeOrderDto.getEntId(), contractTradeOrderDto.getEntType());
+            }else {
+                // 采购商登录时，企业ID从商品表获取，忽略前端传入的企业ID,兼容前端之前可能不会传商品id的情况，增加校验
+                if (Objects.isNull(contractTradeOrderDto.getGoodsId()) && Objects.equals(contractTradeOrderDto.getEntType(), 1)) {
+                    throw new BusinessException("商品id不能为空！");
+                }
+                KwpGoods kwpGoods = goodsInfoService.getGoodsById(contractTradeOrderDto.getGoodsId());
+                if (Objects.isNull(kwpGoods) || Objects.isNull(kwpGoods.getEntId())) {
+                    throw new BusinessException("商品不存在或商品企业信息缺失！");
+                }
+                contractTradeOrderDto.setEntId(kwpGoods.getEntId());
+                contractTradeOrderDto.setEntType(CooperateTypeEnum.SUPPLIER.getCode());
+                log.debug("采购商登录，使用商品[{}]关联企业ID[{}]进行查询",
+                        contractTradeOrderDto.getGoodsId(), contractTradeOrderDto.getEntId());
             }
-            contractTradeOrderDto.setEntId(kwpGoods.getEntId());
-            contractTradeOrderDto.setEntType(CooperateTypeEnum.SUPPLIER.getCode());
-            log.debug("采购商登录，使用商品[{}]关联企业ID[{}]进行查询",
-                    contractTradeOrderDto.getGoodsId(), contractTradeOrderDto.getEntId());
+
         }
 
         // 1. 参数校验：确保商品ID、企业ID和企业类型不为空
@@ -2851,9 +2858,9 @@ public class KwcContractTradeService {
     }
 
     private static void checkParam(Long contractTradeOrderDto, Long contractTradeOrderDto1, Integer contractTradeOrderDto2) {
-        if (Objects.isNull(contractTradeOrderDto) && Objects.equals(contractTradeOrderDto2, 1)) {
-            throw new BusinessException("商品id不能为空！");
-        }
+//        if (Objects.isNull(contractTradeOrderDto) && Objects.equals(contractTradeOrderDto2, 1)) {
+//            throw new BusinessException("商品id不能为空！");
+//        }
         if (Objects.isNull(contractTradeOrderDto1)) {
             throw new BusinessException("托运方企业id不能为空！");
         }

sckw-modules/sckw-order/src/main/java/com/sckw/order/model/KwoTradeOrder.java

@@ -160,5 +160,23 @@ public class KwoTradeOrder extends BaseModel implements Serializable {
     @TableField("agent_flag")
     private Integer agentFlag;
 
+    /**
+     * 是否应用收费策略（0-否，1-是）
+     */
+    @TableField("apply_charge_strategy")
+    private Integer applyChargeStrategy;
+
+    /**
+     * 应用的收费策略id
+     */
+    @TableField("charge_strategy_id")
+    private Long chargeStrategyId;
+
+    /**
+     * 应用的收费策略描述，如10元/吨
+     */
+    @TableField("charge_strategy_desc")
+    private String chargeStrategyDesc;
+
 
 }

sckw-modules/sckw-order/src/main/java/com/sckw/order/model/vo/res/TradeOrderAuditResp.java

@@ -0,0 +1,22 @@
+package com.sckw.order.model.vo.res;
+
+import lombok.Data;
+
+import java.io.Serial;
+import java.io.Serializable;
+import java.math.BigDecimal;
+
+/**
+ * 贸易订单审核结果
+ */
+@Data
+public class TradeOrderAuditResp implements Serializable {
+
+    @Serial
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 采购方服务费余额
+     */
+    private BigDecimal serviceFeeBalance;
+}

sckw-modules/sckw-order/src/main/java/com/sckw/order/serivce/KwoTradeOrderService.java

@@ -81,13 +81,16 @@ import com.sckw.system.api.feign.DataPermissionFeignService;
 import com.sckw.system.api.model.dto.req.ActualDisPatchDto;
 import com.sckw.system.api.model.dto.req.DataPermissionFilterReqDto;
 import com.sckw.system.api.model.dto.res.*;
+import com.sckw.transport.api.dubbo.ParkingWalletFeeRemoteService;
 import com.sckw.transport.api.dubbo.TransportRemoteStatisticsService;
 import com.sckw.transport.api.dubbo.TransportRemoteService;
 import com.sckw.transport.api.model.param.AddLogisticOrderParam;
 import com.sckw.transport.api.model.param.LogisticInfo;
 import com.sckw.transport.api.model.param.OrderFinishParam;
+import com.sckw.transport.api.model.param.ParkingWalletFeeFreezeParam;
 import com.sckw.transport.api.model.vo.KwtLogisticsOrderVO;
 import com.sckw.transport.api.model.vo.LogisticContractVo;
+import com.sckw.transport.api.model.vo.ParkingWalletFeeFreezeResult;
 import jakarta.annotation.Resource;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -160,6 +163,9 @@ public class KwoTradeOrderService {
     @DubboReference(version = "1.0.0", group = "design", check = false, timeout = 6000)
     private TransportRemoteStatisticsService transportRemoteStatisticsService;
 
+    @DubboReference(version = "1.0.0", group = "design", check = false, timeout = 6000)
+    private ParkingWalletFeeRemoteService parkingWalletFeeRemoteService;
+
     @DubboReference(version = "1.0.0", group = "design", check = false, timeout = 6000)
     protected RemoteFleetService remoteFleetService;
 
@@ -2561,6 +2567,20 @@ public class KwoTradeOrderService {
         }
         // ====== 下单前校验 end ======
 
+        // 收费策略开启时冻结采购方服务费，并记录订单收费策略信息
+        Long purchaseEntId = resolvePurchaseEntId(tradeContractResDto.getUnitList());
+        Long supplyEntId = resolveSupplyEntId(tradeContractResDto.getUnitList());
+        ParkingWalletFeeFreezeParam feeFreezeParam = new ParkingWalletFeeFreezeParam();
+        feeFreezeParam.setOrderNo(order.getTOrderNo());
+        feeFreezeParam.setProEntId(purchaseEntId);
+        feeFreezeParam.setSupEntId(supplyEntId);
+        feeFreezeParam.setPurchaseQuantity(tradeOrderParam.getAmount());
+        feeFreezeParam.setOperatorId(LoginUserHolder.getUserId());
+        log.info("贸易订单下单应用收费策略，orderNo:{}, feeFreezeParam:{}", order.getTOrderNo(), JSON.toJSONString(feeFreezeParam));
+        ParkingWalletFeeFreezeResult feeFreezeResult = parkingWalletFeeRemoteService.applyChargeStrategyFreeze(feeFreezeParam);
+        fillChargeStrategyInfo(order, feeFreezeResult);
+        log.info("贸易订单收费策略处理完成，orderNo:{}, feeFreezeResult:{}", order.getTOrderNo(), JSON.toJSONString(feeFreezeResult));
+
         //商品地址信息
         AddressInfoDetail goodsAddress = goodsInfoService.getGoodsAddress(tradeOrderParam.getGoodsId());
         if (Objects.isNull(goodsAddress)) {
@@ -2763,6 +2783,49 @@ public class KwoTradeOrderService {
         return StrUtil.equals(contractUnitType, "1") ? "2" : "1";
     }
 
+    /**
+     * 解析贸易合同中的采购方企业id
+     */
+    private Long resolvePurchaseEntId(List<TradeContractUnitDto> unitList) {
+        if (CollUtil.isEmpty(unitList)) {
+            throw new BusinessException("贸易合同企业信息不存在");
+        }
+        return unitList.stream()
+                .filter(unit -> StrUtil.equals(convertContractUnitTypeToOrderUnitType(unit.getUnitType()), "1"))
+                .map(TradeContractUnitDto::getEntId)
+                .filter(Objects::nonNull)
+                .findFirst()
+                .orElseThrow(() -> new BusinessException("采购方企业信息不存在"));
+    }
+
+    /**
+     * 解析贸易合同中的供应方企业id
+     */
+    private Long resolveSupplyEntId(List<TradeContractUnitDto> unitList) {
+        if (CollUtil.isEmpty(unitList)) {
+            throw new BusinessException("贸易合同企业信息不存在");
+        }
+        return unitList.stream()
+                .filter(unit -> StrUtil.equals(convertContractUnitTypeToOrderUnitType(unit.getUnitType()), "2"))
+                .map(TradeContractUnitDto::getEntId)
+                .filter(Objects::nonNull)
+                .findFirst()
+                .orElseThrow(() -> new BusinessException("供应方企业信息不存在"));
+    }
+
+    /**
+     * 回填贸易订单收费策略信息
+     */
+    private void fillChargeStrategyInfo(KwoTradeOrder order, ParkingWalletFeeFreezeResult feeFreezeResult) {
+        if (feeFreezeResult == null) {
+            order.setApplyChargeStrategy(Global.NO);
+            return;
+        }
+        order.setApplyChargeStrategy(feeFreezeResult.getApplyChargeStrategy() == null ? Global.NO : feeFreezeResult.getApplyChargeStrategy());
+        order.setChargeStrategyId(feeFreezeResult.getChargeStrategyId());
+        order.setChargeStrategyDesc(feeFreezeResult.getChargeStrategyDesc());
+    }
+
     /**
      * 代理订单创建物流订单时，将贸易订单企业表中的代理单位同步传递给运输模块。
      *
@@ -2951,7 +3014,7 @@ public class KwoTradeOrderService {
      * @return
      */
     @Transactional(rollbackFor = Exception.class)
-    public Object auditOrder(TradeOrderAuditParam tradeOrderAuditParam) {
+    public TradeOrderAuditResp auditOrder(TradeOrderAuditParam tradeOrderAuditParam) {
         KwoTradeOrder kwoTradeOrder = kwoTradeOrderMapper.selectOne(new LambdaQueryWrapper<KwoTradeOrder>().eq(KwoTradeOrder::getId, tradeOrderAuditParam.getId()).eq(KwoTradeOrder::getDelFlag, 0));
         if (Objects.isNull(kwoTradeOrder)) {
             throw new BusinessException("贸易订单不存在");
@@ -2981,6 +3044,21 @@ public class KwoTradeOrderService {
         }
 
         if (Objects.equals(tradeOrderAuditParam.getStatus(), 2)) {
+            BigDecimal serviceFeeBalance = null;
+            // 审核拒绝：若应用了收费策略，解冻并返还采购方服务费余额
+            if (Objects.equals(kwoTradeOrder.getApplyChargeStrategy(), Global.YES)) {
+                ParkingWalletFeeFreezeParam serviceFeeUnfreezeParam = new ParkingWalletFeeFreezeParam();
+                serviceFeeUnfreezeParam.setOrderNo(kwoTradeOrder.getTOrderNo());
+                serviceFeeUnfreezeParam.setProEntId(unitMap.get(String.valueOf(1)).getEntId());
+                serviceFeeUnfreezeParam.setSupEntId(unitMap.get(String.valueOf(2)).getEntId());
+                serviceFeeUnfreezeParam.setOperatorId(LoginUserHolder.getUserId());
+                log.info("贸易订单审核拒绝解冻服务费，orderNo:{}, param:{}",
+                        kwoTradeOrder.getTOrderNo(), JSON.toJSONString(serviceFeeUnfreezeParam));
+                ParkingWalletFeeFreezeResult unfreezeResult =
+                        parkingWalletFeeRemoteService.unfreezeChargeStrategy(serviceFeeUnfreezeParam);
+                serviceFeeBalance = unfreezeResult.getServiceFeeBalance();
+            }
+
             //钱包退回金额
             WalletPrepaidDto walletFreeze = new WalletPrepaidDto();
 //            walletFreeze.setTTradeOrderId(kwoTradeOrder.getId());
@@ -3017,7 +3095,7 @@ public class KwoTradeOrderService {
             kwoTradeOrderTrackService.insert(kwoTradeOrderTrack);
             kwoTradeOrder.setStatus(Objects.equals(tradeOrderAuditParam.getStatus(), 2) ? TradeOrderStatusEnum.BACK.getCode() : TradeOrderStatusEnum.ING.getCode());
             kwoTradeOrderMapper.updateById(kwoTradeOrder);
-            return true;
+            return buildAuditServiceFeeBalanceResp(kwoTradeOrder, unitMap, serviceFeeBalance);
         }
         TradeContractResDto tradeContractResDto = remoteContractService.queryTradeContract(tradeOrderAuditParam.getTradeContractId(), byOrderId.getGoodsId());
         if (Objects.isNull(tradeContractResDto)) {
@@ -3270,7 +3348,27 @@ public class KwoTradeOrderService {
         //更新贸易订单状态
         kwoTradeOrder.setStatus(Objects.equals(tradeOrderAuditParam.getStatus(), 2) ? TradeOrderStatusEnum.BACK.getCode() : TradeOrderStatusEnum.ING.getCode());
         kwoTradeOrderMapper.updateById(kwoTradeOrder);
-        return true;
+        return buildAuditServiceFeeBalanceResp(kwoTradeOrder, unitMap, null);
+    }
+
+    /**
+     * 构建审核结果，返回采购方服务费余额
+     */
+    private TradeOrderAuditResp buildAuditServiceFeeBalanceResp(KwoTradeOrder order,
+                                                                Map<String, KwoTradeOrderUnit> unitMap,
+                                                                BigDecimal serviceFeeBalance) {
+        TradeOrderAuditResp resp = new TradeOrderAuditResp();
+        if (!Objects.equals(order.getApplyChargeStrategy(), Global.YES)) {
+            return resp;
+        }
+        if (serviceFeeBalance != null) {
+            resp.setServiceFeeBalance(serviceFeeBalance);
+            return resp;
+        }
+        Long proEntId = unitMap.get(String.valueOf(1)).getEntId();
+        Long supEntId = unitMap.get(String.valueOf(2)).getEntId();
+        resp.setServiceFeeBalance(parkingWalletFeeRemoteService.queryServiceFeeBalance(proEntId, supEntId));
+        return resp;
     }
 
     @NotNull

sckw-modules/sckw-transport/src/main/java/com/sckw/transport/controller/ParkingChangeStrategyController.java

@@ -0,0 +1,101 @@
+package com.sckw.transport.controller;
+
+
+import com.sckw.core.web.response.BaseResult;
+import com.sckw.core.web.response.result.PageDataResult;
+import com.sckw.transport.model.ParkingChangeStrategySaveParam;
+import com.sckw.transport.model.param.ParkingChangeStrategyQueryParam;
+import com.sckw.transport.model.param.ParkingChangeStrategyResp;
+import com.sckw.transport.model.param.ParkingChangeStrategyUnitResp;
+import com.sckw.transport.model.param.ParkingChangeStrategyUnitSaveParam;
+import com.sckw.transport.service.ParkingChangeStrategyService;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import jakarta.validation.Valid;
+import lombok.RequiredArgsConstructor;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+
+/**
+ * Author: donglang
+ * Time: 2026-01-05
+ * Des: 收费策略Controller
+ * Version: 1.0
+ */
+
+@RestController
+@RequestMapping("/strategy")
+@RequiredArgsConstructor
+@Tag(name = "收费策略接口", description = "收费策略接口")
+public class ParkingChangeStrategyController {
+
+    private final ParkingChangeStrategyService parkingChangeStrategyService;
+
+    /**
+     * 分页查询门卫订单
+     *
+     * @param param
+     * @return
+     */
+    @Operation(summary = "分页查询收费策略", description = "分页查询收费策略")
+    @PostMapping("/pageQueryChangeStrategy")
+    public BaseResult<PageDataResult<ParkingChangeStrategyResp>> pageQueryChangeStrategy(@RequestBody @Valid ParkingChangeStrategyQueryParam param){
+        PageDataResult<ParkingChangeStrategyResp> gatekeeperOrderList = parkingChangeStrategyService.pageQueryChangeStrategy(param);
+        return BaseResult.success(gatekeeperOrderList);
+    }
+
+    /**
+     * 保存收费策略
+     *
+     * @param param
+     * @return
+     */
+    @Operation(summary = "保存收费策略", description = "保存收费策略")
+    @PostMapping("/saveChangeStrategy")
+    public BaseResult saveChangeStrategy(@RequestBody @Valid ParkingChangeStrategySaveParam param){
+        parkingChangeStrategyService.saveChangeStrategy(param);
+        return BaseResult.success();
+    }
+
+    /**
+     * 删除收费策略
+     *
+     * @param id
+     * @return
+     */
+    @Operation(summary = "删除收费策略", description = "删除收费策略")
+    @PostMapping("/deleteChangeStrategy")
+    public BaseResult deleteChangeStrategy(@RequestParam Long id){
+        parkingChangeStrategyService.deleteChangeStrategy(id);
+        return BaseResult.success();
+    }
+
+    /**
+     * 查询单位分配
+     *
+     * @param id
+     * @return
+     */
+    @Operation(summary = "查询单位分配", description = "查询单位分配")
+    @PostMapping("/queryChangeStrategyEnt")
+    public BaseResult<List<ParkingChangeStrategyUnitResp>> queryChangeStrategyEnt(@RequestParam Long id){
+        List<ParkingChangeStrategyUnitResp> changeStrategyUnitRespList = parkingChangeStrategyService.queryChangeStrategyEnt(id);
+        return BaseResult.success(changeStrategyUnitRespList);
+    }
+
+    /**
+     * 保存单位分配
+     *
+     * @param param
+     * @return
+     */
+    @Operation(summary = "保存单位分配", description = "保存单位分配")
+    @PostMapping("/saveChangeStrategyEnt")
+    public BaseResult saveChangeStrategyEnt(@RequestBody @Valid ParkingChangeStrategyUnitSaveParam param){
+        parkingChangeStrategyService.saveChangeStrategyEnt(param);
+        return BaseResult.success();
+    }
+
+
+}

sckw-modules/sckw-transport/src/main/java/com/sckw/transport/controller/ParkingWalletFeeController.java

@@ -0,0 +1,101 @@
+package com.sckw.transport.controller;
+
+
+import com.sckw.core.web.response.BaseResult;
+import com.sckw.core.web.response.result.PageDataResult;
+import com.sckw.transport.model.ParkingChangeStrategySaveParam;
+import com.sckw.transport.model.param.ParkingChangeStrategyQueryParam;
+import com.sckw.transport.model.param.ParkingChangeStrategyResp;
+import com.sckw.transport.model.param.ParkingChangeStrategyUnitResp;
+import com.sckw.transport.model.param.ParkingChangeStrategyUnitSaveParam;
+import com.sckw.transport.service.ParkingChangeStrategyService;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import jakarta.validation.Valid;
+import lombok.RequiredArgsConstructor;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+
+/**
+ * Author: donglang
+ * Time: 2026-01-05
+ * Des: 服务费
+ * Version: 1.0
+ */
+
+@RestController
+@RequestMapping("/parking/wallet")
+@RequiredArgsConstructor
+@Tag(name = "服务费接口", description = "服务费接口")
+public class ParkingWalletFeeController {
+
+    private final ParkingChangeStrategyService parkingChangeStrategyService;
+
+    /**
+     * 分页查询门卫订单
+     *
+     * @param param
+     * @return
+     */
+    @Operation(summary = "分页查询收费策略", description = "分页查询收费策略")
+    @PostMapping("/pageQueryChangeStrategy")
+    public BaseResult<PageDataResult<ParkingChangeStrategyResp>> pageQueryChangeStrategy(@RequestBody @Valid ParkingChangeStrategyQueryParam param){
+        PageDataResult<ParkingChangeStrategyResp> gatekeeperOrderList = parkingChangeStrategyService.pageQueryChangeStrategy(param);
+        return BaseResult.success(gatekeeperOrderList);
+    }
+
+    /**
+     * 保存收费策略
+     *
+     * @param param
+     * @return
+     */
+    @Operation(summary = "保存收费策略", description = "保存收费策略")
+    @PostMapping("/saveChangeStrategy")
+    public BaseResult saveChangeStrategy(@RequestBody @Valid ParkingChangeStrategySaveParam param){
+        parkingChangeStrategyService.saveChangeStrategy(param);
+        return BaseResult.success();
+    }
+
+    /**
+     * 删除收费策略
+     *
+     * @param id
+     * @return
+     */
+    @Operation(summary = "删除收费策略", description = "删除收费策略")
+    @PostMapping("/deleteChangeStrategy")
+    public BaseResult deleteChangeStrategy(@RequestParam Long id){
+        parkingChangeStrategyService.deleteChangeStrategy(id);
+        return BaseResult.success();
+    }
+
+    /**
+     * 查询单位分配
+     *
+     * @param id
+     * @return
+     */
+    @Operation(summary = "查询单位分配", description = "查询单位分配")
+    @PostMapping("/queryChangeStrategyEnt")
+    public BaseResult<List<ParkingChangeStrategyUnitResp>> queryChangeStrategyEnt(@RequestParam Long id){
+        List<ParkingChangeStrategyUnitResp> changeStrategyUnitRespList = parkingChangeStrategyService.queryChangeStrategyEnt(id);
+        return BaseResult.success(changeStrategyUnitRespList);
+    }
+
+    /**
+     * 保存单位分配
+     *
+     * @param param
+     * @return
+     */
+    @Operation(summary = "保存单位分配", description = "保存单位分配")
+    @PostMapping("/saveChangeStrategyEnt")
+    public BaseResult saveChangeStrategyEnt(@RequestBody @Valid ParkingChangeStrategyUnitSaveParam param){
+        parkingChangeStrategyService.saveChangeStrategyEnt(param);
+        return BaseResult.success();
+    }
+
+
+}

sckw-modules/sckw-transport/src/main/java/com/sckw/transport/controller/ParkingWalletFeeEstimateController.java

@@ -0,0 +1,35 @@
+package com.sckw.transport.controller;
+
+import com.sckw.core.web.response.BaseResult;
+import com.sckw.transport.model.param.ParkingWalletFeeEstimateQueryParam;
+import com.sckw.transport.model.param.ParkingWalletFeeEstimateResp;
+import com.sckw.transport.service.ParkingWalletFeeService;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import jakarta.validation.Valid;
+import lombok.RequiredArgsConstructor;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * Author: donglang
+ * Time: 2026-06-25
+ * Des: 服务费预估
+ * Version: 1.0
+ */
+@RestController
+@RequestMapping("/parking/wallet/fee")
+@RequiredArgsConstructor
+@Tag(name = "服务费预估接口", description = "服务费预估接口")
+public class ParkingWalletFeeEstimateController {
+
+    private final ParkingWalletFeeService parkingWalletFeeService;
+
+    @Operation(summary = "查询服务费余额、本次预计服务费与最大可购买数量", description = "查询服务费余额、本次预计服务费与最大可购买数量")
+    @PostMapping("/queryEstimate")
+    public BaseResult<ParkingWalletFeeEstimateResp> queryEstimate(@RequestBody @Valid ParkingWalletFeeEstimateQueryParam param) {
+        return BaseResult.success(parkingWalletFeeService.queryEstimateServiceFee(param));
+    }
+}

sckw-modules/sckw-transport/src/main/java/com/sckw/transport/dao/KwtParkingChangeStrategyMapper.java

@@ -0,0 +1,16 @@
+package com.sckw.transport.dao;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.sckw.transport.model.KwtParkingChargeStrategy;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * @author zk
+ * @desc 门卫车辆订单
+ * @date 2026/01/06
+ */
+@Mapper
+public interface KwtParkingChangeStrategyMapper extends BaseMapper<KwtParkingChargeStrategy> {
+
+
+}

sckw-modules/sckw-transport/src/main/java/com/sckw/transport/dao/KwtParkingChangeStrategyUnitMapper.java

@@ -0,0 +1,16 @@
+package com.sckw.transport.dao;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.sckw.transport.model.KwtParkingChargeStrategyUnit;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * @author zk
+ * @desc 门卫车辆订单
+ * @date 2026/01/06
+ */
+@Mapper
+public interface KwtParkingChangeStrategyUnitMapper extends BaseMapper<KwtParkingChargeStrategyUnit> {
+
+
+}

sckw-modules/sckw-transport/src/main/java/com/sckw/transport/dao/KwtParkingWalletFeeBalanceMapper.java

@@ -0,0 +1,16 @@
+package com.sckw.transport.dao;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.sckw.transport.model.KwtParkingWalletFeeBalance;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * @author zk
+ * @desc 门卫车辆订单
+ * @date 2026/01/06
+ */
+@Mapper
+public interface KwtParkingWalletFeeBalanceMapper extends BaseMapper<KwtParkingWalletFeeBalance> {
+
+
+}

sckw-modules/sckw-transport/src/main/java/com/sckw/transport/dao/KwtParkingWalletFeeMapper.java

@@ -0,0 +1,17 @@
+package com.sckw.transport.dao;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.sckw.transport.model.KwtParkingChargeStrategy;
+import com.sckw.transport.model.KwtParkingWalletFee;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * @author zk
+ * @desc 门卫车辆订单
+ * @date 2026/01/06
+ */
+@Mapper
+public interface KwtParkingWalletFeeMapper extends BaseMapper<KwtParkingWalletFee> {
+
+
+}

sckw-modules/sckw-transport/src/main/java/com/sckw/transport/dubbo/ParkingWalletFeeRemoteServiceImpl.java

@@ -0,0 +1,37 @@
+package com.sckw.transport.dubbo;
+
+import com.sckw.transport.api.dubbo.ParkingWalletFeeRemoteService;
+import com.sckw.transport.api.model.param.ParkingWalletFeeFreezeParam;
+import com.sckw.transport.api.model.vo.ParkingWalletFeeFreezeResult;
+import com.sckw.transport.service.ParkingWalletFeeService;
+import lombok.RequiredArgsConstructor;
+import org.apache.dubbo.config.annotation.DubboService;
+import org.springframework.stereotype.Service;
+
+import java.math.BigDecimal;
+
+/**
+ * 服务费远程服务实现
+ */
+@Service
+@DubboService(group = "design", version = "1.0.0", timeout = 60000)
+@RequiredArgsConstructor
+public class ParkingWalletFeeRemoteServiceImpl implements ParkingWalletFeeRemoteService {
+
+    private final ParkingWalletFeeService parkingWalletFeeService;
+
+    @Override
+    public ParkingWalletFeeFreezeResult applyChargeStrategyFreeze(ParkingWalletFeeFreezeParam param) {
+        return parkingWalletFeeService.applyChargeStrategyFreeze(param);
+    }
+
+    @Override
+    public ParkingWalletFeeFreezeResult unfreezeChargeStrategy(ParkingWalletFeeFreezeParam param) {
+        return parkingWalletFeeService.unfreezeChargeStrategy(param);
+    }
+
+    @Override
+    public BigDecimal queryServiceFeeBalance(Long proEntId, Long supEntId) {
+        return parkingWalletFeeService.queryPurchaserServiceFeeBalance(proEntId, supEntId);
+    }
+}

sckw-modules/sckw-transport/src/main/java/com/sckw/transport/model/KwtParkingChargeStrategy.java

@@ -0,0 +1,73 @@
+package com.sckw.transport.model;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.math.BigDecimal;
+import java.util.Date;
+
+/**
+ * @author lfdc
+ * @description 收费策略
+ * @date 2023-06-26 16:06:12
+ */
+@Data
+@TableName("kwt_parking_charge_strategy")
+public class KwtParkingChargeStrategy implements Serializable {
+
+    /**
+     * 主键
+     */
+    private Long id;
+
+    /**
+     * 策略名称
+     */
+    private String strategyName;
+
+    /**
+     * 策略类型（1-按吨计费，2-按次计费、3-按月计费）
+     */
+    private Integer type;
+
+    /**
+     * 计价方式
+     */
+    private BigDecimal method;
+
+    /**
+     * 状态（0-关闭，1-开启）
+     */
+    private Integer status;
+
+    /**
+     * 备注
+     */
+    private String remark;
+
+    /**
+     * 创建人
+     */
+    private Long createBy;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 创建人更新人
+     */
+    private Long updateBy;
+
+    /**
+     * 更新时间
+     */
+    private Date updateTime;
+
+    /**
+     * 是否删除（0未删除，1删除）
+     */
+    private Integer delFlag;
+}

sckw-modules/sckw-transport/src/main/java/com/sckw/transport/model/KwtParkingChargeStrategyUnit.java

@@ -0,0 +1,57 @@
+package com.sckw.transport.model;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * @author lfdc
+ * @description 收费策略
+ * @date 2023-06-26 16:06:12
+ */
+@Data
+@TableName("kwt_parking_charge_strategy_unit")
+public class KwtParkingChargeStrategyUnit implements Serializable {
+
+    /**
+     * 主键
+     */
+    private Long id;
+
+    /**
+     * 策略id
+     */
+    private Long strategyId;
+
+    /**
+     * 企业id
+     */
+    private Long entId;
+
+    /**
+     * 创建人
+     */
+    private Long createBy;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 创建人更新人
+     */
+    private Long updateBy;
+
+    /**
+     * 更新时间
+     */
+    private Date updateTime;
+
+    /**
+     * 是否删除（0未删除，1删除）
+     */
+    private Integer delFlag;
+}

sckw-modules/sckw-transport/src/main/java/com/sckw/transport/model/KwtParkingWalletFee.java

@@ -0,0 +1,75 @@
+package com.sckw.transport.model;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.math.BigDecimal;
+import java.util.Date;
+
+/**
+ * 预存服务费
+ */
+@Data
+@TableName("kwt_parking_wallet_fee")
+public class KwtParkingWalletFee implements Serializable {
+
+    /**
+     * 主键
+     */
+    private Long id;
+
+    /**
+     * 采购商企业id
+     */
+    private Long proEntId;
+
+    /**
+     * 供应商企业id
+     */
+    @TableField("sup_ent_id")
+    private Long supEntId;
+
+    /**
+     * 服务费余额
+     */
+    private BigDecimal serviceFeeBalance;
+
+    /**
+     * 履约中金额
+     */
+    private BigDecimal tradingAmount;
+
+    /**
+     * 备注
+     */
+    private String remark;
+
+    /**
+     * 创建人
+     */
+    @TableField("create_user")
+    private Long createUser;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 更新人
+     */
+    @TableField("update_user")
+    private Long updateUser;
+
+    /**
+     * 更新时间
+     */
+    private Date updateTime;
+
+    /**
+     * 是否删除（0未删除，1删除）
+     */
+    private Integer delFlag;
+}

sckw-modules/sckw-transport/src/main/java/com/sckw/transport/model/KwtParkingWalletFeeBalance.java

@@ -0,0 +1,96 @@
+package com.sckw.transport.model;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.math.BigDecimal;
+import java.util.Date;
+
+/**
+ * 预存服务费明细（钱包日志）
+ */
+@Data
+@TableName("kwt_parking_wallet_fee_balance")
+public class KwtParkingWalletFeeBalance implements Serializable {
+
+    /**
+     * 主键
+     */
+    private Long id;
+
+    /**
+     * 关联订单编号
+     */
+    private String orderNo;
+
+    /**
+     * 采购商企业id
+     */
+    private Long proEntId;
+
+    /**
+     * 供应商企业id
+     */
+    @TableField("sup_ent_id")
+    private Long supEntId;
+
+    /**
+     * 交易类型 2-预付 3-收益 4-冻结 5-解冻 6-消费 9-人工录入
+     */
+    private Integer tradeType;
+
+    /**
+     * 交易金额
+     */
+    private BigDecimal tradeAmount;
+
+    /**
+     * 服务费余额
+     */
+    private BigDecimal serviceFeeBalance;
+
+    /**
+     * 履约中金额
+     */
+    private BigDecimal tradingAmount;
+
+    /**
+     * 凭证图片
+     */
+    @TableField("voucher_url")
+    private String voucherUrl;
+
+    /**
+     * 备注
+     */
+    private String remark;
+
+    /**
+     * 创建人
+     */
+    @TableField("create_user")
+    private Long createUser;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 更新人
+     */
+    @TableField("update_user")
+    private Long updateUser;
+
+    /**
+     * 更新时间
+     */
+    private Date updateTime;
+
+    /**
+     * 是否删除（0未删除，1删除）
+     */
+    private Integer delFlag;
+}

sckw-modules/sckw-transport/src/main/java/com/sckw/transport/model/ParkingChangeStrategySaveParam.java

@@ -0,0 +1,65 @@
+package com.sckw.transport.model;
+
+import com.sckw.core.web.request.PageReq;
+import io.swagger.v3.oas.annotations.media.Schema;
+import jakarta.validation.constraints.NotBlank;
+import jakarta.validation.constraints.NotNull;
+import lombok.Data;
+
+import java.io.Serial;
+import java.io.Serializable;
+import java.math.BigDecimal;
+
+/**
+ * @author :donglang
+ * @version :1.0
+ * @description : 收费策略
+ * @create :2026-01-05 08:59:00
+ */
+@Data
+public class ParkingChangeStrategySaveParam extends PageReq implements Serializable {
+
+    @Serial
+    private static final long serialVersionUID = -5431003248533000828L;
+
+    /**
+     * 主键id
+     */
+    @Schema(description = "主键id")
+    private Long id;
+
+    /**
+     * 策略名称
+     */
+    @NotBlank(message = "策略名称不能为空")
+    @Schema(description = "策略名称")
+    private String strategyName;
+
+    /**
+     * 策略类型（1-按吨计费，2-按次计费、3-按月计费）
+     */
+    @NotNull(message = "策略类型不能为空")
+    @Schema(description = "策略类型")
+    private Integer type;
+
+    /**
+     * 计价方式
+     */
+    @NotNull(message = "计价方式不能为空")
+    @Schema(description = "计价方式")
+    private BigDecimal method;
+
+    /**
+     * 状态（0-关闭，1-开启）
+     */
+    @Schema(description = "状态")
+    private Integer status;
+
+    /**
+     * 备注
+     */
+    @Schema(description = "计价方式")
+    private String remark;
+
+
+}

sckw-modules/sckw-transport/src/main/java/com/sckw/transport/model/param/ParkingChangeStrategyQueryParam.java

@@ -0,0 +1,49 @@
+package com.sckw.transport.model.param;
+
+import com.sckw.core.web.request.PageReq;
+import io.swagger.v3.oas.annotations.media.Schema;
+import jakarta.validation.constraints.NotNull;
+import lombok.Data;
+
+import java.io.Serial;
+import java.io.Serializable;
+
+/**
+ * @author :donglang
+ * @version :1.0
+ * @description : 收费策略
+ * @create :2026-01-05 08:59:00
+ */
+@Data
+public class ParkingChangeStrategyQueryParam extends PageReq implements Serializable {
+
+    @Serial
+    private static final long serialVersionUID = -5431003248533000828L;
+
+    /**
+     * 平台企业id
+     */
+    @NotNull(message = "平台企业id不能为空")
+    @Schema(description = "平台企业id")
+    private Long entId;
+
+    /**
+     * 策略名称
+     */
+    @Schema(description = "策略名称")
+    private String strategyName;
+
+    /**
+     * 策略类型（1-按吨计费，2-按次计费、3-按月计费）
+     */
+    @Schema(description = "策略类型")
+    private Integer type;
+
+    /**
+     * 单位名称
+     */
+    @Schema(description = "单位名称")
+    private String entName;
+
+
+}

sckw-modules/sckw-transport/src/main/java/com/sckw/transport/model/param/ParkingChangeStrategyResp.java

@@ -0,0 +1,92 @@
+package com.sckw.transport.model.param;
+
+import lombok.Data;
+
+import java.io.Serial;
+import java.io.Serializable;
+import java.math.BigDecimal;
+import java.util.Date;
+
+/**
+ * @author :chenXiaoFei
+ * @version :1.0
+ * @description : 分页查询收费策略
+ * @create :2025-11-11 20:16:00
+ */
+@Data
+public class ParkingChangeStrategyResp implements Serializable {
+
+    @Serial
+    private static final long serialVersionUID = -6153312023002477484L;
+
+    /**
+     * 主键
+     */
+    private Long id;
+
+    /**
+     * 策略名称
+     */
+    private String strategyName;
+
+    /**
+     * 策略类型（1-按吨计费，2-按次计费、3-按月计费）
+     */
+    private Integer type;
+
+    /**
+     * 策略类型描述
+     */
+    private String typeDesc;
+
+    /**
+     * 计价方式
+     */
+    private BigDecimal method;
+
+    /**
+     * 计价方式
+     */
+    private String methodDesc;
+
+    /**
+     * 	使用单位数
+     */
+    private Integer EntNumber;
+
+    /**
+     * 状态（0-关闭，1-开启）
+     */
+    private Integer status;
+
+    /**
+     * 备注
+     */
+    private String remark;
+
+    /**
+     * 创建人
+     */
+    private Long createBy;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 创建人更新人
+     */
+    private Long updateBy;
+
+    /**
+     * 更新时间
+     */
+    private Date updateTime;
+
+    /**
+     * 是否删除（0未删除，1删除）
+     */
+    private Integer delFlag;
+
+}

sckw-modules/sckw-transport/src/main/java/com/sckw/transport/model/param/ParkingChangeStrategyUnitResp.java

@@ -0,0 +1,40 @@
+package com.sckw.transport.model.param;
+
+import lombok.Data;
+
+import java.io.Serial;
+import java.io.Serializable;
+
+/**
+ * @author :chenXiaoFei
+ * @version :1.0
+ * @description : 查询收费策略分配单位
+ * @create :2025-11-11 20:16:00
+ */
+@Data
+public class ParkingChangeStrategyUnitResp implements Serializable {
+
+    @Serial
+    private static final long serialVersionUID = -6153312023002477484L;
+
+    /**
+     * 主键
+     */
+    private Long id;
+
+    /**
+     * 策略id
+     */
+    private Long strategyId;
+
+    /**
+     * 企业id
+     */
+    private Long entId;
+
+    /**
+     * 企业名称
+     */
+    private String entName;
+
+}

sckw-modules/sckw-transport/src/main/java/com/sckw/transport/model/param/ParkingChangeStrategyUnitSaveParam.java

@@ -0,0 +1,37 @@
+package com.sckw.transport.model.param;
+
+import com.sckw.core.web.request.PageReq;
+import io.swagger.v3.oas.annotations.media.Schema;
+import jakarta.validation.constraints.NotNull;
+import lombok.Data;
+
+import java.io.Serial;
+import java.io.Serializable;
+import java.util.List;
+
+/**
+ * @author :donglang
+ * @version :1.0
+ * @description : 收费策略
+ * @create :2026-01-05 08:59:00
+ */
+@Data
+public class ParkingChangeStrategyUnitSaveParam extends PageReq implements Serializable {
+
+    @Serial
+    private static final long serialVersionUID = -5431003248533000828L;
+
+    /**
+     * 收费策略id
+     */
+    @NotNull(message = "收费策略id不能为空")
+    @Schema(description = "收费策略id")
+    private Long strategyId;
+
+    /**
+     * 单位id
+     */
+    @Schema(description = "单位id")
+    private List<Long> entIds;
+
+}

sckw-modules/sckw-transport/src/main/java/com/sckw/transport/model/param/ParkingWalletFeeEstimateQueryParam.java

@@ -0,0 +1,25 @@
+package com.sckw.transport.model.param;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import jakarta.validation.constraints.DecimalMin;
+import jakarta.validation.constraints.NotNull;
+import lombok.Data;
+
+import java.io.Serial;
+import java.io.Serializable;
+import java.math.BigDecimal;
+
+/**
+ * 服务费预估查询参数
+ */
+@Data
+public class ParkingWalletFeeEstimateQueryParam implements Serializable {
+
+    @Serial
+    private static final long serialVersionUID = -5630735374527006854L;
+
+    @NotNull(message = "采购数量不能为空")
+    @DecimalMin(value = "0", message = "采购数量不能小于0")
+    @Schema(description = "本次采购数量")
+    private BigDecimal purchaseQuantity;
+}

sckw-modules/sckw-transport/src/main/java/com/sckw/transport/model/param/ParkingWalletFeeEstimateResp.java

@@ -0,0 +1,36 @@
+package com.sckw.transport.model.param;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Data;
+
+import java.io.Serial;
+import java.io.Serializable;
+import java.math.BigDecimal;
+
+/**
+ * 服务费预估结果
+ */
+@Data
+public class ParkingWalletFeeEstimateResp implements Serializable {
+
+    @Serial
+    private static final long serialVersionUID = -5146116069901904418L;
+
+    /**
+     * 服务费余额
+     */
+    @Schema(description = "服务费余额")
+    private BigDecimal serviceFeeBalance;
+
+    /**
+     * 本次预计服务费
+     */
+    @Schema(description = "本次预计服务费")
+    private BigDecimal estimatedServiceFee;
+
+    /**
+     * 最大可购买数量（收费策略开启时，按服务费余额/策略单价计算）
+     */
+    @Schema(description = "最大可购买数量")
+    private BigDecimal maxPurchaseQuantity;
+}

sckw-modules/sckw-transport/src/main/java/com/sckw/transport/repository/KwtParkingChangeStrategyRepository.java

@@ -0,0 +1,28 @@
+package com.sckw.transport.repository;
+
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.sckw.transport.dao.KwtParkingChangeStrategyMapper;
+import com.sckw.transport.model.KwtParkingChargeStrategy;
+import org.springframework.stereotype.Repository;
+
+import java.util.List;
+
+/**
+ * @Author: 门卫车辆订单
+ * @CreateTime: 2025-10-12
+ * @Description:
+ * @Version: 1.0
+ */
+
+@Repository
+public class KwtParkingChangeStrategyRepository extends ServiceImpl<KwtParkingChangeStrategyMapper, KwtParkingChargeStrategy> {
+
+
+    public List<KwtParkingChargeStrategy> queryParkingChangeStrategy() {
+        return list(
+                Wrappers.<KwtParkingChargeStrategy>lambdaQuery()
+                        .orderByDesc(KwtParkingChargeStrategy::getId));
+    }
+
+}

sckw-modules/sckw-transport/src/main/java/com/sckw/transport/repository/KwtParkingChangeStrategyUnitRepository.java

@@ -0,0 +1,35 @@
+package com.sckw.transport.repository;
+
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.sckw.transport.dao.KwtParkingChangeStrategyUnitMapper;
+import com.sckw.transport.model.KwtParkingChargeStrategyUnit;
+import org.springframework.stereotype.Repository;
+
+import java.util.List;
+
+/**
+ * @Author: 门卫车辆订单
+ * @CreateTime: 2025-10-12
+ * @Description:
+ * @Version: 1.0
+ */
+
+@Repository
+public class KwtParkingChangeStrategyUnitRepository extends ServiceImpl<KwtParkingChangeStrategyUnitMapper, KwtParkingChargeStrategyUnit> {
+
+
+    public List<KwtParkingChargeStrategyUnit> queryByStrategyId(Long id) {
+        return list(
+                Wrappers.<KwtParkingChargeStrategyUnit>lambdaQuery()
+                        .eq(KwtParkingChargeStrategyUnit::getStrategyId, id)
+                        .orderByDesc(KwtParkingChargeStrategyUnit::getId));
+    }
+
+    public void deleteByStrategyId(Long id) {
+        remove(
+                Wrappers.<KwtParkingChargeStrategyUnit>lambdaQuery()
+                        .eq(KwtParkingChargeStrategyUnit::getStrategyId, id));
+    }
+
+}

sckw-modules/sckw-transport/src/main/java/com/sckw/transport/repository/KwtParkingWalletFeeBalanceRepository.java

@@ -0,0 +1,31 @@
+package com.sckw.transport.repository;
+
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.sckw.transport.dao.KwtParkingChangeStrategyUnitMapper;
+import com.sckw.transport.dao.KwtParkingWalletFeeBalanceMapper;
+import com.sckw.transport.model.KwtParkingChargeStrategy;
+import com.sckw.transport.model.KwtParkingChargeStrategyUnit;
+import com.sckw.transport.model.KwtParkingWalletFeeBalance;
+import org.springframework.stereotype.Repository;
+
+import java.util.List;
+
+/**
+ * @Author: 门卫车辆订单
+ * @CreateTime: 2025-10-12
+ * @Description:
+ * @Version: 1.0
+ */
+
+@Repository
+public class KwtParkingWalletFeeBalanceRepository extends ServiceImpl<KwtParkingWalletFeeBalanceMapper, KwtParkingWalletFeeBalance> {
+
+
+    public List<KwtParkingWalletFeeBalance> queryParkingChangeStrategy() {
+        return list(
+                Wrappers.<KwtParkingWalletFeeBalance>lambdaQuery()
+                        .orderByDesc(KwtParkingWalletFeeBalance::getId));
+    }
+
+}

sckw-modules/sckw-transport/src/main/java/com/sckw/transport/repository/KwtParkingWalletFeeRepository.java

@@ -0,0 +1,28 @@
+package com.sckw.transport.repository;
+
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.sckw.transport.dao.KwtParkingWalletFeeMapper;
+import com.sckw.transport.model.KwtParkingWalletFee;
+import org.springframework.stereotype.Repository;
+
+import java.util.List;
+
+/**
+ * @Author: 门卫车辆订单
+ * @CreateTime: 2025-10-12
+ * @Description:
+ * @Version: 1.0
+ */
+
+@Repository
+public class KwtParkingWalletFeeRepository extends ServiceImpl<KwtParkingWalletFeeMapper, KwtParkingWalletFee> {
+
+
+    public List<KwtParkingWalletFee> queryParkingChangeStrategy() {
+        return list(
+                Wrappers.<KwtParkingWalletFee>lambdaQuery()
+                        .orderByDesc(KwtParkingWalletFee::getId));
+    }
+
+}

sckw-modules/sckw-transport/src/main/java/com/sckw/transport/service/ParkingChangeStrategyService.java

@@ -0,0 +1,233 @@
+package com.sckw.transport.service;
+
+
+import com.alibaba.fastjson.JSON;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.sckw.core.common.enums.enums.ErrorCodeEnum;
+import com.sckw.core.exception.BusinessPlatfromException;
+import com.sckw.core.model.constant.Global;
+import com.sckw.core.model.enums.ParkingChangeStrategyEnum;
+import com.sckw.core.utils.CollectionUtils;
+import com.sckw.core.utils.StringUtils;
+import com.sckw.core.web.response.result.PageDataResult;
+import com.sckw.system.api.RemoteSystemService;
+import com.sckw.system.api.model.dto.res.EntCacheResDto;
+import com.sckw.transport.model.KwtParkingChargeStrategy;
+import com.sckw.transport.model.KwtParkingChargeStrategyUnit;
+import com.sckw.transport.model.ParkingChangeStrategySaveParam;
+import com.sckw.transport.model.param.ParkingChangeStrategyQueryParam;
+import com.sckw.transport.model.param.ParkingChangeStrategyResp;
+import com.sckw.transport.model.param.ParkingChangeStrategyUnitResp;
+import com.sckw.transport.model.param.ParkingChangeStrategyUnitSaveParam;
+import com.sckw.transport.repository.KwtParkingChangeStrategyRepository;
+import com.sckw.transport.repository.KwtParkingChangeStrategyUnitRepository;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.dubbo.config.annotation.DubboReference;
+import org.springframework.stereotype.Service;
+
+import java.util.Collections;
+import java.util.List;
+import java.util.Objects;
+import java.util.stream.Collectors;
+
+/**
+ * Author: donglang
+ * Time: 2026-01-05
+ * Des: 收费策略 Service
+ * Version: 1.0
+ */
+
+@Slf4j
+@Service
+@RequiredArgsConstructor
+public class ParkingChangeStrategyService {
+
+
+    private final KwtParkingChangeStrategyRepository parkingChangeStrategyRepository;
+    private final KwtParkingChangeStrategyUnitRepository parkingChangeStrategyUnitRepository;
+
+    @DubboReference(version = "1.0.0", group = "design", check = false, timeout = 6000)
+   RemoteSystemService remoteSystemService;
+
+    /**
+     * 分页查询收费策略
+     * @param param
+     */
+    public PageDataResult<ParkingChangeStrategyResp> pageQueryChangeStrategy(ParkingChangeStrategyQueryParam param) {
+        log.info("分页查询收费策略：{}", JSON.toJSONString(param));
+        if (param.getEntId() == null) {
+            throw new BusinessPlatfromException(ErrorCodeEnum.PARAM_ERROR, "平台企业id不能为空！");
+        }
+
+        //构建查询条件
+        LambdaQueryWrapper<KwtParkingChargeStrategy> wrapper = buildAndExecuteQuery(param);
+
+        //查询门卫订单
+        Page<KwtParkingChargeStrategy> pageByStatus = parkingChangeStrategyRepository.page(new Page<>(param.getPageNum(), param.getPageSize()), wrapper);
+        List<KwtParkingChargeStrategy> records = pageByStatus.getRecords();
+        if (CollectionUtils.isEmpty(records)) {
+            log.info("当前收费策略信息");
+            return PageDataResult.empty(param.getPageNum(), param.getPageSize());
+        }
+        List<ParkingChangeStrategyResp> changeStrategyRespList = getChangeStrategyPageResult(records);
+        return PageDataResult.success(param.getPageNum(), param.getPageSize(), pageByStatus.getTotal(), changeStrategyRespList);
+    }
+
+
+    /**
+     * 构建查询条件并执行分页查询
+     */
+    private LambdaQueryWrapper<KwtParkingChargeStrategy> buildAndExecuteQuery(ParkingChangeStrategyQueryParam param) {
+        return  Wrappers.<KwtParkingChargeStrategy>lambdaQuery()
+                .eq(param.getType() != null, KwtParkingChargeStrategy::getType, param.getType())
+                .like(StringUtils.isNotBlank(param.getStrategyName()), KwtParkingChargeStrategy::getStrategyName, param.getStrategyName())
+                .orderByDesc(KwtParkingChargeStrategy::getCreateBy);
+    }
+
+    /**
+     * 获取收费策略
+     * @param records
+     */
+    private List<ParkingChangeStrategyResp> getChangeStrategyPageResult(List<KwtParkingChargeStrategy> records) {
+        log.info("开始查询收费策略，param:{}", JSON.toJSONString(records));
+        if (CollectionUtils.isEmpty(records)) {
+            return Collections.emptyList();
+        }
+        List<ParkingChangeStrategyResp> changeStrategyList = records.stream()
+                .map(change -> {
+                    ParkingChangeStrategyResp resp = new ParkingChangeStrategyResp();
+                    resp.setId(change.getId());
+                    resp.setStrategyName(change.getStrategyName());
+                    resp.setType(change.getType());
+                    resp.setTypeDesc(ParkingChangeStrategyEnum.geDesc(change.getType()));
+                    resp.setMethod(change.getMethod());
+
+                    if (Objects.equals(ParkingChangeStrategyEnum.BY_TON, change.getType())) {
+                        resp.setMethodDesc(change.getMethod() + "元/吨");
+                    } else if (Objects.equals(ParkingChangeStrategyEnum.BY_TIME, change.getType())) {
+                        resp.setMethodDesc(change.getMethod() + "元/次");
+                    } else {
+                        resp.setMethodDesc(change.getMethod() + "元/月");
+                    }
+                    // 查询分配单位数量
+                    List<KwtParkingChargeStrategyUnit> strategyUnitList = parkingChangeStrategyUnitRepository.queryByStrategyId(change.getId());
+                    if (CollectionUtils.isEmpty(strategyUnitList)) {
+                        resp.setEntNumber(0);
+                    } else {
+                        resp.setEntNumber(strategyUnitList.size());
+                    }
+                    resp.setStatus(change.getStatus());
+                    resp.setRemark(change.getRemark());
+                    resp.setCreateTime(change.getCreateTime());
+                    return resp;
+                }).collect(Collectors.toList());
+
+        log.info("收费策略查询结束，size:{}", JSON.toJSONString(changeStrategyList.size()));
+        return changeStrategyList;
+
+    }
+
+
+    /**
+     * 保存收费策略
+     * @param param
+     */
+    public void saveChangeStrategy(ParkingChangeStrategySaveParam param) {
+        log.info("保存收费策略，param：{}", JSON.toJSONString(param));
+        // 新增
+        if (param.getId() == null) {
+            KwtParkingChargeStrategy changeStrategy = new KwtParkingChargeStrategy();
+            changeStrategy.setStrategyName(param.getStrategyName());
+            changeStrategy.setType(param.getType());
+            changeStrategy.setMethod(param.getMethod());
+            changeStrategy.setStatus(1);
+            changeStrategy.setRemark(param.getRemark());
+            parkingChangeStrategyRepository.save(changeStrategy);
+        } else {
+            // 更新
+            KwtParkingChargeStrategy changeStrategy = parkingChangeStrategyRepository.getById(param.getId());
+            if (changeStrategy == null) {
+                throw new BusinessPlatfromException(ErrorCodeEnum.DRIVER_NOT_FOUND, "收费策略不存在");
+            }
+            changeStrategy.setStrategyName(param.getStrategyName());
+            changeStrategy.setType(param.getType());
+            changeStrategy.setMethod(param.getMethod());
+            changeStrategy.setStatus(param.getStatus());
+            changeStrategy.setRemark(param.getRemark());
+            parkingChangeStrategyRepository.updateById(changeStrategy);
+        }
+    }
+
+    /**
+     * 删除收费策略
+     * @param id
+     */
+    public void deleteChangeStrategy(Long id) {
+        log.info("删除收费策略，id：{}", id);
+        // 新增
+        if (id == null) {
+            throw new BusinessPlatfromException(ErrorCodeEnum.DRIVER_NOT_FOUND, "id不存在");
+        }
+        KwtParkingChargeStrategy changeStrategy = parkingChangeStrategyRepository.getById(id);
+        if (changeStrategy == null) {
+            throw new BusinessPlatfromException(ErrorCodeEnum.DRIVER_NOT_FOUND, "收费策略不存在");
+        }
+        changeStrategy.setDelFlag(Global.YES);
+        parkingChangeStrategyRepository.updateById(changeStrategy);
+    }
+
+    /**
+     * 查询收费策略已分配单位
+     * @param id
+     * @return List<ParkingChangeStrategyUnitResp>
+     */
+    public List<ParkingChangeStrategyUnitResp> queryChangeStrategyEnt(Long id) {
+        log.info("查询收费策略已分配单位，id：{}", id);
+        List<KwtParkingChargeStrategyUnit> strategyUnitList = parkingChangeStrategyUnitRepository.queryByStrategyId(id);
+        if (CollectionUtils.isEmpty(strategyUnitList)) {
+            return Collections.emptyList();
+        }
+        return strategyUnitList.stream()
+                .map(unit -> {
+                    ParkingChangeStrategyUnitResp resp = new ParkingChangeStrategyUnitResp();
+                    resp.setId(unit.getId());
+                    resp.setStrategyId(id);
+                    resp.setEntId(unit.getEntId());
+
+                    // 查询企业名称
+                    EntCacheResDto entCacheResDto = remoteSystemService.queryEntDetails(unit.getEntId());
+                    resp.setEntName(entCacheResDto.getFirmName());
+                    return resp;
+                }).collect(Collectors.toList());
+    }
+
+    /**
+     * 保存单位分配
+     * @param param
+     */
+    public void saveChangeStrategyEnt(ParkingChangeStrategyUnitSaveParam param) {
+        log.info("保存单位分配，param：{}", JSON.toJSONString(param));
+        // 如果企业id为空，删除所以的单位关联关系
+        if (CollectionUtils.isEmpty(param.getEntIds())) {
+            parkingChangeStrategyUnitRepository.deleteByStrategyId(param.getStrategyId());
+        } else {
+            parkingChangeStrategyUnitRepository.deleteByStrategyId(param.getStrategyId());
+            // 构建关联表实体列表
+            List<KwtParkingChargeStrategyUnit> insertList = param.getEntIds().stream()
+                    .map(entId -> {
+                        KwtParkingChargeStrategyUnit unit = new KwtParkingChargeStrategyUnit();
+                        unit.setStrategyId(param.getStrategyId());
+                        unit.setEntId(entId);
+                        return unit;
+                    })
+                    .collect(Collectors.toList());
+
+            // 批量插入
+            parkingChangeStrategyUnitRepository.saveBatch(insertList);
+        }
+    }
+
+}

sckw-modules/sckw-transport/src/main/java/com/sckw/transport/service/ParkingWalletFeeService.java

@@ -0,0 +1,460 @@
+package com.sckw.transport.service;
+
+
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.sckw.core.common.enums.enums.ErrorCodeEnum;
+import com.sckw.core.exception.BusinessPlatfromException;
+import com.sckw.core.model.constant.Global;
+import com.sckw.core.model.enums.ParkingChangeStrategyEnum;
+import com.sckw.core.web.context.LoginUserHolder;
+import com.sckw.transport.model.KwtParkingChargeStrategy;
+import com.sckw.transport.model.KwtParkingChargeStrategyUnit;
+import com.sckw.transport.model.KwtParkingWalletFee;
+import com.sckw.transport.model.KwtParkingWalletFeeBalance;
+import com.sckw.transport.model.param.ParkingWalletFeeEstimateQueryParam;
+import com.sckw.transport.model.param.ParkingWalletFeeEstimateResp;
+import com.sckw.transport.api.model.param.ParkingWalletFeeFreezeParam;
+import com.sckw.transport.api.model.vo.ParkingWalletFeeFreezeResult;
+import com.sckw.transport.repository.KwtParkingChangeStrategyRepository;
+import com.sckw.transport.repository.KwtParkingChangeStrategyUnitRepository;
+import com.sckw.system.api.RemoteSystemService;
+import com.sckw.transport.repository.KwtParkingWalletFeeBalanceRepository;
+import com.sckw.transport.repository.KwtParkingWalletFeeRepository;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.collections4.CollectionUtils;
+import org.apache.dubbo.config.annotation.DubboReference;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.math.BigDecimal;
+import java.math.RoundingMode;
+import java.util.Comparator;
+import java.util.Date;
+import java.util.List;
+import java.util.Objects;
+
+/**
+ * Author: donglang
+ * Time: 2026-01-05
+ * Des: 收费策略 Service
+ * Version: 1.0
+ */
+
+@Slf4j
+@Service
+@RequiredArgsConstructor
+public class ParkingWalletFeeService {
+
+
+    private static final BigDecimal ZERO_AMOUNT = BigDecimal.ZERO;
+    private static final int STRATEGY_OPEN = 1;
+    private static final int TRADE_TYPE_FREEZE = 4;
+    private static final int TRADE_TYPE_UNFREEZE = 5;
+
+    private final KwtParkingWalletFeeRepository parkingWalletFeeRepository;
+    private final KwtParkingWalletFeeBalanceRepository parkingWalletFeeBalanceRepository;
+    private final KwtParkingChangeStrategyRepository parkingChangeStrategyRepository;
+    private final KwtParkingChangeStrategyUnitRepository parkingChangeStrategyUnitRepository;
+
+    @DubboReference(version = "1.0.0", group = "design", check = false, timeout = 6000)
+    RemoteSystemService remoteSystemService;
+
+    /**
+     * 查询服务费余额、本次预计服务费与最大可购买数量
+     * 规则：
+     * 1. 服务费余额 = 采购方当前服务费余额
+     * 2. 本次预计服务费 = 采购数量 * 采购方当前配置的收费策略单价
+     * 3. 最大可购买数量 = 收费策略开启时，服务费余额 / 策略单价；未开启时不返回余额约束
+     *
+     * @param param 查询参数
+     * @return 服务费余额、本次预计服务费与最大可购买数量
+     */
+    public ParkingWalletFeeEstimateResp queryEstimateServiceFee(ParkingWalletFeeEstimateQueryParam param) {
+        Long entId = LoginUserHolder.getEntId();
+        log.info("服务费预估开始，entId:{}, param:{}", entId, param);
+        if (param.getPurchaseQuantity() == null || param.getPurchaseQuantity().compareTo(ZERO_AMOUNT) < 0) {
+            log.warn("服务费预估参数异常，采购数量非法，entId:{}, purchaseQuantity:{}",
+                    entId, param.getPurchaseQuantity());
+            throw new BusinessPlatfromException(ErrorCodeEnum.PARAM_ERROR, "采购数量不能为空且不能小于0");
+        }
+
+        // 查询采购方当前服务费余额
+        BigDecimal serviceFeeBalance = queryServiceFeeBalance(entId, null);
+
+        // 查询当前企业生效中的收费策略（仅取状态开启的最新一条）
+        KwtParkingChargeStrategy currentStrategy = queryCurrentEnableStrategy(entId);
+        BigDecimal currentStrategyUnitFee = currentStrategy == null || currentStrategy.getMethod() == null
+                ? ZERO_AMOUNT : currentStrategy.getMethod();
+        log.info("服务费预估策略信息，entId:{}, strategyId:{}, strategyStatus:{}, unitFee:{}",
+                entId,
+                currentStrategy == null ? null : currentStrategy.getId(),
+                currentStrategy == null ? null : currentStrategy.getStatus(),
+                currentStrategyUnitFee);
+
+        // 本次预计服务费 = 采购数量 * 策略单价，金额统一保留2位
+        BigDecimal estimatedServiceFee = param.getPurchaseQuantity().multiply(currentStrategyUnitFee)
+                .setScale(2, RoundingMode.HALF_UP);
+
+        // 收费策略开关开启时，按服务费余额计算最大可购买数量
+        BigDecimal maxPurchaseQuantity = calculateMaxPurchaseQuantity(currentStrategy, currentStrategyUnitFee, serviceFeeBalance);
+        log.info("服务费预估计算完成，entId:{}, purchaseQuantity:{}, serviceFeeBalance:{}, estimatedServiceFee:{}, maxPurchaseQuantity:{}",
+                entId, param.getPurchaseQuantity(), serviceFeeBalance, estimatedServiceFee, maxPurchaseQuantity);
+
+        ParkingWalletFeeEstimateResp resp = new ParkingWalletFeeEstimateResp();
+        resp.setServiceFeeBalance(serviceFeeBalance);
+        resp.setEstimatedServiceFee(estimatedServiceFee);
+        resp.setMaxPurchaseQuantity(maxPurchaseQuantity);
+        log.info("服务费预估结束，entId:{}, resp:{}", entId, resp);
+        return resp;
+    }
+
+    /**
+     * 贸易订单下单应用收费策略并冻结服务费
+     * 规则：
+     * 1. 收费策略开关未开启时，不冻结服务费，订单记录为未应用收费策略
+     * 2. 收费策略开关开启时，冻结金额=采购数量*策略单价，并记录策略信息
+     *
+     * @param param 冻结参数
+     * @return 收费策略应用结果
+     */
+    @Transactional(rollbackFor = Exception.class)
+    public ParkingWalletFeeFreezeResult applyChargeStrategyFreeze(ParkingWalletFeeFreezeParam param) {
+        log.info("贸易订单应用收费策略开始，param:{}", param);
+        if (param == null || param.getProEntId() == null) {
+            throw new BusinessPlatfromException(ErrorCodeEnum.PARAM_ERROR, "采购方企业id不能为空");
+        }
+        if (param.getPurchaseQuantity() == null || param.getPurchaseQuantity().compareTo(ZERO_AMOUNT) < 0) {
+            throw new BusinessPlatfromException(ErrorCodeEnum.PARAM_ERROR, "采购数量不能为空且不能小于0");
+        }
+        if (param.getOrderNo() == null || param.getOrderNo().isBlank()) {
+            throw new BusinessPlatfromException(ErrorCodeEnum.PARAM_ERROR, "贸易订单号不能为空");
+        }
+
+        ParkingWalletFeeFreezeResult result = new ParkingWalletFeeFreezeResult();
+        result.setApplyChargeStrategy(Global.NO);
+        result.setFreezeAmount(ZERO_AMOUNT);
+
+        KwtParkingChargeStrategy currentStrategy = queryCurrentEnableStrategy(param.getProEntId());
+        if (currentStrategy == null || !Objects.equals(currentStrategy.getStatus(), STRATEGY_OPEN)) {
+            log.info("收费策略未开启或未匹配，跳过服务费冻结，proEntId:{}, orderNo:{}",
+                    param.getProEntId(), param.getOrderNo());
+            return result;
+        }
+
+        BigDecimal unitFee = currentStrategy.getMethod() == null ? ZERO_AMOUNT : currentStrategy.getMethod();
+        if (unitFee.compareTo(ZERO_AMOUNT) <= 0) {
+            log.info("收费策略单价无效，跳过服务费冻结，strategyId:{}, unitFee:{}",
+                    currentStrategy.getId(), unitFee);
+            return result;
+        }
+
+        BigDecimal freezeAmount = param.getPurchaseQuantity().multiply(unitFee).setScale(2, RoundingMode.HALF_UP);
+        KwtParkingWalletFee walletFee = queryWalletFee(param.getProEntId(), param.getSupEntId());
+        if (walletFee == null) {
+            log.warn("服务费账户不存在，proEntId:{}, supEntId:{}, orderNo:{}",
+                    param.getProEntId(), param.getSupEntId(), param.getOrderNo());
+            throw new BusinessPlatfromException(ErrorCodeEnum.PARAM_ERROR, "采购方服务费账户不存在");
+        }
+
+        BigDecimal currentBalance = walletFee.getServiceFeeBalance() == null ? ZERO_AMOUNT : walletFee.getServiceFeeBalance();
+        if (currentBalance.compareTo(freezeAmount) < 0) {
+            log.warn("服务费余额不足，proEntId:{}, orderNo:{}, balance:{}, freezeAmount:{}",
+                    param.getProEntId(), param.getOrderNo(), currentBalance, freezeAmount);
+            throw new BusinessPlatfromException(ErrorCodeEnum.PARAM_ERROR, "服务费余额不足，无法下单");
+        }
+
+        BigDecimal currentTradingAmount = walletFee.getTradingAmount() == null ? ZERO_AMOUNT : walletFee.getTradingAmount();
+        walletFee.setServiceFeeBalance(currentBalance.subtract(freezeAmount));
+        walletFee.setTradingAmount(currentTradingAmount.add(freezeAmount));
+        parkingWalletFeeRepository.updateById(walletFee);
+
+        saveFreezeWalletBalanceLog(param, walletFee, freezeAmount);
+
+        result.setApplyChargeStrategy(Global.YES);
+        result.setChargeStrategyId(currentStrategy.getId());
+        result.setChargeStrategyDesc(buildStrategyMethodDesc(currentStrategy));
+        result.setFreezeAmount(freezeAmount);
+        result.setServiceFeeBalance(walletFee.getServiceFeeBalance());
+        log.info("贸易订单应用收费策略完成，orderNo:{}, result:{}", param.getOrderNo(), result);
+        return result;
+    }
+
+    /**
+     * 贸易订单审核拒绝解冻服务费
+     * 规则：根据订单冻结记录解冻，返还服务费余额并写入钱包日志
+     *
+     * @param param 解冻参数
+     * @return 解冻结果（含采购方服务费余额）
+     */
+    @Transactional(rollbackFor = Exception.class)
+    public ParkingWalletFeeFreezeResult unfreezeChargeStrategy(ParkingWalletFeeFreezeParam param) {
+        log.info("贸易订单解冻服务费开始，param:{}", param);
+        validateUnfreezeParam(param);
+
+        ParkingWalletFeeFreezeResult result = new ParkingWalletFeeFreezeResult();
+        result.setApplyChargeStrategy(Global.YES);
+
+        if (existsUnfreezeRecord(param.getOrderNo(), param.getProEntId(), param.getSupEntId())) {
+            log.info("服务费已解冻，跳过重复处理，orderNo:{}, proEntId:{}", param.getOrderNo(), param.getProEntId());
+            result.setServiceFeeBalance(queryServiceFeeBalance(param.getProEntId(), param.getSupEntId()));
+            return result;
+        }
+
+        KwtParkingWalletFeeBalance freezeRecord = queryFreezeBalanceRecord(param);
+        if (freezeRecord == null) {
+            log.warn("未找到服务费冻结记录，orderNo:{}, proEntId:{}", param.getOrderNo(), param.getProEntId());
+            throw new BusinessPlatfromException(ErrorCodeEnum.PARAM_ERROR, "服务费冻结记录不存在，无法解冻");
+        }
+
+        BigDecimal unfreezeAmount = freezeRecord.getTradeAmount() == null ? ZERO_AMOUNT : freezeRecord.getTradeAmount();
+        if (unfreezeAmount.compareTo(ZERO_AMOUNT) <= 0) {
+            throw new BusinessPlatfromException(ErrorCodeEnum.PARAM_ERROR, "服务费冻结金额异常，无法解冻");
+        }
+
+        KwtParkingWalletFee walletFee = queryWalletFee(param.getProEntId(), param.getSupEntId());
+        if (walletFee == null) {
+            throw new BusinessPlatfromException(ErrorCodeEnum.PARAM_ERROR, "采购方服务费账户不存在");
+        }
+
+        BigDecimal currentTradingAmount = walletFee.getTradingAmount() == null ? ZERO_AMOUNT : walletFee.getTradingAmount();
+        if (currentTradingAmount.compareTo(unfreezeAmount) < 0) {
+            log.warn("服务费履约中金额不足，无法解冻，orderNo:{}, tradingAmount:{}, unfreezeAmount:{}",
+                    param.getOrderNo(), currentTradingAmount, unfreezeAmount);
+            throw new BusinessPlatfromException(ErrorCodeEnum.PARAM_ERROR, "服务费履约中金额不足，无法解冻");
+        }
+
+        BigDecimal currentBalance = walletFee.getServiceFeeBalance() == null ? ZERO_AMOUNT : walletFee.getServiceFeeBalance();
+        walletFee.setServiceFeeBalance(currentBalance.add(unfreezeAmount));
+        walletFee.setTradingAmount(currentTradingAmount.subtract(unfreezeAmount));
+        parkingWalletFeeRepository.updateById(walletFee);
+
+        saveUnfreezeWalletBalanceLog(param, walletFee, unfreezeAmount);
+        result.setFreezeAmount(unfreezeAmount);
+        result.setServiceFeeBalance(walletFee.getServiceFeeBalance());
+        log.info("贸易订单解冻服务费完成，orderNo:{}, unfreezeAmount:{}, balanceAfter:{}",
+                param.getOrderNo(), unfreezeAmount, walletFee.getServiceFeeBalance());
+        return result;
+    }
+
+    /**
+     * 查询采购方服务费余额
+     */
+    public BigDecimal queryPurchaserServiceFeeBalance(Long proEntId, Long supEntId) {
+        return queryServiceFeeBalance(proEntId, supEntId);
+    }
+
+    private void validateUnfreezeParam(ParkingWalletFeeFreezeParam param) {
+        if (param == null || param.getProEntId() == null) {
+            throw new BusinessPlatfromException(ErrorCodeEnum.PARAM_ERROR, "采购方企业id不能为空");
+        }
+        if (param.getOrderNo() == null || param.getOrderNo().isBlank()) {
+            throw new BusinessPlatfromException(ErrorCodeEnum.PARAM_ERROR, "贸易订单号不能为空");
+        }
+    }
+
+    private boolean existsUnfreezeRecord(String orderNo, Long proEntId, Long supEntId) {
+        return parkingWalletFeeBalanceRepository.count(
+                Wrappers.<KwtParkingWalletFeeBalance>lambdaQuery()
+                        .eq(KwtParkingWalletFeeBalance::getOrderNo, orderNo)
+                        .eq(KwtParkingWalletFeeBalance::getProEntId, proEntId)
+                        .eq(supEntId != null, KwtParkingWalletFeeBalance::getSupEntId, supEntId)
+                        .eq(KwtParkingWalletFeeBalance::getTradeType, TRADE_TYPE_UNFREEZE)
+                        .eq(KwtParkingWalletFeeBalance::getDelFlag, Global.NO)
+        ) > 0;
+    }
+
+    private KwtParkingWalletFeeBalance queryFreezeBalanceRecord(ParkingWalletFeeFreezeParam param) {
+        return parkingWalletFeeBalanceRepository.getOne(
+                Wrappers.<KwtParkingWalletFeeBalance>lambdaQuery()
+                        .eq(KwtParkingWalletFeeBalance::getOrderNo, param.getOrderNo())
+                        .eq(KwtParkingWalletFeeBalance::getProEntId, param.getProEntId())
+                        .eq(param.getSupEntId() != null, KwtParkingWalletFeeBalance::getSupEntId, param.getSupEntId())
+                        .eq(KwtParkingWalletFeeBalance::getTradeType, TRADE_TYPE_FREEZE)
+                        .eq(KwtParkingWalletFeeBalance::getDelFlag, Global.NO)
+                        .orderByDesc(KwtParkingWalletFeeBalance::getId)
+                        .last("limit 1"),
+                false
+        );
+    }
+
+    private void saveUnfreezeWalletBalanceLog(ParkingWalletFeeFreezeParam param,
+                                              KwtParkingWalletFee walletFee,
+                                              BigDecimal unfreezeAmount) {
+        Long operatorId = resolveOperatorId(param.getOperatorId());
+        Date now = new Date();
+        KwtParkingWalletFeeBalance balanceRecord = new KwtParkingWalletFeeBalance();
+        balanceRecord.setOrderNo(param.getOrderNo());
+        balanceRecord.setProEntId(param.getProEntId());
+        balanceRecord.setSupEntId(param.getSupEntId());
+        balanceRecord.setTradeType(TRADE_TYPE_UNFREEZE);
+        balanceRecord.setTradeAmount(unfreezeAmount);
+        balanceRecord.setServiceFeeBalance(walletFee.getServiceFeeBalance());
+        balanceRecord.setTradingAmount(walletFee.getTradingAmount());
+        balanceRecord.setRemark("贸易订单号：" + param.getOrderNo() + "，审核拒绝解冻服务费");
+        balanceRecord.setDelFlag(Global.NO);
+        balanceRecord.setCreateUser(operatorId);
+        balanceRecord.setUpdateUser(operatorId);
+        balanceRecord.setCreateTime(now);
+        balanceRecord.setUpdateTime(now);
+        parkingWalletFeeBalanceRepository.save(balanceRecord);
+        log.info("服务费解冻钱包日志已写入kwt_parking_wallet_fee_balance，orderNo:{}, proEntId:{}, supEntId:{}, tradeType:{}, tradeAmount:{}, balanceAfter:{}",
+                param.getOrderNo(), param.getProEntId(), param.getSupEntId(), TRADE_TYPE_UNFREEZE,
+                unfreezeAmount, walletFee.getServiceFeeBalance());
+    }
+
+    private String buildStrategyMethodDesc(KwtParkingChargeStrategy strategy) {
+        if (strategy == null || strategy.getMethod() == null) {
+            return null;
+        }
+        if (Objects.equals(ParkingChangeStrategyEnum.BY_TON.getCode(), strategy.getType())) {
+            return strategy.getMethod().stripTrailingZeros().toPlainString() + "元/吨";
+        }
+        if (Objects.equals(ParkingChangeStrategyEnum.BY_TIME.getCode(), strategy.getType())) {
+            return strategy.getMethod().stripTrailingZeros().toPlainString() + "元/次";
+        }
+        return strategy.getMethod().stripTrailingZeros().toPlainString() + "元/月";
+    }
+
+    /**
+     * 写入服务费钱包日志（kwt_parking_wallet_fee_balance）
+     */
+    private void saveFreezeWalletBalanceLog(ParkingWalletFeeFreezeParam param,
+                                            KwtParkingWalletFee walletFee,
+                                            BigDecimal freezeAmount) {
+        Long operatorId = resolveOperatorId(param.getOperatorId());
+        Date now = new Date();
+        KwtParkingWalletFeeBalance balanceRecord = new KwtParkingWalletFeeBalance();
+        balanceRecord.setOrderNo(param.getOrderNo());
+        balanceRecord.setProEntId(param.getProEntId());
+        balanceRecord.setSupEntId(param.getSupEntId());
+        balanceRecord.setTradeType(TRADE_TYPE_FREEZE);
+        balanceRecord.setTradeAmount(freezeAmount);
+        balanceRecord.setServiceFeeBalance(walletFee.getServiceFeeBalance());
+        balanceRecord.setTradingAmount(walletFee.getTradingAmount());
+        balanceRecord.setRemark("贸易订单号：" + param.getOrderNo() + "，下单冻结服务费");
+        balanceRecord.setDelFlag(Global.NO);
+        balanceRecord.setCreateUser(operatorId);
+        balanceRecord.setUpdateUser(operatorId);
+        balanceRecord.setCreateTime(now);
+        balanceRecord.setUpdateTime(now);
+        parkingWalletFeeBalanceRepository.save(balanceRecord);
+        log.info("服务费钱包日志已写入kwt_parking_wallet_fee_balance，orderNo:{}, proEntId:{}, supEntId:{}, tradeType:{}, tradeAmount:{}, balanceAfter:{}",
+                param.getOrderNo(), param.getProEntId(), param.getSupEntId(), TRADE_TYPE_FREEZE,
+                freezeAmount, walletFee.getServiceFeeBalance());
+    }
+
+    private KwtParkingWalletFee queryWalletFee(Long proEntId, Long supEntId) {
+        return parkingWalletFeeRepository.getOne(
+                Wrappers.<KwtParkingWalletFee>lambdaQuery()
+                        .eq(KwtParkingWalletFee::getProEntId, proEntId)
+                        .eq(supEntId != null, KwtParkingWalletFee::getSupEntId, supEntId)
+                        .eq(KwtParkingWalletFee::getDelFlag, Global.NO)
+                        .orderByDesc(KwtParkingWalletFee::getId)
+                        .last("limit 1"),
+                false
+        );
+    }
+
+    private Long resolveOperatorId(Long operatorId) {
+        Long loginUserId = LoginUserHolder.getUserId();
+        if (loginUserId != null) {
+            return loginUserId;
+        }
+        return operatorId == null ? -1L : operatorId;
+    }
+
+    /**
+     * 计算服务费余额支持的最大可购买数量
+     * 仅在收费策略开关开启且单价大于0时计算：服务费余额 / 策略单价（向下取整，保留4位小数）
+     *
+     * @param currentStrategy       当前收费策略
+     * @param currentStrategyUnitFee 策略单价
+     * @param serviceFeeBalance     服务费余额
+     * @return 最大可购买数量；策略未开启时不做余额约束，返回null
+     */
+    private BigDecimal calculateMaxPurchaseQuantity(KwtParkingChargeStrategy currentStrategy,
+                                                    BigDecimal currentStrategyUnitFee,
+                                                    BigDecimal serviceFeeBalance) {
+        if (currentStrategy == null || !Objects.equals(currentStrategy.getStatus(), STRATEGY_OPEN)
+                || currentStrategyUnitFee.compareTo(ZERO_AMOUNT) <= 0) {
+            log.info("最大可购买数量未计算，原因:{}",
+                    currentStrategy == null ? "未匹配到收费策略" : "收费策略未开启或单价<=0");
+            return null;
+        }
+        //向下取整
+        BigDecimal maxPurchaseQuantity = serviceFeeBalance.divide(currentStrategyUnitFee, 0, RoundingMode.DOWN);
+        log.info("最大可购买数量计算完成，serviceFeeBalance:{}, unitFee:{}, maxPurchaseQuantity:{}",
+                serviceFeeBalance, currentStrategyUnitFee, maxPurchaseQuantity);
+        return maxPurchaseQuantity.max(ZERO_AMOUNT);
+    }
+
+    /**
+     * 查询企业当前生效的收费策略
+     * 逻辑：先查企业绑定的策略，再查策略详情，最后取“开启状态”且id最大（最新）的一条
+     *
+     * @param proEntId 采购企业id
+     * @return 生效策略；未匹配到则返回null
+     */
+    private KwtParkingChargeStrategy queryCurrentEnableStrategy(Long proEntId) {
+        List<KwtParkingChargeStrategyUnit> strategyUnitList = parkingChangeStrategyUnitRepository.list(
+                Wrappers.<KwtParkingChargeStrategyUnit>lambdaQuery()
+                        .eq(KwtParkingChargeStrategyUnit::getEntId, proEntId)
+                        .eq(KwtParkingChargeStrategyUnit::getDelFlag, Global.NO)
+        );
+        log.info("查询企业策略绑定关系，proEntId:{}, bindCount:{}",
+                proEntId, strategyUnitList == null ? 0 : strategyUnitList.size());
+
+        if (CollectionUtils.isEmpty(strategyUnitList)) {
+            log.info("企业未绑定任何策略，proEntId:{}, strategyUnitList:[]", proEntId);
+            return null;
+        }
+        List<Long> strategyIds = strategyUnitList.stream()
+                .map(KwtParkingChargeStrategyUnit::getStrategyId)
+                .filter(Objects::nonNull)
+                .toList();
+        log.info("查询企业策略ID集合，proEntId:{}, strategyIds:{}", proEntId, strategyIds);
+        if (CollectionUtils.isEmpty(strategyIds)) {
+            log.info("企业绑定策略ID集合为空");
+            return null;
+        }
+        List<KwtParkingChargeStrategy> strategyList = parkingChangeStrategyRepository.list(
+                Wrappers.<KwtParkingChargeStrategy>lambdaQuery()
+                        .in(KwtParkingChargeStrategy::getId, strategyIds)
+                        .eq(KwtParkingChargeStrategy::getDelFlag, Global.NO)
+                        .orderByDesc(KwtParkingChargeStrategy::getId)
+        );
+        log.info("查询策略详情完成，proEntId:{}, strategyCount:{}",
+                proEntId, strategyList == null ? 0 : strategyList.size());
+        if (CollectionUtils.isEmpty(strategyList)) {
+            return null;
+        }
+        KwtParkingChargeStrategy hitStrategy = strategyList.stream()
+                .filter(item -> Objects.equals(item.getStatus(), STRATEGY_OPEN))
+                .max(Comparator.comparing(KwtParkingChargeStrategy::getId))
+                .orElse(null);
+        log.info("匹配生效策略结果，proEntId:{}, hitStrategyId:{}",
+                proEntId, hitStrategy == null ? null : hitStrategy.getId());
+        return hitStrategy;
+    }
+
+    /**
+     * 查询企业当前可用服务费余额
+     *
+     * @param proEntId 采购企业id
+     * @param supEntId 供应商企业id，可为空
+     * @return 服务费余额，无记录时返回0
+     */
+    private BigDecimal queryServiceFeeBalance(Long proEntId, Long supEntId) {
+        KwtParkingWalletFee walletFee = queryWalletFee(proEntId, supEntId);
+        if (walletFee == null || walletFee.getServiceFeeBalance() == null) {
+            log.info("查询服务费余额为空，按0处理，proEntId:{}, supEntId:{}", proEntId, supEntId);
+            return ZERO_AMOUNT;
+        }
+        log.info("查询服务费余额成功，proEntId:{}, supEntId:{}, serviceFeeBalance:{}",
+                proEntId, supEntId, walletFee.getServiceFeeBalance());
+        return walletFee.getServiceFeeBalance();
+    }
+
+
+}

sql/2026/06/2026_06_16_create.sql

@@ -0,0 +1,67 @@
+
+create table kwt_parking_charge_strategy
+(
+    id                              bigint          NOT NULL AUTO_INCREMENT COMMENT '主键',
+    strategy_name                   varchar(20)     NOT NULL default '' COMMENT '策略名称',
+    type                            int             NOT NULL DEFAULT '0' COMMENT '策略类型（1-按吨计费，2-按次计费、3-按月计费）',
+    method                          decimal(10,2)   NOT NULL DEFAULT 0.00 COMMENT '计价方式',
+    status                          int             NOT NULL DEFAULT '0' COMMENT '状态（0-关闭，1-开启）',
+    remark                          varchar(20)     DEFAULT NULL COMMENT '备注',
+    del_flag                        int             NOT NULL DEFAULT '0' COMMENT '是否删除（0未删除，1删除）',
+    create_time                     datetime        NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+    update_time                     datetime        NOT NULL DEFAULT CURRENT_TIMESTAMP on update CURRENT_TIMESTAMP COMMENT '更新时间',
+    create_user                     bigint          NOT NULL DEFAULT '-1' COMMENT '创建人',
+    update_user                     bigint          NOT NULL DEFAULT '-1' COMMENT '更新人',
+    PRIMARY KEY (`id`) USING BTREE
+) comment '收费策略表';
+
+
+create table kwt_parking_charge_strategy_unit
+(
+    id                              bigint          NOT NULL AUTO_INCREMENT COMMENT '主键',
+    strategy_id                     bigint          NOT NULL DEFAULT '-1' COMMENT '策略id',
+    ent_id                          bigint          NOT NULL DEFAULT '-1' COMMENT '企业id',
+    del_flag                        int             NOT NULL DEFAULT '0' COMMENT '是否删除（0未删除，1删除）',
+    create_time                     datetime        NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+    update_time                     datetime        NOT NULL DEFAULT CURRENT_TIMESTAMP on update CURRENT_TIMESTAMP COMMENT '更新时间',
+    create_user                     bigint          NOT NULL DEFAULT '-1' COMMENT '创建人',
+    update_user                     bigint          NOT NULL DEFAULT '-1' COMMENT '更新人',
+    PRIMARY KEY (`id`) USING BTREE
+) comment '收费策略企业关联表';
+
+
+
+CREATE TABLE `kwt_parking_wallet_fee` (
+                                          `id`                            bigint          NOT NULL AUTO_INCREMENT COMMENT '主键',
+                                          `pro_ent_id`                    bigint          NOT NULL DEFAULT '-1' COMMENT '采购商企业id',
+                                          `sup_ent_id`                    bigint          NOT NULL DEFAULT '-1' COMMENT '供应商企业id',
+                                          `service_fee_balance`           decimal(16,2)   NOT NULL DEFAULT '0.00' COMMENT '服务费余额',
+                                          `trading_amount`                decimal(16,2)   NOT NULL DEFAULT '0.00' COMMENT '履约中金额',
+                                          `remark`                        varchar(20)     DEFAULT NULL DEFAULT '' COMMENT '备注',
+                                          del_flag                        int             NOT NULL DEFAULT '0' COMMENT '是否删除（0未删除，1删除）',
+                                          create_time                     datetime        NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+                                          update_time                     datetime        NOT NULL DEFAULT CURRENT_TIMESTAMP on update CURRENT_TIMESTAMP COMMENT '更新时间',
+                                          create_user                     bigint          NOT NULL DEFAULT '-1' COMMENT '创建人',
+                                          update_user                     bigint          NOT NULL DEFAULT '-1' COMMENT '更新人',
+                                          PRIMARY KEY (`id`) USING BTREE
+) comment '预存服务费';
+
+
+CREATE TABLE `kwt_parking_wallet_fee_balance` (
+                                                  `id`                            bigint          NOT NULL AUTO_INCREMENT COMMENT '主键',
+                                                  `order_no`                      varchar(32)     CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT '关联订单编号',
+                                                  `pro_ent_id`                    bigint          NOT NULL DEFAULT '-1' COMMENT '采购商企业id',
+                                                  `sup_ent_id`                    bigint          NOT NULL DEFAULT '-1' COMMENT '供应商企业id',
+                                                  `trade_type`                    int             NOT NULL DEFAULT '0' COMMENT '交易类型 2-预付 3-收益 4-冻结 5-解冻 6-消费 9-人工录入',
+                                                  `trade_amount`                  decimal(16,2)   NOT NULL DEFAULT '0.00' COMMENT '交易金额',
+                                                  `service_fee_balance`           decimal(16,2)   NOT NULL DEFAULT '0.00' COMMENT '服务费余额',
+                                                  `trading_amount`                decimal(16,2)   NOT NULL DEFAULT '0.00' COMMENT '履约中金额',
+                                                  `voucher_url`                   longtext        CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci COMMENT '凭证图片',
+                                                  `remark`                        varchar(20)     DEFAULT NULL DEFAULT '' COMMENT '备注',
+                                                  del_flag                        int             NOT NULL DEFAULT '0' COMMENT '是否删除（0未删除，1删除）',
+                                                  create_time                     datetime        NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+                                                  update_time                     datetime        NOT NULL DEFAULT CURRENT_TIMESTAMP on update CURRENT_TIMESTAMP COMMENT '更新时间',
+                                                  create_user                     bigint          NOT NULL DEFAULT '-1' COMMENT '创建人',
+                                                  update_user                     bigint          NOT NULL DEFAULT '-1' COMMENT '更新人',
+                                                  PRIMARY KEY (`id`) USING BTREE
+) comment '预存服务费明细';

sql/2026/06/2026_06_25_add_trade_order_charge_strategy.sql

@@ -0,0 +1,4 @@
+ALTER TABLE kwo_trade_order
+    ADD COLUMN apply_charge_strategy tinyint NOT NULL DEFAULT 0 COMMENT '是否应用收费策略（0-否，1-是）' AFTER agent_flag,
+    ADD COLUMN charge_strategy_id bigint DEFAULT NULL COMMENT '应用的收费策略id' AFTER apply_charge_strategy,
+    ADD COLUMN charge_strategy_desc varchar(50) DEFAULT NULL COMMENT '应用的收费策略描述，如10元/吨' AFTER charge_strategy_id;