340 lines
14 KiB
C#
340 lines
14 KiB
C#
// Copyright (c) 2022-Now 少林寺驻北固山办事处大神父王喇嘛
|
|
//
|
|
// SimpleAdmin 基于 Apache License Version 2.0 协议发布，可用于商业项目，但必须遵守以下补充条款:
|
|
// 1.请不要删除和修改根目录下的LICENSE文件。
|
|
// 2.请不要删除和修改SimpleAdmin源码头部的版权声明。
|
|
// 3.分发源码时候，请注明软件出处 https://gitee.com/dotnetmoyu/SimpleAdmin
|
|
// 4.基于本软件的作品，只能使用 SimpleAdmin 作为后台服务，除外情况不可商用且不允许二次分发或开源。
|
|
// 5.请不得将本软件应用于危害国家安全、荣誉和利益的行为，不能以任何形式用于非法为目的的行为。
|
|
// 6.任何基于本软件而产生的一切法律纠纷和责任，均于我司无关。
|
|
|
|
using Masuit.Tools.DateTimeExt;
|
|
|
|
namespace SimpleAdmin.System;
|
|
|
|
/// <summary>
|
|
/// <inheritdoc cref="IMessageService"/>
|
|
/// </summary>
|
|
public class MessageService : DbRepository<SysMessage>, IMessageService
|
|
{
|
|
private readonly ILogger<MessageService> _logger;
|
|
private readonly ISimpleCacheService _simpleCacheService;
|
|
private readonly IRelationService _relationService;
|
|
private readonly IEventPublisher _eventPublisher;
|
|
|
|
public MessageService(ILogger<MessageService> logger, ISimpleCacheService simpleCacheService, IRelationService relationService,
|
|
IEventPublisher eventPublisher)
|
|
{
|
|
_logger = logger;
|
|
_simpleCacheService = simpleCacheService;
|
|
_relationService = relationService;
|
|
_eventPublisher = eventPublisher;
|
|
}
|
|
|
|
/// <inheritdoc />
|
|
public async Task<SqlSugarPagedList<SysMessage>> Page(MessagePageInput input)
|
|
{
|
|
var query = Context.Queryable<SysMessage>().WhereIF(!string.IsNullOrEmpty(input.Category), it => it.Category == input.Category)//根据分类查询
|
|
.WhereIF(!string.IsNullOrEmpty(input.SearchKey),
|
|
it => it.Subject.Contains(input.SearchKey) || it.Content.Contains(input.SearchKey))//根据关键字查询
|
|
.OrderByIF(!string.IsNullOrEmpty(input.SortField), $"{input.SortField} {input.SortOrder}")//排序
|
|
.OrderBy(it => it.CreateTime, OrderByType.Desc);
|
|
|
|
var pageInfo = await query.ToPagedListAsync(input.PageNum, input.PageSize);//分页
|
|
return pageInfo;
|
|
}
|
|
|
|
/// <inheritdoc />
|
|
public async Task<SqlSugarPagedList<SysMessage>> MyMessagePage(MessagePageInput input, long userId)
|
|
{
|
|
var query = Context.Queryable<SysMessageUser>().LeftJoin<SysMessage>((u, m) => u.MessageId == m.Id)
|
|
.Where((u, m) => u.IsDelete == false && u.UserId == userId && u.Status == SysDictConst.MESSAGE_STATUS_ALREADY)
|
|
.WhereIF(!string.IsNullOrEmpty(input.Category), (u, m) => m.Category == input.Category)//根据分类查询
|
|
.WhereIF(!string.IsNullOrEmpty(input.SearchKey),
|
|
(u, m) => m.Subject.Contains(input.SearchKey) || m.Content.Contains(input.SearchKey))//根据关键字查询
|
|
.OrderBy((u, m) => u.Read).OrderBy((u, m) => u.CreateTime, OrderByType.Desc).Select((u, m) => new SysMessage
|
|
{
|
|
Id = m.Id.SelectAll(),
|
|
Read = u.Read
|
|
});
|
|
var pageInfo = await query.ToPagedListAsync(input.PageNum, input.PageSize);//分页
|
|
return pageInfo;
|
|
}
|
|
|
|
/// <inheritdoc />
|
|
public async Task Add(MessageSendInput input)
|
|
{
|
|
CheckInput(input);
|
|
var sysMessage = input.Adapt<SysMessage>();//实体转换
|
|
sysMessage.Id = CommonUtils.GetSingleId();
|
|
//如果是立即发送的直接修改状态
|
|
if (sysMessage.SendWay == SysDictConst.SEND_WAY_NOW)
|
|
sysMessage.Status = SysDictConst.MESSAGE_STATUS_ALREADY;//已发送
|
|
var messageUsers = new List<SysMessageUser>();
|
|
var userIds = new List<long>();
|
|
//根据接收人获取需要发送的用户id
|
|
switch (sysMessage.ReceiverType)
|
|
{
|
|
case SysDictConst.RECEIVER_TYPE_ALL:
|
|
userIds = await Context.Queryable<SysUser>().Select(it => it.Id).ToListAsync();
|
|
break;
|
|
case SysDictConst.RECEIVER_TYPE_ROLE:
|
|
var roleIds = sysMessage.ReceiverInfo.Select(it => it.Id.ToString()).ToList();//获取角色ID列表
|
|
var roleUsers =
|
|
await _relationService.GetRelationListByTargetIdListAndCategory(roleIds, CateGoryConst.RELATION_SYS_USER_HAS_ROLE);//获取角色用户列表
|
|
userIds = roleUsers.Select(it => it.ObjectId).ToList();//获取用户ID列表
|
|
break;
|
|
case SysDictConst.RECEIVER_TYPE_APPOINT:
|
|
userIds = sysMessage.ReceiverInfo.Select(it => it.Id).ToList();
|
|
break;
|
|
}
|
|
//去掉自己
|
|
userIds = userIds.Where(it => it != UserManager.UserId).ToList();
|
|
|
|
//遍历用户ID
|
|
userIds.ForEach(userId =>
|
|
{
|
|
messageUsers.Add(new SysMessageUser
|
|
{
|
|
MessageId = sysMessage.Id,
|
|
UserId = userId,
|
|
Read = false,
|
|
IsDelete = false,
|
|
Status = sysMessage.SendWay == SysDictConst.SEND_WAY_NOW ? SysDictConst.MESSAGE_STATUS_ALREADY : SysDictConst.MESSAGE_STATUS_READY
|
|
});
|
|
});
|
|
//事务
|
|
var result = await Tenant.UseTranAsync(async () =>
|
|
{
|
|
await InsertAsync(sysMessage);//添加消息
|
|
await Context.Insertable(messageUsers).ExecuteCommandAsync();
|
|
});
|
|
if (result.IsSuccess)//如果成功了
|
|
{
|
|
await _eventPublisher.PublishAsync(EventSubscriberConst.NEW_MESSAGE, new NewMessageEvent
|
|
{
|
|
Id = sysMessage.Id,
|
|
SendWay = sysMessage.SendWay,
|
|
SendTime = sysMessage.SendTime
|
|
});//通知用户有新的消息
|
|
}
|
|
else
|
|
{
|
|
//写日志
|
|
_logger.LogError(result.ErrorMessage, result.ErrorException);
|
|
throw Oops.Oh(ErrorCodeEnum.A0003);
|
|
}
|
|
}
|
|
|
|
/// <inheritdoc />
|
|
public async Task Edit(MessageSendUpdateInput input)
|
|
{
|
|
CheckInput(input);
|
|
var sysMessage = input.Adapt<SysMessage>();//实体转换
|
|
await UpdateAsync(sysMessage);//更新数据
|
|
}
|
|
|
|
|
|
|
|
|
|
/// <inheritdoc />
|
|
public async Task<SysMessage> Detail(MessageDetailInput input)
|
|
{
|
|
//获取消息
|
|
var message = await GetFirstAsync(it => it.Id == input.Id);
|
|
if (message != null && message.SendWay == SysDictConst.SEND_WAY_DELAY)
|
|
{
|
|
//delayTime等于发送时间减掉创建时间
|
|
message.DelayTime = (int)(message.SendTime.GetTotalSeconds() - message.CreateTime.Value.GetTotalSeconds());
|
|
}
|
|
if (message != null && input.ShowReceiveInfo)
|
|
{
|
|
var messageUserRep = ChangeRepository<DbRepository<SysMessageUser>>();//切换仓储
|
|
var messageUsers = await messageUserRep.GetListAsync(it => it.MessageId == message.Id);
|
|
|
|
var userIds = messageUsers.Select(it => it.UserId).ToList();//获取用户ID列表
|
|
var userInfos = await Context.Queryable<SysUser>().Where(it => userIds.Contains(it.Id)).Select(it => new { it.Id, it.Name })
|
|
.ToListAsync();//获取用户姓名信息列表
|
|
//遍历关系
|
|
messageUsers.ForEach(messageUser =>
|
|
{
|
|
var user = userInfos.Where(u => u.Id == messageUser.UserId).FirstOrDefault();//获取用户信息
|
|
if (user != null)
|
|
{
|
|
//添加到已读列表
|
|
message.ReceiverDetail.Add(new ReceiverDetail
|
|
{
|
|
Id = user.Id,
|
|
Name = user.Name,
|
|
Read = messageUser.Read
|
|
});
|
|
}
|
|
});
|
|
}
|
|
//设置已读
|
|
if (input.Read)
|
|
{
|
|
await Context.Updateable<SysMessageUser>()
|
|
.SetColumns(it => it.Read == true)
|
|
.SetColumns(it => it.UpdateTime == DateTime.Now)
|
|
.Where(it => it.MessageId == input.Id && it.Read == false && it.UserId == UserManager.UserId).ExecuteCommandAsync();
|
|
}
|
|
return message;
|
|
}
|
|
|
|
|
|
|
|
|
|
/// <inheritdoc />
|
|
public async Task Delete(BaseIdListInput input)
|
|
{
|
|
//获取所有ID
|
|
var ids = input.Ids;
|
|
if (ids.Count > 0)
|
|
{
|
|
//事务
|
|
var result = await Tenant.UseTranAsync(async () =>
|
|
{
|
|
await DeleteAsync(it => ids.Contains(it.Id));
|
|
await Context.Deleteable<SysMessageUser>().Where(it => ids.Contains(it.MessageId)).ExecuteCommandAsync();
|
|
});
|
|
if (!result.IsSuccess)//如果失败了
|
|
{
|
|
//写日志
|
|
_logger.LogError(result.ErrorMessage, result.ErrorException);
|
|
throw Oops.Oh(ErrorCodeEnum.A0002);
|
|
}
|
|
}
|
|
}
|
|
|
|
/// <inheritdoc />
|
|
public async Task DeleteMyMessage(BaseIdInput input, long userId)
|
|
{
|
|
var messageUserRep = ChangeRepository<DbRepository<SysMessageUser>>();//切换仓储
|
|
await Context.Deleteable<SysMessageUser>().Where(it => it.UserId == userId && it.MessageId == input.Id).IsLogic().ExecuteCommandAsync();//逻辑删除
|
|
}
|
|
|
|
/// <inheritdoc />
|
|
public async Task<List<MessageUnReadOutPut>> UnReadCount(long userId)
|
|
{
|
|
// 连表查询未读
|
|
var unReadList = await Context.Queryable<SysMessage>().LeftJoin<SysMessageUser>((m, u) => u.MessageId == m.Id)
|
|
.Where((m, u) => u.UserId == userId && u.Read == false && u.IsDelete == false)
|
|
.Select<SysMessage>().ToListAsync();
|
|
//根据消息分类分组
|
|
var groupList = unReadList.GroupBy(it => it.Category).Select(it => new MessageUnReadOutPut
|
|
{
|
|
Category = it.Key,
|
|
UnReadCount = it.Count()
|
|
}).ToList();
|
|
return groupList;
|
|
}
|
|
|
|
/// <inheritdoc />
|
|
public async Task<List<SysMessage>> NewUnRead(long userId)
|
|
{
|
|
//根据消息分类分组,获取每组未读前五条
|
|
var result = await Context.Queryable<SysMessage>().LeftJoin<SysMessageUser>((m, u) => u.MessageId == m.Id)
|
|
.Where((m, u) => u.UserId == userId && u.IsDelete == false && u.Status == SysDictConst.MESSAGE_STATUS_ALREADY)
|
|
.Select((m, u) => new SysMessage
|
|
{
|
|
Index2 = SqlFunc.RowNumber($"{m.Id} desc",
|
|
m.Category),//order by id partition by name，参考sqlsugar分组查询https://www.donet5.com/Doc/1/2243
|
|
Subject = m.Subject,
|
|
CreateTime = m.CreateTime,
|
|
SendTime = m.SendTime,
|
|
Category = m.Category,
|
|
Read = u.Read
|
|
})
|
|
.MergeTable()//将结果合并成一个表
|
|
.Where(it => it.Index2 <= 5)//取第五条
|
|
.Mapper(it =>
|
|
{
|
|
it.SendTimeFormat = TimeHelper.FormatTimeAgo(it.SendTime);
|
|
})
|
|
.ToListAsync();
|
|
return result;
|
|
}
|
|
|
|
/// <inheritdoc />
|
|
public async Task<int> SetRead(MessageReadInput input)
|
|
{
|
|
//如果ID列表为空，就是全部已读
|
|
if (input.Ids.Count == 0 && input.Category != null)
|
|
{
|
|
var result = await Context.Updateable<SysMessageUser>()
|
|
.SetColumns(it => it.Read == true)
|
|
.SetColumns(it => it.UpdateTime == DateTime.Now)
|
|
.Where(it => it.UserId == UserManager.UserId && it.Read == false)
|
|
.Where(it => SqlFunc.Subqueryable<SysMessage>().Where(s => s.Id == it.MessageId && s.Category == input.Category).Any())
|
|
.ExecuteCommandAsync();
|
|
return result;
|
|
}
|
|
else
|
|
{
|
|
return await Context.Updateable<SysMessageUser>()
|
|
.SetColumns(it => it.Read == true)
|
|
.SetColumns(it => it.UpdateTime == DateTime.Now)
|
|
.Where(it => it.UserId == UserManager.UserId && input.Ids.Contains(it.MessageId))
|
|
.Where(it => it.Read == false)
|
|
.ExecuteCommandAsync();
|
|
}
|
|
}
|
|
|
|
/// <inheritdoc />
|
|
public async Task<int> SetDelete(MessageReadInput input)
|
|
{
|
|
//如果ID列表为空，就是全部删除
|
|
if (input.Ids.Count == 0 && input.Category != null)
|
|
{
|
|
var result = await Context.Updateable<SysMessageUser>()
|
|
.SetColumns(it => it.IsDelete == true)
|
|
.SetColumns(it => it.UpdateTime == DateTime.Now)
|
|
.Where(it => it.UserId == UserManager.UserId && it.IsDelete == false)
|
|
.Where(it => SqlFunc.Subqueryable<SysMessage>().Where(s => s.Id == it.MessageId && s.Category == input.Category).Any())
|
|
.ExecuteCommandAsync();
|
|
return result;
|
|
}
|
|
else
|
|
{
|
|
return await Context.Updateable<SysMessageUser>()
|
|
.SetColumns(it => it.IsDelete == true)
|
|
.SetColumns(it => it.UpdateTime == DateTime.Now)
|
|
.Where(it => it.UserId == UserManager.UserId && input.Ids.Contains(it.MessageId))
|
|
.Where(it => it.IsDelete == false)
|
|
.ExecuteCommandAsync();
|
|
}
|
|
}
|
|
|
|
#region 方法
|
|
|
|
/// <summary>
|
|
/// 检查输入
|
|
/// </summary>
|
|
/// <param name="input"></param>
|
|
private void CheckInput(MessageSendInput input)
|
|
{
|
|
if (input.Status == SysDictConst.MESSAGE_STATUS_ALREADY)
|
|
throw Oops.Oh("已发送的消息不能修改");
|
|
switch (input.SendWay)
|
|
{
|
|
case SysDictConst.SEND_WAY_NOW:
|
|
input.SendTime = DateTime.Now;
|
|
break;
|
|
case SysDictConst.SEND_WAY_DELAY:
|
|
if (input.CreateTime != null)
|
|
input.SendTime = input.CreateTime.Value.AddSeconds(input.DelayTime);
|
|
else
|
|
input.SendTime = DateTime.Now.AddSeconds(input.DelayTime);
|
|
break;
|
|
case SysDictConst.SEND_WAY_SCHEDULE:
|
|
if (input.SendTime < DateTime.Now)
|
|
throw Oops.Oh("发送时间不能小于当前时间");
|
|
input.SendTime = input.SendTime;
|
|
break;
|
|
}
|
|
}
|
|
|
|
#endregion
|
|
}
|