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/otherview/sh2023/pr/SHApi2101PR.java | 17 +++++------------ 1 files changed, 5 insertions(+), 12 deletions(-) diff --git a/src/main/java/com/fzzy/otherview/sh2023/pr/SHApi2101PR.java b/src/main/java/com/fzzy/otherview/sh2023/pr/SHApi2101PR.java index 01284de..c403fdf 100644 --- a/src/main/java/com/fzzy/otherview/sh2023/pr/SHApi2101PR.java +++ b/src/main/java/com/fzzy/otherview/sh2023/pr/SHApi2101PR.java @@ -9,7 +9,6 @@ import com.fzzy.api.Constant; import com.fzzy.api.data.ApiParam; import com.fzzy.api.dto.ResponseDto; -import com.fzzy.api.entity.Api1204; import com.fzzy.api.entity.ApiConfs; import com.fzzy.api.entity.ApiInfoData; import com.fzzy.api.service.ApiCommonService; @@ -17,15 +16,10 @@ import com.fzzy.api.service.ApiRemoteService; import com.fzzy.api.utils.ContextUtil; import com.fzzy.api.view.repository.ApiInfoDataRep; -import com.fzzy.otherview.gd2022.dto.GdApi1023; -import com.fzzy.otherview.whhpjl.WhjlConstant; -import com.fzzy.otherview.whhpjl.dto.WhjlApi1101; -import com.fzzy.push.gd2022.ApiCodeConstant; import com.fzzy.push.sh2023.SH2023Constant; import com.fzzy.push.sh2023.dto.SH2023Api2101; import org.apache.commons.lang.StringUtils; import org.apache.commons.lang.time.DateFormatUtils; -import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.domain.PageRequest; import org.springframework.data.domain.Pageable; @@ -40,7 +34,6 @@ import java.util.ArrayList; import java.util.Date; import java.util.List; -import java.util.Map; /** * 涓婃捣甯傛帴鍙�-2101 妫�鏂ゅ崟 @@ -121,7 +114,7 @@ data.setPch(data.getHwdm() + DateFormatUtils.format(data.getJjrq(), "yyyy")); } ApiInfoData infoData; - List<ApiInfoData> apiInfoList = apiInfoDataRep.getDataByInteAndData(SH2023Constant.SH_2023_API_CODE_2101, data.getJjdh()); + List<ApiInfoData> apiInfoList = apiInfoDataRep.getDataByInteAndData(SH2023Constant.SH_2023_API_CODE_2101, data.getJjdh(),data.getKqdm()); if (apiInfoList.size() != 0) { infoData = apiInfoList.get(0); infoData.setData(JSON.toJSONString(data)); @@ -145,7 +138,7 @@ */ @Expose public void delData(SH2023Api2101 data) { - List<ApiInfoData> apiInfoList = apiInfoDataRep.getDataByInteAndData(SH2023Constant.SH_2023_API_CODE_2101, data.getJjdh()); + List<ApiInfoData> apiInfoList = apiInfoDataRep.getDataByInteAndData(SH2023Constant.SH_2023_API_CODE_2101, data.getJjdh(),data.getKqdm()); apiInfoDataRep.deleteById(apiInfoList.get(0).getId()); } @@ -157,7 +150,7 @@ if (null == data) { return "鏃犳暟鎹墽琛�"; } - List<ApiInfoData> apiInfoList = apiInfoDataRep.getDataByInteAndData(SH2023Constant.SH_2023_API_CODE_2101, data.getJjdh()); + List<ApiInfoData> apiInfoList = apiInfoDataRep.getDataByInteAndData(SH2023Constant.SH_2023_API_CODE_2101, data.getJjdh(),data.getKqdm()); data.setCzbz(Constant.CZBZ_D); apiInfoDataRep.updateStatus(apiInfoList.get(0).getId(), JSON.toJSONString(data), Constant.CZBZ_D); return null; @@ -176,7 +169,7 @@ } //灏佽鍙傛暟 - ApiParam param = new ApiParam(apiConf, "21", SH2023Constant.SH_2023_API_CODE_2101); + ApiParam param = new ApiParam(apiConf, "90", Constant.API_CODE_9105); //鑾峰彇瀹炵幇鎺ュ彛 ApiRemoteService apiService = apiPushManager.getApiRemoteService(param.getPushProtocol()); @@ -192,7 +185,7 @@ for (SH2023Api2101 data : items) { if (Constant.CZBZ_I.equals(data.getCzbz())) { //鎺ㄩ�佹垚鍔燂紝鏇存柊鏁版嵁涓婁紶鐘舵�� - List<ApiInfoData> apiInfoList = apiInfoDataRep.getDataByInteAndData(SH2023Constant.SH_2023_API_CODE_2101, data.getJjdh()); + List<ApiInfoData> apiInfoList = apiInfoDataRep.getDataByInteAndData(SH2023Constant.SH_2023_API_CODE_2101, data.getJjdh(),data.getKqdm()); data.setCzbz(Constant.CZBZ_U); infoData = apiInfoList.get(0); infoData.setUpdateTime(new Date()); -- Gitblit v1.9.3