package com.walker.wxtools;
|
|
import com.walker.infrastructure.utils.StringUtils;
|
import com.walker.wxtools.util.AccessTokenUtils;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
|
public abstract class AbstractOfficialAccountEngine implements OfficialAccountEngine{
|
|
protected final transient Logger logger = LoggerFactory.getLogger(this.getClass());
|
|
@Override
|
public WxUserInfo getUserInfoSub(String openId) throws AccessTokenNotFoundException{
|
String basicAccessToken = null;
|
try {
|
basicAccessToken = this.getBasicAccessToken();
|
if(StringUtils.isEmpty(basicAccessToken)){
|
throw new Exception("basicAccessToken为空", null);
|
}
|
|
} catch (Exception ex){
|
throw new AccessTokenNotFoundException(ex.getMessage(), ex);
|
}
|
|
try {
|
return this.acquireRemoteUserInfoSub(openId, basicAccessToken);
|
} catch (WxRemoteException e) {
|
throw new RuntimeException("远程调用'获取微信用户接口'失败:" + e.getError(), e);
|
}
|
}
|
|
@Override
|
public WxUserInfo getUserInfo(String openId) {
|
throw new UnsupportedOperationException();
|
}
|
|
@Override
|
public String getAuthAccessToken(String code) {
|
throw new UnsupportedOperationException();
|
}
|
|
@Override
|
public String getJsApiTicket() {
|
String basicAccessToken = this.getBasicAccessToken();
|
if(StringUtils.isEmpty(basicAccessToken)){
|
logger.error("getJsApiTicket:获取'basicAccessToken'为空!");
|
return null;
|
}
|
return this.getJsApiTicket(basicAccessToken);
|
}
|
|
@Override
|
public String getJsApiTicket(String basicAccessToken) {
|
JsTicket jsTicket = this.acquireCachedJsTicket(Constants.CACHE_PREFIX_JS_TICKET + this.getAppId());
|
if(jsTicket != null){
|
if(!AccessTokenUtils.isExpiredCache(jsTicket.getCreateTime(), this.maxCachedAccessTokenSeconds)){
|
return jsTicket.getTicket();
|
}
|
}
|
|
// 重新获取：jsTicket
|
try {
|
jsTicket = this.acquireRemoteJsTicket(basicAccessToken);
|
logger.debug("远程获取'jsTicket'..........{}", jsTicket);
|
this.writeJsTicketToCache(Constants.CACHE_PREFIX_JS_TICKET + this.getAppId(), jsTicket);
|
return jsTicket.getTicket();
|
} catch (WxRemoteException e) {
|
throw new RuntimeException(e.getError(), e);
|
}
|
}
|
|
@Override
|
public String getJsApiTicket4Card(String basicAccessToken) {
|
throw new UnsupportedOperationException();
|
}
|
|
@Override
|
public String getBasicAccessToken() {
|
BasicAccessToken accessToken = this.acquireCachedBasicAccessToken(Constants.CACHE_PREFIX_ACCESS_TOKEN + this.getAppId());
|
if(accessToken != null){
|
if(!AccessTokenUtils.isExpiredCache(accessToken.getCreateTime(), this.maxCachedAccessTokenSeconds)){
|
// 缓存未过期，直接返回
|
return accessToken.getAccessToken();
|
}
|
}
|
|
// 重新获取：access_token
|
try {
|
accessToken = this.acquireRemoteBasicAccessToken(this.getAppId(), this.getSecret());
|
logger.debug("远程获取'access_token'..........{}", accessToken);
|
this.writeBasicAccessTokenToCache(Constants.CACHE_PREFIX_ACCESS_TOKEN + this.getAppId(), accessToken);
|
return accessToken.getAccessToken();
|
} catch (WxRemoteException e) {
|
throw new RuntimeException(e.getError(), e);
|
}
|
}
|
|
protected abstract JsTicket acquireCachedJsTicket(String cacheKey);
|
protected abstract void writeJsTicketToCache(String cacheKey, JsTicket jsTicket);
|
protected abstract JsTicket acquireRemoteJsTicket(String basicAccessToken) throws WxRemoteException;
|
|
/**
|
* 从缓存中获取appId对应的基础'access_token'对象。
|
* @param cacheKey
|
* @return
|
* @date 2023-04-20
|
*/
|
protected abstract BasicAccessToken acquireCachedBasicAccessToken(String cacheKey);
|
|
/**
|
* 把基础'access_token'写入缓存中。<p>默认基于内存，业务可以重写方法，写入redis中</p>
|
* @param cacheKey 缓存的key = access_token:appId
|
* @param basicAccessToken 缓存的对象
|
* @date 2023-04-20
|
*/
|
protected abstract void writeBasicAccessTokenToCache(String cacheKey, BasicAccessToken basicAccessToken);
|
|
/**
|
* 远程调用微信，获取一个新的基础'access_token'数据。
|
* @param appId
|
* @param secret
|
* @return
|
* @throws WxRemoteException
|
* @date 2023-04-20
|
*/
|
protected abstract BasicAccessToken acquireRemoteBasicAccessToken(String appId, String secret) throws WxRemoteException;
|
|
protected abstract WxUserInfo acquireRemoteUserInfoSub(String openId, String basicAccessToken) throws WxRemoteException;
|
|
@Override
|
public void setAppId(String appId) {
|
if(StringUtils.isEmpty(appId)){
|
throw new IllegalArgumentException("'appId'必须提供");
|
}
|
this.appId = appId;
|
}
|
|
@Override
|
public void setSecret(String secret) {
|
if(StringUtils.isEmpty(secret)){
|
throw new IllegalArgumentException("'secret'必须提供");
|
}
|
this.secret = secret;
|
}
|
|
@Override
|
public String getAppId() {
|
return appId;
|
}
|
|
protected String getSecret() {
|
return secret;
|
}
|
|
public long getMaxCachedAccessTokenSeconds() {
|
return maxCachedAccessTokenSeconds;
|
}
|
|
/**
|
* 设置：access_token 缓存最大时间（秒），默认：5400秒
|
* @param maxCachedAccessTokenSeconds
|
* @date 2023-04-20
|
*/
|
public void setMaxCachedAccessTokenSeconds(long maxCachedAccessTokenSeconds) {
|
this.maxCachedAccessTokenSeconds = maxCachedAccessTokenSeconds;
|
}
|
|
private long maxCachedAccessTokenSeconds = 5400;
|
private String appId;
|
private String secret;
|
}
|
