From fa1153a9efc040962a5cf717ef790dce465fd61a Mon Sep 17 00:00:00 2001 From: "pref_mail@163.com" Date: Fri, 1 Nov 2024 10:32:15 +0800 Subject: [PATCH] =?UTF-8?q?add:=E4=BF=AE=E5=A4=8D=E7=BA=BF=E4=B8=8A?= =?UTF-8?q?=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../logpm/statistics/listener/mq/PackageFanoutListener.java | 3 +++ .../com/logpm/statistics/mapper/StatisticsOrderInfoMapper.xml | 1 + 2 files changed, 4 insertions(+) diff --git a/blade-service/logpm-statisticsdata/src/main/java/com/logpm/statistics/listener/mq/PackageFanoutListener.java b/blade-service/logpm-statisticsdata/src/main/java/com/logpm/statistics/listener/mq/PackageFanoutListener.java index b94c2240e..80694dcd7 100644 --- a/blade-service/logpm-statisticsdata/src/main/java/com/logpm/statistics/listener/mq/PackageFanoutListener.java +++ b/blade-service/logpm-statisticsdata/src/main/java/com/logpm/statistics/listener/mq/PackageFanoutListener.java @@ -109,6 +109,9 @@ public class PackageFanoutListener { }); statisticsDistributionPackageService.updateBatchById(statisticsDistributionList); + if(orderInfoSet.isEmpty()){ + return ; + } List statisticsList = statisticsDistributionPackageService.findListByOrderInfoSet(orderInfoSet); // 把statisticsList通过元素的orderInfoId进行map分组 Map> groupedStatisticsList = statisticsList.stream() diff --git a/blade-service/logpm-statisticsdata/src/main/java/com/logpm/statistics/mapper/StatisticsOrderInfoMapper.xml b/blade-service/logpm-statisticsdata/src/main/java/com/logpm/statistics/mapper/StatisticsOrderInfoMapper.xml index 7d2711076..0579665d4 100644 --- a/blade-service/logpm-statisticsdata/src/main/java/com/logpm/statistics/mapper/StatisticsOrderInfoMapper.xml +++ b/blade-service/logpm-statisticsdata/src/main/java/com/logpm/statistics/mapper/StatisticsOrderInfoMapper.xml @@ -47,6 +47,7 @@ from logpm_statistics_order_info lsoi left join logpm_basicdata_client lbc on lbc.id = lsoi.consignee_id left join logpm_warehouse_waybill lww on lww.id = lsoi.waybill_id + LEFT JOIN logpm_warehouse_waybill_detail lwwd on lwwd.waybill_id=lww.id where 1=1 and lsoi.create_reconciliation_order_status = 0