From 1e0ffb4026328506fa3fe77fc6d9554dc667b681 Mon Sep 17 00:00:00 2001
From: YYC <1833023622@qq.com>
Date: 星期五, 08 十一月 2024 16:59:02 +0800
Subject: [PATCH] 普宁配置文件
---
src/main/java/com/fzzy/otherview/whhpjl/pr/WhjlShareApi2007PR.java | 52 ++++++++++++++++++++++++++++------------------------
1 files changed, 28 insertions(+), 24 deletions(-)
diff --git a/src/main/java/com/fzzy/otherview/whhpjl/pr/WhjlShareApi2007PR.java b/src/main/java/com/fzzy/otherview/whhpjl/pr/WhjlShareApi2007PR.java
index ee59d18..6be3e4d 100644
--- a/src/main/java/com/fzzy/otherview/whhpjl/pr/WhjlShareApi2007PR.java
+++ b/src/main/java/com/fzzy/otherview/whhpjl/pr/WhjlShareApi2007PR.java
@@ -7,6 +7,7 @@
import com.bstek.dorado.annotation.Expose;
import com.fzzy.api.Constant;
import com.fzzy.api.data.ApiParam;
+import com.fzzy.api.data.SyncProtocol;
import com.fzzy.api.dto.ResponseDto;
import com.fzzy.api.entity.ApiConfs;
import com.fzzy.api.entity.ApiInfoData;
@@ -15,7 +16,7 @@
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.WhjlShareApi2007;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
@@ -39,20 +40,20 @@
/**
* 鑾峰彇鍒楄〃淇℃伅
- * whjlShareApi2002PR#listData
+ * whjlShareApi2007PR#listData
*
* @return
*/
@DataProvider
- public List<WhjlShareApi2002> listData() {
- List<ApiInfoData> result = apiInfoDataRep.getDataByInteId(WhjlConstant.API_CODE_2002);
+ public List<WhjlShareApi2007> listData() {
+ List<ApiInfoData> result = apiInfoDataRep.getDataByInteId(WhjlConstant.API_CODE_2007);
if (null == result || result.isEmpty()) {
return null;
}
- List<WhjlShareApi2002> list = new ArrayList<>();
- WhjlShareApi2002 whjlShareApiData;
+ List<WhjlShareApi2007> list = new ArrayList<>();
+ WhjlShareApi2007 whjlShareApiData;
for (ApiInfoData infoData : result) {
- whjlShareApiData = JSONObject.parseObject(infoData.getData(), WhjlShareApi2002.class);
+ whjlShareApiData = JSONObject.parseObject(infoData.getData(), WhjlShareApi2007.class);
whjlShareApiData.setKqdm(infoData.getKqdm());
whjlShareApiData.setCzbz(infoData.getCzbz());
whjlShareApiData.setUpdateTime(infoData.getUpdateTime());
@@ -64,20 +65,20 @@
/**
* 鏇存柊鎴栦慨鏀�
- * whjlShareApi2002PR#saveData
+ * whjlShareApi2007PR#saveData
*
* @param data
* @return
*/
@DataResolver
- public void saveData(WhjlShareApi2002 data) {
+ public void saveData(WhjlShareApi2007 data) {
ApiInfoData infoData = new ApiInfoData();
- infoData.setId(data.getCpflbm());
+ infoData.setId(data.getJlcpbh());
infoData.setKqdm(data.getKqdm());
infoData.setInteType(WhjlConstant.API_CATEGORY_20);
- infoData.setInteId(WhjlConstant.API_CODE_2002);
+ infoData.setInteId(WhjlConstant.API_CODE_2007);
infoData.setUpdateTime(new Date());
- infoData.setDataId(data.getCpflbm());
+ infoData.setDataId(data.getJlcpbh());
infoData.setData(JSON.toJSONString(data));
infoData.setCzbz(data.getCzbz());
infoData.setRemarks("澶囨敞淇℃伅");
@@ -88,26 +89,26 @@
/**
* 鍒犻櫎
- * whjlShareApi2002PR#delData
+ * whjlShareApi2007PR#delData
*
* @param data
* @return
*/
@Expose
- public String delData(WhjlShareApi2002 data) {
- apiInfoDataRep.deleteById(data.getCpflbm());
+ public String delData(WhjlShareApi2007 data) {
+ apiInfoDataRep.deleteById(data.getJlcpbh());
return null;
}
/**
* 鏇存柊鏁版嵁
- * whjlShareApi2002PR#pullData
+ * whjlShareApi2007PR#pullData
*
* @param items
* @return
*/
@Expose
- public String pullData(List<WhjlShareApi2002> items) {
+ public String pullData(List<WhjlShareApi2007> items) {
//鑾峰彇閰嶇疆淇℃伅
@@ -121,28 +122,31 @@
ResponseDto responseDto;
ApiInfoData infoData;
String result = "";
- List<WhjlShareApi2002> list;
+ List<WhjlShareApi2007> list;
for (ApiConfs apiConf : apiConfs) {
+ if(!apiConf.getSyncProtocol().equals(SyncProtocol.FZZY_V40_WHJL.getCode())){
+ continue;
+ }
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_2007);
responseDto = apiService.pullData(param, apiConf);
if (responseDto.getSuccess() == 0) {
- list = JSONObject.parseArray(responseDto.getData(), WhjlShareApi2002.class);
+ list = JSONObject.parseArray(responseDto.getData(), WhjlShareApi2007.class);
if(null != list && list.size() > 0){
- for (WhjlShareApi2002 shareData : list) {
+ for (WhjlShareApi2007 shareData : list) {
shareData.setCzbz(Constant.CZBZ_U);
infoData = new ApiInfoData();
- infoData.setId(shareData.getCpflbm());
+ infoData.setId(shareData.getJlcpbh());
infoData.setKqdm(apiConf.getKqdm());
infoData.setInteType(WhjlConstant.API_CATEGORY_20);
- infoData.setInteId(WhjlConstant.API_CODE_2002);
+ infoData.setInteId(WhjlConstant.API_CODE_2007);
infoData.setUpdateTime(new Date());
- infoData.setDataId(shareData.getCpflbm());
+ infoData.setDataId(shareData.getJlcpbh());
infoData.setData(JSON.toJSONString(shareData));
infoData.setCzbz(Constant.CZBZ_U);
apiInfoDataRep.save(infoData);
--
Gitblit v1.9.3