From 7494eb35eb0e6a3f33dff907133e59f677800003 Mon Sep 17 00:00:00 2001
From: 陈战涛 <chenzhantao7055@sina.com>
Date: 星期四, 25 五月 2023 11:29:27 +0800
Subject: [PATCH] 优化3.5版本同步时,操作标志的状态

---
 src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1302.java |   11 +++++++----
 1 files changed, 7 insertions(+), 4 deletions(-)

diff --git a/src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1302.java b/src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1302.java
index c4bf0c7..2103ef8 100644
--- a/src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1302.java
+++ b/src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1302.java
@@ -16,7 +16,6 @@
 import org.apache.commons.lang.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
-
 import java.util.Date;
 import java.util.List;
 
@@ -71,7 +70,7 @@
             Date syncTime = new Date();
             Api1302 api1302;
             Api1105 api1105;
-            //int index = 10001;
+            List<Api1302> api1302List;
             for (Fz35Grain fz35Grain : list) {
                 //鑾峰彇璐т綅淇℃伅
                 api1105 = commonService.getApi1105Cache(fz35Grain.getDepotId());
@@ -113,15 +112,19 @@
                     api1302.setLssdzjh(getHumPointList2(fz35Grain.getPoints(), fz35Grain.getCable(), fz35Grain.getCableCir()));
                 }
 
-                api1302.setCzbz(Constant.CZBZ_I);
                 api1302.setZhgxsj(syncTime);
 
                 api1302.setBizId(fz35Grain.getBatchId());
                 api1302.setKqdm(api1105.getKqdm());
                 api1302.setSyncTime(syncTime);
+                api1302List = api1302Rep.getDataByWsdjcdh(api1302.getWsdjcdh());
+                if(null == api1302List || api1302List.isEmpty()){
+                    api1302.setCzbz(Constant.CZBZ_I);
+                }else {
+                    api1302.setCzbz(api1302List.get(0).getCzbz());
+                }
                 log.info("1302---鍚屾鏁版嵁锛�" + api1302.toString());
                 api1302Rep.save(api1302);
-               // index++;
             }
 
         } catch (Exception e) {

--
Gitblit v1.9.3