添加最后一车的逻辑

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

@@ -125,4 +125,5 @@ public interface OrderChildDao extends BaseDao<OrderChildMapper, OrderChild, Int
      */
     List<OrderChild> selectInTransitOrderChildByOrderGoodsNo(String orderGoodsNo);
 
+    OrderChild findLastTruckChild(String orderNo);
 }

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

@@ -85,4 +85,6 @@ public interface OrderGoodsDao extends BaseDao<OrderGoodsMapper, OrderGoods, Int
     List<OrderGoods> getOrderGoodsListByOrderNoAndStatus(String orderNo);
 
     List<OrderGoodsAPPVO> getCancelOrderGoods(List<OrderGoodsTruckBind> list);
+
+    BigDecimal getAlreadyTransportWeight(String orderNo);
 }

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

@@ -381,4 +381,12 @@ public class OrderChildDaoImpl extends BaseDaoImpl<OrderChildMapper, OrderChild,
         return baseMapper.selectList(lQrWrapper().eq(OrderChild::getOrderGoodsNo, orderGoodsNo)
                 .lt(OrderChild::getStatus, OrderChildEnum.Status.UNLOAD.getCode())
         );    }
+
+    @Override
+    public OrderChild findLastTruckChild(String orderNo) {
+        return getOne(lQrWrapper().eq(OrderChild::getOrderNo,orderNo)
+                .notIn(OrderChild::getStatus,OrderChildEnum.DTS_LISTEN_CANCEL_lIST)
+                .orderByDesc(OrderChild::getCreateTime)
+                .last("limit 1"));
+    }
 }

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

@@ -228,5 +228,8 @@ public class OrderGoodsDaoImpl extends BaseDaoImpl<OrderGoodsMapper, OrderGoods,
         return baseMapper.getCancelOrderGoods(param);
     }
 
-
+    @Override
+    public BigDecimal getAlreadyTransportWeight(String orderNo) {
+        return baseMapper.getAlreadyTransportWeight(orderNo);
+    }
 }

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

@@ -82,4 +82,6 @@ public interface OrderGoodsMapper extends BaseMapper<OrderGoods> {
 
     @SelectProvider(type = OrderGoodsSqlProvider.class, method = "getCancelOrderGoods")
     List<OrderGoodsAPPVO> getCancelOrderGoods(@Param(value = "param") List<OrderGoodsTruckBind> param);
+    @SelectProvider(type = OrderGoodsSqlProvider.class, method = "getAlreadyTransportWeight")
+    BigDecimal getAlreadyTransportWeight(@Param("orderNo") String orderNo);
 }

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

+package com.clx.performance.service;
+
+import com.clx.performance.model.OrderChild;
+
+public interface LastTruckService {
+
+    OrderChild getLastTruckChild(String orderNo);
+}

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

+package com.clx.performance.service.impl;
+
+import com.clx.order.enums.OrderEnum;
+import com.clx.order.feign.OrderFeign;
+import com.clx.order.vo.feign.FeignOrderVO;
+import com.clx.performance.dao.OrderChildDao;
+import com.clx.performance.dao.OrderGoodsDao;
+import com.clx.performance.enums.PerformanceResultEnum;
+import com.clx.performance.model.OrderChild;
+import com.clx.performance.service.LastTruckService;
+import com.clx.user.enums.SyncPlatformEnum;
+import com.msl.common.exception.ServiceSystemException;
+import groovy.util.logging.Slf4j;
+import lombok.AllArgsConstructor;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.stereotype.Service;
+
+import java.math.BigDecimal;
+import java.util.Objects;
+
+/**
+ * @ClassName LastTruckServiceImpl
+ * @Description
+ * @Author kavin
+ * @Date 2023/11/9 13:13
+ * @Version 1.0
+ */
+@Service
+@Slf4j
+@AllArgsConstructor
+public class LastTruckServiceImpl implements LastTruckService {
+
+    private final OrderFeign orderFeign;
+    private final OrderChildDao orderChildDao;
+    private final OrderGoodsDao orderGoodsDao;
+    /**
+     * @Author kavin
+     * @Description 判断最后一车的逻辑
+     * @Param [orderNo]
+     * @return
+     **/
+    @Override
+    public OrderChild getLastTruckChild(String orderNo) {
+        //判断订单是否已经完结
+        FeignOrderVO orderInfo = orderFeign.getOrderInfoFeign(orderNo);
+        if(Objects.isNull(orderInfo)){
+            return null;
+        }
+        if(!Objects.equals(orderInfo.getOrderSource(), SyncPlatformEnum.TRADE_PLATFORM.getCode())){
+           return null;
+        }
+        //已完结直接按照时间顺序查找最后一个运单
+        if(Objects.equals(orderInfo.getOrderStatus(), OrderEnum.Status.COMPLETED.getCode()) ||
+                Objects.equals(orderInfo.getOrderStatus(), OrderEnum.Status.SUCCESS.getCode())
+        ){
+            return orderChildDao.findLastTruckChild(orderNo);
+        }else{   //未完结，判断所有货单的已拉运的吨数是否等于 订单的拉运吨数-向下浮动量
+            BigDecimal alreadyTransprotWeight = orderGoodsDao.getAlreadyTransportWeight(orderNo);
+            //查询所有货单的已拉运吨数 + 向下浮动量 >= 订单的承运吨数 (满足此情况查找最后一单)
+            if(Objects.nonNull(alreadyTransprotWeight) &&
+                    alreadyTransprotWeight.add(new BigDecimal(orderInfo.getDownFloatWeight())).compareTo(orderInfo.getTransportWeight()) >= 0){
+                return orderChildDao.findLastTruckChild(orderNo);
+            }
+        }
+        return null;
+    }
+}

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

@@ -277,4 +277,13 @@ public class OrderGoodsSqlProvider {
     }
 
 
+    public String getAlreadyTransportWeight(String orderNo){
+        String sql = new SQL() {{
+            SELECT("sum(already_transport_weight)");
+            FROM("order_goods ");
+            WHERE("order_no = #{orderNo}");
+        }}.toString();
+        return sql;
+    }
+
 }