lsm/OpenAuth.Net
1
0
Fork 0
mirror of https://gitee.com/dotnetchina/OpenAuth.Net.git synced 2026-06-22 16:42:08 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

调整为SqlSugar

Browse Source
This commit is contained in:
yubaolee
2026-05-24 21:20:08 +08:00
parent ea658e3cba
commit 684b6e0fea
1 changed files with 12 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
OpenAuth.App/SysMessage/SysMessageApp.cs
View File

@@ -2,20 +2,18 @@
using System.Linq;
using System.Threading.Tasks;
using Infrastructure;
using Microsoft.EntityFrameworkCore;
using Microsoft.Extensions.Logging;
using OpenAuth.App.Interface;
using OpenAuth.App.Request;
using OpenAuth.App.Response;
using OpenAuth.Repository;
using OpenAuth.Repository.Domain;
using OpenAuth.Repository.Interface;
using Infrastructure.Helpers;
using SqlSugar;
namespace OpenAuth.App
{
public class SysMessageApp : BaseStringApp<SysMessage,OpenAuthDBContext>
public class SysMessageApp : SqlSugarBaseApp<SysMessage>
{
private RevelanceManagerApp _revelanceApp;
private readonly ILogger<SysMessageApp> _logger;
@@ -32,7 +30,7 @@ namespace OpenAuth.App
}
var result = new PagedDynamicDataResp();
var objs = UnitWork.Find<SysMessage>(u =>u.ToId == loginContext.User.Id && u.ToStatus != -1);
var objs = SugarClient.Queryable<SysMessage>().Where(u =>u.ToId == loginContext.User.Id && u.ToStatus != -1);
if (!string.IsNullOrEmpty(request.key))
{
@@ -54,7 +52,7 @@ namespace OpenAuth.App
public void Add(SysMessage obj)
{
Repository.Add(obj);
Repository.Insert(obj);
}
/// <summary>
@@ -75,14 +73,14 @@ namespace OpenAuth.App
}
else
{
sysUser = UnitWork.FirstOrDefault<SysUser>(u => u.Id == userId);
sysUser = SugarClient.Queryable<SysUser>().First(u => u.Id == userId);
}
if (sysUser == null)
{
_logger.LogError($"未能找到用户{userId},不能给该用户发送消息");
return;
}
Repository.Add(new SysMessage
Repository.Insert(new SysMessage
{
ToId = sysUser.Id,
ToName = sysUser.Name,
@@ -101,10 +99,10 @@ namespace OpenAuth.App
/// <param name="msgid"></param>
public void Read(ReadMsgReq req)
{
UnitWork.Update<SysMessage>(u => u.Id == req.Id, u => new SysMessage
Repository.Update(u => new SysMessage
{
ToStatus = 1
});
}, u => u.Id == req.Id);
}
/// <summary>
/// 消息采用逻辑删除
@@ -112,15 +110,15 @@ namespace OpenAuth.App
/// <param name="ids"></param>
public void Del(string[] ids)
{
UnitWork.Update<SysMessage>(u => ids.Contains(u.Id), u => new SysMessage
Repository.Update(u => new SysMessage
{
ToStatus = -1 //逻辑删除
});
}, u => ids.Contains(u.Id));
}
public SysMessageApp(IUnitWork<OpenAuthDBContext> unitWork, IRepository<SysMessage,OpenAuthDBContext> repository,
RevelanceManagerApp app,IAuth auth, ILogger<SysMessageApp> logger) : base(unitWork, repository, auth)
public SysMessageApp(ISqlSugarClient client,
RevelanceManagerApp app,IAuth auth, ILogger<SysMessageApp> logger) : base(client, auth)
{
_revelanceApp = app;
_logger = logger;