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/push/whhpjl/WhjlApiRemoteService.java | 96 ++++++++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 96 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 eef3e64..b3ba95b 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; @@ -231,6 +233,8 @@ return WhjlConstant.API_CODE_WZKCYJGZ; case "1220": return WhjlConstant.API_CODE_WZKCYJJL; + case "1221": + return WhjlConstant.API_CODE_CCJH; case "1301": return WhjlConstant.API_CODE_WSDJCJL; case "1302": @@ -275,8 +279,100 @@ return WhjlConstant.API_CODE_CLYSHJ; case "1413": 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; + case "2013": + return WhjlConstant.API_CODE_SHARE_SZJZXBG; 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