From 15d4bbfb0833b5dd844066eaaf373647d0eb2978 Mon Sep 17 00:00:00 2001
From: zhenghaoyu <zhenghaoyu@superbgrace.com>
Date: Thu, 8 Aug 2024 16:29:47 +0800
Subject: [PATCH] =?UTF-8?q?1.=E5=B9=B2=E7=BA=BFbug=E4=BF=AE=E5=A4=8D?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../AftersalesAbnormalRecordServiceImpl.java  | 32 +++++++++++++++-
 .../impl/TrunklineCarsLoadServiceImpl.java    |  2 +-
 .../TrunklineWaybillPackageServiceImpl.java   | 38 ++++++++++---------
 3 files changed, 52 insertions(+), 20 deletions(-)

diff --git a/blade-service/logpm-aftersales/src/main/java/com/logpm/aftersales/service/impl/AftersalesAbnormalRecordServiceImpl.java b/blade-service/logpm-aftersales/src/main/java/com/logpm/aftersales/service/impl/AftersalesAbnormalRecordServiceImpl.java
index 60122f6fa..6c0931497 100644
--- a/blade-service/logpm-aftersales/src/main/java/com/logpm/aftersales/service/impl/AftersalesAbnormalRecordServiceImpl.java
+++ b/blade-service/logpm-aftersales/src/main/java/com/logpm/aftersales/service/impl/AftersalesAbnormalRecordServiceImpl.java
@@ -13,8 +13,12 @@ import com.logpm.distribution.entity.DistributionParcelListEntity;
 import com.logpm.distribution.entity.DistributionStockArticleEntity;
 import com.logpm.distribution.feign.IDistributionParcelListClient;
 import com.logpm.distribution.feign.IDistributionStockArticleClient;
+import com.logpm.trunkline.dto.AddWaybillTrackDTO;
 import com.logpm.trunkline.entity.TrunklineCarsLoadScanEntity;
 import com.logpm.trunkline.feign.ITrunklineCarsLoadScanClient;
+import com.logpm.trunkline.feign.ITrunklineWaybillTrackClient;
+import com.logpm.warehouse.entity.WarehouseWaybillEntity;
+import com.logpm.warehouse.feign.IWarehouseWaybillClient;
 import lombok.AllArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springblade.common.utils.CommonUtil;
@@ -43,6 +47,10 @@ public class AftersalesAbnormalRecordServiceImpl extends BaseServiceImpl<Aftersa
 
 	private final IDistributionParcelListClient parcelListClient;
 
+	private final IWarehouseWaybillClient warehouseWaybillClient;
+
+	private final ITrunklineWaybillTrackClient trunklineWaybillTrackClient;
+
 	@Override
 	public R findPageList(AbnormalRecordDTO abnormalRecordDTO) {
 		IPage<Object> page = new Page<>();
@@ -268,7 +276,7 @@ public class AftersalesAbnormalRecordServiceImpl extends BaseServiceImpl<Aftersa
 									}
 								}else{
 
-									stockArticleClient.addHandQuantity(currentStockArticleEntity.getId(),enterNum);
+									stockArticleClient.addHandQuantityAndIncomingNum(currentStockArticleEntity.getId(),enterNum);
 
 								}
 								abnormalRecordEntity.setRemark("差异"+enterNum+"件数入库本仓,原仓返回"+diff+"件");
@@ -276,6 +284,28 @@ public class AftersalesAbnormalRecordServiceImpl extends BaseServiceImpl<Aftersa
 							carsLoadScanEntity.setScanStatus("2");
 							carsLoadScanEntity.setUnloadNum(carsLoadScanEntity.getUnloadNum()+enterNum);
 							trunklineCarsLoadScanClient.updateEntity(carsLoadScanEntity);
+
+							String waybillNo = carsLoadScanEntity.getWaybillNo();
+							WarehouseWaybillEntity waybillEntity = warehouseWaybillClient.findByWaybillNo(waybillNo);
+							Long waybillId = null;
+							if(!Objects.isNull(waybillEntity)){
+								waybillId = waybillEntity.getId();
+							}
+
+							String warehouseName = warehouseEntity.getName();
+
+							String operationRemark = warehouseName+"干线异常列表卸车，总数/卸车数："+num+"/"+enterNum+"，卸车时间"+ CommonUtil.dateToStringGeneral(new Date());
+							AddWaybillTrackDTO addWaybillTrackDTO = new AddWaybillTrackDTO();
+							addWaybillTrackDTO.setTrackType("80");
+							addWaybillTrackDTO.setWaybillId(waybillId);
+							addWaybillTrackDTO.setWaybillNo(waybillNo);
+							addWaybillTrackDTO.setRefer("异常列表卸车");
+							addWaybillTrackDTO.setOperationRemark(operationRemark);
+							addWaybillTrackDTO.setUserId(AuthUtil.getUserId());
+							addWaybillTrackDTO.setWarehouseId(warehouseId);
+							addWaybillTrackDTO.setWarehouseName(warehouseName);
+							addWaybillTrackDTO.setNickName(AuthUtil.getNickName());
+							trunklineWaybillTrackClient.addWaybillLog(addWaybillTrackDTO);
 						}
 					}
 				}
diff --git a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineCarsLoadServiceImpl.java b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineCarsLoadServiceImpl.java
index b44dc60f0..414780d1a 100644
--- a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineCarsLoadServiceImpl.java
+++ b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineCarsLoadServiceImpl.java
@@ -5579,7 +5579,7 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
 					warehousePackageTrackLogEntity.setWarehouseId(warehouseId);
 					warehousePackageTrackLogEntity.setWarehouseName(warehouseName);
 					warehousePackageTrackLogEntity.setWorkNode(WorkNodeEnums.INITIAL_WAREHOUSE_LOADING.getCode());
-					String content = "包件在 " + warehouseName + "手动批量装车,配载计划目的仓 " + carsLoadScanEntity.getFinalNodeName() + ",数据来源仓库 " + warehouseName;
+					String content = "包件在 " + warehouseName + "手动批量装车,车次号:"+carsNo+",配载计划目的仓 " + carsLoadScanEntity.getFinalNodeName() + ",数据来源仓库 " + warehouseName;
 					warehousePackageTrackLogEntity.setContent(content);
 					warehousePackageTrackLogEntity.setOperator(nickName);
 					addPackageTrackLogList.add(warehousePackageTrackLogEntity);
diff --git a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineWaybillPackageServiceImpl.java b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineWaybillPackageServiceImpl.java
index b454786d6..0f7eb5114 100644
--- a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineWaybillPackageServiceImpl.java
+++ b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineWaybillPackageServiceImpl.java
@@ -203,29 +203,31 @@ public class TrunklineWaybillPackageServiceImpl extends BaseServiceImpl<Trunklin
 			packageStatus = 10;
 		}
 
-		if(!Objects.isNull(packageStatus)){
-			List<TrunklineWaybillPackageEntity> waybillPackageEntities = new ArrayList<>();
-			Set<Long> waybillIds = new HashSet<>();
-			QueryWrapper<TrunklineWaybillPackageEntity> queryWrapper = new QueryWrapper<>();
-			queryWrapper.in("order_package_code",orderPackageCodes)
-				.eq("is_deleted",0);
-			List<TrunklineWaybillPackageEntity> trunklineWaybillPackageEntities = baseMapper.selectList(queryWrapper);
-			if(!trunklineWaybillPackageEntities.isEmpty()){
-				for (TrunklineWaybillPackageEntity trunklineWaybillPackageEntity : trunklineWaybillPackageEntities) {
-					trunklineWaybillPackageEntity.setPackageStatus(packageStatus);
-					waybillIds.add(trunklineWaybillPackageEntity.getWaybillId());
-				}
+		if(CollUtil.isNotEmpty(orderPackageCodes)){
+			if(!Objects.isNull(packageStatus)){
+				List<TrunklineWaybillPackageEntity> waybillPackageEntities = new ArrayList<>();
+				Set<Long> waybillIds = new HashSet<>();
+				QueryWrapper<TrunklineWaybillPackageEntity> queryWrapper = new QueryWrapper<>();
+				queryWrapper.in("order_package_code",orderPackageCodes)
+					.eq("is_deleted",0);
+				List<TrunklineWaybillPackageEntity> trunklineWaybillPackageEntities = baseMapper.selectList(queryWrapper);
+				if(!trunklineWaybillPackageEntities.isEmpty()){
+					for (TrunklineWaybillPackageEntity trunklineWaybillPackageEntity : trunklineWaybillPackageEntities) {
+						trunklineWaybillPackageEntity.setPackageStatus(packageStatus);
+						waybillIds.add(trunklineWaybillPackageEntity.getWaybillId());
+					}
 
-				updateBatchById(trunklineWaybillPackageEntities);
+					updateBatchById(trunklineWaybillPackageEntities);
 
-				for (Long waybillId : waybillIds) {
-					WarehouseWaybillEntity waybillEntity = warehouseWaybillClient.findByWaybillId(waybillId);
-					updateWaybillStatus(waybillEntity);
+					for (Long waybillId : waybillIds) {
+						WarehouseWaybillEntity waybillEntity = warehouseWaybillClient.findByWaybillId(waybillId);
+						updateWaybillStatus(waybillEntity);
+					}
 				}
 			}
-		}
 
-		packageTrackLogAsyncService.sendPackageWorkNodeFanout(orderPackageCodes,workNode,warehouseId, map);
+			packageTrackLogAsyncService.sendPackageWorkNodeFanout(orderPackageCodes,workNode,warehouseId, map);
+		}
 
 	}
 }