From 1857cc66e4c31005f2d667a9a2083937bb792284 Mon Sep 17 00:00:00 2001
From: AnonymousDotNet <18776095145@163.com>
Date: Thu, 12 Dec 2024 17:09:46 +0800
Subject: [PATCH] feat: Add GetWeChatUser API

---
 .../BotSharp.Plugin.MongoStorage/MongoDbContext.cs  |  5 ++++-
 .../Repository/MongoRepository.WeChatUser.cs        | 13 +++++++++++++
 2 files changed, 17 insertions(+), 1 deletion(-)
 create mode 100644 src/Plugins/BotSharp.Plugin.MongoStorage/Repository/MongoRepository.WeChatUser.cs

diff --git a/src/Plugins/BotSharp.Plugin.MongoStorage/MongoDbContext.cs b/src/Plugins/BotSharp.Plugin.MongoStorage/MongoDbContext.cs
index 89eb18ad..4c633dd9 100644
--- a/src/Plugins/BotSharp.Plugin.MongoStorage/MongoDbContext.cs
+++ b/src/Plugins/BotSharp.Plugin.MongoStorage/MongoDbContext.cs
@@ -36,7 +36,7 @@ public class MongoDbContext
                 Key = x.Split("=")[0],
                 Value = x.Split("=")[1]
             }).ToList();
-            
+
             var source = queries.FirstOrDefault(x => x.Key.IsEqualTo(DB_NAME_INDEX));
             if (source != null)
             {
@@ -168,4 +168,7 @@ public class MongoDbContext
 
     public IMongoCollection<CrontabItemDocument> CrontabItems
         => Database.GetCollection<CrontabItemDocument>($"{_collectionPrefix}_CronTabItems");
+
+    public IMongoCollection<WeChatUserDocument> WeChatUsers
+        => Database.GetCollection<WeChatUserDocument>($"{_collectionPrefix}_WeChatUsers");
 }
diff --git a/src/Plugins/BotSharp.Plugin.MongoStorage/Repository/MongoRepository.WeChatUser.cs b/src/Plugins/BotSharp.Plugin.MongoStorage/Repository/MongoRepository.WeChatUser.cs
new file mode 100644
index 00000000..81a325d4
--- /dev/null
+++ b/src/Plugins/BotSharp.Plugin.MongoStorage/Repository/MongoRepository.WeChatUser.cs
@@ -0,0 +1,13 @@
+using BotSharp.Abstraction.Users.Models;
+
+namespace BotSharp.Plugin.MongoStorage.Repository;
+
+public partial class MongoRepository
+{
+    public WeChatUser? GetWeChatUser(string openId)
+    {
+        var weChatUser = _dc.WeChatUsers.AsQueryable().FirstOrDefault(x => x.OpenId == openId);
+        return weChatUser != null ? weChatUser.ToWeChatUser() : null;
+    }
+
+}