package com.hdl.linkpm.sdk.core.interceptor;
|
|
import android.text.TextUtils;
|
import android.util.Log;
|
|
import androidx.annotation.NonNull;
|
|
import com.google.gson.Gson;
|
import com.google.gson.JsonObject;
|
import com.google.gson.JsonParser;
|
import com.google.gson.reflect.TypeToken;
|
import com.hdl.hdlhttp.HxHttpConfig;
|
import com.hdl.linkpm.sdk.core.api.HDLCloudUserApi;
|
import com.hdl.linkpm.sdk.core.code.HDLCloudCode;
|
import com.hdl.linkpm.sdk.core.response.BaseInfo;
|
import com.hdl.linkpm.sdk.user.HDLLinkPMUser;
|
import com.hdl.linkpm.sdk.user.bean.HDLLoginBean;
|
import com.hdl.linkpm.sdk.utils.HDLGsonUtils;
|
|
import java.io.IOException;
|
import java.nio.charset.Charset;
|
|
import okhttp3.Headers;
|
import okhttp3.Interceptor;
|
import okhttp3.MediaType;
|
import okhttp3.OkHttpClient;
|
import okhttp3.Request;
|
import okhttp3.RequestBody;
|
import okhttp3.Response;
|
import okhttp3.ResponseBody;
|
import okio.Buffer;
|
import okio.BufferedSource;
|
|
/**
|
* Created by Tong on 2021/11/2.
|
*/
|
public class HDLLoginInterceptor implements Interceptor {
|
|
@NonNull
|
@Override
|
public Response intercept(@NonNull Chain chain) throws IOException {
|
Request request = chain.request();
|
if (!isRefreshTokenHeader(request.headers())) {
|
String token = HDLLinkPMUser.getInstance().getAccessToken();
|
if (!TextUtils.isEmpty(token)) {
|
Request processRequest = addToken(request, token);
|
Response processResponse = chain.proceed(processRequest);
|
return disposeToken(chain, processRequest, processResponse);
|
}
|
}
|
return chain.proceed(request);
|
}
|
|
@NonNull
|
private Response disposeToken(Chain chain, Request request, Response response) {
|
try {
|
|
// ResponseBody responseBody2 = response.body();
|
// BufferedSource source2 = responseBody2.source();
|
// source2.request(Long.MAX_VALUE);
|
// Buffer buffer2 = source2.getBuffer().clone();
|
// String respString2 = buffer2.readString(Charset.defaultCharset());
|
//http标准状态码
|
if (401 == response.code() || 402 == response.code() || 403 == response.code()) {
|
final String token = refreshToken();
|
if (!TextUtils.isEmpty(token)) {
|
return chain.proceed(addToken(request, token));
|
}
|
|
} else if (response.isSuccessful()) {
|
ResponseBody responseBody = response.body();
|
if (responseBody != null) {
|
BufferedSource source = responseBody.source();
|
source.request(Long.MAX_VALUE);
|
Buffer buffer = source.getBuffer().clone();
|
String respString = buffer.readString(Charset.defaultCharset());
|
JsonObject object = JsonParser.parseString(respString).getAsJsonObject();
|
int code = object.get("code").getAsInt();
|
//1.判断token是否过期是否需要刷新token
|
if (isTokenTimeoutByCode(code)) {
|
final String token = refreshToken();
|
if (!TextUtils.isEmpty(token)) {
|
return chain.proceed(addToken(request, token));
|
}
|
}
|
//2.判断Token是否错误 发送登出处理通知
|
if (isTokenNeedReLoginByCode(code)) {
|
//3.清空登录信息并发出重新登录通知
|
HDLLinkPMUser.getInstance().logout(0);
|
}
|
}
|
|
}
|
|
} catch (Exception e) {
|
Log.d("HDL===>", "disposeToken: 失败," + e);
|
}
|
return response;
|
}
|
|
/**
|
* 根据code判断token是否失效 需要刷新重新token
|
*
|
* @param code 业务code
|
* @return ture 失效
|
*/
|
private boolean isTokenTimeoutByCode(int code) {
|
return HDLCloudCode.TOKEN_TIMEOUT == code;
|
}
|
|
/**
|
* 根据code判断token是否失效 需要重新登录的
|
*
|
* @param code 业务code
|
* @return ture 失效
|
*/
|
private boolean isTokenNeedReLoginByCode(int code) {
|
return HDLCloudCode.RE_LOGIN == code
|
|| HDLCloudCode.TOKEN_NOT_STANDARD == code
|
|| HDLCloudCode.NO_TOKEN == code
|
|| HDLCloudCode.CODE_TOKEN_ERROR_10006 == code
|
|| HDLCloudCode.CODE_TOKEN_ERROR_10009 == code;
|
}
|
|
|
/**
|
* 是否存在刷新头
|
*/
|
private boolean isRefreshTokenHeader(Headers headers) {
|
String signHeader = headers.get(HDLSmartHeader.REFRESH_TOKEN_HEADER);
|
return !TextUtils.isEmpty(signHeader);
|
}
|
|
private Request addToken(Request request, String token) {
|
return request.newBuilder()
|
.removeHeader("Authorization")
|
.build()
|
.newBuilder()
|
.method(request.method(), request.body())
|
.addHeader("Authorization", token)
|
.build();
|
}
|
|
/**
|
* 拦截器EncryptInterceptor会处理加密
|
*
|
* @return token
|
*/
|
private String refreshToken() {
|
final String cacheRefreshToken = HDLLinkPMUser.getInstance().getRefreshToken();
|
final String regionUrl = HDLCloudUserApi.getRequestUrl(HDLCloudUserApi.POST_LOGIN);
|
final OkHttpClient client = HxHttpConfig.getInstance().getClient();
|
Request.Builder builder = new Request.Builder();
|
|
final JsonObject json = new JsonObject();
|
json.addProperty("refreshToken", cacheRefreshToken);
|
json.addProperty("grantType", "refresh_token");
|
|
final RequestBody requestBody = RequestBody.create(json.toString(), MediaType.parse("application/json;charset=UTF-8"));
|
builder.post(requestBody);
|
builder.url(regionUrl);
|
builder.addHeader(HDLSmartHeader.REFRESH_TOKEN_HEADER, "0");
|
try {
|
Response response = client.newCall(builder.build()).execute();
|
if (response.isSuccessful()) {
|
ResponseBody responseBody = response.body();
|
if (responseBody != null) {
|
BufferedSource source = responseBody.source();
|
source.request(Long.MAX_VALUE);
|
Buffer buffer = source.getBuffer().clone();
|
String respString = buffer.readString(Charset.defaultCharset());
|
BaseInfo<HDLLoginBean> baseInfo = HDLGsonUtils.fromJson(respString, new TypeToken<BaseInfo<HDLLoginBean>>() {
|
}.getType());
|
if (baseInfo != null) {
|
if (baseInfo.getCode() == HDLCloudCode.SUCCEED) {
|
if (baseInfo.getData() != null) {
|
HDLLoginBean loginBean = baseInfo.getData();
|
HDLLinkPMUser.getInstance().updateRefreshToken(loginBean);
|
return loginBean.getHeaderPrefix() + loginBean.getAccessToken();
|
}
|
} else {
|
//refreshToken也过期的话，则发出登出处理通知，重新登录
|
//清空登录信息并发出重新登录通知
|
HDLLinkPMUser.getInstance().logout(0);
|
}
|
}
|
}
|
}
|
} catch (Exception ignored) {
|
Log.d("HDL===>", "refreshToken: 失败");
|
}
|
return "";
|
}
|
}
|
