package com.hdl.sdk.connect.cloud.interceptor; import android.content.Intent; import android.text.TextUtils; import android.util.Log; import androidx.annotation.NonNull; import com.google.gson.JsonObject; import com.google.gson.JsonParser; import com.hdl.hdlhttp.HxHttpConfig; import com.hdl.sdk.common.utils.SPUtils; import com.hdl.sdk.connect.cloud.CloudCode; import com.hdl.sdk.connect.cloud.HdlCloudApi; import com.hdl.sdk.connect.cloud.broadcast.CloudBroadcast; import com.hdl.sdk.connect.cloud.broadcast.CloudBroadcastAction; import com.hdl.sdk.connect.config.HDLCloudConfig; import com.hdl.sdk.sourceos.utils.SPKey; 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 = HDLCloudConfig.getInstance().getToken(); if (!TextUtils.isEmpty(token)) { Request processRequest = addToken(request, token); Response processResponse = chain.proceed(processRequest); return disposeToken(chain, processRequest, processResponse); } else { //没有缓存token处理 Response response = chain.proceed(request); //是否需要token，需要则广播 ResponseBody responseBody = response.body(); if (401 == response.code() || 402 == response.code() || 403 == response.code()) { //网络校验异常，需要token final Intent intent = new Intent(); intent.setAction(CloudBroadcastAction.REFRESH_TOKEN_INVALID_ACTION); sendBroadcast(intent); } else if (responseBody != null && response.isSuccessful()) { try { MediaType mediaType = responseBody.contentType(); if (mediaType != null) { String type = mediaType.toString(); //json类型才处理 if (!TextUtils.isEmpty(type) && type.contains("json")) { 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(); if (isTokenLoseByCode(code)) { //token失效了,需要token final Intent intent = new Intent(); intent.setAction(CloudBroadcastAction.REFRESH_TOKEN_INVALID_ACTION); sendBroadcast(intent); } } } } catch (Exception e) { e.printStackTrace(); } } return response; } } return chain.proceed(request); } @NonNull private Response disposeToken(Chain chain, Request request, Response response) { try { if (401 == response.code() || 402 == response.code() || 403 == response.code()) { final String token = refreshToken(); if (!TextUtils.isEmpty(token)) { return chain.proceed(addToken(request, token)); } //网络异常不需要重置token } else if (response.isSuccessful()) { ResponseBody responseBody = response.body(); if (responseBody != null) { MediaType mediaType = responseBody.contentType(); if (mediaType != null) { String type = mediaType.toString(); //json类型才处理 if (!TextUtils.isEmpty(type) && type.contains("json")) { 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 = -1; try { if (object != null) { code = object.get("code").getAsInt(); } } catch (Exception e) { e.printStackTrace(); } String message = ""; try { if (object != null && object.has("message")) { message = object.get("message").getAsString(); if (TextUtils.isEmpty(message)) { message = ""; } } } catch (Exception e) { e.printStackTrace(); } if (isTokenLoseByCode(code)) { //刷新token final String token = refreshToken(); if (!TextUtils.isEmpty(token)) { Response newResponse = chain.proceed(addToken(request, token)); //token更新了 final Intent intent = new Intent(); intent.setAction(CloudBroadcastAction.REFRESH_TOKEN_ACTION); sendBroadcast(intent); return newResponse; } else { //清空token HDLCloudConfig.getInstance().setToken(""); HDLCloudConfig.getInstance().setRefreshToken(""); //token刷新失败，通知token失效了 final Intent intent = new Intent(); intent.setAction(CloudBroadcastAction.REFRESH_TOKEN_INVALID_ACTION); sendBroadcast(intent); } } else { try { //其他异常情况 final Intent intent = new Intent(); intent.setAction(CloudBroadcastAction.API_ERROR_ACTION); intent.putExtra(CloudBroadcast.KEY_API_CODE, code); intent.putExtra(CloudBroadcast.KEY_API_MESSAGE, message); sendBroadcast(intent); } catch (Exception e) { e.printStackTrace(); } } buffer.clear(); } } } } } catch (Exception e) { Log.d("HDL===>", "disposeToken: 失败," + e); } return response; } /** * 根据code判断token是否失效 * * @param code 业务code * @return ture 失效 */ private boolean isTokenLoseByCode(int code) { return CloudCode.TOKEN_TIMEOUT == code || CloudCode.TOKEN_NOT_STANDARD == code || CloudCode.NO_TOKEN == code; } /** * 是否存在刷新头 */ private boolean isRefreshTokenHeader(Headers headers) { String signHeader = headers.get(SmartHeader.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", HDLCloudConfig.getInstance().getTokenHeaderPrefix() + token) .build(); } /** * 拦截器EncryptInterceptor会处理加密 * * @return token */ private String refreshToken() { final String cacheRefreshToken = SPUtils.getString(SPKey.REFRESH_TOKEN); if (TextUtils.isEmpty(cacheRefreshToken)) { return null; } 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(HDLCloudConfig.getInstance().getBaseUrl() + HdlCloudApi.LOGIN); builder.addHeader(SmartHeader.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()); JsonObject object = JsonParser.parseString(respString).getAsJsonObject(); JsonObject dataJson = object.get("data").getAsJsonObject(); String accessToken = dataJson.get("accessToken").getAsString(); String refreshToken = dataJson.get("refreshToken").getAsString(); if (!TextUtils.isEmpty(accessToken)) { HDLCloudConfig.getInstance().setToken(accessToken); } if (!TextUtils.isEmpty(refreshToken)) { HDLCloudConfig.getInstance().setRefreshToken(refreshToken); } return accessToken; } } else { Log.d("OKHTTP===>", "refreshToken: 失败了"); } } catch (Exception ignored) { Log.d("OKHTTP===>", "refreshToken: 失败,异常"); } return ""; } private void sendBroadcast(Intent intent) { HDLCloudConfig.getInstance().getContext().sendBroadcast(intent); } }