package com.hdl.sdk.sourceos.bind;

import android.text.TextUtils;

import com.hdl.hdlhttp.HxHttp;
import com.hdl.sdk.common.utils.SPUtils;
import com.hdl.sdk.connect.bean.response.BindInfoBean;
import com.hdl.sdk.connect.cloud.HDLException;
import com.hdl.sdk.connect.cloud.HDLResponse;
import com.hdl.sdk.connect.cloud.HdlCloudApi;
import com.hdl.sdk.connect.config.HDLCloudConfig;
import com.hdl.sdk.connect.config.HDLLinkConfig;
import com.hdl.sdk.sourceos.Rk3566Manager;
import com.hdl.sdk.sourceos.qrcode.QRCode;
import com.hdl.sdk.sourceos.utils.DeviceUtils;
import com.hdl.sdk.sourceos.utils.SPKey;
import com.hdl.sdk.sourceos.utils.thread.ThreadUtils;

import org.greenrobot.eventbus.EventBus;

import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicLong;

import io.reactivex.rxjava3.disposables.CompositeDisposable;
import io.reactivex.rxjava3.disposables.Disposable;

/**
 * Created by Tong on 2021/11/11.
 * on+是否绑定
 * 1、绑定成功需要查询住宅信息
 * 2、扫码3分钟超时
 */
public class BindHomeService {

    private ScheduledExecutorService queryThread;

    private final CompositeDisposable compositeDisposable = new CompositeDisposable();

    //最大时间
    private static final long MAX_TIME = 3 * 60 * 1000;

    //上一次执行时间
    private final AtomicLong lastTime = new AtomicLong(0);

    private BindHomeService() {
    }

    private static class SingletonInstance {
        private static final BindHomeService INSTANCE = new BindHomeService();
    }

    public static BindHomeService getInstance() {
        return SingletonInstance.INSTANCE;
    }

    /**
     * 轮询是否绑定
     *
     * @param timestamp 时间戳
     */
    public void startQuery(String timestamp) {
        stopQuery();
        lastTime.set(System.currentTimeMillis());
        String packageName = Rk3566Manager.getInstance().getContext().getPackageName();
        String unique = DeviceUtils.getUniqueCode();
        queryThread = ThreadUtils.newScheduledThreadPool(1);
        queryThread.scheduleWithFixedDelay(new Runnable() {
            @Override
            public void run() {
                long timeMillis = System.currentTimeMillis();
                if (timeMillis - lastTime.get() < MAX_TIME) {
                    compositeDisposable.add(isBind(packageName, unique, timestamp));
                } else {
                    //超时了
                    EventBus.getDefault().post(new BindAuthEvent(BindAuthEvent.ON_PLUS_BINDING_TIMEOUT_ACTION));
                    stopQuery();
                }

            }
        }, 0L, 800L, TimeUnit.MILLISECONDS);
    }

    /**
     * 停止查询
     */
    public void stopQuery() {
        lastTime.set(0);
        if (queryThread != null && !queryThread.isShutdown()) {
            queryThread.shutdownNow();
        }
        if (!compositeDisposable.isDisposed()) {
            compositeDisposable.dispose();
        }
    }


    /**
     * 通过保存的code查询是否绑定
     *
     * @param bindCode 保存的code查询是否绑定
     * @return
     */
    public static Disposable isBindByCode(String bindCode) {
        if (TextUtils.isEmpty(bindCode)) return null;
        String[] code = bindCode.split("_");
        if (code.length < 3) {
            return null;
        }
        String packageName = code[0];
        String unique = code[1];
        String timestamp = code[2];
        return isBind(packageName, unique, timestamp);
    }

    public static Disposable isBind(String timestamp) {
        String packageName = Rk3566Manager.getInstance().getContext().getPackageName();
        String unique = DeviceUtils.getUniqueCode();
        return isBind(packageName, unique, timestamp);
    }

    /**
     * @param timestamp   时间戳
     * @param packageName 包名
     * @param unique      序列号
     * @return
     */
    public static Disposable isBind(String packageName, String unique, String timestamp) {
        return isBind(packageName, unique, timestamp, new HDLResponse<BindInfoBean>() {
            @Override
            public void onResponse(BindInfoBean response) {
                handleBind(response, timestamp);
            }

            @Override
            public void onFailure(HDLException e) {
                //网络异常、或者接口报错
                EventBus.getDefault().post(new BindAuthEvent(BindAuthEvent.ON_PLUS_BINDING_ERROR_ACTION));
            }
        });
    }


    /**
     * @param timestamp   时间戳
     * @param packageName 包名
     * @param unique      序列号
     * @return
     */
    public static Disposable isBind(String packageName, String unique, String timestamp, HDLResponse<BindInfoBean> response) {
        return HxHttp.builder()
                .url(HdlCloudApi.IS_BIND_URL)
                .params("packageName", packageName)
                .params("unique", unique)
                .params("qrcodeTimestamp", timestamp)
                .build()
                .executePost()
                .subscribeWith(response);
    }


    /**
     * 处理绑定
     *
     * @param response  返回
     * @param timestamp 时间戳
     */
    private static void handleBind(BindInfoBean response, String timestamp) {
        if (!TextUtils.isEmpty(response.getHomeId())) {

            SPUtils.saveSerializableEntity(SPKey.BIND_HOME_INFO, response);
            SPUtils.put(SPKey.BIND_CODE, QRCode.createBindQRCodeInfo(timestamp));

            HDLCloudConfig.getInstance().setToken(response.getToken());
            HDLCloudConfig.getInstance().setRefreshToken(response.getRefreshToken());

            EventBus.getDefault().post(new BindAuthEvent(BindAuthEvent.ON_PLUS_BINDING_SUCCEED_ACTION));

            getInstance().stopQuery();
        }
    }


}