package com.hdl.linkpm.sdk.device.controller;

import android.text.TextUtils;

import com.google.gson.JsonArray;
import com.google.gson.JsonObject;
import com.hdl.hdlhttp.HxHttp;
import com.hdl.linkpm.sdk.core.api.HDLCloudHomeApi;
import com.hdl.linkpm.sdk.core.callback.IDefaultCallBack;
import com.hdl.linkpm.sdk.core.callback.IResponseCallBack;
import com.hdl.linkpm.sdk.core.exception.HDLException;
import com.hdl.linkpm.sdk.core.response.HDLResponse;
import com.hdl.linkpm.sdk.device.bean.CategoryInfo;
import com.hdl.linkpm.sdk.device.bean.DeviceOidInfoBean;
import com.hdl.linkpm.sdk.device.bean.FunctionActionBean;
import com.hdl.linkpm.sdk.device.bean.FunctionInfoBaseBean;
import com.hdl.linkpm.sdk.device.bean.FunctionInfoListBean;
import com.hdl.linkpm.sdk.device.bean.GatewayCloudBean;
import com.hdl.linkpm.sdk.device.bean.ProductInfo;
import com.hdl.linkpm.sdk.home.bean.QuestionListInfo;
import com.hdl.linkpm.sdk.utils.HDLExceptionSubmitUtils;
import com.hdl.linkpm.sdk.utils.HDLGsonUtils;

import java.util.List;

import io.reactivex.rxjava3.disposables.Disposable;

/**
 * Created by jlchen on 12/3/21.
 * 设备相关的网络请求
 */
public class HDLPMDeviceController {
    /**
     * instance
     */
    private volatile static HDLPMDeviceController instance;

    /**
     * getInstance
     *
     * @return HDLDeviceController
     */
    public static synchronized HDLPMDeviceController getInstance() {
        if (instance == null) {
            synchronized (HDLPMDeviceController.class) {
                if (instance == null) {
                    instance = new HDLPMDeviceController();
                }
            }
        }
        return instance;
    }

    /***************4.设备、功能增删改查管理***************/
    /**
     * 设备基本信息列表(oid)全量添加
     *
     * @param homeId        住宅id
     * @param oidDeviceList 最新的设备Oid列表
     * @param callBack
     * @return
     */
    public Disposable fullAddDeviceOidList(String homeId, List<DeviceOidInfoBean> oidDeviceList, IDefaultCallBack callBack) {
        JsonObject json = new JsonObject();
        json.addProperty("homeId", homeId);
        json.add("devices", HDLGsonUtils.toJsonArray(oidDeviceList));
        String requestUrl = HDLCloudHomeApi.getRequestUrl(HDLCloudHomeApi.POST_DEVICE_OID_LIST_FULL_ADD);
        return HxHttp.builder()
                .url(requestUrl)
                .raw(json.toString())
                .build()
                .post()
                .subscribeWith(new HDLResponse<String>() {
                    @Override
                    public void onResponse(String response) {
                        if (callBack != null) {
                            callBack.onSuccess();
                        }
                    }

                    @Override
                    public void onFailure(HDLException e) {
                        HDLExceptionSubmitUtils.submit(requestUrl,json,e);
                        if (callBack != null) {
                            callBack.onFailure(e);
                        }
                    }
                });
    }

    /**
     * 设备基本信息列表(oid)获取
     *
     * @param homeId   住宅id
     * @param callBack
     * @return
     */
    public Disposable getDeviceOidList(String homeId, IResponseCallBack<List<DeviceOidInfoBean>> callBack) {
        JsonObject json = new JsonObject();
        json.addProperty("homeId", homeId);
        String requestUrl = HDLCloudHomeApi.getRequestUrl(HDLCloudHomeApi.POST_DEVICE_OID_LIST_GET);
        return HxHttp.builder()
                .url(requestUrl)
                .raw(json.toString())
                .build()
                .post()
                .subscribeWith(new HDLResponse<List<DeviceOidInfoBean>>() {
                    @Override
                    public void onResponse(List<DeviceOidInfoBean> response) {
                        if (callBack != null) {
                            callBack.onSuccess(response);
                        }
                    }

                    @Override
                    public void onFailure(HDLException e) {
                        HDLExceptionSubmitUtils.submit(requestUrl,json,e);
                        if (callBack != null) {
                            callBack.onFailure(e);
                        }
                    }
                });
    }

    /**
     * 设备基本信息(oid)删除
     * 删除设备或者从网关等oid
     *
     * @param homeId   住宅id
     * @param oid      设备的oid
     * @param callBack
     * @return
     */
    public Disposable removeDeviceOid(String homeId, String oid, IDefaultCallBack callBack) {
        JsonObject json = new JsonObject();
        json.addProperty("homeId", homeId);
        json.addProperty("oid", oid);
        String requestUrl = HDLCloudHomeApi.getRequestUrl(HDLCloudHomeApi.POST_DEVICE_OID_REMOVE);
        return HxHttp.builder()
                .url(requestUrl)
                .raw(json.toString())
                .build()
                .post()
                .subscribeWith(new HDLResponse<String>() {
                    @Override
                    public void onResponse(String response) {
                        if (callBack != null) {
                            callBack.onSuccess();
                        }
                    }

                    @Override
                    public void onFailure(HDLException e) {
                        HDLExceptionSubmitUtils.submit(requestUrl,json,e);
                        if (callBack != null) {
                            callBack.onFailure(e);
                        }
                    }
                });
    }


    /**
     * 设备（功能）全量更新
     *
     * @param homeId       住宅id
     * @param gatewayId    网关Id
     * @param functionList 最新的功能列表
     * @param callBack
     * @return
     */
    public Disposable fullAddFunctionList(String homeId, String gatewayId, List<FunctionInfoBaseBean> functionList, IDefaultCallBack callBack) {
        JsonObject json = new JsonObject();
        json.addProperty("homeId", homeId);
        json.addProperty("gatewayId", gatewayId);
        json.add("devices", HDLGsonUtils.toJsonArray(functionList));
        String requestUrl = HDLCloudHomeApi.getRequestUrl(HDLCloudHomeApi.POST_FUNCTION_LIST_FULL_ADD);
        return HxHttp.builder()
                .url(requestUrl)
                .raw(json.toString())
                .build()
                .post()
                .subscribeWith(new HDLResponse<String>() {
                    @Override
                    public void onResponse(String response) {
                        if (callBack != null) {
                            callBack.onSuccess();
                        }
                    }

                    @Override
                    public void onFailure(HDLException e) {
                        HDLExceptionSubmitUtils.submit(requestUrl,json,e);
                        if (callBack != null) {
                            callBack.onFailure(e);
                        }
                    }
                });
    }

    /**
     * 获取产品分类树
     *
     * @param callBack
     * @return
     */
    public Disposable getCategoryList(IResponseCallBack<List<CategoryInfo>> callBack) {
        JsonObject json = new JsonObject();
        String requestUrl = HDLCloudHomeApi.getRequestUrl(HDLCloudHomeApi.POST_CATEGORY_LIST_ALLTREE);
        return HxHttp.builder()
                .url(requestUrl)
                .raw(json.toString())
                .build()
                .post()
                .subscribeWith(new HDLResponse<List<CategoryInfo>>() {
                    @Override
                    public void onResponse(List<CategoryInfo> response) {
                        if (callBack != null) {
                            callBack.onSuccess(response);
                        }
                    }

                    @Override
                    public void onFailure(HDLException e) {
                        HDLExceptionSubmitUtils.submit(requestUrl,json,e);
                        if (callBack != null) {
                            callBack.onFailure(e);
                        }
                    }
                });
    }

    /**
     * 获取网关列表
     *
     * @param callBack
     * @return
     */
    public Disposable getGatewayList(String homeId, IResponseCallBack<List<GatewayCloudBean>> callBack) {
        JsonObject json = new JsonObject();
        json.addProperty("homeId", homeId);
        String requestUrl = HDLCloudHomeApi.getRequestUrl(HDLCloudHomeApi.POST_GATEWAY_LIST);
        return HxHttp.builder()
                .url(requestUrl)
                .raw(json.toString())
                .build()
                .post()
                .subscribeWith(new HDLResponse<List<GatewayCloudBean>>() {
                    @Override
                    public void onResponse(List<GatewayCloudBean> response) {
                        if (callBack != null) {
                            callBack.onSuccess(response);
                        }
                    }

                    @Override
                    public void onFailure(HDLException e) {
                        HDLExceptionSubmitUtils.submit(requestUrl,json,e);
                        if (callBack != null) {
                            callBack.onFailure(e);
                        }
                    }
                });
    }


    /**
     * 获取类目下设备列表
     *
     * @param callBack
     * @return
     */
    public Disposable getCategoryListByName(String productName, IResponseCallBack<List<ProductInfo>> callBack) {
        JsonObject json = new JsonObject();
        json.addProperty("productName", productName);
        String requestUrl = HDLCloudHomeApi.getRequestUrl(HDLCloudHomeApi.POST_CATEGORY_DEVICE_LIST);
        return HxHttp.builder()
                .url(requestUrl)
                .raw(json.toString())
                .build()
                .post()
                .subscribeWith(new HDLResponse<List<ProductInfo>>() {
                    @Override
                    public void onResponse(List<ProductInfo> response) {
                        if (callBack != null) {
                            callBack.onSuccess(response);
                        }
                    }

                    @Override
                    public void onFailure(HDLException e) {
                        HDLExceptionSubmitUtils.submit(requestUrl,json,e);
                        if (callBack != null) {
                            callBack.onFailure(e);
                        }
                    }
                });
    }

    /**
     * 获取类目下设备列表
     *
     * @param callBack
     * @return
     */
    public Disposable getCategoryListByCode(String categorySecondCode, IResponseCallBack<List<ProductInfo>> callBack) {
        JsonObject json = new JsonObject();
        json.addProperty("categorySecondCode", categorySecondCode);
        String requestUrl = HDLCloudHomeApi.getRequestUrl(HDLCloudHomeApi.POST_CATEGORY_DEVICE_LIST);
        return HxHttp.builder()
                .url(requestUrl)
                .raw(json.toString())
                .build()
                .post()
                .subscribeWith(new HDLResponse<List<ProductInfo>>() {
                    @Override
                    public void onResponse(List<ProductInfo> response) {
                        if (callBack != null) {
                            callBack.onSuccess(response);
                        }
                    }

                    @Override
                    public void onFailure(HDLException e) {
                        HDLExceptionSubmitUtils.submit(requestUrl,json,e);
                        if (callBack != null) {
                            callBack.onFailure(e);
                        }
                    }
                });
    }

    /**
     * 设备（功能）列表获取
     *
     * @param homeId    住宅id
     * @param gatewayId 网关Id
     * @param callBack
     * @return
     */
    public Disposable getFunctionList(String homeId, String gatewayId, IResponseCallBack<FunctionInfoListBean> callBack) {
        JsonObject json = new JsonObject();
        json.addProperty("homeId", homeId);
        json.addProperty("gatewayId", gatewayId);
        String requestUrl = HDLCloudHomeApi.getRequestUrl(HDLCloudHomeApi.POST_FUNCTION_LIST_GET);
        return HxHttp.builder()
                .url(requestUrl)
                .raw(json.toString())
                .build()
                .post()
                .subscribeWith(new HDLResponse<FunctionInfoListBean>() {
                    @Override
                    public void onResponse(FunctionInfoListBean response) {
                        if (callBack != null) {
                            callBack.onSuccess(response);
                        }
                    }

                    @Override
                    public void onFailure(HDLException e) {
                        HDLExceptionSubmitUtils.submit(requestUrl,json,e);
                        if (callBack != null) {
                            callBack.onFailure(e);
                        }
                    }
                });
    }

    /**
     * 设备（功能）删除，支持批量
     *
     * @param homeId    住宅id
     * @param gatewayId 网关Id
     * @param devices   云端设备ID集合
     * @param callBack
     * @return
     */
    public Disposable batchDeleteFunctionList(String homeId, String gatewayId, List<String> devices, IDefaultCallBack callBack) {
        JsonObject json = new JsonObject();
        json.addProperty("homeId", homeId);
        json.addProperty("gatewayId", gatewayId);
        json.add("devices", HDLGsonUtils.toJsonArray(devices));
        String requestUrl = HDLCloudHomeApi.getRequestUrl(HDLCloudHomeApi.POST_FUNCTION_BATCH_DELETE);
        return HxHttp.builder()
                .url(requestUrl)
                .raw(json.toString())
                .build()
                .post()
                .subscribeWith(new HDLResponse<String>() {
                    @Override
                    public void onResponse(String response) {
                        if (callBack != null) {
                            callBack.onSuccess();
                        }
                    }

                    @Override
                    public void onFailure(HDLException e) {
                        HDLExceptionSubmitUtils.submit(requestUrl,json,e);
                        if (callBack != null) {
                            callBack.onFailure(e);
                        }
                    }
                });
    }

    /**
     * 控制设备
     *
     * @param homeId    住宅id
     * @param gatewayId 网关Id
     * @param actions   动作
     * @param callBack
     * @return
     */
    public Disposable controlFunction(String homeId, String gatewayId, List<FunctionActionBean> actions, IDefaultCallBack callBack) {
        JsonObject json = new JsonObject();
        json.addProperty("homeId", homeId);
        json.addProperty("gatewayId", gatewayId);
        json.add("actions", HDLGsonUtils.toJsonArray(actions));
        String requestUrl = HDLCloudHomeApi.getRequestUrl(HDLCloudHomeApi.POST_FUNCTION_CONTROL);
        return HxHttp.builder()
                .url(requestUrl)
                .raw(json.toString())
                .build()
                .post()
                .subscribeWith(new HDLResponse<String>() {
                    @Override
                    public void onResponse(String response) {
                        if (callBack != null) {
                            callBack.onSuccess();
                        }
                    }

                    @Override
                    public void onFailure(HDLException e) {
                        HDLExceptionSubmitUtils.submit(requestUrl,json,e);
                        if (callBack != null) {
                            callBack.onFailure(e);
                        }
                    }
                });
    }


    /**
     * 获取常见问题列表
     *
     * @param languageType 0:中文 1:英文,可用值:CHINESE,ENGLISH
     * @param pageNo       当前页
     * @param pageSize     页面大小
     * @param question     问题
     * @param callBack
     * @return
     */
    public Disposable getQuestionList(String languageType, String question, String pageNo, String pageSize, IResponseCallBack<QuestionListInfo> callBack) {
        JsonObject json = new JsonObject();
        json.addProperty("zoneType", languageType);
        json.addProperty("question", question);
        json.addProperty("pageNo", pageNo);
        json.addProperty("pageSize", pageSize);
        json.addProperty("softwareType", "DEBUGGING_TREASURE");
        String requestUrl = HDLCloudHomeApi.getRequestUrl(HDLCloudHomeApi.POST_QUESTION_GET_LIST);
        return HxHttp.builder()
                .url(requestUrl)
                .raw(json.toString())
                .build()
                .post()
                .subscribeWith(new HDLResponse<QuestionListInfo>() {
                    @Override
                    public void onResponse(QuestionListInfo response) {
                        if (callBack != null) {
                            callBack.onSuccess(response);
                        }
                    }

                    @Override
                    public void onFailure(HDLException e) {
                        HDLExceptionSubmitUtils.submit(requestUrl,json,e);
                        if (callBack != null) {
                            callBack.onFailure(e);
                        }
                    }
                });
    }

    /**
     * 绑定毫米波设备
     *
     * @param homeId   住宅Id
     * @param name     设备名称
     * @param apk      产品spk
     * @param oid      设备oid
     * @param mac      设备mac
     * @param sid      设备sid
     * @param uidList     房间uid列表
     * @param callBack 回调
     * @return -
     */
    public Disposable bindMillimeterDevice(String homeId, String name, String apk, String oid, String mac, String sid, List<String> uidList, IResponseCallBack<String> callBack) {
        JsonObject json = new JsonObject();
        json.addProperty("homeId", homeId);
        json.addProperty("name", name);
        json.addProperty("spk", apk);
        json.addProperty("oid", oid);
        json.addProperty("mac", mac);
        json.addProperty("sid", sid);
        if(uidList!=null) {
            json.add("uids", HDLGsonUtils.toJsonArray(uidList));
        }
        String requestUrl = HDLCloudHomeApi.getRequestUrl(HDLCloudHomeApi.POST_DEVICE_INDEPENDENT_REGISTER);
        return HxHttp.builder()
                .url(requestUrl)
                .raw(json.toString())
                .build()
                .post()
                .subscribeWith(new HDLResponse<String>() {
                    @Override
                    public void onResponse(String str) {
                        if (callBack != null) {
                            callBack.onSuccess(str);
                        }
                    }

                    @Override
                    public void onFailure(HDLException e) {
                        HDLExceptionSubmitUtils.submit(requestUrl,json,e);
                        if (callBack != null) {
                            callBack.onFailure(e);
                        }
                    }
                });
    }

    /**
     * 解绑毫米波设备
     *
     * @param homeId   住宅Id
     * @param spk      产品spk
     * @param mac      设备mac
     * @param callBack 回调
     * @return -
     */
    public Disposable unBindMillimeterDevice(String homeId, String spk, String mac, IResponseCallBack<String> callBack) {
        JsonObject json = new JsonObject();
        json.addProperty("homeId", homeId);
        json.addProperty("spk", spk);
        json.addProperty("mac", mac);
        String requestUrl = HDLCloudHomeApi.getRequestUrl(HDLCloudHomeApi.POST_DEVICE_INDEPENDENT_UNBIND);
        return HxHttp.builder()
                .url(requestUrl)
                .raw(json.toString())
                .build()
                .post()
                .subscribeWith(new HDLResponse<String>() {
                    @Override
                    public void onResponse(String str) {
                        if (callBack != null) {
                            callBack.onSuccess(str);
                        }
                    }

                    @Override
                    public void onFailure(HDLException e) {
                        HDLExceptionSubmitUtils.submit(requestUrl,json,e);
                        if (callBack != null) {
                            callBack.onFailure(e);
                        }
                    }
                });
    }

    /**
     * 获取link功能列表
     *
     * @param homeId   住宅Id
     * @param spk      spk(指定获取单个功能)
     * @param callBack 回调
     * @return -
     */
    public Disposable getDeviceList(String homeId, String spk, IResponseCallBack<FunctionInfoListBean> callBack) {
        JsonObject json = new JsonObject();
        json.addProperty("homeId", homeId);
        if(!TextUtils.isEmpty(spk)) {
            json.addProperty("spk", spk);
        }
        String requestUrl = HDLCloudHomeApi.getRequestUrl(HDLCloudHomeApi.POST_FUNCTION_LIST_GET);
        return HxHttp.builder()
                .url(requestUrl)
                .raw(json.toString())
                .build()
                .post()
                .subscribeWith(new HDLResponse<FunctionInfoListBean>() {
                    @Override
                    public void onResponse(FunctionInfoListBean functionInfoListBean) {
                        if (callBack != null) {
                            callBack.onSuccess(functionInfoListBean);
                        }
                    }

                    @Override
                    public void onFailure(HDLException e) {
                        HDLExceptionSubmitUtils.submit(requestUrl,json,e);
                        if (callBack != null) {
                            callBack.onFailure(e);
                        }
                    }
                });
    }

    /**
     * 获取毫米波(获取设备远程通讯信息)
     *
     * @param homeId   住宅Id
     * @param spk      spk
     * @param mac      设备mac
     * @param callBack 回调
     * @return -
     */
    public Disposable getDeviceRemoteInfo(String homeId, String spk,String mac, IResponseCallBack<String> callBack) {
        JsonObject json = new JsonObject();
        json.addProperty("homeId", homeId);
        json.addProperty("spk", spk);
        json.addProperty("mac", mac);
        String requestUrl = HDLCloudHomeApi.getRequestUrl(HDLCloudHomeApi.POST_DEVICE_REMOTEINFO_GET);
        return HxHttp.builder()
                .url(requestUrl)
                .raw(json.toString())
                .build()
                .post()
                .subscribeWith(new HDLResponse<String>() {
                    @Override
                    public void onResponse(String str) {
                        if (callBack != null) {
                            callBack.onSuccess(str);
                        }
                    }

                    @Override
                    public void onFailure(HDLException e) {
                        HDLExceptionSubmitUtils.submit(requestUrl,json,e);
                        if (callBack != null) {
                            callBack.onFailure(e);
                        }
                    }
                });
    }


    /**
     * 设备（功能）修改备注
     *
     * @param homeId    住宅id
     * @param deviceId 设备Id
     * @param name 设备名称
     * @return  callBack
     */
    public Disposable rename(String homeId, long deviceId,String name, IResponseCallBack<String> callBack) {
        JsonObject json = new JsonObject();
        json.addProperty("homeId", homeId);
        json.addProperty("deviceId", deviceId);
        json.addProperty("name", name);
        String requestUrl = HDLCloudHomeApi.getRequestUrl(HDLCloudHomeApi.POST_DEVICE_RENAME);
        return HxHttp.builder()
                .url(requestUrl)
                .raw(json.toString())
                .build()
                .post()
                .subscribeWith(new HDLResponse<String>() {
                    @Override
                    public void onResponse(String string) {
                        if (callBack != null) {
                            callBack.onSuccess(string);
                        }
                    }

                    @Override
                    public void onFailure(HDLException e) {
                        HDLExceptionSubmitUtils.submit(requestUrl,json,e);
                        if (callBack != null) {
                            callBack.onFailure(e);
                        }
                    }
                });
    }


    /**
     * 设备（功能）绑定房间
     *
     * @param homeId    住宅id
     * @param deviceIds 设备id列表
     * @param roomIds 房间id列表
     * @return  callBack
     */
    public Disposable bindRoom(String homeId, List<String> deviceIds,List<String> roomIds, IResponseCallBack<String> callBack) {
        JsonObject json = new JsonObject();
        JsonArray deviceIdsArray=new JsonArray();
        JsonArray roomIdsArray=new JsonArray();
        for (int i = 0; i < deviceIds.size(); i++) {
            deviceIdsArray.add(deviceIdsArray.get(i));
        }
        for (int i = 0; i < roomIds.size(); i++) {
            roomIdsArray.add(roomIdsArray.get(i));
        }
        json.addProperty("homeId", homeId);
        json.add("deviceIds", deviceIdsArray);
        json.add("roomIds", roomIdsArray);
        String requestUrl = HDLCloudHomeApi.getRequestUrl(HDLCloudHomeApi.POST_DEVICE_BINDROOM);
        return HxHttp.builder()
                .url(requestUrl)
                .raw(json.toString())
                .build()
                .post()
                .subscribeWith(new HDLResponse<String>() {
                    @Override
                    public void onResponse(String string) {
                        if (callBack != null) {
                            callBack.onSuccess(string);
                        }
                    }

                    @Override
                    public void onFailure(HDLException e) {
                        HDLExceptionSubmitUtils.submit(requestUrl,json,e);
                        if (callBack != null) {
                            callBack.onFailure(e);
                        }
                    }
                });
    }

}