Browse Source

add:修复线上问题

visual
pref_mail@163.com 4 months ago
parent
commit
fa1153a9ef
  1. 3
      blade-service/logpm-statisticsdata/src/main/java/com/logpm/statistics/listener/mq/PackageFanoutListener.java
  2. 1
      blade-service/logpm-statisticsdata/src/main/java/com/logpm/statistics/mapper/StatisticsOrderInfoMapper.xml

3
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<StatisticsDistributionPackageEntity> statisticsList = statisticsDistributionPackageService.findListByOrderInfoSet(orderInfoSet);
// 把statisticsList通过元素的orderInfoId进行map分组
Map<Long, List<StatisticsDistributionPackageEntity>> groupedStatisticsList = statisticsList.stream()

1
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
<if test="param.listType == 1">

Loading…
Cancel
Save