From 81f8164227bd019f8fe0233e0bebfe5614bfa644 Mon Sep 17 00:00:00 2001
From: CZT <czt18638530771@163.com>
Date: 星期三, 29 十一月 2023 17:57:45 +0800
Subject: [PATCH] 优化倒仓数据同步

---
 src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1207.java |    9 ++++++++-
 1 files changed, 8 insertions(+), 1 deletions(-)

diff --git a/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1207.java b/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1207.java
index 3008cba..eb5c271 100644
--- a/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1207.java
+++ b/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1207.java
@@ -72,6 +72,7 @@
             Api1207 apiData;
             Api1105 api1105In;
             Api1105 api1105Out;
+            List<Api1207> api1207List;
             for (Fz40InoutStockChange sysData : list) {
                 //鑾峰彇璐т綅淇℃伅
                 api1105Out = commonService.getApi1105Cache(sysData.getDepotIdOut());
@@ -99,13 +100,19 @@
                 apiData.setBzw(sysData.getBzw());
                 apiData.setBzbjs(sysData.getBzbjs());
                 apiData.setZxzydw(sysData.getZxzydw());
-                apiData.setCzbz(Constant.CZBZ_I);
                 apiData.setZhgxsj(sysData.getUpdateTime());
 
                 apiData.setBizId(sysData.getId());
                 apiData.setKqdm(kqdm);
                 apiData.setSyncTime(new Date());
 
+                api1207List = api1207Rep.getDataById(apiData.getDcdh());
+                if (null == api1207List || api1207List.isEmpty()) {
+                    apiData.setCzbz(Constant.CZBZ_I);
+                } else {
+                    apiData.setCzbz(api1207List.get(0).getCzbz());
+                }
+
                 //淇濆瓨鏁版嵁
                 api1207Rep.save(apiData);
                 log.info("1207---鍚屾鏁版嵁锛歿}", apiData.toString());

--
Gitblit v1.9.3