新增通用消息事件 Message (message_event.hpp);

Author: cyanray

examples/RepeatMessage.cpp

@@ -75,6 +75,23 @@ system("chcp 65001");
 			m.Reply(m.MessageChain);
 		});
 
+	// 通用型消息
+	// 收到 FriendMessage、GroupMessage、TempMessage 时都会调用它
+	// 判断类型之后，也可调用对应的转换函数进行转换 (类型不正确将转换失败抛出异常)
+	bot.On<Message>(
+		[&](Message m)
+		{
+			m.Reply("Message事件可处理三种消息:" + m.MessageChain);
+
+			// 判断是否群组消息
+			if(m.GetMessageType() == MessageType::GroupMessage)
+			{
+				GroupMessage gm = m.ToGroupMessage();
+				// TODO: 针对群组消息的特别处理
+			}
+			
+		});
+
 
 	// 记录轮询事件时的错误
 	bot.EventLoop([](const char* errMsg)

include/events/events.hpp

@@ -3,6 +3,7 @@
 #define mirai_cpp_events_events_hpp_H_
 
 // 消息事件
+#include "message_event.hpp"
 #include "friend_message.hpp"
 #include "group_message.hpp"
 #include "temp_message.hpp"

include/events/message_event.hpp

@@ -0,0 +1,117 @@
+#pragma once
+#ifndef mirai_cpp_events_message_hpp_H_
+#define mirai_cpp_events_message_hpp_H_
+
+#include <nlohmann/json.hpp>
+#include "defs/qq_types.hpp"
+#include "friend_message.hpp"
+#include "group_message.hpp"
+#include "temp_message.hpp"
+#include "event_interface.hpp"
+#include "exported.h"
+
+namespace Cyan
+{
+
+	enum class MessageType
+	{
+		FriendMessage,		// 好友消息
+		GroupMessage,		// 群组消息
+		TempMessage			// 临时消息
+	};
+
+	// 通用消息事件 (可转换为 FriendMessage GroupMessage TempMessage)
+	class EXPORTED Message : public EventBase
+	{
+	public:
+		Cyan::MessageChain MessageChain;
+
+		static MiraiEvent GetMiraiEvent()
+		{
+			return MiraiEvent::Message;
+		}
+
+		MessageType GetMessageType() const
+		{
+			return messageType_;
+		}
+
+		FriendMessage ToFriendMessage() const
+		{
+			FriendMessage m;
+			m.Set(this->ToJson());
+			return m;
+		}
+
+		GroupMessage ToGroupMessage() const
+		{
+			GroupMessage m;
+			m.Set(this->ToJson());
+			return m;
+		}
+
+		TempMessage ToTempMessage() const
+		{
+			TempMessage m;
+			m.Set(this->ToJson());
+			return m;
+		}
+
+		MessageId GetMessageId() const
+		{
+			return (this->MessageChain).GetMessageId();
+		}
+
+		int64_t GetTimestamp() const
+		{
+			return (this->MessageChain).GetTimestamp();
+		}
+
+		virtual void SetMiraiBot(MiraiBot* bot) override
+		{
+			this->bot_ = bot;
+		}
+
+		MessageId Reply(const Cyan::MessageChain& mc) const;
+		MessageId QuoteReply(const Cyan::MessageChain& mc) const;
+
+		virtual bool Set(const json& j) override
+		{
+			if (j["type"] == "FriendMessage")
+			{
+				messageType_ = MessageType::FriendMessage;
+				friendMessage_.Set(j);
+			}
+			if (j["type"] == "GroupMessage")
+			{
+				messageType_ = MessageType::GroupMessage;
+				groupMessage_.Set(j);
+			}
+			if (j["type"] == "TempMessage")
+			{
+				messageType_ = MessageType::TempMessage;
+				tempMessage_.Set(j);
+			}
+			this->MessageChain.Set(j["messageChain"]);
+			return true;
+		}
+		virtual json ToJson() const override
+		{
+			switch (messageType_)
+			{
+			case	 MessageType::FriendMessage: return friendMessage_.ToJson();
+			case MessageType::GroupMessage: return groupMessage_.ToJson();
+			case MessageType::TempMessage: return tempMessage_.ToJson();
+			default: throw std::runtime_error("错误的 MessageType .");
+			}
+		}
+	private:
+		MiraiBot* bot_;
+		MessageType messageType_;
+		FriendMessage friendMessage_;
+		GroupMessage groupMessage_;
+		TempMessage tempMessage_;
+	};
+}
+
+#endif // !mirai_cpp_events_message_hpp_H_

include/events/mirai_event.hpp

@@ -34,6 +34,7 @@ namespace Cyan
 		MemberJoinRequestEvent,	// 用户入群申请
 		BotLeaveEventActive,		// Bot 主动离开群
 		BotLeaveEventKick,		// Bot 被剔出群
+		Message					// 通用消息事件
 	};
 
 	inline MiraiEvent MiraiEventStr(const std::string& miraiEvent)

include/mirai_bot.hpp

@@ -342,25 +342,25 @@ namespace Cyan
 	template <typename T>
 	MiraiBot& MiraiBot::OnEventReceived(const EventProcessor<T>& ep)
 	{
-		processors_.insert({
-			T::GetMiraiEvent(),
-			[=](WeakEvent we)
+		auto func = [=](WeakEvent we)
+		{
+			// 这个lambda函数有两个作用
+			// 1.创建类型为T的WeakEvent
+			// 2.将传入的WeakEvent转化为类型T
+			//   然后给 EventProcessor 使用
+			if (we == nullptr)
+			{
+				std::shared_ptr<T> e = std::make_shared<T>();
+				return std::dynamic_pointer_cast<EventBase>(e);
+			}
+			else
 			{
-				// 这个lambda函数有两个作用
-				// 1.创建类型为T的WeakEvent
-				// 2.将传入的WeakEvent转化为类型T
-				//   然后给 EventProcessor 使用
-				if (we == nullptr)
-				{
-					std::shared_ptr<T> e = std::make_shared<T>();
-					return std::dynamic_pointer_cast<EventBase>(e);
-				}
-				else
-				{
-					ep(*(std::dynamic_pointer_cast<T>(we)));
-					return we;
-				}
-			} });
+				ep(*(std::dynamic_pointer_cast<T>(we)));
+				return we;
+			}
+		};
+		
+		processors_.insert({T::GetMiraiEvent(), func });
 		return *this;
 	}
 

src/event_func.cpp

@@ -94,4 +94,26 @@ namespace Cyan
 		return true;
 	}
 
+	MessageId Message::Reply(const Cyan::MessageChain& mc) const
+	{
+		switch (messageType_)
+		{
+		case	 MessageType::FriendMessage: return friendMessage_.Reply(mc);
+		case MessageType::GroupMessage: return groupMessage_.Reply(mc);
+		case MessageType::TempMessage: return tempMessage_.Reply(mc);
+		default: throw std::runtime_error("错误的 MessageType .");
+		}
+	}
+
+	MessageId Message::QuoteReply(const Cyan::MessageChain& mc) const
+	{
+		switch (messageType_)
+		{
+		case	 MessageType::FriendMessage: return friendMessage_.QuoteReply(mc);
+		case MessageType::GroupMessage: return groupMessage_.QuoteReply(mc);
+		case MessageType::TempMessage: return tempMessage_.QuoteReply(mc);
+		default: throw std::runtime_error("错误的 MessageType .");
+		}
+	}
+	
 }