From ac7503f70284a1280c8ee698bc66d76d9f4f562e Mon Sep 17 00:00:00 2001
From: zhenghaoyu <zhenghaoyu@superbgrace.com>
Date: Tue, 9 Apr 2024 10:55:31 +0800
Subject: [PATCH] =?UTF-8?q?1.=E9=9B=B6=E6=8B=85=E6=95=B0=E6=8D=AE=E6=8E=A8?=
 =?UTF-8?q?=E9=80=81=E9=80=BB=E8=BE=91=E6=9B=B4=E6=96=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../main/java/com/logpm/warehouse/dto/WaybillDTO.java |  2 +-
 .../service/impl/WarehouseWaybillServiceImpl.java     | 11 ++++++++---
 2 files changed, 9 insertions(+), 4 deletions(-)

diff --git a/blade-service/logpm-warehouse/src/main/java/com/logpm/warehouse/dto/WaybillDTO.java b/blade-service/logpm-warehouse/src/main/java/com/logpm/warehouse/dto/WaybillDTO.java
index 2e41aa583..97cd225fa 100644
--- a/blade-service/logpm-warehouse/src/main/java/com/logpm/warehouse/dto/WaybillDTO.java
+++ b/blade-service/logpm-warehouse/src/main/java/com/logpm/warehouse/dto/WaybillDTO.java
@@ -1,6 +1,5 @@
 package com.logpm.warehouse.dto;
 
-import io.swagger.models.auth.In;
 import lombok.Data;
 
 import java.io.Serializable;
@@ -35,6 +34,7 @@ public class WaybillDTO implements Serializable {
 	private Integer isZero;
 
 
+	private Integer warehouseId;
 
 
 }
diff --git a/blade-service/logpm-warehouse/src/main/java/com/logpm/warehouse/service/impl/WarehouseWaybillServiceImpl.java b/blade-service/logpm-warehouse/src/main/java/com/logpm/warehouse/service/impl/WarehouseWaybillServiceImpl.java
index 052369ba1..cb6323934 100644
--- a/blade-service/logpm-warehouse/src/main/java/com/logpm/warehouse/service/impl/WarehouseWaybillServiceImpl.java
+++ b/blade-service/logpm-warehouse/src/main/java/com/logpm/warehouse/service/impl/WarehouseWaybillServiceImpl.java
@@ -92,6 +92,7 @@ public class WarehouseWaybillServiceImpl extends BaseServiceImpl<WarehouseWaybil
 		// 通过ID 获取老系统的订单数据
 		Integer wayBillId = waybillDTO.getId();
 		Integer allNum = waybillDTO.getNumber();
+		Integer oprationWarehouseId = waybillDTO.getWarehouseId();
 		Date date = new Date();
 		Long waybillId = null;
 		boolean isOrder = false;
@@ -107,11 +108,15 @@ public class WarehouseWaybillServiceImpl extends BaseServiceImpl<WarehouseWaybil
 			log.warn("##############waybillDataHandler: 老系统中未找到对应运单waybillId={}", waybillDTO.getId());
 			throw new CustomerException("老系统中未找到对应运单");
 		}
-
+		Integer warehouseId = wayBillEntity.getWarehouseId();
+		if(!warehouseId.equals(oprationWarehouseId)){
+			log.warn("##############waybillDataHandler: 作业仓库与目的仓不同 warehouseId={} oprationWarehouseId={}", warehouseId,oprationWarehouseId);
+			throw new CustomerException("作业仓库与目的仓不同");
+		}
 
 		// 需要验证当前需要开启的数据推送仓库
-		if(!OldSystemDataPushConfig.getWarehourseIdList().contains(wayBillEntity.getWarehouseId()+"")){
-			log.info(">>>> waybillDataHandler 当前开单仓库不是目前系统上线运行仓库 {}", wayBillEntity.getWarehouseId());
+		if(!OldSystemDataPushConfig.getWarehourseIdList().contains(warehouseId+"")){
+			log.info(">>>> waybillDataHandler 当前开单仓库不是目前系统上线运行仓库 {}", warehouseId);
 			throw new CustomerException("当前开单仓库不是目前系统上线运行仓库");
 		}