package org.ruoyi.common.wechat.itchat4j.core;

import com.alibaba.fastjson.JSONObject;
import com.alibaba.fastjson.annotation.JSONField;
import org.ruoyi.common.wechat.itchat4j.beans.BaseMsg;
import org.ruoyi.common.wechat.itchat4j.beans.SendMsg;
import org.ruoyi.common.wechat.itchat4j.beans.User;
import org.ruoyi.common.wechat.itchat4j.client.HttpClientManage;
import org.ruoyi.common.wechat.itchat4j.client.SingleHttpClient;
import org.ruoyi.common.wechat.itchat4j.service.impl.LoginServiceImpl;
import org.ruoyi.common.wechat.itchat4j.utils.enums.parameters.BaseParaEnum;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

/**
 * 核心存储类，全局只保存一份，单例模式
 *
 * @author https://github.com/yaphone
 * @author WesleyOne 修改
 * @version 1.0
 * @date 创建时间：2017年4月23日 下午2:33:56
 */
public class Core {

    private Core() {

    }

    private Core(String uniqueKey) {
        this.uniqueKey = uniqueKey;
        this.myHttpClient = HttpClientManage.getInstance(this.uniqueKey);
        this.threadGroup = new ThreadGroup(this.uniqueKey);
    }

    protected static Core getInstance(String uniqueKey) {
        return new Core(uniqueKey);
    }

    private String uniqueKey;

    boolean alive = false;

    /**
     * 管理当前机器人的所有业务线程
     */
    @JSONField(serialize = false)
    private ThreadGroup threadGroup;

    @JSONField(serialize = false)
    boolean isFinishInit = false;

    /**
     * login,webWxInit
     * 登录接口获取
     */
    private String indexUrl;
    private String userName;
    private String nickName;
    String uuid = null;
    /**
     * webWxInit
     * InviteStartCount
     * SyncKey
     * synckey 随着每次获取最新消息后的返回值更新，其目的在于每次同步消息后记录一个当前同步的状态
     */
    Map<String, Object> loginInfo = new HashMap<String, Object>();

    /**
     * webWxInit
     * 登陆账号自身信息
     *
     * @see User
     */
    private JSONObject userSelf;


    /**
     * 初始化/cgi-bin/mmwebwx-bin/webwxinit
     * 最后一次收到正常retcode的时间，秒为单位
     * <p>
     * synccheck刷新
     */
    private long lastNormalRetcodeTime;


    /**
     * synccheck和webWxSync容错次数,超过退出
     */
    int receivingRetryCount = 5;


    @JSONField(serialize = false)
    SingleHttpClient myHttpClient;

    public SingleHttpClient getMyHttpClient() {
        return HttpClientManage.getInstance(uniqueKey);
    }

    /**
     * 初始话时获取联系人时创建
     * @see LoginServiceImpl#webWxGetContact()
     */
    /**
     * memberList长度
     */
    @JSONField(serialize = false)
    private int memberCount = 0;
    /**
     * 好友+群聊+公众号+特殊账号
     * 注意：不主动插入,获取时通过其他几个账号集合合并
     */
    @JSONField(serialize = false)
    private List<JSONObject> memberList = new ArrayList<JSONObject>();
    /**
     * 好友
     */
    @JSONField(serialize = false)
    private List<JSONObject> contactList = new ArrayList<JSONObject>();
    /**
     * 群
     */
    @JSONField(serialize = false)
    private List<JSONObject> groupList = new ArrayList<JSONObject>();
    /**
     * 公众号/服务号
     */
    @Deprecated
    @JSONField(serialize = false)
    private List<JSONObject> publicUsersList = new ArrayList<JSONObject>();
    /**
     * 特殊账号
     */
    @JSONField(serialize = false)
    private List<JSONObject> specialUsersList = new ArrayList<JSONObject>();

    /* ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ */

    /**
     * synccheck和webWxSynct添加
     * 异步接受消息存储
     */
    @JSONField(serialize = false)
    private List<BaseMsg> msgList = new ArrayList<>();

    /**
     * 异步发送消息存储
     */
    @JSONField(serialize = false)
    private List<SendMsg> sendList = new ArrayList();

    /********************************
     * 缓存字段,用于快速查找
     ********************************/

    /**
     * 微信昵称不能超过16位，而ID比较长，干脆用一个Map
     * 群ID或昵称,群信息
     * 注意:存在相同昵称会后者覆盖前者
     * <p>
     * WebWxBatchGetContact之后可以通过
     * .getJSONArray("MemberList")获取群成员列表
     */
    @JSONField(serialize = false)
    private Map<String, JSONObject> groupInfoMap = new HashMap<>(1024);

    /**
     * 微信昵称不能超过16位，而ID比较长，干脆用一个Map
     * 玩家ID或昵称，玩家信息
     * 注意:存在相同昵称会后者覆盖前者
     */
    @JSONField(serialize = false)
    private Map<String, JSONObject> userInfoMap = new HashMap<>(1024);

    /* ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ */

    /**
     * 请求参数
     */
    @JSONField(serialize = false)
    public Map<String, Object> getParamMap() {
        return new HashMap<String, Object>(1) {
            /**
             *
             */
            private static final long serialVersionUID = 1L;

            {
                Map<String, String> map = new HashMap<>(16);
                for (BaseParaEnum baseRequest : BaseParaEnum.values()) {
                    map.put(baseRequest.para(), getLoginInfo().get(baseRequest.value()).toString());
                }
                put("BaseRequest", map);
            }
        };
    }

    public String getUniqueKey() {
        return uniqueKey;
    }

    public void setUniqueKey(String uniqueKey) {
        this.uniqueKey = uniqueKey;
    }

    public boolean isAlive() {
        return alive;
    }

    public void setAlive(boolean alive) {
        this.alive = alive;
        if (!alive) {
            this.isFinishInit = false;
        }
    }

    public String getIndexUrl() {
        return indexUrl;
    }

    public void setIndexUrl(String indexUrl) {
        this.indexUrl = indexUrl;
    }

    public String getUserName() {
        return userName;
    }

    public void setUserName(String userName) {
        this.userName = userName;
    }

    public String getNickName() {
        return nickName;
    }

    public void setNickName(String nickName) {
        this.nickName = nickName;
    }

    public String getUuid() {
        return uuid;
    }

    public void setUuid(String uuid) {
        this.uuid = uuid;
    }

    public Map<String, Object> getLoginInfo() {
        return loginInfo;
    }

    public void setLoginInfo(Map<String, Object> loginInfo) {
        this.loginInfo = loginInfo;
    }

    public JSONObject getUserSelf() {
        return userSelf;
    }

    public void setUserSelf(JSONObject userSelf) {
        this.userSelf = userSelf;
    }

    public long getLastNormalRetcodeTime() {
        return lastNormalRetcodeTime;
    }

    public void setLastNormalRetcodeTime(long lastNormalRetcodeTime) {
        this.lastNormalRetcodeTime = lastNormalRetcodeTime;
    }

    public int getReceivingRetryCount() {
        return receivingRetryCount;
    }

    public void setReceivingRetryCount(int receivingRetryCount) {
        this.receivingRetryCount = receivingRetryCount;
    }

    public int getMemberCount() {
        return getContactList().size() + getGroupList().size() + getPublicUsersList().size() + getSpecialUsersList().size();
    }

    public List<JSONObject> getMemberList() {
        List<JSONObject> memberList = new ArrayList<>();
        memberList.addAll(this.getContactList());
        memberList.addAll(this.getGroupList());
        memberList.addAll(this.getPublicUsersList());
        memberList.addAll(this.getSpecialUsersList());
        return memberList;
    }

    public List<JSONObject> getContactList() {
        return contactList;
    }

    public void setContactList(List<JSONObject> contactList) {
        this.contactList = contactList;
    }

    public List<JSONObject> getGroupList() {
        return groupList;
    }

    public void setGroupList(List<JSONObject> groupList) {
        this.groupList = groupList;
    }

    public List<JSONObject> getPublicUsersList() {
        return publicUsersList;
    }

    public void setPublicUsersList(List<JSONObject> publicUsersList) {
        this.publicUsersList = publicUsersList;
    }

    public List<JSONObject> getSpecialUsersList() {
        return specialUsersList;
    }

    public void setSpecialUsersList(List<JSONObject> specialUsersList) {
        this.specialUsersList = specialUsersList;
    }

    public List<BaseMsg> getMsgList() {
        return msgList;
    }

    public void setMsgList(List<BaseMsg> msgList) {
        this.msgList = msgList;
    }

    public Map<String, JSONObject> getGroupInfoMap() {
        return groupInfoMap;
    }

    public void setGroupInfoMap(Map<String, JSONObject> groupInfoMap) {
        this.groupInfoMap = groupInfoMap;
    }

    public Map<String, JSONObject> getUserInfoMap() {
        return userInfoMap;
    }

    public void setUserInfoMap(Map<String, JSONObject> userInfoMap) {
        this.userInfoMap = userInfoMap;
    }

    public boolean isFinishInit() {
        return isFinishInit;
    }

    public void setFinishInit(boolean finishInit) {
        isFinishInit = finishInit;
    }

    public ThreadGroup getThreadGroup() {
        return threadGroup;
    }

    public void setThreadGroup(ThreadGroup threadGroup) {
        this.threadGroup = threadGroup;
    }

    public List<SendMsg> getSendList() {
        return sendList;
    }
}