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

import com.google.gson.JsonObject;
import com.hdl.hdlhttp.HxHttp;
import com.hdl.linkpm.sdk.HDLLinkPMSdk;
import com.hdl.linkpm.sdk.core.api.HDLCloudUserApi;
import com.hdl.linkpm.sdk.core.callback.IDefaultCallBack;
import com.hdl.linkpm.sdk.core.callback.IDefaultStrCallBack;
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.user.bean.HDLLoginBean;
import com.hdl.linkpm.sdk.user.bean.HDLMemberInfoBean;
import com.hdl.linkpm.sdk.user.bean.HDLUserRegionBean;
import com.hdl.linkpm.sdk.user.bean.ImageSubmitInfo;
import com.hdl.linkpm.sdk.user.bean.MqttInfo;
import com.hdl.linkpm.sdk.user.bean.NewVersionBean;
import com.hdl.linkpm.sdk.user.bean.UploadImageRequest;
import com.hdl.linkpm.sdk.user.callback.ILoginCallBack;
import com.hdl.linkpm.sdk.user.callback.IMemberInfoBack;
import com.hdl.linkpm.sdk.user.callback.IRegionByAccountCallBack;
import com.hdl.linkpm.sdk.utils.HDLExceptionSubmitUtils;
import com.hdl.linkpm.sdk.utils.HDLGsonUtils;

import java.io.File;

import io.reactivex.rxjava3.disposables.Disposable;

/**
 * Created by jlchen on 12/3/21.
 * B端用户相关的网络请求
 */
public class HDLPMUserController {

    /**
     * instance
     */
    private volatile static HDLPMUserController instance;

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

    /**
     * 获取账号所在区域
     *
     * @param account
     * @param callBack
     * @return https://nearest.hdlcontrol.com/smart-footstone/region/regionByUserAccount
     */
    public Disposable regionByAccount(String account, IRegionByAccountCallBack callBack) {
        String requestUrl = HDLLinkPMSdk.getInitUrl() + HDLCloudUserApi.POST_RegionByAccount;
        return HxHttp.builder()
                .url(requestUrl)
                .params("account", account)
                .build()
                .post()
                .subscribeWith(new HDLResponse<HDLUserRegionBean>() {
                    @Override
                    public void onResponse(HDLUserRegionBean response) {
                        if (callBack != null) {
                            callBack.onSuccess(response);
                        }
                    }

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

    }

    /**
     * 登录
     * 通过账号和密码
     *
     * @param isBooleanB true=B,false=C
     * @param account    手机或者邮箱
     * @param loginPwd   密码
     * @param callBack   回调
     * @return -
     */
    public Disposable loginByPassword(boolean isBooleanB, String account, String loginPwd, ILoginCallBack callBack) {
        String requestUrl = HDLCloudUserApi.getRequestUrl(HDLCloudUserApi.POST_LOGIN);
        if (!isBooleanB) {
            requestUrl = HDLCloudUserApi.getRequestUrl(HDLCloudUserApi.C_POST_LOGIN);
        }
        JsonObject json = new JsonObject();
        json.addProperty("account", account);
        json.addProperty("loginPwd", loginPwd);
//        json.addProperty("platform", "APP");
        json.addProperty("grantType", "password");

        String finalRequestUrl = requestUrl;
        return HxHttp.builder()
                .url(requestUrl)
                .raw(json.toString())
                .build()
                .post()
                .subscribeWith(new HDLResponse<HDLLoginBean>() {
                    @Override
                    public void onResponse(HDLLoginBean response) {
                        if (callBack != null) {
                            callBack.onSuccess(response);
                        }
                    }

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

    }

    /**
     * 登录
     * 通过验证码
     *
     * @param account  手机或者邮箱
     * @param vCode    验证码
     * @param callBack 回调
     * @return
     */
    public Disposable loginByCode(String account, String vCode, ILoginCallBack callBack) {
        String requestUrl = HDLCloudUserApi.getRequestUrl(HDLCloudUserApi.POST_LOGIN);
        JsonObject json = new JsonObject();
        json.addProperty("account", account);
        json.addProperty("verifyCode", vCode);
//        json.addProperty("platform", "APP");
        json.addProperty("grantType", "verify");
        return HxHttp.builder()
                .url(requestUrl)
                .raw(json.toString())
                .build()
                .post()
                .subscribeWith(new HDLResponse<HDLLoginBean>() {
                    @Override
                    public void onResponse(HDLLoginBean response) {
                        if (callBack != null) {
                            callBack.onSuccess(response);
                        }
                    }

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

    }

    /**
     * 通用 发送验证码方法
     * LanguageTypeEnum CHINESE,ENGLISH
     *
     * @param verifyType    1:注册 2：找回密码 3：绑定 4:验证码登陆 5:敏感数据
     * @param account       邮箱或者手机号
     * @param isPhone       是否手机
     * @param phoneZoneCode 手机国家区号
     * @param languageType  语言
     * @param callBack
     * @return
     */
    public Disposable verificationCodeSend(int verifyType, String account, Boolean isPhone, String phoneZoneCode, String languageType, IDefaultCallBack callBack) {
        String requestUrl = HDLCloudUserApi.getRequestUrl(HDLCloudUserApi.POST_VERIFICATION_CODE_SEND);
        JsonObject json = new JsonObject();
        json.addProperty("verifyType", verifyType);
        json.addProperty("languageType", languageType);
        json.addProperty("expireSecond", 300);////验证码过期时间（秒）,默认5分钟
        //是否手机
        if (isPhone) {
            json.addProperty("phone", account);
            json.addProperty("phonePrefix", phoneZoneCode);
        } else {
            json.addProperty("mail", account);
        }
        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 account  邮箱或者手机号
     * @param password 新密码
     * @param vCode    验证码
     * @param isPhone  是否手机
     * @param callBack 回调
     */
    public Disposable forgetPassword(String account, String password, String vCode, Boolean isPhone, IDefaultCallBack callBack) {
        String requestUrl = HDLCloudUserApi.getRequestUrl(HDLCloudUserApi.POST_FORGET_PROGRAM_PWD);
        JsonObject json = new JsonObject();
        json.addProperty("loginPwd", password);
        json.addProperty("verifyCode", vCode);
        //是否手机
        if (isPhone) {
            json.addProperty("userPhone", account);
        } else {
            json.addProperty("userEmail", account);
        }
        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 userId      当前用户ID
     * @param loginOldPwd 老密码
     * @param loginPwd    新密码
     * @param callBack    回调
     */
    public Disposable updateProgramPassword(String userId, String loginOldPwd, String loginPwd, IDefaultCallBack callBack) {
        String requestUrl = HDLCloudUserApi.getRequestUrl(HDLCloudUserApi.POST_UPDATE_PROGRAM_PASSWORD);
        JsonObject json = new JsonObject();
        json.addProperty("userId", userId);
        json.addProperty("loginOldPwd", loginOldPwd);
        json.addProperty("loginPwd", loginPwd);
        json.addProperty("confirmLoginPwd", loginPwd);
        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
     */
    public Disposable getMemberInfo(IMemberInfoBack callBack) {
        String requestUrl = HDLCloudUserApi.getRequestUrl(HDLCloudUserApi.POST_GET_MEMBER_INFO);
        return HxHttp.builder()
                .url(requestUrl)
                .build()
                .post()
                .subscribeWith(new HDLResponse<HDLMemberInfoBean>() {
                    @Override
                    public void onResponse(HDLMemberInfoBean response) {
                        if (callBack != null) {
                            callBack.onSuccess(response);
                        }
                    }

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

    /**
     * 更新个人信息
     * memberHeadIcon、memberName、memberBirthday、languageType、memberSex
     *
     * @param callBack
     */
    public Disposable updateMemberInfo(JsonObject updateInfo, IDefaultCallBack callBack) {
        String requestUrl = HDLCloudUserApi.getRequestUrl(HDLCloudUserApi.POST_UPDATE_MEMBER_INFO);
        return HxHttp.builder()
                .url(requestUrl)
                .raw(updateInfo.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, updateInfo, e);
                        if (callBack != null) {
                            callBack.onFailure(e);
                        }
                    }
                });
    }

    /**
     * 获取用户头像路径
     *
     * @param memberHeadIconKey 用户头像imageKey
     * @param callBack
     */
    public Disposable getHeadImageUrl(String memberHeadIconKey, IDefaultStrCallBack callBack) {
        String requestUrl = HDLCloudUserApi.getRequestUrl(HDLCloudUserApi.POST_GET_IMAGE_URL);
        return HxHttp.builder()
                .url(requestUrl)
                .params("imageKey", memberHeadIconKey)
                .build()
                .post()
                .subscribeWith(new HDLResponse<String>() {
                    @Override
                    public void onResponse(String response) {
                        if (callBack != null) {
                            callBack.onSuccess(response);
                        }
                    }

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

    /**
     * 上传用户头像
     *
     * @param userId     用户id
     * @param imageBytes 头像图片
     * @param callBack
     * @return
     */
    public Disposable uploadUserHeadImage(String userId, byte[] imageBytes, IDefaultStrCallBack callBack) {
        UploadImageRequest uploadImageRequest = new UploadImageRequest();
        uploadImageRequest.setPrefix("Icon" + System.currentTimeMillis());
        uploadImageRequest.setUid(userId);
        uploadImageRequest.setFileName("HeadImage.png");
        uploadImageRequest.setContent(imageBytes);

        String requestUrl = HDLCloudUserApi.getRequestUrl(HDLCloudUserApi.POST_UPLOAD_IMAGE);
        return HxHttp.builder()
                .url(requestUrl)
                .raw(HDLGsonUtils.toJson(uploadImageRequest))
                .build()
                .post()
                .subscribeWith(new HDLResponse<String>() {
                    @Override
                    public void onResponse(String response) {
                        if (callBack != null) {
                            callBack.onSuccess(response);
                        }
                    }

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

    /**
     * 上传用户头像(新)
     *
     * @param file     图片
     * @param callBack
     * @return
     */
    public Disposable uplfadUserHeadImage(File file, IResponseCallBack<ImageSubmitInfo> callBack) {
        String requestUrl = HDLCloudUserApi.getRequestUrl(HDLCloudUserApi.POST_UPLOAD_IMAGE_NEW);
        return HxHttp.builder()
                .url(requestUrl)
                .file(file)
                .build()
                .upload()
                .subscribeWith(new HDLResponse<ImageSubmitInfo>() {
                    @Override
                    public void onResponse(ImageSubmitInfo response) {
                        if (callBack != null) {
                            callBack.onSuccess(response);
                        }
                    }

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

//    /**
//     * 版本检测更新
//     *
//     * @param appName  app名称
//     * @param version  版本号
//     * @param callBack 如果onSuccess 回调的bean为空，代表当前版本已经是最新版本，没有新版本
//     * @return
//     */
//    public Disposable checkAppVersion(String appName, String version, IResponseCallBack<NewVersionBean> callBack) {
//        JsonObject json = new JsonObject();
//        json.addProperty("appName", appName);
//        json.addProperty("version", version);
//        json.addProperty("version", version);
//        String requestUrl = HDLLinkPMSdk.getRegionUrl() + HDLCloudUserApi.POST_APP_APPVERSION_CHECK;
//        return HxHttp.builder()
//                .url(requestUrl)
//                .raw(json.toString())
//                .build()
//                .post()
//                .subscribeWith(new HDLResponse<NewVersionBean>() {
//                    @Override
//                    public void onResponse(NewVersionBean response) {
//                        if (callBack != null) {
//                            callBack.onSuccess(response);
//                        }
//                    }
//
//                    @Override
//                    public void onFailure(HDLException e) {
//                        if (callBack != null) {
//                            callBack.onFailure(e);
//                        }
//                    }
//                });
//    }

    /**
     * 版本检测更新
     * 支持Android、iOS、wgt检测
     *
     * @param appCode       app编码
     * @param version       版本号
     * @param releaseSystem 发布系统，IOS、Android, wgt
     * @param callBack      如果onSuccess 回调的bean为空，代表当前版本已经是最新版本，没有新版本
     * @return
     */
    public Disposable checkAppVersion(String appCode, String version, String releaseSystem, IResponseCallBack<NewVersionBean> callBack) {
        JsonObject json = new JsonObject();
        json.addProperty("appCode", appCode);
        json.addProperty("version", version);
        json.addProperty("releaseSystem", releaseSystem);
        String requestUrl = HDLCloudUserApi.getRequestUrl(HDLCloudUserApi.POST_APP_APPVERSION_CHECK);
        return HxHttp.builder()
                .url(requestUrl)
                .raw(json.toString())
                .build()
                .post()
                .subscribeWith(new HDLResponse<NewVersionBean>() {
                    @Override
                    public void onResponse(NewVersionBean response) {
                        if (callBack != null) {
                            callBack.onSuccess(response);
                        }
                    }

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

    /**
     * 获取mqtt信息
     *
     * @return
     */
    public static Disposable getMqttInfo(String attachClientId, String homeType, String deviceUuid, IResponseCallBack<MqttInfo> listener) {
        return HxHttp.builder()
                .url(HDLCloudUserApi.getRequestUrl(HDLCloudUserApi.MQTT_INFO_URL))
                .params("attachClientId", attachClientId)
                .params("homeType", homeType)
                .params("deviceUuid", deviceUuid)
                .build()
                .post()
                .subscribeWith(new HDLResponse<MqttInfo>() {
                    @Override
                    public void onResponse(MqttInfo response) {
                        if (listener != null) {
                            listener.onSuccess(response);
                        }
                    }

                    @Override
                    public void onFailure(HDLException e) {
                        JsonObject json = new JsonObject();
                        json.addProperty("attachClientId", attachClientId);
                        json.addProperty("homeType", homeType);
                        json.addProperty("deviceUuid", deviceUuid);
                        HDLExceptionSubmitUtils.submit(HDLCloudUserApi.getRequestUrl(HDLCloudUserApi.MQTT_INFO_URL), json, e);
                        if (listener != null) {
                            listener.onFailure(e);
                        }
                    }
                });
    }

}