From dc0b51ccd9c3d477eac100faa13c72e769a80f72 Mon Sep 17 00:00:00 2001 From: kilo Date: Thu, 2 Nov 2023 18:57:33 +0800 Subject: [PATCH 1/3] =?UTF-8?q?=E5=A2=9E=E5=80=BC=E6=9C=8D=E5=8A=A1?= =?UTF-8?q?=E9=9B=B6=E6=8B=85=E7=BC=96=E8=BE=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../vo/DistributionAddvaluePackageVO.java | 8 ++ .../DistributionAddvalueAppController.java | 5 - .../DistributionSignforController.java | 2 +- .../DistributionAddvalueDetailMapper.java | 4 +- .../DistributionAddvalueDetailMapper.xml | 8 +- .../mapper/DistributionAddvalueMapper.xml | 1 + .../DistributionAddvaluePackageMapper.java | 2 +- .../mapper/DistributionDeliveryInfoMapper.xml | 4 +- .../mapper/DistributionReservationMapper.xml | 3 +- .../mapper/DistributionSignforMapper.xml | 1 + .../impl/DistributionAddvalueServiceImpl.java | 37 +++---- .../impl/DistributionAsyncServiceImpl.java | 1 - .../DistributionDeliveryListServiceImpl.java | 101 ++++++++++++++++-- .../impl/DistributionSignforServiceImpl.java | 60 +++++++++-- 14 files changed, 187 insertions(+), 50 deletions(-) diff --git a/blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/vo/DistributionAddvaluePackageVO.java b/blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/vo/DistributionAddvaluePackageVO.java index a716b2e07..f05b5a9ee 100644 --- a/blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/vo/DistributionAddvaluePackageVO.java +++ b/blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/vo/DistributionAddvaluePackageVO.java @@ -32,6 +32,14 @@ import lombok.EqualsAndHashCode; public class DistributionAddvaluePackageVO extends DistributionAddvaluePackageEntity { private static final long serialVersionUID = 1L; + /** + * 最大操作数量 零担需要先进行装车 + */ private Integer maxQuantity; + /** + * 计划数量 + */ + private Integer planQuantity; + } diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/appcontroller/DistributionAddvalueAppController.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/appcontroller/DistributionAddvalueAppController.java index 4135ac484..bf3201df7 100644 --- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/appcontroller/DistributionAddvalueAppController.java +++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/appcontroller/DistributionAddvalueAppController.java @@ -95,7 +95,6 @@ public class DistributionAddvalueAppController { return r; } - /** * 编辑保存 */ @@ -107,8 +106,6 @@ public class DistributionAddvalueAppController { return r; } - - /** * 查询编辑增值服务数据 */ @@ -120,8 +117,6 @@ public class DistributionAddvalueAppController { return r; } - - /** * 查询增值服务数据 */ diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/controller/DistributionSignforController.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/controller/DistributionSignforController.java index c995518c2..33ca15b5d 100644 --- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/controller/DistributionSignforController.java +++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/controller/DistributionSignforController.java @@ -130,7 +130,7 @@ public class DistributionSignforController extends BladeController { @ApiOperationSupport(order = 1) @ApiOperation(value = "详情", notes = "传入distributionSignfor") public R> signforPackageList(Long signforId) { - List distributionSignforsnmbVO = distributionSignforService.signforPackageList(signforId); + List distributionSignforsnmbVO= distributionSignforService.signforPackageList(signforId); return R.data(distributionSignforsnmbVO); } diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionAddvalueDetailMapper.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionAddvalueDetailMapper.java index 6cc5af367..f06dbdf17 100644 --- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionAddvalueDetailMapper.java +++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionAddvalueDetailMapper.java @@ -53,7 +53,7 @@ public interface DistributionAddvalueDetailMapper extends BaseMapper - + @@ -27,7 +28,7 @@ - DELETE FROM logpm_distribution_addvalue_detil WHERE addvalue_id = #{addvalueId} + DELETE FROM logpm_distribution_addvalue_detail WHERE addvalue_id = #{addvalueId} @@ -36,7 +37,8 @@ - SELECT * FROM logpm_distribution_addvalue_detail ${ew.customSqlSegment} diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionAddvalueMapper.xml b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionAddvalueMapper.xml index cd9be75a7..c651c45dc 100644 --- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionAddvalueMapper.xml +++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionAddvalueMapper.xml @@ -61,6 +61,7 @@ ldad.num AS num, ldad.flool_num AS floolNum, ldad.distance AS distance, + lda.addvalue_id AS addvalueId, ldad.id AS addvalueDetailId, GROUP_CONCAT(ldap.package_id) AS packageListIds, ldad.record_type AS isAll diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionAddvaluePackageMapper.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionAddvaluePackageMapper.java index 373f0c89b..bc6ce2c25 100644 --- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionAddvaluePackageMapper.java +++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionAddvaluePackageMapper.java @@ -57,7 +57,7 @@ public interface DistributionAddvaluePackageMapper extends BaseMapper @@ -1037,7 +1038,7 @@ resultType="com.logpm.distribution.vo.DistributionAddvaluePackageVO"> SELECT ldrzp.parcel_list_id, - ldrzp.quantity AS quantity, + ldrzp.quantity AS reservationNum, ldrzp.reservation_id AS reservationId, 3 AS conditions, ldsa.order_code AS orderCode, diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionSignforMapper.xml b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionSignforMapper.xml index 52a095749..5f8c92620 100644 --- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionSignforMapper.xml +++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionSignforMapper.xml @@ -555,6 +555,7 @@ CASE WHEN lds.positioning IS NOT NULL THEN true ELSE false END AS positioning, (SELECT COALESCE(COUNT(*), 0) from logpm_distribution_reservation_stockarticle ldrs WHERE ldrs.reservation_id =ldr.id ) ordNub, COALESCE(lds.received_quantity + lds.receivedin_quantity, 0) signNub, + COALESCE(lds.loaded_number + lds.loadedin_number, 0) signNub, COALESCE(ldr.reservation_num + ldr.reservation_stock_list_num, 0) reservationNum FROM logpm_distribution_signfor lds diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionAddvalueServiceImpl.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionAddvalueServiceImpl.java index 716cc075b..c94cbc85f 100644 --- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionAddvalueServiceImpl.java +++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionAddvalueServiceImpl.java @@ -190,18 +190,20 @@ public class DistributionAddvalueServiceImpl extends BaseServiceImpl packageEntityList = distributionAppAddvalueDTO.getPackageEntityList().stream().filter(p->p.getQuantity()>0).collect(Collectors.toList()); + List packageEntityList = distributionAppAddvalueDTO.getPackageEntityList(); + List packageDTOList = packageEntityList.stream().filter(p -> Func.isNotEmpty(p.getQuantity()) && p.getQuantity() > 0).collect(Collectors.toList()); + if (Func.isEmpty(packageDTOList)){ + return Resp.scanFail("操作失败","无可用包件信息"); + } //查询是否重复添加 DistributionAddvalueEntity addvalueEntity = distributionAddvalueMapper.selectOne(Wrappers.query().lambda() .eq(DistributionAddvalueEntity::getAddvalueId, distributionAppAddvalueDTO.getAddvalueType()) .eq(DistributionAddvalueEntity::getRefId, distributionAppAddvalueDTO.getReservationId()) .eq(DistributionAddvalueEntity::getRefType, 1)); + if (Func.isNotEmpty(addvalueEntity)){ return Resp.scanFail("操作失败", "存在该类型增值服务项,如需更改请编辑"); } - if (Func.isEmpty(packageEntityList)) { - return Resp.scanFail("请添加包件", "请添加包件"); - } DistributionAddvalueDetailEntity distributionAddvalueDetailEntity = new DistributionAddvalueDetailEntity(); if (Func.isEmpty(distributionAppAddvalueDTO.getNum())) { return Resp.scanFail("添加失败", "错误的包件数量"); @@ -211,7 +213,6 @@ public class DistributionAddvalueServiceImpl extends BaseServiceImplquery().lambda() + .eq(DistributionAddvalueEntity::getRefId, distributionAppAddvalueDTO.getReservationId()) + .eq(DistributionAddvalueEntity::getAddvalueId, distributionAppAddvalueDTO.getAddvalueType())); + DistributionAddvalueDetailEntity addvalueDetailEntity = distributionAddvalueDetailService.getOne(Wrappers.query().lambda() + .eq(DistributionAddvalueDetailEntity::getAddvalueId, distributionAddvalueEntity.getId())); + distributionAddvaluePackageMapper.deleteAddvaluePackageList(distributionAppAddvalueDTO.getReservationId(), addvalueDetailEntity.getId()); + distributionAddvalueDetailMapper.deleteAddvalueDetail(distributionAddvalueEntity.getId()); + distributionAddvalueMapper.deleteAddvalue(distributionAppAddvalueDTO.getReservationId(), distributionAppAddvalueDTO.getAddvalueType()); + return Resp.scanSuccess("操作成功","操作成功"); + } switch (distributionAppAddvalueDTO.getAddvalueType()) { case "1": if (Func.isEmpty(distributionAppAddvalueDTO.getFloolNum())) { @@ -377,18 +390,6 @@ public class DistributionAddvalueServiceImpl extends BaseServiceImplquery().lambda() - .eq(DistributionAddvalueEntity::getRefId, distributionAppAddvalueDTO.getReservationId()) - .eq(DistributionAddvalueEntity::getAddvalueId, distributionAppAddvalueDTO.getAddvalueType())); - DistributionAddvalueDetailEntity addvalueDetailEntity = distributionAddvalueDetailService.getOne(Wrappers.query().lambda() - .eq(DistributionAddvalueDetailEntity::getAddvalueId, distributionAddvalueEntity.getId())); - - distributionAddvalueMapper.deleteAddvalue(distributionAppAddvalueDTO.getReservationId(), distributionAppAddvalueDTO.getAddvalueType()); - distributionAddvalueDetailMapper.deleteAddvalueDetail(distributionAddvalueEntity.getId()); - distributionAddvaluePackageMapper.deleteAddvaluePackageList(distributionAppAddvalueDTO.getReservationId(), addvalueDetailEntity.getId()); - } else { //查询出原来的包件信息 DistributionAddvalueVO addvalueVO = distributionAddvalueMapper.selectReservationAddvalue(distributionAppAddvalueDTO.getReservationId(), distributionAppAddvalueDTO.getAddvalueType()); String packageListIds = addvalueVO.getPackageListIds(); @@ -454,7 +455,7 @@ public class DistributionAddvalueServiceImpl extends BaseServiceImpl customList = distributionDeliveryInfoMapper.selectAppcustomListPage(page, distributionDeliveryList.getId()); for (DistributionAppReservationVO distributionAppReservationVO : customList) { - List parcelListEntities = distributionReservationMapper.selectPackageListByReservationId(distributionAppReservationVO.getId()); + List reservationStockarticleEntityList = distributionReservationMapper.selectStockArticleByReservationId(distributionAppReservationVO.getId()); + List distributionStockEntities = new ArrayList<>(); + List loadscanEntityList = new ArrayList<>(); + List trayList = new ArrayList<>(); + for (DistributionReservationStockarticleEntity reservationStockarticleEntity : reservationStockarticleEntityList) { + if (reservationStockarticleEntity.equals(IsOrNoConstant.no.getValue())){ + //查询订制品备货数量 + List packageListStockUpScan = distributionStockMapper.selectList(Wrappers.query().lambda() + .eq(DistributionStockEntity::getType, 1) + .eq(DistributionStockEntity::getParcelListId, reservationStockarticleEntity.getStockArticleId()) + .eq(DistributionStockEntity::getReservationId, reservationStockarticleEntity.getReservationId())); + if (Func.isNotEmpty(packageListStockUpScan)){ + distributionStockEntities.addAll(packageListStockUpScan); + } + //统计托盘数 + //查询所有包件 + List parcelListEntities = distributionReservationMapper.selectPackageByReservationAndStockArticle(reservationStockarticleEntity.getReservationId(), reservationStockarticleEntity.getStockArticleId()); + parcelListEntities.forEach(p->{ + WarehouseTrayGoodsEntity warehouseTrayGoodsEntity = new WarehouseTrayGoodsEntity(); + warehouseTrayGoodsEntity.setAssociationId(p.getId()); + warehouseTrayGoodsEntity.setAssociationType("1"); + List trayGoodsClientTrayList = warehouseTrayGoodsClient.getTrayList(warehouseTrayGoodsEntity); + if (Func.isNotEmpty(trayGoodsClientTrayList)){ + trayList.addAll(trayGoodsClientTrayList); + } + }); + //查询订制品装车数量 + List packageListLoadingScan = distributionLoadscanService.list(Wrappers.query().lambda() + .eq(DistributionLoadscanEntity::getReservationId, reservationStockarticleEntity.getReservationId()) + .eq(DistributionLoadscanEntity::getOrderId, reservationStockarticleEntity.getStockArticleId()) + .ne(DistributionLoadscanEntity::getScanStatus, LoadingStatusConstant.quxiao.getValue())); + if (Func.isNotEmpty(packageListLoadingScan)){ + loadscanEntityList.addAll(packageListLoadingScan); + } + + }else if (reservationStockarticleEntity.equals(IsOrNoConstant.yes.getValue())){ + //查询零担备货数量 + List zeroPackageListStockUpScan = distributionStockMapper.selectList(Wrappers.query().lambda() + .eq(DistributionStockEntity::getType, 2) + .eq(DistributionStockEntity::getParcelListId, reservationStockarticleEntity.getStockArticleId()) + .eq(DistributionStockEntity::getReservationId, reservationStockarticleEntity.getReservationId())); + if (Func.isNotEmpty(zeroPackageListStockUpScan)){ + distributionStockEntities.addAll(zeroPackageListStockUpScan); + } + //查询零担装车数量 + List zeroPackageListLoadingScan = distributionLoadscanService.list(Wrappers.query().lambda() + .eq(DistributionLoadscanEntity::getReservationId, reservationStockarticleEntity.getReservationId()) + .eq(DistributionLoadscanEntity::getOrderId, reservationStockarticleEntity.getStockArticleId()) + .ne(DistributionLoadscanEntity::getScanStatus, LoadingStatusConstant.quxiao.getValue())); + if (Func.isNotEmpty(zeroPackageListLoadingScan)){ + loadscanEntityList.addAll(zeroPackageListLoadingScan); + } + } + } + distributionAppReservationVO.setTrayNum(0); + if (Func.isNotEmpty(trayList)){ + Long count = trayList.stream().map(WarehouseTrayGoodsEntity::getTrayId).count(); + distributionAppReservationVO.setTrayNum(count.intValue()); + } List stockListDetailEntityList = distributionReservationMapper.selectInventoryListByReservation(distributionAppReservationVO.getId()); - boolean stockArticleStockupStatus = parcelListEntities.stream().allMatch(s -> Func.isNotEmpty(s.getOrderPackageStockupStatus()) && s.getOrderPackageStockupStatus().equals(OrderPackageStockupStatusConstant.yibeihu.getValue())); - boolean inventoryStockupStatus = stockListDetailEntityList.stream().allMatch(i -> Func.isNotEmpty(i.getStockPackageCode())); - if (stockArticleStockupStatus && inventoryStockupStatus) { +// boolean inventoryStockupStatus = stockListDetailEntityList.stream().allMatch(i -> Func.isNotEmpty(i.getStockPackageCode())); + //备货数和计划数一致时完成备货 + if (distributionStockEntities.size()+stockListDetailEntityList.stream().filter(s->Func.isNotEmpty(s.getStockPackageCode())).count() == distributionAppReservationVO.getReservationNum()){ distributionAppReservationVO.setIsstock("是"); - } else { + }else { distributionAppReservationVO.setIsstock("否"); } - boolean stockArticleLoadingStatus = parcelListEntities.stream().allMatch(s -> Func.isNotEmpty(s.getOrderPackageLoadingStatus()) && s.getOrderPackageLoadingStatus().equals(OrderPackageLoadingStatusConstant.yizhuangche.getValue())); - boolean inventoryLoadingStatus = stockListDetailEntityList.stream().allMatch(i -> Func.isNotEmpty(i.getStockPackageCode()) && i.getStockLockingStatus().equals(InventoryLoadingStatusConstant.yizhuangche.getValue())); - if (stockArticleLoadingStatus && inventoryLoadingStatus) { + int packageListScanNum = loadscanEntityList.stream().mapToInt(DistributionLoadscanEntity::getLoadedNub).sum(); + long inventoryListScanNum = stockListDetailEntityList.stream().filter(i -> Func.isNotEmpty(i.getStockPackageCode()) && i.getStockLockingStatus().equals(InventoryLoadingStatusConstant.yizhuangche.getValue())).count(); + + if (packageListScanNum + inventoryListScanNum ==distributionAppReservationVO.getReservationNum() ) { distributionAppReservationVO.setIsload("是"); } else { distributionAppReservationVO.setIsload("否"); - } + + + + + +// List parcelListEntities = distributionReservationMapper.selectPackageListByReservationId(distributionAppReservationVO.getId()); +// +// boolean stockArticleStockupStatus = parcelListEntities.stream().allMatch(s -> Func.isNotEmpty(s.getOrderPackageStockupStatus()) && s.getOrderPackageStockupStatus().equals(OrderPackageStockupStatusConstant.yibeihu.getValue())); +// if (stockArticleStockupStatus && inventoryStockupStatus) { +// distributionAppReservationVO.setIsstock("是"); +// } else { +// distributionAppReservationVO.setIsstock("否"); +// } +// boolean stockArticleLoadingStatus = parcelListEntities.stream().allMatch(s -> Func.isNotEmpty(s.getOrderPackageLoadingStatus()) && s.getOrderPackageLoadingStatus().equals(OrderPackageLoadingStatusConstant.yizhuangche.getValue())); +// boolean inventoryLoadingStatus = stockListDetailEntityList.stream().allMatch(i -> Func.isNotEmpty(i.getStockPackageCode()) && i.getStockLockingStatus().equals(InventoryLoadingStatusConstant.yizhuangche.getValue())); +// if (stockArticleLoadingStatus && inventoryLoadingStatus) { +// distributionAppReservationVO.setIsload("是"); +// } else { +// distributionAppReservationVO.setIsload("否"); +// } + + // //查询备货是否完成 // int aLong = distributionStockMapper.selectCount(new QueryWrapper().lambda() // .eq(DistributionStockEntity::getReservationId, distributionAppReservationVO.getId()) diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionSignforServiceImpl.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionSignforServiceImpl.java index 276d4559c..eebc5ea33 100644 --- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionSignforServiceImpl.java +++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionSignforServiceImpl.java @@ -287,7 +287,7 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl parcelListEntities = baseMapper.getSignforPackageList(signforEntity.getReservationId()); - List reservationStockarticleEntityList = distributionReservationStockarticleService.list(Wrappers.query().lambda().eq(DistributionReservationStockarticleEntity::getReservationId, signforEntity.getReservationId()).ne(DistributionReservationStockarticleEntity::getStockArticleStatus, ReservationOrderStatusConstant.quxiao.getValue())); + List reservationStockarticleEntityList = distributionReservationStockarticleService.list(Wrappers.query().lambda() + .eq(DistributionReservationStockarticleEntity::getReservationId, signforEntity.getReservationId()) + .ne(DistributionReservationStockarticleEntity::getStockArticleStatus, ReservationOrderStatusConstant.quxiao.getValue())); List parcelListVOS = new ArrayList<>(); if (Func.isNotEmpty(reservationStockarticleEntityList)){ reservationStockarticleEntityList.forEach(rs->{ @@ -1843,6 +1845,9 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl parcelListEntityList = distributionReservationMapper.selectPackageByReservationAndStockArticle(rs.getReservationId(), rs.getStockArticleId()); List parcelListVOList = DistributionParcelListWrapper.build().listVO(parcelListEntityList); parcelListVOList.forEach(p -> { + p.setReservationNum(p.getQuantity()); + p.setLoadingNub(0); + p.setSigningNub(0); DistributionLoadscanEntity distributionLoadscanEntity = distributionLoadscanMapper.selectOne(Wrappers.query().lambda().eq(DistributionLoadscanEntity::getPackageId, p.getId())); if (Func.isNotEmpty(distributionLoadscanEntity)) { //该包件存在扫描记录 @@ -1861,6 +1866,8 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl distributionParcelNumberDTOS = distributionReservationMapper.selectZeroPackageListByReservationId(rs.getReservationId()); + distributionParcelNumberDTOS.forEach(zp->{ + DistributionParcelListEntity parcelListEntity = distributionParcelListService.getById(zp.getParcelListId()); + DistributionParcelListVO parcelListVO = DistributionParcelListWrapper.build().entityVO(parcelListEntity); +// DistributionParcelListVO parcelListVO = Func.copy(parcelListEntity, DistributionParcelListVO.class); +// parcelListVO.setReservationNum(zp.get); + parcelListVO.setReservationNum(zp.getReservationNum()); + parcelListVO.setLoadingNub(0); + parcelListVO.setSigningNub(0); + DistributionLoadscanEntity distributionLoadscanEntity = distributionLoadscanMapper.selectOne(Wrappers.query().lambda() + .eq(DistributionLoadscanEntity::getPackageId, zp.getParcelListId()) + .eq(DistributionLoadscanEntity::getReservationId,rs.getReservationId())); + if (Func.isNotEmpty(distributionLoadscanEntity)) { + //该包件存在扫描记录 + String scanStatus = distributionLoadscanEntity.getScanStatus(); + switch (scanStatus) { + case "1": + parcelListVO.setScanStatus(LoadingStatusConstant.quxiao.getName()); + break; + case "2": + parcelListVO.setScanStatus(LoadingStatusConstant.saomiao.getName()); + break; + case "3": + parcelListVO.setScanStatus(LoadingStatusConstant.queren.getName()); + break; + case "4": + parcelListVO.setScanStatus(LoadingStatusConstant.yijianzhuangche.getName()); + break; + } + parcelListVO.setLoadingNub(distributionLoadscanEntity.getLoadedNub()); + parcelListVO.setSigningNub(distributionLoadscanEntity.getReceivedQuantity()); + if (Func.isNotEmpty(distributionLoadscanEntity.getSigningTime())) { + parcelListVO.setSigningTime(distributionLoadscanEntity.getSigningTime()); + } + if (Func.isNotEmpty(distributionLoadscanEntity.getScanUser())) { + parcelListVO.setScanUser(distributionLoadscanEntity.getScanUser()); + } + if (Func.isNotEmpty(distributionLoadscanEntity.getDriverName())) { + parcelListVO.setDriverName(distributionLoadscanEntity.getDriverName()); + } + } + parcelListVOS.add(parcelListVO); + }); } }); } - - return parcelListVOS; } From cb52e3a7713c7183a3dcfeaab66a38a5c934d1d7 Mon Sep 17 00:00:00 2001 From: "pref_mail@163.com" <123456> Date: Thu, 2 Nov 2023 20:49:35 +0800 Subject: [PATCH 2/3] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E7=99=BB=E5=BD=95?= =?UTF-8?q?=E4=BB=93=E5=BA=93=E7=9A=84=E6=9F=A5=E8=AF=A2=E7=BC=93=E5=AD=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../BasicdataWarehouseController.java | 19 ++++++++++++++++++- .../factory/receiver/OrderStatusHandler.java | 1 - 2 files changed, 18 insertions(+), 2 deletions(-) diff --git a/blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/controller/BasicdataWarehouseController.java b/blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/controller/BasicdataWarehouseController.java index 7ecfb97b0..6d6bbfd1f 100644 --- a/blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/controller/BasicdataWarehouseController.java +++ b/blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/controller/BasicdataWarehouseController.java @@ -18,6 +18,7 @@ package com.logpm.basicdata.controller; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; +import com.baomidou.mybatisplus.core.toolkit.ObjectUtils; import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport; import com.logpm.basicdata.dto.BasicdataWarehouseDTO; import com.logpm.basicdata.entity.BasicdataWarehouseEntity; @@ -33,9 +34,11 @@ import io.swagger.annotations.ApiParam; import lombok.AllArgsConstructor; import lombok.extern.log4j.Log4j2; import org.springblade.core.boot.ctrl.BladeController; +import org.springblade.core.cache.utils.CacheUtil; import org.springblade.core.excel.util.ExcelUtil; import org.springblade.core.mp.support.Condition; import org.springblade.core.mp.support.Query; +import org.springblade.core.redis.cache.BladeRedis; import org.springblade.core.secure.BladeUser; import org.springblade.core.tool.api.R; import org.springblade.core.tool.constant.BladeConstant; @@ -66,6 +69,8 @@ public class BasicdataWarehouseController extends BladeController { private final IBasicdataWarehouseClient basicdataWarehouseClient; + private final BladeRedis bladeRedis; + /** * 仓库 详情 */ @@ -178,6 +183,7 @@ public class BasicdataWarehouseController extends BladeController { @ApiOperation(value = "新增", notes = "传入warehouseWarehouse") public R save(@Valid @RequestBody BasicdataWarehouseEntity warehouseWarehouse) { warehouseWarehouse.setEnableStatus("2"); + CacheUtil.evict("getMyWarehouseList","basicdata","WarehouseList"); return R.status(warehouseService.save(warehouseWarehouse)); } @@ -198,6 +204,7 @@ public class BasicdataWarehouseController extends BladeController { @ApiOperationSupport(order = 6) @ApiOperation(value = "新增或修改", notes = "传入warehouseWarehouse") public R submit(@Valid @RequestBody BasicdataWarehouseEntity warehouseWarehouse) { + CacheUtil.evict("getMyWarehouseList","basicdata","WarehouseList"); return R.status(warehouseService.saveOrUpdate(warehouseWarehouse)); } @@ -211,6 +218,9 @@ public class BasicdataWarehouseController extends BladeController { @ApiOperationSupport(order = 7) @ApiOperation(value = "逻辑删除", notes = "传入ids") public R remove(@ApiParam(value = "主键集合", required = true) @RequestParam String ids) { + + CacheUtil.evict("getMyWarehouseList","basicdata","WarehouseList"); + boolean result = warehouseService.removeWarehouse(ids); if (result) { return R.status(true); @@ -274,7 +284,14 @@ public class BasicdataWarehouseController extends BladeController { @GetMapping("/getMyWarehouseList") @ApiOperationSupport(order = 3) public R> getMyWarehouseList() { - List basicdataGoodsShelfVOList = warehouseService.getMyWarehouseList(); + + List basicdataGoodsShelfVOList = CacheUtil.get("getMyWarehouseList", "basicdata", "WarehouseList",List.class); + + if(ObjectUtils.isNull(basicdataGoodsShelfVOList)){ + basicdataGoodsShelfVOList = warehouseService.getMyWarehouseList(); + CacheUtil.put("getMyWarehouseList","basicdata","WarehouseList",basicdataGoodsShelfVOList); + } + return R.data(basicdataGoodsShelfVOList); } diff --git a/blade-service/logpm-factory/src/main/java/com/logpm/factory/receiver/OrderStatusHandler.java b/blade-service/logpm-factory/src/main/java/com/logpm/factory/receiver/OrderStatusHandler.java index 9c75565c4..46233ed0e 100644 --- a/blade-service/logpm-factory/src/main/java/com/logpm/factory/receiver/OrderStatusHandler.java +++ b/blade-service/logpm-factory/src/main/java/com/logpm/factory/receiver/OrderStatusHandler.java @@ -97,7 +97,6 @@ public class OrderStatusHandler { break; case FactoryConstant.OUPAI: - // todo cangku peizhi xinxi cunzai went // r = ouPaiFactoryService.handleStatusData(orderStatusDTO); // if (r.getCode() == 400 || r.getCode() == 200) { // log.info("TAG {} ##################orderStatusHandler: 该条数据不用处理 orderNo={}", FactoryConstant.OUPAI, orderSelfNum); From 25da9cbdc672fa3732e2ced1057e918f84530f72 Mon Sep 17 00:00:00 2001 From: "pref_mail@163.com" <123456> Date: Thu, 2 Nov 2023 21:33:35 +0800 Subject: [PATCH 3/3] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E4=BB=93=E5=BA=93?= =?UTF-8?q?=E7=9A=84=E7=BC=93=E5=AD=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../common/cache/CacheObjNames.java | 33 +++++++++++++++++++ .../BasicdataWarehouseController.java | 16 ++++++--- .../impl/BasicdataWarehouseServiceImpl.java | 14 +++----- 3 files changed, 48 insertions(+), 15 deletions(-) create mode 100644 blade-biz-common/src/main/java/org/springblade/common/cache/CacheObjNames.java diff --git a/blade-biz-common/src/main/java/org/springblade/common/cache/CacheObjNames.java b/blade-biz-common/src/main/java/org/springblade/common/cache/CacheObjNames.java new file mode 100644 index 000000000..960924ddd --- /dev/null +++ b/blade-biz-common/src/main/java/org/springblade/common/cache/CacheObjNames.java @@ -0,0 +1,33 @@ +package org.springblade.common.cache; + +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.Getter; + +/** + * 系统查询缓存名称定义 + */ +@AllArgsConstructor +@Getter +public enum CacheObjNames { + + /** + * 基础数据模块 当前登陆人操作仓库的缓存 + */ + basic_data_warehourse_list("getMyWarehouseList","basicdataWarehouseList"); + + + /** + * 缓存名称 + */ + final String cacheName; + + + /** + * 缓存前缀 + */ + final String keyPrefix; + + + +} diff --git a/blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/controller/BasicdataWarehouseController.java b/blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/controller/BasicdataWarehouseController.java index 6d6bbfd1f..dfa8f2ad6 100644 --- a/blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/controller/BasicdataWarehouseController.java +++ b/blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/controller/BasicdataWarehouseController.java @@ -33,6 +33,7 @@ import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiParam; import lombok.AllArgsConstructor; import lombok.extern.log4j.Log4j2; +import org.springblade.common.cache.CacheObjNames; import org.springblade.core.boot.ctrl.BladeController; import org.springblade.core.cache.utils.CacheUtil; import org.springblade.core.excel.util.ExcelUtil; @@ -40,6 +41,7 @@ import org.springblade.core.mp.support.Condition; import org.springblade.core.mp.support.Query; import org.springblade.core.redis.cache.BladeRedis; import org.springblade.core.secure.BladeUser; +import org.springblade.core.secure.utils.AuthUtil; import org.springblade.core.tool.api.R; import org.springblade.core.tool.constant.BladeConstant; import org.springblade.core.tool.utils.DateUtil; @@ -182,8 +184,9 @@ public class BasicdataWarehouseController extends BladeController { @ApiOperationSupport(order = 4) @ApiOperation(value = "新增", notes = "传入warehouseWarehouse") public R save(@Valid @RequestBody BasicdataWarehouseEntity warehouseWarehouse) { + BladeUser user = AuthUtil.getUser(); + CacheUtil.evict(CacheObjNames.basic_data_warehourse_list.getCacheName(), CacheObjNames.basic_data_warehourse_list.getKeyPrefix(),user.getUserId()); warehouseWarehouse.setEnableStatus("2"); - CacheUtil.evict("getMyWarehouseList","basicdata","WarehouseList"); return R.status(warehouseService.save(warehouseWarehouse)); } @@ -204,7 +207,8 @@ public class BasicdataWarehouseController extends BladeController { @ApiOperationSupport(order = 6) @ApiOperation(value = "新增或修改", notes = "传入warehouseWarehouse") public R submit(@Valid @RequestBody BasicdataWarehouseEntity warehouseWarehouse) { - CacheUtil.evict("getMyWarehouseList","basicdata","WarehouseList"); + BladeUser user = AuthUtil.getUser(); + CacheUtil.evict(CacheObjNames.basic_data_warehourse_list.getCacheName(), CacheObjNames.basic_data_warehourse_list.getKeyPrefix(),user.getUserId()); return R.status(warehouseService.saveOrUpdate(warehouseWarehouse)); } @@ -218,8 +222,9 @@ public class BasicdataWarehouseController extends BladeController { @ApiOperationSupport(order = 7) @ApiOperation(value = "逻辑删除", notes = "传入ids") public R remove(@ApiParam(value = "主键集合", required = true) @RequestParam String ids) { + BladeUser user = AuthUtil.getUser(); - CacheUtil.evict("getMyWarehouseList","basicdata","WarehouseList"); + CacheUtil.evict(CacheObjNames.basic_data_warehourse_list.getCacheName(), CacheObjNames.basic_data_warehourse_list.getKeyPrefix(),user.getUserId()); boolean result = warehouseService.removeWarehouse(ids); if (result) { @@ -285,11 +290,12 @@ public class BasicdataWarehouseController extends BladeController { @ApiOperationSupport(order = 3) public R> getMyWarehouseList() { - List basicdataGoodsShelfVOList = CacheUtil.get("getMyWarehouseList", "basicdata", "WarehouseList",List.class); + BladeUser user = AuthUtil.getUser(); + List basicdataGoodsShelfVOList = CacheUtil.get(CacheObjNames.basic_data_warehourse_list.getCacheName(), CacheObjNames.basic_data_warehourse_list.getKeyPrefix(), user.getUserId(),List.class); if(ObjectUtils.isNull(basicdataGoodsShelfVOList)){ basicdataGoodsShelfVOList = warehouseService.getMyWarehouseList(); - CacheUtil.put("getMyWarehouseList","basicdata","WarehouseList",basicdataGoodsShelfVOList); + CacheUtil.put(CacheObjNames.basic_data_warehourse_list.getCacheName(), CacheObjNames.basic_data_warehourse_list.getKeyPrefix(),user.getUserId(),basicdataGoodsShelfVOList); } return R.data(basicdataGoodsShelfVOList); diff --git a/blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/service/impl/BasicdataWarehouseServiceImpl.java b/blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/service/impl/BasicdataWarehouseServiceImpl.java index 631c1500b..13d5fe7b5 100644 --- a/blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/service/impl/BasicdataWarehouseServiceImpl.java +++ b/blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/service/impl/BasicdataWarehouseServiceImpl.java @@ -179,16 +179,10 @@ public class BasicdataWarehouseServiceImpl extends BaseServiceImpl warehouseEntityList = baseMapper.selectList(Wrappers.query().lambda().in(BasicdataWarehouseEntity::getDepartment, deptIds)); -// String json = redis.get(CacheNames.tenantKeyObj(user.getTenantId(), CacheNames.USER_WAREHOUSE_KEY, user.getUserId())); -// if (warehouseEntityList.size() <= 1) { -// redis.setEx(CacheNames.tenantKeyObj(user.getTenantId(), CacheNames.USER_WAREHOUSE_KEY, user.getUserId()), warehouseEntityList.get(0), 30 * 24 * 60 * 60L); -// } - return warehouseEntityList; + if(deptIds.isEmpty()){ + return null; + } + return baseMapper.selectList(Wrappers.query().lambda().in(BasicdataWarehouseEntity::getDepartment, deptIds)); } @Override