1.修复运单上的的日志重复的问题

blade-service/logpm-distribution/src/main/java/com/logpm/distribution/feign/DistributionSignforClient.java

@@ -146,7 +146,7 @@ public class DistributionSignforClient implements IDistributionSignforClient {
 			if (!distributionReservationEntities.isEmpty()) {
 				List<Long> collect = distributionReservationEntities.stream().map(DistributionReservationEntity::getId).collect(Collectors.toList());
 				for (Long reservationId : collect) {
-					log.info(">>>>>>>>>>handletrunklineWaybillSignLog ",reservationId);
+					log.info(">>>>>>>>>>handletrunklineWaybillSignLog {}",reservationId);
 					distributionSignforService.handletrunklineWaybillSignLog(reservationId);
 				}
 			}

blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionSignforServiceImpl.java

@@ -7099,10 +7099,8 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl<Distribution
 		log.info(">>>> updateSign isSuccess ={}", isSuccess);
 		buildArgsToPushMq(distributionSignfor);
 		if (isSuccess) {
-			//整理签收数据回退干线
-			handletrunklineWaybillSignLog(distributionSignfor.getReservationId());
-
-
+			//理签收数据回退干线
+			//handletrunklineWaybillSignLog(distributionSignfor.getReservationId());
 			this.updateById(distributionSignfor);
 			// 创建异步队列推送老系统的的签收信息 构建请求参数
 			return R.status(true);

blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mq/waybil/StatusLogListener.java

@@ -121,8 +121,9 @@ public class StatusLogListener {
 		BizOperationEnums bizOperation = bean.getBizOperation();
 		List<PackageData> details = vo.getPackageDataList();
 
-		// 按照运单号进行分组 后面的集合 按照创建时间进行排序
-		Map<String, List<PackageData>> map = details.stream().collect(Collectors.groupingBy(PackageData::getWaybillNumber));
+		// 按照运单号进行分组 后面的集合 按照创建时间进行排序 运单号不能为null
+
+		Map<String, List<PackageData>> map = details.stream().filter(t->ObjectUtil.isNotNull(t.getWaybillNumber())).collect(Collectors.groupingBy(PackageData::getWaybillNumber));
 		// 根据运单号  统计 每个运单的数量
 		Map<String, Integer> waybillCountMap = new HashMap<>();
 

blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineWaybillTrackServiceImpl.java

@@ -86,6 +86,7 @@ public class TrunklineWaybillTrackServiceImpl extends BaseServiceImpl<TrunklineW
 				updateWaybill.setSignCheckTime(new Date());
 				updateWaybill.setDeliveryTime(waybillLogDTO.getDeliveryTime() == null?null:waybillLogDTO.getDeliveryTime());
 				updateWaybill.setDeliveryDriverName(waybillLogDTO.getDriverName()==null?"":waybillLogDTO.getDriverName());
+
 				warehouseWaybillClient.updateEntity(updateWaybill);
 				warehouseWaybillEntity.setSignNum(updateWaybill.getSignNum());