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/Fzzy35Sync1203.java | 32 ++++++++++++++++++-------------- 1 files changed, 18 insertions(+), 14 deletions(-) diff --git a/src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1203.java b/src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1203.java index ed9b4f6..2583529 100644 --- a/src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1203.java +++ b/src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1203.java @@ -5,6 +5,7 @@ import com.fzzy.api.service.ApiCommonService; import com.fzzy.api.service.ApiTriggerService; import com.fzzy.api.utils.ContextUtil; +import com.fzzy.api.view.repository.Api1202Rep; import com.fzzy.api.view.repository.Api1203Rep; import com.fzzy.api.view.repository.ApiLogRep; import com.fzzy.api.view.repository.GbCheckItemRep; @@ -14,6 +15,7 @@ import com.fzzy.async.fzzy35.repository.Fzzy35Sync1203Rep; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang.StringUtils; +import org.apache.commons.lang.time.DateFormatUtils; import org.apache.commons.lang.time.DateUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; @@ -37,9 +39,10 @@ private Fzzy35Sync1202Rep fzzySync1202Rep; @Autowired private Fzzy35Sync1203Rep fzzySync1203Rep; - @Autowired private ApiTriggerService apiTriggerService; + @Autowired + private Api1202Rep api1202Rep; @Autowired private Api1203Rep api1203Rep; @Autowired @@ -86,12 +89,14 @@ String zkj; String zkl; List<Api1203> api1203List; + List<Api1202> api1102List; for (Fz35InoutRecord sysData : list) { - //鍒ゆ柇鍑�閲嶆槸鍚﹀ぇ浜�0锛岀瓑浜�0琛ㄧず涓嶅悎鏍硷紝涓嶈繘琛屽悓姝ヤ笂浼� - if(null == sysData.getRecordWeight() || sysData.getRecordWeight() == 0){ + //鏌ヨ绮鍏ュ簱淇℃伅锛岃嫢涓虹┖鍒欎笉杩涜鍚屾涓婁紶 + api1102List = api1202Rep.getDataByBizId(sysData.getId()); + if(null == api1102List || api1102List.isEmpty()){ continue; } - fz35CheckItems = null; + //鑾峰彇鍏ュ簱璐ㄦ淇℃伅 fz35CheckItems = fzzySync1203Rep.listInoutCheckItem(sysData.getCheckId(), deptId.substring(0, 4)); if (null == fz35CheckItems || fz35CheckItems.isEmpty()) { @@ -99,19 +104,15 @@ continue; } - //鑾峰彇璐т綅淇℃伅 - api1105 = commonService.getApi1105Cache(sysData.getDepotId()); - if (null == api1105) { - continue; - } - apiData = new Api1203(); - apiData.setRkjydh(Constant.INOUT_TYPE_14 + sysData.getId().substring(4)); - + apiData.setRkjydh(api1102List.get(0).getRkywdh()); //璐т綅浠g爜 - apiData.setHwdm(api1105.getHwdm()); - apiData.setRkywdh(apiData.getRkjydh()); + apiData.setHwdm(api1102List.get(0).getHwdm()); + apiData.setRkywdh(api1102List.get(0).getRkywdh()); + if(null == sysData.getFullWeightTime()){ + sysData.setFullWeightTime(DateUtils.addMinutes(sysData.getRegisterTime(), 5)); + } apiData.setQysj(sysData.getFullWeightTime()); apiData.setQyrxm(sysData.getCheckUser()); //鎵︽牱鏂瑰紡 2-鏅鸿兘闅忔満 @@ -154,6 +155,9 @@ String mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSPZ, sysData.getFoodVariety()); apiData.setLspzdm(mappingCode); + //淇濈鍛樺鏍� + apiData.setBgyfh(apiData.getJyjg()); + //绮绛夌骇 mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSDJ, sysData.getFoodLevel()); apiData.setLsdd(mappingCode); -- Gitblit v1.9.3