diff --git a/functional-modules/xj-anyan-api/src/main/java/com/renkang/anyan/client/AnYanClientExecutor.java b/functional-modules/xj-anyan-api/src/main/java/com/renkang/anyan/client/AnYanClientExecutor.java index cd717d2..f545199 100644 --- a/functional-modules/xj-anyan-api/src/main/java/com/renkang/anyan/client/AnYanClientExecutor.java +++ b/functional-modules/xj-anyan-api/src/main/java/com/renkang/anyan/client/AnYanClientExecutor.java @@ -258,8 +258,11 @@ public class AnYanClientExecutor implements AnYanClient { return token; } - @Override - public AuthResult publicNetworkTokenNoCache() { + /** + * @description: 旧版公网获取token实现(SM4 + AnYanResult 包裹解密),保留备份 + * @author PengJ + */ + public AuthResult publicNetworkTokenNoCacheBAK() { JSONObject param = new JSONObject(); String password = anYanProperties.getPublicPassWrod(); String userName = anYanProperties.getPublicUserNmae(); @@ -289,6 +292,47 @@ public class AnYanClientExecutor implements AnYanClient { return null; } + /** + * @description: 公网获取token(密码模式,调用方式与 getAuthTokenByPassword 保持一致) + * 表单提交 + 公网 host + QUERY_AUTH_TOKEN,仅 RSA 加密密码,不写 Redis(缓存由调用方负责) + * @author PengJ + */ + @Override + public AuthResult publicNetworkTokenNoCache() { + String username = anYanProperties.getPublicUserNmae(); + String password = anYanProperties.getPublicPassWrod(); + try { + // 仅 RSA 加密密码,与 getAuthTokenByPassword 保持一致 + String encryptPassword = StringUtils.encryptByPublicKey(publicKey, password); + HttpHeaders headers = new HttpHeaders(); + headers.setContentType(MediaType.MULTIPART_FORM_DATA); + MultiValueMap formData = new LinkedMultiValueMap<>(); + formData.add("grant_type", "password"); + formData.add("username", username); + formData.add("password", encryptPassword); + formData.add("client_id", anYanProperties.getClientId()); + formData.add("client_secret", anYanProperties.getClientSecret()); + ResponseEntity authResult = RestTemplateUtil.postExchangeForGetTokenByPassword(AnYanApiEnum.QUERY_AUTH_TOKEN, formData, headers, AuthResult.class); + if (HttpStatus.OK.equals(authResult.getStatusCode()) + && ObjectUtils.isNotEmpty(authResult.getBody())) { + return authResult.getBody(); + } else { + log.error("------安眼系统获取公网token失败{}------", authResult.getBody()); + ExceptionAssertsUtil.fail("------安眼系统获取公网token失败------" + authResult.getBody()); + return null; + } + } catch (HttpClientErrorException e) { + log.error("------安眼系统获取公网token失败{}------", e.getMessage()); + String replace = Objects.requireNonNull(e.getMessage()).replace("401 Unauthorized: ", ""); + replace = replace.replace("\"", ""); + AuthResult bean = JSONUtil.toBean(replace, AuthResult.class); + ExceptionAssertsUtil.fail(bean.getMessage()); + } catch (Exception e) { + ExceptionAssertsUtil.fail(e.getMessage()); + } + return null; + } + /** * @description: 根据token获取用户信息 * @author PengJ diff --git a/functional-modules/xj-anyan-api/src/main/java/com/renkang/anyan/config/RestTemplateUtil.java b/functional-modules/xj-anyan-api/src/main/java/com/renkang/anyan/config/RestTemplateUtil.java index eca2526..dfd004a 100644 --- a/functional-modules/xj-anyan-api/src/main/java/com/renkang/anyan/config/RestTemplateUtil.java +++ b/functional-modules/xj-anyan-api/src/main/java/com/renkang/anyan/config/RestTemplateUtil.java @@ -1,5 +1,6 @@ package com.renkang.anyan.config; +import com.alibaba.fastjson.JSON; import com.renkang.anyan.enums.AnYanApiEnum; import com.renkang.anyan.model.vo.AnYanResult; import lombok.extern.slf4j.Slf4j; @@ -81,7 +82,15 @@ public class RestTemplateUtil { public static ResponseEntity postExchangeForGetToken(AnYanApiEnum api, Object requestBody, Class responseType) { String url = getProperties().getPublicHost() + api.getMethodPath() + api.getMethodParam(); HttpEntity requestEntity = new HttpEntity<>(requestBody); - return getRestTemplate().exchange(url, api.getHttpMethod(), requestEntity, responseType); + // 打印请求入参,便于排查 + String bodyJson = JSON.toJSONString(requestBody); + log.info("安眼获取token请求入参: url={}, body={}", url, bodyJson); + // 打印等价 curl(application/json),便于本地手动调试 + log.info("安眼获取token等价curl: curl -X POST '{}' -H 'Content-Type: application/json' -d '{}'", url, bodyJson); + ResponseEntity response = getRestTemplate().exchange(url, api.getHttpMethod(), requestEntity, responseType); + // 打印返回信息(状态码 + 响应体) + log.info("安眼获取token返回信息: statusCode={}, body={}", response.getStatusCode(), JSON.toJSONString(response.getBody())); + return response; } /** diff --git a/jeecg-system/jeecg-system-biz/src/main/java/org/jeecg/modules/message/controller/SysMessageController.java b/jeecg-system/jeecg-system-biz/src/main/java/org/jeecg/modules/message/controller/SysMessageController.java index 33c1c7e..203acdf 100644 --- a/jeecg-system/jeecg-system-biz/src/main/java/org/jeecg/modules/message/controller/SysMessageController.java +++ b/jeecg-system/jeecg-system-biz/src/main/java/org/jeecg/modules/message/controller/SysMessageController.java @@ -48,7 +48,7 @@ public class SysMessageController extends JeecgController page = new Page(pageNo, pageSize); IPage pageList = sysMessageService.page(page, queryWrapper);