suzhuhong/zxjp-web
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

miniProgramJsCodeSession

Browse Source
This commit is contained in:
wxp01309236
2023-06-19 10:29:47 +08:00
parent 4958b50982
commit c94f8083d6
1 changed files with 12 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
coolstore-partner-service/src/main/java/com/cool/store/http/WechatRest.java
View File

@@ -9,8 +9,10 @@ import com.cool.store.enums.ErrorCodeEnum;
import com.cool.store.exception.ServiceException; import com.cool.store.exception.ServiceException;
import com.cool.store.mq.util.HttpRestTemplateService; import com.cool.store.mq.util.HttpRestTemplateService;
import com.cool.store.utils.RedisUtilPool; import com.cool.store.utils.RedisUtilPool;
import com.cool.store.utils.RestTemplateUtil;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import javax.annotation.Resource; import javax.annotation.Resource;
@@ -50,12 +52,17 @@ public class WechatRest {
requestMap.put("secret", secret); requestMap.put("secret", secret);
requestMap.put("js_code", jsCode); requestMap.put("js_code", jsCode);
requestMap.put("grant_type","authorization_code"); requestMap.put("grant_type","authorization_code");
CodeSessionDTO codeSessionDTO = null; ResponseEntity<CodeSessionDTO> responseEntity = null;
try { try {
codeSessionDTO = httpRestTemplateService.getForObject(url, CodeSessionDTO.class, requestMap); responseEntity = RestTemplateUtil.loadGet(url, CodeSessionDTO.class);
log.info("WechatRest#miniProgramJsCodeSession, url:{}, response:{}", url, JSONObject.toJSONString(codeSessionDTO)); log.info("WechatRest#miniProgramJsCodeSession, url:{}, response:{}", url, JSONObject.toJSONString(responseEntity));
if(Objects.nonNull(responseEntity.getBody()) && responseEntity.getBody().isSuccess()){
return responseEntity.getBody();
}
} catch (Exception e) { } catch (Exception e) {
log.error("调用微信服务异常", e); log.info("调用微信服务异常{}", e);
throw new ServiceException(ErrorCodeEnum.WX_SERVICE_ERROR);
} }
return null; return null;
} }
@@ -75,7 +82,7 @@ public class WechatRest {
if (StringUtils.isBlank(token)) { if (StringUtils.isBlank(token)) {
throw new ServiceException(ErrorCodeEnum.GET_ACCESSTOKEN_ERROR); throw new ServiceException(ErrorCodeEnum.GET_ACCESSTOKEN_ERROR);
} }
redisUtilPool.setString(cacheAccessToken, token, 7000); redisUtilPool.setString(cacheAccessToken, token, 7000);
accessToken = token; accessToken = token;
} catch (Exception e) { } catch (Exception e) {