From dbef4eea6194ffba3bd25f978b33e09d65f5a6de Mon Sep 17 00:00:00 2001
From: czt <czt18638530771@163.com>
Date: 星期五, 01 十一月 2024 14:07:21 +0800
Subject: [PATCH] 根据国家局接口，调整基础表字段
---
src/main/java/com/fzzy/otherview/sh2023/pr/SHApi1311PR.java | 75 +++++++++++++++++++++++++++++++++++++
1 files changed, 74 insertions(+), 1 deletions(-)
diff --git a/src/main/java/com/fzzy/otherview/sh2023/pr/SHApi1311PR.java b/src/main/java/com/fzzy/otherview/sh2023/pr/SHApi1311PR.java
index f3fc1c0..b6f71fe 100644
--- a/src/main/java/com/fzzy/otherview/sh2023/pr/SHApi1311PR.java
+++ b/src/main/java/com/fzzy/otherview/sh2023/pr/SHApi1311PR.java
@@ -19,8 +19,10 @@
import com.fzzy.push.sh2023.SH2023Constant;
import com.fzzy.push.sh2023.dto.SH2023Api1311;
import com.fzzy.push.sh2023.dto.SH2023Api2101;
+import com.fzzy.push.sh2023.dto.SH2023ShareApi1311;
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;
@@ -117,6 +119,7 @@
if (apiInfoList.size() != 0) {
infoData = apiInfoList.get(0);
infoData.setData(JSON.toJSONString(data));
+ infoData.setCzbz(data.getCzbz());
} else {
infoData = new ApiInfoData();
infoData.setId(ContextUtil.getUUID());
@@ -172,7 +175,7 @@
}
//灏佽鍙傛暟
- ApiParam param = new ApiParam(apiConf, "21", SH2023Constant.SH_2023_API_CODE_1311);
+ ApiParam param = new ApiParam(apiConf, "13", SH2023Constant.SH_2023_API_CODE_1311);
//鑾峰彇瀹炵幇鎺ュ彛
ApiRemoteService apiService = apiPushManager.getApiRemoteService(param.getPushProtocol());
@@ -201,4 +204,74 @@
return result;
}
+ /**
+ * 鍏变韩鎷夊彇鏁版嵁
+ * sHApi1311PR#pullData
+ *
+ * @return
+ */
+ @Expose
+ public String pullData() {
+
+
+ //鑾峰彇閰嶇疆淇℃伅
+ List<ApiConfs> apiConfs = apiCommonService.listCacheConf();
+ if (null == apiConfs || apiConfs.isEmpty()) {
+ return "绯荤粺娌℃湁鑾峰彇鍒板簱鍖洪厤缃俊鎭紝鎵ц澶辫触";
+ }
+
+ ApiRemoteService apiService;
+ ApiParam param;
+ ResponseDto responseDto;
+ ApiInfoData infoData;
+ String result = "";
+ List<SH2023ShareApi1311> list;
+ SH2023Api1311 sh2023Api1311;
+ List<ApiInfoData> apiInfoDataList;
+ for (ApiConfs apiConf : apiConfs) {
+ apiService = apiPushManager.getApiRemoteService(apiConf.getPushProtocol());
+ if (null == apiService) {
+ continue;
+ }
+ //灏佽鍙傛暟
+ param = new ApiParam(apiConf, "13", SH2023Constant.SH_2023_API_CODE_1311);
+ responseDto = apiService.pullData(param, apiConf);
+
+ if (responseDto.getSuccess() == 0) {
+ list = JSONObject.parseArray(responseDto.getData(), SH2023ShareApi1311.class);
+ if(null != list && list.size() > 0){
+ for (SH2023ShareApi1311 shareData : list) {
+
+ apiInfoDataList = apiInfoDataRep.getDataByDataId(shareData.getSxtbh());
+ if(null == apiInfoDataList || apiInfoDataList.isEmpty()){
+ sh2023Api1311 = new SH2023Api1311();
+ sh2023Api1311.setSpjksbid(shareData.getSxtbh());
+ sh2023Api1311.setCzbz(Constant.CZBZ_I);
+ }else {
+ sh2023Api1311 = JSONObject.parseObject(apiInfoDataList.get(0).getData(), SH2023Api1311.class);
+ sh2023Api1311.setCzbz(apiInfoDataList.get(0).getCzbz());
+ }
+ if(StringUtils.isNotEmpty(shareData.getHwdm())){
+ sh2023Api1311.setHwdm(shareData.getHwdm());
+ }
+ sh2023Api1311.setJksbmc(shareData.getTdmc());
+ infoData = new ApiInfoData();
+ infoData.setId(sh2023Api1311.getSpjksbid());
+ infoData.setKqdm(apiConf.getKqdm());
+ infoData.setInteType("13");
+ infoData.setInteId(SH2023Constant.SH_2023_API_CODE_1311);
+ infoData.setUpdateTime(new Date());
+ infoData.setDataId(sh2023Api1311.getSpjksbid());
+ infoData.setData(JSON.toJSONString(sh2023Api1311));
+ infoData.setCzbz(sh2023Api1311.getCzbz());
+ apiInfoDataRep.save(infoData);
+ }
+ }
+ }
+ result += responseDto.toString();
+ return result;
+ }
+ return null;
+ }
+
}
--
Gitblit v1.9.3