增加配置支持35

no message
2025-06-30 14:30:52 +08:00 · 2025-05-07 17:35:06 +08:00 · 2025-05-07 17:01:30 +08:00 · 2025-05-07 16:01:31 +08:00 · 2025-05-07 11:27:33 +08:00
18 changed files with 643 additions and 604 deletions
--- a/android/build.gradle
+++ b/android/build.gradle
@ -42,6 +42,7 @@ rootProject.allprojects {
 apply plugin: 'com.android.library'

 android {
+    namespace 'io.openim.flutter_openim_sdk'
    compileSdkVersion 34

    defaultConfig {
--- a/android/src/main/AndroidManifest.xml
+++ b/android/src/main/AndroidManifest.xml
@ -1,6 +1,5 @@
 <?xml version="1.0" encoding="utf-8"?>
-<manifest xmlns:android="http://schemas.android.com/apk/res/android"
-    package="io.openim.flutter_openim_sdk">
+<manifest xmlns:android="http://schemas.android.com/apk/res/android">

    <uses-permission android:name="android.permission.ACCESS_NETWORK_STATE" />
 </manifest>
--- a/example/lib/main.dart
+++ b/example/lib/main.dart
@ -18,29 +18,48 @@ class MyApp extends StatefulWidget {
 }

 class _MyAppState extends State<MyApp> {
+  Future<void> send() async {
+    OpenIM.iMManager.messageManager
+        .sendMessage(
+            userID: "724f91aceb434a28a1cd10f5564b2c68",
+            message: await OpenIM.iMManager.messageManager
+                .createTextMessage(text: 'hello openim'),
+            offlinePushInfo: OfflinePushInfo(title: 'title', desc: 'desc'))
+        .then((value) {
+      print('send success');
+    }).catchError((error) {
+      print('send error');
+    });
+  }
+
  @override
  void initState() {
    super.initState();
    OpenIM.iMManager
        .initSDK(
-            platformID: 2,
+            platformID: 3,
            apiAddr: 'http://192.168.77.135:10002',
            wsAddr: 'ws://192.168.77.135:10001',
            dataDir: './',
            listener: OnConnectListener())
-        .then((value) {
-      print('SDK initialized successfully');
+        .then((value) {});
+    OpenIM.iMManager.userManager.setUserListener(OnUserListener());
+
    OpenIM.iMManager
        .login(
-              userID: "3e8b8fb2ecd8414db50838d9f7bcb19d",
+            userID: "8bfe13b5eac44e87963652abb91d80d2",
            token:
-                  "eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJVc2VySUQiOiIzZThiOGZiMmVjZDg0MTRkYjUwODM4ZDlmN2JjYjE5ZCIsIlBsYXRmb3JtSUQiOjIsImV4cCI6MTc1Mzc1MTYyNywiaWF0IjoxNzQ1OTc1NjIyfQ.S-CxfETXYyLFe2VqStwbrVCRcB5j2T2qi-52y1L-3OI")
+                "eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJVc2VySUQiOiI4YmZlMTNiNWVhYzQ0ZTg3OTYzNjUyYWJiOTFkODBkMiIsIlBsYXRmb3JtSUQiOjMsImV4cCI6MTc1NDM2NDkwNCwiaWF0IjoxNzQ2NTg4ODk5fQ.575xwR9lzJo1i5Te-Ul-99odONfxbzDXW0_2Kv3nFEE")
        .then((value) {
-        print('Login successful');
-      }).catchError((error) {
-        print('Login failed: $error');
-      });
+      List<String> list = [];
+      OpenIM.iMManager.userManager.subscribeUsersStatus(list);
+      send();
+      OpenIM.iMManager.conversationManager
+          .getAllConversationList()
+          .then((value) {
+        print('Get all conversation list successful');
      });
+    }).catchError((error) {});
  }

  @override
--- a/windows/src/common/ThreadUtil.cpp
+++ b/windows/src/common/ThreadUtil.cpp
@ -14,13 +14,6 @@ namespace ThreadUtil {
    static std::condition_variable g_queueCondition;
    static bool g_initialized = false;
    static HANDLE g_workerThread = NULL;
-
-    // Function to initialize the platform thread ID
-    void InitializePlatformThreadId() {
-        g_platformThreadId = GetCurrentThreadId();
-        g_initialized = true;
-    }
-
    // Worker thread function
    unsigned __stdcall WorkerThreadProc(void* param) {
        while (true) {
@ -39,6 +32,16 @@ namespace ThreadUtil {

        return 0;
    }
+    // Function to initialize the platform thread ID
+    void InitializePlatformThreadId() {
+        g_platformThreadId = GetCurrentThreadId();
+        
+        // Create worker thread
+        g_workerThread = (HANDLE)_beginthreadex(NULL, 0, WorkerThreadProc, NULL, 0, NULL);
+        g_initialized = true;
+    }
+
+   

    // Function to ensure code runs on the platform thread
    void RunOnPlatformThread(std::function<void()> callback) {
@ -46,8 +49,7 @@ namespace ThreadUtil {
        if (!g_initialized) {
            InitializePlatformThreadId();

-            // Create worker thread
-            g_workerThread = (HANDLE)_beginthreadex(NULL, 0, WorkerThreadProc, NULL, 0, NULL);
+
        }

        // If we're already on the platform thread, execute directly
--- a/windows/src/common/ZegoDataUtils.cpp
+++ b/windows/src/common/ZegoDataUtils.cpp
@ -69,3 +69,6 @@ std::string map_2_json(const flutter::EncodableMap& map) {
 	auto json_string = json_object.dump(); // 序列化为 JSON 字符串
    return json_string; // 序列化为 JSON 字符串
 }
+std::string value_2_json(flutter::EncodableValue value){
+    return EncodableValueToJson(value).dump();
+}
--- a/windows/src/common/ZegoDataUtils.h
+++ b/windows/src/common/ZegoDataUtils.h
@ -31,6 +31,6 @@ std::vector<uint8_t> zego_value_get_vector_uint8(flutter::EncodableValue value);
 ZFMap zego_value_get_map(flutter::EncodableValue value);
 ZFArray zego_value_get_list(flutter::EncodableValue value);
 std::string map_2_json(const flutter::EncodableMap& map);
-
-
+std::string value_2_json(flutter::EncodableValue value);
+nlohmann::json EncodableValueToJson(const flutter::EncodableValue& value);

--- a/windows/src/common/services/ChannelManager.cpp
+++ b/windows/src/common/services/ChannelManager.cpp
@ -55,7 +55,7 @@ void ChannelManagerService::getChannelMembersInfo(
    if (arguments) {
        auto operationID = zego_value_get_string(arguments->at(flutter::EncodableValue("operationID")));
        auto channelID = zego_value_get_string(arguments->at(flutter::EncodableValue("channelID")));
-        auto userIDList = zego_value_get_string(arguments->at(flutter::EncodableValue("userIDList")));
+        auto userIDList = value_2_json(arguments->at(flutter::EncodableValue("userIDList")));
        char* operationID_cs = const_cast<char*>(operationID.c_str());
        char* channelID_cs = const_cast<char*>(channelID.c_str());
        char* userIDList_cs = const_cast<char*>(userIDList.c_str());
@ -89,7 +89,7 @@ void ChannelManagerService::getChannelsInfo(
    std::shared_ptr<flutter::MethodResult<flutter::EncodableValue>> result) {
    if (arguments) {
        auto operationID = zego_value_get_string(arguments->at(flutter::EncodableValue("operationID")));
-        auto channelIDList = zego_value_get_string(arguments->at(flutter::EncodableValue("channelIDList")));
+        auto channelIDList = value_2_json(arguments->at(flutter::EncodableValue("channelIDList")));
        char* operationID_cs = const_cast<char*>(operationID.c_str());
        char* channelIDList_cs = const_cast<char*>(channelIDList.c_str());

@ -189,7 +189,7 @@ void ChannelManagerService::getUsersInChannel(
    if (arguments) {
        auto operationID = zego_value_get_string(arguments->at(flutter::EncodableValue("operationID")));
        auto channelID = zego_value_get_string(arguments->at(flutter::EncodableValue("channelID")));
-        auto userIDs = zego_value_get_string(arguments->at(flutter::EncodableValue("userIDs")));
+        auto userIDs = value_2_json(arguments->at(flutter::EncodableValue("userIDs")));
        char* operationID_cs = const_cast<char*>(operationID.c_str());
        char* channelID_cs = const_cast<char*>(channelID.c_str());
        char* userIDs_cs = const_cast<char*>(userIDs.c_str());
--- a/windows/src/common/services/ChannelManager.h
+++ b/windows/src/common/services/ChannelManager.h
@ -12,10 +12,10 @@ class ChannelManagerService : public FLTService
 public:
 	ChannelManagerService();

-        void onMethodCalled(
-            const std::string &method,
-            const flutter::EncodableMap *arguments,
-            std::shared_ptr<flutter::MethodResult<flutter::EncodableValue>> result);
+	virtual void onMethodCalled(
+		const std::string& method, const flutter::EncodableMap* arguments,
+		std::shared_ptr<flutter::MethodResult<flutter::EncodableValue>> result)
+		override;

 	// Method handlers
 	void setChannelListener(
@ -49,8 +49,7 @@ class ChannelManagerService : public FLTService
 		const flutter::EncodableMap* arguments,
 		std::shared_ptr<flutter::MethodResult<flutter::EncodableValue>> result);

-    private:
-        std::string m_serviceName;
+
 };

 #endif // CHANNEL_MANAGER_SERVICE_H
--- a/windows/src/common/services/ConversationManager.cpp
+++ b/windows/src/common/services/ConversationManager.cpp
@ -116,7 +116,7 @@ void ConversationManagerService::getMultipleConversation(
    std::shared_ptr<flutter::MethodResult<flutter::EncodableValue>> result) {
    if (arguments) {
        auto operationID = zego_value_get_string(arguments->at(flutter::EncodableValue("operationID")));
-        auto conversationIDList = zego_value_get_string(arguments->at(flutter::EncodableValue("conversationIDList")));
+        auto conversationIDList = value_2_json(arguments->at(flutter::EncodableValue("conversationIDList")));
        char* operationID_cs = const_cast<char*>(operationID.c_str());
        char* conversationIDList_cs = const_cast<char*>(conversationIDList.c_str());

@ -314,7 +314,7 @@ void ConversationManagerService::setConversation(
    if (arguments) {
        auto operationID = zego_value_get_string(arguments->at(flutter::EncodableValue("operationID")));
        auto conversationID = zego_value_get_string(arguments->at(flutter::EncodableValue("conversationID")));
-        auto req = zego_value_get_string(arguments->at(flutter::EncodableValue("req")));
+        auto req = value_2_json(arguments->at(flutter::EncodableValue("req")));
        char* operationID_cs = const_cast<char*>(operationID.c_str());
        char* conversationID_cs = const_cast<char*>(conversationID.c_str());
        char* req_cs = const_cast<char*>(req.c_str());
--- a/windows/src/common/services/ConversationManager.h
+++ b/windows/src/common/services/ConversationManager.h
@ -11,10 +11,10 @@ public:
 	ConversationManagerService();


-  void onMethodCalled(
-      const std::string& method,
-      const flutter::EncodableMap* arguments,
-      std::shared_ptr<flutter::MethodResult<flutter::EncodableValue>> result);
+	virtual void onMethodCalled(
+		const std::string& method, const flutter::EncodableMap* arguments,
+		std::shared_ptr<flutter::MethodResult<flutter::EncodableValue>> result)
+		override;

 	// Method handlers
 	void setConversationListener(
@ -75,8 +75,7 @@ public:
 		const flutter::EncodableMap* arguments,
 		std::shared_ptr<flutter::MethodResult<flutter::EncodableValue>> result);

-private:
-  std::string m_serviceName;
+
 };

 #endif // CONVERSATION_MANAGER_SERVICE_H
--- a/windows/src/common/services/FriendManager.cpp
+++ b/windows/src/common/services/FriendManager.cpp
@ -107,7 +107,7 @@ void FriendshipManagerService::getFriendsInfo(
    if (arguments)
    {
        auto operationID = zego_value_get_string(arguments->at(flutter::EncodableValue("operationID")));
-        auto userIDList = zego_value_get_string(arguments->at(flutter::EncodableValue("userIDList")));
+        auto userIDList = value_2_json(arguments->at(flutter::EncodableValue("userIDList")));
        auto filterBlack = zego_value_get_bool(arguments->at(flutter::EncodableValue("filterBlack")));
        char *operationID_cs = const_cast<char *>(operationID.c_str());
        char *userIDList_cs = const_cast<char *>(userIDList.c_str());
@ -275,7 +275,7 @@ void FriendshipManagerService::checkFriend(
    if (arguments)
    {
        auto operationID = zego_value_get_string(arguments->at(flutter::EncodableValue("operationID")));
-        auto userIDList = zego_value_get_string(arguments->at(flutter::EncodableValue("userIDList")));
+        auto userIDList = value_2_json(arguments->at(flutter::EncodableValue("userIDList")));
        char *operationID_cs = const_cast<char *>(operationID.c_str());
        char *userIDList_cs = const_cast<char *>(userIDList.c_str());

@ -351,7 +351,7 @@ void FriendshipManagerService::searchFriends(
    if (arguments)
    {
        auto operationID = zego_value_get_string(arguments->at(flutter::EncodableValue("operationID")));
-        auto searchParam = zego_value_get_string(arguments->at(flutter::EncodableValue("searchParam")));
+        auto searchParam = value_2_json(arguments->at(flutter::EncodableValue("searchParam")));
        char *operationID_cs = const_cast<char *>(operationID.c_str());
        char *searchParam_cs = const_cast<char *>(searchParam.c_str());

@ -370,7 +370,7 @@ void FriendshipManagerService::updateFriends(
    if (arguments)
    {
        auto operationID = zego_value_get_string(arguments->at(flutter::EncodableValue("operationID")));
-        auto req = zego_value_get_string(arguments->at(flutter::EncodableValue("req")));
+        auto req = value_2_json(arguments->at(flutter::EncodableValue("req")));
        char *operationID_cs = const_cast<char *>(operationID.c_str());
        char *req_cs = const_cast<char *>(req.c_str());

--- a/windows/src/common/services/FriendManager.h
+++ b/windows/src/common/services/FriendManager.h
@ -12,10 +12,10 @@ class FriendshipManagerService : public FLTService
 public:
 	FriendshipManagerService();

-    void onMethodCalled(
-        const std::string &method,
-        const flutter::EncodableMap *arguments,
-        std::shared_ptr<flutter::MethodResult<flutter::EncodableValue>> result);
+	virtual void onMethodCalled(
+		const std::string& method, const flutter::EncodableMap* arguments,
+		std::shared_ptr<flutter::MethodResult<flutter::EncodableValue>> result)
+		override;

 	// Method handlers
 	void setFriendListener(
@ -67,8 +67,6 @@ public:
 		const flutter::EncodableMap* arguments,
 		std::shared_ptr<flutter::MethodResult<flutter::EncodableValue>> result);

-private:
-    std::string m_serviceName;
 };

 #endif // FRIENDSHIP_MANAGER_SERVICE_H
--- a/windows/src/common/services/GroupManager.cpp
+++ b/windows/src/common/services/GroupManager.cpp
@ -90,7 +90,7 @@ void GroupManagerService::inviteUserToGroup(
        auto operationID = zego_value_get_string(arguments->at(flutter::EncodableValue("operationID")));
        auto groupID = zego_value_get_string(arguments->at(flutter::EncodableValue("groupID")));
        auto reason = zego_value_get_string(arguments->at(flutter::EncodableValue("reason")));
-        auto userIDList = zego_value_get_string(arguments->at(flutter::EncodableValue("userIDList")));
+        auto userIDList = value_2_json(arguments->at(flutter::EncodableValue("userIDList")));
        char* operationID_cs = const_cast<char*>(operationID.c_str());
        char* groupID_cs = const_cast<char*>(groupID.c_str());
        char* reason_cs = const_cast<char*>(reason.c_str());
@ -109,7 +109,7 @@ void GroupManagerService::kickGroupMember(
        auto operationID = zego_value_get_string(arguments->at(flutter::EncodableValue("operationID")));
        auto groupID = zego_value_get_string(arguments->at(flutter::EncodableValue("groupID")));
        auto reason = zego_value_get_string(arguments->at(flutter::EncodableValue("reason")));
-        auto userIDList = zego_value_get_string(arguments->at(flutter::EncodableValue("userIDList")));
+        auto userIDList = value_2_json(arguments->at(flutter::EncodableValue("userIDList")));
        char* operationID_cs = const_cast<char*>(operationID.c_str());
        char* groupID_cs = const_cast<char*>(groupID.c_str());
        char* reason_cs = const_cast<char*>(reason.c_str());
@ -127,7 +127,7 @@ void GroupManagerService::getGroupMembersInfo(
    if (arguments) {
        auto operationID = zego_value_get_string(arguments->at(flutter::EncodableValue("operationID")));
        auto groupID = zego_value_get_string(arguments->at(flutter::EncodableValue("groupID")));
-        auto userIDList = zego_value_get_string(arguments->at(flutter::EncodableValue("userIDList")));
+        auto userIDList = value_2_json(arguments->at(flutter::EncodableValue("userIDList")));
        char* operationID_cs = const_cast<char*>(operationID.c_str());
        char* groupID_cs = const_cast<char*>(groupID.c_str());
        char* userIDList_cs = const_cast<char*>(userIDList.c_str());
@ -204,7 +204,7 @@ void GroupManagerService::setGroupInfo(
    std::shared_ptr<flutter::MethodResult<flutter::EncodableValue>> result) {
    if (arguments) {
        auto operationID = zego_value_get_string(arguments->at(flutter::EncodableValue("operationID")));
-        auto groupInfo = zego_value_get_string(arguments->at(flutter::EncodableValue("groupInfo")));
+        auto groupInfo = value_2_json(arguments->at(flutter::EncodableValue("groupInfo")));
        char* operationID_cs = const_cast<char*>(operationID.c_str());
        char* groupInfo_cs = const_cast<char*>(groupInfo.c_str());

@ -219,7 +219,7 @@ void GroupManagerService::getGroupsInfo(
    std::shared_ptr<flutter::MethodResult<flutter::EncodableValue>> result) {
    if (arguments) {
        auto operationID = zego_value_get_string(arguments->at(flutter::EncodableValue("operationID")));
-        auto groupIDList = zego_value_get_string(arguments->at(flutter::EncodableValue("groupIDList")));
+        auto groupIDList = value_2_json(arguments->at(flutter::EncodableValue("groupIDList")));
        char* operationID_cs = const_cast<char*>(operationID.c_str());
        char* groupIDList_cs = const_cast<char*>(groupIDList.c_str());

@ -399,7 +399,7 @@ void GroupManagerService::searchGroups(
    std::shared_ptr<flutter::MethodResult<flutter::EncodableValue>> result) {
    if (arguments) {
        auto operationID = zego_value_get_string(arguments->at(flutter::EncodableValue("operationID")));
-        auto searchParam = zego_value_get_string(arguments->at(flutter::EncodableValue("searchParam")));
+        auto searchParam = value_2_json(arguments->at(flutter::EncodableValue("searchParam")));
        char* operationID_cs = const_cast<char*>(operationID.c_str());
        char* searchParam_cs = const_cast<char*>(searchParam.c_str());

@ -419,7 +419,7 @@ void GroupManagerService::getGroupMemberListByJoinTimeFilter(
        auto count = zego_value_get_int(arguments->at(flutter::EncodableValue("count")));
        auto joinTimeBegin = zego_value_get_int(arguments->at(flutter::EncodableValue("joinTimeBegin")));
        auto joinTimeEnd = zego_value_get_int(arguments->at(flutter::EncodableValue("joinTimeEnd")));
-        auto excludeUserIDList = zego_value_get_string(arguments->at(flutter::EncodableValue("excludeUserIDList")));
+        auto excludeUserIDList = value_2_json(arguments->at(flutter::EncodableValue("excludeUserIDList")));
        char* operationID_cs = const_cast<char*>(operationID.c_str());
        char* groupID_cs = const_cast<char*>(groupID.c_str());
        char* excludeUserIDList_cs = const_cast<char*>(excludeUserIDList.c_str());
@ -450,7 +450,7 @@ void GroupManagerService::searchGroupMembers(
    std::shared_ptr<flutter::MethodResult<flutter::EncodableValue>> result) {
    if (arguments) {
        auto operationID = zego_value_get_string(arguments->at(flutter::EncodableValue("operationID")));
-        auto searchParam = zego_value_get_string(arguments->at(flutter::EncodableValue("searchParam")));
+        auto searchParam = value_2_json(arguments->at(flutter::EncodableValue("searchParam")));
        char* operationID_cs = const_cast<char*>(operationID.c_str());
        char* searchParam_cs = const_cast<char*>(searchParam.c_str());

@ -465,7 +465,7 @@ void GroupManagerService::setGroupMemberInfo(
    std::shared_ptr<flutter::MethodResult<flutter::EncodableValue>> result) {
    if (arguments) {
        auto operationID = zego_value_get_string(arguments->at(flutter::EncodableValue("operationID")));
-        auto info = zego_value_get_string(arguments->at(flutter::EncodableValue("info")));
+        auto info = value_2_json(arguments->at(flutter::EncodableValue("info")));
        char* operationID_cs = const_cast<char*>(operationID.c_str());
        char* info_cs = const_cast<char*>(info.c_str());

@ -496,7 +496,7 @@ void GroupManagerService::getUsersInGroup(
    if (arguments) {
        auto operationID = zego_value_get_string(arguments->at(flutter::EncodableValue("operationID")));
        auto groupID = zego_value_get_string(arguments->at(flutter::EncodableValue("groupID")));
-        auto userIDs = zego_value_get_string(arguments->at(flutter::EncodableValue("userIDs")));
+        auto userIDs = value_2_json(arguments->at(flutter::EncodableValue("userIDs")));
        char* operationID_cs = const_cast<char*>(operationID.c_str());
        char* groupID_cs = const_cast<char*>(groupID.c_str());
        char* userIDs_cs = const_cast<char*>(userIDs.c_str());
--- a/windows/src/common/services/GroupManager.h
+++ b/windows/src/common/services/GroupManager.h
@ -12,10 +12,10 @@ class GroupManagerService : public FLTService
 public:
 	GroupManagerService();

-    void onMethodCalled(
-        const std::string &method,
-        const flutter::EncodableMap *arguments,
-        std::shared_ptr<flutter::MethodResult<flutter::EncodableValue>> result);
+	virtual void onMethodCalled(
+		const std::string& method, const flutter::EncodableMap* arguments,
+		std::shared_ptr<flutter::MethodResult<flutter::EncodableValue>> result)
+		override;

 	// Method handlers
 	void setGroupListener(
@ -100,8 +100,7 @@ public:
 		const flutter::EncodableMap* arguments,
 		std::shared_ptr<flutter::MethodResult<flutter::EncodableValue>> result);

-private:
-    std::string m_serviceName;
+
 };

 #endif // GROUP_MANAGER_SERVICE_H
--- a/windows/src/common/services/MessageManager.cpp
+++ b/windows/src/common/services/MessageManager.cpp
@ -125,13 +125,16 @@ void MessageManagerService::sendMessage(
    std::shared_ptr<flutter::MethodResult<flutter::EncodableValue>> result) {
    if (arguments) {
        auto operationID = zego_value_get_string(arguments->at(flutter::EncodableValue("operationID")));
-        auto message = zego_value_get_string(arguments->at(flutter::EncodableValue("message")));
+        auto message = value_2_json(arguments->at(flutter::EncodableValue("message")));
        auto userID = zego_value_get_string(arguments->at(flutter::EncodableValue("userID")));
        auto groupID = zego_value_get_string(arguments->at(flutter::EncodableValue("groupID")));
        auto channelID = zego_value_get_string(arguments->at(flutter::EncodableValue("channelID")));
-        auto offlinePushInfo = zego_value_get_string(arguments->at(flutter::EncodableValue("offlinePushInfo")));
+        auto offlinePushInfo = value_2_json(arguments->at(flutter::EncodableValue("offlinePushInfo")));
        auto isOnlineOnly = zego_value_get_bool(arguments->at(flutter::EncodableValue("isOnlineOnly")));
-        auto clientMsgID = zego_value_get_string(arguments->at(flutter::EncodableValue("clientMsgID")));
+        auto json = EncodableValueToJson(arguments->at(flutter::EncodableValue("message")));
+        auto clientMsgID = json["clientMsgID"].get<std::string>();
+
+

        char* operationID_cs = const_cast<char*>(operationID.c_str());
        char* message_cs = const_cast<char*>(message.c_str());
@ -170,7 +173,7 @@ void MessageManagerService::editMessage(
        auto operationID = zego_value_get_string(arguments->at(flutter::EncodableValue("operationID")));
        auto conversationID = zego_value_get_string(arguments->at(flutter::EncodableValue("conversationID")));
        auto clientMsgID = zego_value_get_string(arguments->at(flutter::EncodableValue("clientMsgID")));
-        auto message = zego_value_get_string(arguments->at(flutter::EncodableValue("message")));
+        auto message = value_2_json(arguments->at(flutter::EncodableValue("message")));
        char* operationID_cs = const_cast<char*>(operationID.c_str());
        char* conversationID_cs = const_cast<char*>(conversationID.c_str());
        char* clientMsgID_cs = const_cast<char*>(clientMsgID.c_str());
@ -247,7 +250,7 @@ void MessageManagerService::insertSingleMessageToLocalStorage(
    std::shared_ptr<flutter::MethodResult<flutter::EncodableValue>> result) {
    if (arguments) {
        auto operationID = zego_value_get_string(arguments->at(flutter::EncodableValue("operationID")));
-        auto message = zego_value_get_string(arguments->at(flutter::EncodableValue("message")));
+        auto message = value_2_json(arguments->at(flutter::EncodableValue("message")));
        auto receiverID = zego_value_get_string(arguments->at(flutter::EncodableValue("receiverID")));
        auto senderID = zego_value_get_string(arguments->at(flutter::EncodableValue("senderID")));
        char* operationID_cs = const_cast<char*>(operationID.c_str());
@ -266,7 +269,7 @@ void MessageManagerService::insertGroupMessageToLocalStorage(
    std::shared_ptr<flutter::MethodResult<flutter::EncodableValue>> result) {
    if (arguments) {
        auto operationID = zego_value_get_string(arguments->at(flutter::EncodableValue("operationID")));
-        auto message = zego_value_get_string(arguments->at(flutter::EncodableValue("message")));
+        auto message = value_2_json(arguments->at(flutter::EncodableValue("message")));
        auto groupID = zego_value_get_string(arguments->at(flutter::EncodableValue("groupID")));
        auto channelID = zego_value_get_string(arguments->at(flutter::EncodableValue("channelID")));
        auto senderID = zego_value_get_string(arguments->at(flutter::EncodableValue("senderID")));
@ -288,7 +291,7 @@ void MessageManagerService::markMessagesAsReadByMsgID(
    if (arguments) {
        auto operationID = zego_value_get_string(arguments->at(flutter::EncodableValue("operationID")));
        auto conversationID = zego_value_get_string(arguments->at(flutter::EncodableValue("conversationID")));
-        auto messageIDList = zego_value_get_string(arguments->at(flutter::EncodableValue("messageIDList")));
+        auto messageIDList = value_2_json(arguments->at(flutter::EncodableValue("messageIDList")));
        char* operationID_cs = const_cast<char*>(operationID.c_str());
        char* conversationID_cs = const_cast<char*>(conversationID.c_str());
        char* messageIDList_cs = const_cast<char*>(messageIDList.c_str());
@ -338,9 +341,9 @@ void MessageManagerService::createTextAtMessage(
    if (arguments) {
        auto operationID = zego_value_get_string(arguments->at(flutter::EncodableValue("operationID")));
        auto text = zego_value_get_string(arguments->at(flutter::EncodableValue("text")));
-        auto atUserIDList = zego_value_get_string(arguments->at(flutter::EncodableValue("atUserIDList")));
-        auto atUserInfoList = zego_value_get_string(arguments->at(flutter::EncodableValue("atUserInfoList")));
-        auto quoteMessage = zego_value_get_string(arguments->at(flutter::EncodableValue("quoteMessage")));
+        auto atUserIDList = value_2_json(arguments->at(flutter::EncodableValue("atUserIDList")));
+        auto atUserInfoList = value_2_json(arguments->at(flutter::EncodableValue("atUserInfoList")));
+        auto quoteMessage = value_2_json(arguments->at(flutter::EncodableValue("quoteMessage")));
        char* operationID_cs = const_cast<char*>(operationID.c_str());
        char* text_cs = const_cast<char*>(text.c_str());
        char* atUserIDList_cs = const_cast<char*>(atUserIDList.c_str());
@ -503,9 +506,9 @@ void MessageManagerService::createMergerMessage(
    std::shared_ptr<flutter::MethodResult<flutter::EncodableValue>> result) {
    if (arguments) {
        auto operationID = zego_value_get_string(arguments->at(flutter::EncodableValue("operationID")));
-        auto messageList = zego_value_get_string(arguments->at(flutter::EncodableValue("messageList")));
+        auto messageList = value_2_json(arguments->at(flutter::EncodableValue("messageList")));
        auto title = zego_value_get_string(arguments->at(flutter::EncodableValue("title")));
-        auto summaryList = zego_value_get_string(arguments->at(flutter::EncodableValue("summaryList")));
+        auto summaryList = value_2_json(arguments->at(flutter::EncodableValue("summaryList")));
        char* operationID_cs = const_cast<char*>(operationID.c_str());
        char* messageList_cs = const_cast<char*>(messageList.c_str());
        char* title_cs = const_cast<char*>(title.c_str());
@ -523,7 +526,7 @@ void MessageManagerService::createForwardMessage(
    std::shared_ptr<flutter::MethodResult<flutter::EncodableValue>> result) {
    if (arguments) {
        auto operationID = zego_value_get_string(arguments->at(flutter::EncodableValue("operationID")));
-        auto message = zego_value_get_string(arguments->at(flutter::EncodableValue("message")));
+        auto message = value_2_json(arguments->at(flutter::EncodableValue("message")));
        char* operationID_cs = const_cast<char*>(operationID.c_str());
        char* message_cs = const_cast<char*>(message.c_str());

@ -579,7 +582,7 @@ void MessageManagerService::createQuoteMessage(
    if (arguments) {
        auto operationID = zego_value_get_string(arguments->at(flutter::EncodableValue("operationID")));
        auto quoteText = zego_value_get_string(arguments->at(flutter::EncodableValue("quoteText")));
-        auto quoteMessage = zego_value_get_string(arguments->at(flutter::EncodableValue("quoteMessage")));
+        auto quoteMessage = value_2_json(arguments->at(flutter::EncodableValue("quoteMessage")));
        char* operationID_cs = const_cast<char*>(operationID.c_str());
        char* quoteText_cs = const_cast<char*>(quoteText.c_str());
        char* quoteMessage_cs = const_cast<char*>(quoteMessage.c_str());
@ -596,7 +599,7 @@ void MessageManagerService::createCardMessage(
    std::shared_ptr<flutter::MethodResult<flutter::EncodableValue>> result) {
    if (arguments) {
        auto operationID = zego_value_get_string(arguments->at(flutter::EncodableValue("operationID")));
-        auto cardMessage = zego_value_get_string(arguments->at(flutter::EncodableValue("cardMessage")));
+        auto cardMessage = value_2_json(arguments->at(flutter::EncodableValue("cardMessage")));
        char* operationID_cs = const_cast<char*>(operationID.c_str());
        char* cardMessage_cs = const_cast<char*>(cardMessage.c_str());

@ -630,7 +633,7 @@ void MessageManagerService::createAdvancedTextMessage(
    if (arguments) {
        auto operationID = zego_value_get_string(arguments->at(flutter::EncodableValue("operationID")));
        auto text = zego_value_get_string(arguments->at(flutter::EncodableValue("text")));
-        auto richMessageInfoList = zego_value_get_string(arguments->at(flutter::EncodableValue("richMessageInfoList")));
+        auto richMessageInfoList = value_2_json(arguments->at(flutter::EncodableValue("richMessageInfoList")));
        char* operationID_cs = const_cast<char*>(operationID.c_str());
        char* text_cs = const_cast<char*>(text.c_str());
        char* richMessageInfoList_cs = const_cast<char*>(richMessageInfoList.c_str());
@ -648,8 +651,8 @@ void MessageManagerService::createAdvancedQuoteMessage(
    if (arguments) {
        auto operationID = zego_value_get_string(arguments->at(flutter::EncodableValue("operationID")));
        auto quoteText = zego_value_get_string(arguments->at(flutter::EncodableValue("quoteText")));
-        auto quoteMessage = zego_value_get_string(arguments->at(flutter::EncodableValue("quoteMessage")));
-        auto richMessageInfoList = zego_value_get_string(arguments->at(flutter::EncodableValue("richMessageInfoList")));
+        auto quoteMessage = value_2_json(arguments->at(flutter::EncodableValue("quoteMessage")));
+        auto richMessageInfoList = value_2_json(arguments->at(flutter::EncodableValue("richMessageInfoList")));
        char* operationID_cs = const_cast<char*>(operationID.c_str());
        char* quoteText_cs = const_cast<char*>(quoteText.c_str());
        char* quoteMessage_cs = const_cast<char*>(quoteMessage.c_str());
@ -667,7 +670,7 @@ void MessageManagerService::searchLocalMessages(
    std::shared_ptr<flutter::MethodResult<flutter::EncodableValue>> result) {
    if (arguments) {
        auto operationID = zego_value_get_string(arguments->at(flutter::EncodableValue("operationID")));
-        auto filter = zego_value_get_string(arguments->at(flutter::EncodableValue("filter")));
+        auto filter = value_2_json(arguments->at(flutter::EncodableValue("filter")));
        char* operationID_cs = const_cast<char*>(operationID.c_str());
        char* filter_cs = const_cast<char*>(filter.c_str());

@ -727,7 +730,7 @@ void MessageManagerService::findMessageList(
    std::shared_ptr<flutter::MethodResult<flutter::EncodableValue>> result) {
    if (arguments) {
        auto operationID = zego_value_get_string(arguments->at(flutter::EncodableValue("operationID")));
-        auto searchParams = zego_value_get_string(arguments->at(flutter::EncodableValue("searchParams")));
+        auto searchParams = value_2_json(arguments->at(flutter::EncodableValue("searchParams")));
        char* operationID_cs = const_cast<char*>(operationID.c_str());
        char* searchParams_cs = const_cast<char*>(searchParams.c_str());

@ -775,13 +778,16 @@ void MessageManagerService::sendMessageNotOss(
    std::shared_ptr<flutter::MethodResult<flutter::EncodableValue>> result) {
    if (arguments) {
        auto operationID = zego_value_get_string(arguments->at(flutter::EncodableValue("operationID")));
-        auto message = zego_value_get_string(arguments->at(flutter::EncodableValue("message")));
+        auto message = value_2_json(arguments->at(flutter::EncodableValue("message")));
        auto userID = zego_value_get_string(arguments->at(flutter::EncodableValue("userID")));
        auto groupID = zego_value_get_string(arguments->at(flutter::EncodableValue("groupID")));
        auto channelId = zego_value_get_string(arguments->at(flutter::EncodableValue("channelId")));
-        auto offlinePushInfo = zego_value_get_string(arguments->at(flutter::EncodableValue("offlinePushInfo")));
-        auto clientMsgID = zego_value_get_string(arguments->at(flutter::EncodableValue("clientMsgID")));
+        auto offlinePushInfo = value_2_json(arguments->at(flutter::EncodableValue("offlinePushInfo")));
        auto isOnlineOnly = zego_value_get_bool(arguments->at(flutter::EncodableValue("isOnlineOnly")));
+        
+        auto json = EncodableValueToJson(arguments->at(flutter::EncodableValue("message")));
+        auto clientMsgID = json["clientMsgID"].get<std::string>();
+
        char* operationID_cs = const_cast<char*>(operationID.c_str());
        char* message_cs = const_cast<char*>(message.c_str());
        char* userID_cs = const_cast<char*>(userID.c_str());
@ -801,9 +807,9 @@ void MessageManagerService::createImageMessageByURL(
    if (arguments) {
        auto operationID = zego_value_get_string(arguments->at(flutter::EncodableValue("operationID")));
        auto sourcePath = zego_value_get_string(arguments->at(flutter::EncodableValue("sourcePath")));
-        auto sourcePicture = zego_value_get_string(arguments->at(flutter::EncodableValue("sourcePicture")));
-        auto bigPicture = zego_value_get_string(arguments->at(flutter::EncodableValue("bigPicture")));
-        auto snapshotPicture = zego_value_get_string(arguments->at(flutter::EncodableValue("snapshotPicture")));
+        auto sourcePicture = value_2_json(arguments->at(flutter::EncodableValue("sourcePicture")));
+        auto bigPicture = value_2_json(arguments->at(flutter::EncodableValue("bigPicture")));
+        auto snapshotPicture = value_2_json(arguments->at(flutter::EncodableValue("snapshotPicture")));
        char* operationID_cs = const_cast<char*>(operationID.c_str());
        char* sourcePath_cs = const_cast<char*>(sourcePath.c_str());
        char* sourcePicture_cs = const_cast<char*>(sourcePicture.c_str());
@ -822,7 +828,7 @@ void MessageManagerService::createSoundMessageByURL(
    std::shared_ptr<flutter::MethodResult<flutter::EncodableValue>> result) {
    if (arguments) {
        auto operationID = zego_value_get_string(arguments->at(flutter::EncodableValue("operationID")));
-        auto soundElem = zego_value_get_string(arguments->at(flutter::EncodableValue("soundElem")));
+        auto soundElem = value_2_json(arguments->at(flutter::EncodableValue("soundElem")));
        char* operationID_cs = const_cast<char*>(operationID.c_str());
        char* soundElem_cs = const_cast<char*>(soundElem.c_str());

@ -838,7 +844,7 @@ void MessageManagerService::createVideoMessageByURL(
    std::shared_ptr<flutter::MethodResult<flutter::EncodableValue>> result) {
    if (arguments) {
        auto operationID = zego_value_get_string(arguments->at(flutter::EncodableValue("operationID")));
-        auto videoElem = zego_value_get_string(arguments->at(flutter::EncodableValue("videoElem")));
+        auto videoElem = value_2_json(arguments->at(flutter::EncodableValue("videoElem")));
        char* operationID_cs = const_cast<char*>(operationID.c_str());
        char* videoElem_cs = const_cast<char*>(videoElem.c_str());

@ -854,7 +860,7 @@ void MessageManagerService::createFileMessageByURL(
    std::shared_ptr<flutter::MethodResult<flutter::EncodableValue>> result) {
    if (arguments) {
        auto operationID = zego_value_get_string(arguments->at(flutter::EncodableValue("operationID")));
-        auto fileElem = zego_value_get_string(arguments->at(flutter::EncodableValue("fileElem")));
+        auto fileElem = value_2_json(arguments->at(flutter::EncodableValue("fileElem")));
        char* operationID_cs = const_cast<char*>(operationID.c_str());
        char* fileElem_cs = const_cast<char*>(fileElem.c_str());

@ -870,7 +876,7 @@ void MessageManagerService::fetchSurroundingMessages(
    std::shared_ptr<flutter::MethodResult<flutter::EncodableValue>> result) {
    if (arguments) {
        auto operationID = zego_value_get_string(arguments->at(flutter::EncodableValue("operationID")));
-        auto message = zego_value_get_string(arguments->at(flutter::EncodableValue("message")));
+        auto message = value_2_json(arguments->at(flutter::EncodableValue("message")));
        auto before = zego_value_get_int(arguments->at(flutter::EncodableValue("before")));
        auto after = zego_value_get_int(arguments->at(flutter::EncodableValue("after")));
        char* operationID_cs = const_cast<char*>(operationID.c_str());
--- a/windows/src/common/services/MessageManager.h
+++ b/windows/src/common/services/MessageManager.h
@ -10,10 +10,10 @@ class MessageManagerService : public FLTService {
 public:
 	MessageManagerService();

-  void onMethodCalled(
-      const std::string& method,
-      const flutter::EncodableMap* arguments,
-      std::shared_ptr<flutter::MethodResult<flutter::EncodableValue>> result);
+	virtual void onMethodCalled(
+		const std::string& method, const flutter::EncodableMap* arguments,
+		std::shared_ptr<flutter::MethodResult<flutter::EncodableValue>> result)
+		override;

 	// Method handlers
 	void setAdvancedMsgListener(
@ -152,8 +152,7 @@ public:
 		const flutter::EncodableMap* arguments,
 		std::shared_ptr<flutter::MethodResult<flutter::EncodableValue>> result);

-private:
-  std::string m_serviceName;
+
 };

 #endif // MESSAGE_MANAGER_SERVICE_H
--- a/windows/src/common/services/UserManager.cpp
+++ b/windows/src/common/services/UserManager.cpp
@ -15,21 +15,29 @@ void UserManagerService::onMethodCalled(
 	std::shared_ptr<flutter::MethodResult<flutter::EncodableValue>> result) {
 	if (method == "setUserListener") {
 		setUserListener(arguments, result);
-    } else if (method == "getUsersInfo") {
+	}
+	else if (method == "getUsersInfo") {
 		getUsersInfo(arguments, result);
-    } else if (method == "setSelfInfo") {
+	}
+	else if (method == "setSelfInfo") {
 		setSelfInfo(arguments, result);
-    } else if (method == "getSelfUserInfo") {
+	}
+	else if (method == "getSelfUserInfo") {
 		getSelfUserInfo(arguments, result);
-    } else if (method == "subscribeUsersStatus") {
+	}
+	else if (method == "subscribeUsersStatus") {
 		subscribeUsersStatus(arguments, result);
-    } else if (method == "unsubscribeUsersStatus") {
+	}
+	else if (method == "unsubscribeUsersStatus") {
 		unsubscribeUsersStatus(arguments, result);
-    } else if (method == "getSubscribeUsersStatus") {
+	}
+	else if (method == "getSubscribeUsersStatus") {
 		getSubscribeUsersStatus(arguments, result);
-    } else if (method == "getUserStatus") {
+	}
+	else if (method == "getUserStatus") {
 		getUserStatus(arguments, result);
-    } else {
+	}
+	else {
 		result->NotImplemented();
 	}
 }
@ -40,7 +48,8 @@ void UserManagerService::setUserListener(
 	if (arguments) {
 		set_user_listener(NewUserListenCallBack());
 		result->Success(flutter::EncodableValue());
-    } else {
+	}
+	else {
 		result->Error("INVALID_ARGUMENT", "Arguments cannot be null");
 	}
 }
@ -50,12 +59,13 @@ void UserManagerService::getUsersInfo(
 	std::shared_ptr<flutter::MethodResult<flutter::EncodableValue>> result) {
 	if (arguments) {
 		auto operationID = zego_value_get_string(arguments->at(flutter::EncodableValue("operationID")));
-        auto userIDList = zego_value_get_string(arguments->at(flutter::EncodableValue("userIDList")));
+		auto userIDList = value_2_json(arguments->at(flutter::EncodableValue("userIDList")));
 		char* operationID_cs = const_cast<char*>(operationID.c_str());
 		char* userIDList_cs = const_cast<char*>(userIDList.c_str());

 		get_users_info(NewBaseCallBack(result), operationID_cs, userIDList_cs);
-    } else {
+	}
+	else {
 		result->Error("INVALID_ARGUMENT", "Arguments cannot be null");
 	}
 }
@ -70,7 +80,8 @@ void UserManagerService::setSelfInfo(
 		char* userInfo_cs = const_cast<char*>(userInfo.c_str());

 		set_self_info(NewBaseCallBack(result), operationID_cs, userInfo_cs);
-    } else {
+	}
+	else {
 		result->Error("INVALID_ARGUMENT", "Arguments cannot be null");
 	}
 }
@ -83,7 +94,8 @@ void UserManagerService::getSelfUserInfo(
 		char* operationID_cs = const_cast<char*>(operationID.c_str());

 		get_self_user_info(NewBaseCallBack(result), operationID_cs);
-    } else {
+	}
+	else {
 		result->Error("INVALID_ARGUMENT", "Arguments cannot be null");
 	}
 }
@ -93,12 +105,13 @@ void UserManagerService::subscribeUsersStatus(
 	std::shared_ptr<flutter::MethodResult<flutter::EncodableValue>> result) {
 	if (arguments) {
 		auto operationID = zego_value_get_string(arguments->at(flutter::EncodableValue("operationID")));
-        auto userIDs = zego_value_get_string(arguments->at(flutter::EncodableValue("userIDs")));
+		auto userIDs = value_2_json(arguments->at(flutter::EncodableValue("userIDs")));
 		char* operationID_cs = const_cast<char*>(operationID.c_str());
 		char* userIDs_cs = const_cast<char*>(userIDs.c_str());

 		subscribe_users_status(NewBaseCallBack(result), operationID_cs, userIDs_cs);
-    } else {
+	}
+	else {
 		result->Error("INVALID_ARGUMENT", "Arguments cannot be null");
 	}
 }
@ -108,12 +121,13 @@ void UserManagerService::unsubscribeUsersStatus(
 	std::shared_ptr<flutter::MethodResult<flutter::EncodableValue>> result) {
 	if (arguments) {
 		auto operationID = zego_value_get_string(arguments->at(flutter::EncodableValue("operationID")));
-        auto userIDs = zego_value_get_string(arguments->at(flutter::EncodableValue("userIDs")));
+		auto userIDs = value_2_json(arguments->at(flutter::EncodableValue("userIDs")));
 		char* operationID_cs = const_cast<char*>(operationID.c_str());
 		char* userIDs_cs = const_cast<char*>(userIDs.c_str());

 		unsubscribe_users_status(NewBaseCallBack(result), operationID_cs, userIDs_cs);
-    } else {
+	}
+	else {
 		result->Error("INVALID_ARGUMENT", "Arguments cannot be null");
 	}
 }
@ -126,7 +140,8 @@ void UserManagerService::getSubscribeUsersStatus(
 		char* operationID_cs = const_cast<char*>(operationID.c_str());

 		get_subscribe_users_status(NewBaseCallBack(result), operationID_cs);
-    } else {
+	}
+	else {
 		result->Error("INVALID_ARGUMENT", "Arguments cannot be null");
 	}
 }
@ -136,12 +151,13 @@ void UserManagerService::getUserStatus(
 	std::shared_ptr<flutter::MethodResult<flutter::EncodableValue>> result) {
 	if (arguments) {
 		auto operationID = zego_value_get_string(arguments->at(flutter::EncodableValue("operationID")));
-        auto userIDs = zego_value_get_string(arguments->at(flutter::EncodableValue("userIDs")));
+		auto userIDs = value_2_json(arguments->at(flutter::EncodableValue("userIDs")));
 		char* operationID_cs = const_cast<char*>(operationID.c_str());
 		char* userIDs_cs = const_cast<char*>(userIDs.c_str());

 		get_user_status(NewBaseCallBack(result), operationID_cs, userIDs_cs);
-    } else {
+	}
+	else {
 		result->Error("INVALID_ARGUMENT", "Arguments cannot be null");
 	}
 }
--- a/windows/src/common/services/UserManager.h
+++ b/windows/src/common/services/UserManager.h
@ -11,10 +11,10 @@ class UserManagerService : public FLTService {
 public:
 	UserManagerService();

-  void onMethodCalled(
-      const std::string& method,
-      const flutter::EncodableMap* arguments,
-      std::shared_ptr<flutter::MethodResult<flutter::EncodableValue>> result);
+	virtual void onMethodCalled(
+		const std::string& method, const flutter::EncodableMap* arguments,
+		std::shared_ptr<flutter::MethodResult<flutter::EncodableValue>> result)
+		override;

 	// Method handlers
 	void setUserListener(
@ -42,8 +42,7 @@ public:
 		const flutter::EncodableMap* arguments,
 		std::shared_ptr<flutter::MethodResult<flutter::EncodableValue>> result);

-private:
-  std::string m_serviceName;
+
 };

 #endif // USER_MANAGER_SERVICE_H
Author	SHA1	Message	Date
gem	cdc12e513c	增加配置支持35	2025-06-30 14:30:52 +08:00
cpdl	ee0cea6c2b	no message	2025-05-07 17:35:06 +08:00
cpdl	b2c3c09c20	no message	2025-05-07 17:01:30 +08:00
cpdl	114980dab0	no message	2025-05-07 16:01:31 +08:00
cpdl	1af1ecfbb9	no message	2025-05-07 11:27:33 +08:00