From 9f6dacf7b39e5aeba37d8faf575c9e56d8cbe51a Mon Sep 17 00:00:00 2001 From: czt <czt18638530771@163.com> Date: 星期六, 11 十月 2025 13:35:42 +0800 Subject: [PATCH] 武汉黄陂军粮-质检报告共享接口同步及推送 --- src/main/java/com/fzzy/async/whhpjl/impl/Fz40ToWhjlSync1107.java | 46 +++++++++++++++++++++++++--------------------- 1 files changed, 25 insertions(+), 21 deletions(-) diff --git a/src/main/java/com/fzzy/async/whhpjl/impl/Fz40ToWhjlSync1107.java b/src/main/java/com/fzzy/async/whhpjl/impl/Fz40ToWhjlSync1107.java index 75422ff..ef7a889 100644 --- a/src/main/java/com/fzzy/async/whhpjl/impl/Fz40ToWhjlSync1107.java +++ b/src/main/java/com/fzzy/async/whhpjl/impl/Fz40ToWhjlSync1107.java @@ -7,7 +7,7 @@ import com.fzzy.api.utils.ContextUtil; import com.fzzy.api.view.repository.ApiInfoDataRep; import com.fzzy.api.view.repository.ApiLogRep; -import com.fzzy.async.whhpjl.entity.Fz40WhjlDefaultDepot; +import com.fzzy.async.whhpjl.entity.Fz40WhjlDefaultGranary; import com.fzzy.async.whhpjl.repository.Fz40ToWhjlSync1107Rep; import com.fzzy.otherview.whhpjl.WhjlConstant; import com.fzzy.otherview.whhpjl.dto.WhjlApi1107; @@ -19,14 +19,13 @@ import java.util.List; /** - * 璐т綅淇℃伅 + * 寤掗棿淇℃伅 * * @Author:YAN */ @Slf4j @Component public class Fz40ToWhjlSync1107 { - @Autowired private Fz40ToWhjlSync1107Rep fz40ToWhjlSync1107Rep; @Autowired @@ -35,7 +34,7 @@ private ApiInfoDataRep apiInfoDataRep; /** - * 璐т綅淇℃伅 + * 寤掗棿淇℃伅 * * @param kqdm * @param deptId @@ -55,42 +54,47 @@ apiLog.setId(ContextUtil.getUUID()); try { - List<Fz40WhjlDefaultDepot> list = fz40ToWhjlSync1107Rep.listApi1107(deptId.substring(0, 4)); + List<Fz40WhjlDefaultGranary> list = fz40ToWhjlSync1107Rep.listApi1107(deptId.substring(0, 4)); if (null == list || list.isEmpty()) { log.info("-------------娌℃湁鑾峰彇鍒板崟浣嶄俊鎭�------------------"); return; } List<ApiInfoData> apiInfoDataList; WhjlApi1107 apiData; - for (Fz40WhjlDefaultDepot sysData : list) { + for (Fz40WhjlDefaultGranary sysData : list) { apiData = new WhjlApi1107(); - apiData.setHwbh(sysData.getId()); //璐т綅缂栧彿 + apiData.setAjbh(sysData.getAjdh()); //寤掗棿缂栧彿 apiData.setJlqybh(""); //鍐涚伯浼佷笟缂栧彿 apiData.setJlqymc(""); //鍐涚伯浼佷笟鍚嶇О apiData.setJgzdbh(""); //鍐涗緵绔欑偣缂栧彿 apiData.setJlqymc(""); //鍐涗緵绔欑偣鍚嶇О - apiData.setSscfbh(sysData.getBuildingId()); //浠撴埧缂栧彿 + apiData.setSscfbh(sysData.getCfbh()); //浠撴埧缂栧彿 apiData.setSscfmc(""); //浠撴埧鍚嶇О - apiData.setSsajbh(sysData.getGranaryId()); //寤掗棿缂栧彿 - apiData.setAjmc(""); //寤掗棿鍚嶇О - apiData.setHwmc(sysData.getName()); //璐т綅鍚嶇О - apiData.setHwqyrq(sysData.getStoreDate()); //璐т綅鍚敤鏃ユ湡 - apiData.setHwzt(sysData.getDepotStatus()); //璐т綅鐘舵�� - apiData.setClfs(sysData.getStoreType()); //鍌ㄧ伯鏂瑰紡 - apiData.setHwrl(sysData.getStorageMax()); //璐т綅瀹归噺 + apiData.setAjmc(sysData.getAjmc()); //寤掗棿鍚嶇О + apiData.setAjcd(sysData.getAjcd()); //寤掗棿闀垮害 + apiData.setAjkd(sysData.getAjkd()); //寤掗棿瀹藉害 + apiData.setAjgd(sysData.getAjgd()); //寤掗棿楂樺害 + apiData.setAjsjcr(sysData.getAjsjcr()); //寤掗棿璁捐浠撳 + apiData.setAjsjcr01(null); //寤掗棿瀹為檯浠撳 + apiData.setAjlxdh(sysData.getAjlxdh()); //寤掗棿鑱旂郴鐢佃瘽 + apiData.setAjjd(null); //寤掗棿缁忓害 + apiData.setAjwd(null); //寤掗棿绾害 + apiData.setAjqyrq(sysData.getAjqyrq()); //寤掗棿鍚敤鏃ユ湡 + apiData.setAjzt(sysData.getAjzt()); //寤掗棿鐘舵�� + apiData.setAjsyzt(""); //寤掗棿浣跨敤鐘舵�� apiData.setSfyx(""); //鏄惁鏈夋晥 - apiData.setBizId(sysData.getId()); + apiData.setBizId(sysData.getAjdh()); apiData.setUpdateTime(new Date()); //鎸佷箙鍖栦繚瀛橈紝鍗曠嫭瀛樺叆闈炲浗鏍囨帴鍙h〃 ApiInfoData infoData = new ApiInfoData(); - infoData.setId(sysData.getId()); + infoData.setId(sysData.getAjdh()); infoData.setKqdm(kqdm); infoData.setInteType(WhjlConstant.API_CATEGORY_11); infoData.setInteId(WhjlConstant.API_CODE_1107); infoData.setUpdateTime(new Date()); - infoData.setDataId(sysData.getId()); + infoData.setDataId(sysData.getAjdh()); infoData.setRemarks("澶囨敞淇℃伅"); //璁剧疆鎿嶄綔鏍囧織 @@ -107,12 +111,12 @@ apiInfoDataRep.save(infoData); - log.info("1107---璐т綅-鍚屾鏁版嵁锛歿}", apiData.toString()); + log.info("1107---寤掗棿-鍚屾鏁版嵁锛歿}", apiData.toString()); } } catch (Exception e) { - log.error("---1107璐т綅-鍚屾鏁版嵁鎵ц澶辫触----{}", e.getMessage()); - apiLog.setResult("1107璐т綅淇℃伅鍚屾澶辫触锛�" + e.getMessage()); + log.error("---1107寤掗棿-鍚屾鏁版嵁鎵ц澶辫触----{}", e.getMessage()); + apiLog.setResult("1107寤掗棿淇℃伅鍚屾澶辫触锛�" + e.getMessage()); apiLogRep.save(apiLog); } } -- Gitblit v1.9.3