Merge remote-tracking branch 'origin/v20.8_add_sub_weight_20240805' into test

performance-api/src/main/java/com/clx/performance/enums/OrderChildEnum.java

@@ -177,6 +177,14 @@ public enum OrderChildEnum {
     );
 
 
+
+    public static final List<Integer> CARRIER_CAN_CANCEL_STATUS_LIST = Arrays.asList(
+            Status.CREATED.getCode(),
+            Status.GO_TO_SEND.getCode(),
+            Status.ARRIVE_SEND.getCode()
+    );
+
+
     public static ConcurrentHashMap<Integer, String> map = new ConcurrentHashMap();
     static {
         for(OrderChildEnum.Status

performance-api/src/main/java/com/clx/performance/feign/PerformanceFeign.java

@@ -11,6 +11,7 @@ import com.clx.performance.param.pc.owner.ThawAccountParam;
 import com.clx.performance.param.pc.owner.UpdateStatusParam;
 import com.clx.performance.vo.app.collect.AppCollectTruckVO;
 import com.clx.performance.vo.feign.FreightEstimateVO;
+import com.clx.performance.vo.feign.OrderExtractWeightVO;
 import com.clx.performance.vo.feign.OrderGoodsFeignVO;
 import com.clx.performance.vo.feign.PlatformServiceFeeConfigFeignVO;
 import com.clx.performance.vo.pc.OwnerAccountAllVO;
@@ -154,4 +155,16 @@ public interface PerformanceFeign {
     @GetMapping(value = {"clx-performance/feign/platformServiceFee/getPlatformServiceFeeConfig"})
     Result<PlatformServiceFeeConfigFeignVO> getPlatformServiceFeeConfig();
 
+
+
+
+    @GetMapping(value = {"clx-performance/feign/order/weight/getOrderResidueWeight"})
+    Result<BigDecimal> getOrderResidueWeight(@RequestParam("orderNo") String orderNo);
+
+
+
+    @GetMapping(value = {"clx-performance/feign/order/weight/getOrderCanExtractWeight"})
+    Result<OrderExtractWeightVO> getOrderCanExtractWeight(@RequestParam("orderNo") String orderNo);
+
+
 }

performance-api/src/main/java/com/clx/performance/feign/PerformanceSDKFeign.java

@@ -3,6 +3,7 @@ package com.clx.performance.feign;
 import com.clx.open.sdk.request.action.GetOrderBreakContractOwnerRuleFileAction;
 import com.clx.open.sdk.request.action.QueryPerformanceProgressAction;
 import com.clx.open.sdk.request.action.QueryPerformanceProgressLogAction;
+import com.clx.open.sdk.request.dto.OrderCanExtractWeightDTO;
 import com.clx.open.sdk.request.dto.OwnerCancelResidueWeightDTO;
 import com.clx.performance.param.pc.OrderCancelParam;
 import com.clx.performance.vo.pc.OwnerAccountAllVO;
@@ -44,4 +45,10 @@ public interface PerformanceSDKFeign {
 
     @GetMapping("clx-performance/feign/sdk/queryPerformanceProgressLog")
     Result<List<PerformanceProgressOperationLogVO>> queryPerformanceProgressLog(@RequestBody QueryPerformanceProgressLogAction action);
+
+
+    @GetMapping(value = {"clx-performance/feign/sdk/getOrderCanExtractWeight"})
+    Result<OrderCanExtractWeightDTO> getOrderCanExtractWeight(@RequestParam(value = "orderNo") String orderNo);
+
+
 }

performance-api/src/main/java/com/clx/performance/param/pc/OrderChildCarrierBatchCancelParam.java

+package com.clx.performance.param.pc;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.Setter;
+
+import javax.validation.constraints.NotEmpty;
+import java.util.List;
+
+@Getter
+@Setter
+@NoArgsConstructor
+public class OrderChildCarrierBatchCancelParam {
+
+    @ApiModelProperty(value = "运单编号集合", example = "")
+    @NotEmpty(message = "运单编号集合不能为空")
+    private List<String> childNoList;
+
+    @ApiModelProperty(value = "取消原因", example = "信息错误")
+    private String remark;
+
+}

performance-api/src/main/java/com/clx/performance/vo/app/OrderGoodsAPPVO.java

@@ -5,10 +5,10 @@ import io.swagger.annotations.ApiModelProperty;
 import lombok.Getter;
 import lombok.NoArgsConstructor;
 import lombok.Setter;
+import org.apache.commons.lang3.StringUtils;
 
 import java.math.BigDecimal;
 
-
 @Getter
 @Setter
 @NoArgsConstructor
@@ -29,6 +29,11 @@ public class OrderGoodsAPPVO {
     @ApiModelProperty("剩余拉运吨数")
     private String residueTransportWeight;
 
+    public String getResidueTransportWeight(){
+        return new BigDecimal(extractWeight).subtract(StringUtils.isNotBlank(alreadyTransportWeight)
+                ?new BigDecimal(alreadyTransportWeight):BigDecimal.ZERO).toString();
+    }
+
     @ApiModelProperty("已拉运吨数")
     private String alreadyTransportWeight;
 

performance-api/src/main/java/com/clx/performance/vo/feign/OrderExtractWeightVO.java

+package com.clx.performance.vo.feign;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.*;
+
+import java.math.BigDecimal;
+
+/**
+ * @ClassName OrderExtractWeightVO
+ * @Description
+ * @Author kavin
+ * @Date 2024/8/5 11:54
+ * @Version 1.0
+ */
+
+@Getter
+@Setter
+@AllArgsConstructor
+@NoArgsConstructor
+@Builder
+public class OrderExtractWeightVO {
+
+    @ApiModelProperty("用车需求： 1平台车辆 2部分平台车辆 3自有车辆")
+    private Integer truckDemand;
+
+    @ApiModelProperty(value = "拉运吨数")
+    private BigDecimal transportWeight;
+
+    @ApiModelProperty("平台承运吨数")
+    private BigDecimal platformCarryWeight;
+
+
+    @ApiModelProperty("自有承运吨数")
+    private BigDecimal ownCarryWeight;
+
+
+    @ApiModelProperty("平台可提取吨数")
+    private BigDecimal platCanExtractWeight;
+
+    @ApiModelProperty("自有可提取吨数")
+    private BigDecimal ownCanExtractWeight;
+
+
+}

performance-api/src/main/java/com/clx/performance/vo/pc/OrderChildPCVO.java

@@ -30,4 +30,12 @@ public class OrderChildPCVO {
 
     @ApiModelProperty("司机手机号")
     private String driverMobile;
+
+
+    @ApiModelProperty("接单时间")
+    private String createTime;
+
+    @ApiModelProperty("完成时间")
+    private String finishTime;
+
 }
\ No newline at end of file

performance-api/src/main/java/com/clx/performance/vo/pc/OrderGoodsVO.java

@@ -197,4 +197,8 @@ public class OrderGoodsVO {
     public String getSendWaitModeMsg() {
         return OrderGoodsEnum.SendWaitModeEnum.getMsgByCode(sendWaitMode);
     }
+
+
+    @ApiModelProperty("当前货单总吨数是否超过总拉运量  1:超过  ")
+    private Integer overOrderWeight;
 }
\ No newline at end of file

performance-api/src/main/java/com/clx/performance/vo/pc/child/UpdateCarrierBatchCancelVO.java

+package com.clx.performance.vo.pc.child;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Getter;
+import lombok.Setter;
+
+import java.util.List;
+
+/**
+ * @ClassName UpdateCarrierBatchCancelVO
+ * @Description
+ * @Author kavin
+ * @Date 2024/8/6 15:17
+ * @Version 1.0
+ */
+@Getter
+@Setter
+public class UpdateCarrierBatchCancelVO {
+
+
+    @ApiModelProperty("成功取消运单数量")
+    private Integer successCount;
+
+
+    @ApiModelProperty("失败的运单编号集合")
+    private List<String> failChildNoList;
+
+
+
+
+}

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

@@ -99,23 +99,6 @@ public class GoodsOrderTruckRecordComponent {
         }
         orderGoodsTruckBindDao.updateOrderGoodsBindStatusExpire(orderGoodsNo, truckNo);
 
-    }
-    //货单剩余吨数低于35吨时，自动恢复到订单，并释放未接单车辆
-    public void releaseOrderGoodsDriverAndTruck(String orderGoodsNo) {
-        List<OrderGoodsTruckBind> truckBindList = orderGoodsTruckBindDao.selectListByOrderGoodsNo(orderGoodsNo);
-        List<Integer> ids = new ArrayList<>();
-        for (OrderGoodsTruckBind bind : truckBindList) {
-            if (Objects.equals(OrderGoodsTruckBindEnum.Status.NORMAL.getCode(),bind.getStatus())) {
-                ids.add(bind.getId());
-                this.deleteTruckRecord(orderGoodsNo, bind.getTruckNo());
-            }
-        }
-        //释放车辆bind
-        if(CollectionUtils.isNotEmpty(ids)){
-            log.info("定向单进行车辆释放,货单编号:{},释放的绑定车辆的id集合:{}",orderGoodsNo,ids);
-            orderGoodsTruckBindDao.updateTruckBindExpire(ids);
-        }
-
     }
 
     public Set<String> getFleetPublicTruckList(String orderGoodsNo) {

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

@@ -3,11 +3,9 @@ package com.clx.performance.component;
 import cn.hutool.core.collection.CollectionUtil;
 import cn.hutool.json.JSONUtil;
 import com.clx.order.enums.OrderEnum;
-import com.clx.order.enums.UpdateEnum;
 import com.clx.order.enums.VehicleUsageEnum;
 import com.clx.order.feign.OrderFeign;
 import com.clx.order.param.feign.RollbackOrderWeightParam;
-import com.clx.order.vo.feign.FeignOrderInfoVO;
 import com.clx.order.vo.feign.FeignOrderVO;
 import com.clx.performance.dao.OrderChildDao;
 import com.clx.performance.dao.OrderGoodsDao;
@@ -25,7 +23,6 @@ import com.clx.performance.service.OrderGoodsTruckBindService;
 import com.clx.performance.service.breakcontract.BreakContractSettlementOwnerService;
 import com.clx.performance.service.child.OrderChildPostService;
 import com.clx.user.enums.driver.DriverInfoEnum;
-import com.msl.common.base.Optional;
 import com.msl.common.exception.ServiceSystemException;
 import com.msl.common.result.Result;
 import com.msl.common.utils.DateUtils;
@@ -160,7 +157,9 @@ public class OrderCancelComponent implements InitializingBean {
                     reduce = reduce.add(orderChild.getWeight());
                 }
 
-                if (orderGoods.getExtractWeight().compareTo(orderGoods.getResidueTransportWeight().add(reduce)) == 0) {
+                BigDecimal residueTransportWeight = orderGoodsService.calcOrderGoodsResidueWeight
+                        (orderGoods.getExtractWeight(),orderGoods.getAlreadyTransportWeight());
+                if (orderGoods.getExtractWeight().compareTo(residueTransportWeight.add(reduce)) == 0) {
                     update.setOrderGoodsStatus(OrderGoodsStatusEnum.Status.CANCEL.getCode());
                 } else {
                     orderStatusCode = OrderEnum.Status.COMPLETED.getCode();
@@ -190,7 +189,11 @@ public class OrderCancelComponent implements InitializingBean {
         for (OrderGoods orderGoods : orderGoodsList) {
             OrderGoods update = new OrderGoods();
             update.setId(orderGoods.getId());
-            if (orderGoods.getResidueTransportWeight().compareTo(orderGoods.getExtractWeight()) == 0) {
+
+            BigDecimal residueTransportWeight = orderGoodsService.calcOrderGoodsResidueWeight
+                    (orderGoods.getExtractWeight(),orderGoods.getAlreadyTransportWeight());
+
+            if (residueTransportWeight.compareTo(orderGoods.getExtractWeight()) == 0) {
                 update.setOrderGoodsStatus(OrderGoodsStatusEnum.Status.CANCEL.getCode());
             } else {
                 orderStatusCode = OrderEnum.Status.COMPLETED.getCode();
@@ -278,83 +281,6 @@ public class OrderCancelComponent implements InitializingBean {
         }
     }
 
-    /**
-     * @Author kavin
-     * @Description 货单低于35吨自动归还吨数到订单/货单吨数不够扣减，从订单上借吨数
-     * @Param [orderGoods, weight,updateType(1: 增加 2：减少)]
-     * @return 
-     **/
-    public void backFillOrderWeight(OrderGoods orderGoods, BigDecimal weight, Integer updateType) {
-        Integer truckDemand = orderGoods.getTruckDemand();
-        java.util.Optional<UpdateEnum> byCode1 = UpdateEnum.getByCode(updateType);
-        String updateTypeMsg = byCode1.isPresent()?byCode1.get().getMsg():"未知调整类型";
-        java.util.Optional<TruckDemandEnum.TruckType> byCode = TruckDemandEnum.TruckType.getByCode(truckDemand);
-        String truckDemandValue = byCode.isPresent()?byCode.get().getMsg():"未知用车需求";
-        log.info("订单号：{},货单号:{},用车需求:{},进行订单剩余吨数{} ,调整吨数:{}",
-                orderGoods.getOrderNo(),orderGoods.getOrderGoodsNo(),truckDemandValue,updateTypeMsg,weight);
-        String orderNo = orderGoods.getOrderNo();
-        Optional<FeignOrderInfoVO> optional = orderService.getOrderInfo(orderNo);
-        if(!optional.isPresent()){
-            log.warn("通过订单号未查询到对应的订单信息,订单号:{}",orderNo);
-            throw new ServiceSystemException(PerformanceResultEnum.DATA_NOT_FIND);
-        }
-        FeignOrderInfoVO orderInfo = optional.get();
-        boolean isSub = Objects.equals(UpdateEnum.SUB.getCode(), updateType);
-
-        RollbackOrderWeightParam rollbackOrderWeightParam = new RollbackOrderWeightParam();
-        rollbackOrderWeightParam.setOrderNo(orderGoods.getOrderNo());
-        rollbackOrderWeightParam.setResidueWeight(weight);
-        rollbackOrderWeightParam.setUpdateType(updateType);
-
-        //归还吨数
-        if (!truckDemand.equals(TruckDemandEnum.TruckType.PLATFORM_ANY_CAR.getCode())) {
-            if (truckDemand.equals(TruckDemandEnum.TruckType.PLATFORM_CAR.getCode())) {
-                if(isSub && weight.compareTo(orderInfo.getResidueWeight()) > 0 ){
-                    log.warn("货单用车需求: {},订单号：{},货单号：{},平台剩余吨数:{},需要扣减吨数:{},不足扣减",
-                            truckDemandValue,orderNo,orderGoods.getOrderGoodsNo(),orderInfo.getPlatformResidueCarryWeight()
-                            ,weight);
-                    throw new ServiceSystemException(PerformanceResultEnum.ORDER_WEIGHT_LACK);
-                }
-            } else if (truckDemand.equals(TruckDemandEnum.TruckType.OWNER_CAR.getCode())) {
-                if(isSub && weight.compareTo(orderInfo.getResidueWeight()) > 0 ){
-                    log.warn("货单用车需求: {},订单号：{},货单号：{},自有剩余吨数:{},需要扣减吨数:{},不足扣减",
-                            truckDemandValue,orderNo,orderGoods.getOrderGoodsNo(),orderInfo.getOwnResidueCarryWeight()
-                            ,weight);
-                    throw new ServiceSystemException(PerformanceResultEnum.ORDER_WEIGHT_LACK);
-                }
-            }
-            rollbackOrderWeightParam.setOwnResidueCarryWeight(BigDecimal.ZERO);
-            rollbackOrderWeightParam.setPlatformResidueCarryWeight(BigDecimal.ZERO);
-        } else {
-            if (Objects.equals(orderGoods.getVehicleUsage(),VehicleUsageEnum.Status.OWN.getCode())) {
-                if(isSub && weight.compareTo(orderInfo.getOwnResidueCarryWeight()) > 0 ){
-                    log.warn("货单用车需求: {},订单号：{},货单号：{},自有剩余吨数:{},需要扣减吨数:{},不足扣减",
-                            TruckDemandEnum.TruckType.PLATFORM_ANY_CAR.getMsg(),orderNo,orderGoods.getOrderGoodsNo(),
-                            orderInfo.getOwnResidueCarryWeight(),weight);
-                    throw new ServiceSystemException(PerformanceResultEnum.ORDER_WEIGHT_LACK);
-                }
-                rollbackOrderWeightParam.setPlatformResidueCarryWeight(BigDecimal.ZERO);
-                rollbackOrderWeightParam.setOwnResidueCarryWeight(weight);
-            } else {
-                if(isSub && weight.compareTo(orderInfo.getPlatformResidueCarryWeight()) > 0 ){
-                    log.warn("货单用车需求: {},订单号：{},货单号：{},平台剩余吨数:{},需要扣减吨数:{},不足扣减",
-                            truckDemandValue,orderNo,orderGoods.getOrderGoodsNo(),
-                            orderInfo.getPlatformResidueCarryWeight(),weight);
-                    throw new ServiceSystemException(PerformanceResultEnum.ORDER_WEIGHT_LACK);
-                }
-                rollbackOrderWeightParam.setPlatformResidueCarryWeight(weight);
-                rollbackOrderWeightParam.setOwnResidueCarryWeight(BigDecimal.ZERO);
-            }
-        }
-        Result<Object> result = orderFeign.rollbackOrderWeight(rollbackOrderWeightParam);
-        if (!result.succeed()) {
-            log.warn("订单号：{} 的订单做吨数调整，对应货单号:{} 调整失败，调整吨数：{},调整类型:{}",
-                    orderNo,orderGoods.getOrderGoodsNo(),weight,updateTypeMsg);
-            throw new ServiceSystemException(PerformanceResultEnum.HTTP_ERROR, "远程调用更新订单余量失败");
-        }
-    }
-
-
     /**
      * 客服取消归还吨数
      *
@@ -399,7 +325,6 @@ public class OrderCancelComponent implements InitializingBean {
             }
             ArrayList<OrderGoods> list = new ArrayList<>();
             list.add(orderGoods);
-            orderGoodsService.batchUpdateResidueWeight(list);
         } else {
             //返回到货单
             orderGoodsDao.updateOrderGoodsSetResidueWeightAndAlreadyWeight(weight, weight, orderGoods.getId());

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

 package com.clx.performance.component;
 
 import cn.hutool.core.collection.CollectionUtil;
-import com.clx.order.enums.VehicleUsageEnum;
 import com.clx.order.feign.OrderFeign;
-import com.clx.order.param.feign.RollbackOrderWeightParam;
 import com.clx.performance.constant.RedisConstants;
 import com.clx.performance.dao.OrderChildDao;
 import com.clx.performance.dao.OrderGoodsDao;
 import com.clx.performance.dao.OrderGoodsTruckBindDao;
-import com.clx.performance.enums.*;
+import com.clx.performance.enums.OrderChildEnum;
+import com.clx.performance.enums.OrderChildLogEnum;
+import com.clx.performance.enums.OrderGoodsStatusEnum;
+import com.clx.performance.enums.OrderGoodsTruckBindEnum;
 import com.clx.performance.extranal.user.DriverService;
 import com.clx.performance.model.OrderChild;
 import com.clx.performance.model.OrderGoods;
 import com.clx.performance.service.OrderChildLogService;
+import com.clx.performance.service.OrderGoodsService;
 import com.clx.performance.service.breakcontract.BreakContractDriverRecordService;
 import com.clx.performance.service.child.OrderChildPostService;
 import com.clx.user.enums.driver.DriverInfoEnum;
@@ -30,7 +32,9 @@ import org.springframework.transaction.annotation.Transactional;
 import java.math.BigDecimal;
 import java.time.LocalDateTime;
 import java.time.ZoneOffset;
-import java.util.*;
+import java.util.LinkedList;
+import java.util.List;
+import java.util.Set;
 
 /**
  * 货单最晚接单时间、最晚到达货源地时间处理
@@ -60,6 +64,8 @@ public class OrderGoodsStatusLazyComponent implements InitializingBean {
 
     private final OrderChildPostService orderChildPostService;
 
+    private final OrderGoodsService orderGoodsService;
+
 
     //根据货单最晚接单时间处理
     public void expireProduceByLastOrderTime(LocalDateTime localDateTime, String orderGoodsNo) {
@@ -90,7 +96,6 @@ public class OrderGoodsStatusLazyComponent implements InitializingBean {
     public void consumingLastOrderTime() {
         log.info("货单-最晚接单时间-定时器启动");
         long nowTimeMillis = System.currentTimeMillis();
-        LocalDateTime nowDateTime = new Date(nowTimeMillis).toInstant().atOffset(ZoneOffset.of("+8")).toLocalDateTime();
         Set<ZSetOperations.TypedTuple<String>> orderGoodsIds = redisTemplate.opsForZSet().rangeByScoreWithScores(
                 RedisConstants.ORDER_GOODS_STATUS_LAZY_LAST_ORDER_TIME,
                 0, nowTimeMillis  //延时任务score最小值
@@ -118,11 +123,10 @@ public class OrderGoodsStatusLazyComponent implements InitializingBean {
                     continue;
                 }
                 OrderGoods orderGoods = optional.get();
-//                if(Objects.equals(orderGoods.getOrderGoodsStatus(),OrderGoodsStatusEnum.Status.CANCEL.getCode())){
-//                    continue;
-//                }
+                BigDecimal residueTransportWeight = orderGoodsService.calcOrderGoodsResidueWeight
+                        (orderGoods.getExtractWeight(),orderGoods.getAlreadyTransportWeight());
 
-                if (orderGoods.getResidueTransportWeight().compareTo(BigDecimal.ZERO) == 0) {
+                if (residueTransportWeight.compareTo(BigDecimal.ZERO) == 0) {
                     List<OrderChild> orderChildren = orderChildDao.selectInTransitOrderChildByOrderGoodsNo(orderGoodsNo);
                     if (CollectionUtil.isNotEmpty(orderChildren)) {
                         //更新货单已完结
@@ -134,33 +138,10 @@ public class OrderGoodsStatusLazyComponent implements InitializingBean {
                         orderGoodsDao.updateOrderGoodsStatusByOrderGoodsNo(orderGoodsNo, OrderGoodsStatusEnum.Status.SUCCESS.getCode());
                     }
 
-
                 } else {
                     OrderGoods update = new OrderGoods();
                     update.setId(orderGoods.getId());
                     update.setOrderGoodsStatus(OrderGoodsStatusEnum.Status.COMPLETED.getCode());
-                    //大于35吨的归还吨数在这里处理
-                    if(orderGoods.getResidueTransportWeight().compareTo(new BigDecimal("35")) >= 0){
-                        RollbackOrderWeightParam param = new RollbackOrderWeightParam();
-                        param.setOrderNo(orderGoods.getOrderNo());
-                        param.setResidueWeight(orderGoods.getResidueTransportWeight());
-                        if (orderGoods.getTruckDemand().equals(TruckDemandEnum.TruckType.PLATFORM_CAR.getCode())
-                                || orderGoods.getTruckDemand().equals(TruckDemandEnum.TruckType.OWNER_CAR.getCode())) {
-                            param.setOwnResidueCarryWeight(BigDecimal.ZERO);
-                            param.setPlatformResidueCarryWeight(BigDecimal.ZERO);
-                        } else {
-                            if (orderGoods.getVehicleUsage().equals(VehicleUsageEnum.Status.PLATFORM.getCode())) {
-                                param.setOwnResidueCarryWeight(BigDecimal.ZERO);
-                                param.setPlatformResidueCarryWeight(orderGoods.getResidueTransportWeight());
-                            } else if (orderGoods.getVehicleUsage().equals(VehicleUsageEnum.Status.OWN.getCode())) {
-                                param.setOwnResidueCarryWeight(orderGoods.getResidueTransportWeight());
-                                param.setPlatformResidueCarryWeight(BigDecimal.ZERO);
-                            }
-                        }
-                        orderFeign.rollbackOrderWeight(param);
-                        //更新剩余吨数
-                        update.setResidueTransportWeight(BigDecimal.ZERO);
-                    }
                     //更新已完结
                     orderGoodsDao.updateEntityByKey(update);
                     log.info("删除redis ORDER_GOODS_STATUS_LAZY id: {}", orderGoodsId.getValue());
@@ -238,35 +219,10 @@ public class OrderGoodsStatusLazyComponent implements InitializingBean {
                     orderChildDao.batchUpdateOrderChildStatus(OrderChildEnum.Status.PLATFORM_CANCEL.getCode(), "系统自动取消，未按照最晚装货时间到达货源地", now, now, childNoList);
                 }
 
+                //更新货单未拉运吨数,已拉运吨数
+                orderGoodsDao.updateOrderGoodsSetResidueWeightAndAlreadyWeight(childSum, childSum, orderGoods.getId());
 
-                //当前货单已经到了最晚接单时间，所有相关状态均已经处理完毕，此刻单独处理运单的数据
-                if (OrderGoodsStatusEnum.Status.SUCCESS.getCode().equals(orderGoods.getOrderGoodsStatus())
-                        || OrderGoodsStatusEnum.Status.COMPLETED.getCode().equals(orderGoods.getOrderGoodsStatus())
-                ) {
-                    RollbackOrderWeightParam param = new RollbackOrderWeightParam();
-                    param.setOrderNo(orderGoods.getOrderNo());
-                    param.setResidueWeight(childSum);
 
-                    //当前情况需要回填订单的余量
-                    if (orderGoods.getTruckDemand().equals(1) || orderGoods.getTruckDemand().equals(3)) {
-                        param.setOwnResidueCarryWeight(BigDecimal.ZERO);
-                        param.setPlatformResidueCarryWeight(BigDecimal.ZERO);
-                    } else {
-                        if (orderGoods.getVehicleUsage().equals(VehicleUsageEnum.Status.PLATFORM.getCode())) {
-                            param.setOwnResidueCarryWeight(BigDecimal.ZERO);
-                            param.setPlatformResidueCarryWeight(orderGoods.getResidueTransportWeight());
-                        } else if (orderGoods.getVehicleUsage().equals(VehicleUsageEnum.Status.OWN.getCode())) {
-                            param.setOwnResidueCarryWeight(orderGoods.getResidueTransportWeight());
-                            param.setPlatformResidueCarryWeight(BigDecimal.ZERO);
-                        }
-                    }
-                    //只更新货单已拉运吨数
-                    orderGoodsDao.updateOrderGoodsSetResidueWeightAndAlreadyWeight(childSum, childSum, orderGoods.getId());
-                    orderFeign.rollbackOrderWeight(param);
-                } else {
-                    //只更新货单未拉运吨数,已拉运吨数
-                    orderGoodsDao.updateOrderGoodsSetResidueWeightAndAlreadyWeight(childSum, childSum, orderGoods.getId());
-                }
                 redisTemplate.opsForZSet().remove(RedisConstants.ORDER_GOODS_STATUS_LAZY_LAST_ARRIVE_SEND_TIME, orderGoodsId.getValue());
 
 

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

-package com.clx.performance.constant;
-
-import java.math.BigDecimal;
-
-/**
- * @ClassName BusinessConstants
- * @Description
- * @Author kavin
- * @Date 2024/7/22 15:26
- * @Version 1.0
- */
-public class BusinessConstants {
-
-
-    //承运订单需要减去的吨数
-    public static final BigDecimal ORDER_SUB_WEIGHT = new BigDecimal("35");
-
-}

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

@@ -42,4 +42,10 @@ public class RedisConstants {
      */
     public static final String LINE_WARN_WEATHER = "clx-performance:lineWarn:weather:";
 
+
+    /**
+     * 订单最后一车
+     */
+    public static final String ORDER_LAST_TRUCK_CHILD = "clx-performance:order:last:truck:child:";
+
 }

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

@@ -16,4 +16,9 @@ public class RedissonConstants {
 
     public static final String OWNER_LOAN_EVENT_USERID_LOCK = "clx-performance:ownerLoanEvent:ownerUserId:";
 
+
+    public static final String CALC_ORDER_LAST_TRUCK_LOCK = "clx-performance:order:last:truck:orderNo:";
+
+
+
 }

performance-web/src/main/java/com/clx/performance/controller/feign/OrderWeightFeignController.java

+package com.clx.performance.controller.feign;
+
+import com.clx.performance.service.OrderWeightService;
+import com.clx.performance.vo.feign.OrderExtractWeightVO;
+import com.msl.common.result.Result;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import lombok.AllArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.validation.constraints.NotBlank;
+import java.math.BigDecimal;
+
+/**
+ * @ClassName OrderWeightController
+ * @Description
+ * @Author kavin
+ * @Date 2024/8/5 11:45
+ * @Version 1.0
+ */
+
+@Slf4j
+@RestController
+@RequestMapping(value="/feign/order/weight")
+@Validated
+@Api(tags = "订单量查询")
+@AllArgsConstructor
+public class OrderWeightFeignController {
+
+    private final OrderWeightService orderWeightService;
+
+
+    @ApiOperation(value = "查询订单可提取量",notes = "<br>By:刘海泉")
+    @GetMapping("/getOrderCanExtractWeight")
+    public Result<OrderExtractWeightVO> getOrderCanExtractWeight(@RequestParam("orderNo")
+    @NotBlank(message = "订单编号不能为空") String orderNo) {
+        return Result.ok(orderWeightService.getOrderCanExtractWeight(orderNo));
+    }
+
+    @ApiOperation(value = "查询订单剩余量",notes = "<br>By:刘海泉")
+    @GetMapping("/getOrderResidueWeight")
+    public Result<BigDecimal> getOrderResidueWeight(@RequestParam("orderNo")
+    @NotBlank(message = "订单编号不能为空") String orderNo) {
+        return Result.ok(orderWeightService.getOrderResidueWeight(orderNo));
+    }
+
+
+}

performance-web/src/main/java/com/clx/performance/controller/feign/PerformanceSdkFeignController.java

@@ -4,13 +4,16 @@ import com.clx.open.sdk.request.action.GetOrderBreakContractOwnerRuleFileAction;
 import com.clx.open.sdk.request.action.GetOwnerAccountInfoAction;
 import com.clx.open.sdk.request.action.QueryPerformanceProgressAction;
 import com.clx.open.sdk.request.action.QueryPerformanceProgressLogAction;
+import com.clx.open.sdk.request.dto.OrderCanExtractWeightDTO;
 import com.clx.open.sdk.request.dto.OwnerCancelResidueWeightDTO;
 import com.clx.performance.param.pc.OrderCancelParam;
 import com.clx.performance.service.OrderCancelService;
 import com.clx.performance.service.OrderGoodsService;
+import com.clx.performance.service.OrderWeightService;
 import com.clx.performance.service.OwnerAccountService;
 import com.clx.performance.service.PerformanceProgressService;
 import com.clx.performance.service.breakcontract.BreakContractOwnerRuleService;
+import com.clx.performance.vo.feign.OrderExtractWeightVO;
 import com.clx.performance.vo.pc.OwnerAccountAllVO;
 import com.clx.performance.vo.pc.PerformanceProgressOperationLogVO;
 import com.clx.performance.vo.pc.PerformanceProgressVO;
@@ -21,6 +24,7 @@ import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import lombok.AllArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.BeanUtils;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
 
@@ -28,6 +32,7 @@ import java.math.BigDecimal;
 import java.util.List;
 
 import static com.clx.performance.enums.PerformanceProgressEnum.LogType.PERFORMANCE_ABNORMAL_REASON;
+import javax.validation.constraints.NotBlank;
 
 @Slf4j
 @RestController
@@ -48,6 +53,10 @@ public class PerformanceSdkFeignController {
 
     private final PerformanceProgressService performanceProgressService;
 
+    private final OrderWeightService orderWeightService;
+
+
+
 
     @ApiOperation(value = "货主端取消订单", notes = "<br>By:胡宇帆")
     @PostMapping("/ownCancelOrderPre")
@@ -88,4 +97,15 @@ public class PerformanceSdkFeignController {
     Result<List<PerformanceProgressOperationLogVO>> queryPerformanceProgressLog(@RequestBody QueryPerformanceProgressLogAction action){
         return Result.ok(performanceProgressService.getOperationLog(action.getOrderNo(),PERFORMANCE_ABNORMAL_REASON.getCode()));
     }
+    @ApiOperation(value = "获取当前订单的可提取吨数", notes = "<br>By:刘海泉")
+    @GetMapping("/getOrderCanExtractWeight")
+    public Result<OrderCanExtractWeightDTO> getOrderCanExtractWeight(@RequestParam(value = "orderNo")
+    @NotBlank(message = "订单编号不能为空") String orderNo) {
+        OrderExtractWeightVO orderCanExtractWeight = orderWeightService.getOrderCanExtractWeight(orderNo);
+        OrderCanExtractWeightDTO data  = new OrderCanExtractWeightDTO();
+        BeanUtils.copyProperties(orderCanExtractWeight,data);
+        return Result.ok(data);
+    }
+
+
 }

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

@@ -2,11 +2,13 @@ package com.clx.performance.controller.pc;
 
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.clx.performance.enums.OrderChildEnum;
+import com.clx.performance.param.pc.OrderChildCarrierBatchCancelParam;
 import com.clx.performance.param.pc.OrderChildCarrierCancelParam;
 import com.clx.performance.param.pc.PageCarrierOrderChildParam;
 import com.clx.performance.param.pc.PageMonitorOrderChildQCParam;
 import com.clx.performance.service.OrderChildService;
 import com.clx.performance.vo.pc.*;
+import com.clx.performance.vo.pc.child.UpdateCarrierBatchCancelVO;
 import com.msl.common.base.PageData;
 import com.msl.common.convertor.aspect.UnitCovert;
 import com.msl.common.result.Result;
@@ -127,4 +129,11 @@ public class CarrierOrderChildController {
     }
 
 
+
+    @ApiOperation(value = "批量取消运单", notes = "<br>By:刘海泉")
+    @PostMapping("/updateCarrierBatchCancel")
+    public Result<UpdateCarrierBatchCancelVO> updateCarrierBatchCancel(@RequestBody @Validated OrderChildCarrierBatchCancelParam param) {
+        return Result.ok(orderChildService.updateCarrierBatchCancel(param));
+    }
+
 }

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

@@ -7,10 +7,8 @@ import com.clx.performance.component.GoodsOrderStrategyContext;
 import com.clx.performance.constant.RedisConstants;
 import com.clx.performance.enums.PerformanceResultEnum;
 import com.clx.performance.param.pc.*;
-import com.clx.performance.service.OrderChildService;
-import com.clx.performance.service.OrderGoodsAdjustmentPriceService;
-import com.clx.performance.service.OrderGoodsService;
-import com.clx.performance.service.OrderGoodsTruckBindService;
+import com.clx.performance.service.*;
+import com.clx.performance.vo.feign.OrderExtractWeightVO;
 import com.clx.performance.vo.pc.*;
 import com.msl.common.base.PageData;
 import com.msl.common.convertor.aspect.UnitCovert;
@@ -71,6 +69,9 @@ public class GoodsOrderController {
     @Autowired
     private OrderGoodsAdjustmentPriceService orderGoodsAdjustmentPriceService;
 
+    @Autowired
+    private OrderWeightService orderWeightService;
+
     @ApiOperation(value = "提交货单", notes = "<br>By:胡宇帆")
     @PostMapping("/saveGoodsOrder")
     @UnitCovert(result = false)
@@ -88,7 +89,11 @@ public class GoodsOrderController {
             FeignOrderVO orderInfo = orderFeign.getOrderInfoFeign(orderNo);
             //1平台车辆 2部分平台车辆 3自有车辆
             Integer truckDemand = orderInfo.getTruckDemand();
-            goodsOrderStrategyContext.strategyContext.get(truckDemand).saveGoodsOrder(orderGoodsParams, orderInfo, now, rabbitTemplate);
+
+            OrderExtractWeightVO orderCanExtractWeight = orderWeightService.getOrderCanExtractWeight(orderNo);
+
+            goodsOrderStrategyContext.strategyContext.get(truckDemand).saveGoodsOrder(orderGoodsParams, orderInfo,
+                    orderCanExtractWeight,now);
 
         } catch (Exception e) {
             log.info(e.getMessage());

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

+package com.clx.performance.controller.pc;
+
+import com.clx.performance.model.OrderChild;
+import com.clx.performance.service.LastTruckService;
+import com.clx.performance.struct.OrderChildStruct;
+import com.clx.performance.vo.app.OrderChildVO;
+import com.msl.common.result.Result;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import lombok.AllArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.validation.constraints.NotBlank;
+
+/**
+ * @ClassName OrderWeightController
+ * @Description
+ * @Author kavin
+ * @Date 2024/8/5 11:45
+ * @Version 1.0
+ */
+
+@Slf4j
+@RestController
+@RequestMapping(value="/pc/lastTruck")
+@Validated
+@Api(tags = "最后一车")
+@AllArgsConstructor
+public class LastTruckController {
+
+    private final LastTruckService lastTruckService;
+    private final OrderChildStruct orderChildStruct;
+
+
+    @ApiOperation(value = "查询订单下的最后一车",notes = "<br>By:刘海泉")
+    @GetMapping("/getOrderLastTruck")
+    public Result<OrderChildVO> getOrderLastTruck(@RequestParam("orderNo")
+    @NotBlank(message = "订单编号不能为空") String orderNo) throws Exception{
+        OrderChild child = lastTruckService.getOrderLastTruck(orderNo);
+        return Result.ok(orderChildStruct.convert(child));
+    }
+
+
+
+}

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

+package com.clx.performance.controller.pc;
+
+import com.clx.performance.service.OrderGoodsWeightService;
+import com.msl.common.result.Result;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import lombok.AllArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.validation.constraints.NotBlank;
+import java.math.BigDecimal;
+
+/**
+ * @ClassName OrderWeightController
+ * @Description
+ * @Author kavin
+ * @Date 2024/8/5 11:45
+ * @Version 1.0
+ */
+
+@Slf4j
+@RestController
+@RequestMapping(value="/pc/orderGoods/weight")
+@Validated
+@Api(tags = "货单量查询")
+@AllArgsConstructor
+public class OrderGoodsWeightController {
+
+    private final OrderGoodsWeightService orderGoodsWeightService;
+
+
+    @ApiOperation(value = "查询货单可提取量",notes = "<br>By:刘海泉")
+    @GetMapping("/getOrderGoodsCanExtractWeight")
+    public Result<BigDecimal> getOrderGoodsCanExtractWeight(@RequestParam("orderGoodsNo")
+    @NotBlank(message = "货单编号不能为空") String orderGoodsNo) {
+        return Result.ok(orderGoodsWeightService.getOrderGoodsCanExtractWeight(orderGoodsNo));
+    }
+
+}

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

+package com.clx.performance.controller.pc;
+
+import com.clx.performance.service.OrderWeightService;
+import com.clx.performance.vo.feign.OrderExtractWeightVO;
+import com.msl.common.result.Result;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import lombok.AllArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.validation.constraints.NotBlank;
+import java.math.BigDecimal;
+
+/**
+ * @ClassName OrderWeightController
+ * @Description
+ * @Author kavin
+ * @Date 2024/8/5 11:45
+ * @Version 1.0
+ */
+
+@Slf4j
+@RestController
+@RequestMapping(value="/pc/order/weight")
+@Validated
+@Api(tags = "订单量查询")
+@AllArgsConstructor
+public class OrderWeightController {
+
+    private final OrderWeightService orderWeightService;
+
+
+    @ApiOperation(value = "查询订单可提取量",notes = "<br>By:刘海泉")
+    @GetMapping("/getOrderCanExtractWeight")
+    public Result<OrderExtractWeightVO> getOrderCanExtractWeight(@RequestParam("orderNo")
+    @NotBlank(message = "订单编号不能为空") String orderNo) {
+        return Result.ok(orderWeightService.getOrderCanExtractWeight(orderNo));
+    }
+
+    @ApiOperation(value = "查询订单剩余量",notes = "<br>By:刘海泉")
+    @GetMapping("/getOrderResidueWeight")
+    public Result<BigDecimal> getOrderResidueWeight(@RequestParam("orderNo")
+    @NotBlank(message = "订单编号不能为空") String orderNo) {
+        return Result.ok(orderWeightService.getOrderResidueWeight(orderNo));
+    }
+
+
+}

performance-web/src/main/java/com/clx/performance/dao/OrderChildDao.java

@@ -3,6 +3,7 @@ package com.clx.performance.dao;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.clx.performance.dto.CancelOrderGoodsWeightDTO;
+import com.clx.performance.dto.OrderGoodsNotCancelChildDTO;
 import com.clx.performance.dto.linewarn.LineWarnOrderChildStatisticsDTO;
 import com.clx.performance.mapper.OrderChildMapper;
 import com.clx.performance.model.OrderChild;
@@ -209,4 +210,8 @@ public interface OrderChildDao extends BaseDao<OrderChildMapper, OrderChild, Int
 
     List<OrderChild> listChidNosByStatus(List<Integer> status);
 
+
+    List<OrderGoodsNotCancelChildDTO> countValidByOrderGoodsNoList(List<String> orderGoodsList);
+
+    void batchUpdateCancel(List<OrderChild> canCancelOrderChildList);
 }

performance-web/src/main/java/com/clx/performance/dao/OrderGoodsDao.java

@@ -2,6 +2,8 @@ package com.clx.performance.dao;
 
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.clx.performance.dto.CancelOrderGoodsWeightDTO;
+import com.clx.performance.dto.OrderExtractWeightDTO;
+import com.clx.performance.dto.OrderGoodsCancelWeightDTO;
 import com.clx.performance.mapper.OrderGoodsMapper;
 import com.clx.performance.model.OrderGoods;
 import com.clx.performance.model.OrderGoodsFleetOpenTruck;
@@ -14,7 +16,6 @@ import com.clx.performance.vo.app.OrderGoodsAPPVO;
 import com.clx.performance.vo.pc.OrderGoodsVO;
 import com.msl.common.base.Optional;
 import com.msl.common.dao.BaseDao;
-import org.apache.ibatis.annotations.Param;
 
 import java.math.BigDecimal;
 import java.time.LocalDateTime;
@@ -26,7 +27,6 @@ import java.util.List;
  * Time 16:45
  */
 public interface OrderGoodsDao extends BaseDao<OrderGoodsMapper, OrderGoods, Integer> {
-    boolean updateWeight(@Param("orderId")Integer orderId, @Param("weight") BigDecimal weight);
 
     String getMaxOrderGoodsId();
 
@@ -41,7 +41,7 @@ public interface OrderGoodsDao extends BaseDao<OrderGoodsMapper, OrderGoods, Int
 
     void updateOrderGoodsReduceWeightAndStatus(Integer id, BigDecimal orderChildWeight, Integer orderGoodsStatus);
 
-    void updateOrderGoodsWeightResidueAndAlreadyAndStatus(Integer id, BigDecimal alreadyTransportWeight,BigDecimal residueTransportWeight,Integer orderGoodsStatus);
+    void updateOrderGoodsWeightAlreadyAndStatus(Integer id, BigDecimal residueWeight,Integer orderGoodsStatus);
 
     IPage<OrderGoodsAPPVO> openOrderPageGoodsList(OrderGoodsListPageParam orderGoodsListPageParam,List<String> orderGoodsNoList);
 
@@ -72,7 +72,7 @@ public interface OrderGoodsDao extends BaseDao<OrderGoodsMapper, OrderGoods, Int
 
     Integer updateOrderGoodsSetResidueWeightAndAlreadyWeight(BigDecimal residueWeight, BigDecimal alreadyWeight, Integer id);
 
-    Integer updateOrderGoodsSetResidueWeightAndAlreadyWeightAndStatus(BigDecimal residueWeight, BigDecimal alreadyWeight, Integer status, Integer id);
+    Integer updateOrderGoodsSetAlreadyWeightAndStatus( BigDecimal alreadyWeight, Integer status, Integer id);
 
 
     OrderGoodsVO findOrderGoodsById(Integer id);
@@ -83,7 +83,6 @@ public interface OrderGoodsDao extends BaseDao<OrderGoodsMapper, OrderGoods, Int
 
     boolean batchUpdateOrderGoodsStatus(Integer status, List<Integer> ids);
 
-    boolean batchUpdateOrderGoodsWeight(BigDecimal residueWeight, List<Integer> ids);
 
 
     void updateSendSystemAddress(Integer ownerAddressId, Integer systemAddressId);
@@ -99,7 +98,6 @@ public interface OrderGoodsDao extends BaseDao<OrderGoodsMapper, OrderGoods, Int
 
     IPage<OrderGoodsAPPVO> indexOrderGoodsListSearch(AppGoodsOrderSearchParam param);
 
-    void batchUpdateResidueWeight(List<Integer> list, BigDecimal residueWeight);
 
     List<OrderGoodsFleetOpenTruck> queryProcessFleetOpenTruckList();
 
@@ -112,4 +110,9 @@ public interface OrderGoodsDao extends BaseDao<OrderGoodsMapper, OrderGoods, Int
 
     List<OrderGoods> listAfterCreatedByOrderNo(String orderNo);
 
+    void batchUpdateOrderGoodsPaying(List<OrderGoods> updateOrderGoods);
+
+    void batchCancelOrderGoodsWeight(List<OrderGoodsCancelWeightDTO> cancelOrderGoodsList);
+
+    List<OrderExtractWeightDTO> calcOrderGoodsExtractWeightByOrderNoList(List<String> orderNoList);
 }

performance-web/src/main/java/com/clx/performance/dao/OrderGoodsTruckBindDao.java

@@ -69,4 +69,6 @@ public interface OrderGoodsTruckBindDao extends BaseDao<OrderGoodsTruckBindMappe
     void batchUpdateBindTruckList(String orderGoodsNo, Integer code, List<String> truckNo);
 
     List<OrderGoodsTruckBind> queryNotOrderTruck(List<String> cancelTruckBindOrderGoodsNoList);
+
+    void batchCancelTruckList(List<OrderGoodsTruckBind> updateList);
 }

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

@@ -7,6 +7,7 @@ import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.clx.performance.dao.OrderChildDao;
 import com.clx.performance.dto.CancelOrderGoodsWeightDTO;
+import com.clx.performance.dto.OrderGoodsNotCancelChildDTO;
 import com.clx.performance.dto.linewarn.LineWarnOrderChildStatisticsDTO;
 import com.clx.performance.enums.OrderChildEnum;
 import com.clx.performance.mapper.OrderChildMapper;
@@ -695,4 +696,14 @@ public class OrderChildDaoImpl extends BaseDaoImpl<OrderChildMapper, OrderChild,
                 .in(OrderChild :: getStatus, status)
         );
     }
+
+    @Override
+    public List<OrderGoodsNotCancelChildDTO> countValidByOrderGoodsNoList(List<String> orderGoodsList) {
+        return baseMapper.countValidByOrderGoodsNoList(orderGoodsList);
+    }
+
+    @Override
+    public void batchUpdateCancel(List<OrderChild> canCancelOrderChildList) {
+        baseMapper.batchUpdateCancel(canCancelOrderChildList);
+    }
 }

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

@@ -5,6 +5,8 @@ import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.clx.performance.dao.OrderGoodsDao;
 import com.clx.performance.dto.CancelOrderGoodsWeightDTO;
+import com.clx.performance.dto.OrderExtractWeightDTO;
+import com.clx.performance.dto.OrderGoodsCancelWeightDTO;
 import com.clx.performance.enums.OrderGoodsStatusEnum;
 import com.clx.performance.mapper.OrderGoodsMapper;
 import com.clx.performance.model.OrderGoods;
@@ -18,7 +20,6 @@ import com.clx.performance.vo.app.OrderGoodsAPPVO;
 import com.clx.performance.vo.pc.OrderGoodsVO;
 import com.msl.common.base.Optional;
 import com.msl.common.dao.impl.BaseDaoImpl;
-import org.apache.ibatis.annotations.Param;
 import org.springframework.stereotype.Repository;
 
 import java.math.BigDecimal;
@@ -33,11 +34,6 @@ import java.util.List;
 @Repository
 public class OrderGoodsDaoImpl extends BaseDaoImpl<OrderGoodsMapper, OrderGoods, Integer> implements OrderGoodsDao {
 
-    @Override
-    public boolean updateWeight(@Param("orderId") Integer orderId, @Param("weight") BigDecimal weight) {
-        return baseMapper.updateWeight(orderId, weight) > 0;
-    }
-
     @Override
     public String getMaxOrderGoodsId() {
         return baseMapper.getMaxOrderGoodsId();
@@ -82,8 +78,8 @@ public class OrderGoodsDaoImpl extends BaseDaoImpl<OrderGoodsMapper, OrderGoods,
     }
 
     @Override
-    public void updateOrderGoodsWeightResidueAndAlreadyAndStatus(Integer id, BigDecimal alreadyTransportWeight,BigDecimal residueTransportWeight,Integer orderGoodsStatus) {
-        baseMapper.updateOrderGoodsWeightResidueAndAlreadyAndStatus(id, alreadyTransportWeight, residueTransportWeight, orderGoodsStatus);
+    public void updateOrderGoodsWeightAlreadyAndStatus(Integer id, BigDecimal residueWeight,Integer orderGoodsStatus) {
+        baseMapper.updateOrderGoodsWeightAlreadyAndStatus(id, residueWeight, orderGoodsStatus);
     }
 
     @Override
@@ -191,8 +187,8 @@ public class OrderGoodsDaoImpl extends BaseDaoImpl<OrderGoodsMapper, OrderGoods,
     }
 
     @Override
-    public Integer updateOrderGoodsSetResidueWeightAndAlreadyWeightAndStatus(BigDecimal residueWeight, BigDecimal alreadyWeight, Integer status, Integer id) {
-        return baseMapper.updateOrderGoodsSetResidueWeightAndAlreadyWeightAndStatus(residueWeight,alreadyWeight,status,id);
+    public Integer updateOrderGoodsSetAlreadyWeightAndStatus(BigDecimal alreadyWeight, Integer status, Integer id) {
+        return baseMapper.updateOrderGoodsSetAlreadyWeightAndStatus(alreadyWeight,status,id);
     }
 
     @Override
@@ -217,13 +213,6 @@ public class OrderGoodsDaoImpl extends BaseDaoImpl<OrderGoodsMapper, OrderGoods,
                 ;
     }
 
-    @Override
-    public boolean batchUpdateOrderGoodsWeight(BigDecimal residueWeight, List<Integer> ids) {
-        return update(lUdWrapper().in(OrderGoods :: getId,ids)
-                .set(OrderGoods::getResidueTransportWeight, residueWeight)
-        );
-    }
-
     @Override
     public List<OrderGoods> getOrderGoodsListByOrderNoAndStatus(String orderNo) {
         return baseMapper.selectList(lQrWrapper().eq(OrderGoods::getOrderNo, orderNo)
@@ -273,14 +262,6 @@ public class OrderGoodsDaoImpl extends BaseDaoImpl<OrderGoodsMapper, OrderGoods,
         return baseMapper.indexOrderGoodsListSearch(page,param);
     }
 
-    @Override
-    public void batchUpdateResidueWeight(List<Integer> list, BigDecimal residueWeight) {
-        update(lUdWrapper()
-                .in(OrderGoods::getId, list)
-                .set(OrderGoods::getResidueTransportWeight, residueWeight)
-        );
-    }
-
     @Override
     public List<OrderGoodsFleetOpenTruck> queryProcessFleetOpenTruckList() {
         return baseMapper.queryProcessFleetOpenTruckList();
@@ -314,7 +295,20 @@ public class OrderGoodsDaoImpl extends BaseDaoImpl<OrderGoodsMapper, OrderGoods,
                 .ne(OrderGoods::getOrderGoodsStatus,OrderGoodsStatusEnum.Status.CREATED.getCode())
                 .orderByDesc(OrderGoods :: getPendingOrderTime)
         );
+    }
+
+    @Override
+    public void batchUpdateOrderGoodsPaying(List<OrderGoods> updateOrderGoods) {
+        baseMapper.batchUpdateOrderGoodsPaying(updateOrderGoods);
+    }
 
+    @Override
+    public void batchCancelOrderGoodsWeight(List<OrderGoodsCancelWeightDTO> cancelOrderGoodsList) {
+        baseMapper.batchCancelOrderGoodsWeight(cancelOrderGoodsList);
     }
 
+    @Override
+    public List<OrderExtractWeightDTO> calcOrderGoodsExtractWeightByOrderNoList(List<String> orderNoList) {
+        return baseMapper.calcOrderGoodsExtractWeightByOrderNoList(orderNoList);
+    }
 }

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

@@ -231,4 +231,9 @@ public class OrderGoodsTruckBindDaoImpl extends BaseDaoImpl<OrderGoodsTruckBindM
         return baseMapper.selectList(lQrWrapper().in(OrderGoodsTruckBind::getOrderGoodsNo, cancelTruckBindOrderGoodsNoList)
                 .eq(OrderGoodsTruckBind::getStatus, OrderGoodsTruckBindEnum.Status.NORMAL.getCode()));
     }
+
+    @Override
+    public void batchCancelTruckList(List<OrderGoodsTruckBind> updateList) {
+        baseMapper.batchCancelTruckList(updateList);
+    }
 }

performance-web/src/main/java/com/clx/performance/dto/OrderExtractWeightDTO.java

+package com.clx.performance.dto;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Getter;
+import lombok.Setter;
+
+import java.math.BigDecimal;
+
+/**
+ * @ClassName OrderExtractWeightDTO
+ * @Description
+ * @Author kavin
+ * @Date 2024/8/8 11:47
+ * @Version 1.0
+ */
+
+@Getter
+@Setter
+public class OrderExtractWeightDTO {
+
+    @ApiModelProperty("订单编号")
+    private String orderNo;
+
+    @ApiModelProperty("已提取吨数")
+
+    private BigDecimal extractWeight;
+}

performance-web/src/main/java/com/clx/performance/dto/OrderGoodsCancelWeightDTO.java

+package com.clx.performance.dto;
+
+import lombok.Getter;
+import lombok.Setter;
+
+import java.math.BigDecimal;
+
+/**
+ * @ClassName OrderGoodsNotCancelChildDTO
+ * @Description
+ * @Author kavin
+ * @Date 2024/8/6 10:52
+ * @Version 1.0
+ */
+
+
+@Getter
+@Setter
+public class OrderGoodsCancelWeightDTO {
+    private String orderGoodsNo;  //货单编号
+    private BigDecimal weight;   //归还货单的吨数
+}

performance-web/src/main/java/com/clx/performance/dto/OrderGoodsNotCancelChildDTO.java

+package com.clx.performance.dto;
+
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ * @ClassName OrderGoodsNotCancelChildDTO
+ * @Description
+ * @Author kavin
+ * @Date 2024/8/6 10:52
+ * @Version 1.0
+ */
+
+
+@Getter
+@Setter
+public class OrderGoodsNotCancelChildDTO {
+    private String orderGoodsNo;  //货单编号
+    private Long count;   //货单下未取消的运单数量
+}

performance-web/src/main/java/com/clx/performance/extranal/user/DriverService.java

 package com.clx.performance.extranal.user;
 
+import com.clx.user.param.feign.BatchUpdateDriverAndTruckParam;
 import com.clx.user.vo.feign.DriverInfoFeignVo;
 import com.clx.user.vo.feign.DriverTruckInfoFeignVo;
 import com.clx.user.vo.feign.FeignDriverTruckModelVo;
 import com.msl.common.base.Optional;
 
+import java.util.List;
+
 public interface DriverService {
 
 
@@ -18,4 +21,7 @@ public interface DriverService {
 
     Optional<FeignDriverTruckModelVo> getDumpType(String truckModel);//通过车型获取自卸非自卸
 
+    //批量恢复司机和车辆状态
+    void batchUpdateDriverAndTruckStatusCancel(List<BatchUpdateDriverAndTruckParam> list);
+
 }

performance-web/src/main/java/com/clx/performance/extranal/user/OrderService.java

@@ -5,6 +5,7 @@ import com.msl.common.base.Optional;
 import org.springframework.web.bind.annotation.RequestParam;
 
 import java.util.List;
+import java.util.Map;
 
 public interface OrderService {
 
@@ -14,4 +15,8 @@ public interface OrderService {
 
     Optional<List<String>>   getMonthSameLineOrderList(String orderNo);
 
+
+    Optional<Map<String,FeignOrderInfoVO>> queryListOrderByOrderNoList(List<String> orderNoList);
+
+
 }

performance-web/src/main/java/com/clx/performance/extranal/user/impl/DriverServiceImpl.java

@@ -2,6 +2,7 @@ package com.clx.performance.extranal.user.impl;
 
 import com.clx.performance.extranal.user.DriverService;
 import com.clx.user.feign.DriverFeign;
+import com.clx.user.param.feign.BatchUpdateDriverAndTruckParam;
 import com.clx.user.vo.feign.DriverInfoFeignVo;
 import com.clx.user.vo.feign.DriverTruckInfoFeignVo;
 import com.clx.user.vo.feign.FeignDriverTruckModelVo;
@@ -13,6 +14,7 @@ import lombok.AllArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
 
+import java.util.List;
 import java.util.Objects;
 
 @Slf4j
@@ -66,4 +68,10 @@ public class DriverServiceImpl implements DriverService {
 
         return Optional.ofNullable(result.getData());
     }
+
+    @Override
+    public void batchUpdateDriverAndTruckStatusCancel(List<BatchUpdateDriverAndTruckParam> list) {
+        Optional.ofNullable(driverFeign.batchUpdateOrderStatus(list))
+                .filter(Result::succeed).orElseThrow(ResultCodeEnum.FAIL);
+    }
 }

performance-web/src/main/java/com/clx/performance/extranal/user/impl/OrderServiceImpl.java

@@ -10,6 +10,7 @@ import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
 
 import java.util.List;
+import java.util.Map;
 
 @Service
 @Slf4j
@@ -31,4 +32,11 @@ public class OrderServiceImpl implements OrderService {
                 .filter(Result::succeed)
                 .map(Result::getData);
     }
+
+    @Override
+    public Optional<Map<String,FeignOrderInfoVO>> queryListOrderByOrderNoList(List<String> orderNoList) {
+        return Optional.ofNullable(orderFeign.queryListOrderByOrderNoList(orderNoList))
+                .filter(Result::succeed)
+                .map(Result::getData);
+    }
 }

performance-web/src/main/java/com/clx/performance/listener/OrderChildDtsListener.java

@@ -171,7 +171,7 @@ public class OrderChildDtsListener  {
                             Objects.nonNull(byCode)?byCode.getName():"未知状态");
                     child = lastTruckService.getOrderCompleteLastTruck(after.getOrderNo());
                 }else{  // 订单除  已完成 || 已完结  外的其他状态
-                    child = lastTruckService.getLastTruckChild(after.getOrderNo());
+                    child = lastTruckService.getOrderLastTruck(after.getOrderNo());
                 }
                 if (Objects.nonNull(child)) {
                     log.info("开始同步新货主客户端最后一车的运单，运单编号:{}", child.getChildNo());
@@ -222,7 +222,7 @@ public class OrderChildDtsListener  {
         }
     }
 
-    public void syncLastTruck(FeignOrderVO orderInfoFeign,OrderChildMessage after){
+    public void syncLastTruck(FeignOrderVO orderInfoFeign,OrderChildMessage after) {
         //当运单状态为到达目的地之后的状态时候，需要判断最后一车的逻辑
         if(Objects.equals(com.clx.open.sdk.enums.OrderChildEnum.Status.COMMON_CANCEL.getCode(),after.getStatus()) ||
                 (after.getStatus() >= OrderChildEnum.Status.ARRIVE_RECEIVE.getCode()  && after.getStatus() <= OrderChildEnum.Status.COMPLETE.getCode())){
@@ -234,7 +234,7 @@ public class OrderChildDtsListener  {
                         Objects.nonNull(byCode)?byCode.getName():"未知状态");
                 child = lastTruckService.getOrderCompleteLastTruck(after.getOrderNo());
             }else{  // 订单除  已完成 || 已完结  外的其他状态
-                child = lastTruckService.getLastTruckChild(after.getOrderNo());
+                child = lastTruckService.getOrderLastTruck(after.getOrderNo());
             }
             if(Objects.nonNull(child)){
                 lastTruckService.syncLastTruckChild(child);

performance-web/src/main/java/com/clx/performance/listener/OrderGoodsDtsListener.java

 package com.clx.performance.listener;
 
 import com.alibaba.fastjson.JSON;
-import com.clx.order.enums.UpdateEnum;
-import com.clx.order.enums.VehicleUsageEnum;
 import com.clx.performance.common.MqWrapper;
 import com.clx.performance.component.GoodsOrderTruckRecordComponent;
 import com.clx.performance.component.OrderCancelComponent;
@@ -10,8 +8,6 @@ import com.clx.performance.constant.RabbitKeyConstants;
 import com.clx.performance.dao.OrderGoodsDao;
 import com.clx.performance.dto.dts.DataTransportDTO;
 import com.clx.performance.enums.DtsOperationTypeEnum;
-import com.clx.performance.enums.OrderGoodsLogsEnum;
-import com.clx.performance.enums.OrderGoodsPendingOrderWayStatusEnum;
 import com.clx.performance.enums.OrderGoodsStatusEnum;
 import com.clx.performance.model.OrderGoods;
 import com.clx.performance.model.OrderGoodsAdjustmentPrice;
@@ -57,7 +53,6 @@ public class OrderGoodsDtsListener {
                 sendSaveOrderGoodsAdjustmentPriceMessage(before,after,DtsOperationTypeEnum.INSERT.getCode());
             }else if(Objects.equals(DtsOperationTypeEnum.UPDATE.getCode(),dataTransportDTO.getOperationType().getCode())){
                 log.info("修改:{}",JSON.toJSONString(after));
-                backFillOrderWeight(after);
                 syncPerformanceProgress(before,after,DtsOperationTypeEnum.UPDATE.getCode());
                 sendSaveOrderGoodsAdjustmentPriceMessage(before,after,DtsOperationTypeEnum.UPDATE.getCode());
             }else if(Objects.equals(DtsOperationTypeEnum.DELETE.getCode(),dataTransportDTO.getOperationType().getCode())){
@@ -69,31 +64,6 @@ public class OrderGoodsDtsListener {
         }
     }
 
-    //货单剩余吨数不足35吨，自动恢复吨数到订单上
-    public void backFillOrderWeight(OrderGoods after){
-        //剩余吨数小于35吨并且大于0，自动归还订单上
-        if(new BigDecimal("35").compareTo(after.getResidueTransportWeight()) > 0 &&
-                after.getResidueTransportWeight().compareTo(BigDecimal.ZERO) > 0){
-            log.info("开始自动恢复吨数到订单,订单号:{},货单号:{},货单剩余吨数:{}",
-                    after.getOrderNo(),after.getOrderGoodsNo(),after.getResidueTransportWeight());
-            orderCancelComponent.backFillOrderWeight(after,after.getResidueTransportWeight(), UpdateEnum.ADD.getCode());
-            OrderGoods orderGoods = new OrderGoods();
-            orderGoods.setId(after.getId());
-            orderGoods.setResidueTransportWeight(BigDecimal.ZERO);
-            orderGoodsDao.updateEntityByKey(orderGoods);
-            orderGoodsLogService.saveLog(after.getOrderGoodsNo(), 0L, "系统", OrderGoodsLogsEnum.Type.SYSTEM_RELEASE.getName(),
-                    String.format("系统自动释放：%s吨", after.getResidueTransportWeight()));
-            //释放定向单(非自由车辆)对应的定向车辆
-            if( (  Objects.equals(after.getPendingOrderWay(), OrderGoodsPendingOrderWayStatusEnum.Status.EXCLUSIVE.getCode())
-                || Objects.equals(after.getPendingOrderWay(), OrderGoodsPendingOrderWayStatusEnum.Status.FLEET_EXCLUSIVE.getCode()) )
-            && !Objects.equals(after.getVehicleUsage(), VehicleUsageEnum.Status.OWN.getCode())){
-                goodsOrderTruckRecordComponent.releaseOrderGoodsDriverAndTruck(after.getOrderGoodsNo());
-            }
-            log.info("结束自动恢复吨数到订单,订单号:{},货单号:{},货单剩余吨数:{}",
-                    after.getOrderNo(),after.getOrderGoodsNo(),after.getResidueTransportWeight());
-        }
-    }
-
 
     public void syncPerformanceProgress(OrderGoods before,OrderGoods after, Integer updateType) {
         boolean isSend = false;

performance-web/src/main/java/com/clx/performance/mapper/OrderChildMapper.java

@@ -4,6 +4,7 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.clx.performance.dto.CancelOrderGoodsWeightDTO;
+import com.clx.performance.dto.OrderGoodsNotCancelChildDTO;
 import com.clx.performance.dto.linewarn.LineWarnOrderChildStatisticsDTO;
 import com.clx.performance.model.OrderChild;
 import com.clx.performance.param.app.PageOrderChildOfDriverParam;
@@ -176,4 +177,13 @@ public interface OrderChildMapper extends BaseMapper<OrderChild> {
             " group by order_goods_no " +
             "</script>")
     List<CancelOrderGoodsWeightDTO> statisticsCancelOrderGoodsWeight(@Param("list") List<String> childNos);
+
+
+    @SelectProvider(type = OrderChildSqlProvider.class, method = "countValidByOrderGoodsNoList")
+    List<OrderGoodsNotCancelChildDTO> countValidByOrderGoodsNoList(@Param("orderGoodsList") List<String> orderGoodsList);
+
+
+
+    @SelectProvider(type = OrderChildSqlProvider.class, method = "batchUpdateCancel")
+    void batchUpdateCancel(@Param("canCancelOrderChildList") List<OrderChild> canCancelOrderChildList);
 }
\ No newline at end of file

performance-web/src/main/java/com/clx/performance/mapper/OrderGoodsMapper.java

@@ -4,6 +4,8 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.clx.performance.dto.CancelOrderGoodsWeightDTO;
+import com.clx.performance.dto.OrderExtractWeightDTO;
+import com.clx.performance.dto.OrderGoodsCancelWeightDTO;
 import com.clx.performance.model.OrderGoods;
 import com.clx.performance.model.OrderGoodsFleetOpenTruck;
 import com.clx.performance.param.app.AppGoodsOrderSearchParam;
@@ -24,11 +26,6 @@ import java.util.List;
  */
 public interface OrderGoodsMapper extends BaseMapper<OrderGoods> {
 
-    @Update(" update order_goods set " +
-            " residue_transport_weight = residue_transport_weight-#{weight} " +
-            " where id = #{orderId}")
-    int updateWeight(@Param("orderId") Integer orderId, @Param("weight") BigDecimal weight);
-
     @SelectProvider(type = OrderGoodsSqlProvider.class, method = "getMaxOrderGoodsId")
     String getMaxOrderGoodsId();
 
@@ -36,18 +33,16 @@ public interface OrderGoodsMapper extends BaseMapper<OrderGoods> {
     IPage<OrderGoodsVO> pageOrderGoodsList(@Param("page") Page<OrderGoodsVO> page, @Param("param") PageOrderGoodsListParam param);
 
     @Update(" update order_goods set " +
-            " residue_transport_weight = residue_transport_weight-#{weight}," +
             " already_transport_weight = already_transport_weight+#{weight}," +
             "order_goods_status = #{orderGoodsStatus} " +
             " where id = #{id}")
     void updateOrderGoodsWeightAndStatus(@Param("id") Integer id, @Param("weight") BigDecimal orderChildWeight, @Param("orderGoodsStatus") Integer orderGoodsStatus);
 
     @Update(" update order_goods set " +
-            " residue_transport_weight = residue_transport_weight-#{residueTransportWeight}," +
-            " already_transport_weight = already_transport_weight+#{alreadyTransportWeight}," +
+            " already_transport_weight = already_transport_weight - #{residueWeight}," +
             "order_goods_status = #{orderGoodsStatus} " +
             " where id = #{id}")
-    void updateOrderGoodsWeightResidueAndAlreadyAndStatus(@Param("id") Integer id, @Param("alreadyTransportWeight") BigDecimal alreadyTransportWeight, @Param("residueTransportWeight") BigDecimal residueTransportWeight,@Param("orderGoodsStatus") Integer orderGoodsStatus);
+    void updateOrderGoodsWeightAlreadyAndStatus(@Param("id") Integer id, @Param("residueWeight") BigDecimal residueWeight, @Param("orderGoodsStatus") Integer orderGoodsStatus);
 
 
     @SelectProvider(type = OrderGoodsSqlProvider.class, method = "openOrderPageGoodsList")
@@ -76,8 +71,8 @@ public interface OrderGoodsMapper extends BaseMapper<OrderGoods> {
     @UpdateProvider(type = OrderGoodsSqlProvider.class, method = "updateOrderGoods")
     Integer updateOrderGoods(@Param(value = "params") OrderGoodsEditParams orderGoodsEditParams);
 
-    @UpdateProvider(type = OrderGoodsSqlProvider.class, method = "updateOrderGoodsSetResidueWeightAndAlreadyWeightAndStatus")
-    Integer updateOrderGoodsSetResidueWeightAndAlreadyWeightAndStatus(@Param(value = "residueWeight") BigDecimal residueWeight,@Param(value = "alreadyWeight") BigDecimal alreadyWeight,@Param(value = "status") Integer status,@Param(value = "id") Integer id);
+    @UpdateProvider(type = OrderGoodsSqlProvider.class, method = "updateOrderGoodsSetAlreadyWeightAndStatus")
+    Integer updateOrderGoodsSetAlreadyWeightAndStatus(@Param(value = "alreadyWeight") BigDecimal alreadyWeight,@Param(value = "status") Integer status,@Param(value = "id") Integer id);
 
     @SelectProvider(type = OrderGoodsSqlProvider.class, method = "getAlreadyTransportWeight")
     BigDecimal getAlreadyTransportWeight(@Param("orderNo") String orderNo);
@@ -108,4 +103,14 @@ public interface OrderGoodsMapper extends BaseMapper<OrderGoods> {
     void batchCancelOrderGoods(List<CancelOrderGoodsWeightDTO> cancelOrderGoodsWeight);
 
 
+    @UpdateProvider(type = OrderGoodsSqlProvider.class, method = "batchUpdateOrderGoodsPaying")
+    void batchUpdateOrderGoodsPaying(@Param("updateOrderGoods") List<OrderGoods> updateOrderGoods);
+
+
+    @UpdateProvider(type = OrderGoodsSqlProvider.class, method = "batchCancelOrderGoodsWeight")
+    void batchCancelOrderGoodsWeight(@Param("cancelOrderGoodsList") List<OrderGoodsCancelWeightDTO> cancelOrderGoodsList);
+
+
+    @SelectProvider(type = OrderGoodsSqlProvider.class, method = "calcOrderGoodsExtractWeightByOrderNoList")
+    List<OrderExtractWeightDTO> calcOrderGoodsExtractWeightByOrderNoList(List<String> orderNoList);
 }

performance-web/src/main/java/com/clx/performance/mapper/OrderGoodsTruckBindMapper.java

@@ -38,4 +38,8 @@ public interface OrderGoodsTruckBindMapper extends BaseMapper<OrderGoodsTruckBin
 
     @SelectProvider(type = OrderGoodsTruckBindSqlProvider.class, method = "queryOrderGoodsTruckNum")
     List<OrderGoodsBindTruckNumDTO> queryOrderGoodsTruckNum(List<String> fleetNoList);
+
+
+    @SelectProvider(type = OrderGoodsTruckBindSqlProvider.class, method = "batchCancelTruckList")
+    void batchCancelTruckList(List<OrderGoodsTruckBind> updateList);
 }
\ No newline at end of file

performance-web/src/main/java/com/clx/performance/service/LastTruckService.java

@@ -5,7 +5,6 @@ import com.msl.common.result.Result;
 
 public interface LastTruckService {
 
-    OrderChild getLastTruckChild(String orderNo);
 
     Result<?> syncLastTruckChild(OrderChild child);
 
@@ -14,4 +13,8 @@ public interface LastTruckService {
 
     Result<?> syncLastTruckChild4OrderTrigger(String orderNo);
 
+    OrderChild getOrderLastTruck(String orderNo);
+
+
+
 }

performance-web/src/main/java/com/clx/performance/service/OrderChildLogService.java

@@ -16,4 +16,5 @@ public interface OrderChildLogService {
 
     void saveBatchOrderChildLog(List<OrderChildLog> logs);
 
+    void batchSaveCarrierOrderChildLogs(List<OrderChild> canCancelOrderChildList,Long userNo,String userName);
 }

performance-web/src/main/java/com/clx/performance/service/OrderChildService.java

@@ -11,6 +11,7 @@ import com.clx.performance.param.pc.*;
 import com.clx.performance.vo.app.*;
 import com.clx.performance.vo.app.owner.OwnerOrderChildVO;
 import com.clx.performance.vo.pc.*;
+import com.clx.performance.vo.pc.child.UpdateCarrierBatchCancelVO;
 import com.msl.common.base.PageParam;
 import org.apache.poi.xssf.streaming.SXSSFWorkbook;
 
@@ -110,4 +111,6 @@ public interface OrderChildService {
     List<HistoryLineTranVolumeChartVO> getHistoryLineTransportVolume(String orderNo);
 
 
+
+    UpdateCarrierBatchCancelVO updateCarrierBatchCancel(OrderChildCarrierBatchCancelParam param);
 }

performance-web/src/main/java/com/clx/performance/service/OrderGoodsService.java

@@ -34,9 +34,6 @@ public interface OrderGoodsService {
 
     void updateOrderGoodsReduceWeightAndStatusAmountLoad(OrderGoods orderGoods, BigDecimal orderChildWeight, Integer orderGoodsStatus);
 
-    void borrowWeight(OrderGoods orderGoods,String orderChildNo,BigDecimal subOrderGoodsResidue, BigDecimal addAlready,BigDecimal borrowOrderWeight,
-            Integer orderGoodsStatus);
-
 
     void updateOrderGoodsReduceWeightAndStatus(OrderGoods orderGoods, OrderChild orderChild, Integer orderGoodsStatus);
 
@@ -102,8 +99,6 @@ public interface OrderGoodsService {
 
     IPage<OrderGoodsAPPVO> indexOrderGoodsListSearch(AppGoodsOrderSearchParam param);
 
-    void batchUpdateResidueWeight(List<OrderGoods> list);
-
     void saveBindTruck(DistributionTruckParam param);
 
 
@@ -114,4 +109,7 @@ public interface OrderGoodsService {
     List<DriverFreightPriceVO> getDriverFreightPriceList(String orderNo);
 
     List<OrderGoodsPendingVO> getOrderGoodsPendingList(String orderNo);
+
+
+    BigDecimal calcOrderGoodsResidueWeight(BigDecimal extractWeight,BigDecimal alreadyWeight);
 }

performance-web/src/main/java/com/clx/performance/service/OrderGoodsWeightService.java

+package com.clx.performance.service;
+
+import java.math.BigDecimal;
+
+public interface OrderGoodsWeightService {
+    BigDecimal getOrderGoodsCanExtractWeight(String orderGoodsNo);
+}

performance-web/src/main/java/com/clx/performance/service/OrderWeightService.java

+package com.clx.performance.service;
+
+import com.clx.performance.vo.feign.OrderExtractWeightVO;
+
+import java.math.BigDecimal;
+
+public interface OrderWeightService {
+    OrderExtractWeightVO getOrderCanExtractWeight(String orderNo);
+
+    BigDecimal getOrderResidueWeight(String orderNo);
+}

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

@@ -4,20 +4,29 @@ import com.alibaba.fastjson.JSON;
 import com.clx.open.sdk.callback.OpenCallBackClient;
 import com.clx.open.sdk.callback.message.OrderChildMessage;
 import com.clx.open.sdk.enums.ResultStatusEnum;
+import com.clx.order.enums.ResultEnum;
 import com.clx.order.feign.OrderFeign;
 import com.clx.order.vo.feign.FeignOrderVO;
 import com.clx.performance.config.ThirdAppConfig;
+import com.clx.performance.constant.RedisConstants;
+import com.clx.performance.constant.RedissonConstants;
 import com.clx.performance.dao.OrderChildDao;
 import com.clx.performance.model.OrderChild;
 import com.clx.performance.service.LastTruckService;
 import com.clx.performance.struct.OrderChildStruct;
+import com.msl.common.exception.ServiceSystemException;
 import com.msl.common.result.Result;
 import lombok.AllArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang.exception.ExceptionUtils;
+import org.redisson.api.RLock;
+import org.redisson.api.RedissonClient;
+import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.stereotype.Service;
 
 import java.math.BigDecimal;
 import java.util.Objects;
+import java.util.concurrent.TimeUnit;
 
 /**
  * @ClassName LastTruckServiceImpl
@@ -35,31 +44,9 @@ public class LastTruckServiceImpl implements LastTruckService {
     private final OrderChildDao orderChildDao;
     private final OrderChildStruct orderChildStruct;
     private final ThirdAppConfig thirdAppConfig;
-    /**
-     * @Author kavin
-     * @Description 判断最后一车的逻辑
-     * @Param [orderNo]
-     * @return
-     **/
-    @Override
-    public OrderChild getLastTruckChild(String orderNo) {
-        FeignOrderVO orderInfo = orderFeign.getOrderInfoFeign(orderNo);
-        if(Objects.isNull(orderInfo)){
-            log.error("计算最后一车，通过订单号:{},未查询到对应的订单",orderNo);
-            return null;
-        }
-        BigDecimal weight = orderChildDao.listAfterArrayReceiveChild(orderNo);
-        //判断当前订单下所有到达目的地之后的运单的装车吨数  >= （订单拉运吨数 -35吨）
-        log.info("订单号:{} ,计算是否到达可计算最后一车标准，运单累计拉运吨数：{}, 订单拉运吨数:{}",
-                orderNo,weight,orderInfo.getTransportWeight());
-        if(Objects.nonNull(weight) && weight.compareTo(orderInfo.getTransportWeight().subtract(new BigDecimal("35"))) >= 0){
-            //查询最后一车的运单
-            OrderChild child = orderChildDao.getLastTruckChild(orderNo);
-            log.info("当前订单计算出最后一车，运单编号：{} ", child.getChildNo());
-            return child;
-        }
-        return  null;
-    }
+    private final RedissonClient redissonClient;
+    private final RedisTemplate<String, String> redisTemplate;
+
     /**
      * @Author kavin
      * @Description 同步最后一车
@@ -79,16 +66,24 @@ public class LastTruckServiceImpl implements LastTruckService {
         return result;
     }
 
+    //在没有算出最后一车的前提下，订单变成已完结或者已完成状态，但是订单量可能并没有提取完，所以只需要判断订单下是否还有未到达 目的地的运单，没有则进行最后一车运算
     @Override
     public OrderChild getOrderCompleteLastTruck(String orderNo) {
-        //判断当前订单下是否存在未到达目的地之前的运单 && 排除掉已取消的运单
-        Long count = orderChildDao.haveArriveReceiveChild(orderNo);
-        log.info("已完成/已完结的订单号:{},查询运单状态非取消并且在到达目的地之前的运单数量为:{}",orderNo,count);
-        if(count  == 0 ){
-            //说明排除已取消的运单后，剩下的所有运单都已经是到达目的地之后的状态，根据到达目的地的时间倒序取出第一条运单作为最后一车
-            return orderChildDao.getOrderCompleteLastTruck(orderNo);
+        String lastTruckCacheKey = getLastTruckCacheKey(orderNo);
+        //已经计算出最后一车，则直接返回运单信息
+        if(Objects.equals(Boolean.TRUE,redisTemplate.hasKey(lastTruckCacheKey))){
+            String childNo = redisTemplate.opsForValue().get(lastTruckCacheKey);
+            return orderChildDao.getByChildNo(childNo).orElseThrow(ResultEnum.DATA_NOT_FIND);
+        }else{
+            //判断当前订单下是否存在未到达目的地之前的运单 && 排除掉已取消的运单
+            Long count = orderChildDao.haveArriveReceiveChild(orderNo);
+            log.info("已完成/已完结的订单号:{},查询运单状态非取消并且在到达目的地之前的运单数量为:{}",orderNo,count);
+            if(count  == 0 ){
+                //说明排除已取消的运单后，剩下的所有运单都已经是到达目的地之后的状态，根据到达目的地的时间倒序取出第一条运单作为最后一车
+                return orderChildDao.getOrderCompleteLastTruck(orderNo);
+            }
+            return null;
         }
-        return null;
     }
 
 
@@ -106,4 +101,54 @@ public class LastTruckServiceImpl implements LastTruckService {
         }
         return Result.ok("订单完成/完结状态下未查询最后一车，订单编号:" + orderNo);
     }
+
+    //调用此方法前查订单是否存在最后一车，存在则不进行该方法调用
+    @Override
+    public OrderChild getOrderLastTruck(String orderNo){
+        FeignOrderVO orderInfo = orderFeign.getOrderInfoFeign(orderNo);
+        if(Objects.isNull(orderInfo)){
+            log.error("计算订单最后一车，通过订单号:{},未查询到对应的订单",orderNo);
+            return null;
+        }
+
+        //为每个货主的订单进行加锁，计算最后一车进行排队，防止多个运单dts监听并发导致最后一车重复计算
+        RLock lock = redissonClient.getLock(RedissonConstants.CALC_ORDER_LAST_TRUCK_LOCK + orderNo);
+        try{
+            String lastTruckCacheKey = getLastTruckCacheKey(orderNo);
+            //已经计算出最后一车，则直接返回运单信息
+            if(Objects.equals(Boolean.TRUE,redisTemplate.hasKey(lastTruckCacheKey))){
+                String childNo = redisTemplate.opsForValue().get(lastTruckCacheKey);
+                return orderChildDao.getByChildNo(childNo).orElseThrow(ResultEnum.DATA_NOT_FIND);
+            }
+            boolean flag = lock.tryLock(15, 30, TimeUnit.SECONDS);
+            if (!flag) {
+                throw new ServiceSystemException(ResultEnum.TRY_LOCK_ERROR,"计算最后一车请求排队超时");
+            }
+
+            BigDecimal weight = orderChildDao.listAfterArrayReceiveChild(orderNo);
+            log.info("计算订单最后一车，订单号:{} ,计算是否到达可计算最后一车标准，运单累计拉运吨数：{}, 订单拉运吨数:{}",
+                    orderNo,weight,orderInfo.getTransportWeight());
+
+            if(Objects.nonNull(weight) && weight.subtract(orderInfo.getTransportWeight()).compareTo(BigDecimal.ZERO) >= 0){
+                //查询最后一车的运单
+                OrderChild child = orderChildDao.getLastTruckChild(orderNo);
+                log.info("当前订单计算出最后一车，运单编号：{} ", child.getChildNo());
+                //更新订单最后一车到缓存,并设置有效期为60天
+                redisTemplate.opsForValue().set(getLastTruckCacheKey(orderNo),child.getChildNo(),60, TimeUnit.DAYS);
+                return child;
+            }
+            return null;
+        } catch (InterruptedException e){
+            log.warn("计算订单最后一车发生异常，异常原因:{}", ExceptionUtils.getStackTrace(e));
+        }finally {
+            if (lock.isLocked() && lock.isHeldByCurrentThread()) {
+                lock.unlock();
+            }
+        }
+        return null;
+    }
+
+    public String getLastTruckCacheKey(String orderNo){
+        return RedisConstants.ORDER_LAST_TRUCK_CHILD + orderNo;
+    }
 }

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

@@ -2,12 +2,14 @@ package com.clx.performance.service.impl;
 
 import com.clx.performance.dao.OrderChildLogDao;
 import com.clx.performance.enums.OrderChildLogEnum;
+import com.clx.performance.model.OrderChild;
 import com.clx.performance.model.OrderChildLog;
 import com.clx.performance.service.OrderChildLogService;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import java.util.ArrayList;
 import java.util.List;
 
 @Slf4j
@@ -52,4 +54,22 @@ public class OrderChildLogServiceImpl implements OrderChildLogService {
     public void saveBatchOrderChildLog(List<OrderChildLog> logs) {
         orderChildLogDao.saveBatchList(logs);
     }
+
+    @Override
+    public void batchSaveCarrierOrderChildLogs(List<OrderChild> canCancelOrderChildList,Long userNo,String userName) {
+
+        List<OrderChildLog> logs = new ArrayList<>();
+        OrderChildLog orderChildLog;
+        for (OrderChild child : canCancelOrderChildList) {
+            orderChildLog = new OrderChildLog();
+            orderChildLog.setChildNo(child.getChildNo());
+            orderChildLog.setType(OrderChildLogEnum.Type.PLATFORM_CANCEL.getCode());
+            orderChildLog.setRemark(OrderChildLogEnum.Type.PLATFORM_CANCEL.getMsg());
+            orderChildLog.setCreateType(OrderChildLogEnum.CreateType.PLATFORM.getCode());
+            orderChildLog.setCreateBy(userNo);
+            orderChildLog.setCreateName(userName);
+            logs.add(orderChildLog);
+        }
+        orderChildLogDao.saveBatchList(logs);
+    }
 }

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

+package com.clx.performance.service.impl;
+
+import com.clx.performance.dao.OrderGoodsDao;
+import com.clx.performance.enums.ResultEnum;
+import com.clx.performance.model.OrderGoods;
+import com.clx.performance.service.OrderGoodsWeightService;
+import lombok.AllArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+
+import java.math.BigDecimal;
+
+/**
+ * @ClassName OrderGoodsWeightServiceImpl
+ * @Description
+ * @Author kavin
+ * @Date 2024/8/5 14:16
+ * @Version 1.0
+ */
+@Slf4j
+@Service
+@AllArgsConstructor
+public class OrderGoodsWeightServiceImpl implements OrderGoodsWeightService {
+
+    private final OrderGoodsDao orderGoodsDao;
+    @Override
+    public BigDecimal getOrderGoodsCanExtractWeight(String orderGoodsNo) {
+        OrderGoods orderGoods = orderGoodsDao.getByOrderGoodsNo(orderGoodsNo).orElseThrow(ResultEnum.DATA_NOT_FIND);
+        return orderGoods.getExtractWeight().subtract(orderGoods.getAlreadyTransportWeight());
+    }
+}

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

+package com.clx.performance.service.impl;
+
+import com.clx.order.enums.VehicleUsageEnum;
+import com.clx.order.vo.feign.FeignOrderInfoVO;
+import com.clx.performance.dao.OrderChildDao;
+import com.clx.performance.dao.OrderGoodsDao;
+import com.clx.performance.enums.OrderGoodsStatusEnum;
+import com.clx.performance.enums.PerformanceResultEnum;
+import com.clx.performance.enums.ResultEnum;
+import com.clx.performance.enums.TruckDemandEnum;
+import com.clx.performance.extranal.user.OrderService;
+import com.clx.performance.model.OrderChild;
+import com.clx.performance.model.OrderGoods;
+import com.clx.performance.service.OrderWeightService;
+import com.clx.performance.vo.feign.OrderExtractWeightVO;
+import com.msl.common.exception.ServiceSystemException;
+import lombok.AllArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.collections4.CollectionUtils;
+import org.springframework.stereotype.Service;
+
+import java.math.BigDecimal;
+import java.util.List;
+import java.util.Objects;
+
+/**
+ * @ClassName OrderWeightServiceImpl
+ * @Description
+ * @Author kavin
+ * @Date 2024/8/5 11:52
+ * @Version 1.0
+ */
+
+@Slf4j
+@Service
+@AllArgsConstructor
+public class OrderWeightServiceImpl implements OrderWeightService {
+
+    private final OrderService orderService;
+    private final OrderGoodsDao orderGoodsDao;
+    private final OrderChildDao orderChildDao;
+    @Override
+    public OrderExtractWeightVO getOrderCanExtractWeight(String orderNo) {
+        FeignOrderInfoVO orderInfo = orderService.getOrderInfo(orderNo).orElseThrow(
+                PerformanceResultEnum.DATA_NOT_FIND);
+
+
+        List<OrderGoods> orderGoodsList = orderGoodsDao.listByField(OrderGoods::getOrderNo, orderNo);
+        if(CollectionUtils.isEmpty(orderGoodsList)){
+            return  OrderExtractWeightVO.builder().transportWeight(orderInfo.getTransportWeight())
+                    .truckDemand(orderInfo.getTruckDemand())
+                    .ownCarryWeight(orderInfo.getOwnCarryWeight()).platformCarryWeight(orderInfo.getPlatformCarryWeight())
+                    .ownCanExtractWeight(orderInfo.getOwnCarryWeight()).platCanExtractWeight(orderInfo.getPlatformCarryWeight())
+                    .build();
+        }
+        //已发布的自有车辆吨数
+        BigDecimal ownOrderGoodsWeight = BigDecimal.ZERO;
+        //已发布的平台车辆吨数
+        BigDecimal platOrderGoodsWeight = BigDecimal.ZERO;
+
+        for (OrderGoods item : orderGoodsList) {
+            BigDecimal weight;   //取消，完成，完结的货单取 已拉运吨数 作为提取吨数，
+            if(Objects.equals(item.getOrderGoodsStatus(), OrderGoodsStatusEnum.Status.CANCEL.getCode())
+                || Objects.equals(item.getOrderGoodsStatus(), OrderGoodsStatusEnum.Status.SUCCESS.getCode())
+                    || Objects.equals(item.getOrderGoodsStatus(), OrderGoodsStatusEnum.Status.COMPLETED.getCode())){
+                weight = item.getAlreadyTransportWeight();
+            }else{
+                weight = item.getExtractWeight();
+            }
+
+            if(Objects.equals(item.getVehicleUsage(), VehicleUsageEnum.Status.OWN.getCode())){
+                ownOrderGoodsWeight = ownOrderGoodsWeight.add(weight);
+            }
+            if(Objects.equals(item.getVehicleUsage(), VehicleUsageEnum.Status.PLATFORM.getCode())){
+                platOrderGoodsWeight = platOrderGoodsWeight.add(weight);
+            }
+        }
+
+
+        if(Objects.equals(orderInfo.getTruckDemand(), TruckDemandEnum.TruckType.PLATFORM_CAR.getCode())){
+            return  OrderExtractWeightVO.builder().transportWeight(orderInfo.getTransportWeight())
+                    .truckDemand(orderInfo.getTruckDemand())
+                    .platformCarryWeight(orderInfo.getPlatformCarryWeight())
+                    .platCanExtractWeight(orderInfo.getTransportWeight().subtract(platOrderGoodsWeight))
+                    .build();
+        }
+        if(Objects.equals(orderInfo.getTruckDemand(), TruckDemandEnum.TruckType.OWNER_CAR.getCode())){
+            return  OrderExtractWeightVO.builder().transportWeight(orderInfo.getTransportWeight())
+                    .truckDemand(orderInfo.getTruckDemand())
+                    .ownCarryWeight(orderInfo.getOwnCarryWeight())
+                    .ownCanExtractWeight(orderInfo.getTransportWeight().subtract(ownOrderGoodsWeight))
+                    .build();
+        }
+        if(Objects.equals(orderInfo.getTruckDemand(), TruckDemandEnum.TruckType.PLATFORM_ANY_CAR.getCode())){
+            //因为自有车辆的货单必须一次性全部提取，所有只要自有车辆吨数，剩下的吨数则为平台可提取吨数
+            BigDecimal ownCanExtractWeight = BigDecimal.ZERO;
+            BigDecimal platCanExtractWeight;
+            if(ownOrderGoodsWeight.compareTo(BigDecimal.ZERO) == 0 ){
+                //自有的车辆未发布货单,自有可提取吨数则为订单上自有可提取的吨数
+                ownCanExtractWeight  =  orderInfo.getOwnCarryWeight();
+                //平台可提取吨数 = 承运吨数 - 自有可提取吨数 - 平台已提取的吨数
+                platCanExtractWeight = orderInfo.getTransportWeight().subtract(ownCanExtractWeight).
+                        subtract(platOrderGoodsWeight);
+            }else{
+                //平台可提取吨数 = 承运吨数 - 自有已经提取吨数 - 平台已提取的吨数
+                platCanExtractWeight = orderInfo.getTransportWeight().subtract(ownOrderGoodsWeight).
+                        subtract(platOrderGoodsWeight);
+            }
+
+            return  OrderExtractWeightVO.builder().transportWeight(orderInfo.getTransportWeight())
+                    .truckDemand(orderInfo.getTruckDemand())
+                    .ownCarryWeight(orderInfo.getOwnCarryWeight())
+                    .platformCarryWeight(orderInfo.getPlatformCarryWeight())
+                    .ownCanExtractWeight(ownCanExtractWeight)
+                    .platCanExtractWeight(platCanExtractWeight)
+                    .build();
+        }else{
+            log.warn("订单号：{} 的用车需求未知",orderNo);
+            throw new ServiceSystemException(ResultEnum.DATA_ERROR,"未知的用车需求");
+        }
+
+    }
+
+    @Override
+    public BigDecimal getOrderResidueWeight(String orderNo) {
+        FeignOrderInfoVO orderInfo = orderService.getOrderInfo(orderNo).orElseThrow(
+                PerformanceResultEnum.DATA_NOT_FIND);
+
+        List<OrderChild> orderChildList = orderChildDao.listByField(OrderChild::getOrderNo, orderNo);
+        if(CollectionUtils.isEmpty(orderChildList)){
+            return orderInfo.getTransportWeight();
+        }
+        BigDecimal alreadyWeight = BigDecimal.ZERO;    //该订单下已经拉运的重量
+
+        for (OrderChild child : orderChildList) {
+            if(Objects.nonNull(child.getLoadNet())){
+                alreadyWeight = alreadyWeight.add(child.getLoadNet());
+            }else{
+                alreadyWeight = alreadyWeight.add(child.getWeight());
+            }
+        }
+        return orderInfo.getTransportWeight().subtract(alreadyWeight);
+    }
+}

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

@@ -148,9 +148,9 @@ public class PerformanceProgressServiceImpl  implements PerformanceProgressServi
                     }
                     if(Objects.nonNull(item.getTaskWeight()) && Objects.nonNull(item.getSumUnloadWeight())){
 
-                        //任务完成率 =  到站量 / 任务量+35
+                        //任务完成率 =  到站量 / 任务量
                         BigDecimal taskCompleteRatio =  item.getSumUnloadWeight()
-                                .divide(item.getTaskWeight().add(BusinessConstants.ORDER_SUB_WEIGHT),
+                                .divide(item.getTaskWeight(),
                                         3, RoundingMode.HALF_UP).multiply(new BigDecimal(100));
                         item.setTaskCompleteRatio(taskCompleteRatio);
                     }
@@ -353,7 +353,7 @@ public class PerformanceProgressServiceImpl  implements PerformanceProgressServi
         item.setGoodsNameId(data.getGoodsNameId());
         item.setGoodsName(data.getGoodsName());
         item.setSendOverStandard(data.getOverWeight());
-        item.setTaskWeight(data.getTransportWeight().subtract(BusinessConstants.ORDER_SUB_WEIGHT));
+        item.setTaskWeight(data.getTransportWeight());
         item.setPendingWeight(data.getTransportWeight().subtract(data.getResidueWeight()));
 
         item.setTransportTimeSlot(DateUtils.formatDateTime(data.getTransportBeginTime()).get() + "至" +

performance-web/src/main/java/com/clx/performance/sqlProvider/OrderChildSqlProvider.java

@@ -3,6 +3,7 @@ package com.clx.performance.sqlProvider;
 import cn.hutool.core.collection.CollectionUtil;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.clx.performance.enums.OrderChildEnum;
+import com.clx.performance.model.OrderChild;
 import com.clx.performance.param.app.PageOrderChildOfDriverParam;
 import com.clx.performance.param.app.PageOrderChildOfDriverSearchParam;
 import com.clx.performance.param.pc.OrderChildCancelRecordParam;
@@ -12,6 +13,7 @@ import com.clx.performance.param.pc.PagePoundAuditParam;
 import com.clx.performance.vo.app.OrderChildVO;
 import com.clx.performance.vo.pc.PageCarrierOrderChildVO;
 import com.clx.performance.vo.pc.PageOrderChildPoundAuditVO;
+import com.msl.common.utils.DateUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.apache.ibatis.annotations.Param;
 import org.apache.ibatis.jdbc.SQL;
@@ -19,6 +21,7 @@ import org.apache.ibatis.jdbc.SQL;
 import java.time.LocalDateTime;
 import java.util.List;
 import java.util.Objects;
+import java.util.StringJoiner;
 
 public class OrderChildSqlProvider {
 
@@ -233,4 +236,35 @@ public class OrderChildSqlProvider {
                 " SELECT count(*) AS monthOrderNumber,sum(freight) total FROM  order_child  WHERE truck_no = #{truckNo} and AND finish_time >= #{startTime} AND finish_time <=  #{endTime}" +
                 ") a";
     }
+
+
+    public String countValidByOrderGoodsNoList(@Param("orderGoodsList") List<String> orderGoodsList){
+        return new SQL(){{
+            SELECT("order_goods_no,count(1) count ");
+            FROM("order_child ");
+
+            StringJoiner sj = new StringJoiner(",","order_goods_no in (",")");
+            orderGoodsList.forEach(item -> sj.add("'"+item+"'"));
+            WHERE(sj.toString());
+            WHERE(" a.status < " + OrderChildEnum.Status.DRIVER_CANCEL.getCode());
+            GROUP_BY(" order_goods_no");
+        }}.toString();
+    }
+
+
+    public String batchUpdateCancel(List<OrderChild> list){
+        StringJoiner sj = new StringJoiner("; ");
+        for(OrderChild child : list){
+            sj.add("update order_child " +
+                    "set " +
+                    "cancel_remark = '" + child.getCancelRemark() + "',"  +
+                    "cancel_time = '" + DateUtils.formatDateTime(child.getCancelTime()).get() + "',"  +
+                    "finish_time = '" + DateUtils.formatDateTime(child.getFinishTime()).get() + "',"  +
+                    "status = " + child.getStatus() + "  "  +
+                    "where id = "+child.getId()
+            );
+        }
+        return sj.toString();
+    }
+
 }

performance-web/src/main/java/com/clx/performance/sqlProvider/OrderGoodsTruckBindSqlProvider.java

@@ -2,6 +2,7 @@ package com.clx.performance.sqlProvider;
 
 import com.clx.performance.enums.OrderGoodsStatusEnum;
 import com.clx.performance.enums.OrderGoodsTruckBindEnum;
+import com.clx.performance.model.OrderGoodsTruckBind;
 import org.apache.ibatis.jdbc.SQL;
 
 import java.util.List;
@@ -59,4 +60,19 @@ public class OrderGoodsTruckBindSqlProvider {
             GROUP_BY("a.order_goods_no");
         }}.toString();
     }
+
+
+    public String batchCancelTruckList(List<OrderGoodsTruckBind> updateList){
+        StringJoiner sj = new StringJoiner("; ");
+        for(OrderGoodsTruckBind bind : updateList){
+            sj.add("update order_goods_truck_bind " +
+                    "set " +
+                    "status = " + bind.getStatus() + " "  +
+                    "where order_no = '" +  bind.getOrderNo()+ "' "  +
+                    "and order_goods_no = '" + bind.getOrderGoodsNo() + "' "  +
+                    "and truck_no = '" + bind.getTruckNo() + "'"
+            );
+        }
+        return sj.toString();
+    }
 }

performance-web/src/main/java/com/clx/performance/strategy/GoodsOrderStrategy.java

@@ -9,13 +9,11 @@ import com.clx.performance.model.OrderGoodsTruckBind;
 import com.clx.performance.param.pc.OrderGoodsChildParams;
 import com.clx.performance.param.pc.OrderGoodsParams;
 import com.clx.performance.utils.SpringContextUtils;
+import com.clx.performance.vo.feign.OrderExtractWeightVO;
 import com.msl.common.exception.ServiceSystemException;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.lang3.StringUtils;
-import org.springframework.amqp.rabbit.core.RabbitTemplate;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.core.env.Environment;
 
 import java.time.LocalDateTime;
 import java.util.HashSet;
@@ -27,9 +25,6 @@ import java.util.stream.Collectors;
 @Slf4j
 public abstract class GoodsOrderStrategy {
 
-    @Autowired
-    private Environment environment;
-
 
     /**
      * 不同的用车需求执行不同的策略   1：one  2:two 3:three
@@ -40,23 +35,15 @@ public abstract class GoodsOrderStrategy {
      * @param now
      * @return
      */
-    public abstract LocalDateTime goodsOrderProcess(OrderGoodsParams orderGoodsParams, FeignOrderVO orderInfo, LocalDateTime now);
+    public abstract LocalDateTime goodsOrderProcess(OrderGoodsParams orderGoodsParams, FeignOrderVO orderInfo,
+            OrderExtractWeightVO orderCanExtractWeight, LocalDateTime now);
 
 
-    public void saveGoodsOrder(OrderGoodsParams orderGoodsParams, FeignOrderVO orderInfo, LocalDateTime now, RabbitTemplate rabbitTemplate) {
-        String orderNo = orderGoodsParams.getOrderNo();
+    public void saveGoodsOrder(OrderGoodsParams orderGoodsParams, FeignOrderVO orderInfo,
+            OrderExtractWeightVO orderCanExtractWeight, LocalDateTime now) {
         if (Objects.equals(orderInfo.getStopFlag(), OrderStopEnum.Status.YES.getCode())) {
             throw new ServiceSystemException(ResultEnum.DATA_ERROR, "订单已暂停，无法进行提量");
         }
-        String transportBeginTime = orderInfo.getTransportBeginTime();
-/*        if (!"test".equals(environment.getActiveProfiles()[0])) {
-            for (OrderGoodsChildParams param : orderGoodsParams.getOrderGoodsChildParams()) {
-                String pendingOrderTime = param.getPendingOrderTime();
-                if (DateUtils.parseDateTime(pendingOrderTime).get().isBefore(DateUtils.parseDateTime(transportBeginTime).get())) {
-                    throw new ServiceSystemException(ResultEnum.DATA_ERROR, "挂单时间不能早于拉运开始时间");
-                }
-            }
-        }*/
 
         //多个定向单不允许车辆重复
         List<OrderGoodsChildParams> orderGoodsChildParams = orderGoodsParams.getOrderGoodsChildParams();
@@ -81,30 +68,6 @@ public abstract class GoodsOrderStrategy {
                 throw new ServiceSystemException(ResultEnum.DATA_ERROR, "已被定向单绑定车辆：" + trucks);            }
         }
         //根据不同的订单类型创建不同的货单
-        LocalDateTime sendLazyTime = goodsOrderProcess(orderGoodsParams, orderInfo, now);
-
- /*       Message message = MessageBuilder.withBody(orderNo.getBytes()).build();
-        BigDecimal epochMilli = null;
-        if (sendLazyTime.isAfter(now)) {
-            epochMilli = new BigDecimal(sendLazyTime.minusMinutes(now.getMinute()).getMinute() * 60 * 1000);
-            log.info("执行订单状态更改,选择时间在当前时间之后，则设置延迟队列时间,时间为：{}", epochMilli);
-
-        }
-        if (epochMilli == null) {
-            log.info("执行订单状态更改,epochMilli时间为0,时间为：{}", epochMilli);
-
-            rabbitTemplate.send(
-                    RabbitKeyConstants.ORDER_ON_DEAD_EXCHANGE, RabbitKeyConstants.ORDER_ON_DEAD_ROUTE_KEY, message
-            );
-        } else {
-            log.info("执行订单状态更改,epochMilli时间不为0,时间为：{}", epochMilli);
-            rabbitTemplate.send(RabbitKeyConstants.ORDER_POSTED_EXCHANGE, RabbitKeyConstants.ORDER_POSTED_ROUTE_KEY, MessageBuilder.withBody(orderNo.getBytes()).build());
-
-            message.getMessageProperties().setHeader("x-delay", epochMilli);
-
-            rabbitTemplate.send(
-                    RabbitKeyConstants.ORDER_ON_EXCHANGE, RabbitKeyConstants.ORDER_ON_ROUTE_KEY, message
-            );
-        }*/
+        goodsOrderProcess(orderGoodsParams, orderInfo,orderCanExtractWeight, now);
     }
 }

performance-web/src/main/java/com/clx/performance/strategy/impl/OwnGoodsOrderStrategy.java

@@ -5,9 +5,6 @@ import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONPObject;
 import com.clx.order.enums.OrderEnum;
 import com.clx.order.feign.OrderFeign;
-import com.clx.order.param.feign.UpdateOrderInfoResidueWeightParam;
-import com.clx.performance.param.pc.OrderGoodsChildParams;
-import com.clx.performance.param.pc.OrderGoodsParams;
 import com.clx.order.vo.feign.FeignOrderVO;
 import com.clx.order.vo.feign.OrderOwnTruckVo;
 import com.clx.performance.component.*;
@@ -19,8 +16,11 @@ import com.clx.performance.enums.PendingOrderWayStatusEnum;
 import com.clx.performance.enums.PerformanceResultEnum;
 import com.clx.performance.enums.TruckDemandEnum;
 import com.clx.performance.model.OrderGoods;
+import com.clx.performance.param.pc.OrderGoodsChildParams;
+import com.clx.performance.param.pc.OrderGoodsParams;
 import com.clx.performance.service.ordergoods.OrderGoodsPostService;
 import com.clx.performance.strategy.GoodsOrderStrategy;
+import com.clx.performance.vo.feign.OrderExtractWeightVO;
 import com.msl.common.exception.ServiceSystemException;
 import com.msl.common.utils.DateUtils;
 import com.msl.user.data.UserSessionData;
@@ -73,7 +73,8 @@ public class OwnGoodsOrderStrategy extends GoodsOrderStrategy implements Initial
 
     @Override
     @Transactional(rollbackFor = Exception.class)
-    public LocalDateTime goodsOrderProcess(OrderGoodsParams orderGoodsParams, FeignOrderVO orderInfo, LocalDateTime now) {
+    public LocalDateTime goodsOrderProcess(OrderGoodsParams orderGoodsParams, FeignOrderVO orderInfo,
+            OrderExtractWeightVO orderCanExtractWeight, LocalDateTime now) {
         String orderNo = orderGoodsParams.getOrderNo();
         FeignOrderVO orderInfoFeign = orderFeign.getOrderInfoFeign(orderNo);
         if (!OrderEnum.Status.ON_ORDER.getCode().equals(orderInfoFeign.getOrderStatus())&&
@@ -90,8 +91,7 @@ public class OwnGoodsOrderStrategy extends GoodsOrderStrategy implements Initial
         List<OrderGoodsChildParams> childParamsList = orderGoodsParams.getOrderGoodsChildParams();
         BigDecimal childSum = childParamsList.stream().map(OrderGoodsChildParams::getExtractWeight).reduce(
                 BigDecimal.ZERO, BigDecimal::add);
-        BigDecimal residueWeight = new BigDecimal(orderInfo.getResidueWeight());
-        if (residueWeight.compareTo(childSum) < 0) {
+        if (orderCanExtractWeight.getOwnCanExtractWeight().compareTo(childSum) < 0) {
             throw new ServiceSystemException(PerformanceResultEnum.HTTP_ERROR, "当前货单总吨数已超订单总吨数");
         }
         if (childParamsList.size() > 1) {
@@ -108,7 +108,6 @@ public class OwnGoodsOrderStrategy extends GoodsOrderStrategy implements Initial
             OrderGoods orderGoods = new OrderGoods();
             //提取吨数
             orderGoods.setExtractWeight(child.getExtractWeight());
-            orderGoods.setResidueTransportWeight(child.getExtractWeight());
             orderGoods.setAlreadyTransportWeight(BigDecimal.ZERO);
 
             orderGoods.setLossPrice(orderInfo.getLossPrice());
@@ -216,11 +215,6 @@ public class OwnGoodsOrderStrategy extends GoodsOrderStrategy implements Initial
         // 货单新增后置逻辑
         orderGoodsPostService.orderGoodsAdd(orderGoodsList);
 
-        UpdateOrderInfoResidueWeightParam param = new UpdateOrderInfoResidueWeightParam();
-        param.setOrderId(orderInfo.getId());
-        param.setUpdateType("1");
-        param.setResidueWeight(residueWeight.subtract(childSum));
-        orderFeign.updateOrderInfoResidueWeight(param);
         sendMq(mqMap, now);
         return sendLazyTime;
     }

performance-web/src/main/java/com/clx/performance/strategy/impl/PartGoodsOrderStrategy.java

@@ -4,9 +4,6 @@ import cn.hutool.core.collection.CollectionUtil;
 import com.alibaba.fastjson.JSON;
 import com.clx.order.enums.OrderEnum;
 import com.clx.order.feign.OrderFeign;
-import com.clx.order.param.feign.UpdateOrderInfoResidueWeightParam;
-import com.clx.performance.param.pc.OrderGoodsChildParams;
-import com.clx.performance.param.pc.OrderGoodsParams;
 import com.clx.order.vo.feign.FeignOrderVO;
 import com.clx.performance.component.*;
 import com.clx.performance.constant.RabbitKeyConstants;
@@ -14,8 +11,11 @@ import com.clx.performance.dao.OrderGoodsDao;
 import com.clx.performance.dao.OrderGoodsTruckBindDao;
 import com.clx.performance.enums.*;
 import com.clx.performance.model.OrderGoods;
+import com.clx.performance.param.pc.OrderGoodsChildParams;
+import com.clx.performance.param.pc.OrderGoodsParams;
 import com.clx.performance.service.ordergoods.OrderGoodsPostService;
 import com.clx.performance.strategy.GoodsOrderStrategy;
+import com.clx.performance.vo.feign.OrderExtractWeightVO;
 import com.msl.common.exception.ServiceSystemException;
 import com.msl.common.utils.DateUtils;
 import com.msl.user.data.UserSessionData;
@@ -66,7 +66,8 @@ public class PartGoodsOrderStrategy extends GoodsOrderStrategy implements Initia
 
     @Override
     @Transactional(rollbackFor = Exception.class)
-    public LocalDateTime goodsOrderProcess(OrderGoodsParams orderGoodsParams, FeignOrderVO orderInfo, LocalDateTime now) {
+    public LocalDateTime goodsOrderProcess(OrderGoodsParams orderGoodsParams, FeignOrderVO orderInfo,
+            OrderExtractWeightVO orderCanExtractWeight,LocalDateTime now) {
         String orderNo = orderGoodsParams.getOrderNo();
         FeignOrderVO orderInfoFeign = orderFeign.getOrderInfoFeign(orderNo);
         if (!OrderEnum.Status.ON_ORDER.getCode().equals(orderInfoFeign.getOrderStatus())&&
@@ -84,12 +85,10 @@ public class PartGoodsOrderStrategy extends GoodsOrderStrategy implements Initia
                 BigDecimal.ZERO, BigDecimal::add);
         BigDecimal ownSum = childParamsList.stream().filter(i -> !"1".equals(i.getVehicleUsage())).map(OrderGoodsChildParams::getExtractWeight).reduce(
                 BigDecimal.ZERO, BigDecimal::add);
-        BigDecimal platformCarryWeight = new BigDecimal(orderInfo.getPlatformResidueCarryWeight());
-        if (platformCarryWeight.compareTo(platSum) < 0) {
+        if (orderCanExtractWeight.getPlatCanExtractWeight().compareTo(platSum) < 0) {
             throw new ServiceSystemException(PerformanceResultEnum.HTTP_ERROR, "当前平台承运货单总吨数已超平台承运订单总吨数");
         }
-        BigDecimal ownCarryWeight = new BigDecimal(orderInfo.getOwnResidueCarryWeight());
-        if (ownCarryWeight.compareTo(ownSum) < 0) {
+        if (orderCanExtractWeight.getOwnCanExtractWeight().compareTo(ownSum) < 0) {
             throw new ServiceSystemException(PerformanceResultEnum.HTTP_ERROR, "当前自有承运货单总吨数已超自有承运订单总吨数");
         }
         Map<String, LocalDateTime> mqMap = new HashMap<>();
@@ -111,7 +110,6 @@ public class PartGoodsOrderStrategy extends GoodsOrderStrategy implements Initia
             OrderGoods orderGoods = new OrderGoods();
             //提取吨数
             orderGoods.setExtractWeight(child.getExtractWeight());
-            orderGoods.setResidueTransportWeight(child.getExtractWeight());
             orderGoods.setAlreadyTransportWeight(BigDecimal.ZERO);
 
             orderGoods.setLossPrice(orderInfo.getLossPrice());
@@ -208,39 +206,6 @@ public class PartGoodsOrderStrategy extends GoodsOrderStrategy implements Initia
         // 货单新增后置逻辑
         orderGoodsPostService.orderGoodsAdd(orderGoodsList);
 
-        BigDecimal residueWeight = new BigDecimal(orderInfo.getResidueWeight());
-        if (platSum.compareTo(BigDecimal.ZERO) != 0 && ownSum.compareTo(BigDecimal.ZERO) != 0) {
-            BigDecimal residuePlatSum = new BigDecimal(orderInfo.getPlatformResidueCarryWeight());
-            BigDecimal residueOwnSum = new BigDecimal(orderInfo.getOwnResidueCarryWeight());
-
-            UpdateOrderInfoResidueWeightParam param = new UpdateOrderInfoResidueWeightParam();
-            param.setOrderId(orderInfo.getId());
-            param.setUpdateType("4");
-            param.setResidueWeight(residueWeight.subtract(platSum).subtract(ownSum));
-            param.setOwnWeight(residueOwnSum.subtract(ownSum));
-            param.setPlatWeight(residuePlatSum.subtract(platSum));
-            orderFeign.updateOrderInfoResidueWeight(param);
-        } else if (platSum.compareTo(BigDecimal.ZERO) != 0 && ownSum.compareTo(BigDecimal.ZERO) == 0) {
-            BigDecimal residuePlatSum = new BigDecimal(orderInfo.getPlatformResidueCarryWeight());
-
-            UpdateOrderInfoResidueWeightParam param = new UpdateOrderInfoResidueWeightParam();
-            param.setOrderId(orderInfo.getId());
-            param.setUpdateType("2");
-            param.setResidueWeight(residueWeight.subtract(platSum));
-            param.setPlatWeight(residuePlatSum.subtract(platSum));
-            orderFeign.updateOrderInfoResidueWeight(param);
-        } else if (platSum.compareTo(BigDecimal.ZERO) == 0 && ownSum.compareTo(BigDecimal.ZERO) != 0) {
-            BigDecimal residueOwnSum = new BigDecimal(orderInfo.getOwnResidueCarryWeight());
-
-            UpdateOrderInfoResidueWeightParam param = new UpdateOrderInfoResidueWeightParam();
-            param.setOrderId(orderInfo.getId());
-            param.setUpdateType("3");
-            param.setResidueWeight(residueWeight.subtract(ownSum));
-            param.setOwnWeight(residueOwnSum.subtract(ownSum));
-            orderFeign.updateOrderInfoResidueWeight(param);
-        }
-
-
         sendMq(mqMap, now);
         return sendLazyTime;
     }

performance-web/src/main/java/com/clx/performance/strategy/impl/PlatformGoodsOrderStrategy.java

@@ -4,9 +4,6 @@ import cn.hutool.core.collection.CollectionUtil;
 import com.alibaba.fastjson.JSON;
 import com.clx.order.enums.OrderEnum;
 import com.clx.order.feign.OrderFeign;
-import com.clx.order.param.feign.UpdateOrderInfoResidueWeightParam;
-import com.clx.performance.param.pc.OrderGoodsChildParams;
-import com.clx.performance.param.pc.OrderGoodsParams;
 import com.clx.order.vo.feign.FeignOrderVO;
 import com.clx.performance.component.*;
 import com.clx.performance.constant.RabbitKeyConstants;
@@ -14,8 +11,11 @@ import com.clx.performance.dao.OrderGoodsDao;
 import com.clx.performance.dao.OrderGoodsTruckBindDao;
 import com.clx.performance.enums.*;
 import com.clx.performance.model.OrderGoods;
+import com.clx.performance.param.pc.OrderGoodsChildParams;
+import com.clx.performance.param.pc.OrderGoodsParams;
 import com.clx.performance.service.ordergoods.OrderGoodsPostService;
 import com.clx.performance.strategy.GoodsOrderStrategy;
+import com.clx.performance.vo.feign.OrderExtractWeightVO;
 import com.msl.common.exception.ServiceSystemException;
 import com.msl.common.utils.DateUtils;
 import com.msl.user.data.UserSessionData;
@@ -68,7 +68,8 @@ public class PlatformGoodsOrderStrategy extends GoodsOrderStrategy implements In
 
     @Override
     @Transactional(rollbackFor = Exception.class)
-    public LocalDateTime goodsOrderProcess(OrderGoodsParams orderGoodsParams, FeignOrderVO orderInfo, LocalDateTime now) {
+    public LocalDateTime goodsOrderProcess(OrderGoodsParams orderGoodsParams, FeignOrderVO orderInfo,
+            OrderExtractWeightVO orderCanExtractWeight, LocalDateTime now) {
         String orderNo = orderGoodsParams.getOrderNo();
         FeignOrderVO orderInfoFeign = orderFeign.getOrderInfoFeign(orderNo);
         if (!OrderEnum.Status.ON_ORDER.getCode().equals(orderInfoFeign.getOrderStatus())&&
@@ -85,8 +86,7 @@ public class PlatformGoodsOrderStrategy extends GoodsOrderStrategy implements In
         List<OrderGoodsChildParams> childParamsList = orderGoodsParams.getOrderGoodsChildParams();
         BigDecimal childSum = childParamsList.stream().map(OrderGoodsChildParams::getExtractWeight).reduce(
                 BigDecimal.ZERO, BigDecimal::add);
-        BigDecimal residueWeight = new BigDecimal(orderInfo.getResidueWeight());
-        if (residueWeight.compareTo(childSum) < 0) {
+        if (orderCanExtractWeight.getPlatCanExtractWeight().compareTo(childSum) < 0) {
             throw new ServiceSystemException(PerformanceResultEnum.HTTP_ERROR, "当前货单总吨数已超订单总吨数");
         }
         long beginOrderGoodsId = orderGoodsIdGenerate.getOrderGoodsId(childParamsList.size());
@@ -108,7 +108,6 @@ public class PlatformGoodsOrderStrategy extends GoodsOrderStrategy implements In
             OrderGoods orderGoods = new OrderGoods();
             //提取吨数
             orderGoods.setExtractWeight(child.getExtractWeight());
-            orderGoods.setResidueTransportWeight(child.getExtractWeight());
             orderGoods.setAlreadyTransportWeight(BigDecimal.ZERO);
             orderGoods.setLossPrice(orderInfo.getLossPrice());
             orderGoods.setTruckDemand(TruckDemandEnum.TruckType.PLATFORM_CAR.getCode());
@@ -201,12 +200,6 @@ public class PlatformGoodsOrderStrategy extends GoodsOrderStrategy implements In
         // 货单新增后置逻辑
         orderGoodsPostService.orderGoodsAdd(orderGoodsList);
 
-        UpdateOrderInfoResidueWeightParam param = new UpdateOrderInfoResidueWeightParam();
-        param.setOrderId(orderInfo.getId());
-        param.setUpdateType("1");
-        param.setResidueWeight(residueWeight.subtract(childSum));
-        orderFeign.updateOrderInfoResidueWeight(param);
-
         sendMq(mqMap, now);
         return sendLazyTime;
     }