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;
|
}
|
}
|
|
}
|
|
}
|
