package com.future.dispatch.netUtls;


import com.google.gson.Gson;

import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.TimeUnit;

import io.reactivex.Observer;
import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.schedulers.Schedulers;
import okhttp3.OkHttpClient;
import okhttp3.ResponseBody;
import retrofit2.Retrofit;
import retrofit2.adapter.rxjava2.RxJava2CallAdapterFactory;
import retrofit2.converter.gson.GsonConverterFactory;


/**
 * 网络请求管理类
 * Created by Administrator on 2018/1/25.
 */

public class FaceHttpManager {
    private static FaceHttpManager httpManager;
    private Gson gson;
    private Map<String, String> headerParams;
    private HashMap<String, Object> map;

    public static synchronized FaceHttpManager getInstance() {
        if (httpManager == null) synchronized (FaceHttpManager.class) {
            if (httpManager == null) {
                httpManager = new FaceHttpManager();
            }
        }
        return httpManager;
    }


    /**
     * 初始化请求头，具体情况根据需求设置
     */
    public void initHeader() {
        headerParams = new HashMap<>();
        map = new HashMap<>();
        // 传参方式为json
        headerParams.put("Content-Type", "application/x-www-form-urlencoded; charset=UTF-8");
        headerParams.put("Authorization", "APPCODE " + "b7d32437d08149099457dcb50fb57df2");
    }

    public HashMap<String, Object> getMap() {
        if (map == null) {
            map = new HashMap<>();
        }
        map.clear();
        return map;
    }



    /**
     * 初始化数据
     *
     * @param action 当前请求的尾址
     */
    private Retrofit initBaseData(final String action) {
        initHeader();
        // 监听请求条件
        OkHttpClient.Builder builder = new OkHttpClient.Builder();
        builder.connectTimeout(20, TimeUnit.SECONDS);
        Retrofit.Builder builder1 = new Retrofit.Builder()
                .client(builder.build())                                    // 配置监听请求
                .addConverterFactory(GsonConverterFactory.create())         // 请求结果转换（当前为GSON）
                .addCallAdapterFactory(RxJava2CallAdapterFactory.create()); // 请求接受工具（当前为RxJava2）
        builder1.baseUrl("https://sfzread.market.alicloudapi.com/");

        return builder1.build();
    }


    /**
     * Post请求
     *
     * @param action 请求接口的尾址
     * @param params 请求参数
     */
    public void post(final String action, Map<String, Object> params,
                                          Observer<ResponseBody> observer) {
        if (params == null) {
            params = new HashMap<>();
        }
        ApiServics jsonService = initBaseData(action).create(ApiServics.class);
        jsonService.postResult(action, headerParams,params)
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(observer);
    }

    /**
     * Get请求
     *
     * @param action   请求接口的尾址
     * @param params   请求参数
     * @param observer observer
     */
    //                                         public <T extends BaseBean> void get(final String action,
    public  void get(final String action, Map<String, String> params, Observer<ResponseBody> observer) {
        if (params == null) {
            params = new HashMap<>();
        }
        if (gson == null) {
            gson = new Gson();
        }

        ApiServics getService = initBaseData(action).create(ApiServics.class);
        getService.getResult(action, headerParams, params)
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(observer);
    }

//
//    /**
//     * Post请求
//     *
//     * @param action   请求接口的尾址
//     * @param fileName 文件名
//     */
//    public <T extends BaseBean> void post(final String action, File fileName,
//                                          Observer<ResponseBody> observer) {
//        ApiServics service = initBaseData(action).create(ApiServics.class);
//        File file = fileName;
//        RequestBody requestFile =
//                RequestBody.create(MediaType.parse("multipart/form-data"), file);
//        MultipartBody.Part body =
//                MultipartBody.Part.createFormData("picture", file.getName(), requestFile);
//        service.upload(action, body)
//                .subscribeOn(Schedulers.io())
//                .observeOn(AndroidSchedulers.mainThread())
//                .subscribe(observer);
//
//    }

}