From ce9d44e48aa77ebf2537f22ff8bf4a70089d0474 Mon Sep 17 00:00:00 2001
From: CZT <czt18638530771@163.com>
Date: 星期二, 22 八月 2023 18:17:29 +0800
Subject: [PATCH] 优化3.5和4.0版本的出入库信息同步

---
 src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1202.java |   30 +++++++++++++++++++++++-------
 1 files changed, 23 insertions(+), 7 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 cbc63a9..4fdc9f4 100644
--- a/src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1202.java
+++ b/src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1202.java
@@ -20,9 +20,7 @@
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
-import java.util.Calendar;
-import java.util.Date;
-import java.util.List;
+import java.util.*;
 
 /**
  * 绮鍏ュ簱淇℃伅
@@ -81,9 +79,15 @@
             List<Fz35InoutNoticeIn> listInoutNotice;
             List<Api1202> api1202List;
             Calendar c = Calendar.getInstance();
+            String ywsj = "";
+            String num = "";
+            Map<String, Integer> map = new HashMap<>();
             for (Fz35InoutRecord sysData : list) {
+                if(null == sysData.getRecordWeight() || sysData.getRecordWeight() == 0){
+                    sysData.setRecordWeight(sysData.getSettleWeight());
+                }
                 //鍒ゆ柇鍑�閲嶆槸鍚﹀ぇ浜�0锛岀瓑浜�0琛ㄧず涓嶅悎鏍硷紝涓嶈繘琛屽悓姝ヤ笂浼�
-                if(sysData.getRecordWeight() == 0){
+                if(null == sysData.getRecordWeight() || sysData.getRecordWeight() == 0){
                     continue;
                 }
                 //鑾峰彇璐т綅淇℃伅
@@ -94,6 +98,16 @@
                 apiData = new Api1202();
 
                 apiData.setRkywdh(Constant.INOUT_TYPE_14 + sysData.getId().substring(4));
+                //鍒ゆ柇涓氬姟鏃堕棿涓庡崟鎹彿鏄惁鍖归厤
+                ywsj = DateFormatUtils.format(sysData.getCompleteTime(),"yyMMdd");
+                if(!ywsj.equals(sysData.getId().substring(4, 10))){
+                    if(null == map.get(ywsj)){
+                        map.put(ywsj, 10201);
+                    }
+                    num = String.valueOf(map.get(ywsj)).substring(1);
+                    apiData.setRkywdh(Constant.INOUT_TYPE_14 + ywsj + num);
+                    map.put(ywsj, map.get(ywsj) + 1);
+                }
 
                 //璐т綅浠g爜
                 apiData.setHwdm(api1105.getHwdm());
@@ -104,7 +118,7 @@
                 //榛樿涓�涓殢渚垮��
                 apiData.setLxdh(StringUtils.isEmpty(sysData.getUserContact()) ? "13012345678" : sysData.getUserContact());
 
-                apiData.setSfzh(null == sysData.getUserId() ? "410183200010100000" : sysData.getUserId());
+                apiData.setSfzh(null == sysData.getUserId() ? "410183200010100000" : sysData.getUserId().trim());
 
                 //鑾峰彇鍚堝悓鍙�
                 listInoutNotice = fzzy35SyncNoticeInRep.listInoutNoticeInById(sysData.getNoticeId());
@@ -116,8 +130,8 @@
 
                 apiData.setXxdz(sysData.getUserAddress());
 
-                //杩愯緭宸ュ叿锛岄粯璁ゆ苯杞︼紝TODO>> 寰呰皟鏁翠负鏍规嵁鏁版嵁搴撹幏鍙�
-                apiData.setYsgj("1");
+                //杩愯緭宸ュ叿锛岃嫢涓虹┖锛屽垯榛樿缁�1-姹借溅
+                apiData.setYsgj(StringUtils.isEmpty(sysData.getTransType()) ? "1":sysData.getTransType());
 
                 //杞﹁埞鍙�
                 apiData.setCch(sysData.getPlateNum());
@@ -186,6 +200,8 @@
                 api1202List = api1202Rep.getDataById(apiData.getRkywdh());
                 if(null == api1202List || api1202List.isEmpty()){
                     apiData.setCzbz(Constant.CZBZ_I);
+                }else {
+                    apiData.setCzbz(api1202List.get(0).getCzbz());
                 }
                 //淇濆瓨鏁版嵁
                 api1202Rep.save(apiData);

--
Gitblit v1.9.3