From 2c41cea1ec9bf0fd7be9658cb996b494ebb6b277 Mon Sep 17 00:00:00 2001
From: zhenghaoyu <zhenghaoyu@superbgrace.com>
Date: Fri, 10 May 2024 23:56:41 +0800
Subject: [PATCH 1/2] =?UTF-8?q?1.=E5=8D=B8=E8=BD=A6=E4=BC=A0=E5=87=BA?=
 =?UTF-8?q?=E8=AE=A2=E5=8D=95=E5=8F=B7?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../trunkline/service/impl/InComingServiceImpl.java      | 1 -
 .../service/impl/TrunklineCarsLoadServiceImpl.java       | 9 +++++----
 2 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/InComingServiceImpl.java b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/InComingServiceImpl.java
index c711d9ece..ee9f57e44 100644
--- a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/InComingServiceImpl.java
+++ b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/InComingServiceImpl.java
@@ -18,7 +18,6 @@ import lombok.extern.slf4j.Slf4j;
 import org.springblade.common.constant.IncomingTypeEnum;
 import org.springblade.common.constant.RabbitConstant;
 import org.springblade.common.constant.WorkNodeEnums;
-import org.springblade.common.utils.CommonUtil;
 import org.springblade.core.secure.utils.AuthUtil;
 import org.springblade.core.tool.api.R;
 import org.springblade.core.tool.utils.Func;
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 f7d65669f..4f6117006 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
@@ -5446,6 +5446,7 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
 		Long trayId = null;
 		String trayName = null;
 		String trayCode = null;
+		String orderCode = null;
 
 		//判断包件是否已入库
 		DistributionParcelListEntity distributionParcelListEntity = distributionParcelListClient.findByPacketBarCodeAndWarehouseId(orderPackageCode, warehouseId);
@@ -5512,7 +5513,7 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
 
 			} else {
 				String waybillNumber = parcelListEntity.getWaybillNumber();
-				String orderCode = parcelListEntity.getOrderCode();
+				orderCode = parcelListEntity.getOrderCode();
 				Long wid = parcelListEntity.getWarehouseId();
 				String wName = parcelListEntity.getWarehouse();
 				Long pacakageId = parcelListEntity.getId();
@@ -5656,7 +5657,7 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
 			Long finalNodeId = carsLoadScanEntity.getFinalNodeId();
 			Long waybillId = carsLoadScanEntity.getWaybillId();
 			String waybillNo = carsLoadScanEntity.getWaybillNo();
-			String orderCode = carsLoadScanEntity.getOrderCode();
+			orderCode = carsLoadScanEntity.getOrderCode();
 			Long loadScanId = carsLoadScanEntity.getId();
 			Long fromWarehouseId = carsLoadScanEntity.getFromWarehouseId();
 			Integer isData = carsLoadScanEntity.getIsData();
@@ -5771,7 +5772,7 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
 				TrunklineAdvanceDetailEntity advanceDetailEntity = trunklineAdvanceDetailService.findEntityByOrderPackageCode(orderPackageCode);
 				if (!Objects.isNull(advanceDetailEntity)) {
 					String packageStatus = advanceDetailEntity.getPackageStatus();
-					String orderCode1 = advanceDetailEntity.getOrderCode();
+					orderCode = advanceDetailEntity.getOrderCode();
 					String waybillNo1 = advanceDetailEntity.getWaybillNo();
 					if ("0".equals(packageStatus)) {
 						//未入库
@@ -5780,7 +5781,7 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
 						inComingDTO.setWarehouseId(warehouseId);
 						inComingService.incomingPackage(inComingDTO);
 
-						carsLoadScanEntity.setOrderCode(orderCode1);
+						carsLoadScanEntity.setOrderCode(orderCode);
 						carsLoadScanEntity.setWaybillNo(waybillNo1);
 						carsLoadScanEntity.setUnloadUserName(AuthUtil.getNickName());
 						carsLoadScanEntity.setUnloadTime(new Date());

From 67c353e3729cd97d297ec5d7dbf23f210b1858d9 Mon Sep 17 00:00:00 2001
From: zhaoqiaobo <zhaoqiaobo@163.com>
Date: Sat, 11 May 2024 00:00:51 +0800
Subject: [PATCH 2/2] =?UTF-8?q?feat(all):=20=E4=BF=AE=E6=94=B9=E6=8E=A8?=
 =?UTF-8?q?=E9=80=81=E6=B6=88=E6=81=AF=E5=A4=B1=E8=B4=A5=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/impl/InComingServiceImpl.java     |  2 +-
 .../impl/TrunklineCarsLoadServiceImpl.java    | 36 +++++++++++++++++++
 2 files changed, 37 insertions(+), 1 deletion(-)

diff --git a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/InComingServiceImpl.java b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/InComingServiceImpl.java
index ee9f57e44..4c51bd5ca 100644
--- a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/InComingServiceImpl.java
+++ b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/InComingServiceImpl.java
@@ -138,7 +138,7 @@ public class InComingServiceImpl implements IInComingService {
 					// 通过包件id 查询包件
 					orderStatusDTO.setUnitNo(packageCode);
 					orderStatusDTO.setOrderNo(advanceDetailEntity.getOrderCode());
-					orderStatusDTO.setStatus("4");
+					orderStatusDTO.setStatus("1");
 					orderStatusDTO.setOperationTime(DateUtil.now());
 					orderStatusDTO.setCurrentWarehouse(warehouseId.toString());
 					Map<String, Object> map = new HashMap<>();
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 4f6117006..4b53a25b2 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
@@ -3820,6 +3820,25 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
 
 			//直接新增的包件
 			distributionParcelListClient.addBatch(newParcelListEntities);
+			if(CollUtil.isNotEmpty(newParcelListEntities)){
+				for (DistributionParcelListEntity entity : newParcelListEntities) {
+					try {
+						// 发送入库消息
+						OrderStatusDTO orderStatusDTO = new OrderStatusDTO();
+						// 通过包件id 查询包件
+						orderStatusDTO.setUnitNo(entity.getOrderPackageCode());
+						orderStatusDTO.setOrderNo(entity.getOrderCode());
+						orderStatusDTO.setStatus("4");
+						orderStatusDTO.setOperationTime(DateUtil.now());
+						orderStatusDTO.setCurrentWarehouse(warehouseId.toString());
+						Map<String, Object> map = new HashMap<>();
+						map.put("messageData", JSONUtil.toJsonStr(orderStatusDTO));
+						rabbitTemplate.convertAndSend(RabbitConstant.HWY_ORDER_STATUS_EXCHANGE, RabbitConstant.HWY_ORDER_STATUS_ROUTING, map);
+					}catch (Exception e){
+						log.error("推送卸车失败{}",e);
+					}
+				}
+			}
 
 			trunklineCarsLoadScanService.updateBatchById(updateScanEntityList);
 
@@ -5828,6 +5847,23 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
 			orderPackageCodes.add(orderPackageCode);
 			String content = "包件在 " + warehouseName + "卸车，卸车方式：" + IncomingTypeEnum.getValue(incomingType);
 			packageTrackLogAsyncService.addPackageTrackLog(AuthUtil.getTenantId(), AuthUtil.getUserId(), Func.firstLong(AuthUtil.getDeptId()), AuthUtil.getNickName(), orderPackageCodes, warehouseId, warehouseName, WorkNodeEnums.UNLOAD_INCOMING_WAREHOUSE.getCode(), content);
+			try {
+				if(StrUtil.isNotEmpty(orderCode)){
+					// 发送入库消息
+					OrderStatusDTO orderStatusDTO = new OrderStatusDTO();
+					// 通过包件id 查询包件
+					orderStatusDTO.setUnitNo(orderPackageCode);
+					orderStatusDTO.setOrderNo(orderCode);
+					orderStatusDTO.setStatus("4");
+					orderStatusDTO.setOperationTime(DateUtil.now());
+					orderStatusDTO.setCurrentWarehouse(warehouseId.toString());
+					Map<String, Object> map = new HashMap<>();
+					map.put("messageData", JSONUtil.toJsonStr(orderStatusDTO));
+					rabbitTemplate.convertAndSend(RabbitConstant.HWY_ORDER_STATUS_EXCHANGE, RabbitConstant.HWY_ORDER_STATUS_ROUTING, map);
+				}
+			} catch (Exception e) {
+				log.error("入库推送失败：{}", e);
+			}
 		} catch (Exception e) {
 			log.warn("#########3卸车存入日志失败");
 		}