diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionAsyncServiceImpl.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionAsyncServiceImpl.java index 3cd75aac4..d333a395a 100644 --- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionAsyncServiceImpl.java +++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionAsyncServiceImpl.java @@ -1870,6 +1870,10 @@ public class DistributionAsyncServiceImpl implements IDistributionAsyncService { .eq(DistrilbutionBillPackageEntity::getBillLadingId, l) .in(DistrilbutionBillPackageEntity::getParceListId, packageIds) ); + //增加释放日志 + + + } String collect = distributionParcelListEntities.stream().map(DistributionParcelListEntity::getOrderCode).distinct().collect(Collectors.joining(",")); distributionStockArticleService.maintenanceOrderInfo(collect, warehouseId); diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistrilbutionBillLadingServiceImpl.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistrilbutionBillLadingServiceImpl.java index fbbf22dc5..f3582d517 100644 --- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistrilbutionBillLadingServiceImpl.java +++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistrilbutionBillLadingServiceImpl.java @@ -126,6 +126,7 @@ import org.springblade.common.constant.order.OrderStatusConstant; import org.springblade.common.constant.orderpackage.OrderPackageLoadingStatusConstant; import org.springblade.common.constant.orderpackage.OrderPackageReservationStatusConstant; import org.springblade.common.constant.orderpackage.OrderPackageStatusConstant; +import org.springblade.common.constant.orderpackage.OrderPackageStockupStatusConstant; import org.springblade.common.constant.pda.PdaAudioLingoStatus; import org.springblade.common.constant.reservation.ReservationOrderStatusConstant; import org.springblade.common.constant.reservation.ReservationPackageStatusConstant; @@ -3614,7 +3615,7 @@ public class DistrilbutionBillLadingServiceImpl extends BaseServiceImpl 0){ @@ -3730,6 +3731,49 @@ public class DistrilbutionBillLadingServiceImpl extends BaseServiceImpl list = distrilbutionBillPackageService.list(Wrappers.query().lambda() + .eq(DistrilbutionBillPackageEntity::getBillLadingId, l) + .ne(DistrilbutionBillPackageEntity::getPacketBarStatus, 2) + ); + if (Func.isNotEmpty(list)) { + List ids = list.stream().map(DistrilbutionBillPackageEntity::getParceListId).collect(Collectors.toList()); + //查询包件 + List distributionParcelListEntities = distributionParcelListService.listByIds(ids); + List packageIds = distributionParcelListEntities.stream().filter(f -> !OrderPackageLoadingStatusConstant.yizhuangche.getValue().equals(f.getOrderPackageLoadingStatus()) || !OrderPackageStatusConstant.yiqianshou.getValue().equals(f.getOrderPackageStatus())).map(DistributionParcelListEntity::getId).collect(Collectors.toList()); + if (Func.isNotEmpty(packageIds)) { + distributionParcelListService.update(new UpdateWrapper().lambda() + .set(DistributionParcelListEntity::getOrderPackageReservationStatus, OrderPackageReservationStatusConstant.daiyuyue.getValue()) + .set(DistributionParcelListEntity::getOrderPackageLoadingStatus, OrderPackageLoadingStatusConstant.weizhuancghe.getValue()) + .set(DistributionParcelListEntity::getOrderPackageStatus, OrderPackageStatusConstant.yiruku.getValue()) + .set(DistributionParcelListEntity::getOrderPackageStockupStatus, OrderPackageStockupStatusConstant.daibeihuo.getValue()) + .in(DistributionParcelListEntity::getId, packageIds) + ); + distrilbutionBillPackageService.update(new UpdateWrapper().lambda() + .set(DistrilbutionBillPackageEntity::getPacketBarStatus, 2) + .eq(DistrilbutionBillPackageEntity::getBillLadingId, l) + .in(DistrilbutionBillPackageEntity::getParceListId, packageIds) + ); + List logList = new ArrayList<>(); + + for (DistributionParcelListEntity distributionParcelListEntity : distributionParcelListEntities) { + String content = "包件在" + warehouse.getName() + "由" + AuthUtil.getNickName() + "取消自提,操作方式:复核自提单包件释放,自提批次号:" + pickupBatch; + JSONObject logJS = handleLogJSONObject(warehouse, AuthUtil.getUser(), distributionParcelListEntity.getOrderPackageCode(), content, WorkNodeEnums.CANCEL_BILLOFLADING.getCode()); + logList.add(logJS); + } + if (!logList.isEmpty()) { + trunklinePackageTrackLogClient.addPackageTrackLog(logList); + } + + } + String collect = distributionParcelListEntities.stream().map(DistributionParcelListEntity::getOrderCode).distinct().collect(Collectors.joining(",")); + distributionStockArticleService.maintenanceOrderInfo(collect, warehouse.getId()); + //维护自提单订单信息 + distrilbutionBillStockService.maintenanceOrderInfo(l); + } + + } + private void sendFactory(BasicdataWarehouseEntity myCurrentWarehouse, Set parcelListIds) { try { // ladingScanEntities中的包件id数据封装为set