package com.qianwen.core.social.request;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.dingtalk.api.DefaultDingTalkClient;
|
import com.dingtalk.api.request.OapiGettokenRequest;
|
import com.dingtalk.api.request.OapiUserGetRequest;
|
import com.dingtalk.api.request.OapiUserGetuserinfoRequest;
|
import com.dingtalk.api.response.OapiGettokenResponse;
|
import com.dingtalk.api.response.OapiUserGetResponse;
|
import com.dingtalk.api.response.OapiUserGetuserinfoResponse;
|
import me.zhyd.oauth.cache.AuthStateCache;
|
import me.zhyd.oauth.config.AuthConfig;
|
import me.zhyd.oauth.exception.AuthException;
|
import me.zhyd.oauth.model.AuthCallback;
|
import me.zhyd.oauth.model.AuthToken;
|
import me.zhyd.oauth.model.AuthUser;
|
import me.zhyd.oauth.request.AuthDefaultRequest;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import com.qianwen.core.social.props.BladeAuthSource;
|
|
/* loaded from: blade-starter-social-9.3.2.0-SNAPSHOT.jar:org/springblade/core/social/request/CustomAuthDingTalkRequest.class */
|
public class CustomAuthDingTalkRequest extends AuthDefaultRequest {
|
private static final Logger log = LoggerFactory.getLogger(CustomAuthDingTalkRequest.class);
|
public static final String DAILY_DING_JS_TICKET = "dailyApplication:ticket:";
|
public static final String DAILY_DING_ACCESS_TOKEN = "dailyApplication:accessToken:";
|
private static final String URL_GET_USER_INFO = "https://oapi.dingtalk.com/user/getuserinfo";
|
|
public CustomAuthDingTalkRequest(AuthConfig config, AuthStateCache authStateCache) {
|
this(config, BladeAuthSource.DINGTALK_WEB, authStateCache);
|
}
|
|
public CustomAuthDingTalkRequest(AuthConfig config, BladeAuthSource source, AuthStateCache authStateCache) {
|
super(config, source, authStateCache);
|
}
|
|
public AuthToken getAccessToken(final AuthCallback authCallback) {
|
String accessToken = getAccessToken();
|
AuthToken authToken = null;
|
if (accessToken != null) {
|
authToken = new AuthToken();
|
authToken.setAccessToken(accessToken);
|
authToken.setCode(authCallback.getCode());
|
}
|
return authToken;
|
}
|
|
public String getAccessToken() {
|
try {
|
String appkey = this.config.getClientId();
|
String appsecret = this.config.getClientSecret();
|
String appTokenRedisKey = DAILY_DING_ACCESS_TOKEN.concat(appkey).concat(":");
|
String accessToken = this.authStateCache.get(appTokenRedisKey);
|
if (accessToken != null) {
|
return accessToken;
|
}
|
DefaultDingTalkClient client = new DefaultDingTalkClient(this.source.accessToken());
|
OapiGettokenRequest request = new OapiGettokenRequest();
|
request.setAppkey(appkey);
|
request.setAppsecret(appsecret);
|
request.setHttpMethod("GET");
|
OapiGettokenResponse response = client.execute(request);
|
if (!response.isSuccess()) {
|
throw new AuthException(response.getErrmsg());
|
}
|
String accessToken2 = response.getAccessToken();
|
this.authStateCache.cache(appTokenRedisKey, accessToken2, response.getExpiresIn().longValue() * 1000);
|
return accessToken2;
|
}catch(Exception e) {
|
throw new RuntimeException(e);
|
}
|
}
|
|
public String getUserId(final String authCode) {
|
try {
|
String accessToken = getAccessToken();
|
DefaultDingTalkClient defaultDingTalkClient = new DefaultDingTalkClient(URL_GET_USER_INFO);
|
OapiUserGetuserinfoRequest request = new OapiUserGetuserinfoRequest();
|
request.setCode(authCode);
|
request.setHttpMethod("GET");
|
//OapiGettokenResponse response = (OapiGettokenResponse)defaultDingTalkClient.execute(request);
|
|
OapiUserGetuserinfoResponse response = defaultDingTalkClient.execute(request, accessToken);
|
if (!response.isSuccess()) {
|
throw new AuthException(response.getErrmsg());
|
}
|
|
return response.getUserid();
|
}catch(Exception e) {
|
throw new RuntimeException(e);
|
}
|
}
|
|
protected AuthUser getUserInfo(AuthToken authToken) {
|
try {
|
String accessToken = authToken.getAccessToken();
|
String userId = getUserId(authToken.getCode());
|
DefaultDingTalkClient defaultDingTalkClient = new DefaultDingTalkClient(this.source.userInfo());
|
OapiUserGetRequest request = new OapiUserGetRequest();
|
request.setUserid(userId);
|
request.setHttpMethod("GET");
|
//OapiUserGetResponse response = defaultDingTalkClient.execute(request, accessToken);
|
OapiUserGetResponse response = defaultDingTalkClient.execute(request, accessToken);
|
if (!response.isSuccess()) {
|
throw new AuthException(response.getErrmsg());
|
}
|
log.info("用户信息：{}", JSONObject.toJSONString(response));
|
return AuthUser.builder().rawUserInfo((JSONObject) JSONObject.toJSON(response)).uuid(response.getUserid()).nickname(response.getNickname()).username(response.getName()).location(response.getPosition()).email(response.getEmail()).avatar(response.getAvatar()).source(this.source.toString()).token(authToken).build();
|
}catch(Exception e) {
|
throw new RuntimeException(e);
|
}
|
}
|
}
|
