diff --git a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/InComingServiceImpl.java b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/InComingServiceImpl.java index f4f6dfd09..8c2d044ad 100644 --- a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/InComingServiceImpl.java +++ b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/InComingServiceImpl.java @@ -43,6 +43,7 @@ import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import java.util.*; +import java.util.concurrent.atomic.AtomicReference; import java.util.function.Function; import java.util.stream.Collectors; @@ -198,6 +199,7 @@ public class InComingServiceImpl implements IInComingService { @Transactional(rollbackFor = Exception.class) public R incomingPackage(InComingDTO inComingDTO) { + AtomicReference audio = new AtomicReference<>(); try{ String orderPackageCode = inComingDTO.getOrderPackageCode();//包件码 Long warehouseId = inComingDTO.getWarehouseId();//仓库id @@ -235,6 +237,8 @@ public class InComingServiceImpl implements IInComingService { } } + + //把advanceDetailEntityList通过packageStatus分组 Map> advanceDetailEntityMap = advanceDetailEntityList.stream().collect(Collectors.groupingBy(TrunklineAdvanceDetailEntity::getPackageStatus)); @@ -327,7 +331,11 @@ public class InComingServiceImpl implements IInComingService { map.put("trayCode", trayCode); map.put("warehouseId", warehouseId); map.put("orderPackageCode", packageCode); - warehouseTrayTypeClient.orderScanOrderPackageCodeReturnR(map); + R r = warehouseTrayTypeClient.orderScanOrderPackageCodeReturnR(map); + Object data = r.getData(); + if(!Objects.isNull(data)){ + audio.set((String) data); + } } }); } @@ -421,7 +429,11 @@ public class InComingServiceImpl implements IInComingService { map.put("trayCode", trayCode); map.put("warehouseId", warehouseId); map.put("orderPackageCode", packageCode); - warehouseTrayTypeClient.orderScanOrderPackageCode(map); + R r = warehouseTrayTypeClient.orderScanOrderPackageCodeReturnR(map); + Object data = r.getData(); + if(!Objects.isNull(data)){ + audio.set((String) data); + } } }); } @@ -469,6 +481,11 @@ public class InComingServiceImpl implements IInComingService { throw e; } + String a = audio.get(); + if(StringUtil.isNotBlank(a)){ + return Resp.scanSuccess("入库成功",a); + } + return R.success("入库成功"); } 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 6758d2a92..49326b45c 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 @@ -2290,12 +2290,12 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl loadScanQueryWrapper = new QueryWrapper<>(); + QueryWrapper loadScanQueryWrapper = new QueryWrapper<>(); loadScanQueryWrapper.eq("load_id", loadId) .eq("scan_code", orderPackageCode); TrunklineCarsLoadScanEntity carsLoadScanEntity = trunklineCarsLoadScanService.getOne(loadScanQueryWrapper); //判断是否有装车扫描记录 if (Objects.isNull(carsLoadScanEntity)) { //没有装车扫码记录 + //先判断是否在其他车次中 +// QueryWrapper loadScanQueryWrapper = new QueryWrapper<>(); +// loadScanQueryWrapper.eq("load_id", loadId) +// .eq("scan_code", orderPackageCode); +// carsLoadScanEntity = trunklineCarsLoadScanService.getOne(loadScanQueryWrapper); + //不在计划中,则查询在哪个仓库中 DistributionParcelListEntity parcelListEntity = distributionParcelListClient.findByOrderPackageCodeAndStatus(orderPackageCode); Long loadScanId = null; @@ -7116,7 +7122,17 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl