diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/controller/DistributionDeliveryListController.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/controller/DistributionDeliveryListController.java index 86b3f2cbf..4e1934e55 100644 --- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/controller/DistributionDeliveryListController.java +++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/controller/DistributionDeliveryListController.java @@ -464,7 +464,6 @@ public class DistributionDeliveryListController extends BladeController { @ApiOperationSupport(order = 2) @ApiOperation(value = "PC签收包件") public R signfor(@Valid @RequestBody DistrilbutionAppsignforDTO distrilbutionloadingscanDTO) { - try{ R r = distributionSignforService.signforPC(distrilbutionloadingscanDTO); long time = System.currentTimeMillis(); diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionSignforMapper.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionSignforMapper.java index 08cf275f7..9d8cc30d7 100644 --- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionSignforMapper.java +++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionSignforMapper.java @@ -488,4 +488,11 @@ public interface DistributionSignforMapper extends BaseMapper SELECT received_quantity+receivedin_quantity FROM logpm_distribution_signfor WHERE reservation_id = #{reservationId} + 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 10c012615..d35581e08 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 @@ -9404,10 +9404,6 @@ public class DistributionDeliveryListServiceImpl extends BaseServiceImpl a = bladeRedis.get("warehouseId:" + myCurrentWarehouse.getId() + ":trainNumber:" + deliveryList.getTrainNumber() + ":orderPackageIds:"); if (!Objects.isNull(a)) { @@ -9424,7 +9420,8 @@ public class DistributionDeliveryListServiceImpl extends BaseServiceImpl - r.getReceivingUnit().equals(stockArticleEntity.getConsigneeUnit()) && - r.getMallName().equals(stockArticleEntity.getMallName()) && - r.getId().equals(distrilbutionloadingscanDTO.getReservationId()) + r.getReceivingUnit().equals(stockArticleEntity.getConsigneeUnit()) + && r.getMallName().equals(stockArticleEntity.getMallName()) + && r.getId().equals(distrilbutionloadingscanDTO.getReservationId()) ); if (flag) { List reservationEntities = reservationEntityList.stream().filter(r -> Func.isNotEmpty(r.getConsignee()) @@ -10117,7 +10117,6 @@ public class DistributionDeliveryListServiceImpl extends BaseServiceImpl detailEntities = distributionReservationMapper.selectInventoryListByReservation(distrilbutionloadingscanDTO.getReservationId()); List jsonObjects = new ArrayList<>(); @@ -938,6 +943,9 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl().lambda() .eq(DistributionDeliveryTripartiteEntity::getDeliveryId, distrilbutionloadingscanDTO.getDeliveryId())); BeanUtils.copyProperties(distributionDeliveryTripartiteEntity, distributionDeliverySelfEntity); + distributionDeliverySelfEntity.setVehicleNub(distributionDeliveryTripartiteEntity.getVehicleNum()); } DistributionLoadscaninvnEntity distributionLoadscaninvnEntity = new DistributionLoadscaninvnEntity(); @@ -979,7 +988,7 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl deliverySelfInfo = distributionDeliverySelfMapper.getDeliverySelfInfo(deliveryListEntity.getId()); + DistributionDeliverySelfEntity distributionDeliverySelfEntity = new DistributionDeliverySelfEntity(); + if (deliveryListEntity.getKind().equals(ServiceConstant.DELIVERLIST_KIND_SELF)) { + distributionDeliverySelfEntity = distributionDeliverySelfMapper.selectOne(new QueryWrapper().lambda() + .eq(DistributionDeliverySelfEntity::getIsMaster, ServiceConstant.IS_MASTER_YES) + .eq(DistributionDeliverySelfEntity::getDeliveryId, distrilbutionloadingscanDTO.getDeliveryId()) + ); + } else { + DistributionDeliveryTripartiteEntity distributionDeliveryTripartiteEntity = distributionDeliveryTripartiteMapper.selectOne(new QueryWrapper().lambda() + .eq(DistributionDeliveryTripartiteEntity::getDeliveryId, distrilbutionloadingscanDTO.getDeliveryId())); + BeanUtils.copyProperties(distributionDeliveryTripartiteEntity, distributionDeliverySelfEntity); + distributionDeliverySelfEntity.setVehicleNub(distributionDeliveryTripartiteEntity.getVehicleNum()); + } //在库数 int a = 0; //签收数 @@ -1454,19 +1474,8 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl 2 == f.getIsMaster()).map(DistributionDeliverySelfVO::getDriverPhone).collect(Collectors.joining(",")); - driverName = deliverySelfInfo.stream().filter(f -> 2 == f.getIsMaster()).map(DistributionDeliverySelfVO::getDriverName).collect(Collectors.joining(",")); - vehicleNub = deliverySelfInfo.stream().filter(f -> 2 == f.getIsMaster()).map(DistributionDeliverySelfVO::getVehicleNub).collect(Collectors.joining(",")); - List collect = deliverySelfInfo.stream().filter(f -> 2 == f.getIsMaster()).map(DistributionDeliverySelfVO::getId).collect(Collectors.toList()); - loadingId = collect.get(0); - } else if ("2".equals(deliveryListEntity.getKind())) { - //外协 - } else { - log.error(method + "配送司机异常:{}", distrilbutionloadingscanDTO.getDeliveryId()); - return R.fail("请联系管理员"); + if (isStrictLoading == Integer.parseInt(IsOrNoConstant.yes.getValue())){ + return R.fail("操作失败,存在未装车包件"); } a = distributionParcelNumberDTO.getHandQuantity() - reservationZeroPackageEntities.getQuantity(); b = distributionParcelNumberDTO.getSigninQuantity() + reservationZeroPackageEntities.getQuantity(); @@ -1474,9 +1483,24 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl>>>当前车次:{},异常车次:{}", deliveryListEntity.getTrainNumber(), abnormalEntities.stream().map(DistributionLoadscanAbnormalEntity::getTrainNumber).collect(Collectors.joining(","))); return R.fail(code + "已在其他车次执行异常!!"); } - //判断具体的装车信息 } } List parcelListEntityList = distributionReservationMapper.selectPackageListByReservationId(distrilbutionloadingscanDTO.getReservationId()); @@ -3238,31 +3268,25 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl().lambda() .eq(DistributionDeliveryTripartiteEntity::getDeliveryId, distrilbutionloadingscanDTO.getDeliveryId())); BeanUtils.copyProperties(distributionDeliveryTripartiteEntity, distributionDeliverySelfEntity); + distributionDeliverySelfEntity.setVehicleNub(distributionDeliveryTripartiteEntity.getVehicleNum()); } DistributionDeliveryListEntity listEntity = distributionDeliveryListMapper.selectById(distrilbutionloadingscanDTO.getDeliveryId()); if (Func.isEmpty(listEntity)) { @@ -3346,13 +3374,8 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl>>> 签收推送报错", e); - // } - + distributionSignforMapper.autoDpdateSignfor(distributionReservationEntity.getId()); } else { //一个客户下出现重复包条码 log.error("############出现重复包条码:{}", collect); @@ -3397,7 +3405,7 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl a = bladeRedis.get("warehouseId:" + myCurrentWarehouse.getId() + "trainNumber:" + deliveryListEntity.getTrainNumber() + "orderPackageCode:"); + List a = bladeRedis.get("warehouseId:" + myCurrentWarehouse.getId() + ":trainNumber:" + deliveryListEntity.getTrainNumber() + ":orderPackageCode:"); if (Func.isNotEmpty(a)) { assert a != null; boolean flag = a.stream().anyMatch(any -> packageLockIds.contains(any)); @@ -3406,10 +3414,10 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl list = distributionLoadscanAbnormalService.list(Wrappers.query().lambda() - .eq(DistributionLoadscanAbnormalEntity::getReservationId, distrilbutionloadingscanDTO.getReservationId()) - .eq(DistributionLoadscanAbnormalEntity::getDeliveryListId, distrilbutionloadingscanDTO.getDeliveryId()) - .eq(DistributionLoadscanAbnormalEntity::getPackageCode, distrilbutionloadingscanDTO.getBarcode()) - ); - if (Func.isEmpty(list)) { - DistributionLoadscanAbnormalEntity distributionLoadscanAbnormalEntity = new DistributionLoadscanAbnormalEntity(); - distributionLoadscanAbnormalEntity.setAuditingStatus(LoadingAbnormalAuditingStatusConstant.daishenhe.getValue()); - distributionLoadscanAbnormalEntity.setStockArticleId(parcelListEntity.getStockArticleId()); - distributionLoadscanAbnormalEntity.setTrainNumber(distributionDeliveryListEntity.getTrainNumber()); - distributionLoadscanAbnormalEntity.setDriverName(deliverySelfEntity.getDriverName()); - distributionLoadscanAbnormalEntity.setDriverId(Long.parseLong(deliverySelfEntity.getDriverId())); - distributionLoadscanAbnormalEntity.setDriverPhone(deliverySelfEntity.getDriverPhone()); - distributionLoadscanAbnormalEntity.setDeliveryListId(distributionDeliveryListEntity.getId()); - distributionLoadscanAbnormalEntity.setReservationId(reservationEntity.getId()); - distributionLoadscanAbnormalEntity.setDeliveryType(distributionDeliveryListEntity.getType()); - distributionLoadscanAbnormalEntity.setScanUser(user.getNickName()); - distributionLoadscanAbnormalEntity.setScanTime(new Date()); - distributionLoadscanAbnormalEntity.setLoadingQuantity(parcelListEntity.getQuantity()); - distributionLoadscanAbnormalEntity.setPackageCode(parcelListEntity.getOrderPackageCode()); - distributionLoadscanAbnormalEntity.setPackageId(parcelListEntity.getId()); - distributionLoadscanAbnormalEntity.setLoadingId(loadingId); - distributionLoadscanAbnormalEntity.setAbnormalType(LoadingAbnormalTypeConstant.qianshouyichang.getValue()); - distributionLoadscanAbnormalEntity.setGoodsType(1); - distributionLoadscanAbnormalEntity.setWarehouseId(myCurrentWarehouse.getId()); - distributionLoadscanAbnormalEntity.setWarehouseName(myCurrentWarehouse.getName()); - distributionLoadscanAbnormalEntity.setGoodsType(1); - distributionLoadscanAbnormalEntity.setLoadingId(loadingId); - distributionLoadscanAbnormalEntity.setVehicleId(Long.parseLong(deliverySelfEntity.getVehicleId())); - distributionLoadscanAbnormalEntity.setVehicleName(deliverySelfEntity.getVehicleNub()); - distributionLoadscanAbnormalEntity.setLoadingId(loadingId); - distributionLoadscanAbnormalService.save(distributionLoadscanAbnormalEntity); - } + DistributionLoadscanAbnormalEntity distributionLoadscanAbnormalEntity = new DistributionLoadscanAbnormalEntity(); + distributionLoadscanAbnormalEntity.setAuditingStatus(LoadingAbnormalAuditingStatusConstant.daishenhe.getValue()); + distributionLoadscanAbnormalEntity.setStockArticleId(parcelListEntity.getStockArticleId()); + distributionLoadscanAbnormalEntity.setTrainNumber(distributionDeliveryListEntity.getTrainNumber()); + distributionLoadscanAbnormalEntity.setDriverName(deliverySelfEntity.getDriverName()); + distributionLoadscanAbnormalEntity.setDriverId(Long.parseLong(deliverySelfEntity.getDriverId())); + distributionLoadscanAbnormalEntity.setDriverPhone(deliverySelfEntity.getDriverPhone()); + distributionLoadscanAbnormalEntity.setDeliveryListId(distributionDeliveryListEntity.getId()); + distributionLoadscanAbnormalEntity.setReservationId(reservationEntity.getId()); + distributionLoadscanAbnormalEntity.setDeliveryType(distributionDeliveryListEntity.getType()); + distributionLoadscanAbnormalEntity.setScanUser(user.getNickName()); + distributionLoadscanAbnormalEntity.setScanTime(new Date()); + distributionLoadscanAbnormalEntity.setLoadingQuantity(parcelListEntity.getQuantity()); + distributionLoadscanAbnormalEntity.setPackageCode(parcelListEntity.getOrderPackageCode()); + distributionLoadscanAbnormalEntity.setPackageId(parcelListEntity.getId()); + distributionLoadscanAbnormalEntity.setLoadingId(loadingId); + distributionLoadscanAbnormalEntity.setAbnormalType(LoadingAbnormalTypeConstant.qianshouyichang.getValue()); + distributionLoadscanAbnormalEntity.setGoodsType(1); + distributionLoadscanAbnormalEntity.setWarehouseId(myCurrentWarehouse.getId()); + distributionLoadscanAbnormalEntity.setWarehouseName(myCurrentWarehouse.getName()); + distributionLoadscanAbnormalEntity.setGoodsType(1); + distributionLoadscanAbnormalEntity.setLoadingId(loadingId); + distributionLoadscanAbnormalEntity.setVehicleId(Long.parseLong(deliverySelfEntity.getVehicleId())); + distributionLoadscanAbnormalEntity.setVehicleName(deliverySelfEntity.getVehicleNub()); + distributionLoadscanAbnormalEntity.setLoadingId(loadingId); + distributionLoadscanAbnormalService.save(distributionLoadscanAbnormalEntity); //修改对应的签收为可审核 DistributionSignforEntity signforEntity = distributionSignforMapper.getByReservationId(reservationEntity.getId()); signforEntity.setIsHaveAbnormalPackage(2); @@ -3912,7 +3912,10 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl loadscanEntityList = distributionLoadscanService.list(Wrappers.query().lambda().eq(DistributionLoadscanEntity::getReservationId, distrilbutionloadingscanDTO.getReservationId()).ne(DistributionLoadscanEntity::getScanStatus, LoadingStatusConstant.quxiao.getValue())); + List loadscanEntityList = distributionLoadscanService.list(Wrappers.query().lambda() + .eq(DistributionLoadscanEntity::getReservationId, distrilbutionloadingscanDTO.getReservationId()) + .ne(DistributionLoadscanEntity::getScanStatus, LoadingStatusConstant.quxiao.getValue()) + ); List loadscaninvnEntityList = distributionLoadscaninvnService.list(Wrappers.query().lambda().eq(DistributionLoadscaninvnEntity::getReservationId, distrilbutionloadingscanDTO.getReservationId()).ne(DistributionLoadscaninvnEntity::getScanState, LoadingStatusConstant.quxiao.getValue())); if (Func.isNotEmpty(loadscanEntityList)) { int packSignTotal = loadscanEntityList.stream().filter(l -> Func.equals(l.getSignforState(), LoadScanSigningStatusConstant.yiqianshou.getValue())).mapToInt(DistributionLoadscanEntity::getReceivedQuantity).sum(); @@ -5405,7 +5408,7 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl pushList = new ArrayList<>(); List pushInventoryList = new ArrayList<>(); //配置项 - DistributionDeliverySelfEntity distributionDeliverySelfEntity = this.getDriver(deliveryListEntity,user,distributionDeliveryListService.judgeIsDriver(user)); - if (Objects.isNull(distributionDeliverySelfEntity)){ - return Resp.scanFail("当前操作人无此包件签收权限!!!","当前操作人无此包件签收权限!!!"); + DistributionDeliverySelfEntity distributionDeliverySelfEntity = this.getDriver(deliveryListEntity, user, distributionDeliveryListService.judgeIsDriver(user)); + if (Objects.isNull(distributionDeliverySelfEntity)) { + return Resp.scanFail("当前操作人无此包件签收权限!!!", "当前操作人无此包件签收权限!!!"); } switch (type) { case 1: @@ -7776,10 +7779,9 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl>>>>>>>>>>>>user:{}",user.getNickName()); - log.info("driver>>>>>>>>>>>>>user:{}",driver); + log.info("username>>>>>>>>>>>>>user:{}", user.getNickName()); + log.info("driver>>>>>>>>>>>>>user:{}", driver); if (deliveryListEntity.getKind().equals("1")) { @@ -8840,7 +8846,7 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl>>>>>>>>>>>>:{}",deliverySelfEntity.getDriverName()); + log.info("driverName>>>>>>>>>>>>>:{}", deliverySelfEntity.getDriverName()); if (Objects.isNull(deliverySelfEntity)) { @@ -8910,7 +8916,7 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl>>>>>>>>>>>>:{}",user.getNickName()); + log.info("driverName>>>>>>>>>>>>>:{}", user.getNickName()); signforEntity.setSigneeId(user.getUserId()); return R.data(this.updateById(signforEntity)); } @@ -9028,7 +9034,7 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl 0) { stockArticleEntity.setGenre(1); }