From 9b65b37b250238794325fae0217f398d3feeb0ec Mon Sep 17 00:00:00 2001 From: wxp01309236 Date: Mon, 19 Jun 2023 10:23:14 +0800 Subject: [PATCH] getAccessToken --- .../java/com/cool/store/http/WechatRest.java | 28 ++++++++----------- 1 file changed, 11 insertions(+), 17 deletions(-) diff --git a/coolstore-partner-service/src/main/java/com/cool/store/http/WechatRest.java b/coolstore-partner-service/src/main/java/com/cool/store/http/WechatRest.java index d9435dbbb..486bf22aa 100644 --- a/coolstore-partner-service/src/main/java/com/cool/store/http/WechatRest.java +++ b/coolstore-partner-service/src/main/java/com/cool/store/http/WechatRest.java @@ -50,13 +50,10 @@ public class WechatRest { requestMap.put("secret", secret); requestMap.put("js_code", jsCode); requestMap.put("grant_type","authorization_code"); - ResultDTO responseEntity = null; + CodeSessionDTO codeSessionDTO = null; try { - responseEntity = httpRestTemplateService.getForObject(url, ResultDTO.class, requestMap); - log.info("WechatRest#miniProgramJsCodeSession, url:{}, response:{}", url, JSONObject.toJSONString(responseEntity)); - if(Objects.nonNull(responseEntity.getData()) && responseEntity.isSuccess()){ - return JSONObject.parseObject(JSONObject.toJSONString(responseEntity.getData()), CodeSessionDTO.class); - } + codeSessionDTO = httpRestTemplateService.getForObject(url, CodeSessionDTO.class, requestMap); + log.info("WechatRest#miniProgramJsCodeSession, url:{}, response:{}", url, JSONObject.toJSONString(codeSessionDTO)); } catch (Exception e) { log.error("调用微信服务异常", e); } @@ -70,19 +67,16 @@ public class WechatRest { return accessToken; } String reqUrl = String.format(ACCESS_TOKEN, appId, secret); - ResultDTO responseEntity = null; + JSONObject jsonObject = null; try { - responseEntity = httpRestTemplateService.getForObject(reqUrl, ResultDTO.class, null); - log.info("WechatRest#getAccessToken, reqUrl:{}, response:{}", reqUrl, JSONObject.toJSONString(responseEntity)); - if(Objects.nonNull(responseEntity.getData()) && responseEntity.isSuccess()){ - JSONObject jsonObject = JSON.parseObject(JSONObject.toJSONString(responseEntity.getData())); - String token = jsonObject.getString("access_token"); - if (StringUtils.isBlank(token)) { - throw new ServiceException(ErrorCodeEnum.GET_ACCESSTOKEN_ERROR); - } - redisUtilPool.setString(cacheAccessToken, token, 7000); - accessToken = token; + jsonObject = httpRestTemplateService.getForObject(reqUrl, JSONObject.class, null); + log.info("WechatRest#getAccessToken, reqUrl:{}, response:{}", reqUrl, JSONObject.toJSONString(jsonObject)); + String token = jsonObject.getString("access_token"); + if (StringUtils.isBlank(token)) { + throw new ServiceException(ErrorCodeEnum.GET_ACCESSTOKEN_ERROR); } + redisUtilPool.setString(cacheAccessToken, token, 7000); + accessToken = token; } catch (Exception e) { log.error("获取微信小程序token异常", e); }