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

import android.text.TextUtils;

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.home.bean.GatewayInfoBean;
import com.hdl.linkpm.sdk.home.bean.GatewayBindBean;
import com.hdl.linkpm.sdk.home.bean.HomeInfoBean;
import com.hdl.linkpm.sdk.home.bean.logic.LogicInfoBean;
import com.hdl.linkpm.sdk.home.bean.RoomInfoBean;
import com.hdl.linkpm.sdk.home.bean.RoomInfoListBean;
import com.hdl.linkpm.sdk.home.bean.logic.SecurityInfoBean;
import com.hdl.linkpm.sdk.home.callback.IAddRoomListCallBack;
import com.hdl.linkpm.sdk.home.callback.IRoomListCallBack;
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 HDLPMHomeController {
    /**
     * instance
     */
    private volatile static HDLPMHomeController instance;

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

    /**
     * house表的数据没有同步到home表、数据存在两张表里面，需要客户端调接口同步
     *
     * @param homeInfoBean 住宅Info
     * @param callBack
     * @return
     */
    public Disposable synchHouseToHome(HomeInfoBean homeInfoBean, IDefaultCallBack callBack) {
        String requestUrl = HDLCloudHomeApi.getRequestUrl(HDLCloudHomeApi.POST_PROGRAM_HOME_ADD);
        return HxHttp.builder()
                .url(requestUrl)
                .raw(HDLGsonUtils.toJson(homeInfoBean))
                .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,homeInfoBean,e);
                        if (callBack != null) {
                            callBack.onFailure(e);
                        }
                    }
                });

    }

    /***************2.房间管理***************/
    /**
     * 获取住宅下房间表
     *
     * @param homeId   住宅ID
     * @param roomType 房屋类型 FLOOR  ROOM、为空的时候查全部
     * @param pageNo   哪一页
     * @param pageSize 页面大小
     * @param callBack
     * @return
     */
    public Disposable getRoomList(String homeId, String roomType, int pageNo, int pageSize, IRoomListCallBack callBack) {
        String requestUrl = HDLCloudHomeApi.getRequestUrl(HDLCloudHomeApi.POST_ROOM_GET_LIST);
        JsonObject json = new JsonObject();
        json.addProperty("homeId", homeId);
        if (!TextUtils.isEmpty(roomType)) {
            json.addProperty("roomType", roomType);
        }
        json.addProperty("pageNo", pageNo);
        json.addProperty("pageSize", pageSize);
        return HxHttp.builder()
                .url(requestUrl)
                .raw(json.toString())
                .build()
                .post()
                .subscribeWith(new HDLResponse<RoomInfoListBean>() {
                    @Override
                    public void onResponse(RoomInfoListBean 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 roomList 最新的房间列表
     * @param callBack
     * @return
     */
    public Disposable fullAddOrEditRoomList(String homeId, List<RoomInfoBean> roomList, IAddRoomListCallBack callBack) {
        String requestUrl = HDLCloudHomeApi.getRequestUrl(HDLCloudHomeApi.POST_ROOM_FULL_ADD_OR_EDIT);
        JsonObject json = new JsonObject();
        json.addProperty("homeId", homeId);
        json.add("rooms", HDLGsonUtils.toJsonArray(roomList));
        return HxHttp.builder()
                .url(requestUrl)
                .raw(json.toString())
                .build()
                .post()
                .subscribeWith(new HDLResponse<Boolean>() {
                    @Override
                    public void onResponse(Boolean response) {
                        if (callBack != null) {
                            callBack.onSuccess(response);
                        }
                    }

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


    /***************3.网关管理***************/
    /**
     * 绑定网关到住宅
     *
     * @param bean     网关信息
     * @param callBack
     * @return
     */
    public Disposable bindGateway(GatewayBindBean bean, IResponseCallBack<GatewayInfoBean> callBack) {
        String requestUrl = HDLCloudHomeApi.getRequestUrl(HDLCloudHomeApi.POST_GATEWAY_BIND);
        return HxHttp.builder()
                .url(requestUrl)
                .raw(HDLGsonUtils.toJson(bean))
                .build()
                .post()
                .subscribeWith(new HDLResponse<GatewayInfoBean>() {
                    @Override
                    public void onResponse(GatewayInfoBean response) {
                        if (callBack != null) {
                            callBack.onSuccess(response);
                        }
                    }

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

    /**
     * 强制绑定网关
     * 如果绑定网关返回10510 已经被绑定了,则调这个接口强制换绑
     *
     * @param homeId   住宅ID
     * @param mac      网关MAC
     * @param callBack
     * @return
     */
    public Disposable forceBindGateway(String homeId, String mac, IResponseCallBack<GatewayInfoBean> callBack) {
        JsonObject json = new JsonObject();
        json.addProperty("homeId", homeId);
        json.addProperty("mac", mac);
        String requestUrl = HDLCloudHomeApi.getRequestUrl(HDLCloudHomeApi.POST_GATEWAY_FORCE_BIND);
        return HxHttp.builder()
                .url(requestUrl)
                .raw(json.toString())
                .build()
                .post()
                .subscribeWith(new HDLResponse<GatewayInfoBean>() {
                    @Override
                    public void onResponse(GatewayInfoBean 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      网关gatewayId
     * @param callBack
     * @return
     */
    public Disposable unbindGateway(String homeId, String gatewayId, IResponseCallBack<Boolean> callBack) {
        JsonObject json = new JsonObject();
        json.addProperty("homeId", homeId);
        json.addProperty("gatewayId", gatewayId);
        String requestUrl = HDLCloudHomeApi.getRequestUrl(HDLCloudHomeApi.POST_GATEWAY_UNBIND);
        return HxHttp.builder()
                .url(requestUrl)
                .raw(json.toString())
                .build()
                .post()
                .subscribeWith(new HDLResponse<Boolean>() {
                    @Override
                    public void onResponse(Boolean 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 mac   网关mac地址
     * @param callBack
     * @return
     */
    public Disposable getGatewayHomeInfo(String mac, IResponseCallBack<GatewayInfoBean> callBack) {
        JsonObject json = new JsonObject();
        json.addProperty("mac", mac);
        String requestUrl = HDLCloudHomeApi.getRequestUrl(HDLCloudHomeApi.POST_GATEWAY_HOMEINFO);
        return HxHttp.builder()
                .url(requestUrl)
                .raw(json.toString())
                .build()
                .post()
                .subscribeWith(new HDLResponse<GatewayInfoBean>() {
                    @Override
                    public void onResponse(GatewayInfoBean 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 oid      设备oid
     * @param callBack
     * @return
     */
    public Disposable unbindFalseGateway(String homeId, String oid,IResponseCallBack<Boolean> 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<Boolean>() {
                    @Override
                    public void onResponse(Boolean 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 callBack
     * @return
     */
    public Disposable getGatewayList(String homeId, IResponseCallBack<List<GatewayInfoBean>> callBack) {
        JsonObject json = new JsonObject();
        json.addProperty("homeId", homeId);
        String requestUrl = HDLCloudHomeApi.getRequestUrl(HDLCloudHomeApi.POST_GATEWAY_GET_LIST);
        return HxHttp.builder()
                .url(requestUrl)
                .raw(json.toString())
                .build()
                .post()
                .subscribeWith(new HDLResponse<List<GatewayInfoBean>>() {
                    @Override
                    public void onResponse(List<GatewayInfoBean> 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 newMac    新网关mac
     * @param callBack
     * @return
     */
    public Disposable replaceGateway(String homeId, String gatewayId, String newMac, IDefaultCallBack callBack) {
        JsonObject json = new JsonObject();
        json.addProperty("homeId", homeId);
        json.addProperty("gatewayId", gatewayId);
        json.addProperty("newMac", newMac);
        String requestUrl = HDLCloudHomeApi.getRequestUrl(HDLCloudHomeApi.POST_GATEWAY_REPLACE);
        return HxHttp.builder()
                .url(requestUrl)
                .raw(json.toString())
                .build()
                .post()
                .subscribeWith(new HDLResponse<List<String>>() {
                    @Override
                    public void onResponse(List<String> response) {
                        if (callBack != null) {
                            callBack.onSuccess();
                        }
                    }

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


    /***************6.自动化增删改查管理***************/
    /**
     * 全量更新同步自动化、存在不变,不存在新增
     *
     * @param homeId   住宅id
     * @param logics   自动化列表
     * @param callBack
     * @return
     */
    public Disposable fullAddLogicList(String homeId, List<LogicInfoBean> logics, IDefaultCallBack callBack) {
        JsonObject json = new JsonObject();
        json.addProperty("homeId", homeId);
        json.add("logics", HDLGsonUtils.toJsonArray(logics));
        String requestUrl = HDLCloudHomeApi.getRequestUrl(HDLCloudHomeApi.POST_LOGIC_FULL_SYNC);
        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);
                        }
                    }
                });
    }

    /***************7.安防化增删改查管理***************/
    /**
     * 全量更新同步安防、存在不变,不存在新增
     *
     * @param homeId    住宅id
     * @param gatewayId 网关ID
     * @param securitys 安防列表
     * @param callBack
     * @return
     */
    public Disposable fullAddSecurityList(String homeId, String gatewayId, List<SecurityInfoBean> securitys, IDefaultCallBack callBack) {
        JsonObject json = new JsonObject();
        json.addProperty("homeId", homeId);
        json.addProperty("gatewayId", gatewayId);
        json.add("securitys", HDLGsonUtils.toJsonArray(securitys));
        String requestUrl = HDLCloudHomeApi.getRequestUrl(HDLCloudHomeApi.POST_SECURITY_FULL_SYNC);
        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);
                        }
                    }
                });
    }


}