feat: Add GetWeChatUser API
This commit is contained in:
parent
dead8cfc93
commit
1857cc66e4
|
|
@ -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");
|
||||
}
|
||||
|
|
|
|||
|
|
@ -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;
|
||||
}
|
||||
|
||||
}
|
||||
Loading…
Reference in a new issue