From ac9b4c99b2534e31a8ce9948b376feb514c2ec20 Mon Sep 17 00:00:00 2001 From: CZT <czt18638530771@163.com> Date: 星期五, 01 三月 2024 11:31:52 +0800 Subject: [PATCH] 优化损益数据同步 --- src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1202.java | 26 ++++++++++++++++++-------- 1 files changed, 18 insertions(+), 8 deletions(-) diff --git a/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1202.java b/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1202.java index 03b7474..def2483 100644 --- a/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1202.java +++ b/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1202.java @@ -5,7 +5,6 @@ import com.fzzy.api.service.ApiCommonService; import com.fzzy.api.service.ApiTriggerService; import com.fzzy.api.utils.ContextUtil; -import com.fzzy.api.utils.DateUtil; import com.fzzy.api.view.repository.Api1201Rep; import com.fzzy.api.view.repository.Api1202Rep; import com.fzzy.api.view.repository.Api1404Rep; @@ -22,9 +21,6 @@ import org.apache.commons.lang.time.DateUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; - -import java.text.ParseException; -import java.text.SimpleDateFormat; import java.util.*; /** @@ -121,7 +117,10 @@ //榛樿涓�涓殢渚垮�� apiData.setLxdh(StringUtils.isEmpty(sysData.getUserContact()) ? "13012345678" : sysData.getUserContact().trim()); - apiData.setSfzh(null == sysData.getUserId() ? "410183200010100000" : sysData.getUserId().trim()); + if(StringUtils.isEmpty(sysData.getUserId()) || sysData.getUserId().length() != 18){ + sysData.setUserId("410183199003187055"); + } + apiData.setSfzh(sysData.getUserId()); //鑾峰彇閫氱煡鍗曚俊鎭紝鏌ヨ鍚堝悓鍙峰拰璁″垝鏄庣粏鍙� listInoutNotice = fzzySyncNoticeInRep.listInoutNoticeInById(sysData.getNoticeId()); @@ -134,9 +133,12 @@ } } if (StringUtils.isNotEmpty(listInoutNotice.get(0).getPlanId())) { - api1404List = api1404Rep.getDataByBizId(listInoutNotice.get(0).getPlanId()); + api1404List = api1404Rep.getDataByBizIdAndKqdm(listInoutNotice.get(0).getPlanId(), kqdm); if(null != api1404List && api1404List.size() > 0){ apiData.setJhmxh(api1404List.get(0).getJhmxdh()); + if(StringUtils.isEmpty(sysData.getFoodYear())){ + sysData.setFoodYear(api1404List.get(0).getShnd()); + } } } } @@ -159,7 +161,7 @@ mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSXZ, sysData.getFoodType()); apiData.setLsxzdm(mappingCode); - apiData.setShnd(StringUtils.isEmpty(sysData.getFoodYear()) ? DateFormatUtils.format(new Date(), "yyyy") : sysData.getFoodYear()); + apiData.setShnd(StringUtils.isEmpty(sysData.getFoodYear()) ? DateFormatUtils.format(sysData.getRegisterTime(), "yyyy") : sysData.getFoodYear()); //浜у湴浠g爜 mappingCode = commonService.getFoodLocationIdFromCache(sysData.getFoodLocation()); @@ -202,7 +204,10 @@ apiData.setBzwkl(0 - sysData.getDePackage()); apiData.setBzbjs(sysData.getBzbjs()); - + apiData.setCmsj(sysData.getCompleteTime()); + if(StringUtils.isNotEmpty(sysData.getSettleId())){ + apiData.setRkjsdh(kqdm + sysData.getSettleId()); + } //鍏跺畠 apiData.setQtkl(0 - sysData.getDeOther()); //鍊间粨 鐜板満鎵i噸 @@ -232,6 +237,9 @@ int idNum = Integer.valueOf(sysData.getId().substring(12)) * 100 + 10001; for (Fz40InoutRecordItem fz40InoutRecordItem : listInoutRecordItem) { + if ("DEL".equals(fz40InoutRecordItem.getRecordStatus())) { + continue; + } if (fz40InoutRecordItem.getSettleWeight() <= 0) { continue; } @@ -239,6 +247,8 @@ apiData.setMz(fz40InoutRecordItem.getFullWeight()); apiData.setPz(fz40InoutRecordItem.getEmptyWeight()); apiData.setJz(fz40InoutRecordItem.getSettleWeight()); + apiData.setMzjlsj(fz40InoutRecordItem.getFullWeightTime()); + apiData.setPzjlsj(fz40InoutRecordItem.getEmptyWeightTime()); api1202List = api1202Rep.getDataById(apiData.getRkywdh()); if (null == api1202List || api1202List.isEmpty()) { apiData.setCzbz(Constant.CZBZ_I); -- Gitblit v1.9.3