diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/receiver/report/PlanReportListener.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/receiver/report/PlanReportListener.java index 077edd48f..820e81dd1 100644 --- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/receiver/report/PlanReportListener.java +++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/receiver/report/PlanReportListener.java @@ -64,6 +64,21 @@ public class PlanReportListener implements ReportService { Long warehouseId = bean.getWarehouseId(); BizOperationEnums bizOperation = bean.getBizOperation(); List reservationVOList = vo.getReservationVOList(); + // 删除,根据车次号删除 + if (bizOperation.equals(BizOperationEnums.DELETE)) { + String trainNumber = vo.getTrainNumber(); + if(StrUtil.isNotEmpty(trainNumber)){ + List entities = qualityDeliverService.list(Wrappers.lambdaQuery() + .select(QualityDeliverEntity::getId) + .eq(QualityDeliverEntity::getPlanTrainNumber, trainNumber)); + if (CollUtil.isNotEmpty(entities)) { + for (QualityDeliverEntity entity : entities) { + sendReport(entity, bizOperation); + } + } + } + return; + } if (CollUtil.isNotEmpty(reservationVOList)) { List planDriverbindCars = vo.getPlanDriverbindCars(); String vehicleName = ""; @@ -77,6 +92,7 @@ public class PlanReportListener implements ReportService { Map> cmpMap = new HashMap<>(); Map> ltlMap = new HashMap<>(); Map> invMap = new HashMap<>(); + Integer totalNum = 0; for (ReservationVO reservationVO : reservationVOList) { List details = reservationVO.getPackageDataList();