|
|
@ -5,6 +5,7 @@ import cc.yunxi.config.props.WxShProperties;
|
|
|
|
import cc.yunxi.domain.vo.vxmessage.AccessToken;
|
|
|
|
import cc.yunxi.domain.vo.vxmessage.AccessToken;
|
|
|
|
import cc.yunxi.domain.vo.vxmessage.MessageTemplate;
|
|
|
|
import cc.yunxi.domain.vo.vxmessage.MessageTemplate;
|
|
|
|
import cc.yunxi.domain.vo.vxmessage.ResultVo;
|
|
|
|
import cc.yunxi.domain.vo.vxmessage.ResultVo;
|
|
|
|
|
|
|
|
import cn.hutool.cron.timingwheel.SystemTimer;
|
|
|
|
import cn.hutool.http.HttpUtil;
|
|
|
|
import cn.hutool.http.HttpUtil;
|
|
|
|
import cn.hutool.json.JSONUtil;
|
|
|
|
import cn.hutool.json.JSONUtil;
|
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
@ -76,16 +77,16 @@ public class WeChatMessageUtil {
|
|
|
|
if ("client".equals(endpointType)) {//预约端
|
|
|
|
if ("client".equals(endpointType)) {//预约端
|
|
|
|
param.put("appid", clientProperties.getAppId());
|
|
|
|
param.put("appid", clientProperties.getAppId());
|
|
|
|
param.put("secret", clientProperties.getAppSecret());
|
|
|
|
param.put("secret", clientProperties.getAppSecret());
|
|
|
|
result = HttpUtil.get(clientProperties.getTokenUrl(), param,1000);
|
|
|
|
result = HttpUtil.get(clientProperties.getTokenUrl(), param, 1000);
|
|
|
|
} else if ("recycler".equals(endpointType)) {//回收端
|
|
|
|
} else if ("recycler".equals(endpointType)) {//回收端
|
|
|
|
param.put("appid", recyclerProperties.getAppId());
|
|
|
|
param.put("appid", recyclerProperties.getAppId());
|
|
|
|
param.put("secret", recyclerProperties.getAppSecret());
|
|
|
|
param.put("secret", recyclerProperties.getAppSecret());
|
|
|
|
result = HttpUtil.get(recyclerProperties.getTokenUrl(), param,1000);
|
|
|
|
result = HttpUtil.get(recyclerProperties.getTokenUrl(), param, 1000);
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
return null;
|
|
|
|
return null;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
AccessToken access_token = JSONUtil.toBean(result, AccessToken.class);
|
|
|
|
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);
|
|
|
|
accessTokenMap.put(endpointType, access_token);
|
|
|
|
return access_token;
|
|
|
|
return access_token;
|
|
|
|
}
|
|
|
|
}
|
|
|
|