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


import cn.hutool.core.collection.CollectionUtil;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import org.apache.commons.lang3.StringUtils;
import org.ruoyi.common.wechat.itchat4j.api.MessageTools;
import org.ruoyi.common.wechat.itchat4j.api.WechatTools;
import org.ruoyi.common.wechat.itchat4j.beans.BaseMsg;
import org.ruoyi.common.wechat.itchat4j.beans.SendMsg;
import org.ruoyi.common.wechat.itchat4j.face.IMsgHandlerFace;
import org.ruoyi.common.wechat.itchat4j.utils.LogInterface;
import org.ruoyi.common.wechat.itchat4j.utils.MoreConfig;
import org.ruoyi.common.wechat.itchat4j.utils.enums.MsgCodeEnum;
import org.ruoyi.common.wechat.itchat4j.utils.enums.MsgTypeEnum;
import org.ruoyi.common.wechat.itchat4j.utils.enums.SendMsgType;
import org.ruoyi.common.wechat.itchat4j.utils.tools.CommonTools;

import java.util.ArrayList;
import java.util.List;

/**
 * 消息处理中心
 *
 * @author https://github.com/yaphone
 * @author WesleyOne 修改
 * @version 1.0
 * @date 创建时间：2017年5月14日 下午12:47:50
 */
public class MsgCenter implements LogInterface {

    /**
     * 接收消息，放入队列
     *
     * @param msgList
     * @return
     * @author https://github.com/yaphone
     * @date 2017年4月23日 下午2:30:48
     */
    public static JSONArray produceMsg(JSONArray msgList, String uniqueKey) {
        Core core = CoreManage.getInstance(uniqueKey);
        JSONArray result = new JSONArray();
        // 用于暂存未知群ID,最后调用webwxbatchgetcontact获取
        List<String> unknowGroup = new ArrayList<>();

        for (int i = 0; i < msgList.size(); i++) {
            JSONObject m = msgList.getJSONObject(i);
            // 是否是群消息
            boolean isGroupMsg = false;
            boolean isAtMe = false;
            if (m.getString("FromUserName").contains("@@") || m.getString("ToUserName").contains("@@")) {
                // 群聊消息
                isGroupMsg = true;
                if (m.getString("FromUserName").contains("@@")
                    && !core.getGroupInfoMap().containsKey(m.getString("FromUserName"))) {
                    unknowGroup.add(m.getString("FromUserName"));
                } else if (m.getString("ToUserName").contains("@@")
                    && !core.getGroupInfoMap().containsKey(m.getString("ToUserName"))) {
                    unknowGroup.add(m.getString("ToUserName"));
                }
                // 群消息与普通消息不同的是在其消息体（Content）中会包含发送者id及":<br/>"消息，这里需要处理一下，去掉多余信息，只保留消息内容
                String splitCode = ":<br/>";
                if (m.getString("Content").contains(splitCode)) {
                    String source = m.getString("Content");
                    String content = source.substring(source.indexOf(splitCode) + splitCode.length());
                    String sendMemberId = source.substring(0, source.indexOf(splitCode));

                    m.put("Content", content);
                    m.put(MoreConfig.SEND_MEMBER_ID, sendMemberId);

                    if (content.contains("@" + core.getNickName())) {
                        isAtMe = true;
                    }
                }

            }
            m.put("groupMsg", isGroupMsg);
            m.put("atMe", isAtMe);
            // 1.文本消息
            if (m.getInteger("MsgType").equals(MsgCodeEnum.MSGTYPE_TEXT.getCode())) {
                if (m.getString("Url").length() != 0) {
                    // 1.1分享位置 不处理
                    continue;
//					String[] contents = m.getString("Content").split(":");
//					String data = "Map";
//					if (contents.length>0) {
//						data = contents[0]+":"+m.getString("Url");
//					}
//					m.put("Type", MsgTypeEnum.MAP.getType());
//					m.put("Text", data);
//					LOG.warn("MAP_CONTENT: {},URL: {}",m.getString("Content"),m.getString("Url"));
                    /**
                     *	MAP_CONTENT: 滨兴小区(东区):/cgi-bin/mmwebwx-bin/webwxgetpubliclinkimg?url=xxx&msgid=7525662842661720095&pictype=location,URL: http://apis.map.qq.com/uri/v1/geocoder?coord=30.191660,120.200508
                     */

                } else {
                    // 1.2 普通文本
                    m.put("Type", MsgTypeEnum.TEXT.getType());
                    CommonTools.emojiFormatter2(m, "Content");
                    m.put("Text", m.getString("Content"));

                }
            } else if (m.getInteger("MsgType").equals(MsgCodeEnum.MSGTYPE_IMAGE.getCode())
                || m.getInteger("MsgType").equals(MsgCodeEnum.MSGTYPE_EMOTICON.getCode())) {
                // 2.图片消息 不处理
                continue;
//				m.put("Type", MsgTypeEnum.PIC.getType());
            } else if (m.getInteger("MsgType").equals(MsgCodeEnum.MSGTYPE_VOICE.getCode())) {
                // 3.语音消息 不处理
                continue;
//				m.put("Type", MsgTypeEnum.VOICE.getType());
            } else if (m.getInteger("MsgType").equals(MsgCodeEnum.MSGTYPE_VERIFYMSG.getCode())) {
                // 4.好友确认消息 不处理
                continue;
                // MessageTools.addFriend(core, userName, 3, ticket); // 确认添加好友
//				m.put("Type", MsgTypeEnum.VERIFYMSG.getType());
            } else if (m.getInteger("MsgType").equals(MsgCodeEnum.MSGTYPE_SHARECARD.getCode())) {
                // 5.共享名片 不处理
//				m.put("Type", MsgTypeEnum.NAMECARD.getType());
            } else if (m.getInteger("MsgType").equals(MsgCodeEnum.MSGTYPE_VIDEO.getCode())
                || m.getInteger("MsgType").equals(MsgCodeEnum.MSGTYPE_MICROVIDEO.getCode())) {
                // 6.视频 不处理
                continue;
//				m.put("Type", MsgTypeEnum.VIEDO.getType());
            } else if (m.getInteger("MsgType").equals(MsgCodeEnum.MSGTYPE_MEDIA.getCode())) {
                // 7.分享链接 不处理
                continue;
//				m.put("Type", MsgTypeEnum.MEDIA.getType());
            } else if (m.getInteger("MsgType").equals(MsgCodeEnum.MSGTYPE_STATUSNOTIFY.getCode())) {
                // 微信初始化消息	系统
                m.put("Type", MsgTypeEnum.SYS.getType());
            } else if (m.getInteger("MsgType").equals(MsgCodeEnum.MSGTYPE_SYS.getCode())) {
                // 系统消息	系统
                m.put("Type", MsgTypeEnum.SYS.getType());
            } else if (m.getInteger("MsgType").equals(MsgCodeEnum.MSGTYPE_RECALLED.getCode())) {
                // 撤回消息	系统  不处理
                continue;
//				m.put("Type", MsgTypeEnum.SYS.getType());
            } else {
                LOG.error("Useless msg: {} \n {}", m.getInteger("MsgType"), m.getString("Content"));
            }

            /**
             *	日志
             *	显示收到的消息
             */
            String nickName;
            String memberName = "";
            if (m.getBoolean("groupMsg")) {
                nickName = WechatTools.getGroupNickNameByUserName(m.getString("FromUserName"), uniqueKey);

                if (m.getString(MoreConfig.SEND_MEMBER_ID) != null) {
                    // 获取成员昵称
                    memberName = WechatTools.getMemberNickName(m.getString("FromUserName"), uniqueKey, m.getString(MoreConfig.SEND_MEMBER_ID));
                    m.put(MoreConfig.SEND_MEMBER_NICKNAMW, memberName);
                }
            } else {
                nickName = WechatTools.getContactNickNameByUserName(m.getString("FromUserName"), uniqueKey);
            }
            m.put("fromNickName", nickName);
            LOG.info("收到【{}】=>【{}】消息,来自: {} 内容:\n{} ",
                MsgCodeEnum.fromCode(m.getInteger("MsgType")) == null ? "未知类型" + m.getInteger("MsgType") : MsgCodeEnum.fromCode(m.getInteger("MsgType")).getType(),
                m.getString("Type"),
                nickName + " : " + memberName,
                StringUtils.isNotEmpty(m.getString("Content")) ? m.getString("Content") : "");
            result.add(m);
        }
        return result;
    }

    /**
     * 微信接收消息处理
     *
     * @param uniqueKey
     * @author https://github.com/yaphone
     * @date 2017年5月14日 上午10:52:34
     */
    public static void handleMsg(String uniqueKey, IMsgHandlerFace msgHandler) {
        Core core = CoreManage.getInstance(uniqueKey);
        while (true) {
            if (!core.isAlive()) {
                LOG.info("停止消息处理");
                break;
            }
            if (core.getMsgList().size() > 0 && core.getMsgList().get(0).getContent() != null) {
                if (core.getMsgList().get(0).getContent().length() > 0) {
                    BaseMsg msg = core.getMsgList().get(0);
                    if (msg.getType() != null) {
                        try {
                            if (msg.getType().equals(MsgTypeEnum.TEXT.getType())) {
                                msgHandler.textMsgHandle(msg);
                            } else if (msg.getType().equals(MsgTypeEnum.PIC.getType())) {
                                msgHandler.picMsgHandle(msg);
                            } else if (msg.getType().equals(MsgTypeEnum.VOICE.getType())) {
                                msgHandler.voiceMsgHandle(msg);
                            } else if (msg.getType().equals(MsgTypeEnum.VIEDO.getType())) {
                                msgHandler.videoMsgHandle(msg);
                            } else if (msg.getType().equals(MsgTypeEnum.NAMECARD.getType())) {
                                msgHandler.nameCardMsgHandle(msg);
                            } else if (msg.getType().equals(MsgTypeEnum.SYS.getType())) {
                                msgHandler.sysMsgHandle(msg);
                            } else if (msg.getType().equals(MsgTypeEnum.VERIFYMSG.getType())) {
                                msgHandler.verifyAddFriendMsgHandle(msg);
                            } else if (msg.getType().equals(MsgTypeEnum.MEDIA.getType())) {
                                msgHandler.mediaMsgHandle(msg);
                            } else {
                                LOG.warn("暂未处理信息【{}】", msg.getType());
                            }
                        } catch (Exception e) {
                            LOG.error(e.getMessage(), e);
                        }
                    }
                }
                core.getMsgList().remove(0);
            }
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
                LOG.error("消息处理中断");
                break;
            }
        }
    }

    /**
     * 统一发送消息
     *
     * @param uniqueKey
     */
    public static void sendMsg(String uniqueKey) {
        Core core = CoreManage.getInstance(uniqueKey);
        while (true) {
            if (core == null || !core.isAlive()) {
                LOG.info("停止消息发送");
                break;
            }
            if (CollectionUtil.isNotEmpty(core.getSendList())) {
                SendMsg sendMsg = core.getSendList().get(0);
                try {
                    String userName = sendMsg.getUserName();
                    String nickName = sendMsg.getNickName();
                    String message = sendMsg.getMessage();
                    boolean isGroup = sendMsg.isGroup();
                    SendMsgType msgType = sendMsg.getMsgType();
                    if (StringUtils.isNotEmpty(message) && msgType != null) {
                        if (StringUtils.isNotEmpty(userName)) {
                            MessageTools.send(userName, uniqueKey, message, msgType.toValue());
                        } else if (StringUtils.isNotEmpty(nickName)) {
                            MessageTools.sendByNickName(nickName, uniqueKey, message, msgType.toValue(), isGroup);
                        } else {
                            LOG.error("无效发送消息: {}", JSONObject.toJSONString(sendMsg));
                        }
                    }
                } catch (Exception e) {
                    LOG.error(e.getMessage(), e);
                }
                core.getSendList().remove(0);
            }
            try {
                // 控制发送频率
                Thread.sleep(2000);
            } catch (InterruptedException e) {
                e.printStackTrace();
                LOG.error("消息发送中断");
                break;
            }
        }

    }

}