diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionDeliveryListServiceImpl.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionDeliveryListServiceImpl.java index 7201c088b..9e6e43a4b 100644 --- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionDeliveryListServiceImpl.java +++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionDeliveryListServiceImpl.java @@ -5451,6 +5451,10 @@ public class DistributionDeliveryListServiceImpl extends BaseServiceImpl page, Long deliveryId, Long orderId) { + BasicdataWarehouseEntity myCurrentWarehouse = warehouseClient.getMyCurrentWarehouse(); + if (Func.isEmpty(myCurrentWarehouse)){ + return R.fail(403,"未授权!!!"); + } List allPackageList = new ArrayList<>(); List reservationPackageList = baseMapper.getPackageListByDeliveryId(deliveryId, orderId); DistributionReservationOrderPackageVO reservationOrderPackageVO = new DistributionReservationOrderPackageVO(); @@ -5458,6 +5462,7 @@ public class DistributionDeliveryListServiceImpl extends BaseServiceImpl parcelListEntityLambdaQueryWrapper = Wrappers.query().lambda() .notIn(DistributionParcelListEntity::getOrderPackageStatus, OrderPackageStatusConstant.yiqianshou.getValue(), OrderPackageStatusConstant.yichuku.getValue()) .ne(DistributionParcelListEntity::getOrderPackageLoadingStatus, OrderPackageLoadingStatusConstant.yizhuangche.getValue()) + .eq(DistributionParcelListEntity::getWarehouseId, myCurrentWarehouse.getId()) .eq(DistributionParcelListEntity::getStockArticleId, orderId); if (Func.isNotEmpty(reservationPackageList)) { List packageIds = reservationPackageList.stream().map(DistributionParcelListEntity::getId).collect(Collectors.toList()); @@ -7025,7 +7030,7 @@ public class DistributionDeliveryListServiceImpl extends BaseServiceImpl distributionStockArticleEntities = distributionStockArticleService.listByIds(ids); if (!distributionStockArticleEntities.isEmpty()) { String orderCodes = distributionStockArticleEntities.stream().map(DistributionStockArticleEntity::getOrderCode).distinct().collect(Collectors.joining(",\n")); - return R.fail(orderCodes+"当前订单已装车,请滞留后进行移除"); + return R.fail(orderCodes + "当前订单已装车,请滞留后进行移除"); } } return R.data(true); @@ -7287,7 +7292,7 @@ public class DistributionDeliveryListServiceImpl extends BaseServiceImpl deliveryListEntity.getId().equals(a.getDeliveryId())); - if (isSatisfy){ + if (isSatisfy) { //本车次的异常装车 DistributionLoadscanEntity distributionLoadscanEntity = loadscanEntityList.get(0); - if (distributionLoadscanEntity.equals("2")){ + if (distributionLoadscanEntity.equals("2")) { //进行异常签收的标识 //存在装车数据 distributionLoadscanEntity.setSigningTime(simpleDateFormat.format(new Date())); @@ -7449,10 +7454,10 @@ public class DistributionDeliveryListServiceImpl extends BaseServiceImpl warehouseIds = new ArrayList<>(); + //当前登录人选择的仓库 + BasicdataWarehouseEntity myCurrentWarehouse = warehouseClient.getMyCurrentWarehouse(); + if(Objects.isNull(myCurrentWarehouse)){ + List myWatchWarehouse = warehouseClient.getMyWatchWarehouse(); + myWatchWarehouse.forEach(warehouseEntity -> { + warehouseIds.add(warehouseEntity.getId()); + }); + }else{ + warehouseIds.add(myCurrentWarehouse.getId()); + } + indexDTO.setWarehouseIds(warehouseIds); + + //查询订制品打托列表 + IndexUnloadAbnormalDataVO indexUnloadAbnormalDataVO = warehouseIndexService.unloadAbnormalData(indexDTO); + return R.data(indexUnloadAbnormalDataVO); + }catch (CustomerException e){ + log.warn(e.message); + return R.fail(e.code,e.message); + }catch (Exception e){ + log.error(method+"系统异常,联系管理员",e); + return R.fail(500,"系统异常,联系管理员"); + } + } + + }