From 7c12194086786106a9568af2d18c943d7da3e814 Mon Sep 17 00:00:00 2001
From: zhenghaoyu <zhenghaoyu@superbgrace.com>
Date: Wed, 5 Jun 2024 20:10:22 +0800
Subject: [PATCH] =?UTF-8?q?1.=E5=90=8E=E5=8F=B0=E6=89=B9=E9=87=8F=E5=90=8C?=
 =?UTF-8?q?=E6=AD=A5=E8=80=81=E7=B3=BB=E7=BB=9F=E6=89=98=E7=9B=98=E6=95=B0?=
 =?UTF-8?q?=E6=8D=AE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../api/WarehouseTrayTypeApiController.java   | 79 ++++++++++++++++++-
 1 file changed, 75 insertions(+), 4 deletions(-)

diff --git a/blade-service/logpm-warehouse/src/main/java/com/logpm/warehouse/api/WarehouseTrayTypeApiController.java b/blade-service/logpm-warehouse/src/main/java/com/logpm/warehouse/api/WarehouseTrayTypeApiController.java
index 139197ba8..f9b76f6ed 100644
--- a/blade-service/logpm-warehouse/src/main/java/com/logpm/warehouse/api/WarehouseTrayTypeApiController.java
+++ b/blade-service/logpm-warehouse/src/main/java/com/logpm/warehouse/api/WarehouseTrayTypeApiController.java
@@ -1,5 +1,7 @@
 package com.logpm.warehouse.api;
 
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport;
 import com.logpm.basicdata.entity.BasicdataWarehouseEntity;
@@ -23,10 +25,7 @@ import org.springblade.system.cache.DictBizCache;
 import org.springblade.system.entity.DictBiz;
 import org.springframework.web.bind.annotation.*;
 
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-import java.util.Objects;
+import java.util.*;
 
 @Log4j2
 @RestController
@@ -1337,6 +1336,78 @@ public class WarehouseTrayTypeApiController {
 		}
 	}
 
+	@ResponseBody
+	@PostMapping("/batchSyncOldTrayTypeInfo")
+	@ApiOperationSupport(order = 1)
+	@ApiOperation(value = "批量同步老系统托盘数据", notes = "传入trayTypeDTO")
+	public R batchSyncOldTrayTypeInfo(@RequestBody TrayTypeDTO trayTypeDTO) {
+		String method = "###########batchSyncOldTrayTypeInfo: ";
+		log.info(method + "移托包件 trayTypeDTO={}", trayTypeDTO);
+		String trayCodeStr = trayTypeDTO.getTrayCode();
+
+		try{
+
+			BasicdataWarehouseEntity myCurrentWarehouse = warehouseClient.getMyCurrentWarehouse();
+			if(Objects.isNull(myCurrentWarehouse)){
+				log.warn(method+"仓库信息不能为空");
+				return R.fail(403,"仓库信息不能为空");
+			}
 
+			if(StringUtil.isBlank(trayCodeStr)){
+				log.warn(method+"托盘码不能为空 trayCodeStr={}",trayCodeStr);
+				return R.fail(403,"托盘码不能为空");
+			}
+			List<String> trayCodes = new ArrayList<>();
+			if(trayCodeStr.contains(",")){
+				String[] split = trayCodeStr.split(",");
+				trayCodes.addAll(Arrays.asList(split));
+			}else{
+				trayCodes.add(trayCodeStr);
+			}
+
+			for (String trayCode : trayCodes) {
+				log.info(method+"当前同步的托盘 trayCode={}",trayCode);
+				R trayData = warehouseTrayTypeService.findTrayData(trayCode, myCurrentWarehouse.getId());
+				Object data = trayData.getData();
+				String s = JSONObject.toJSONString(data);
+				JSONObject jsonObject = JSONObject.parseObject(s);
+				JSONArray packageList = jsonObject.getJSONArray("packageList");
+				JSONArray zeroOrderList = jsonObject.getJSONArray("zeroOrderList");
+				JSONArray stockOrderList = jsonObject.getJSONArray("stockOrderList");
+				int packageSize = packageList.size();
+				int zeroSize = zeroOrderList.size();
+				int stockSize = stockOrderList.size();
+				int total = packageSize+zeroSize+stockSize;
+
+				R syncOldTrayData = warehouseTrayTypeService.findSyncOldTrayData(trayCode, myCurrentWarehouse.getId());
+				Object data1 = syncOldTrayData.getData();
+				String s1 = JSONObject.toJSONString(data1);
+				JSONObject jsonObject1 = JSONObject.parseObject(s1);
+				JSONArray packageList1 = jsonObject1.getJSONArray("packageList");
+				String trayType1 = jsonObject1.getString("trayType");
+				String trayCode1 = jsonObject1.getString("trayCode");
+				int size = packageList1.size();
+				if(total >= size){
+					log.warn(method+"新系统打托数量大于等于老系统 trayCode={}  不同步",trayCode);
+					continue;
+				}
+				List<String> orderPackageCodes = new ArrayList<>();
+				for (int i = 0; i < size; i++){
+					JSONObject jsonObject2 = packageList1.getJSONObject(i);
+					orderPackageCodes.add(jsonObject2.getString("orderPackageCode"));
+				}
+
+				warehouseTrayTypeService.syncOldTrayData(trayCode1,trayType1,orderPackageCodes,myCurrentWarehouse.getId(),"同步老系统打托");
+			}
+
+			return R.success("处理完成");
+		}catch (CustomerException e){
+			log.warn(e.message);
+			return R.fail(e.code,e.message);
+		}catch (Exception e){
+			log.error(method+"系统异常，联系管理员",e);
+			return R.fail(500,"系统异常，联系管理员");
+		}
+	}
 
 }