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