article
This commit is contained in:
owenchen committed
1 parent
c6eb00b406
commit
1c91f62ff6
58 files changed
+3888
-69
No files matched your search
@@ -0,0 +1,423 @@
|
||||
|
||||
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 ?? "") ?? "";
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
Reference in new issue
Block a user