diff --git a/blade-service-api/logpm-basicdata-api/src/main/java/com/logpm/basicdata/feign/IBasicdataClientClient.java b/blade-service-api/logpm-basicdata-api/src/main/java/com/logpm/basicdata/feign/IBasicdataClientClient.java index 64e4e22d1..95691b71a 100644 --- a/blade-service-api/logpm-basicdata-api/src/main/java/com/logpm/basicdata/feign/IBasicdataClientClient.java +++ b/blade-service-api/logpm-basicdata-api/src/main/java/com/logpm/basicdata/feign/IBasicdataClientClient.java @@ -127,4 +127,6 @@ public interface IBasicdataClientClient { @PostMapping(API_PREFIX+"/saveEntity") Long saveEntity(@RequestBody BasicdataClientEntity clientEntity) ; + @GetMapping(API_PREFIX+"/getFinallyClientCode") + String getFinallyClientCode(); } diff --git a/blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/feign/IDistributionParcelListClient.java b/blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/feign/IDistributionParcelListClient.java index d6b266310..f9a13b99e 100644 --- a/blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/feign/IDistributionParcelListClient.java +++ b/blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/feign/IDistributionParcelListClient.java @@ -306,5 +306,8 @@ public interface IDistributionParcelListClient { @PostMapping(API_PREFIX + "/deleteListByOrderPackageCodes") R deleteListByOrderPackageCodes(@RequestBody FindParamterDTO findParamterDTO); + + @GetMapping(API_PREFIX + "/findOrderPackageCodeAndStatus") + DistributionParcelListEntity findOrderPackageCodeAndStatus(@RequestParam String orderPackageCode, @RequestParam String orderPackageStatus); } diff --git a/blade-service-api/logpm-trunkline-api/src/main/java/com/logpm/trunkline/vo/CarsLoadPackagePlanVO.java b/blade-service-api/logpm-trunkline-api/src/main/java/com/logpm/trunkline/vo/CarsLoadPackagePlanVO.java new file mode 100644 index 000000000..504488b00 --- /dev/null +++ b/blade-service-api/logpm-trunkline-api/src/main/java/com/logpm/trunkline/vo/CarsLoadPackagePlanVO.java @@ -0,0 +1,16 @@ +package com.logpm.trunkline.vo; + +import lombok.Data; + +import java.io.Serializable; + +@Data +public class CarsLoadPackagePlanVO implements Serializable { + + private String orderCode; + private String waybillNo; + private String orderPackageCode; + private String thirds; + private String materialName; + +} diff --git a/blade-service-api/logpm-trunkline-api/src/main/java/com/logpm/trunkline/vo/LoadScanOrderVO.java b/blade-service-api/logpm-trunkline-api/src/main/java/com/logpm/trunkline/vo/LoadScanOrderVO.java index 98e573dd4..5f936610a 100644 --- a/blade-service-api/logpm-trunkline-api/src/main/java/com/logpm/trunkline/vo/LoadScanOrderVO.java +++ b/blade-service-api/logpm-trunkline-api/src/main/java/com/logpm/trunkline/vo/LoadScanOrderVO.java @@ -12,5 +12,6 @@ public class LoadScanOrderVO implements Serializable { private Integer totalNum; private Integer planNum; private Integer realNum; + private Integer isAbnormal; } diff --git a/blade-service-api/logpm-trunkline-api/src/main/java/com/logpm/trunkline/vo/OrderScanDetailVO.java b/blade-service-api/logpm-trunkline-api/src/main/java/com/logpm/trunkline/vo/OrderScanDetailVO.java index ebcb96c9a..07907260f 100644 --- a/blade-service-api/logpm-trunkline-api/src/main/java/com/logpm/trunkline/vo/OrderScanDetailVO.java +++ b/blade-service-api/logpm-trunkline-api/src/main/java/com/logpm/trunkline/vo/OrderScanDetailVO.java @@ -14,6 +14,12 @@ public class OrderScanDetailVO implements Serializable { private Integer num; private String trayName; private String trayCode; + private String firsts; + private String senconds; + private String thirds; + private String materialCode; + private String materialName; + private Integer isAbnormal; private List zeroDetailList = new ArrayList<>(); diff --git a/blade-service-api/logpm-trunkline-api/src/main/java/com/logpm/trunkline/vo/UnloadPackageVO.java b/blade-service-api/logpm-trunkline-api/src/main/java/com/logpm/trunkline/vo/UnloadPackageVO.java index d640d8839..f3cf76591 100644 --- a/blade-service-api/logpm-trunkline-api/src/main/java/com/logpm/trunkline/vo/UnloadPackageVO.java +++ b/blade-service-api/logpm-trunkline-api/src/main/java/com/logpm/trunkline/vo/UnloadPackageVO.java @@ -21,6 +21,12 @@ public class UnloadPackageVO implements Serializable { private String unloadNodeName; private String orderCode; private String waybillNo; + private String firsts; + private String senconds; + private String thirds; + private String materialCode; + private String materialName; + private Integer isAbnormal; private List scanZeroDetailList = new ArrayList<>(); diff --git a/blade-service-api/logpm-trunkline-api/src/main/java/com/logpm/trunkline/vo/UnloadScanOrderVO.java b/blade-service-api/logpm-trunkline-api/src/main/java/com/logpm/trunkline/vo/UnloadScanOrderVO.java index e16c096e1..a8bb3abe0 100644 --- a/blade-service-api/logpm-trunkline-api/src/main/java/com/logpm/trunkline/vo/UnloadScanOrderVO.java +++ b/blade-service-api/logpm-trunkline-api/src/main/java/com/logpm/trunkline/vo/UnloadScanOrderVO.java @@ -13,7 +13,7 @@ public class UnloadScanOrderVO implements Serializable { private String orderCode; private Integer loadingNum; private Integer unloadNum; - private Integer unloadAbnormal; + private Integer isAbnormal; private Integer totalNumber; private List unloadPackageList = new ArrayList<>(); diff --git a/blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/feign/BasicdataClientClient.java b/blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/feign/BasicdataClientClient.java index ec15703b7..3014927e0 100644 --- a/blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/feign/BasicdataClientClient.java +++ b/blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/feign/BasicdataClientClient.java @@ -28,7 +28,6 @@ import com.logpm.basicdata.entity.BasicdataClientUserEntity; import com.logpm.basicdata.service.IBasicdataClientService; import com.logpm.basicdata.service.IBasicdataClientUserService; import com.logpm.basicdata.vo.BasicdataClientVO; -import com.logpm.distribution.entity.DistributionParcelListEntity; import lombok.AllArgsConstructor; import org.springblade.common.annotations.ChangeAsync; import org.springblade.core.mp.support.BladePage; @@ -164,4 +163,9 @@ public class BasicdataClientClient implements IBasicdataClientClient { throw new RuntimeException(e); } } + + @Override + public String getFinallyClientCode() { + return basicdataClientService.getFinallyClientCode(); + } } diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/feign/DistributionParcelListClient.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/feign/DistributionParcelListClient.java index b126f0614..cc47d81bf 100644 --- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/feign/DistributionParcelListClient.java +++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/feign/DistributionParcelListClient.java @@ -654,4 +654,9 @@ public class DistributionParcelListClient implements IDistributionParcelListClie return R.success("删除成功"); } + @Override + public DistributionParcelListEntity findOrderPackageCodeAndStatus(String orderPackageCode, String orderPackageStatus) { + return distributionParcelListService.findOrderPackageCodeAndStatus(orderPackageCode,orderPackageStatus); + } + } diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/IDistributionParcelListService.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/IDistributionParcelListService.java index d6280132f..9063312ad 100644 --- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/IDistributionParcelListService.java +++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/IDistributionParcelListService.java @@ -313,4 +313,5 @@ public interface IDistributionParcelListService extends BaseService orderPackageCodeList,Long warehouseId); + DistributionParcelListEntity findOrderPackageCodeAndStatus(String orderPackageCode, String orderPackageStatus); } diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionParcelListServiceImpl.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionParcelListServiceImpl.java index ac96df667..fb23daaa5 100644 --- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionParcelListServiceImpl.java +++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionParcelListServiceImpl.java @@ -1583,4 +1583,16 @@ public class DistributionParcelListServiceImpl extends BaseServiceImpl orderPackageCodeList, Long warehouseId) { baseMapper.deleteListByOrderPackageCodes(orderPackageCodeList,warehouseId); } + + @Override + public DistributionParcelListEntity findOrderPackageCodeAndStatus(String orderPackageCode, String orderPackageStatus) { + QueryWrapper queryWrapper = new QueryWrapper<>(); + queryWrapper.eq("order_package_code",orderPackageCode).eq("order_package_status",orderPackageStatus); + List distributionParcelListEntities = baseMapper.selectList(queryWrapper); + if(CollUtil.isNotEmpty(distributionParcelListEntities)){ + return distributionParcelListEntities.get(0); + }else{ + return null; + } + } } diff --git a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/api/CarsLoadApiController.java b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/api/CarsLoadApiController.java index 8843461e0..2e357b5d9 100644 --- a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/api/CarsLoadApiController.java +++ b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/api/CarsLoadApiController.java @@ -167,6 +167,41 @@ public class CarsLoadApiController { } } + @ResponseBody + @PostMapping("/findCarsLoadingOrderPlan") + @ApiOperationSupport(order = 1) + @ApiOperation(value = "查询装车订单假话", notes = "传入loadCarsDTO") + public R findCarsLoadingOrderPlan(@RequestBody LoadCarsDTO loadCarsDTO) { + String method = "############findCarsLoadingOrderDetail: "; + log.info(method + "请求参数{}", loadCarsDTO); + Long loadId = loadCarsDTO.getLoadId(); + try{ + + //当前登录人选择的仓库 + BasicdataWarehouseEntity myCurrentWarehouse = warehouseClient.getMyCurrentWarehouse(); + if(Objects.isNull(myCurrentWarehouse)){ + log.warn(method+"仓库信息为空 myCurrentWarehouse={}",myCurrentWarehouse); + return R.fail(405,"仓库信息为空"); + } + loadCarsDTO.setWarehouseId(myCurrentWarehouse.getId()); + + if(Objects.isNull(loadId)){ + log.warn(method+"配载id为空 loadId={}",loadId); + return R.fail(405,"配载id为空"); + } + + return carsLoadService.findCarsLoadingOrderPlan(loadId,myCurrentWarehouse.getId()); + }catch (CustomerException e){ + log.error(e.message,e); + return R.fail(e.code,e.message); + }catch (Exception e){ + log.error(method+"系统异常",e); + return R.fail(500,"系统异常"); + } + } + + + @ResponseBody @PostMapping("/findCarsLoadingOrderDetail") @ApiOperationSupport(order = 1) @@ -176,7 +211,7 @@ public class CarsLoadApiController { log.info(method + "请求参数{}", loadCarsDTO); Long loadId = loadCarsDTO.getLoadId(); String orderCode = loadCarsDTO.getOrderCode(); - + String waybillNo = loadCarsDTO.getWaybillNo(); try{ //当前登录人选择的仓库 @@ -196,7 +231,7 @@ public class CarsLoadApiController { return R.fail(405,"订单号为空"); } - return carsLoadService.findCarsLoadingOrderDetail(loadId,orderCode,myCurrentWarehouse.getId()); + return carsLoadService.findCarsLoadingOrderDetail(loadId,orderCode,myCurrentWarehouse.getId(),waybillNo); }catch (CustomerException e){ log.error(e.message,e); return R.fail(e.code,e.message); @@ -573,6 +608,50 @@ public class CarsLoadApiController { } + @ResponseBody + @PostMapping("/unloadPackageNoXz") + @ApiOperationSupport(order = 1) + @ApiOperation(value = "包件卸车", notes = "传入loadCarsDTO") + public R unloadPackageNoXz(@RequestBody LoadCarsDTO loadCarsDTO) { + String method = "############unloadPackageNoXz: "; + log.info(method + "请求参数{}", loadCarsDTO); + Long loadId = loadCarsDTO.getLoadId(); + String orderPackageCode = loadCarsDTO.getOrderPackageCode(); + Integer incomingType = loadCarsDTO.getIncomingType(); + try{ + + //当前登录人选择的仓库 + BasicdataWarehouseEntity myCurrentWarehouse = warehouseClient.getMyCurrentWarehouse(); + if(Objects.isNull(myCurrentWarehouse)){ + log.warn(method+"仓库信息为空 myCurrentWarehouse={}",myCurrentWarehouse); + return R.fail(405,"仓库信息为空"); + } + loadCarsDTO.setWarehouseId(myCurrentWarehouse.getId()); + if(Objects.isNull(loadId)){ + log.warn(method+"配载计划id为空 loadId={}",loadId); + return R.fail(405,"配载计划id为空"); + } + if(StringUtil.isBlank(orderPackageCode)){ + log.warn(method+"包件码为空 orderPackageCode={}",orderPackageCode); + return R.fail(405,"包件码为空"); + } + if(Objects.isNull(incomingType)){ + log.warn(method+"入库类型为空 orderPackageCode={}",orderPackageCode); + return R.fail(405,"入库类型为空"); + } + + return carsLoadService.unloadPackageNoXz(loadId,orderPackageCode,myCurrentWarehouse.getId(),1,"补录卸车",incomingType,null,null); + }catch (CustomerException e){ + log.error(e.message,e); + return R.fail(e.code,e.message); + }catch (Exception e){ + log.error(method+"系统异常",e); + return R.fail(500,"系统异常"); + } + } + + + @ResponseBody @PostMapping("/unloadZero") @ApiOperationSupport(order = 1) diff --git a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineCarsLoadScanMapper.java b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineCarsLoadScanMapper.java index 9b5673a24..4ca2815ba 100644 --- a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineCarsLoadScanMapper.java +++ b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineCarsLoadScanMapper.java @@ -42,7 +42,7 @@ public interface TrunklineCarsLoadScanMapper extends BaseMapper loadingDetail(IPage page, @Param("param") LoadCarsDTO loadCarsDTO); - List findCarsLoadingOrderDetail(@Param("loadId") Long loadId, @Param("orderCode") String orderCode, @Param("warehouseId") Long warehouseId); + List findCarsLoadingOrderDetail(@Param("loadId") Long loadId, @Param("orderCode") String orderCode, @Param("warehouseId") Long warehouseId, @Param("waybillNo") String waybillNo); boolean deleteEntityByCarsLoadScanId(@Param("carsLoadScanId") Long carsLoadScanId); diff --git a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineCarsLoadScanMapper.xml b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineCarsLoadScanMapper.xml index 53c061573..eda62cc95 100644 --- a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineCarsLoadScanMapper.xml +++ b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineCarsLoadScanMapper.xml @@ -180,7 +180,13 @@ scan_code scanCode, num num, tray_name trayName, - tray_code trayCode + tray_code trayCode, + firsts firsts, + senconds senconds, + thirds thirds, + material_code materialCode, + material_name materialName, + IFNULL(loading_abnormal,0)+IFNULL(unload_abnormal,0) isAbnormal from logpm_trunkline_cars_load_scan where load_id = #{loadId} and order_code = #{orderCode} @@ -220,17 +226,23 @@ @@ -392,4 +400,22 @@ where ltco.load_id = #{loadId} + + + diff --git a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/ITrunklineCarsLoadScanService.java b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/ITrunklineCarsLoadScanService.java index 59f0a4a03..f001e1865 100644 --- a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/ITrunklineCarsLoadScanService.java +++ b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/ITrunklineCarsLoadScanService.java @@ -37,7 +37,7 @@ public interface ITrunklineCarsLoadScanService extends BaseService loadingDetail(IPage page, LoadCarsDTO loadCarsDTO); - List findCarsLoadingOrderDetail(Long loadId, String orderCode, Long warehouseId); + List findCarsLoadingOrderDetail(Long loadId, String orderCode, Long warehouseId,String waybillNo); boolean deleteEntityByCarsLoadScanId(Long carsLoadScanId); diff --git a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/ITrunklineCarsLoadService.java b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/ITrunklineCarsLoadService.java index 8e44ba85d..027d3308a 100644 --- a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/ITrunklineCarsLoadService.java +++ b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/ITrunklineCarsLoadService.java @@ -115,7 +115,7 @@ public interface ITrunklineCarsLoadService extends BaseService findListByLoadId(Long loadId); + List findLoadingOrderPlan(Long loadId, Long warehouseId); + } diff --git a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/OpenOrderServiceImpl.java b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/OpenOrderServiceImpl.java index 054184a35..e1e891f61 100644 --- a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/OpenOrderServiceImpl.java +++ b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/OpenOrderServiceImpl.java @@ -556,6 +556,7 @@ public class OpenOrderServiceImpl implements IOpenOrderService { if (Objects.isNull(consigneeId)) { //如果收货单位没有id值,则把收货单位信息自动添加到client中 consigneeId = saveNewClient(openOrderDTO.getConsignee(), openOrderDTO.getConsigneeName(), openOrderDTO.getConsigneeMobile(), openOrderDTO.getConsigneeAddress(), "2"); + } waybillEntity.setConsigneeId(consigneeId); waybillEntity.setConsignee(openOrderDTO.getConsignee()); @@ -563,6 +564,14 @@ public class OpenOrderServiceImpl implements IOpenOrderService { waybillEntity.setConsigneeMobile(openOrderDTO.getConsigneeMobile()); waybillEntity.setConsigneeAddress(openOrderDTO.getConsigneeAddress()); + BasicdataClientEntity basicdataClient = basicdataClientClient.findEntityById(consigneeId); + if(!Objects.isNull(basicdataClient)){ + waybillEntity.setServiceType(basicdataClient.getTypeService()); + }else{ + waybillEntity.setServiceType(1); + } + + waybillEntity.setDestination(openOrderDTO.getDestination()); waybillEntity.setDestinationCode(openOrderDTO.getDestinationCode()); waybillEntity.setDeparture(openOrderDTO.getDeparture()); @@ -894,6 +903,14 @@ public class OpenOrderServiceImpl implements IOpenOrderService { waybillEntity.setConsigneeMobile(openOrderDTO.getConsigneeMobile()); waybillEntity.setConsigneeAddress(openOrderDTO.getConsigneeAddress()); + BasicdataClientEntity basicdataClient = basicdataClientClient.findEntityById(consigneeId); + if(!Objects.isNull(basicdataClient)){ + waybillEntity.setServiceType(basicdataClient.getTypeService()); + }else{ + waybillEntity.setServiceType(1); + } + + waybillEntity.setDestination(openOrderDTO.getDestination()); waybillEntity.setDestinationCode(openOrderDTO.getDestinationCode()); waybillEntity.setGoodsName(openOrderDTO.getGoodsName()); @@ -2673,15 +2690,15 @@ public class OpenOrderServiceImpl implements IOpenOrderService { } - //验证运单是否有配送任务 - //查询运单下所有订单号 - List orderCodes = distributionParcelListClient.findOrderCodeByWaybillId(waybillId); - //判断运单下所有订单是否在预约关联订单表上是否有数据 - List reservationIds = reservationStockarticleClient.findReservationIdsByOrderCodes(orderCodes); - if(CollUtil.isNotEmpty(reservationIds)){ - log.warn("#############updateWaybill: 已创建配送任务无法改单 waybillId={}", waybillId); - return R.fail(405, "已创建配送任务无法改单"); - } +// //验证运单是否有配送任务 +// //查询运单下所有订单号 +// List orderCodes = distributionParcelListClient.findOrderCodeByWaybillId(waybillId); +// //判断运单下所有订单是否在预约关联订单表上是否有数据 +// List reservationIds = reservationStockarticleClient.findReservationIdsByOrderCodes(orderCodes); +// if(CollUtil.isNotEmpty(reservationIds)){ +// log.warn("#############updateWaybill: 已创建配送任务无法改单 waybillId={}", waybillId); +// return R.fail(405, "已创建配送任务无法改单"); +// } // 得到改单之前的收货单位 @@ -5569,7 +5586,9 @@ public class OpenOrderServiceImpl implements IOpenOrderService { BasicdataClientEntity basicdataClientEntity = basicdataClientClient.findByName(unit); if(Objects.isNull(basicdataClientEntity)){ basicdataClientEntity = new BasicdataClientEntity(); + String finallyClientCode = basicdataClientClient.getFinallyClientCode(); basicdataClientEntity.setClientName(unit); + basicdataClientEntity.setClientCode(finallyClientCode); basicdataClientEntity.setTypeService(2); basicdataClientEntity.setCargoControl(false); basicdataClientEntity.setClientType(type);//1 工厂 2 商场 3装饰 4个人 5门店 6发货单位 diff --git a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineCarsLoadScanServiceImpl.java b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineCarsLoadScanServiceImpl.java index 7414f48d0..15f12e23c 100644 --- a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineCarsLoadScanServiceImpl.java +++ b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineCarsLoadScanServiceImpl.java @@ -81,8 +81,8 @@ public class TrunklineCarsLoadScanServiceImpl extends BaseServiceImpl findCarsLoadingOrderDetail(Long loadId, String orderCode, Long warehouseId) { - return baseMapper.findCarsLoadingOrderDetail(loadId,orderCode,warehouseId); + public List findCarsLoadingOrderDetail(Long loadId, String orderCode, Long warehouseId,String waybillNo) { + return baseMapper.findCarsLoadingOrderDetail(loadId,orderCode,warehouseId,waybillNo); } @Override diff --git a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineCarsLoadServiceImpl.java b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineCarsLoadServiceImpl.java index 71a2bb734..448849d43 100644 --- a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineCarsLoadServiceImpl.java +++ b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineCarsLoadServiceImpl.java @@ -264,6 +264,13 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl list = trunklineCarsOrderService.findLoadingOrderPlan(loadId, warehouseId); + + return R.data(list); + } + @Transactional(rollbackFor = Exception.class) @Override @@ -4488,9 +4503,9 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl orderScanDetailList = trunklineCarsLoadScanService.findCarsLoadingOrderDetail(loadId, orderCode, warehouseId); + List orderScanDetailList = trunklineCarsLoadScanService.findCarsLoadingOrderDetail(loadId, orderCode, warehouseId,waybillNo); if(CollUtil.isNotEmpty(orderScanDetailList)){ //把orderScanDetailList中所有元素的loadScanId放入一个List List loadScanIdList = orderScanDetailList.stream().map(OrderScanDetailVO::getLoadScanId).collect(Collectors.toList()); @@ -8293,7 +8308,9 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl queryWrapper = new QueryWrapper<>(); queryWrapper.eq("load_id", loadId) .eq("warehouse_id", warehouseId) - .eq("loading_abnormal", 1); + .eq("loading_abnormal", 1) + .eq("is_data", 0) + .orderByDesc("update_time"); List exceptionList = trunklineCarsLoadScanService.list(queryWrapper); TrunklineCarsLoadVO trunklineCarsLoadVO = new TrunklineCarsLoadVO(); @@ -8861,6 +8878,14 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl neloadScanQueryWrapper = new QueryWrapper<>(); neloadScanQueryWrapper.eq("load_id", loadId) .eq("scan_code", orderPackageCode) @@ -8869,6 +8894,11 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl orderPackageCodeList = new ArrayList<>(); orderPackageCodeList.add(orderPackageCode); @@ -9557,26 +9587,28 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl loadScanQueryWrapper = new QueryWrapper<>(); loadScanQueryWrapper.eq("load_id", loadId) - .eq("scan_code", orderPackageCode); + .eq("scan_code", orderPackageCode) + .eq("scan_status","1"); TrunklineCarsLoadScanEntity carsLoadScanEntity = trunklineCarsLoadScanService.getOne(loadScanQueryWrapper); //判断是否有装车扫描记录 if (Objects.isNull(carsLoadScanEntity)) { @@ -9646,10 +9679,11 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl brands = this.baseMapper.fingPackageCodeByLoadId(loadId, warehouseId); + sendFactoryData(brands, node, warehouseId, 2); + } } catch (Exception e) { log.error("入库推送失败:{}", e); @@ -10222,15 +10277,14 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl orderPackageCodeList = new ArrayList<>(); @@ -10760,27 +10814,28 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl unloadScanOrderList = trunklineCarsLoadScanService.findPackageWithOrderList(loadId, warehouseId); + + List unloadList = trunklineCarsLoadScanService.findUnloadPackageListByLoadIdAndFinalNodeId(loadId,warehouseId); + if(CollUtil.isNotEmpty(unloadScanOrderList)){ //把unloadScanOrderList中所有元素转化成以orderCode为key的map // Map> unloadScanOrderMap = unloadScanOrderList.stream().collect(Collectors.toMap(UnloadScanOrderVO::getOrderCode, Function.identity())); - Set orderCodeSet = unloadScanOrderList.stream().map(UnloadScanOrderVO::getOrderCode).collect(Collectors.toSet()); +// Set orderCodeSet = unloadScanOrderList.stream().map(UnloadScanOrderVO::getOrderCode).collect(Collectors.toSet()); // Map> unloadScanOrderMap =unloadScanOrderList.stream().map(UnloadScanOrderVO::getOrderCode).collect(Collectors.toList()) // Set orderCodeSet = unloadScanOrderMap.keySet(); - List orderCodeNumList = trunklineAdvanceDetailService.findTotalNumByOrderCodes(orderCodeSet); +// List orderCodeNumList = trunklineAdvanceDetailService.findTotalNumByOrderCodes(orderCodeSet); //把orderCodeNumList中所有元素转化成以orderCode为key的map - Map orderCodeNumMap = orderCodeNumList.stream().collect(Collectors.toMap(OrderCodeNumVO::getOrderCode, Function.identity())); - - List unloadList = trunklineCarsLoadScanService.findUnloadPackageListByLoadIdAndFinalNodeId(loadId,warehouseId); +// Map orderCodeNumMap = orderCodeNumList.stream().collect(Collectors.toMap(OrderCodeNumVO::getOrderCode, Function.identity())); for (UnloadScanOrderVO unloadScanOrderVO : unloadScanOrderList) { String waybillNo = StringUtil.isBlank(unloadScanOrderVO.getWaybillNo())?"null":unloadScanOrderVO.getWaybillNo(); String orderCode = StringUtil.isBlank(unloadScanOrderVO.getOrderCode())?"null":unloadScanOrderVO.getOrderCode(); - OrderCodeNumVO orderCodeNumVO = orderCodeNumMap.get(orderCode); - if(!Objects.isNull(orderCodeNumVO)){ - unloadScanOrderVO.setTotalNumber(orderCodeNumVO.getTotalNum()); - }else{ - unloadScanOrderVO.setTotalNumber(0); - } +// OrderCodeNumVO orderCodeNumVO = orderCodeNumMap.get(orderCode); +// if(!Objects.isNull(orderCodeNumVO)){ +// unloadScanOrderVO.setTotalNumber(orderCodeNumVO.getTotalNum()); +// }else{ +// unloadScanOrderVO.setTotalNumber(0); +// } List unloadPackageList = new ArrayList<>(); unloadList.forEach(unloadPackageVO -> { @@ -10833,7 +10888,9 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl queryWrapper = new QueryWrapper<>(); queryWrapper.eq("load_id", loadId) .eq("unload_node_id", warehouseId) - .eq("unload_abnormal", 1); + .eq("unload_abnormal", 1) + .eq("is_data", 0) + .orderByDesc("update_time"); List exceptionList = trunklineCarsLoadScanService.list(queryWrapper); TrunklineCarsLoadVO trunklineCarsLoadVO = new TrunklineCarsLoadVO(); diff --git a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineCarsOrderEntityServiceImpl.java b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineCarsOrderEntityServiceImpl.java index cbf3cb2bb..fed869e00 100644 --- a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineCarsOrderEntityServiceImpl.java +++ b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineCarsOrderEntityServiceImpl.java @@ -12,7 +12,6 @@ import lombok.extern.slf4j.Slf4j; import org.springblade.core.mp.base.BaseServiceImpl; import org.springframework.stereotype.Service; -import java.util.Collections; import java.util.List; @Slf4j @@ -169,4 +168,9 @@ public class TrunklineCarsOrderEntityServiceImpl extends BaseServiceImpl findLoadingOrderPlan(Long loadId, Long warehouseId) { + return baseMapper.findLoadingOrderPlan(loadId,warehouseId); + } + }