司机端无接单位置上报

performance-web/src/main/java/com/clx/performance/controller/app/AppGoodsOrderController.java

@@ -2,8 +2,10 @@ package com.clx.performance.controller.app;
 
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.clx.performance.mapper.OrderGoodsMapper;
+import com.clx.performance.model.OrderGoods;
 import com.clx.performance.param.app.OrderGoodsListPageParam;
 import com.clx.performance.service.OrderGoodsService;
+import com.clx.performance.service.OrderGoodsTruckBindService;
 import com.clx.performance.vo.app.OrderGoodsAPPVO;
 import com.clx.performance.vo.pc.OrderGoodsVO;
 import com.msl.common.base.PageData;
@@ -16,6 +18,8 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
 
+import java.util.List;
+
 /**
  * @ClassName GoodsOrderController
  * @Description
@@ -37,6 +41,9 @@ public class AppGoodsOrderController {
     @Autowired
     OrderGoodsMapper orderGoodsMapper;
 
+    @Autowired
+    OrderGoodsTruckBindService orderGoodsTruckBindService;
+
 
     @ApiOperation(value = "查看货单详情", notes = "<br>By:胡宇帆")
     @GetMapping("/getOrderGoodsInfo")
@@ -55,10 +62,9 @@ public class AppGoodsOrderController {
 
     }
 
-//    @ApiOperation(value = "专属货单", notes = "<br>By:胡宇帆")
-//    @PostMapping("/exclusiveOrderGoodsList")
-//    @UnitCovert(param = false)
-//    public Result<List<OrderGoodsVO>> exclusiveOrderGoodsList(@Validated @RequestBody OrderGoodsListParam orderGoodsListParam) {
-//        return Result.ok(orderGoodsService.openOrderPageGoodsList(orderGoodsListParam));
-//    }
+    @ApiOperation(value = "司机端无接单位置上报", notes = "<br>By:胡宇帆")
+    @GetMapping("/getCancelOrderGoods")
+    public Result<List<OrderGoods>> getCancelOrderGoods(@RequestParam(value = "userNo") Long userNo) {
+        return Result.ok(orderGoodsTruckBindService.getCancelOrderGoods(userNo));
+    }
 }

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

@@ -196,15 +196,5 @@ public class GoodsOrderController {
         return Result.ok();
     }
 
-    @ApiOperation(value = "司机端无接单位置上报", notes = "<br>By:胡宇帆")
-    @GetMapping("/getCancelOrderGoods")
-    public Result<List<OrderGoods>> getCancelOrderGoods(@RequestParam(value = "truckNo") String truckNo) {
-        LocalDateTime now = LocalDateTime.now();
-        return Result.ok(orderGoodsTruckBindService.getCancelOrderGoods(truckNo,
-                DateUtils.formatDateTime(now.plusDays(-3), "yyyy-MM-dd HH:mm:ss").get(),
-                DateUtils.formatDateTime(now, "yyyy-MM-dd HH:mm:ss").get()
-                )
-        );
-    }
 
 }

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

@@ -38,6 +38,8 @@ 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);
+
     IPage<OrderGoodsAPPVO> openOrderPageGoodsList(OrderGoodsListPageParam orderGoodsListPageParam);
 
     IPage<OrderGoodsAPPVO> exclusiveOrderPageGoodsList(OrderGoodsListPageParam orderGoodsListPageParam, List<String> orderGoodsNoList);

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

@@ -48,7 +48,7 @@ public interface OrderGoodsTruckBindDao extends BaseDao<OrderGoodsTruckBindMappe
 
     List<OrderGoodsTruckBind> selectCancelRecord(String orderGoodsNo, List<String> truckList);
 
-    List<OrderGoodsTruckBind> getCancelOrderGoods(String truckNo, String beginTime, String endTime);
+    List<OrderGoodsTruckBind> getCancelOrderGoods(List<String> truckList, String beginTime, String endTime);
 
     void deleteByOrderGoods(String orderGoodsNo);
 }

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

@@ -78,6 +78,11 @@ public class OrderGoodsDaoImpl extends BaseDaoImpl<OrderGoodsMapper, OrderGoods,
         baseMapper.updateOrderGoodsWeightAndStatus(id, orderChildWeight, orderGoodsStatus);
     }
 
+    @Override
+    public void updateOrderGoodsWeightResidueAndAlreadyAndStatus(Integer id, BigDecimal alreadyTransportWeight,BigDecimal residueTransportWeight,Integer orderGoodsStatus) {
+        baseMapper.updateOrderGoodsWeightResidueAndAlreadyAndStatus(id, alreadyTransportWeight, residueTransportWeight, orderGoodsStatus);
+    }
+
     @Override
     public IPage<OrderGoodsAPPVO> openOrderPageGoodsList(OrderGoodsListPageParam param) {
         Page<OrderGoodsAPPVO> page = Page.of(param.getPage(), param.getPageSize());

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

@@ -157,8 +157,8 @@ public class OrderGoodsTruckBindDaoImpl extends BaseDaoImpl<OrderGoodsTruckBindM
     }
 
     @Override
-    public List<OrderGoodsTruckBind> getCancelOrderGoods(String truckNo, String beginTime, String endTime) {
-        return baseMapper.selectList(lQrWrapper().eq(OrderGoodsTruckBind::getTruckNo, truckNo)
+    public List<OrderGoodsTruckBind> getCancelOrderGoods(List<String> truckList, String beginTime, String endTime) {
+        return baseMapper.selectList(lQrWrapper().in(OrderGoodsTruckBind::getTruckNo, truckList)
                         .eq(OrderGoodsTruckBind::getStatus, OrderGoodsTruckBindEnum.Status.CANCEL.getCode())
                 .le(OrderGoodsTruckBind::getCreateTime, endTime)
                 .ge(OrderGoodsTruckBind::getCreateTime, beginTime)

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

@@ -42,6 +42,14 @@ public interface OrderGoodsMapper extends BaseMapper<OrderGoods> {
             " 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}," +
+            "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);
+
+
     @SelectProvider(type = OrderGoodsSqlProvider.class, method = "openOrderPageGoodsList")
     IPage<OrderGoodsAPPVO> openOrderPageGoodsList(Page<OrderGoodsAPPVO> page);
 

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

@@ -8,5 +8,5 @@ public interface OrderGoodsTruckBindService {
 
     List<Integer> getTrucksByOrderGoodsNo(String orderGoodsNo);
 
-    List<OrderGoods> getCancelOrderGoods(String truckNo, String beginTime, String endTime);
+    List<OrderGoods> getCancelOrderGoods(Long userNo);
 }

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

@@ -288,10 +288,19 @@ public class OrderChildServiceImpl implements OrderChildService {
         orderChild.setTruckModel(driverTruckInfo.getModel());
 
         Integer overWeight = orderInfo.getOverWeight();
+
         if(Objects.equals(overWeight,OrderGoodsOverWeightEnum.NO.getCode())){
-            orderChild.setWeight(new BigDecimal(33));
-        }else{
-            orderChild.setWeight(new BigDecimal(50));
+            if (orderGoods.getResidueTransportWeight().compareTo(new BigDecimal(33)) < 0) {
+                orderChild.setWeight(orderGoods.getResidueTransportWeight());
+            } else {
+                orderChild.setWeight(new BigDecimal(33));
+            }
+        } else{
+            if (orderGoods.getResidueTransportWeight().compareTo(new BigDecimal(50)) < 0) {
+                orderChild.setWeight(orderGoods.getResidueTransportWeight());
+            } else {
+                orderChild.setWeight(new BigDecimal(50));
+            }
         }
         //orderChild.setWeight(orderChild.getTruckLoad());
         orderChild.setFreight(orderChildFreightCalc(orderChild));

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

@@ -132,6 +132,7 @@ public class OrderGoodsServiceImpl implements OrderGoodsService {
             //当前订单已经取消或完结
 
         } else {
+
             orderGoodsDao.updateOrderGoodsReduceWeightAndStatus(orderGoods.getId(), orderChildWeight, orderGoodsStatus);
 
         }
@@ -458,7 +459,7 @@ public class OrderGoodsServiceImpl implements OrderGoodsService {
         Integer orderGoodsStatus = OrderGoodsStatusEnum.Status.CANCEL.getCode();
         switch (cancelOperateType) {
             case 1:
-                orderChildList = orderChildDao.selectResidueWeightByOrderGoodsNo(orderGoods.getOrderGoodsNo(), null);
+                orderChildList = orderChildDao.selectResidueWeightByOrderGoodsNo(orderGoods.getOrderGoodsNo(), OrderChildEnum.Status.DRIVER_CANCEL.getCode());
                 if (CollectionUtils.isNotEmpty(orderChildList)) {
                     throw new ServiceSystemException(PerformanceResultEnum.HTTP_ERROR, "当前货单已产生运单");
                 }

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

@@ -3,14 +3,21 @@ package com.clx.performance.service.impl;
 import cn.hutool.core.collection.CollectionUtil;
 import com.clx.performance.dao.OrderGoodsDao;
 import com.clx.performance.dao.OrderGoodsTruckBindDao;
+import com.clx.performance.enums.PerformanceResultEnum;
 import com.clx.performance.model.OrderGoods;
 import com.clx.performance.model.OrderGoodsTruckBind;
 import com.clx.performance.service.OrderGoodsTruckBindService;
+import com.clx.user.feign.TruckFeign;
+import com.clx.user.vo.app.driver.truck.DriverTruckAppVo;
+import com.msl.common.exception.ServiceSystemException;
+import com.msl.common.result.Result;
+import com.msl.common.utils.DateUtils;
 import lombok.AllArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import java.time.LocalDateTime;
 import java.util.List;
 import java.util.stream.Collectors;
 
@@ -24,6 +31,7 @@ public class OrderGoodsTruckBindServiceImpl implements OrderGoodsTruckBindServic
 
     private final OrderGoodsDao orderGoodsDao;
 
+    private final TruckFeign truckFeign;
 
     @Override
     public List<Integer> getTrucksByOrderGoodsNo(String orderGoodsNo) {
@@ -31,8 +39,18 @@ public class OrderGoodsTruckBindServiceImpl implements OrderGoodsTruckBindServic
     }
 
     @Override
-    public List<OrderGoods> getCancelOrderGoods(String truckNo, String beginTime, String endTime) {
-        List<OrderGoodsTruckBind> list = orderGoodsTruckBindDao.getCancelOrderGoods(truckNo, beginTime, endTime);
+    public List<OrderGoods> getCancelOrderGoods(Long userNo) {
+        Result<List<DriverTruckAppVo>> result = truckFeign.driverTruckList(userNo);
+        if (!result.succeed() || CollectionUtil.isEmpty(result.getData())) {
+            throw new ServiceSystemException(PerformanceResultEnum.DATA_NOT_FIND);
+        }
+        List<String> truckList = result.getData().stream().map(DriverTruckAppVo::getTruckNo).collect(Collectors.toList());
+
+        LocalDateTime now = LocalDateTime.now();
+
+        List<OrderGoodsTruckBind> list = orderGoodsTruckBindDao.getCancelOrderGoods(truckList,
+                DateUtils.formatDateTime(now.plusDays(-3), "yyyy-MM-dd HH:mm:ss").get(),
+                DateUtils.formatDateTime(now, "yyyy-MM-dd HH:mm:ss").get());
         if (CollectionUtil.isEmpty(list)) {
             return null;
         }