112 lines
4.5 KiB
C#
112 lines
4.5 KiB
C#
using Microsoft.AspNetCore.Http;
|
|
using Microsoft.AspNetCore.Mvc;
|
|
using Volo.Abp.Domain.Services;
|
|
using Volo.Abp.Users;
|
|
using Yi.Framework.Bbs.Domain.Entities.Forum;
|
|
using Yi.Framework.Bbs.Domain.Managers.ArticleImport;
|
|
using Yi.Framework.Bbs.Domain.Shared.Consts;
|
|
using Yi.Framework.Bbs.Domain.Shared.Enums;
|
|
using Yi.Framework.Bbs.Domain.Shared.Model;
|
|
using Yi.Framework.SqlSugarCore.Abstractions;
|
|
|
|
namespace Yi.Framework.Bbs.Domain.Managers
|
|
{
|
|
/// <summary>
|
|
/// 论坛模块的领域服务
|
|
/// </summary>
|
|
public class ForumManager : DomainService
|
|
{
|
|
public readonly ISqlSugarRepository<DiscussAggregateRoot, Guid> _discussRepository;
|
|
public readonly ISqlSugarRepository<PlateAggregateRoot, Guid> _plateEntityRepository;
|
|
public readonly ISqlSugarRepository<CommentAggregateRoot, Guid> _commentRepository;
|
|
public readonly ISqlSugarRepository<ArticleAggregateRoot, Guid> _articleRepository;
|
|
public ForumManager(ISqlSugarRepository<DiscussAggregateRoot, Guid> discussRepository, ISqlSugarRepository<PlateAggregateRoot, Guid> plateEntityRepository, ISqlSugarRepository<CommentAggregateRoot, Guid> commentRepository, ISqlSugarRepository<ArticleAggregateRoot, Guid> articleRepository)
|
|
{
|
|
_discussRepository = discussRepository;
|
|
_plateEntityRepository = plateEntityRepository;
|
|
_commentRepository = commentRepository;
|
|
_articleRepository = articleRepository;
|
|
}
|
|
|
|
//主题是不能直接创建的，需要由领域服务统一创建
|
|
public async Task<DiscussAggregateRoot> CreateDiscussAsync(DiscussAggregateRoot entity)
|
|
{
|
|
entity.CreationTime = DateTime.Now;
|
|
entity.AgreeNum = 0;
|
|
entity.SeeNum = 0;
|
|
return await _discussRepository.InsertReturnEntityAsync(entity);
|
|
}
|
|
|
|
public async Task<CommentAggregateRoot> CreateCommentAsync(Guid discussId, Guid parentId, Guid rootId, string content)
|
|
{
|
|
var entity = new CommentAggregateRoot(discussId);
|
|
entity.Content = content;
|
|
entity.ParentId = parentId;
|
|
entity.RootId = rootId;
|
|
return await _commentRepository.InsertReturnEntityAsync(entity);
|
|
}
|
|
|
|
/// <summary>
|
|
/// 校验主题查询权限
|
|
/// </summary>
|
|
/// <param name="discussId"></param>
|
|
/// <returns></returns>
|
|
/// <exception cref="UserFriendlyException"></exception>
|
|
public async Task VerifyDiscussPermissionAsync(Guid discussId,Guid? userId)
|
|
{
|
|
var discuss = await _discussRepository.GetFirstAsync(x => x.Id == discussId);
|
|
if (discuss is null)
|
|
{
|
|
throw new UserFriendlyException(DiscussConst.No_Exist);
|
|
}
|
|
|
|
if (discuss.PermissionType == DiscussPermissionTypeEnum.Oneself)
|
|
{
|
|
if (discuss.CreatorId != userId)
|
|
{
|
|
throw new UserFriendlyException(DiscussConst.Privacy);
|
|
}
|
|
}
|
|
|
|
if (discuss.PermissionType == DiscussPermissionTypeEnum.User)
|
|
{
|
|
if (discuss.CreatorId !=userId &&
|
|
!discuss.PermissionUserIds.Contains(userId?? Guid.Empty))
|
|
{
|
|
throw new UserFriendlyException(DiscussConst.Privacy);
|
|
}
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// 导入文章
|
|
/// </summary>
|
|
/// <param name="discussId"></param>
|
|
/// <param name="articleParentId"></param>
|
|
/// <param name="fileObjs"></param>
|
|
/// <param name="importType"></param>
|
|
/// <returns></returns>
|
|
public async Task PostImportAsync(Guid discussId,Guid articleParentId, List<FileObject> fileObjs, ArticleImportTypeEnum importType)
|
|
{
|
|
AbstractArticleImport abstractArticleImport = default;
|
|
switch (importType)
|
|
{
|
|
case ArticleImportTypeEnum.Default:
|
|
abstractArticleImport = new DefaultArticleImport();
|
|
|
|
break;
|
|
case ArticleImportTypeEnum.VuePress:
|
|
abstractArticleImport = new VuePressArticleImport();
|
|
break;
|
|
|
|
default: abstractArticleImport = new DefaultArticleImport(); break;
|
|
}
|
|
abstractArticleImport.SetLogger(LoggerFactory);
|
|
var articleHandled = abstractArticleImport.Import(discussId, articleParentId, fileObjs);
|
|
|
|
await _articleRepository.InsertManyAsync(articleHandled);
|
|
|
|
}
|
|
}
|
|
}
|