From 0b7e05269281ba4ec4d2be19102be753d79d8126 Mon Sep 17 00:00:00 2001
From: zhenghaoyu <zhenghaoyu@superbgrace.com>
Date: Thu, 1 Aug 2024 19:10:25 +0800
Subject: [PATCH] =?UTF-8?q?1.=E4=BB=93=E5=BA=93=E5=B9=BF=E6=92=AD=E9=80=BB?=
 =?UTF-8?q?=E8=BE=91=E4=BC=98=E5=8C=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../impl/WarehouseUpdownTypeServiceImpl.java  | 25 +++++++++++++++++--
 1 file changed, 23 insertions(+), 2 deletions(-)

diff --git a/blade-service/logpm-warehouse/src/main/java/com/logpm/warehouse/service/impl/WarehouseUpdownTypeServiceImpl.java b/blade-service/logpm-warehouse/src/main/java/com/logpm/warehouse/service/impl/WarehouseUpdownTypeServiceImpl.java
index bdb55b65b..ac731c2ca 100644
--- a/blade-service/logpm-warehouse/src/main/java/com/logpm/warehouse/service/impl/WarehouseUpdownTypeServiceImpl.java
+++ b/blade-service/logpm-warehouse/src/main/java/com/logpm/warehouse/service/impl/WarehouseUpdownTypeServiceImpl.java
@@ -1712,8 +1712,8 @@ public class WarehouseUpdownTypeServiceImpl extends BaseServiceImpl<WarehouseUpd
 				String warehouseName = warehouseEntity.getName();
 
 				updownGoodsLogEntities.forEach(warehouseUpdownGoodsLogEntity -> {
-					String allocationTitle = warehouseUpdownGoodsLogEntity.getAllocationTitle();
-					String content = "包件在 "+warehouseName+" 下架，库位 "+allocationTitle;
+					String positionCode = warehouseUpdownGoodsLogEntity.getPositionCode();
+					String content = "包件在 "+warehouseName+" 下架，库位 "+positionCode;
 					List<String> packageCodeList = new ArrayList<>();
 					packageCodeList.add(warehouseUpdownGoodsLogEntity.getAssociationValue());
 					warehousePackageTrackLogService.addBatchLog(packageCodeList,content,warehouseId,warehouseName, AuthUtil.getNickName(), WorkNodeEnums.DELIST.getCode());
@@ -1919,9 +1919,30 @@ public class WarehouseUpdownTypeServiceImpl extends BaseServiceImpl<WarehouseUpd
 
 				num = num + quantity;
 				warehouseGoodsAllocationClient.updateAllocationCache(allocationId.toString());
+
+				JSONObject jsonObject = new JSONObject();
+				jsonObject.put("dataType",1);
+				jsonObject.put("conditions",parcelListEntity.getConditions());
+				jsonObject.put("operation",4);
+				//把listEntityList中所有元素的orderPackageCode放入一个List
+				List<String> packageCodes = new ArrayList<>();
+				packageCodes.add(parcelListEntity.getOrderPackageCode());
+
+				jsonObject.put("orderPackageCodes",packageCodes);
+				jsonObject.put("warehouseId",warehouseId);
+
+				FanoutMsg fanoutMsg = FanoutMsg.builder().exchange(FanoutConstants.warehouse.ALLOCATION.EXCHANGE).msg(jsonObject.toJSONString()).build();
+
+				sendFanoutService.sendFanoutMsg(fanoutMsg);
+
+				String positionCode = updownTypeEntity.getPositionCode();
+				String content = "包件在 "+parcelListEntity.getWarehouse()+" 下架，库位 "+positionCode;
+				warehousePackageTrackLogService.addBatchLog(packageCodes,content,warehouseId,parcelListEntity.getWarehouse(), AuthUtil.getNickName(), WorkNodeEnums.DELIST.getCode());
+
 			} else {
 				log.error("包件下架失败，找不到上架方式,updownTypeId:{}", updownTypeId);
 			}
+
 		}
 		return Resp.scanSuccess("下架成功", "成功下架" + num + "件");
 	}