From 65c9d5c6a9bb0ed540a2e04441344e4211ad647f Mon Sep 17 00:00:00 2001 From: zhaoqiaobo <583671871@qq.com> Date: Mon, 23 Dec 2024 00:27:00 +0800 Subject: [PATCH] =?UTF-8?q?feat(all):=20=E9=85=8D=E9=80=81=E6=98=8E?= =?UTF-8?q?=E7=BB=86=E6=8A=A5=E8=A1=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 1 优化配送明细广播推送 --- .../receiver/report/PlanReportListener.java | 16 ++++++++++++++++ 1 file changed, 16 insertions(+) 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();