424 lines
21 KiB
C#
424 lines
21 KiB
C#
|
||
using CloudBuilder.Core.DatabaseAccessor;
|
||
using CloudBuilder.Core.DatabaseAccessor.Entity;
|
||
using CloudBuilder.Core.Extensions;
|
||
using CloudBuilder.Core.Policy;
|
||
using CloudBuilder.Core.Service;
|
||
using CloudBuilder.Master.Data;
|
||
using CloudBuilder.Master.Entity;
|
||
using CloudBuilder.Master.Policy;
|
||
using CloudBuilder.Master.SearchCriteria;
|
||
using CloudBuilder.Security.Entity;
|
||
using CloudBuilder.Security.Policy;
|
||
using CloudBuilder.Security.Service;
|
||
using CloudBuilder.Security.Utility;
|
||
using Microsoft.AspNetCore.Authorization;
|
||
using Microsoft.Extensions.DependencyInjection;
|
||
using System.Diagnostics;
|
||
namespace CloudBuilder.Master.Service
|
||
{
|
||
/// <summary>
|
||
/// 有家文化传承（文章）服务：主表 article + 群组关联 article_family_group + 配图明细 article_filename。
|
||
/// 可见性：仅文章关联族谱群组的正式成员可见；未审核（approved_indc<>Y）仅作者本人可见。
|
||
/// 作者中文名/头像按 created_by join security_user 回填；封面与配图存物理名、按上传目录打包访问地址。
|
||
/// </summary>
|
||
public class ArticleService : IArticleService
|
||
{
|
||
private readonly IApplicationService service;
|
||
|
||
private IRepository<ArticleEntity> repository;
|
||
public ArticleService(IApplicationService service)
|
||
{
|
||
this.service = service;
|
||
repository = service.GetRepository<IRepository<ArticleEntity>>();
|
||
}
|
||
|
||
[PermissionOperate(name: MasterPermissionPolicy.Article, operate: Operate.Find)]
|
||
public ArticleData FindByKey(string key)
|
||
{
|
||
ArticleData data = new ArticleData();
|
||
if (string.IsNullOrEmpty(key)) return data;
|
||
|
||
ArticleEntity article = repository.DetachedEntities.Where(x => x.ArticleName == key).FirstOrDefault();
|
||
if (article == null) return data;
|
||
|
||
IRepository<ArticleFamilyGroupEntity> repositoryArticleFamilyGroup = repository.GetRepository<IRepository<ArticleFamilyGroupEntity>>();
|
||
IRepository<FamilyGroupEntity> repositoryFamilyGroup = repository.GetRepository<IRepository<FamilyGroupEntity>>();
|
||
|
||
IQueryable<ArticleFamilyGroupDisplayData> q = from e in repositoryArticleFamilyGroup.DetachedEntities
|
||
join fg in repositoryFamilyGroup.DetachedEntities on e.FamilyName equals fg.FamilyName
|
||
where e.ArticleName == key
|
||
select new ArticleFamilyGroupDisplayData(fg)
|
||
{
|
||
CreatedBy = e.CreatedBy,
|
||
CreatedDatetime = e.CreatedDatetime,
|
||
UpdatedBy = e.UpdatedBy,
|
||
UpdatedDatetime = e.UpdatedDatetime,
|
||
ArticleName = e.ArticleName,
|
||
};
|
||
|
||
ArticleFamilyGroupDisplayData[] familyGroups = q.ToArray();
|
||
data.FamilyGroups = familyGroups;
|
||
|
||
// 归属与群组身份：作者全权；群成员可读；群管理员可改信息/群组/审核/置顶
|
||
string[] familyNames = familyGroups.Select(x => x.FamilyName).ToArray();
|
||
bool isOwner = article.CreatedBy == service.UserId;
|
||
bool isMember = isOwner;
|
||
bool isManager = isOwner;
|
||
if (!isOwner && familyNames.Length > 0)
|
||
{
|
||
IRepository<FamilyGroupManagerEntity> repositoryFamilyGroupManager = repository.GetRepository<IRepository<FamilyGroupManagerEntity>>();
|
||
FamilyGroupManagerEntity[] mine = repositoryFamilyGroupManager.DetachedEntities
|
||
.Where(x => x.UserName == service.UserId && x.ValidIndc == YesNoPolicy.YES && familyNames.Contains(x.FamilyName))
|
||
.ToArray();
|
||
isMember = mine.Length > 0;
|
||
isManager = mine.Any(x => x.ManagerIndc == YesNoPolicy.YES);
|
||
}
|
||
|
||
// 群组成员可见性闸门 + 未审核仅作者可见
|
||
if (!isOwner && !isMember)
|
||
{
|
||
throw new ValidatedException("没有权限.");
|
||
}
|
||
if (!isOwner && !YesNoPolicy.IsYes(article.ApprovedIndc))
|
||
{
|
||
throw new ValidatedException("文章尚未审核通过.");
|
||
}
|
||
|
||
ArticleDisplayData display = new ArticleDisplayData(article)
|
||
{
|
||
IsOwner = isOwner,
|
||
IsMember = isMember,
|
||
IsManager = isManager,
|
||
CoverUrl = PackCover(article.ArticleCoverFilename),
|
||
};
|
||
FillAuthor(display, article.CreatedBy);
|
||
data.Article = display;
|
||
|
||
IRepository<ArticleFilenameEntity> repositoryArticleFilename = repository.GetRepository<IRepository<ArticleFilenameEntity>>();
|
||
data.Filenames = repositoryArticleFilename.DetachedEntities
|
||
.Where(x => x.ArticleName == key)
|
||
.OrderBy(x => x.FileId)
|
||
.Select(x => new ArticleFilenameDisplayData(x))
|
||
.ToArray();
|
||
foreach (ArticleFilenameDisplayData f in data.Filenames)
|
||
{
|
||
f.ImageUrl = PackImage(f.FileName);
|
||
}
|
||
|
||
return data;
|
||
}
|
||
|
||
[PermissionOperate(name: MasterPermissionPolicy.Article, operate: Operate.Find)]
|
||
public ArticleResultData FindBySearchCriteria(ArticleSearchCriteria criteria)
|
||
{
|
||
ArticleResultData data = new ArticleResultData();
|
||
string userId = service.UserId;
|
||
|
||
// 我加入的群组（正式成员）
|
||
IRepository<FamilyGroupManagerEntity> repositoryFamilyGroupManager = repository.GetRepository<IRepository<FamilyGroupManagerEntity>>();
|
||
string[] myGroups = repositoryFamilyGroupManager.DetachedEntities
|
||
.Where(x => x.UserName == userId && x.ValidIndc == YesNoPolicy.YES)
|
||
.Select(x => x.FamilyName).Distinct().ToArray();
|
||
|
||
// 这些群组下挂的文章编号
|
||
IRepository<ArticleFamilyGroupEntity> repositoryArticleFamilyGroup = repository.GetRepository<IRepository<ArticleFamilyGroupEntity>>();
|
||
string[] articleNamesInMyGroups = myGroups.Length == 0
|
||
? new string[0]
|
||
: repositoryArticleFamilyGroup.DetachedEntities
|
||
.Where(x => myGroups.Contains(x.FamilyName))
|
||
.Select(x => x.ArticleName).Distinct().ToArray();
|
||
|
||
IQueryable<ArticleEntity> query = repository.DetachedEntities
|
||
.Where(x => x.CreatedBy == userId || articleNamesInMyGroups.Contains(x.ArticleName))
|
||
.Where(x => x.ApprovedIndc == YesNoPolicy.YES || x.CreatedBy == userId);
|
||
|
||
// 关键字：命中 ArticleTitle 的过滤器取标题模糊（首页搜索用）
|
||
string keyword = criteria.Filter?
|
||
.FirstOrDefault(f => f.Column == ArticleEntity.ARTICLE_TITLE || f.Column == ArticleEntity.DB_ARTICLE_TITLE)?.Value;
|
||
if (!string.IsNullOrWhiteSpace(keyword))
|
||
{
|
||
keyword = keyword.Trim();
|
||
query = query.Where(x => x.ArticleTitle.Contains(keyword));
|
||
}
|
||
|
||
// 排序：置顶优先，其次 OrderBy 升序（CloudBuilder 约定值小者靠前），最后按创建时间倒序兜底
|
||
IOrderedQueryable<ArticleEntity> ordered = query
|
||
.OrderByDescending(x => x.TopIndc == YesNoPolicy.YES)
|
||
.ThenBy(x => x.OrderBy)
|
||
.ThenByDescending(x => x.CreatedDatetime);
|
||
|
||
data.Total = ordered.Count();
|
||
|
||
int limit = criteria.limit > 0 ? criteria.limit : 20;
|
||
int page = criteria.page > 0 ? criteria.page : 1;
|
||
ArticleEntity[] slice = ordered.Skip((page - 1) * limit).Take(limit).ToArray();
|
||
|
||
ArticleDisplayData[] list = slice.Select(x => new ArticleDisplayData(x)
|
||
{
|
||
CoverUrl = PackCover(x.ArticleCoverFilename),
|
||
}).ToArray();
|
||
FillAuthors(list);
|
||
|
||
data.Limit = limit;
|
||
data.Page = page;
|
||
data.Datas = list;
|
||
return data;
|
||
}
|
||
|
||
[PermissionOperate(name: MasterPermissionPolicy.Article, operate: Operate.Insert)]
|
||
[UnitOfWork]
|
||
public ArticleData Insert(ArticleData data)
|
||
{
|
||
if (data == null || data.Article == null)
|
||
{
|
||
throw new ValidatedException("文章内容为空.");
|
||
}
|
||
|
||
Validate(data.Article);
|
||
|
||
ArticleEntity article = new ArticleEntity();
|
||
ObjectCopyHelper.Copy(data.Article, article);
|
||
|
||
ISecurityGeneratorNumberService securityGeneratorNumberService = service.ServiceProvider.GetService<ISecurityGeneratorNumberService>()!;
|
||
article.ArticleName = securityGeneratorNumberService.GetNo(MasterPrefixPolicy.ARTICLE, MasterPrefixPolicy.ARTICLE_ARTICLE_NAME, MasterPrefixPolicy.ARTICLE_PREFIX, YesNoPolicy.YES, MasterPrefixPolicy.ARTICLE_FORMAT);
|
||
article.CreatedBy = service.UserId;
|
||
article.UpdatedBy = service.UserId;
|
||
article.CreatedDatetime = DateTime.Now;
|
||
article.UpdatedDatetime = article.CreatedDatetime;
|
||
// 新文章默认未审核、不置顶（审核由作者/管理员在详情页开关控制）
|
||
if (string.IsNullOrEmpty(article.ApprovedIndc)) article.ApprovedIndc = YesNoPolicy.NO;
|
||
if (string.IsNullOrEmpty(article.TopIndc)) article.TopIndc = YesNoPolicy.NO;
|
||
|
||
repository.InsertNow(article);
|
||
|
||
// 先主表再子表，避免子表关联不到主键
|
||
SaveArticleFamilyGroup(article.ArticleName, data.FamilyGroups);
|
||
SaveArticleFilenames(article.ArticleName, data.Filenames);
|
||
|
||
return FindByKey(article.ArticleName);
|
||
}
|
||
|
||
[PermissionOperate(name: MasterPermissionPolicy.Article, operate: Operate.Update)]
|
||
[UnitOfWork]
|
||
public ArticleData Update(ArticleData data)
|
||
{
|
||
if (data == null || data.Article == null)
|
||
{
|
||
throw new ValidatedException("文章内容为空.");
|
||
}
|
||
|
||
ArticleEntity original = repository.DetachedEntities.Where(x => x.ArticleName == data.Article.ArticleName).FirstOrDefault();
|
||
if (original == null)
|
||
{
|
||
throw new ValidatedException("记录不存在.");
|
||
}
|
||
|
||
IRepository<ArticleFamilyGroupEntity> repositoryArticleFamilyGroup = repository.GetRepository<IRepository<ArticleFamilyGroupEntity>>();
|
||
IRepository<FamilyGroupManagerEntity> repositoryFamilyGroupManager = repository.GetRepository<IRepository<FamilyGroupManagerEntity>>();
|
||
|
||
bool isOwner = original.CreatedBy == service.UserId;
|
||
bool isManager = false;
|
||
bool isMember = false;
|
||
if (!isOwner)
|
||
{
|
||
string[] familyNames = repositoryArticleFamilyGroup.DetachedEntities
|
||
.Where(x => x.ArticleName == original.ArticleName)
|
||
.Select(x => x.FamilyName)
|
||
.ToArray();
|
||
if (familyNames.Length == 0)
|
||
{
|
||
throw new ValidatedException("没有权限.");
|
||
}
|
||
FamilyGroupManagerEntity[] mine = repositoryFamilyGroupManager.DetachedEntities
|
||
.Where(x => x.UserName == service.UserId && x.ValidIndc == YesNoPolicy.YES && familyNames.Contains(x.FamilyName))
|
||
.ToArray();
|
||
isMember = mine.Length > 0;
|
||
isManager = mine.Any(x => x.ManagerIndc == YesNoPolicy.YES);
|
||
if (!isMember)
|
||
{
|
||
throw new ValidatedException("没有权限.");
|
||
}
|
||
}
|
||
|
||
// 非作者保留归属与建单信息，防客户端伪造
|
||
data.Article.CreatedBy = original.CreatedBy;
|
||
data.Article.CreatedDatetime = original.CreatedDatetime;
|
||
if (!isOwner && !isManager)
|
||
{
|
||
// 普通群成员不可改正文/封面/审核/置顶：一律以库中为准
|
||
data.Article.ArticleTitle = original.ArticleTitle;
|
||
data.Article.Brief = original.Brief;
|
||
data.Article.ArticleCoverFilename = original.ArticleCoverFilename;
|
||
data.Article.ApprovedIndc = original.ApprovedIndc;
|
||
data.Article.TopIndc = original.TopIndc;
|
||
data.Article.OrderBy = original.OrderBy;
|
||
}
|
||
|
||
ValidateHelper.Validate(service, data.Article, ArticleEntity.DB_NAME_ARTICLE);
|
||
|
||
ArticleEntity article = new ArticleEntity();
|
||
ObjectCopyHelper.Copy(data.Article, article);
|
||
article.UpdatedBy = service.UserId;
|
||
article.UpdatedDatetime = DateTime.Now;
|
||
|
||
repository.UpdateNow(article);
|
||
|
||
// 群组增删与配图只对作者/群管理员开放
|
||
if (isOwner || isManager)
|
||
{
|
||
SaveArticleFamilyGroup(article.ArticleName, data.FamilyGroups);
|
||
SaveArticleFilenames(article.ArticleName, data.Filenames);
|
||
}
|
||
|
||
return FindByKey(article.ArticleName);
|
||
}
|
||
|
||
[PermissionOperate(name: MasterPermissionPolicy.Article, operate: Operate.Delete)]
|
||
[UnitOfWork]
|
||
public void Delete(string key)
|
||
{
|
||
ArticleEntity article = repository.DetachedEntities.Where(x => x.ArticleName == key).FirstOrDefault();
|
||
if (article == null) return;
|
||
|
||
// 删除：作者或关联群组管理员
|
||
if (article.CreatedBy != service.UserId && !IsGroupManagerOfArticle(key))
|
||
{
|
||
throw new ValidatedException("没有权限.");
|
||
}
|
||
|
||
repository.DeleteNow(article);
|
||
|
||
IRepository<ArticleFamilyGroupEntity> repositoryFamilyGroup = repository.GetRepository<IRepository<ArticleFamilyGroupEntity>>();
|
||
ArticleFamilyGroupEntity[] groups = repositoryFamilyGroup.Entities.Where(x => x.ArticleName == key).ToArray();
|
||
foreach (ArticleFamilyGroupEntity gp in groups)
|
||
{
|
||
repositoryFamilyGroup.DeleteNow(gp);
|
||
}
|
||
|
||
IRepository<ArticleFilenameEntity> repositoryFilename = repository.GetRepository<IRepository<ArticleFilenameEntity>>();
|
||
ArticleFilenameEntity[] files = repositoryFilename.Entities.Where(x => x.ArticleName == key).ToArray();
|
||
foreach (ArticleFilenameEntity f in files)
|
||
{
|
||
repositoryFilename.DeleteNow(f);
|
||
}
|
||
}
|
||
|
||
/// <summary>当前登录人是否为该文章任一关联群组的管理员（正式成员且 ManagerIndc=Y）</summary>
|
||
private bool IsGroupManagerOfArticle(string articleName)
|
||
{
|
||
IRepository<ArticleFamilyGroupEntity> repositoryArticleFamilyGroup = repository.GetRepository<IRepository<ArticleFamilyGroupEntity>>();
|
||
IRepository<FamilyGroupManagerEntity> repositoryFamilyGroupManager = repository.GetRepository<IRepository<FamilyGroupManagerEntity>>();
|
||
|
||
string[] familyNames = repositoryArticleFamilyGroup.DetachedEntities
|
||
.Where(x => x.ArticleName == articleName)
|
||
.Select(x => x.FamilyName)
|
||
.ToArray();
|
||
if (familyNames.Length == 0) return false;
|
||
|
||
return repositoryFamilyGroupManager.DetachedEntities
|
||
.Any(x => x.UserName == service.UserId && x.ValidIndc == YesNoPolicy.YES && x.ManagerIndc == YesNoPolicy.YES && familyNames.Contains(x.FamilyName));
|
||
}
|
||
|
||
private void SaveArticleFamilyGroup(string articleName, ArticleFamilyGroupEntity[] familyGroups)
|
||
{
|
||
IRepository<ArticleFamilyGroupEntity> repositoryArticleFamilyGroup = repository.GetRepository<IRepository<ArticleFamilyGroupEntity>>();
|
||
|
||
ArticleFamilyGroupEntity[] olds = repositoryArticleFamilyGroup.Entities.Where(x => x.ArticleName == articleName).ToArray();
|
||
foreach (ArticleFamilyGroupEntity old in olds)
|
||
{
|
||
if (familyGroups == null || familyGroups.Length == 0 || familyGroups.Count(x => x.FamilyName == old.FamilyName) == 0)
|
||
{
|
||
repositoryArticleFamilyGroup.DeleteNow(old);
|
||
}
|
||
}
|
||
|
||
if (familyGroups != null)
|
||
{
|
||
foreach (ArticleFamilyGroupEntity dto in familyGroups)
|
||
{
|
||
if (olds.Any(x => x.FamilyName == dto.FamilyName)) continue;
|
||
repositoryArticleFamilyGroup.InsertNow(new ArticleFamilyGroupEntity()
|
||
{
|
||
ArticleName = articleName,
|
||
FamilyName = dto.FamilyName,
|
||
});
|
||
}
|
||
}
|
||
}
|
||
|
||
private void SaveArticleFilenames(string articleName, ArticleFilenameEntity[] filenames)
|
||
{
|
||
IRepository<ArticleFilenameEntity> repositoryArticleFilename = repository.GetRepository<IRepository<ArticleFilenameEntity>>();
|
||
|
||
ArticleFilenameEntity[] olds = repositoryArticleFilename.Entities.Where(x => x.ArticleName == articleName).ToArray();
|
||
foreach (ArticleFilenameEntity old in olds)
|
||
{
|
||
if (filenames == null || filenames.Length == 0 || filenames.Count(x => x.FileName == old.FileName) == 0)
|
||
{
|
||
repositoryArticleFilename.DeleteNow(old);
|
||
}
|
||
}
|
||
|
||
if (filenames != null)
|
||
{
|
||
foreach (ArticleFilenameEntity dto in filenames)
|
||
{
|
||
if (olds.Any(x => x.FileName == dto.FileName)) continue;
|
||
repositoryArticleFilename.InsertNow(new ArticleFilenameEntity()
|
||
{
|
||
ArticleName = articleName,
|
||
FileName = dto.FileName,
|
||
});
|
||
}
|
||
}
|
||
}
|
||
|
||
private void Validate(ArticleEntity article)
|
||
{
|
||
List<SysTableSchemaViewEntity> sysTableSchemas = service.ServiceProvider.GetRequiredService<ISysTableSchemaViewService>().FindByTableName(ArticleEntity.DB_NAME_ARTICLE);
|
||
ValidateHelper.ValidateString(article, sysTableSchemas.ToArray());
|
||
}
|
||
|
||
private string PackCover(string fileName)
|
||
{
|
||
if (string.IsNullOrEmpty(fileName)) return "";
|
||
return FileTypePolicy.PackAvatarUrl(service, UploadFolderPolicy.ARTICLE_COVER, fileName) ?? "";
|
||
}
|
||
|
||
private string PackImage(string fileName)
|
||
{
|
||
if (string.IsNullOrEmpty(fileName)) return "";
|
||
return FileTypePolicy.PackAvatarUrl(service, UploadFolderPolicy.ARTICLE_IMAGE, fileName) ?? "";
|
||
}
|
||
|
||
/// <summary>按用户名 join security_user 回填单个作者的中文名与头像。</summary>
|
||
private void FillAuthor(ArticleDisplayData display, string userName)
|
||
{
|
||
if (display == null || string.IsNullOrEmpty(userName)) return;
|
||
IRepository<SecurityUserEntity> repositoryUser = repository.GetRepository<IRepository<SecurityUserEntity>>();
|
||
SecurityUserEntity user = repositoryUser.DetachedEntities.Where(x => x.UserName == userName).FirstOrDefault();
|
||
display.AuthorLocalName = user?.UserLocalName ?? userName;
|
||
display.AuthorAvatarUrl = FileTypePolicy.PackAvatarUrl(service, UploadFolderPolicy.USER_AVATAR, user?.UserIconImgPath ?? "") ?? "";
|
||
}
|
||
|
||
/// <summary>批量 join：一次取回页内所有作者的中文名与头像，避免 N+1。</summary>
|
||
private void FillAuthors(ArticleDisplayData[] list)
|
||
{
|
||
if (list == null || list.Length == 0) return;
|
||
string[] names = list.Select(x => x.CreatedBy).Where(x => !string.IsNullOrEmpty(x)).Distinct().ToArray();
|
||
if (names.Length == 0) return;
|
||
|
||
IRepository<SecurityUserEntity> repositoryUser = repository.GetRepository<IRepository<SecurityUserEntity>>();
|
||
SecurityUserEntity[] users = repositoryUser.DetachedEntities.Where(x => names.Contains(x.UserName)).ToArray();
|
||
|
||
foreach (ArticleDisplayData item in list)
|
||
{
|
||
SecurityUserEntity user = users.Where(y => y.UserName == item.CreatedBy).FirstOrDefault();
|
||
item.AuthorLocalName = user?.UserLocalName ?? item.CreatedBy;
|
||
item.AuthorAvatarUrl = FileTypePolicy.PackAvatarUrl(service, UploadFolderPolicy.USER_AVATAR, user?.UserIconImgPath ?? "") ?? "";
|
||
}
|
||
}
|
||
}
|
||
}
|