add retrofit lib util

朱显松
1 parent e6959934
Showing 11 changed files with 334 additions and 6 deletions
app/build.gradle
cnlive/src/main/java/com/cnlive/libs/base/activity/MvpBindingActivity.java
cnlive/src/main/java/com/cnlive/libs/base/fragment/MvpBindingFragment.java
cnlive/src/main/java/com/cnlive/libs/base/model/IBaseInfo.java
cnlive/src/main/java/com/cnlive/libs/base/network/ClientInterceptor.java
cnlive/src/main/java/com/cnlive/libs/base/network/NetworkUtil.java
cnlive/src/main/java/com/cnlive/libs/base/network/RetrofitUtil.java
cnlive/src/main/java/com/cnlive/libs/base/network/Subscriber.java
cnlive/src/main/java/com/cnlive/libs/base/network/Tls12SocketFactory.java
cnlive/src/main/java/com/cnlive/libs/base/network/TransformUtil.java
cnlive/src/main/java/com/cnlive/libs/base/ReflectUtil.java → cnlive/src/main/java/com/cnlive/libs/base/util/ReflectUtil.java
@@ -33,5 +33,6 @@ dependencies {
     compile 'com.android.support.constraint:constraint-layout:1.0.2'
     //    TODO 本地酷使用说明 代码仓库标识
     //    compile 'com.cnlive.libs:base:1.0.0@aar'
-    compile 'com.cnlive:cnlive:0.1.0'
+    //    compile 'com.cnlive:cnlive:0.1.0'
+    compile project(':cnlive')
 }
@@ -5,7 +5,7 @@ import android.databinding.ViewDataBinding;
 import android.os.Bundle;
 import android.support.annotation.NonNull;
  
-import com.cnlive.libs.base.ReflectUtil;
+import com.cnlive.libs.base.util.ReflectUtil;
 import com.hannesdorfmann.mosby.mvp.MvpActivity;
 import com.hannesdorfmann.mosby.mvp.MvpPresenter;
 import com.hannesdorfmann.mosby.mvp.MvpView;
@@ -9,7 +9,7 @@ import android.view.LayoutInflater;
 import android.view.View;
 import android.view.ViewGroup;
  
-import com.cnlive.libs.base.ReflectUtil;
+import com.cnlive.libs.base.util.ReflectUtil;
 import com.hannesdorfmann.mosby.mvp.MvpFragment;
 import com.hannesdorfmann.mosby.mvp.MvpPresenter;
 import com.hannesdorfmann.mosby.mvp.MvpView;
+package com.cnlive.libs.base.model;
+
+
+import java.io.Serializable;
+
+public interface IBaseInfo extends Serializable {
+    String getCode();
+
+    String getMessage();
+}
+package com.cnlive.libs.base.network;
+
+
+import android.content.Context;
+
+import java.io.IOException;
+
+import okhttp3.Interceptor;
+import okhttp3.Request;
+import okhttp3.Response;
+
+class ClientInterceptor implements Interceptor {
+
+    private Context mContext;
+
+    ClientInterceptor(Context context) {
+        mContext = context;
+    }
+
+    @Override
+    public Response intercept(Chain chain) throws IOException {
+        Request request = chain.request();
+
+        Response response = chain.proceed(request);
+        if (NetworkUtil.isConnectInternet(mContext)) {
+            int maxAge = 60 * 60; // read from cache for 1 minute
+            response.newBuilder()
+                    .addHeader("Cache-Control", "public, max-age=" + maxAge)
+                    .build();
+
+        } else {
+            int maxStale = 60 * 60 * 24 * 28; // tolerate 4-weeks stale
+            response.newBuilder()
+                    .addHeader("Cache-Control", "public, only-if-cached, max-stale=" + maxStale)
+                    .build();
+        }
+
+        return response;
+    }
+}
 \ No newline at end of file
+package com.cnlive.libs.base.network;
+
+import android.content.Context;
+import android.net.ConnectivityManager;
+import android.net.NetworkInfo;
+
+public class NetworkUtil {
+
+    private static ConnectivityManager connectManager;
+
+    private static void initConnectivityManager(Context context) {
+        if (connectManager == null) connectManager = (ConnectivityManager)
+                context.getSystemService(Context.CONNECTIVITY_SERVICE);
+    }
+
+    public static boolean isConnectInternet(Context context) {
+        if (context == null) return false;
+        initConnectivityManager(context);
+
+        if (connectManager != null) {
+            NetworkInfo networkinfo = connectManager.getActiveNetworkInfo();
+            return networkinfo != null && networkinfo.isAvailable();
+        }
+        return false;
+    }
+
+}
 \ No newline at end of file
+package com.cnlive.libs.base.network;
+
+
+import android.content.Context;
+
+
+import com.cnlive.libs.base.util.LogUtil;
+
+import java.util.concurrent.TimeUnit;
+
+import javax.net.ssl.SSLContext;
+import javax.net.ssl.SSLSocketFactory;
+
+import okhttp3.Cache;
+import okhttp3.OkHttpClient;
+import okhttp3.logging.HttpLoggingInterceptor;
+import retrofit2.Retrofit;
+import retrofit2.adapter.rxjava2.RxJava2CallAdapterFactory;
+import retrofit2.converter.gson.GsonConverterFactory;
+
+public class RetrofitUtil {
+    private static boolean DEBUG = true;
+
+    private static final String TAG = "RetrofitUtil";
+
+    public static void setBuildType(boolean debug) {
+        DEBUG = debug;
+    }
+
+    public static <T> T getRestAPI(String endpoint, Class<T> service) {
+
+        return getRestAPI(null, false, true, 5000, 5000, endpoint, service);
+    }
+
+    public static <T> T getRestAPI(String endpoint, Class<T> service, boolean showLog) {
+
+        return getRestAPI(null, false, showLog, 5000, 5000, endpoint, service);
+    }
+
+    private static <T> T getRestAPI(Context context, boolean hasCache, boolean showLog, int readTimeout, int connectTimeout, String endpoint, Class<T> service) {
+
+        OkHttpClient.Builder okHttpClientBuilder = new OkHttpClient().newBuilder();
+
+        try {
+            SSLContext sslContext = SSLContext.getInstance("TLS");
+            sslContext.init(null, null, null);
+            SSLSocketFactory socketFactory = new Tls12SocketFactory(sslContext.getSocketFactory());
+            okHttpClientBuilder.sslSocketFactory(socketFactory);
+        } catch (Exception e) {
+            LogUtil.e(TAG, "RetrofitUtil", e);
+        }
+
+        if (connectTimeout > 0) {
+            okHttpClientBuilder.connectTimeout(connectTimeout, TimeUnit.SECONDS);
+        }
+        if (readTimeout > 0) {
+            okHttpClientBuilder.readTimeout(readTimeout, TimeUnit.SECONDS);
+        }
+        if (hasCache) {
+            okHttpClientBuilder.cache(new Cache(context.getCacheDir(), 10 * 1024 * 1024));
+            okHttpClientBuilder.addNetworkInterceptor(new ClientInterceptor(context));
+        }
+
+        if (showLog) {
+            HttpLoggingInterceptor httpLoggingInterceptor = new HttpLoggingInterceptor();
+            httpLoggingInterceptor.setLevel(DEBUG ? HttpLoggingInterceptor.Level.BODY : HttpLoggingInterceptor.Level.NONE);
+            okHttpClientBuilder.addInterceptor(httpLoggingInterceptor);
+        }
+
+        Retrofit retrofit = new Retrofit.Builder()
+                .baseUrl(endpoint)
+                .client(okHttpClientBuilder.build())
+                .addConverterFactory(GsonConverterFactory.create())
+                .addCallAdapterFactory(RxJava2CallAdapterFactory.create())
+                .build();
+
+        return retrofit.create(service);
+    }
+
+
+}
+package com.cnlive.libs.base.network;
+
+import android.content.Context;
+import android.content.Intent;
+
+
+import com.cnlive.libs.base.model.IBaseInfo;
+import com.cnlive.libs.base.util.LogUtil;
+
+import io.reactivex.annotations.NonNull;
+import io.reactivex.disposables.Disposable;
+import io.reactivex.functions.Action;
+import io.reactivex.functions.Consumer;
+import retrofit2.Response;
+import retrofit2.adapter.rxjava2.Result;
+
+//TODO
+//load_success_code - 加载成功
+//load_failure_code - 加载失败
+//load_error_code - 加载错误
+//no_network_code - 没有网络
+//
+//特殊处理类型 (全局)
+
+public abstract class Subscriber<T extends IBaseInfo> {
+
+    private static String success_code = "200";
+    private static final String unkonwn_error_code = "-1";
+    private static final String network_error_code = "-2";
+    private T mPageData;
+    private Context mContext;
+
+
+    public Subscriber(Context context) {
+        this.mContext = context;
+    }
+
+    public Consumer<Result<T>> next = new Consumer<Result<T>>() {
+        @Override
+        public void accept(Result<T> data) throws Exception {
+            Response<T> response = data.response();
+            if (response != null) mPageData = response.body();
+            else if (!NetworkUtil.isConnectInternet(mContext)) onNetworkNoConnected();
+            else onError(unkonwn_error_code, network_load_fail);
+        }
+    };
+
+    public Consumer<Throwable> error = new Consumer<Throwable>() {
+        @Override
+        public void accept(Throwable e) throws Exception {
+            LogUtil.d("NetLoader", "onError ", e);
+            if (mContext != null && !NetworkUtil.isConnectInternet(mContext))
+                onNetworkNoConnected();
+            else onError(unkonwn_error_code, e != null ? e.getMessage() : network_load_error);
+        }
+    };
+
+    public Action complete = new Action() {
+        @Override
+        public void run() throws Exception {
+            if (mPageData != null && success_code.equals(mPageData.getCode())) {
+                onCompleted(mPageData);
+            } else if (mPageData != null) {
+                //TODO 特定请求类型
+                if (token_invalid.equals(mPageData.getCode())) {
+                    onError(mPageData.getCode(), "用户信息已失效 ,请重新登录.");
+                    onTokenInvalid();
+                } else {
+                    onError(mPageData.getCode(), mPageData.getMessage());
+                }
+            } else {
+                if (mContext != null && !NetworkUtil.isConnectInternet(mContext))
+                    onNetworkNoConnected();
+                else onError(unkonwn_error_code, network_load_fail);
+            }
+        }
+    };
+
+    public Consumer<Disposable> subscribe = new Consumer<Disposable>() {
+        @Override
+        public void accept(@NonNull Disposable disposable) throws Exception {
+            onStart();
+        }
+    };
+
+
+    public abstract void onCompleted(T data);
+
+    public abstract void onError(String code, String message);
+
+    public void onNetworkNoConnected() {
+        onError(network_error_code, network_no_connected);
+    }
+
+    public void onStart() {
+    }
+
+}
 \ No newline at end of file
+package com.cnlive.libs.base.network;
+
+import java.io.IOException;
+import java.net.InetAddress;
+import java.net.Socket;
+import java.net.UnknownHostException;
+
+import javax.net.ssl.SSLSocket;
+import javax.net.ssl.SSLSocketFactory;
+
+public class Tls12SocketFactory extends SSLSocketFactory {
+    private static final String[] TLS_SUPPORT_VERSION = {"TLSv1.1", "TLSv1.2"};
+
+    final SSLSocketFactory delegate;
+
+    public Tls12SocketFactory(SSLSocketFactory base) {
+        this.delegate = base;
+    }
+
+    @Override
+    public String[] getDefaultCipherSuites() {
+        return delegate.getDefaultCipherSuites();
+    }
+
+    @Override
+    public String[] getSupportedCipherSuites() {
+        return delegate.getSupportedCipherSuites();
+    }
+
+    @Override
+    public Socket createSocket(Socket s, String host, int port, boolean autoClose) throws IOException {
+        return patch(delegate.createSocket(s, host, port, autoClose));
+    }
+
+    @Override
+    public Socket createSocket(String host, int port) throws IOException, UnknownHostException {
+        return patch(delegate.createSocket(host, port));
+    }
+
+    @Override
+    public Socket createSocket(String host, int port, InetAddress localHost, int localPort) throws IOException, UnknownHostException {
+        return patch(delegate.createSocket(host, port, localHost, localPort));
+    }
+
+    @Override
+    public Socket createSocket(InetAddress host, int port) throws IOException {
+        return patch(delegate.createSocket(host, port));
+    }
+
+    @Override
+    public Socket createSocket(InetAddress address, int port, InetAddress localAddress, int localPort) throws IOException {
+        return patch(delegate.createSocket(address, port, localAddress, localPort));
+    }
+
+    private Socket patch(Socket s) {
+        if (s instanceof SSLSocket) {
+            ((SSLSocket) s).setEnabledProtocols(TLS_SUPPORT_VERSION);
+        }
+        return s;
+    }
+}
 \ No newline at end of file
+package com.cnlive.libs.base.network;
+
+import com.google.gson.Gson;
+
+public class TransformUtil {
+
+    public static <T> T transform(Class<T> clazz, Object object) {
+        Gson gson = new Gson();
+        String json = gson.toJson(object);
+        return gson.fromJson(json, clazz);
+    }
+}
-package com.cnlive.libs.base;
+package com.cnlive.libs.base.util;
  
  
-import com.cnlive.libs.base.util.LogUtil;
-
 import java.lang.reflect.Constructor;
 import java.lang.reflect.Method;
 import java.lang.reflect.ParameterizedType;