From 8bdd017371e7a486338862eb0da10bc7f2a5da52 Mon Sep 17 00:00:00 2001 From: ws <ws@123.com> Date: 星期二, 12 十二月 2023 19:06:50 +0800 Subject: [PATCH] 武汉省平台-共享接口更新3 --- src/main/java/com/fzzy/otherview/whhpjl/pr/WhjlShareApi2006PR.java | 49 +++++++++++++++++++++++++------------------------ 1 files changed, 25 insertions(+), 24 deletions(-) diff --git a/src/main/java/com/fzzy/otherview/whhpjl/pr/WhjlShareApi2006PR.java b/src/main/java/com/fzzy/otherview/whhpjl/pr/WhjlShareApi2006PR.java index d20f015..66e17aa 100644 --- a/src/main/java/com/fzzy/otherview/whhpjl/pr/WhjlShareApi2006PR.java +++ b/src/main/java/com/fzzy/otherview/whhpjl/pr/WhjlShareApi2006PR.java @@ -15,7 +15,8 @@ import com.fzzy.api.service.ApiRemoteService; import com.fzzy.api.view.repository.ApiInfoDataRep; import com.fzzy.otherview.whhpjl.WhjlConstant; -import com.fzzy.otherview.whhpjl.dto.WhjlShareApi2002; +import com.fzzy.otherview.whhpjl.dto.WhjlShareApi2006; +import com.fzzy.otherview.whhpjl.dto.WhjlShareApi2006; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; @@ -39,20 +40,20 @@ /** * 鑾峰彇鍒楄〃淇℃伅 - * whjlShareApi2002PR#listData + * whjlShareApi2006PR#listData * * @return */ @DataProvider - public List<WhjlShareApi2002> listData() { - List<ApiInfoData> result = apiInfoDataRep.getDataByInteId(WhjlConstant.API_CODE_2002); + public List<WhjlShareApi2006> listData() { + List<ApiInfoData> result = apiInfoDataRep.getDataByInteId(WhjlConstant.API_CODE_2006); if (null == result || result.isEmpty()) { return null; } - List<WhjlShareApi2002> list = new ArrayList<>(); - WhjlShareApi2002 whjlShareApiData; + List<WhjlShareApi2006> list = new ArrayList<>(); + WhjlShareApi2006 whjlShareApiData; for (ApiInfoData infoData : result) { - whjlShareApiData = JSONObject.parseObject(infoData.getData(), WhjlShareApi2002.class); + whjlShareApiData = JSONObject.parseObject(infoData.getData(), WhjlShareApi2006.class); whjlShareApiData.setKqdm(infoData.getKqdm()); whjlShareApiData.setCzbz(infoData.getCzbz()); whjlShareApiData.setUpdateTime(infoData.getUpdateTime()); @@ -64,20 +65,20 @@ /** * 鏇存柊鎴栦慨鏀� - * whjlShareApi2002PR#saveData + * whjlShareApi2006PR#saveData * * @param data * @return */ @DataResolver - public void saveData(WhjlShareApi2002 data) { + public void saveData(WhjlShareApi2006 data) { ApiInfoData infoData = new ApiInfoData(); - infoData.setId(data.getCpflbm()); + infoData.setId(data.getJlppbh()); infoData.setKqdm(data.getKqdm()); infoData.setInteType(WhjlConstant.API_CATEGORY_20); - infoData.setInteId(WhjlConstant.API_CODE_2002); + infoData.setInteId(WhjlConstant.API_CODE_2006); infoData.setUpdateTime(new Date()); - infoData.setDataId(data.getCpflbm()); + infoData.setDataId(data.getJlppbh()); infoData.setData(JSON.toJSONString(data)); infoData.setCzbz(data.getCzbz()); infoData.setRemarks("澶囨敞淇℃伅"); @@ -88,26 +89,26 @@ /** * 鍒犻櫎 - * whjlShareApi2002PR#delData + * whjlShareApi2006PR#delData * * @param data * @return */ @Expose - public String delData(WhjlShareApi2002 data) { - apiInfoDataRep.deleteById(data.getCpflbm()); + public String delData(WhjlShareApi2006 data) { + apiInfoDataRep.deleteById(data.getJlppbh()); return null; } /** * 鏇存柊鏁版嵁 - * whjlShareApi2002PR#pullData + * whjlShareApi2006PR#pullData * * @param items * @return */ @Expose - public String pullData(List<WhjlShareApi2002> items) { + public String pullData(List<WhjlShareApi2006> items) { //鑾峰彇閰嶇疆淇℃伅 @@ -121,28 +122,28 @@ ResponseDto responseDto; ApiInfoData infoData; String result = ""; - List<WhjlShareApi2002> list; + List<WhjlShareApi2006> list; for (ApiConfs apiConf : apiConfs) { apiService = apiPushManager.getApiRemoteService(apiConf.getPushProtocol()); if (null == apiService) { continue; } //灏佽鍙傛暟 - param = new ApiParam(apiConf, WhjlConstant.API_CATEGORY_20, WhjlConstant.API_CODE_2002); + param = new ApiParam(apiConf, WhjlConstant.API_CATEGORY_20, WhjlConstant.API_CODE_2006); responseDto = apiService.pullData(param, apiConf); if (responseDto.getSuccess() == 0) { - list = JSONObject.parseArray(responseDto.getData(), WhjlShareApi2002.class); + list = JSONObject.parseArray(responseDto.getData(), WhjlShareApi2006.class); if(null != list && list.size() > 0){ - for (WhjlShareApi2002 shareData : list) { + for (WhjlShareApi2006 shareData : list) { shareData.setCzbz(Constant.CZBZ_U); infoData = new ApiInfoData(); - infoData.setId(shareData.getCpflbm()); + infoData.setId(shareData.getJlppbh()); infoData.setKqdm(apiConf.getKqdm()); infoData.setInteType(WhjlConstant.API_CATEGORY_20); - infoData.setInteId(WhjlConstant.API_CODE_2002); + infoData.setInteId(WhjlConstant.API_CODE_2006); infoData.setUpdateTime(new Date()); - infoData.setDataId(shareData.getCpflbm()); + infoData.setDataId(shareData.getJlppbh()); infoData.setData(JSON.toJSONString(shareData)); infoData.setCzbz(Constant.CZBZ_U); apiInfoDataRep.save(infoData); -- Gitblit v1.9.3