From 550b14e27b9bba40e80f1141d0943d1dc62acbbc Mon Sep 17 00:00:00 2001
From: 陈战涛 <chenzhantao7055@sina.com>
Date: 星期一, 22 五月 2023 15:26:55 +0800
Subject: [PATCH] 优化广东粮食购销接口

---
 src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1202.java |   22 +++++++++++++---------
 1 files changed, 13 insertions(+), 9 deletions(-)

diff --git a/src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1202.java b/src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1202.java
index d369ba9..cbc63a9 100644
--- a/src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1202.java
+++ b/src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1202.java
@@ -3,6 +3,7 @@
 import com.fzzy.api.Constant;
 import com.fzzy.api.entity.Api1105;
 import com.fzzy.api.entity.Api1202;
+import com.fzzy.api.entity.Api1208;
 import com.fzzy.api.entity.ApiLog;
 import com.fzzy.api.service.ApiCommonService;
 import com.fzzy.api.service.ApiTriggerService;
@@ -78,16 +79,19 @@
             Api1202 apiData;
             Api1105 api1105;
             List<Fz35InoutNoticeIn> listInoutNotice;
+            List<Api1202> api1202List;
             Calendar c = Calendar.getInstance();
             for (Fz35InoutRecord sysData : list) {
+                //鍒ゆ柇鍑�閲嶆槸鍚﹀ぇ浜�0锛岀瓑浜�0琛ㄧず涓嶅悎鏍硷紝涓嶈繘琛屽悓姝ヤ笂浼�
+                if(sysData.getRecordWeight() == 0){
+                    continue;
+                }
                 //鑾峰彇璐т綅淇℃伅
                 api1105 = commonService.getApi1105Cache(sysData.getDepotId());
                 if (null == api1105) {
                     continue;
                 }
                 apiData = new Api1202();
-
-                apiData.setId(sysData.getId());
 
                 apiData.setRkywdh(Constant.INOUT_TYPE_14 + sysData.getId().substring(4));
 
@@ -164,25 +168,25 @@
                 //鍊间粨 鐜板満鎵i噸
                 apiData.setXckl( 0 - sysData.getDeHandle());
 
-
-                apiData.setJz(sysData.getSettleWeight());
+                apiData.setJz(sysData.getRecordWeight());
                 c.setTime(sysData.getCompleteTime());
                 c.add(Calendar.MINUTE,3);
                 apiData.setCmsj(c.getTime());
 
-
-                //鍏ュ簱缁撶畻鍗曞彿
-                apiData.setRkjsdh(kqdm + sysData.getId().substring(2));
+                //鍏ュ簱缁撶畻鍗曞彿,榛樿缁熶竴缁撶畻锛屼笉璁剧疆缁撶畻鍗曞彿
+                //apiData.setRkjsdh(kqdm + sysData.getId().substring(2));
 
                 //鎿嶄綔鏍囧織鍙婃渶鍚庢洿鏂版椂闂�
-                apiData.setCzbz(Constant.CZBZ_I);
                 apiData.setZhgxsj(c.getTime());
 
                 //涓氬姟id銆佸簱鍖虹紪鐮併�佸悓姝ユ椂闂�
                 apiData.setBizId(sysData.getId());
                 apiData.setKqdm(kqdm);
                 apiData.setSyncTime(new Date());
-
+                api1202List = api1202Rep.getDataById(apiData.getRkywdh());
+                if(null == api1202List || api1202List.isEmpty()){
+                    apiData.setCzbz(Constant.CZBZ_I);
+                }
                 //淇濆瓨鏁版嵁
                 api1202Rep.save(apiData);
                 log.info("1202---鍚屾鏁版嵁锛歿}", apiData.toString());

--
Gitblit v1.9.3