package com.hdl.sdk.connect.cloud.broadcast;

import android.text.TextUtils;
import android.util.Log;

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.config.HDLCloudConfig;
import com.hdl.sdk.sourceos.bind.BindHomeService;
import com.hdl.sdk.sourceos.qrcode.QRCode;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;

/**
 * Created by Tong on 2022/2/12.
 * token失效处理
 */
public class HDLCloudBroadcast extends CloudBroadcast {

    private final ExecutorService service = Executors.newSingleThreadExecutor();

    private volatile Future<?> mBindTokenTask;

    private static final String TAG = HDLCloudBroadcast.class.getSimpleName();

    /**
     * 登录失效了
     */
    @Override
    public void onLogOut() {
        super.onLogOut();
        refreshBindingToken();
    }


    /**
     * 刷新绑定Token
     */
    public void refreshBindingToken() {
        Log.e(TAG, "refreshBindingToken");
        if (mBindTokenTask != null) {
            try {
                mBindTokenTask.cancel(true);
            } catch (Throwable e) {
                e.printStackTrace();
            }
        }
        final String code = QRCode.getBindQRCode();
        if (!TextUtils.isEmpty(code)) {
            String[] split = code.split("_");
            if (split.length == 3) {
                try {
                    mBindTokenTask = service.submit(new Runnable() {
                        @Override
                        public void run() {
                            try {
                                try {
                                    //防止频繁休眠10秒
                                    Thread.sleep(10 * 1000);
                                } catch (Exception e) {
                                    e.printStackTrace();
                                }


                                BindHomeService.isBind(split[0], split[1], split[2], new HDLResponse<BindInfoBean>() {
                                    @Override
                                    public void onResponse(BindInfoBean response) {
                                        if (response != null) {
                                            HDLCloudConfig.getInstance().setToken(response.getToken());
                                            HDLCloudConfig.getInstance().setRefreshToken(response.getRefreshToken());
                                        }
                                        Log.e(TAG, "refreshBindingToken---> succeed");
                                    }

                                    @Override
                                    public void onFailure(HDLException e) {
                                        Log.e(TAG, "refreshBindingToken error---> " + e);
                                        /*if (e instanceof ApiException) {
                                            if (e.getCode() != CloudCode.NO_TOKEN) {

                                            }

                                        }*/
                                    }
                                });

                            } catch (Exception e) {
                                e.printStackTrace();
                            }
                        }
                    });
                } catch (Exception e) {
                    e.printStackTrace();
                }


            }
        }


    }

    @Override
    public void onOtherError(int code, String message) {
        super.onOtherError(code, message);

        Log.d(TAG, "onOtherError: code" + code + "," + message);

        if (code == 125102 || code == 10401) {
            //思必驰失效了， 住宅和当前用户不匹配
            Log.d(TAG, "onOtherError: 思必驰失效了");

            refreshBindingToken();
        }
    }
}