From 954480166aad6d24c9e9889906a0edf762f0da2a Mon Sep 17 00:00:00 2001
From: czt <czt18638530771@163.com>
Date: 星期一, 10 二月 2025 16:32:56 +0800
Subject: [PATCH] 优化库存同步
---
src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1207.java | 17 +++++++++++++++--
1 files changed, 15 insertions(+), 2 deletions(-)
diff --git a/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1207.java b/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1207.java
index 1561e8b..2771377 100644
--- a/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1207.java
+++ b/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1207.java
@@ -15,6 +15,7 @@
import com.fzzy.async.fzzy40.repository.Fzzy40Sync1202Rep;
import com.fzzy.async.fzzy40.repository.Fzzy40Sync1207Rep;
import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
@@ -36,6 +37,8 @@
private ApiCommonService commonService;
@Autowired
private Api1207Rep api1207Rep;
+ @Autowired
+ private ApiTriggerService apiTriggerService;
@Autowired
private ApiLogRep apiLogRep;
@@ -69,6 +72,7 @@
Api1207 apiData;
Api1105 api1105In;
Api1105 api1105Out;
+ List<Api1207> api1207List;
for (Fz40InoutStockChange sysData : list) {
//鑾峰彇璐т綅淇℃伅
api1105Out = commonService.getApi1105Cache(sysData.getDepotIdOut());
@@ -87,21 +91,30 @@
apiData.setTzdh(sysData.getNoticeId());
apiData.setDcdw(kqdm);
apiData.setDrdw(kqdm);
- apiData.setLspzdm(sysData.getFoodVariety());
+ String mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSPZ, sysData.getFoodVariety().substring(0, 3));
+ apiData.setLspzdm(mappingCode);
apiData.setDchwdm(api1105Out.getHwdm());
apiData.setDrhwdm(api1105In.getHwdm());
apiData.setDcrq(sysData.getChangeDate());
+ apiData.setDcksrq(sysData.getChangeStartDate());
+ apiData.setDcjsrq(sysData.getChangeEndDate());
apiData.setDcsl(sysData.getNumber());
apiData.setBzw(sysData.getBzw());
apiData.setBzbjs(sysData.getBzbjs());
apiData.setZxzydw(sysData.getZxzydw());
- apiData.setCzbz(Constant.CZBZ_I);
apiData.setZhgxsj(sysData.getUpdateTime());
apiData.setBizId(sysData.getId());
apiData.setKqdm(kqdm);
apiData.setSyncTime(new Date());
+ api1207List = api1207Rep.getDataById(apiData.getDcdh());
+ if (null == api1207List || api1207List.isEmpty()) {
+ apiData.setCzbz(Constant.CZBZ_I);
+ } else {
+ apiData.setCzbz(api1207List.get(0).getCzbz());
+ }
+
//淇濆瓨鏁版嵁
api1207Rep.save(apiData);
log.info("1207---鍚屾鏁版嵁锛歿}", apiData.toString());
--
Gitblit v1.9.3