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/Fzzy35Sync1205.java | 31 +++++++++++++++++++++++-------- 1 files changed, 23 insertions(+), 8 deletions(-) diff --git a/src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1205.java b/src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1205.java index 91702ab..6cddd0d 100644 --- a/src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1205.java +++ b/src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1205.java @@ -18,9 +18,8 @@ import org.apache.commons.lang.time.DateFormatUtils; 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.*; /** * 绮鍑哄簱淇℃伅 @@ -78,11 +77,16 @@ Api1105 api1105; List<Fz35InoutNoticeOut> listInoutNotice; List<Api1205> api1205List; - // List<GbArea> gbAreaList; 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; } //鑾峰彇璐т綅淇℃伅 @@ -92,7 +96,16 @@ } apiData = new Api1205(); apiData.setCkywdh(Constant.INOUT_TYPE_15 + 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.setCkywdh(Constant.INOUT_TYPE_15 + ywsj + num); + map.put(ywsj, map.get(ywsj) + 1); + } //璐т綅浠g爜 apiData.setHwdm(api1105.getHwdm()); @@ -112,8 +125,8 @@ } - //杩愯緭宸ュ叿锛岄粯璁ゆ苯杞� - apiData.setYsgj("1"); + //杩愯緭宸ュ叿锛岃嫢涓虹┖锛屽垯榛樿缁�1-姹借溅 + apiData.setYsgj(StringUtils.isEmpty(sysData.getTransType()) ? "1":sysData.getTransType()); //杞﹁埞鍙� apiData.setCch(sysData.getPlateNum()); @@ -169,6 +182,8 @@ api1205List = api1205Rep.getDataById(apiData.getCkywdh()); if(null == api1205List || api1205List.isEmpty()){ apiData.setCzbz(Constant.CZBZ_I); + }else { + apiData.setCzbz(api1205List.get(0).getCzbz()); } //淇濆瓨鏁版嵁 api1205Rep.save(apiData); -- Gitblit v1.9.3