diff --git a/nxhs-service/src/main/java/cc/yunxi/utils/WeChatMessageUtil.java b/nxhs-service/src/main/java/cc/yunxi/utils/WeChatMessageUtil.java index e986642..0b0b86b 100644 --- a/nxhs-service/src/main/java/cc/yunxi/utils/WeChatMessageUtil.java +++ b/nxhs-service/src/main/java/cc/yunxi/utils/WeChatMessageUtil.java @@ -5,6 +5,7 @@ import cc.yunxi.config.props.WxShProperties; import cc.yunxi.domain.vo.vxmessage.AccessToken; import cc.yunxi.domain.vo.vxmessage.MessageTemplate; import cc.yunxi.domain.vo.vxmessage.ResultVo; +import cn.hutool.cron.timingwheel.SystemTimer; import cn.hutool.http.HttpUtil; import cn.hutool.json.JSONUtil; import lombok.extern.slf4j.Slf4j; @@ -76,16 +77,16 @@ public class WeChatMessageUtil { if ("client".equals(endpointType)) {//预约端 param.put("appid", clientProperties.getAppId()); param.put("secret", clientProperties.getAppSecret()); - result = HttpUtil.get(clientProperties.getTokenUrl(), param,1000); + result = HttpUtil.get(clientProperties.getTokenUrl(), param, 1000); } else if ("recycler".equals(endpointType)) {//回收端 param.put("appid", recyclerProperties.getAppId()); param.put("secret", recyclerProperties.getAppSecret()); - result = HttpUtil.get(recyclerProperties.getTokenUrl(), param,1000); + result = HttpUtil.get(recyclerProperties.getTokenUrl(), param, 1000); } else { return null; } AccessToken access_token = JSONUtil.toBean(result, AccessToken.class); - access_token.setExpires_in(new AtomicLong(10 * 1000 + access_token.getExpires_in().get() * 1000)); + access_token.setExpires_in(new AtomicLong(System.currentTimeMillis() + 10 * 1000 + access_token.getExpires_in().get() * 1000)); accessTokenMap.put(endpointType, access_token); return access_token; }