From a82631013be641db3979e11013b2cf6e937a3e7b Mon Sep 17 00:00:00 2001
From: CZT <czt18638530771@163.com>
Date: 星期二, 12 十二月 2023 14:24:51 +0800
Subject: [PATCH] 武汉省平台-共享接口实现1
---
src/main/java/com/fzzy/push/whhpjl/WhjlApiRemoteService.java | 90 +++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 90 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/fzzy/push/whhpjl/WhjlApiRemoteService.java b/src/main/java/com/fzzy/push/whhpjl/WhjlApiRemoteService.java
index ecd0bba..535a2bf 100644
--- a/src/main/java/com/fzzy/push/whhpjl/WhjlApiRemoteService.java
+++ b/src/main/java/com/fzzy/push/whhpjl/WhjlApiRemoteService.java
@@ -11,6 +11,8 @@
import com.fzzy.api.service.ApiTriggerService;
import com.fzzy.api.utils.*;
import com.fzzy.api.view.repository.*;
+import com.fzzy.push.whhpjl.dto.WhjlPullReqDto;
+import com.fzzy.push.whhpjl.dto.WhjlPullRespDto;
import com.fzzy.push.whhpjl.dto.WhjlReqDto;
import com.fzzy.push.whhpjl.dto.WhjlRespDto;
import com.fzzy.otherview.whhpjl.WhjlConstant;
@@ -279,8 +281,96 @@
return WhjlConstant.API_CODE_YSLX;
case "1414":
return WhjlConstant.API_CODE_BDZDSB;
+ case "2001":
+ return WhjlConstant.API_CODE_SHARE_SBFL;
+ case "2002":
+ return WhjlConstant.API_CODE_SHARE_CPFL;
+ case "2003":
+ return WhjlConstant.API_CODE_SHARE_JLDW;
+ case "2004":
+ return WhjlConstant.API_CODE_SHARE_JLGLJG;
+ case "2005":
+ return WhjlConstant.API_CODE_SHARE_JLGYSXX;
+ case "2006":
+ return WhjlConstant.API_CODE_SHARE_JLPPXX;
+ case "2007":
+ return WhjlConstant.API_CODE_SHARE_JLCPXX;
+ case "2008":
+ return WhjlConstant.API_CODE_SHARE_JLCCJH;
+ case "2009":
+ return WhjlConstant.API_CODE_SHARE_HTMB;
+ case "2010":
+ return WhjlConstant.API_CODE_SHARE_ZLJCBZ;
+ case "2011":
+ return WhjlConstant.API_CODE_SHARE_ZLJCXM;
+ case "2012":
+ return WhjlConstant.API_CODE_SHARE_YJFAXX;
default:
return inteId;
}
}
+
+ @Override
+ public ResponseDto pullData(ApiParam param, ApiConfs conf) {
+ String inteId = param.getInteId();
+ String kqdm = param.getKqdm();
+
+ try {
+ if (null == conf) {
+ conf = apiCommonService.getConf(kqdm);
+ }
+
+ //娣诲姞鏃ュ織
+ ApiLog apiLog = new ApiLog();
+ apiLog.setId(ContextUtil.getUUID());
+ apiLog.setInteId(inteId);
+ inteId = getInteId(inteId);
+
+ if (StringUtils.isEmpty(inteId)) {
+ ResponseDto responseDto = new ResponseDto(99, "娌℃湁鑾峰彇鍒版帴鍙�");
+ apiLog.setStatus(99);
+ apiLog.setResult("娌℃湁鑾峰彇鍒版帴鍙�");
+ apiLogRep.save(apiLog);
+ return responseDto;
+ }
+
+ if (conf == null) {
+ ResponseDto responseDto = new ResponseDto(99, "娌℃湁鑾峰彇鍒颁笂浼犻厤缃�");
+ apiLog.setStatus(99);
+ apiLog.setResult("娌℃湁鑾峰彇鍒颁笂浼犻厤缃�");
+ apiLogRep.save(apiLog);
+ return responseDto;
+ }
+
+ //灏佽鏁版嵁
+ WhjlPullReqDto reqData = new WhjlPullReqDto();
+ //鎶ユ枃鏍囪瘑ID
+ reqData.setId(ContextUtil.getUUID());
+ //韬唤ID
+ reqData.setUid(conf.getUserName());
+ //搴旂敤鐮�
+ reqData.setAppcode(conf.getAppCode());
+ //鏃堕棿鎴�
+ reqData.setTimestamp(Long.valueOf(ContextUtil.getCurTimeMillis()));
+ //韬唤绛惧悕锛屽搴旂敤鐮乢鎺堟潈鐮乢绔欑偣缂栫爜_鎶ユ枃ID_鏃堕棿鎴宠繘琛孧D5绠楁硶绛惧悕
+ String accessToken = reqData.getAppcode() +"_" + conf.getPassword() +"_" + reqData.getUid() + "_" + reqData.getId() + "_" + reqData.getTimestamp();
+ log.info("韬唤绛惧悕锛�" + accessToken);
+ reqData.setAccesstoken(MyMD5Util.encrypt(accessToken));
+
+ String url = conf.getApiUrl().replace("secure", "share");
+ WhjlPullRespDto responseDto = whjl2023HttpClientUtil.postPullData(url + inteId, reqData);
+ apiLog.setStatus(responseDto.getCode() == 200 ? 0 : responseDto.getCode());
+ apiLog.setKqdm(kqdm);
+ apiLog.setUploadTime(new Date());
+
+ apiLogRep.save(apiLog);
+ ResponseDto resd = new ResponseDto();
+ resd.setSuccess(responseDto.getCode() == 200 ? 0 : responseDto.getCode());
+ resd.setData(responseDto.getData());
+ return resd;
+ } catch (Exception e) {
+ log.error(e.getMessage(), e);
+ return new ResponseDto(99, e.getMessage());
+ }
+ }
}
\ No newline at end of file
--
Gitblit v1.9.3