From 7ac1c19249561ef5cc0bf277ef3c683e7515a146 Mon Sep 17 00:00:00 2001
From: CZT <czt18638530771@163.com>
Date: 星期四, 10 八月 2023 18:28:45 +0800
Subject: [PATCH] 新增客户单位信息同步

---
 src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1212.java |   41 +++++++++++++++++------------------------
 1 files changed, 17 insertions(+), 24 deletions(-)

diff --git a/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1212.java b/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1212.java
index adb09e6..7fbc451 100644
--- a/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1212.java
+++ b/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1212.java
@@ -3,7 +3,6 @@
 import com.fzzy.api.Constant;
 import com.fzzy.api.entity.*;
 import com.fzzy.api.utils.ContextUtil;
-import com.fzzy.api.view.repository.Api1101Rep;
 import com.fzzy.api.view.repository.Api1102Rep;
 import com.fzzy.api.view.repository.Api1212Rep;
 import com.fzzy.api.view.repository.ApiLogRep;
@@ -27,8 +26,6 @@
     private Fzzy40Sync1212Rep fzzySync1212Rep;
     @Autowired
     private Api1102Rep api1102Rep;
-    @Autowired
-    private Api1101Rep api1101Rep;
     @Autowired
     private Api1212Rep api1212Rep;
     @Autowired
@@ -63,37 +60,33 @@
 
             //鏍规嵁搴撳尯浠g爜鑾峰彇搴撳尯浠g爜
             Api1102 api1201 = api1102Rep.findById(kqdm).get();
-            List<Api1101> list1 = api1101Rep.findPushData(kqdm);
-            Api1101 api1101 = list1.get(0);
 
             Api1212 apiData;
             List<Api1212> api1212List;
             for (Fz40InoutCustomer sysData : list) {
 
                 apiData = new Api1212();
-
-                apiData.setId(sysData.getId());
-                //鍗曚綅浠g爜锛� 1101 鎺ュ彛鐨勫崟浣嶄唬 鐮侊級 +鑷畾涔夌紪鐮�
-                apiData.setDwdm(api1101.getDwdm());
-                apiData.setDwmc(api1101.getDwmc());
-                apiData.setKqmc(api1201.getKqmc());
+                //鍗曚綅浠g爜
+                apiData.setId(sysData.getKhbh());
+                apiData.setDwdm(api1201.getDwdm());
                 apiData.setKqdm(kqdm);
-                apiData.setKhlx(StringUtils.isEmpty(sysData.getKhlx()) ? "1":sysData.getKhlx());
-                apiData.setKhtyshxydmhsfzh(sysData.getCardId());
+                apiData.setKhlx(sysData.getKhlx());
+                apiData.setKhtyshxydmhsfzh(sysData.getKhbh());
                 apiData.setKhmc(sysData.getName());
-
-                apiData.setFddbr(StringUtils.isEmpty(sysData.getFddbr())? "娉曞畾浜�" : sysData.getFddbr());
-
-                apiData.setTxdz(sysData.getAddress());
-                apiData.setYzbm(sysData.getYzbm());
-                apiData.setLxrdh(sysData.getContactUser());
-                apiData.setKhfkhh(sysData.getBank());
-                apiData.setKhfzh(sysData.getBankNum());
+                apiData.setFddbr(sysData.getFddbr());
+                apiData.setTxdz(StringUtils.isEmpty(sysData.getAddress()) ? "鍗曚綅鍦板潃" :sysData.getAddress());
+                apiData.setYzbm(StringUtils.isEmpty(sysData.getYzbm()) ? "" :sysData.getYzbm());
+                apiData.setLxrxm(StringUtils.isEmpty(sysData.getContactUser()) ? sysData.getFddbr() :sysData.getContactUser());
+                apiData.setLxrdh(StringUtils.isEmpty(sysData.getPhone()) ? "" :sysData.getPhone());
+                apiData.setLxrsfzh(StringUtils.isEmpty(sysData.getCardId()) ? "100000000000000000" :sysData.getCardId());
+                apiData.setDzyx(StringUtils.isEmpty(sysData.getDzyx()) ? "" :sysData.getDzyx());
+//                apiData.setKhfkhh(StringUtils.isEmpty(sysData.getBank()) ? "" :sysData.getBank());
+                apiData.setKhfzh(StringUtils.isEmpty(sysData.getBankNum()) ? "" :sysData.getBankNum());
+                apiData.setZhgxsj(sysData.getUpdateTime());
                 apiData.setBizId(sysData.getId());
-                apiData.setZhgxsj(new Date());
 
-                api1212List = api1212Rep.getDataById(apiData.getId());
 
+                api1212List = api1212Rep.getDataById(sysData.getKhbh());
                 if(null == api1212List || api1212List.isEmpty()){
                     apiData.setCzbz(Constant.CZBZ_I);
                 }else {
@@ -103,7 +96,7 @@
                 //淇濆瓨鏁版嵁
                 api1212Rep.save(apiData);
 
-                log.info("1201---鍚屾鏁版嵁锛歿}", apiData.toString());
+                log.info("1212---鍚屾鏁版嵁锛歿}", apiData.toString());
             }
         } catch (Exception e) {
             log.error("---鍚堝悓鍚屾鎵ц澶辫触----{}", e);

--
Gitblit v1.9.3