托运订单/承运订单-获取车辆运单-统计

采购订单-托运订单列表-下方数据统计-贸易订单id

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

@@ -93,6 +93,15 @@ public enum CarWaybillEnum {
         return null;
     }
 
+    public static String getWaybillOrderDestination(String status) {
+        for (CarWaybillEnum waybillEnum : CarWaybillEnum.values()) {
+            if (waybillEnum.getStatus().equals(status)) {
+                return waybillEnum.getDestination();
+            }
+        }
+        return null;
+    }
+
     public static String getName(Integer code) {
         for (CarWaybillEnum waybillEnum : CarWaybillEnum.values()) {
             if (waybillEnum.getCode().equals(code)) {

sckw-modules/sckw-report/src/main/java/com/sckw/report/service/KwTransportService.java

@@ -442,7 +442,7 @@ public class KwTransportService {
             Long settlementCycle1 = logisticsOrder.getSettlementCycle();
             String billingMode = logisticsOrder.getBillingMode();
             SysDictResDto sysDictResDto = chargingType.get(String.valueOf(settlementCycle1));
-            SysDictResDto sysDictResDto1 = settlementCycle.get(String.valueOf(billingMode));
+            SysDictResDto sysDictResDto1 = settlementCycle.get(billingMode);
             if (Objects.nonNull(sysDictResDto)) {
                 logisticsOrder.setSettlementCycleLabel(sysDictResDto.getLabel());
             }

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

@@ -46,6 +46,23 @@ public class ConsignOrderController {
         }
     }
 
+    /**
+     * 托运订单/承运订单-获取车辆运单-统计
+     *
+     * @param orderDto
+     * @return
+     */
+    @RequestMapping(value = "/getCarWaybillByOrderCount", method = RequestMethod.POST)
+    public HttpResult getCarWaybillByOrderCount(@Validated @RequestBody OrderDTO orderDto) {
+        try {
+            return consignOrderService.getCarWaybillByOrderCount(orderDto);
+        } catch (Exception e) {
+            log.error("托运订单获取车辆运单失败:订单id {},error {} ", orderDto.getId(), e.getMessage(), e);
+            return HttpResult.error(HttpStatus.GLOBAL_EXCEPTION_CODE, e.getMessage());
+        }
+    }
+
+
     /**
      * 托运订单查看驳回原因
      *
@@ -66,7 +83,7 @@ public class ConsignOrderController {
     @RequestMapping(value = "/getCarListByOrder", method = RequestMethod.POST)
     public HttpResult getCarListByOrder(@Validated @RequestBody OrderDTO orderDto) {
         try {
-            return consignOrderService.getCarListByOrder(orderDto);
+            return consignOrderService.getCarListByOrder(orderDto,"1");
         } catch (Exception e) {
             log.error("托运订单获取车辆运单失败:订单id {},error {} ", orderDto.getId(), e.getMessage(), e);
             return HttpResult.error(HttpStatus.GLOBAL_EXCEPTION_CODE, e.getMessage());

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

@@ -57,14 +57,31 @@ public class LogisticsConsignmentController {
      * @param id 销售订单id
      * @return
      */
-    @Validated
     @RequestMapping(value = "/purchaseLogisticsOrder", method = RequestMethod.GET)
     public HttpResult purchaseLogisticsOrder(@RequestParam("id") @NotBlank(message = "单据id不能为空") String id,
-                                             @RequestParam("page") @NotBlank(message = "当前页不能为空") int page,
-                                             @RequestParam("pageSize") @NotBlank(message = "每页条数不能为空") int pageSize) {
+                                             @RequestParam("page") @NotNull(message = "当前页不能为空") int page,
+                                             @RequestParam("pageSize") @NotNull(message = "每页条数不能为空") int pageSize) {
+        log.info("采购订单-托运订单列表 传递参数信息:{}", id);
+        try {
+            return logisticsConsignmentService.logisticsOrder(id, page, pageSize, "1");
+        } catch (Exception e) {
+            log.error("采购订单-托运订单列表 error :{}", e.getMessage(), e);
+            return HttpResult.error(HttpStatus.GLOBAL_EXCEPTION_CODE, e.getMessage());
+        }
+    }
+
+    /**
+     * 采购订单-托运订单列表-下方数据统计-贸易订单id
+     *
+     * @param id 贸易订单id
+     * @return
+     */
+    @Validated
+    @RequestMapping(value = "/purchaseLogisticsOrderCount", method = RequestMethod.GET)
+    public HttpResult purchaseLogisticsOrderCount(@RequestParam("id") @NotBlank(message = "单据id不能为空") String id) {
         log.info("采购订单-托运订单列表 传递参数信息:{}", id);
         try {
-            return logisticsConsignmentService.logisticsOrder(id, page, pageSize);
+            return logisticsConsignmentService.logisticsOrderCount(id,"1");
         } catch (Exception e) {
             log.error("采购订单-托运订单列表 error :{}", e.getMessage(), e);
             return HttpResult.error(HttpStatus.GLOBAL_EXCEPTION_CODE, e.getMessage());
@@ -103,18 +120,19 @@ public class LogisticsConsignmentController {
     public HttpResult purchaseLogisticsCar(@RequestParam("id") @NotBlank(message = "单据id不能为空") String id,
                                            @RequestParam("page") @NotBlank(message = "当前页不能为空") int page,
                                            @RequestParam("pageSize") @NotBlank(message = "每页条数不能为空") int pageSize) {
-        log.info("采购订单-托运订单列表 传递参数信息:{}", id);
+        log.info("采购订单-车辆详情 传递参数信息:{}", id);
         try {
             return logisticsConsignmentService.purchaseLogisticsCar(id, page, pageSize);
         } catch (Exception e) {
-            log.error("采购订单-托运订单列表 error :{}", e.getMessage(), e);
+            log.error("采购订单-车辆详情 error :{}", e.getMessage(), e);
             return HttpResult.error(HttpStatus.GLOBAL_EXCEPTION_CODE, e.getMessage());
         }
     }
 
     /**
      * 采购订单-托运订单列表-订单完结-数据查询
-     * @param orderId   物流订单id
+     *
+     * @param orderId 物流订单id
      * @return
      */
     @Validated
@@ -131,6 +149,7 @@ public class LogisticsConsignmentController {
 
     /**
      * 采购订单-托运订单列表-完结订单
+     *
      * @param OrderFinishDTO
      * @return
      */
@@ -176,13 +195,30 @@ public class LogisticsConsignmentController {
                                          @RequestParam("pageSize") @NotBlank(message = "每页条数不能为空") int pageSize) {
         log.info("销售订单-托运订单列表 传递参数信息:{}", id);
         try {
-            return logisticsConsignmentService.logisticsOrder(id, page, pageSize);
+            return logisticsConsignmentService.logisticsOrder(id, page, pageSize, "2");
         } catch (Exception e) {
             log.error("销售订单-托运订单列表 error :{}", e.getMessage(), e);
             return HttpResult.error(HttpStatus.GLOBAL_EXCEPTION_CODE, e.getMessage());
         }
     }
 
+    /**
+     * 销售订单-托运订单列表-下方数据统计-贸易订单id
+     *
+     * @param id 贸易订单id
+     * @return
+     */
+    @Validated
+    @RequestMapping(value = "/sellLogisticsOrderCount", method = RequestMethod.GET)
+    public HttpResult sellLogisticsOrderCount(@RequestParam("id") @NotBlank(message = "单据id不能为空") String id) {
+        log.info("销售订单-托运订单列表 传递参数信息:{}", id);
+        try {
+            return logisticsConsignmentService.logisticsOrderCount(id,"2");
+        } catch (Exception e) {
+            log.error("销售订单-托运订单列表 error :{}", e.getMessage(), e);
+            return HttpResult.error(HttpStatus.GLOBAL_EXCEPTION_CODE, e.getMessage());
+        }
+    }
     /**
      * 销售订单-车辆列表-销售订单id
      *
@@ -222,7 +258,8 @@ public class LogisticsConsignmentController {
 
     /**
      * 销售订单-托运订单列表-订单完结-数据查询
-     * @param orderId   物流订单id
+     *
+     * @param orderId 物流订单id
      * @return
      */
     @Validated
@@ -239,6 +276,7 @@ public class LogisticsConsignmentController {
 
     /**
      * 销售订单-托运订单列表-完结订单
+     *
      * @param orderFinishDTO
      * @return
      */

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

@@ -9,7 +9,6 @@ import com.sckw.transport.model.param.LogisticsOrderParam;
 import com.sckw.transport.model.vo.DriverListVo;
 import com.sckw.transport.model.vo.OrderFinishVO;
 import com.sckw.transport.model.vo.SubcontractConsignmentVO;
-import com.sckw.transport.model.vo.WaybillCountVo;
 import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
 
@@ -52,14 +51,23 @@ public interface KwtLogisticsOrderMapper extends BaseMapper<KwtLogisticsOrder> {
      * @param id
      * @return
      */
-    List<com.sckw.transport.model.dto.LogisticsOrderDTO> selectOrderList(@Param("id") String id,@Param("page") int page,@Param("pageSize") int pageSize);
+    List<com.sckw.transport.model.dto.LogisticsOrderDTO> selectOrderList(@Param("id") String id, @Param("page") int page,
+                                                                         @Param("pageSize") int pageSize,@Param("type") String type);
 
     /**
+     * 销售订单-采购订单-托运列表-数据统计
      *
      * @param id
      * @return
      */
-    Long selectOrderCount(@Param("id") String id);
+    List<com.sckw.transport.model.dto.LogisticsOrderDTO> selectOrderCountByTorderId(@Param("id") String id, @Param("type") String type);
+
+    /**
+     * @param id   贸易订单id
+     * @param type 采购单1/销售单2
+     * @return
+     */
+    Long selectOrderCount(@Param("id") String id, @Param("type") String type);
 
     /**
      * @param logisticsOrderParam
@@ -68,10 +76,11 @@ public interface KwtLogisticsOrderMapper extends BaseMapper<KwtLogisticsOrder> {
      */
     Long selectLogisticOrderCount(@Param("logisticsOrderParam") LogisticsOrderParam logisticsOrderParam, @Param("dictId") Long dictId);
 
-    Map<String, String> getRejectReason(@Param("id") String id,@Param("status") String status);
+    Map<String, String> getRejectReason(@Param("id") String id, @Param("status") String status);
 
     /**
      * 根据承运订单id查看分包数据列表
+     *
      * @param lOrderId
      * @param page
      * @param pageSize
@@ -83,13 +92,13 @@ public interface KwtLogisticsOrderMapper extends BaseMapper<KwtLogisticsOrder> {
 
     /**
      * 通过物流订单查看单据下运力司机数据
+     *
      * @param driverParam
      * @return
      */
     List<DriverListVo> selectDriverListById(@Param("driverParam") DriverParam driverParam);
 
     /**
-     *
      * @param ids
      * @return
      */
@@ -97,6 +106,7 @@ public interface KwtLogisticsOrderMapper extends BaseMapper<KwtLogisticsOrder> {
 
     /**
      * 通过物流订单id获取统计数据
+     *
      * @param orderId
      * @return
      */

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

@@ -16,6 +16,11 @@ public class SubcontractConsignmentVO {
      * 状态
      */
     private String status;
+
+    /**
+     * 状态
+     */
+    private String statusLabel;
     /**
      * 数据库表主键id
      */

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

@@ -641,6 +641,7 @@ public class AcceptCarriageOrderService {
         Map<String, String> settlementDictData = getDictData(DictTypeEnum.SETTLEMENT_CYCLE.getType());
         if (CollectionUtils.isNotEmpty(list)) {
             for (SubcontractConsignmentVO subcontractConsignmentVO : list) {
+                subcontractConsignmentVO.setStatusLabel(CarWaybillEnum.getWaybillOrderDestination(subcontractConsignmentVO.getStatus()));
                 subcontractConsignmentVO.setPriceType(priceDictData == null ? null : priceDictData.get(subcontractConsignmentVO.getPriceType()));
                 subcontractConsignmentVO.setLossUnit(weightDictData == null ? null : weightDictData.get(subcontractConsignmentVO.getLossUnit()));
                 subcontractConsignmentVO.setGoodsPriceUnit(priceDictData == null ? null : priceDictData.get(subcontractConsignmentVO.getGoodsPriceUnit()));

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

@@ -18,7 +18,6 @@ import com.sckw.core.web.context.LoginUserHolder;
 import com.sckw.core.web.response.HttpResult;
 import com.sckw.excel.utils.DateUtil;
 import com.sckw.fleet.api.RemoteFleetService;
-import com.sckw.fleet.api.model.vo.RTruckVo;
 import com.sckw.mongo.enums.BusinessTypeEnum;
 import com.sckw.mongo.model.SckwLogisticsOrder;
 import com.sckw.product.api.dubbo.GoodsInfoService;
@@ -44,8 +43,10 @@ import org.springframework.util.ObjectUtils;
 
 import java.math.BigDecimal;
 import java.text.ParseException;
-import java.util.*;
-import java.util.stream.Collectors;
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
+import java.util.Map;
 
 /**
  * @author lfdc
@@ -113,9 +114,9 @@ public class ConsignOrderService {
     public HttpResult getCarWaybillByOrder(OrderDTO orderDto) {
         HttpResult httpResult = new HttpResult();
         if (String.valueOf(NumberConstant.ONE).equals(orderDto.getType())) {
-            httpResult = getCarWaybillByOrderByConsign(orderDto);
+            httpResult = getCarWaybillOrderByConsign(orderDto);
         } else if (String.valueOf(NumberConstant.TWO).equals(orderDto.getType())) {
-            httpResult = getCarWaybillByOrderByAcceptCarriage(orderDto);
+            httpResult = getCarWaybillOrderByAcceptCarriage(orderDto);
         } else {
             throw new RuntimeException("单据类型错误");
         }
@@ -131,9 +132,9 @@ public class ConsignOrderService {
     public HttpResult getCarWaybillByOrderCount(OrderDTO orderDto) {
         HttpResult httpResult = new HttpResult();
         if (String.valueOf(NumberConstant.ONE).equals(orderDto.getType())) {
-            httpResult = getCarWaybillByOrderByConsignCount(orderDto);
+            httpResult = getCarWaybillOrderByConsignCount(orderDto);
         } else if (String.valueOf(NumberConstant.TWO).equals(orderDto.getType())) {
-            httpResult = getCarWaybillByOrderByAcceptCarriageCount(orderDto);
+            httpResult = getCarWaybillOrderByAcceptCarriageCount(orderDto);
         } else {
             throw new RuntimeException("单据类型错误");
         }
@@ -146,7 +147,7 @@ public class ConsignOrderService {
      * @param orderDto
      * @return
      */
-    private HttpResult getCarWaybillByOrderByConsignCount(OrderDTO orderDto) {
+    private HttpResult getCarWaybillOrderByConsignCount(OrderDTO orderDto) {
         KwtLogisticsOrder order = kwtLogisticsOrderMapper.selectOne(new LambdaQueryWrapper<KwtLogisticsOrder>()
                         .eq(StringUtils.isNotBlank(orderDto.getId()), KwtLogisticsOrder::getId, Long.parseLong(orderDto.getId()))
                         .eq(StringUtils.isNotBlank(orderDto.getOrderNo()), KwtLogisticsOrder::getLOrderNo, orderDto.getOrderNo())
@@ -161,31 +162,30 @@ public class ConsignOrderService {
         //合理损耗
         BigDecimal loss = order.getLoss();
         //派车量
-        BigDecimal sendCarWeighNumber = new BigDecimal(NumberConstant.ZERO);
+        BigDecimal sendCarWeighNumber = new BigDecimal("0.00");
         //装货量
-        BigDecimal loadAmountNumber = new BigDecimal(NumberConstant.ZERO);
+        BigDecimal loadAmountNumber = new BigDecimal("0.00");
         //卸货量
-        BigDecimal unloadAmountNumber = new BigDecimal(NumberConstant.ZERO);
+        BigDecimal unloadAmountNumber = new BigDecimal("0.00");
         /**亏吨量/吨->装货量-卸货量
-         扣亏量/吨->亏吨量-合理损耗*/
+         * 合理损耗值=已委托量*合理损耗
+         扣亏量/吨->亏吨量-合理损耗值 扣亏量/吨->亏吨量-合理损耗值(分配量(委托量)*合理损耗)*/
         //亏吨量
-        BigDecimal defectiveWeighNumber = new BigDecimal(NumberConstant.ZERO);
+        BigDecimal defectiveWeighNumber = new BigDecimal("0.00");
         //扣亏量/吨
-        BigDecimal deductWeighNumber = new BigDecimal(NumberConstant.ZERO);
+        BigDecimal deductWeighNumber = new BigDecimal("0.00");
         if (CollectionUtils.isNotEmpty(kwtWaybillOrders)) {
             for (KwtWaybillOrder kwtWaybillOrder : kwtWaybillOrders) {
                 CarWaybillVO carWaybillVo = new CarWaybillVO();
-                //扣亏量/吨->亏吨量-合理损耗值(分配量(委托量)*合理损耗)
-                BigDecimal deduct = null;
-                if (kwtWaybillOrder.getDeficitAmount() != null && (kwtWaybillOrder.getDeficitAmount().compareTo(new BigDecimal(NumberConstant.ZERO)) == NumberConstant.ZERO)) {
-                    deduct = kwtWaybillOrder.getDeficitAmount().subtract(order.getLoss() == null ? new BigDecimal(NumberConstant.ZERO) : order.getLoss());
-                }
                 carWaybillVo.setSendCarWeigh(kwtWaybillOrder.getEntrustAmount() == null ? null : String.valueOf(kwtWaybillOrder.getEntrustAmount()));
                 /**亏吨量/吨->装货量-卸货量
-                 扣亏量/吨->亏吨量*合理损耗*/
+                 * 合理损耗值=已委托量*合理损耗
+                 扣亏量/吨->亏吨量-合理损耗值*/
+                //合理损耗值=已委托量*合理损耗
+                BigDecimal multiply = kwtWaybillOrder.getEntrustAmount().multiply(loss.divide(BigDecimal.valueOf(1000L)));
                 carWaybillVo.setDefectiveWeigh(kwtWaybillOrder.getDeficitAmount() == null ? null : String.valueOf(kwtWaybillOrder.getDeficitAmount()));
                 carWaybillVo.setDeduct(kwtWaybillOrder.getDeficitAmount().compareTo(new BigDecimal(NumberConstant.ZERO)) == 0 ?
-                        new BigDecimal(NumberConstant.ZERO) : kwtWaybillOrder.getDeficitAmount().multiply(loss.divide(BigDecimal.valueOf(1000L))));
+                        new BigDecimal(NumberConstant.ZERO) : kwtWaybillOrder.getDeficitAmount().subtract(multiply));
                 sendCarWeighNumber = sendCarWeighNumber.add(kwtWaybillOrder.getLoadAmount());
                 if (carWaybillVo.getLoadAmount() != null) {
                     loadAmountNumber = loadAmountNumber.add(new BigDecimal(carWaybillVo.getLoadAmount()));
@@ -214,7 +214,7 @@ public class ConsignOrderService {
      * @param orderDto
      * @return
      */
-    private HttpResult getCarWaybillByOrderByAcceptCarriageCount(OrderDTO orderDto) {
+    private HttpResult getCarWaybillOrderByAcceptCarriageCount(OrderDTO orderDto) {
         KwtLogisticsOrder order = kwtLogisticsOrderMapper.selectOne(new LambdaQueryWrapper<KwtLogisticsOrder>()
                         .eq(StringUtils.isNotBlank(orderDto.getId()), KwtLogisticsOrder::getId, Long.parseLong(orderDto.getId()))
                         .eq(StringUtils.isNotBlank(orderDto.getOrderNo()), KwtLogisticsOrder::getLOrderNo, orderDto.getOrderNo())
@@ -235,7 +235,7 @@ public class ConsignOrderService {
         //卸货量
         BigDecimal unloadAmountNumber = new BigDecimal(NumberConstant.ZERO);
         /**亏吨量/吨->装货量-卸货量
-         扣亏量/吨->亏吨量-合理损耗*/
+         扣亏量/吨->亏吨量-合理损耗 (扣亏量/吨->亏吨量-合理损耗值(分配量(委托量)*合理损耗))*/
         //亏吨量
         BigDecimal defectiveWeighNumber = new BigDecimal(NumberConstant.ZERO);
         //扣亏量/吨
@@ -243,17 +243,14 @@ public class ConsignOrderService {
         if (CollectionUtils.isNotEmpty(kwtWaybillOrders)) {
             for (KwtWaybillOrder kwtWaybillOrder : kwtWaybillOrders) {
                 CarWaybillVO carWaybillVo = new CarWaybillVO();
-                //扣亏量/吨->亏吨量-合理损耗值(分配量(委托量)*合理损耗)
-                BigDecimal deduct = null;
-                if (kwtWaybillOrder.getDeficitAmount() != null && (kwtWaybillOrder.getDeficitAmount().compareTo(new BigDecimal(NumberConstant.ZERO)) == NumberConstant.ZERO)) {
-                    deduct = kwtWaybillOrder.getDeficitAmount().subtract(order.getLoss() == null ? new BigDecimal(NumberConstant.ZERO) : order.getLoss());
-                }
                 carWaybillVo.setSendCarWeigh(kwtWaybillOrder.getEntrustAmount() == null ? null : String.valueOf(kwtWaybillOrder.getEntrustAmount()));
                 /**亏吨量/吨->装货量-卸货量
                  扣亏量/吨->亏吨量*合理损耗*/
+                BigDecimal multiply = kwtWaybillOrder.getEntrustAmount().multiply(loss.divide(BigDecimal.valueOf(1000L)));
                 carWaybillVo.setDefectiveWeigh(kwtWaybillOrder.getDeficitAmount() == null ? null : String.valueOf(kwtWaybillOrder.getDeficitAmount()));
                 carWaybillVo.setDeduct(kwtWaybillOrder.getDeficitAmount().compareTo(new BigDecimal(NumberConstant.ZERO)) == 0 ?
-                        new BigDecimal(NumberConstant.ZERO) : kwtWaybillOrder.getDeficitAmount().multiply(loss.divide(BigDecimal.valueOf(1000L))));
+                        new BigDecimal(NumberConstant.ZERO) : kwtWaybillOrder.getDeficitAmount().subtract(multiply));
+                sendCarWeighNumber = sendCarWeighNumber.add(kwtWaybillOrder.getLoadAmount());
                 sendCarWeighNumber = sendCarWeighNumber.add(kwtWaybillOrder.getLoadAmount());
                 if (carWaybillVo.getLoadAmount() != null) {
                     loadAmountNumber = loadAmountNumber.add(new BigDecimal(carWaybillVo.getLoadAmount()));
@@ -282,7 +279,7 @@ public class ConsignOrderService {
      * @param orderDto
      * @return
      */
-    private HttpResult getCarWaybillByOrderByAcceptCarriage(OrderDTO orderDto) {
+    private HttpResult getCarWaybillOrderByAcceptCarriage(OrderDTO orderDto) {
         List<CarWaybillVO> returnList = new ArrayList<>();
         KwtLogisticsOrder order = kwtLogisticsOrderMapper.selectOne(new LambdaQueryWrapper<KwtLogisticsOrder>()
                         .eq(StringUtils.isNotBlank(orderDto.getId()), KwtLogisticsOrder::getId, Long.parseLong(orderDto.getId()))
@@ -293,12 +290,8 @@ public class ConsignOrderService {
         }
         List<KwtWaybillOrder> kwtWaybillOrders = kwtWaybillOrderMapper.selectList(new LambdaQueryWrapper<KwtWaybillOrder>()
                         .eq(StringUtils.isNotBlank(order.getId()), KwtWaybillOrder::getLOrderId, order.getId())
+                        .last("limit " + (orderDto.getPage() - 1) + " , " + orderDto.getPageSize())
                 /**.eq(KwtWaybillOrder::getEntId, LoginUserHolder.getEntId())*/);
-        JSONObject statistics = new JSONObject();
-        BigDecimal sendCarWeighNumber = new BigDecimal(NumberConstant.ZERO);
-        BigDecimal loadAmountNumber = new BigDecimal(NumberConstant.ZERO);
-        BigDecimal unloadAmountNumber = new BigDecimal(NumberConstant.ZERO);
-        BigDecimal defectiveWeighNumber = new BigDecimal(NumberConstant.ZERO);
         if (CollectionUtils.isNotEmpty(kwtWaybillOrders)) {
             for (KwtWaybillOrder kwtWaybillOrder : kwtWaybillOrders) {
                 CarWaybillVO carWaybillVo = new CarWaybillVO();
@@ -308,9 +301,6 @@ public class ConsignOrderService {
                 KwtWaybillOrderTicket unloadTicket = kwtWaybillOrderTicketMapper.selectOne(new LambdaQueryWrapper<KwtWaybillOrderTicket>()
                         .eq(StringUtils.isNotBlank(kwtWaybillOrder.getId()), KwtWaybillOrderTicket::getWOrderId, kwtWaybillOrder.getId())
                         .eq(KwtWaybillOrderTicket::getType, NumberConstant.TWO));
-                KwtLogisticsOrderCirculate circulate = kwtLogisticsOrderCirculateMapper.selectOne(new LambdaQueryWrapper<KwtLogisticsOrderCirculate>()
-                        .eq(StringUtils.isNotBlank(kwtWaybillOrder.getId()), KwtLogisticsOrderCirculate::getLOrderId, kwtWaybillOrder.getId())
-                        .eq(KwtLogisticsOrderCirculate::getEntId, order.getEntId()));
                 //扣亏量/吨->亏吨量-合理损耗
                 BigDecimal deduct = null;
                 if (kwtWaybillOrder.getDeficitAmount() != null && (kwtWaybillOrder.getDeficitAmount().compareTo(new BigDecimal(NumberConstant.ZERO)) == NumberConstant.ZERO)) {
@@ -319,7 +309,7 @@ public class ConsignOrderService {
                 carWaybillVo.setWOrderId(String.valueOf(kwtWaybillOrder.getId()));
                 carWaybillVo.setWOrderNo(order.getLOrderNo());
                 carWaybillVo.setTruckNo(kwtWaybillOrder.getTruckNo());
-                carWaybillVo.setStatus(String.valueOf(kwtWaybillOrder.getStatus()));
+                carWaybillVo.setStatus(CarWaybillEnum.getName(kwtWaybillOrder.getStatus()));
                 carWaybillVo.setWaybillType(kwtWaybillOrder.getType());
                 carWaybillVo.setDriverName(kwtWaybillOrder.getDriverName());
                 //todo 取mongo
@@ -327,11 +317,7 @@ public class ConsignOrderService {
                 /** 2023-07-24 原值为承运车队-去除后更换展示为承运公司*/
 //                carWaybillVo.setConsignMotorcade(sckwWaybillOrder == null ? null : sckwWaybillOrder.getCarrierFirmName());
                 carWaybillVo.setSendCarWeigh(kwtWaybillOrder.getEntrustAmount() == null ? null : String.valueOf(kwtWaybillOrder.getEntrustAmount()));
-                if (circulate != null) {
-                    carWaybillVo.setSendCarDate(circulate.getCreateTime() == null ? null : DateUtil.getDateTime(circulate.getCreateTime()));
-                } else {
-                    carWaybillVo.setSendCarDate(null);
-                }
+                carWaybillVo.setSendCarDate(DateUtil.getDateTime(kwtWaybillOrder.getCreateTime()));
                 if (loadTicket != null) {
                     carWaybillVo.setLoadAmount(loadTicket.getAmount() == null ? null : String.valueOf(loadTicket.getAmount()));
                     carWaybillVo.setLoadDateTime(loadTicket.getCreateTime() == null ? null : DateUtil.getDateTime(loadTicket.getCreateTime()));
@@ -339,7 +325,6 @@ public class ConsignOrderService {
                     carWaybillVo.setLoadAmount(null);
                     carWaybillVo.setLoadDateTime(null);
                 }
-                carWaybillVo.setSendCarWeigh(kwtWaybillOrder.getEntrustAmount() == null ? null : String.valueOf(kwtWaybillOrder.getEntrustAmount()));
                 if (unloadTicket != null) {
                     carWaybillVo.setUnloadAmount(unloadTicket.getAmount() == null ? null : String.valueOf(unloadTicket.getAmount()));
                     carWaybillVo.setUnloadDateTime(unloadTicket.getCreateTime() == null ? null : DateUtil.getDateTime(unloadTicket.getCreateTime()));
@@ -353,27 +338,11 @@ public class ConsignOrderService {
                 carWaybillVo.setDeduct(deduct);
 //                carWaybillVo.setAppointor(remoteSystemService.queryUserCacheById(kwtWaybillOrder.getCreateBy()) == null ?
 //                        String.valueOf(kwtWaybillOrder.getCreateBy()) : remoteSystemService.queryUserCacheById(kwtWaybillOrder.getCreateBy()).getName());
-                if (carWaybillVo.getLoadAmount() != null) {
-                    loadAmountNumber = loadAmountNumber.add(new BigDecimal(carWaybillVo.getLoadAmount()));
-                }
-                if (carWaybillVo.getUnloadAmount() != null) {
-                    unloadAmountNumber = unloadAmountNumber.add(new BigDecimal(carWaybillVo.getUnloadAmount()));
-                }
-                if (carWaybillVo.getDefectiveWeigh() != null) {
-                    defectiveWeighNumber = defectiveWeighNumber.add(new BigDecimal(carWaybillVo.getDefectiveWeigh()));
-                }
                 returnList.add(carWaybillVo);
             }
         }
-        statistics.put("count", kwtWaybillOrders.size());
-        statistics.put("sendCarWeighNumber", sendCarWeighNumber);
-        statistics.put("loadAmountNumber", loadAmountNumber);
-        statistics.put("unloadAmountNumber", unloadAmountNumber);
-        statistics.put("defectiveWeighNumber", defectiveWeighNumber);
-        Map map = new HashMap<>(NumberConstant.SIXTEEN);
-        map.put("returnList", returnList);
-        map.put("statistics", statistics);
-        return HttpResult.ok(map);
+        PageResult result = PageResult.build(orderDto.getPage(), orderDto.getPageSize(), returnList.stream().count(), returnList);
+        return HttpResult.ok(result);
     }
 
 
@@ -383,7 +352,7 @@ public class ConsignOrderService {
      * @param orderDto
      * @return
      */
-    private HttpResult getCarWaybillByOrderByConsign(OrderDTO orderDto) {
+    private HttpResult getCarWaybillOrderByConsign(OrderDTO orderDto) {
         List<CarWaybillVO> returnList = new ArrayList<>();
         KwtLogisticsOrder order = kwtLogisticsOrderMapper.selectOne(new LambdaQueryWrapper<KwtLogisticsOrder>()
                         .eq(StringUtils.isNotBlank(orderDto.getId()), KwtLogisticsOrder::getId, Long.parseLong(orderDto.getId()))
@@ -394,7 +363,7 @@ public class ConsignOrderService {
         }
         List<KwtWaybillOrder> kwtWaybillOrders = kwtWaybillOrderMapper.selectList(new LambdaQueryWrapper<KwtWaybillOrder>()
                         .eq(StringUtils.isNotBlank(order.getId()), KwtWaybillOrder::getLOrderId, order.getId())
-                        .last("limit" + (orderDto.getPage() - 1) + " , " + orderDto.getPageSize())
+                        .last("limit " + (orderDto.getPage() - 1) + " , " + orderDto.getPageSize())
                 /**.eq(KwtWaybillOrder::getEntId, LoginUserHolder.getEntId())*/);
         if (CollectionUtils.isNotEmpty(kwtWaybillOrders)) {
             for (KwtWaybillOrder kwtWaybillOrder : kwtWaybillOrders) {
@@ -405,9 +374,6 @@ public class ConsignOrderService {
                 KwtWaybillOrderTicket unloadTicket = kwtWaybillOrderTicketMapper.selectOne(new LambdaQueryWrapper<KwtWaybillOrderTicket>()
                         .eq(StringUtils.isNotBlank(kwtWaybillOrder.getId()), KwtWaybillOrderTicket::getWOrderId, kwtWaybillOrder.getId())
                         .eq(KwtWaybillOrderTicket::getType, NumberConstant.TWO));
-                KwtLogisticsOrderCirculate circulate = kwtLogisticsOrderCirculateMapper.selectOne(new LambdaQueryWrapper<KwtLogisticsOrderCirculate>()
-                        .eq(StringUtils.isNotBlank(kwtWaybillOrder.getId()), KwtLogisticsOrderCirculate::getLOrderId, kwtWaybillOrder.getId())
-                        .eq(KwtLogisticsOrderCirculate::getEntId, order.getEntId()));
                 //扣亏量/吨->亏吨量-合理损耗
                 BigDecimal deduct = null;
                 if (kwtWaybillOrder.getDeficitAmount() != null && (kwtWaybillOrder.getDeficitAmount().compareTo(new BigDecimal(NumberConstant.ZERO)) == NumberConstant.ZERO)) {
@@ -416,7 +382,7 @@ public class ConsignOrderService {
                 carWaybillVo.setWOrderId(String.valueOf(kwtWaybillOrder.getId()));
                 carWaybillVo.setWOrderNo(order.getLOrderNo());
                 carWaybillVo.setTruckNo(kwtWaybillOrder.getTruckNo());
-                carWaybillVo.setStatus(String.valueOf(kwtWaybillOrder.getStatus()));
+                carWaybillVo.setStatus(CarWaybillEnum.getName(kwtWaybillOrder.getStatus()));
                 carWaybillVo.setWaybillType(kwtWaybillOrder.getType());
                 carWaybillVo.setDriverName(kwtWaybillOrder.getDriverName());
                 //todo 取mongo
@@ -424,11 +390,7 @@ public class ConsignOrderService {
                 /** 2023-07-24 原值为承运车队-去除后更换展示为承运公司*/
 //                carWaybillVo.setConsignMotorcade(sckwWaybillOrder == null ? null : sckwWaybillOrder.getCarrierFirmName());
                 carWaybillVo.setSendCarWeigh(kwtWaybillOrder.getEntrustAmount() == null ? null : String.valueOf(kwtWaybillOrder.getEntrustAmount()));
-                if (circulate != null) {
-                    carWaybillVo.setSendCarDate(circulate.getCreateTime() == null ? null : DateUtil.getDateTime(circulate.getCreateTime()));
-                } else {
-                    carWaybillVo.setSendCarDate(null);
-                }
+                carWaybillVo.setSendCarDate(DateUtil.getDateTime(kwtWaybillOrder.getCreateTime()));
                 if (loadTicket != null) {
                     carWaybillVo.setLoadAmount(loadTicket.getAmount() == null ? null : String.valueOf(loadTicket.getAmount()));
                     carWaybillVo.setLoadDateTime(loadTicket.getCreateTime() == null ? null : DateUtil.getDateTime(loadTicket.getCreateTime()));
@@ -457,12 +419,26 @@ public class ConsignOrderService {
     }
 
     /**
-     * 托运订单获取车辆信息
+     * 托运订单/承运订单-获取车辆信息
      *
      * @param orderDto
      * @return
      */
-    public HttpResult getCarListByOrder(OrderDTO orderDto) {
+    public HttpResult getCarListByOrder(OrderDTO orderDto, String type) {
+        HttpResult httpResult = new HttpResult();
+        if (String.valueOf(NumberConstant.ONE).equals(type)) {
+            //托运
+            httpResult = getAcceptCarListByOrder(orderDto);
+        } else if (String.valueOf(NumberConstant.TWO).equals(type)) {
+            //承运
+            httpResult = getAcceptCarListByOrder(orderDto);
+        } else {
+            return HttpResult.error("单据类型错误！");
+        }
+        return httpResult;
+    }
+
+    private HttpResult getAcceptCarListByOrder(OrderDTO orderDto) {
         KwtLogisticsOrder logisticsOrder = kwtLogisticsOrderMapper.selectOne(new LambdaQueryWrapper<KwtLogisticsOrder>()
                 .eq(KwtLogisticsOrder::getId, orderDto.getId()));
         if (logisticsOrder == null) {
@@ -470,15 +446,15 @@ public class ConsignOrderService {
             HttpResult.error("物流订单不存在");
         }
         List<OrderCarDTO> list = kwtWaybillOrderMapper.selectWaybillOrderCarListGroupByTruckNo(orderDto.getId(), orderDto.getPage(), orderDto.getPageSize());
-        if (CollectionUtils.isNotEmpty(list)) {
-            List<String> stringList = list.stream().map(OrderCarDTO::getTruckNo).collect(Collectors.toList());
-            Map<String, RTruckVo> truck = remoteFleetService.findTruck(stringList);
-            for (OrderCarDTO dto : list) {
-                dto.setLoadAmount(truck.get(dto.getTruckNo()) == null ?
-                        null : (truck.get(dto.getTruckNo()).getActualWeight() == null ?
-                        null : (String.valueOf(truck.get(dto.getTruckNo()).getActualWeight()))));
-            }
-        }
+//        if (CollectionUtils.isNotEmpty(list)) {
+//            List<String> stringList = list.stream().map(OrderCarDTO::getTruckNo).collect(Collectors.toList());
+//            Map<String, RTruckVo> truck = remoteFleetService.findTruck(stringList);
+//            for (OrderCarDTO dto : list) {
+//                dto.setLoadAmount(truck.get(dto.getTruckNo()) == null ?
+//                        null : (truck.get(dto.getTruckNo()).getActualWeight() == null ?
+//                        null : (String.valueOf(truck.get(dto.getTruckNo()).getActualWeight()))));
+//            }
+//        }
         PageResult build = PageResult.build(orderDto.getPage(), orderDto.getPageSize(), (long) list.size(), list);
         return HttpResult.ok(build);
     }

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

@@ -537,28 +537,49 @@ public class LogisticsConsignmentService {
      * @param pageSize
      * @return
      */
-    public HttpResult purchaseLogisticsOrder(String id, Integer page, Integer pageSize) {
-        Long count = getLogisticsOrderCount(id);
+    public HttpResult purchaseLogisticsOrder(String id, Integer page, Integer pageSize, String type) {
+        Long count = getLogisticsOrderCount(id, type);
         Integer newPage = page - 1;
-        List<LogisticsOrderDTO> list = getLogisticsOrderData(id, newPage, pageSize);
+        List<LogisticsOrderDTO> list = getLogisticsOrderData(id, newPage, pageSize, type);
         PageResult build = PageResult.build(page, pageSize, count, list);
         return HttpResult.ok(build);
     }
 
-    private Long getLogisticsOrderCount(String id) {
-        return kwtLogisticsOrderMapper.selectOrderCount(id);
+    private Long getLogisticsOrderCount(String id, String type) {
+        return kwtLogisticsOrderMapper.selectOrderCount(id, type);
     }
 
     /**
      * 销售订单-采购订单-获取托运订单数据
      *
      * @param id       销售订单id
-     * @param page
-     * @param pageSize
+     * @param page     当前页
+     * @param pageSize 每页条数
+     * @param type     属于采购（1）还是销售（2）
      * @return
      */
-    public HttpResult logisticsOrder(String id, Integer page, Integer pageSize) {
+    public HttpResult logisticsOrder(String id, Integer page, Integer pageSize, String type) {
         HttpResult httpResult = new HttpResult();
+        if (String.valueOf(NumberConstant.ONE).equals(type)) {
+            //采购
+            httpResult = logisticsOrderList(id, page, pageSize, type);
+        } else if (String.valueOf(NumberConstant.ONE).equals(type)) {
+            //销售
+            httpResult = logisticsOrderList(id, page, pageSize, type);
+        } else {
+            return HttpResult.error("单据类型错误");
+        }
+        return httpResult;
+    }
+
+    /**
+     * 采购订单/销售订单-托运订单列表-下方数据统计
+     *
+     * @param id   贸易订单id
+     * @param type 采购1 销售2
+     * @return
+     */
+    public HttpResult logisticsOrderCount(String id, String type) {
         OrderDetailRes orderDetailRes = tradeOrderInfoService.getOrderDetailById(Long.parseLong(id));
         /**根据下单方式（代客下单/自主下单）决定托运数据是否展示*/
         boolean flag = false;
@@ -570,41 +591,73 @@ public class LogisticsConsignmentService {
             throw new RuntimeException("获取贸易订单下单方式异常!");
         }
         BigDecimal resAmount = orderDetailRes.getAmount();
+        List<LogisticsOrderDTO> list = new ArrayList<>();
+        JSONObject jsonObject = new JSONObject();
+        //总数
+        Long count = 0L;
+        //计划量
+        BigDecimal amount = new BigDecimal("0.00");
+        //剩余调度量
+        BigDecimal residue = new BigDecimal("0.00");
+        if (flag) {
+            count = getLogisticsOrderCount(id, type);
+            list = kwtLogisticsOrderMapper.selectOrderCountByTorderId(id, type);
+            /**数据统计*/
+            for (LogisticsOrderDTO logisticsOrderDTO : list) {
+                amount = amount.add(logisticsOrderDTO.getAmount() == null ? new BigDecimal("0.00") : logisticsOrderDTO.getAmount());
+            }
+            residue = resAmount.subtract(amount);
+        }
+        jsonObject.put("count", count);
+        jsonObject.put("residue", residue);
+        jsonObject.put("amount", amount);
+        return HttpResult.ok(jsonObject);
+    }
+
+    /**
+     * 销售订单-采购订单-获取托运订单数据
+     *
+     * @param id       销售订单id
+     * @param page     当前页
+     * @param pageSize 每页条数
+     * @param type     属于采购（1）还是销售（2）
+     * @return
+     */
+    private HttpResult logisticsOrderList(String id, Integer page, Integer pageSize, String type) {
+        OrderDetailRes orderDetailRes = tradeOrderInfoService.getOrderDetailById(Long.parseLong(id));
+        /**根据下单方式（代客下单/自主下单）决定托运数据是否展示*/
+        boolean flag = false;
+        if (String.valueOf(NumberConstant.ONE).equals(orderDetailRes.getSource())) {
+            flag = true;
+        } else if (String.valueOf(NumberConstant.TWO).equals(orderDetailRes.getSource())) {
+            flag = true;
+        } else {
+            throw new RuntimeException("获取贸易订单下单方式异常!");
+        }
+        List<LogisticsOrderDTO> list = new ArrayList<>();
+        PageResult build = PageResult.build(page, pageSize, 0L, list);
         if (flag) {
             /**数据展示*/
-            //总数
-            Long count = getLogisticsOrderCount(id);
+            Long count = getLogisticsOrderCount(id, type);
             Integer newPage = page - 1;
-            List<LogisticsOrderDTO> list = getLogisticsOrderData(id, newPage, pageSize);
-            PageResult build = PageResult.build(page, pageSize, count, list);
-            /**数据统计*/
-            //计划量
-            BigDecimal amount = new BigDecimal(NumberConstant.ZERO);
+            list = getLogisticsOrderData(id, newPage, pageSize, type);
             for (LogisticsOrderDTO logisticsOrderDTO : list) {
-                amount = amount.add(logisticsOrderDTO.getAmount() == null ? new BigDecimal(NumberConstant.ZERO) : logisticsOrderDTO.getAmount());
+                logisticsOrderDTO.setStatus(LogisticsOrderEnum.getDestination(logisticsOrderDTO.getStatus()));
             }
-            //剩余调度量
-            BigDecimal residue = resAmount.subtract(amount);
-            JSONObject jsonObject = new JSONObject();
-            jsonObject.put("count", count);
-            jsonObject.put("residue", residue);
-            jsonObject.put("amount", amount);
-            Map<String, Object> map = new HashMap<>(NumberConstant.SIXTEEN);
-            map.put("dataList", build);
-            map.put("TableBottom", jsonObject);
-            httpResult.setData(map);
+            build = PageResult.build(page, pageSize, count, list);
         }
-        return httpResult;
+        return HttpResult.ok(build);
     }
 
     /**
-     * @param id
-     * @param page
-     * @param pageSize
+     * @param id       贸易订单id
+     * @param page     当前页
+     * @param pageSize 每页条数
+     * @param type     采购订单1/销售订单2
      * @return
      */
-    private List<LogisticsOrderDTO> getLogisticsOrderData(String id, Integer page, Integer pageSize) {
-        List<LogisticsOrderDTO> list = kwtLogisticsOrderMapper.selectOrderList(id, page, pageSize);
+    private List<LogisticsOrderDTO> getLogisticsOrderData(String id, Integer page, Integer pageSize, String type) {
+        List<LogisticsOrderDTO> list = kwtLogisticsOrderMapper.selectOrderList(id, page, pageSize, type);
         return list;
     }
 

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

@@ -16,11 +16,8 @@ import com.sckw.mongo.model.SckwWaybillOrder;
 import com.sckw.mongo.model.TableTops;
 import com.sckw.system.api.RemoteSystemService;
 import com.sckw.system.api.model.dto.res.UserCacheResDto;
-import com.sckw.transport.api.model.dto.vo.LogisticsOrderVO;
 import com.sckw.transport.dao.*;
 import com.sckw.transport.model.KwtLogisticsOrder;
-import com.sckw.transport.model.KwtWaybillOrderAddress;
-import com.sckw.transport.model.KwtWaybillOrderTicket;
 import com.sckw.transport.model.KwtWaybillOrderTrack;
 import com.sckw.transport.model.dto.WayBillDetailDTO;
 import com.sckw.transport.model.dto.WaybillOrderDTO;
@@ -39,7 +36,10 @@ import org.springframework.data.mongodb.core.query.Query;
 import org.springframework.stereotype.Service;
 import org.springframework.util.ObjectUtils;
 
-import java.util.*;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
 import java.util.regex.Pattern;
 
 /**

sckw-modules/sckw-transport/src/main/resources/mapper/KwtLogisticsOrderMapper.xml

@@ -64,8 +64,8 @@
                a.create_by   as createBy,
                a.create_time as createTime
         FROM kwt_logistics_order a
-                 LEFT JOIN kwt_logistics_order_track b ON a.id = b.l_order_id
-                 LEFT JOIN kwt_logistics_order_unit c ON a.id = c.l_order_id AND c.unit_type = '2'
+                 LEFT JOIN kwt_logistics_order_track b ON a.id = b.l_order_id and a.`status`=b.`status`
+                 LEFT JOIN kwt_logistics_order_unit c ON a.id = c.l_order_id AND c.unit_type = #{type}
         WHERE a.del_flag = '0'
           AND b.del_flag = '0'
           AND a.t_order_id = #{id,jdbcType=VARCHAR} limit #{page}
@@ -74,8 +74,8 @@
     <select id="selectOrderCount" resultType="java.lang.Long">
         SELECT count(a.id)
         FROM kwt_logistics_order a
-                 LEFT JOIN kwt_logistics_order_track b ON a.id = b.l_order_id
-                 LEFT JOIN kwt_logistics_order_unit c ON a.id = c.l_order_id AND c.unit_type = '2'
+                 LEFT JOIN kwt_logistics_order_track b ON a.id = b.l_order_id and a.`status` = b.`status`
+                 LEFT JOIN kwt_logistics_order_unit c ON a.id = c.l_order_id AND c.unit_type = #{type}
         WHERE a.del_flag = '0'
           AND b.del_flag = '0'
           AND a.t_order_id = #{id,jdbcType=VARCHAR}
@@ -398,4 +398,27 @@
             and id != #{ownOrderId, jdbcType=BIGINT}
         </if>
     </select>
+    <select id="selectOrderCountByTorderId" resultType="com.sckw.transport.model.dto.LogisticsOrderDTO">
+        SELECT a.id          as lOrderId,
+               a.l_order_no  as lOrderNo,
+               b.`status`    as `status`,
+               a.t_order_id  as tOrderId,
+               a.t_order_no  as tOrderNo,
+               a.payment     as payment,
+               a.amount,
+               a.price,
+               a.loss,
+               a.goods_price as goodsPrice,
+               c.firm_name   as comanyName,
+               c.contacts,
+               c.phone,
+               a.create_by   as createBy,
+               a.create_time as createTime
+        FROM kwt_logistics_order a
+                 LEFT JOIN kwt_logistics_order_track b ON a.id = b.l_order_id
+                 LEFT JOIN kwt_logistics_order_unit c ON a.id = c.l_order_id AND c.unit_type = #{type}
+        WHERE a.del_flag = '0'
+          AND b.del_flag = '0'
+          AND a.t_order_id = #{id,jdbcType=VARCHAR}
+    </select>
 </mapper>