diff --git a/OpenAuth.App/SysMessage/SysMessageApp.cs b/OpenAuth.App/SysMessage/SysMessageApp.cs index 7faa7933..2cc94f9b 100644 --- a/OpenAuth.App/SysMessage/SysMessageApp.cs +++ b/OpenAuth.App/SysMessage/SysMessageApp.cs @@ -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 + public class SysMessageApp : SqlSugarBaseApp { private RevelanceManagerApp _revelanceApp; private readonly ILogger _logger; @@ -32,7 +30,7 @@ namespace OpenAuth.App } var result = new PagedDynamicDataResp(); - var objs = UnitWork.Find(u =>u.ToId == loginContext.User.Id && u.ToStatus != -1); + var objs = SugarClient.Queryable().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); } /// @@ -75,14 +73,14 @@ namespace OpenAuth.App } else { - sysUser = UnitWork.FirstOrDefault(u => u.Id == userId); + sysUser = SugarClient.Queryable().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 /// public void Read(ReadMsgReq req) { - UnitWork.Update(u => u.Id == req.Id, u => new SysMessage + Repository.Update(u => new SysMessage { ToStatus = 1 - }); + }, u => u.Id == req.Id); } /// /// 消息采用逻辑删除 @@ -112,15 +110,15 @@ namespace OpenAuth.App /// public void Del(string[] ids) { - UnitWork.Update(u => ids.Contains(u.Id), u => new SysMessage + Repository.Update(u => new SysMessage { ToStatus = -1 //逻辑删除 - }); + }, u => ids.Contains(u.Id)); } - public SysMessageApp(IUnitWork unitWork, IRepository repository, - RevelanceManagerApp app,IAuth auth, ILogger logger) : base(unitWork, repository, auth) + public SysMessageApp(ISqlSugarClient client, + RevelanceManagerApp app,IAuth auth, ILogger logger) : base(client, auth) { _revelanceApp = app; _logger = logger;