|
|
|
@ -2701,6 +2701,23 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl<Distribution
|
|
|
|
|
log.error("########缺失参数,barcodes:{}", distrilbutionloadingscanDTO.getBarcodes()); |
|
|
|
|
return R.fail("存在已签收包件!!"); |
|
|
|
|
} |
|
|
|
|
List<Long> ids = parcelListEntities.stream().map(DistributionParcelListEntity::getId).collect(Collectors.toList()); |
|
|
|
|
List<DistributionLoadscanAbnormalEntity> abnormalEntities = distributionLoadscanAbnormalService.list(Wrappers.<DistributionLoadscanAbnormalEntity>query().lambda() |
|
|
|
|
.in(DistributionLoadscanAbnormalEntity::getPackageId, ids) |
|
|
|
|
); |
|
|
|
|
if (!abnormalEntities.isEmpty()) { |
|
|
|
|
//判断此包件的异常是否是当前扫描车次和客户
|
|
|
|
|
//首先判断存在异常是否不属于当前车次和客户
|
|
|
|
|
boolean a = abnormalEntities.stream().allMatch(a -> !deliveryListEntity.getId().equals(a.getDeliveryListId()) || !distrilbutionloadingscanDTO.getReservationId().equals(a.getReservationId())); |
|
|
|
|
if (a){ |
|
|
|
|
//该异常属于其他车次
|
|
|
|
|
String code = abnormalEntities.stream().filter(c -> !deliveryListEntity.getId().equals(c.getDeliveryListId()) || !distrilbutionloadingscanDTO.getReservationId().equals(c.getReservationId())).map(DistributionLoadscanAbnormalEntity::getPackageCode).collect(Collectors.joining(",")); |
|
|
|
|
log.info("包件已在其他车次存在异常 >>>>包条码:{}",code); |
|
|
|
|
log.info("包件已在其他车次存在异常 >>>>当前车次:{},异常车次:{}",deliveryListEntity.getTrainNumber(),abnormalEntities.stream().map(DistributionLoadscanAbnormalEntity::getTrainNumber).collect(Collectors.joining(","))); |
|
|
|
|
return R.fail(code+"已在其他车次执行异常!!"); |
|
|
|
|
} |
|
|
|
|
//判断具体的装车信息
|
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
List<DistributionParcelListEntity> parcelListEntityList = distributionReservationMapper.selectPackageListByReservationId(distrilbutionloadingscanDTO.getReservationId()); |
|
|
|
|
//查询该客户是否存在该包件信息
|
|
|
|
|