package com.yongninggo.ok_http;

import com.yongninggo.ok_http.https.HttpsUtils;

import java.util.concurrent.TimeUnit;

import javax.net.ssl.HostnameVerifier;
import javax.net.ssl.SSLSession;

import okhttp3.Call;
import okhttp3.OkHttpClient;
import okhttp3.Request;

/**
 * @function 请求发送,请求参数的配置,https的支持
 * @author 小马哥
 */

public class CommonOkhttpClient {

    private static final int TIME_OUT = 30; //超时参数为30秒
    private static OkHttpClient okHttpClient;

    //为我们的Client配置参数
    static {
        //创建构建者对象
        OkHttpClient.Builder okHttpBuilder = new OkHttpClient.Builder();
        okHttpBuilder.connectTimeout(TIME_OUT, TimeUnit.SECONDS);//填充超时时间
        okHttpBuilder.readTimeout(TIME_OUT,TimeUnit.SECONDS);//填充读超时间
        okHttpBuilder.writeTimeout(TIME_OUT,TimeUnit.SECONDS);//填充写超时间

        okHttpBuilder.followRedirects(true);  //允许服务重定向

        //添加https支持
        okHttpBuilder.hostnameVerifier(new HostnameVerifier() {
            @Override
            public boolean verify(String hostname, SSLSession session) {
                return true;
            }
        });
        //设置SSLFactory
        okHttpBuilder.sslSocketFactory(HttpsUtils.getSslSocketFactory());
        //生成Client对象
        okHttpClient = okHttpBuilder.build();
    }

    //发送具体的请求   返回Call
    public static Call sendRequest (Request request, okhttp3.Callback callback){

        Call call = okHttpClient.newCall(request);
        call.enqueue(callback);
        return call;
    }

}

package com.yongninggo.ok_http.listener;

/**
 * 自定义事件监听
 */

public interface DisposeDataListener {
    //请求失败调用
    public void onFailure (Object responseObj);


    //请求成功调用
    public void onSuccess (Object reasonObj);
}

package com.yongninggo.ok_http.listener;

/**
 * @author chao
 * @function json对象装换成实体对象
 */

public class DisposeDataHandle {

    public DisposeDataListener listener = null;
    public Class<?> aClass = null;

    //数据原封不动
    public DisposeDataHandle(DisposeDataListener listener){
        this.listener = listener;
    }
    //数据转化为json实体对象
    public DisposeDataHandle (DisposeDataListener listener,Class<?> clazz){
        this.listener = listener;
        this.aClass = clazz;
    }
}

package com.yongninggo.ok_http.Exception;

/**
 * @author chao
 * @function 自定义异常处理
 */

public class OkhttpException extends Exception {
    private static final long serialVersionUID = 1L;
    private int ecode;
    private Object emsg;
    public OkhttpException(int ecode,Object emsg){
        this.ecode = ecode;
        this.emsg = emsg;
    }
    public int getEcode (){
        return ecode;
    }
    public Object getEmsg (){
        return emsg;
    }
}

package com.yongninggo.ok_http.Response;

import android.os.Handler;
import android.os.Looper;

import com.yongninggo.ok_http.Exception.OkhttpException;
import com.yongninggo.ok_http.listener.DisposeDataHandle;
import com.yongninggo.ok_http.listener.DisposeDataListener;

import org.json.JSONException;
import org.json.JSONObject;

import java.io.IOException;

import okhttp3.Call;
import okhttp3.Response;


/**
 * @function 处理json的回调响应
 */

public class CommonjsonCallback  {

    //与服务器返回字段的对应关系
    protected final String RESULT_CODE = "exode";
    protected final int RESULT_CODE_VALUE = 0;
    protected final String ERROR_MSG = "emsg";
    protected final String EMPTY_MSG = "";

    //自定义异常类型
    protected final int NETWORK_ERROR = -1;//网络错误
    protected final int JSON_ERROR = -2;//json解析错误
    protected final int OTHER_ERROR = -3;//其他错误

    private Handler mDeliveryHandler;//进行消息的转发，将子线程的数据转发到UI线程
    private DisposeDataListener Listener;
    private Class<?> aClass;

    public CommonjsonCallback (DisposeDataHandle handle){
        this.Listener = handle.listener;
        this.aClass = handle.aClass;
        this.mDeliveryHandler = new Handler(Looper.getMainLooper());
    }

    //请求失败处理
    public void onFailure (final Call call, final IOException e){
            mDeliveryHandler.post(new Runnable() {
                @Override
                public void run() {
                    //失败的话将信息传入Exception中
                    Listener.onFailure(new OkhttpException(NETWORK_ERROR,e));
                }
            });
    }

    //请求成功响应处理
    public void onResponse (final Call call, final Response response) throws IOException{
        final String result = response.body().string();
        mDeliveryHandler.post(new Runnable() {
            @Override
            public void run() {
                handleResponse (result);
            }

        });
    }
    //处理服务器返回的响应数据
    private void handleResponse(Object responseObj) {
        //为了保证代码的健壮性
        if (responseObj == null && responseObj.toString().trim().equals(" ")){
            Listener.onFailure(new OkhttpException(NETWORK_ERROR,EMPTY_MSG));
            return;
        }

        try {
            //开始尝试解析json
            JSONObject reuslt = new JSONObject(responseObj.toString());
            //从json对象中取出我们的响应码,若为0（与服务器一致），则是正常的响应
            if (reuslt.has(RESULT_CODE)){
                if (reuslt.getInt(RESULT_CODE) == RESULT_CODE_VALUE){
                    if (aClass == null) {
                        Listener.onSuccess(responseObj);
                    } else {
                        //将json对象转化为实体对象
                        Gson gson = new Gson();
                        Object obj = gson.fromJson(responseObj.toString(),aClass);

                        if (obj != null) {
                            Listener.onSuccess(obj);
                        } else {
                            //返回的不是合法的json
                            Listener.onFailure(new OkhttpException(JSON_ERROR,EMPTY_MSG));
                        }
                    }
                }
                else {
                    //将服务器返回给我们的异常回调到应用层去处理
                    Listener.onFailure(new OkhttpException(OTHER_ERROR,reuslt.get(RESULT_CODE)));
                }
            }
        }
        catch (JSONException e) {
            Listener.onFailure(new OkhttpException(OTHER_ERROR,e.getMessage()));
        }

    }
}

private void test (){
        CommonOkhttpClient.sendRequest(CommonRequest.CreateGetRequest("http://www.baidu.com/",null),new CommonJsonCallback(new DisposeDataHandle(new DisposeDataListener() {
            @Override
            public void onFailure(Object responseObj) {

            }

            @Override
            public void onSuccess(Object reasonObj) {
                
                
            }
        })));
    }