package com.fangxinxing.xxfxx.netUtls;

import android.graphics.Bitmap;
import android.util.Log;

import com.fangxinxing.xxfxx.base.MyApplication;
import com.fangxinxing.xxfxx.utils.LogUtils;
import com.google.gson.JsonSyntaxException;

import java.lang.ref.WeakReference;
import java.net.ConnectException;
import java.net.SocketTimeoutException;

import cn.sinata.xldutils.activitys.BaseActivity;
import cn.sinata.xldutils.fragment.BaseFragment;
import cn.sinata.xldutils.net.utils.ResultException;
import cn.sinata.xldutils.utils.StringUtils;
import cn.sinata.xldutils.utils.Toast;
import cn.sinata.xldutils.utils.Utils;
import cn.sinata.xldutils.xldUtils;
import io.reactivex.Observer;
import io.reactivex.annotations.NonNull;
import io.reactivex.disposables.Disposable;
import okhttp3.ResponseBody;
import retrofit2.HttpException;

/**
 * 自定义Observer类处理网络上传文件 返回链接地址数据
 * Created by Administrator on 2018/1/25.
 */
public abstract class MyUploadObserver implements Observer<ResponseBody>, Disposable {

    WeakReference<BaseActivity> activities;
    WeakReference<BaseFragment> fragments;

    public static final String REQUEST_ERROR = "请求出错！";
    public static final String PARSER_ERROR = "数据解析出错！";
    public static final String SERVER_ERROR = "服务器异常，请稍后重试！";
    public static final String NET_ERROR = "未连接到服务器！";
    public static final String NET_TIMEOUT = "链接超时，请稍后再试！";


    public MyUploadObserver(BaseActivity activity) {
        activities = new WeakReference<>(activity);
        if (activity != null) {
            activity.compositeSubscription.add(this);
        }
    }

    public MyUploadObserver(BaseFragment fragment) {
        fragments = new WeakReference<BaseFragment>(fragment);
        if (fragment != null && !fragment.isDetached()) {
            fragment.addDisposable(this);
        }
    }

    public MyUploadObserver() {
    }

    @Override
    public void onSubscribe(@NonNull Disposable d) {

    }

    @Override
    public void onNext(@NonNull ResponseBody responseBody) {
        dismissDialog();
        try {
            String responseString = responseBody.string().replaceAll("\"","");
            LogUtils.e("responseString", "**" + responseString);
            if (StringUtils.isEmpty(responseString)) { //判空
                int code = -1;
                String msg = PARSER_ERROR;
                onError(code, msg, responseString);
                return;
            }
            if (responseString.startsWith("http")) {
                success(responseString);
            } else {
                onError(-1, "上传失败", responseString);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    @Override
    public void onError(@NonNull Throwable e) {
        dismissDialog();
        if (xldUtils.DEBUG) {
            e.printStackTrace();
        }
        Utils.systemErr(e);
        Log.e("responseString", "responseString get  " + e.toString());
        int code = -1;
        String msg = REQUEST_ERROR;
        if (e instanceof JsonSyntaxException ||
                e instanceof NumberFormatException ||
                e instanceof IllegalStateException) {
            msg = PARSER_ERROR;
        } else if (e instanceof HttpException) {
            msg = SERVER_ERROR;
        } else if (e instanceof ConnectException) {
            msg = NET_ERROR;
        } else if (e instanceof SocketTimeoutException) {
            msg = NET_TIMEOUT;
        } else if (e instanceof ResultException) {
            code = ((ResultException) e).getCode();
            msg = e.getMessage();
        }
        try {
            onError(code, msg, "");
        } catch (Exception es) {
            es.printStackTrace();
        }

    }

    protected void onError(int code, String msg, String resposeString) {
        if (shouldShowErrorToast()) {
            showToast(msg);
        }
    }

    protected boolean shouldShowErrorToast() {
        return true;
    }

    @Override
    public void onComplete() {

    }

    /**
     * 显示toast
     *
     * @param s 提示文字
     */
    protected void showToast(String s) {
        Toast.create(MyApplication.Companion.getInstance()).show(s);
    }

    /**
     * 访问成功回调抽象方法
     *
     * @param responseString 返回的数据
     */
    public abstract void success(String responseString);

    /**
     * 访问成功回调方法
     *
     * @param bitmap 获取的Bitmap
     */
    public void success(Bitmap bitmap) {
    }

    private void dismissDialog() {
        if (activities != null) {
            BaseActivity activity = activities.get();
            if (activity != null) {
                activity.dismissDialog();
            }
        }
        if (fragments != null) {
            BaseFragment fragment = fragments.get();
            if (fragment != null) {
                fragment.dismissDialog();
            }
        }
    }

    @Override
    public boolean isDisposed() {
        return false;
    }

    @Override
    public void dispose() {

    }
}