文件上传功能添加，注意使用Path.Combine处理通用路径问题（windows||docker)
This commit is contained in:
owenchen committed
1 parent
7817c5374c
commit
244b59a3fb
135 files changed
+16937
-75
No files matched your search
@@ -30,8 +30,10 @@
|
||||
<PackageReference Include="Microsoft.Extensions.DependencyInjection.Abstractions" Version="9.0.0" />
|
||||
<PackageReference Include="Microsoft.Extensions.DependencyModel" Version="9.0.0" />
|
||||
<PackageReference Include="Newtonsoft.Json" Version="13.0.4" />
|
||||
|
||||
<PackageReference Include="CliWrap" Version="3.6.6" />
|
||||
<PackageReference Include="Pomelo.EntityFrameworkCore.MySql" Version="8.0.0" />
|
||||
<PackageReference Include="SixLabors.ImageSharp" Version="3.1.3" />
|
||||
<PackageReference Include="SixLabors.ImageSharp.Drawing" Version="2.1.1" />
|
||||
</ItemGroup>
|
||||
|
||||
<ItemGroup>
|
||||
|
||||
File diff suppressed because it is too large.
Load diff
@@ -0,0 +1,679 @@
|
||||
|
||||
using CloudBuilder.Core.DatabaseAccessor.Entity;
|
||||
using Microsoft.AspNetCore.Authorization;
|
||||
using CloudBuilder.Core.DatabaseAccessor;
|
||||
using CloudBuilder.Master.Entity;
|
||||
using CloudBuilder.Master.Policy;
|
||||
using CloudBuilder.Master.SearchCriteria;
|
||||
using CloudBuilder.Master.Data;
|
||||
using CloudBuilder.Core.Service;
|
||||
using CloudBuilder.Security.Utility;
|
||||
using CloudBuilder.Security.Service;
|
||||
using Microsoft.Extensions.DependencyInjection;
|
||||
namespace CloudBuilder.Master.Service
|
||||
{
|
||||
public class FamilyGroupService : IFamilyGroupService
|
||||
{
|
||||
private readonly IApplicationService service;
|
||||
|
||||
private IRepository<FamilyGroupEntity> repository;
|
||||
public FamilyGroupService(IApplicationService service)
|
||||
{
|
||||
this.service = service;
|
||||
repository = service.GetRepository<IRepository<FamilyGroupEntity>>();
|
||||
}
|
||||
|
||||
[PermissionOperate(name: MasterPermissionPolicy.FamilyGroup, operate: Operate.Find)]
|
||||
public FamilyGroupData FindByKey(string key)
|
||||
{
|
||||
FamilyGroupData data = new FamilyGroupData();
|
||||
FamilyGroupEntity familyGroup = repository.DetachedEntities.Where(x => x.FamilyName == key).FirstOrDefault()!;
|
||||
if (familyGroup == null || !YesNoPolicy.IsYes(familyGroup.ValidIndc)) return data;
|
||||
|
||||
data.FamilyGroup = familyGroup;
|
||||
data.IsAdd = familyGroup.AddIndc == YesNoPolicy.YES;
|
||||
data.IsOpen = familyGroup.OpenIndc == YesNoPolicy.YES;
|
||||
|
||||
|
||||
|
||||
IRepository<DmsFolderMapEntity> repositoryDmsFolderMap = repository.GetRepository<IRepository<DmsFolderMapEntity>>();
|
||||
DmsFolderMapEntity[] dmsFolderMapss = repositoryDmsFolderMap.DetachedEntities.Where(x => x.FolderNameParent == key).ToArray();
|
||||
|
||||
IRepository<FamilyGroupFolderEntity> repositoryFamilyGroupFolder = repository.GetRepository<IRepository<FamilyGroupFolderEntity>>();
|
||||
|
||||
FamilyGroupFolderEntity[] folders = repositoryFamilyGroupFolder.DetachedEntities.Where(x => x.FamilyName == key).ToArray();
|
||||
|
||||
List<FamilyGroupFolderEntity> lfs = new List<FamilyGroupFolderEntity>();
|
||||
foreach (var f in folders)
|
||||
{
|
||||
foreach (var m in dmsFolderMapss)
|
||||
{
|
||||
if (f.FolderName == m.FolderNameSon)
|
||||
{
|
||||
lfs.Add(f);
|
||||
break;
|
||||
}
|
||||
}
|
||||
}
|
||||
folders = lfs.ToArray();
|
||||
|
||||
IRepository<FamilyGroupManagerUserViewEntity> repositoryFamilyGroupManagerUser = repository.GetRepository<IRepository<FamilyGroupManagerUserViewEntity>>();
|
||||
|
||||
FamilyGroupManagerUserViewEntity[] users = repositoryFamilyGroupManagerUser.DetachedEntities.Where(x => x.FamilyName == key).ToArray();
|
||||
|
||||
IRepository<FamilyGroupPermissionUserFolderViewEntity> repositoryFamilyGroupPermissionUserFolder = repository.GetRepository<IRepository<FamilyGroupPermissionUserFolderViewEntity>>();
|
||||
FamilyGroupPermissionUserFolderViewEntity[] ufs = repositoryFamilyGroupPermissionUserFolder.DetachedEntities.Where(x => x.FamilyName == key).ToArray();
|
||||
|
||||
if (users == null || users.Length == 0) return data;
|
||||
|
||||
bool isManager = false;
|
||||
bool isUser = false;
|
||||
IRepository<FamilyGroupManagerEntity> repositoryFamilyGroupManager = repository.GetRepository<IRepository<FamilyGroupManagerEntity>>();
|
||||
FamilyGroupManagerEntity[] fgms = repositoryFamilyGroupManager.DetachedEntities.Where(x => x.FamilyName == key && x.ValidIndc == YesNoPolicy.YES).ToArray();
|
||||
if (fgms != null && fgms.Length > 0)
|
||||
{
|
||||
data.FamilyGroupManagers = fgms.Select(x => new FamilyGroupManagerDisplayData(x)
|
||||
{ UserLocalName = users.Where(y => y.UserName == x.UserName).FirstOrDefault()!.UserLocalName }).ToArray();
|
||||
|
||||
//如果不是管理员,则只能看到有权限的目录
|
||||
|
||||
FamilyGroupManagerEntity[] temp = data.FamilyGroupManagers.Where(x => x.ManagerIndc == YesNoPolicy.YES && x.UserName == service.UserId).ToArray();
|
||||
|
||||
if (temp != null && temp.Length > 0) isManager = true;
|
||||
|
||||
temp = data.FamilyGroupManagers.Where(x => x.ValidIndc == YesNoPolicy.YES && x.UserName == service.UserId).ToArray();
|
||||
if (temp != null && temp.Length > 0) isUser = true;
|
||||
}
|
||||
|
||||
//如果隐私，不是成员不能查看
|
||||
if (familyGroup.OpenIndc == YesNoPolicy.NO && !isUser) return new FamilyGroupData();
|
||||
|
||||
IRepository<FamilyGroupPermissionEntity> repositoryFamilyGroupPermission = repository.GetRepository<IRepository<FamilyGroupPermissionEntity>>();
|
||||
FamilyGroupPermissionEntity[] fgps = repositoryFamilyGroupPermission.DetachedEntities.Where(x => x.FamilyName == key).ToArray();
|
||||
|
||||
if (fgps != null && fgps.Length > 0)
|
||||
{
|
||||
data.FamilyGroupPermissions = fgps.Select(x => new FamilyGroupPermissionDisplayData(x)
|
||||
{
|
||||
UserLocalName = users!.Where(y => y.UserName == x.UserName).FirstOrDefault()!.UserLocalName,
|
||||
FolderLocalName = ufs!.Where(y => y.UserName == x.UserName && y.FolderName == x.FolderName).FirstOrDefault()!.FolderLocalName
|
||||
}).ToArray();
|
||||
|
||||
if (!isManager)
|
||||
{
|
||||
FamilyGroupPermissionDisplayData[] ps = data.FamilyGroupPermissions.Where(x => x.UserName == service.UserId).ToArray();
|
||||
|
||||
if (ps == null || ps.Length == 0)
|
||||
{
|
||||
data.FamilyGroupFolders = folders!.Select(x => new FamilyGroupFolderDisplayData(x)
|
||||
{
|
||||
IsSharePermission = false,
|
||||
}).ToArray();
|
||||
}
|
||||
else
|
||||
{
|
||||
if (folders != null && folders.Length > 0)
|
||||
{
|
||||
List<FamilyGroupFolderDisplayData> l = new List<FamilyGroupFolderDisplayData>();
|
||||
FamilyGroupFolderDisplayData d;
|
||||
foreach (var item in folders)
|
||||
{
|
||||
d = new FamilyGroupFolderDisplayData(item);
|
||||
if (ps.Where(x => x.FolderName == item.FolderName).Count() > 0)
|
||||
{
|
||||
d.IsSharePermission = true;
|
||||
}
|
||||
|
||||
l.Add(d);
|
||||
}
|
||||
|
||||
data.FamilyGroupFolders = l.ToArray();
|
||||
}
|
||||
|
||||
}
|
||||
if (!isUser)
|
||||
data.FamilyGroupManagers = null;
|
||||
data.FamilyGroupPermissions = null;
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
|
||||
if (isManager)
|
||||
{
|
||||
fgms = repositoryFamilyGroupManager.DetachedEntities.Where(x => x.FamilyName == key && x.ValidIndc == YesNoPolicy.NO).ToArray();
|
||||
if (fgms != null && fgms.Length > 0)
|
||||
data.FamilyGroupRequests = fgms.Select(x => new FamilyGroupManagerDisplayData(x)
|
||||
{ UserLocalName = users!.Where(y => y.UserName == x.UserName).FirstOrDefault()!.UserLocalName }).ToArray();
|
||||
|
||||
//管理员有分享权限
|
||||
data.FamilyGroupFolders = folders!.Select(x => new FamilyGroupFolderDisplayData(x)
|
||||
{
|
||||
IsSharePermission = true,
|
||||
}).ToArray();
|
||||
}
|
||||
|
||||
data.IsManager = isManager;
|
||||
|
||||
return data;
|
||||
}
|
||||
|
||||
[PermissionOperate(name: MasterPermissionPolicy.FamilyGroup, operate: Operate.Find)]
|
||||
public FamilyGroupResultData FindBySearchCriteria(FamilyGroupSearchCriteria criteria)
|
||||
{
|
||||
FamilyGroupResultData data = new FamilyGroupResultData();
|
||||
FamilyGroupEntity[] list = null;
|
||||
|
||||
Int64 count = 0;
|
||||
|
||||
string sqlWhere = null;
|
||||
|
||||
if (criteria.Filter != null && criteria.Filter.Length > 0)
|
||||
{
|
||||
sqlWhere = SearchFilter.ComposeWhereClause(criteria.Filter);
|
||||
}
|
||||
|
||||
|
||||
string subIn = $"select {FamilyGroupManagerEntity.DB_FAMILY_NAME} from {FamilyGroupManagerEntity.DB_NAME_FAMILY_GROUP_MANAGER} where {FamilyGroupManagerEntity.DB_USER_NAME}='{service.UserId}' ";
|
||||
sqlWhere = sqlWhere + $" and {FamilyGroupEntity.DB_VALID_INDC}='Y' and ( {FamilyGroupEntity.DB_OPEN_INDC}='Y' or ({FamilyGroupEntity.DB_OPEN_INDC}='N' and {FamilyGroupEntity.DB_FAMILY_NAME} in ({subIn})))";
|
||||
|
||||
|
||||
FamilyGroupEntity entity = FamilyGroupEntity.GetInstance(repository.GetDbContext().Database.ProviderName);
|
||||
string sql = entity.GetSelectTopFrom(criteria.limit, criteria.page, criteria.orderby.StringToDbField(), criteria.orderbytag, sqlWhere);
|
||||
|
||||
string err = null;
|
||||
try
|
||||
{
|
||||
list = repository.FromSql(sql).ToArray();
|
||||
}
|
||||
catch (System.Exception ex)
|
||||
{
|
||||
err = ex.Message;
|
||||
}
|
||||
|
||||
|
||||
if (list != null && list.Length > 0)
|
||||
{
|
||||
sql = entity.GetSelectCountFrom(sqlWhere);
|
||||
count = Convert.ToInt64(repository.ExecuteScalar(sql));
|
||||
}
|
||||
|
||||
data.Limit = criteria.limit;
|
||||
data.Page = criteria.page;
|
||||
data.Datas = list;
|
||||
data.Total = count;
|
||||
//data.Sql = sql;
|
||||
data.ErrorMessage = err;
|
||||
return data;
|
||||
}
|
||||
|
||||
[PermissionOperate(name: MasterPermissionPolicy.FamilyGroup, operate: Operate.Find)]
|
||||
public FamilyGroupResultData FindFamilyUserBySearchCriteria(FamilyGroupManagerUserSearchCriteria criteria)
|
||||
{
|
||||
FamilyGroupResultData data = new FamilyGroupResultData();
|
||||
FamilyGroupManagerUserViewEntity[] list = null;
|
||||
|
||||
Int64 count = 0;
|
||||
|
||||
string sqlWhere = null;
|
||||
|
||||
if (criteria.Filter != null && criteria.Filter.Length > 0)
|
||||
{
|
||||
sqlWhere = SearchFilter.ComposeWhereClause(criteria.Filter);
|
||||
}
|
||||
string notIn = $"select {FamilyGroupPermissionUserFolderViewEntity.DB_USER_NAME} from {FamilyGroupPermissionUserFolderViewEntity.DB_NAME_FAMILY_GROUP_PERMISSION_USER_FOLDER_VIEW} where {FamilyGroupPermissionUserFolderViewEntity.DB_FAMILY_NAME}='{criteria.FamilyName}' and {FamilyGroupPermissionUserFolderViewEntity.DB_FOLDER_NAME}='{criteria.FolderName}' ";
|
||||
sqlWhere = sqlWhere + " and " + FamilyGroupManagerUserViewEntity.DB_USER_NAME + $" not in ({notIn})";
|
||||
sqlWhere = sqlWhere + " and " + FamilyGroupManagerUserViewEntity.DB_VALID_INDC + "='Y' ";
|
||||
sqlWhere = sqlWhere + $" and {FamilyGroupManagerUserViewEntity.DB_FAMILY_NAME}= '{criteria.FamilyName}' ";
|
||||
|
||||
IRepository<FamilyGroupManagerUserViewEntity> repositoryFamilyGroupManager = repository.GetRepository<IRepository<FamilyGroupManagerUserViewEntity>>();
|
||||
|
||||
FamilyGroupManagerUserViewEntity entity = FamilyGroupManagerUserViewEntity.GetInstance(repository.GetDbContext().Database.ProviderName);
|
||||
string sql = entity.GetSelectTopFrom(criteria.limit, criteria.page, criteria.orderby.StringToDbField(), criteria.orderbytag, sqlWhere);
|
||||
|
||||
string err = null;
|
||||
try
|
||||
{
|
||||
list = repositoryFamilyGroupManager.FromSql(sql).ToArray();
|
||||
}
|
||||
catch (System.Exception ex)
|
||||
{
|
||||
err = ex.Message;
|
||||
}
|
||||
|
||||
|
||||
if (list != null && list.Length > 0)
|
||||
{
|
||||
sql = entity.GetSelectCountFrom(sqlWhere);
|
||||
count = Convert.ToInt64(repository.ExecuteScalar(sql));
|
||||
}
|
||||
|
||||
data.Limit = criteria.limit;
|
||||
data.Page = criteria.page;
|
||||
data.Users = list;
|
||||
data.Total = count;
|
||||
//data.Sql = sql;
|
||||
data.ErrorMessage = err;
|
||||
return data;
|
||||
}
|
||||
|
||||
[PermissionOperate(name: MasterPermissionPolicy.FamilyGroup, operate: Operate.Find)]
|
||||
public FamilyGroupResultData FamilyFolderFavoriteBySearchCriteria(FamilyGroupManagerUserSearchCriteria criteria)
|
||||
{
|
||||
FamilyGroupResultData data = new FamilyGroupResultData();
|
||||
FamilyFolderFavoriteViewEntity[] list = null;
|
||||
|
||||
Int64 count = 0;
|
||||
|
||||
string sqlWhere = null;
|
||||
|
||||
if (criteria.Filter != null && criteria.Filter.Length > 0)
|
||||
{
|
||||
sqlWhere = SearchFilter.ComposeWhereClause(criteria.Filter);
|
||||
}
|
||||
|
||||
sqlWhere = sqlWhere + $" and {FamilyFolderFavoriteViewEntity.DB_USER_NAME}='{service.UserId}' ";
|
||||
|
||||
IRepository<FamilyFolderFavoriteViewEntity> repositoryFamilyFolderFavorite = repository.GetRepository<IRepository<FamilyFolderFavoriteViewEntity>>();
|
||||
|
||||
FamilyFolderFavoriteViewEntity entity = FamilyFolderFavoriteViewEntity.GetInstance(repository.GetDbContext().Database.ProviderName);
|
||||
string sql = entity.GetSelectTopFrom(criteria.limit, criteria.page, criteria.orderby.StringToDbField(), criteria.orderbytag, sqlWhere);
|
||||
|
||||
string err = null;
|
||||
try
|
||||
{
|
||||
list = repositoryFamilyFolderFavorite.FromSql(sql).ToArray();
|
||||
}
|
||||
catch (System.Exception ex)
|
||||
{
|
||||
err = ex.Message;
|
||||
}
|
||||
|
||||
|
||||
if (list != null && list.Length > 0)
|
||||
{
|
||||
sql = entity.GetSelectCountFrom(sqlWhere);
|
||||
count = Convert.ToInt64(repository.ExecuteScalar(sql));
|
||||
}
|
||||
|
||||
data.Limit = criteria.limit;
|
||||
data.Page = criteria.page;
|
||||
data.Favorites = list;
|
||||
data.Total = count;
|
||||
//data.Sql = sql;
|
||||
data.ErrorMessage = err;
|
||||
return data;
|
||||
}
|
||||
|
||||
[PermissionOperate(name: MasterPermissionPolicy.FamilyGroup, operate: Operate.Print)]
|
||||
public dynamic PrintBySearchCriteria(FamilyGroupSearchCriteria criteria)
|
||||
{
|
||||
throw new NotImplementedException();
|
||||
}
|
||||
|
||||
[PermissionOperate(name: MasterPermissionPolicy.FamilyGroup, operate: Operate.Insert)]
|
||||
[UnitOfWork]
|
||||
public FamilyGroupData Insert(FamilyGroupData data)
|
||||
{
|
||||
FamilyGroupEntity familyGroup = repository.DetachedEntities.Where(x => x.FamilyLocalName == data.FamilyGroup.FamilyLocalName).FirstOrDefault();
|
||||
if (familyGroup != null)
|
||||
{
|
||||
throw new ValidatedException("群组名称已存在.");
|
||||
}
|
||||
|
||||
ValidateHelper.Validate(service, data.FamilyGroup, FamilyGroupEntity.DB_NAME_FAMILY_GROUP);
|
||||
|
||||
familyGroup = new FamilyGroupEntity();
|
||||
ObjectCopyHelper.Copy(data.FamilyGroup, familyGroup);
|
||||
|
||||
ISecurityGeneratorNumberService securityGeneratorNumberService = service.ServiceProvider.GetService<ISecurityGeneratorNumberService>()!;
|
||||
|
||||
familyGroup.FamilyName = securityGeneratorNumberService.GetNo(MasterPrefixPolicy.FAMILY_GROUP, MasterPrefixPolicy.FAMILY_GROUP_FAMILY_NAME, "FM", YesNoPolicy.NO, "000000");
|
||||
familyGroup.ValidIndc = YesNoPolicy.YES;
|
||||
familyGroup.ExpireDatetime = null;
|
||||
|
||||
familyGroup.AddIndc = data.IsAdd ? YesNoPolicy.YES : YesNoPolicy.NO;
|
||||
familyGroup.OpenIndc = data.IsOpen ? YesNoPolicy.YES : YesNoPolicy.NO;
|
||||
|
||||
repository.InsertNow(familyGroup);
|
||||
|
||||
//创建人是管理员
|
||||
|
||||
FamilyGroupManagerEntity managerEntity = new FamilyGroupManagerEntity();
|
||||
managerEntity.FamilyName = familyGroup.FamilyName;
|
||||
managerEntity.ValidIndc = YesNoPolicy.YES;
|
||||
managerEntity.ManagerIndc = YesNoPolicy.YES;
|
||||
managerEntity.UserName = service.UserId;
|
||||
managerEntity.Notice = "创建群用户";
|
||||
|
||||
IRepository<FamilyGroupManagerEntity> repositoryFamilyGroupManager = repository.GetRepository<IRepository<FamilyGroupManagerEntity>>();
|
||||
repositoryFamilyGroupManager.InsertNow(managerEntity);
|
||||
|
||||
SaveFamilyGroupFolders(familyGroup.FamilyName, data.FamilyGroupFolders);
|
||||
|
||||
//SaveFamilyGroupManagers(familyGroup.FamilyName, data.FamilyGroupManagers);
|
||||
|
||||
//SavePermissions(familyGroup.FamilyName, data.FamilyGroupPermissions);
|
||||
|
||||
//创建群根目录
|
||||
IDmsFileService dmsFileService = service.ServiceProvider.GetService<IDmsFileService>()!;
|
||||
dmsFileService.CreateFamilyDmsFolder(familyGroup, data.FamilyGroupFolders);
|
||||
|
||||
return FindByKey(familyGroup.FamilyName);
|
||||
}
|
||||
|
||||
private void SaveFamilyGroupFolders(string familyName, FamilyGroupFolderEntity[] familyGroupFolders)
|
||||
{
|
||||
IRepository<FamilyGroupFolderEntity> repositoryFamilyGroupFolder = repository.GetRepository<IRepository<FamilyGroupFolderEntity>>();
|
||||
ISecurityGeneratorNumberService securityGeneratorNumberService = service.ServiceProvider.GetService<ISecurityGeneratorNumberService>()!;
|
||||
IRepository<DmsFolderMapEntity> repositoryFolderMap = repository.GetRepository<IRepository<DmsFolderMapEntity>>();
|
||||
IRepository<DmsFolderEntity> repositoryFolder = repository.GetRepository<IRepository<DmsFolderEntity>>();
|
||||
|
||||
IDmsFileService dmsFileService = service.ServiceProvider.GetService<IDmsFileService>()!;
|
||||
|
||||
FamilyGroupFolderEntity[] olds = repositoryFamilyGroupFolder.Entities.Where(x => x.FamilyName == familyName).ToArray();
|
||||
if (olds != null && olds.Length > 0)
|
||||
{
|
||||
//存在更新，不存在删除
|
||||
foreach (FamilyGroupFolderEntity old in olds)
|
||||
{
|
||||
if (familyGroupFolders != null && familyGroupFolders.Length > 0 && familyGroupFolders.Where(x => x.FolderId == old.FolderId).Count() > 0)
|
||||
{
|
||||
FamilyGroupFolderEntity folder = familyGroupFolders.Where(x => x.FolderId == old.FolderId).FirstOrDefault();
|
||||
old.FolderLocalName = folder.FolderLocalName;
|
||||
old.Notice = folder.Notice;
|
||||
repositoryFamilyGroupFolder.UpdateNow(old);
|
||||
}
|
||||
else
|
||||
{
|
||||
repositoryFamilyGroupFolder.DeleteNow(old);
|
||||
|
||||
//删除主目录所有内容
|
||||
DmsFolderEntity folder = repositoryFolder.DetachedEntities.Where(x => x.FolderName == old.FolderName).FirstOrDefault()!;
|
||||
if (folder != null)
|
||||
{
|
||||
dmsFileService.DeleteFolder(folder.FolderName);
|
||||
}
|
||||
|
||||
|
||||
//删除目录的时候，也要删除目录对应的权限
|
||||
IRepository<FamilyGroupPermissionEntity> repositoryFamilyGroupPermission = repository.GetRepository<IRepository<FamilyGroupPermissionEntity>>();
|
||||
FamilyGroupPermissionEntity[] permissions = repositoryFamilyGroupPermission.DetachedEntities.Where(x => x.FamilyName == old.FamilyName && x.FolderName == old.FolderName).ToArray();
|
||||
if (permissions != null && permissions.Length > 0)
|
||||
{
|
||||
foreach (var item in permissions)
|
||||
{
|
||||
repositoryFamilyGroupPermission.DeleteNow(item);
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
if (familyGroupFolders == null || familyGroupFolders.Length == 0) return;
|
||||
|
||||
foreach (FamilyGroupFolderEntity dto in familyGroupFolders)
|
||||
{
|
||||
//原来不存在的插入
|
||||
if (!string.IsNullOrEmpty(dto.CreatedBy)) continue;
|
||||
|
||||
ValidateHelper.Validate(service, dto, FamilyGroupFolderEntity.DB_NAME_FAMILY_GROUP_FOLDER);
|
||||
|
||||
FamilyGroupFolderEntity familyGroupFolderEntity = new FamilyGroupFolderEntity()
|
||||
{
|
||||
FolderName = securityGeneratorNumberService.GetNo(MasterPrefixPolicy.DMS_FOLDER, MasterPrefixPolicy.DMS_FOLDER_FOLDER_NAME, "FG", YesNoPolicy.NO, "00000000"),
|
||||
FamilyName = familyName,
|
||||
FolderLocalName = dto.FolderLocalName,
|
||||
Notice = dto.Notice,
|
||||
};
|
||||
//顶级目录
|
||||
familyGroupFolderEntity.TopFolderName = familyGroupFolderEntity.FolderName;
|
||||
|
||||
repositoryFamilyGroupFolder.InsertNow(familyGroupFolderEntity);
|
||||
|
||||
dto.FolderName = familyGroupFolderEntity.FolderName;
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
private void SavePermissions(string familyName, FamilyGroupPermissionEntity[] permissions)
|
||||
{
|
||||
IRepository<FamilyGroupPermissionEntity> repositoryFamilyGroupPermission = repository.GetRepository<IRepository<FamilyGroupPermissionEntity>>();
|
||||
|
||||
FamilyGroupPermissionEntity[] olds = repositoryFamilyGroupPermission.Entities.Where(x => x.FamilyName == familyName).ToArray();
|
||||
if (olds != null && olds.Length > 0)
|
||||
{
|
||||
//存在更新，不存在删除
|
||||
foreach (FamilyGroupPermissionEntity old in olds)
|
||||
{
|
||||
if (permissions != null && permissions.Length > 0 && permissions.Where(x => x.UserName == old.UserName && x.FolderName == old.FolderName).Count() > 0)
|
||||
{
|
||||
FamilyGroupPermissionEntity folder = permissions.Where(x => x.UserName == old.UserName && x.FolderName == old.FolderName).FirstOrDefault();
|
||||
old.DeleteIndc = folder.DeleteIndc;
|
||||
old.CreateIndc = folder.CreateIndc;
|
||||
repositoryFamilyGroupPermission.UpdateNow(old);
|
||||
}
|
||||
else
|
||||
{
|
||||
repositoryFamilyGroupPermission.DeleteNow(old);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
if (permissions == null || permissions.Length == 0) return;
|
||||
|
||||
foreach (FamilyGroupPermissionEntity dto in permissions)
|
||||
{
|
||||
//原来不存在的插入
|
||||
if (!string.IsNullOrEmpty(dto.CreatedBy)) continue;
|
||||
|
||||
ValidateHelper.Validate(service, dto, FamilyGroupPermissionEntity.DB_NAME_FAMILY_GROUP_PERMISSION);
|
||||
|
||||
repositoryFamilyGroupPermission.InsertNow(new FamilyGroupPermissionEntity()
|
||||
{
|
||||
FamilyName = familyName,
|
||||
UserName = dto.UserName,
|
||||
FolderName = dto.FolderName,
|
||||
CreateIndc = YesNoPolicy.YES,
|
||||
DeleteIndc = YesNoPolicy.YES,
|
||||
});
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
private void SaveFamilyGroupManagers(string familyName, FamilyGroupManagerDisplayData[] managers)
|
||||
{
|
||||
IRepository<FamilyGroupManagerEntity> repositoryFamilyGroupManager = repository.GetRepository<IRepository<FamilyGroupManagerEntity>>();
|
||||
|
||||
FamilyGroupManagerEntity[] olds = repositoryFamilyGroupManager.Entities.Where(x => x.FamilyName == familyName).ToArray();
|
||||
if (olds != null && olds.Length > 0)
|
||||
{
|
||||
//存在更新，不存在删除
|
||||
foreach (FamilyGroupManagerEntity old in olds)
|
||||
{
|
||||
if (managers != null && managers.Length > 0 && managers.Where(x => x.UserName == old.UserName).Count() > 0)
|
||||
{
|
||||
FamilyGroupManagerDisplayData mg = managers.Where(x => x.UserName == old.UserName).FirstOrDefault();
|
||||
|
||||
old.ManagerIndc = mg.IsManager ? YesNoPolicy.YES : YesNoPolicy.NO;
|
||||
repositoryFamilyGroupManager.UpdateNow(old);
|
||||
}
|
||||
else
|
||||
{
|
||||
if (old.ValidIndc != YesNoPolicy.YES) continue;
|
||||
repositoryFamilyGroupManager.DeleteNow(old);
|
||||
|
||||
//删除成员的时候，也要删除成员对应的权限
|
||||
IRepository<FamilyGroupPermissionEntity> repositoryFamilyGroupPermission = repository.GetRepository<IRepository<FamilyGroupPermissionEntity>>();
|
||||
FamilyGroupPermissionEntity[] permissions = repositoryFamilyGroupPermission.DetachedEntities.Where(x => x.FamilyName == old.FamilyName && x.UserName == old.UserName).ToArray();
|
||||
if (permissions != null && permissions.Length > 0)
|
||||
{
|
||||
foreach (var item in permissions)
|
||||
{
|
||||
repositoryFamilyGroupPermission.DeleteNow(item);
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
[PermissionOperate(name: MasterPermissionPolicy.FamilyGroup, operate: Operate.Update)]
|
||||
[UnitOfWork]
|
||||
public FamilyGroupData Update(FamilyGroupData data)
|
||||
{
|
||||
FamilyGroupEntity familyGroup = repository.DetachedEntities.Where(x => x.FamilyName == data.FamilyGroup.FamilyName).FirstOrDefault();
|
||||
if (familyGroup == null)
|
||||
{
|
||||
throw new ValidatedException("记录不存在.");
|
||||
}
|
||||
|
||||
familyGroup = repository.DetachedEntities.Where(x => x.FamilyName != data.FamilyGroup.FamilyName && x.FamilyLocalName == data.FamilyGroup.FamilyLocalName).FirstOrDefault();
|
||||
if (familyGroup == null)
|
||||
{
|
||||
throw new ValidatedException("群组名称已存在.");
|
||||
}
|
||||
|
||||
ValidateHelper.Validate(service, data.FamilyGroup, FamilyGroupEntity.DB_NAME_FAMILY_GROUP);
|
||||
|
||||
familyGroup = new FamilyGroupEntity();
|
||||
ObjectCopyHelper.Copy(data.FamilyGroup, familyGroup);
|
||||
|
||||
ISecurityGeneratorNumberService securityGeneratorNumberService = service.ServiceProvider.GetService<ISecurityGeneratorNumberService>()!;
|
||||
|
||||
familyGroup.AddIndc = data.IsAdd ? YesNoPolicy.YES : YesNoPolicy.NO;
|
||||
familyGroup.OpenIndc = data.IsOpen ? YesNoPolicy.YES : YesNoPolicy.NO;
|
||||
|
||||
repository.UpdateNow(familyGroup);
|
||||
|
||||
SaveFamilyGroupFolders(familyGroup.FamilyName, data.FamilyGroupFolders);
|
||||
SavePermissions(familyGroup.FamilyName, data.FamilyGroupPermissions);
|
||||
SaveFamilyGroupManagers(familyGroup.FamilyName, data.FamilyGroupManagers);
|
||||
|
||||
//创建群根目录
|
||||
IDmsFileService dmsFileService = service.ServiceProvider.GetService<IDmsFileService>()!;
|
||||
dmsFileService.CreateFamilyDmsFolder(familyGroup, data.FamilyGroupFolders);
|
||||
|
||||
return FindByKey(familyGroup.FamilyName);
|
||||
}
|
||||
|
||||
|
||||
[PermissionOperate(name: MasterPermissionPolicy.FamilyGroup, operate: Operate.Delete)]
|
||||
[UnitOfWork]
|
||||
public void Delete(string key)
|
||||
{
|
||||
FamilyGroupEntity familyGroup = repository.DetachedEntities.Where(x => x.FamilyName == key).FirstOrDefault();
|
||||
if (familyGroup == null)
|
||||
{
|
||||
throw new ValidatedException("记录不存在.");
|
||||
}
|
||||
bool isManager = false;
|
||||
|
||||
IRepository<FamilyGroupManagerEntity> repositoryFamilyGroupManager = repository.GetRepository<IRepository<FamilyGroupManagerEntity>>();
|
||||
FamilyGroupManagerEntity[] fgms = repositoryFamilyGroupManager.DetachedEntities.Where(x => x.ManagerIndc == YesNoPolicy.YES && x.FamilyName == key && x.ValidIndc == YesNoPolicy.YES).ToArray();
|
||||
if (fgms == null || fgms.Length == 0)
|
||||
{
|
||||
throw new ValidatedException("您不是管理员,不能解散");
|
||||
}
|
||||
|
||||
familyGroup.ValidIndc = YesNoPolicy.NO;
|
||||
|
||||
repository.UpdateNow(familyGroup);
|
||||
|
||||
}
|
||||
|
||||
[PermissionOperate(name: MasterPermissionPolicy.FamilyGroup, operate: Operate.Update)]
|
||||
[UnitOfWork]
|
||||
public void InsertFamilyGroupManager(FamilyGroupManagerEntity manager)
|
||||
{
|
||||
IRepository<FamilyGroupManagerEntity> repositoryFamilyGroupManager = repository.GetRepository<IRepository<FamilyGroupManagerEntity>>();
|
||||
FamilyGroupManagerEntity org = repositoryFamilyGroupManager.DetachedEntities.Where(x => x.FamilyName == manager.FamilyName && x.UserName == service.UserId).FirstOrDefault()!;
|
||||
if (org != null) { return; }
|
||||
|
||||
org = new FamilyGroupManagerEntity();
|
||||
org.FamilyName = manager.FamilyName;
|
||||
org.UserName = service.UserId;
|
||||
org.ManagerIndc = YesNoPolicy.NO;
|
||||
org.ValidIndc = YesNoPolicy.NO;
|
||||
org.Notice = manager.Notice;
|
||||
|
||||
repositoryFamilyGroupManager.InsertNow(org);
|
||||
}
|
||||
|
||||
|
||||
[PermissionOperate(name: MasterPermissionPolicy.FamilyGroup, operate: Operate.Insert)]
|
||||
[UnitOfWork]
|
||||
public void InsertFamilyGroupPermission(FamilyGroupPermissionEntity[] managers)
|
||||
{
|
||||
IRepository<FamilyGroupPermissionEntity> repositoryFamilyGroupPermission = repository.GetRepository<IRepository<FamilyGroupPermissionEntity>>();
|
||||
|
||||
if (managers != null && managers.Length > 0)
|
||||
{
|
||||
foreach (FamilyGroupPermissionEntity manager in managers)
|
||||
{
|
||||
manager.DeleteIndc = YesNoPolicy.YES;
|
||||
manager.CreateIndc = YesNoPolicy.YES;
|
||||
repositoryFamilyGroupPermission.InsertNow(manager);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
[PermissionOperate(name: MasterPermissionPolicy.FamilyGroup, operate: Operate.Update)]
|
||||
[UnitOfWork]
|
||||
public void UpdateFamilyGroupManager(FamilyGroupManagerEntity manager)
|
||||
{
|
||||
IRepository<FamilyGroupManagerEntity> repositoryFamilyGroupManager = repository.GetRepository<IRepository<FamilyGroupManagerEntity>>();
|
||||
FamilyGroupManagerEntity org = repositoryFamilyGroupManager.DetachedEntities.Where(x => x.FamilyName == manager.FamilyName && x.UserName == manager.UserName).FirstOrDefault()!;
|
||||
if (org == null) { return; }
|
||||
|
||||
org.ValidIndc = manager.ValidIndc;
|
||||
|
||||
repositoryFamilyGroupManager.UpdateNow(org);
|
||||
}
|
||||
|
||||
[PermissionOperate(name: MasterPermissionPolicy.FamilyGroup, operate: Operate.Update)]
|
||||
[UnitOfWork]
|
||||
public void DeleteFamilyGroupManager(FamilyGroupManagerEntity manager)
|
||||
{
|
||||
IRepository<FamilyGroupManagerEntity> repositoryFamilyGroupManager = repository.GetRepository<IRepository<FamilyGroupManagerEntity>>();
|
||||
FamilyGroupManagerEntity org = repositoryFamilyGroupManager.DetachedEntities.Where(x => x.FamilyName == manager.FamilyName && x.UserName == manager.UserName).FirstOrDefault()!;
|
||||
if (org == null) { return; }
|
||||
|
||||
repositoryFamilyGroupManager.DeleteNow(org);
|
||||
}
|
||||
|
||||
[PermissionOperate(name: MasterPermissionPolicy.FamilyGroup, operate: Operate.Insert)]
|
||||
public void InsertFamilyFolderFavorite(string folderName)
|
||||
{
|
||||
IRepository<FamilyFolderFavoriteEntity> repositoryFamilyFolderFavorite = repository.GetRepository<IRepository<FamilyFolderFavoriteEntity>>();
|
||||
FamilyFolderFavoriteEntity folderFavorite = new FamilyFolderFavoriteEntity();
|
||||
folderFavorite.FolderName = folderName;
|
||||
folderFavorite.UserName = service.UserId;
|
||||
repositoryFamilyFolderFavorite.InsertNow(folderFavorite);
|
||||
}
|
||||
|
||||
[PermissionOperate(name: MasterPermissionPolicy.FamilyGroup, operate: Operate.Update)]
|
||||
public void DeleteFamilyFolderFavorite(string folderName)
|
||||
{
|
||||
IRepository<FamilyFolderFavoriteEntity> repositoryFamilyFolderFavorite = repository.GetRepository<IRepository<FamilyFolderFavoriteEntity>>();
|
||||
FamilyFolderFavoriteEntity folderFavorite = new FamilyFolderFavoriteEntity();
|
||||
folderFavorite.FolderName = folderName;
|
||||
folderFavorite.UserName = service.UserId;
|
||||
repositoryFamilyFolderFavorite.DeleteNow(folderFavorite);
|
||||
}
|
||||
|
||||
[PermissionOperate(name: MasterPermissionPolicy.FamilyGroup, operate: Operate.Update)]
|
||||
public void DeleteFamilyFolderFavorites(FamilyFolderFavoriteEntity[] familyFolderFavorites)
|
||||
{
|
||||
if (familyFolderFavorites == null || familyFolderFavorites.Length == 0) return;
|
||||
|
||||
IRepository<FamilyFolderFavoriteEntity> repositoryFamilyFolderFavorite = repository.GetRepository<IRepository<FamilyFolderFavoriteEntity>>();
|
||||
foreach (var item in familyFolderFavorites)
|
||||
{
|
||||
repositoryFamilyFolderFavorite.DeleteNow(item);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
}
|
||||
}
|
||||
@@ -53,7 +53,7 @@ namespace CloudBuilder.Master.Service
|
||||
FamilyPersonResultData data = new FamilyPersonResultData();
|
||||
FamilyPersonEntity[] list = null;
|
||||
|
||||
int count = 0;
|
||||
Int64 count = 0;
|
||||
|
||||
string sqlWhere = null;
|
||||
|
||||
@@ -79,7 +79,7 @@ namespace CloudBuilder.Master.Service
|
||||
if (list != null && list.Length > 0)
|
||||
{
|
||||
sql = entity.GetSelectCountFrom(sqlWhere);
|
||||
count = Convert.ToInt32(repository.ExecuteScalar(sql));
|
||||
count = Convert.ToInt64(repository.ExecuteScalar(sql));
|
||||
}
|
||||
|
||||
data.Limit = criteria.limit;
|
||||
|
||||
@@ -134,7 +134,7 @@ namespace CloudBuilder.Master.Service
|
||||
FamilyTreeResultData data = new FamilyTreeResultData();
|
||||
FamilyTreeViewEntity[] list = null;
|
||||
|
||||
int count = 0;
|
||||
Int64 count = 0;
|
||||
|
||||
string sqlWhere = null;
|
||||
|
||||
@@ -162,7 +162,7 @@ namespace CloudBuilder.Master.Service
|
||||
if (list != null && list.Length > 0)
|
||||
{
|
||||
sql = entity.GetSelectCountFrom(sqlWhere);
|
||||
count = Convert.ToInt32(repository.ExecuteScalar(sql));
|
||||
count = Convert.ToInt64(repository.ExecuteScalar(sql));
|
||||
}
|
||||
|
||||
data.Limit = criteria.limit;
|
||||
|
||||
@@ -0,0 +1,48 @@
|
||||
using CloudBuilder.Core.DatabaseAccessor.Entity;
|
||||
using CloudBuilder.Core.Service;
|
||||
using CloudBuilder.Security.Policy;
|
||||
using Microsoft.AspNetCore.Authorization;
|
||||
using Microsoft.AspNetCore.Mvc;
|
||||
using System;
|
||||
using System.Collections.Generic;
|
||||
using System.Linq;
|
||||
using System.Text;
|
||||
using System.Threading.Tasks;
|
||||
|
||||
namespace CloudBuilder.Master.Service
|
||||
{
|
||||
public class FileTypePolicyService : IFileTypePolicyService
|
||||
{
|
||||
private readonly IApplicationService service;
|
||||
|
||||
public FileTypePolicyService(IApplicationService service)
|
||||
{
|
||||
this.service = service;
|
||||
}
|
||||
|
||||
[AllowAnonymous]
|
||||
[HttpPost]
|
||||
public SelectOption[] FindSelectOption(bool blank)
|
||||
{
|
||||
FileTypePolicy policy = FileTypePolicy.GetInstance(service);
|
||||
string[] values = policy.GetValues();
|
||||
List<SelectOption> l = new List<SelectOption>();
|
||||
|
||||
SelectOption selectOption;
|
||||
if (blank)
|
||||
{
|
||||
selectOption = new SelectOption();
|
||||
l.Add(selectOption);
|
||||
}
|
||||
|
||||
foreach (string value in values)
|
||||
{
|
||||
selectOption = new SelectOption();
|
||||
selectOption.BindValue = value;
|
||||
selectOption.DisplayName = policy.ComposeMessage(value, service.Locale);
|
||||
l.Add(selectOption);
|
||||
}
|
||||
return l.ToArray();
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,407 @@
|
||||
|
||||
using CloudBuilder.Core.DatabaseAccessor;
|
||||
using CloudBuilder.Core.DatabaseAccessor.Entity;
|
||||
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;
|
||||
namespace CloudBuilder.Master.Service
|
||||
{
|
||||
public class PublishAudioService : IPublishAudioService
|
||||
{
|
||||
private readonly IApplicationService service;
|
||||
|
||||
private IRepository<PublishAudioEntity> repository;
|
||||
public PublishAudioService(IApplicationService service)
|
||||
{
|
||||
this.service = service;
|
||||
repository = service.GetRepository<IRepository<PublishAudioEntity>>();
|
||||
}
|
||||
|
||||
[PermissionOperate(name: MasterPermissionPolicy.PublishAudio, operate: Operate.Find)]
|
||||
public PublishAudioData FindByKey(string key)
|
||||
{
|
||||
PublishAudioData data = new PublishAudioData();
|
||||
if (string.IsNullOrEmpty(key)) return data;
|
||||
|
||||
PublishAudioEntity publish = repository.DetachedEntities.Where(x => x.PublishName == key).FirstOrDefault();
|
||||
|
||||
if (publish == null) return data;
|
||||
|
||||
IRepository<PublishAudioFamilyGroupEntity> repositoryPublishAudioFamilyGroup = repository.GetRepository<IRepository<PublishAudioFamilyGroupEntity>>();
|
||||
IRepository<FamilyGroupEntity> repositoryFamilyGroup = repository.GetRepository<IRepository<FamilyGroupEntity>>();
|
||||
|
||||
|
||||
IQueryable<PublishAudioFamilyGroupDisplayData>? q = from e in repositoryPublishAudioFamilyGroup.DetachedEntities
|
||||
join fg in repositoryFamilyGroup.DetachedEntities on e.FamilyName equals fg.FamilyName
|
||||
where e.PublishName == key
|
||||
select new PublishAudioFamilyGroupDisplayData(fg)
|
||||
{
|
||||
CreatedBy = e.CreatedBy,
|
||||
CreatedDatetime = e.CreatedDatetime,
|
||||
UpdatedBy = e.UpdatedBy,
|
||||
UpdatedDatetime = e.UpdatedDatetime,
|
||||
PublishName = e.PublishName,
|
||||
};
|
||||
|
||||
data.FamilyGroups = q.ToArray();
|
||||
if (publish.OwnerName != service.UserId && !YesNoPolicy.IsYes(publish.OpenIndc) && data.FamilyGroups.Length == 0)
|
||||
{
|
||||
throw new ValidatedException("没有权限.");
|
||||
}
|
||||
else if (publish.OwnerName != service.UserId && !YesNoPolicy.IsYes(publish.OpenIndc) && data.FamilyGroups.Length > 0)
|
||||
{
|
||||
IRepository<FamilyGroupManagerEntity> repositoryFamilyGroupManager = repository.GetRepository<IRepository<FamilyGroupManagerEntity>>();
|
||||
|
||||
IQueryable<string>? fgm = from e in repositoryFamilyGroupManager.DetachedEntities
|
||||
where e.UserName == service.UserId && data.FamilyGroups.Where(x => x.FamilyName == e.FamilyName).Count() > 0
|
||||
select e.UserName;
|
||||
|
||||
if (fgm.Count() == 0)
|
||||
throw new ValidatedException("没有权限.");
|
||||
}
|
||||
|
||||
data.PublishAudio = publish;
|
||||
|
||||
IRepository<PublishAudioDetailEntity> repositoryPublishAudioDetail = repository.GetRepository<IRepository<PublishAudioDetailEntity>>();
|
||||
data.Details = repositoryPublishAudioDetail.DetachedEntities.Where(x => x.PublishName == publish.PublishName).OrderBy(x => x.OrderBy).Select(x => new PublishAudioDetailDisplayData(x)).ToArray();
|
||||
|
||||
if (data.Details != null && data.Details.Length > 0)
|
||||
{
|
||||
var webRootPath = service.Configuration[ServiceSettingsPolicy.RequestPath];
|
||||
var phy = service.Configuration[ServiceSettingsPolicy.PhysicalFileDirectory];
|
||||
var scale = service.Configuration[ServiceSettingsPolicy.DmsFileScaleDirectory].Replace(phy, "");
|
||||
|
||||
foreach (var item in data.Details)
|
||||
{
|
||||
if (!string.IsNullOrEmpty(item.Pic) && FileTypePolicy.GetType(item.Pic!) == FileTypePolicy.PHOTO)
|
||||
{
|
||||
var fileExtension = Path.GetExtension(item.Pic);
|
||||
var filePathRel = Path.Combine(scale, item.CreatedBy, fileExtension.Replace(".", ""), "");
|
||||
var filePath = filePathRel.Replace(Path.DirectorySeparatorChar, '/');
|
||||
item.FormattedPic = service.Configuration[AppsettingsPolicy.ApplicationUrl] + webRootPath + filePath + item.Pic;
|
||||
}
|
||||
if (!string.IsNullOrEmpty(item.Url) && FileTypePolicy.GetType(item.Url!) == FileTypePolicy.AUDIO)
|
||||
{
|
||||
var fileExtension = Path.GetExtension(item.Url);
|
||||
var backup = service.Configuration[ServiceSettingsPolicy.DmsFileBackupDirectory].Replace(phy, "");
|
||||
var filePathRel = Path.Combine(backup, item.CreatedBy, fileExtension.Replace(".", ""), "");
|
||||
var filePath = filePathRel.Replace(Path.DirectorySeparatorChar, '/');
|
||||
item.FormattedUrl = service.Configuration[AppsettingsPolicy.ApplicationUrl] + webRootPath + filePath + item.Url;
|
||||
}
|
||||
if (!string.IsNullOrEmpty(item.Lrc) && FileTypePolicy.GetType(item.Lrc!) == FileTypePolicy.LYRIC)
|
||||
{
|
||||
var fileExtension = Path.GetExtension(item.Lrc);
|
||||
var upload = service.Configuration[ServiceSettingsPolicy.DmsFileUploadDirectory].Replace(phy, "");
|
||||
var filePathRel = Path.Combine(upload, item.CreatedBy, fileExtension.Replace(".", ""), "");
|
||||
var filePath = filePathRel.Replace(Path.DirectorySeparatorChar, '/');
|
||||
item.FormattedLrc = service.Configuration[AppsettingsPolicy.ApplicationUrl] + webRootPath + filePath + item.Lrc;
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
return data;
|
||||
}
|
||||
|
||||
[PermissionOperate(name: MasterPermissionPolicy.PublishAudio, operate: Operate.Find)]
|
||||
public PublishAudioResultData FindBySearchCriteria(PublishAudioSearchCriteria criteria)
|
||||
{
|
||||
PublishAudioResultData data = new PublishAudioResultData();
|
||||
PublishAudioEntity[] list = null;
|
||||
|
||||
Int64 count = 0;
|
||||
|
||||
string sqlWhere = null;
|
||||
|
||||
if (criteria.Filter != null && criteria.Filter.Length > 0)
|
||||
{
|
||||
sqlWhere = SearchFilter.ComposeWhereClause(criteria.Filter);
|
||||
}
|
||||
|
||||
sqlWhere = sqlWhere + string.Format(" and ({0} ='{1}' or {2} ='{3}') ",
|
||||
PublishAudioEntity.DB_OWNER_NAME, service.UserId,
|
||||
PublishAudioEntity.DB_OPEN_INDC, criteria.IsModal ? service.UserId : YesNoPolicy.YES);
|
||||
|
||||
PublishAudioEntity entity = PublishAudioEntity.GetInstance(repository.GetDbContext().Database.ProviderName);
|
||||
string sql = entity.GetSelectTopFrom(criteria.limit, criteria.page, criteria.orderby.StringToDbField(), criteria.orderbytag, sqlWhere);
|
||||
|
||||
string err = null;
|
||||
try
|
||||
{
|
||||
list = repository.FromSql(sql).ToArray();
|
||||
}
|
||||
catch (System.Exception ex)
|
||||
{
|
||||
err = ex.Message;
|
||||
}
|
||||
|
||||
|
||||
if (list != null && list.Length > 0)
|
||||
{
|
||||
sql = entity.GetSelectCountFrom(sqlWhere);
|
||||
count = Convert.ToInt64(repository.ExecuteScalar(sql));
|
||||
}
|
||||
|
||||
data.Limit = criteria.limit;
|
||||
data.Page = criteria.page;
|
||||
data.Datas = list;
|
||||
data.Total = count;
|
||||
//data.Sql = sql;
|
||||
data.ErrorMessage = err;
|
||||
return data;
|
||||
}
|
||||
|
||||
[PermissionOperate(name: MasterPermissionPolicy.PublishAudio, operate: Operate.Find)]
|
||||
public PublishAudioData FindPublishAudioDefault()
|
||||
{
|
||||
PublishAudioEntity publish = repository.DetachedEntities.Where(x => x.OwnerName == service.UserId && x.DefaultIndc == YesNoPolicy.YES).FirstOrDefault();
|
||||
if (publish == null) return null;
|
||||
return FindByKey(publish.PublishName);
|
||||
}
|
||||
|
||||
[PermissionOperate(name: MasterPermissionPolicy.PublishAudio, operate: Operate.Print)]
|
||||
public dynamic PrintBySearchCriteria(PublishAudioSearchCriteria criteria)
|
||||
{
|
||||
throw new NotImplementedException();
|
||||
}
|
||||
|
||||
[PermissionOperate(name: MasterPermissionPolicy.PublishAudio, operate: Operate.Insert)]
|
||||
[UnitOfWork]
|
||||
public PublishAudioData Insert(PublishAudioData data)
|
||||
{
|
||||
PublishAudioEntity photoPublish = repository.DetachedEntities.Where(x => x.PublishLocalName == data.PublishAudio.PublishLocalName).FirstOrDefault();
|
||||
if (photoPublish != null)
|
||||
{
|
||||
throw new ValidatedException($"[{photoPublish.PublishLocalName}]已发布.");
|
||||
}
|
||||
|
||||
Validate(data.PublishAudio);
|
||||
|
||||
if (data.PublishAudio.DefaultIndc == YesNoPolicy.YES)
|
||||
{
|
||||
CancelDefaultIndc(null);
|
||||
}
|
||||
|
||||
photoPublish = new PublishAudioEntity();
|
||||
ObjectCopyHelper.Copy(data.PublishAudio, photoPublish);
|
||||
|
||||
ISecurityGeneratorNumberService securityGeneratorNumberService = service.ServiceProvider.GetService<ISecurityGeneratorNumberService>()!;
|
||||
|
||||
photoPublish.PublishName = securityGeneratorNumberService.GetNo(MasterPrefixPolicy.AUDIO_PUBLISH, MasterPrefixPolicy.AUDIO_PUBLISH_PUBLISH_NAME, "AP", YesNoPolicy.YES, "yymmdd00000");
|
||||
photoPublish.OwnerName = service.UserId;
|
||||
|
||||
repository.InsertNow(photoPublish);
|
||||
|
||||
SavePublishAudioFamilyGroup(photoPublish.PublishName, data.FamilyGroups);
|
||||
|
||||
return FindByKey(photoPublish.PublishName);
|
||||
}
|
||||
|
||||
[PermissionOperate(name: MasterPermissionPolicy.PublishAudio, operate: Operate.Update)]
|
||||
[UnitOfWork]
|
||||
public PublishAudioData Update(PublishAudioData data)
|
||||
{
|
||||
PublishAudioEntity publishEntity = repository.DetachedEntities.Where(x => x.OwnerName == service.UserId && x.PublishName == data.PublishAudio.PublishName).FirstOrDefault();
|
||||
if (publishEntity == null)
|
||||
{
|
||||
throw new ValidatedException("你不是发布者无法修改.");
|
||||
}
|
||||
|
||||
ValidateHelper.Validate(service, data.PublishAudio, PublishAudioEntity.DB_NAME_PUBLISH_AUDIO);
|
||||
|
||||
if (data.PublishAudio.DefaultIndc == YesNoPolicy.YES)
|
||||
{
|
||||
CancelDefaultIndc(data.PublishAudio.PublishName);
|
||||
}
|
||||
|
||||
publishEntity = new PublishAudioEntity();
|
||||
ObjectCopyHelper.Copy(data.PublishAudio, publishEntity);
|
||||
|
||||
repository.UpdateNow(publishEntity);
|
||||
|
||||
//只有删除和更新，没有插入
|
||||
SavePublishAudioDetails(publishEntity.PublishName, data.Details);
|
||||
|
||||
SavePublishAudioFamilyGroup(publishEntity.PublishName, data.FamilyGroups);
|
||||
|
||||
return FindByKey(publishEntity.PublishName);
|
||||
}
|
||||
|
||||
private void SavePublishAudioDetails(string publishName, PublishAudioDetailEntity[] details)
|
||||
{
|
||||
if (details != null && details.Length > 0)
|
||||
{
|
||||
int i = 1;
|
||||
foreach (PublishAudioDetailEntity dtl in details)
|
||||
{
|
||||
dtl.OrderBy = i++;
|
||||
}
|
||||
}
|
||||
|
||||
IRepository<PublishAudioDetailEntity> repositoryPublishAudioDetail = repository.GetRepository<IRepository<PublishAudioDetailEntity>>();
|
||||
|
||||
PublishAudioDetailEntity[] olds = repositoryPublishAudioDetail.Entities.Where(x => x.PublishName == publishName).ToArray();
|
||||
if (olds != null && olds.Length > 0)
|
||||
{
|
||||
//存在更新，不存在删除
|
||||
|
||||
foreach (PublishAudioDetailEntity old in olds)
|
||||
{
|
||||
if (details != null && details.Length > 0 && details.Where(x => x.DetailId == old.DetailId).Count() > 0)
|
||||
{
|
||||
PublishAudioDetailEntity dtl = details.Where(x => x.DetailId == old.DetailId).FirstOrDefault();
|
||||
|
||||
old.Title = dtl.Title;
|
||||
old.Author = dtl.Author;
|
||||
old.Pic = dtl.Pic;
|
||||
old.Url = dtl.Url;
|
||||
old.Lrc = dtl.Lrc;
|
||||
old.OrderBy = dtl.OrderBy;
|
||||
old.Notice = dtl.Notice;
|
||||
|
||||
repositoryPublishAudioDetail.UpdateNow(old);
|
||||
}
|
||||
else
|
||||
{
|
||||
repositoryPublishAudioDetail.DeleteNow(old);
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
private void Validate(PublishAudioEntity photoPublish)
|
||||
{
|
||||
List<SysTableSchemaViewEntity> sysTableSchemas = service.ServiceProvider.GetRequiredService<ISysTableSchemaViewService>().FindByTableName(PublishAudioEntity.DB_NAME_PUBLISH_AUDIO);
|
||||
ValidateHelper.ValidateString(photoPublish, sysTableSchemas.ToArray());
|
||||
}
|
||||
|
||||
private void SavePublishAudioFamilyGroup(string publishName, PublishAudioFamilyGroupEntity[] familyGroups)
|
||||
{
|
||||
IRepository<PublishAudioFamilyGroupEntity> repositoryPublishAudioFamilyGroup = repository.GetRepository<IRepository<PublishAudioFamilyGroupEntity>>();
|
||||
|
||||
PublishAudioFamilyGroupEntity[] olds = repositoryPublishAudioFamilyGroup.Entities.Where(x => x.PublishName == publishName).ToArray();
|
||||
if (olds != null && olds.Length > 0)
|
||||
{
|
||||
//存在更新，不存在删除
|
||||
|
||||
foreach (PublishAudioFamilyGroupEntity old in olds)
|
||||
{
|
||||
if (familyGroups != null && familyGroups.Length > 0 && familyGroups.Where(x => x.FamilyName == old.FamilyName).Count() > 0)
|
||||
{
|
||||
//只有主键，无需更新
|
||||
//repositoryPpf.UpdateNow(old);
|
||||
}
|
||||
else
|
||||
{
|
||||
repositoryPublishAudioFamilyGroup.DeleteNow(old);
|
||||
}
|
||||
}
|
||||
}
|
||||
if (familyGroups != null && familyGroups.Length > 0)
|
||||
foreach (PublishAudioFamilyGroupEntity dto in familyGroups)
|
||||
{
|
||||
if (string.IsNullOrEmpty(dto.CreatedBy))
|
||||
repositoryPublishAudioFamilyGroup.InsertNow(new PublishAudioFamilyGroupEntity()
|
||||
{
|
||||
PublishName = publishName,
|
||||
FamilyName = dto.FamilyName,
|
||||
});
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
public void CancelDefaultIndc(string publishLocalName)
|
||||
{
|
||||
PublishAudioEntity[] orgs = repository.DetachedEntities.Where(x => x.PublishName != publishLocalName && x.OwnerName == service.UserId && x.DefaultIndc == YesNoPolicy.YES).ToArray();
|
||||
foreach (PublishAudioEntity org in orgs)
|
||||
{
|
||||
org.DefaultIndc = YesNoPolicy.NO;
|
||||
}
|
||||
|
||||
if (orgs != null && orgs.Length > 0)
|
||||
repository.UpdateNow(orgs);
|
||||
}
|
||||
|
||||
[PermissionOperate(name: MasterPermissionPolicy.PublishAudio, operate: Operate.Delete)]
|
||||
[UnitOfWork]
|
||||
public void Delete(string key)
|
||||
{
|
||||
PublishAudioEntity publishEntity = repository.DetachedEntities.Where(x => x.OwnerName == service.UserId && x.PublishName == key).FirstOrDefault();
|
||||
if (publishEntity == null)
|
||||
{
|
||||
throw new ValidatedException("你不是发布者无法删除.");
|
||||
}
|
||||
|
||||
repository.DeleteNow(publishEntity);
|
||||
|
||||
|
||||
IRepository<PublishAudioDetailEntity> repositoryDetail = repository.GetRepository<IRepository<PublishAudioDetailEntity>>();
|
||||
|
||||
PublishAudioDetailEntity[] detail = repositoryDetail.Entities.Where(x => x.PublishName == key).ToArray();
|
||||
if (detail != null && detail.Length > 0)
|
||||
{
|
||||
foreach (PublishAudioDetailEntity dtl in detail)
|
||||
{
|
||||
repositoryDetail.DeleteNow(dtl);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
IRepository<PublishAudioFamilyGroupEntity> repositoryFamilyGroup = repository.GetRepository<IRepository<PublishAudioFamilyGroupEntity>>();
|
||||
|
||||
PublishAudioFamilyGroupEntity[] groups = repositoryFamilyGroup.Entities.Where(x => x.PublishName == key).ToArray();
|
||||
if (groups != null && groups.Length > 0)
|
||||
{
|
||||
foreach (PublishAudioFamilyGroupEntity gp in groups)
|
||||
{
|
||||
repositoryFamilyGroup.DeleteNow(gp);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
[PermissionOperate(name: MasterPermissionPolicy.PublishAudio, operate: Operate.Insert)]
|
||||
public void InsertPublishAudioDetail(PublishData publishData)
|
||||
{
|
||||
IRepository<DmsFileUploadViewEntity> repositoryDmsFile = repository.GetRepository<IRepository<DmsFileUploadViewEntity>>();
|
||||
DmsFileUploadViewEntity dmsFile = repositoryDmsFile.DetachedEntities.Where(x => x.FileId == publishData.FileId).FirstOrDefault();
|
||||
|
||||
if (dmsFile == null) return;
|
||||
if (!FileTypePolicy.IsAudio(dmsFile.OrderKey)) return;
|
||||
|
||||
InsertPublishAudioDetail(dmsFile, publishData.PublishName);
|
||||
}
|
||||
|
||||
private void InsertPublishAudioDetail(DmsFileUploadViewEntity dmsFile, string publishName)
|
||||
{
|
||||
IRepository<PublishAudioDetailEntity> repositoryPublishAudioDetail = repository.GetRepository<IRepository<PublishAudioDetailEntity>>();
|
||||
|
||||
PublishAudioDetailEntity[] dtls = repositoryPublishAudioDetail.DetachedEntities.Where(x => x.PublishName == publishName).ToArray();
|
||||
|
||||
if (dtls != null && dtls.Where(x => x.Url == dmsFile.OrderKey).Count() > 0) return;
|
||||
|
||||
PublishAudioDetailEntity dtl = new PublishAudioDetailEntity();
|
||||
dtl.PublishName = publishName;
|
||||
string orgFileName = Path.GetFileNameWithoutExtension(dmsFile.OrgFileName);
|
||||
string[] tts = orgFileName.Split('-');
|
||||
dtl.Title = tts[0].Trim();
|
||||
if (tts.Length > 1) dtl.Author = tts[1].Trim();
|
||||
|
||||
dtl.OwnerName = dmsFile.OwerId;
|
||||
if (dtls != null && dtls.Length > 0)
|
||||
dtl.OrderBy = dtls.Sum(x => x.OrderBy) + 1;
|
||||
dtl.Url = dmsFile.OrderKey;
|
||||
|
||||
repositoryPublishAudioDetail.InsertNow(dtl);
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,441 @@
|
||||
|
||||
using CloudBuilder.Core.DatabaseAccessor.Entity;
|
||||
using Microsoft.AspNetCore.Authorization;
|
||||
using CloudBuilder.Core.DatabaseAccessor;
|
||||
using CloudBuilder.Master.Entity;
|
||||
using CloudBuilder.Master.Policy;
|
||||
using CloudBuilder.Master.SearchCriteria;
|
||||
using CloudBuilder.Master.Data;
|
||||
using CloudBuilder.Core.Service;
|
||||
using System.Diagnostics;
|
||||
using CloudBuilder.Security.Service;
|
||||
using Microsoft.Extensions.DependencyInjection;
|
||||
using CloudBuilder.Security.Entity;
|
||||
using CloudBuilder.Security.Utility;
|
||||
using CloudBuilder.Security.Policy;
|
||||
using CloudBuilder.Core.Policy;
|
||||
namespace CloudBuilder.Master.Service
|
||||
{
|
||||
public class PublishPhotoService : IPublishPhotoService
|
||||
{
|
||||
private readonly IApplicationService service;
|
||||
|
||||
private IRepository<PublishPhotoEntity> repository;
|
||||
public PublishPhotoService(IApplicationService service)
|
||||
{
|
||||
this.service = service;
|
||||
repository = service.GetRepository<IRepository<PublishPhotoEntity>>();
|
||||
}
|
||||
|
||||
[PermissionOperate(name: MasterPermissionPolicy.PublishPhoto, operate: Operate.Find)]
|
||||
public PublishPhotoData FindByKey(string key)
|
||||
{
|
||||
PublishPhotoData data = new PublishPhotoData();
|
||||
if (string.IsNullOrEmpty(key)) return data;
|
||||
|
||||
PublishPhotoEntity publish = repository.DetachedEntities.Where(x => x.PublishName == key).FirstOrDefault();
|
||||
|
||||
if (publish == null) return data;
|
||||
|
||||
IRepository<PublishPhotoFamilyGroupEntity> repositoryPublishPhotoFamilyGroup = repository.GetRepository<IRepository<PublishPhotoFamilyGroupEntity>>();
|
||||
IRepository<FamilyGroupEntity> repositoryFamilyGroup = repository.GetRepository<IRepository<FamilyGroupEntity>>();
|
||||
|
||||
|
||||
IQueryable<PublishPhotoFamilyGroupDisplayData>? q = from e in repositoryPublishPhotoFamilyGroup.DetachedEntities
|
||||
join fg in repositoryFamilyGroup.DetachedEntities on e.FamilyName equals fg.FamilyName
|
||||
where e.PublishName == key
|
||||
select new PublishPhotoFamilyGroupDisplayData(fg)
|
||||
{
|
||||
CreatedBy = e.CreatedBy,
|
||||
CreatedDatetime = e.CreatedDatetime,
|
||||
UpdatedBy = e.UpdatedBy,
|
||||
UpdatedDatetime = e.UpdatedDatetime,
|
||||
PublishName = e.PublishName,
|
||||
};
|
||||
|
||||
data.FamilyGroups = q.ToArray();
|
||||
if (publish.OwnerName != service.UserId && !YesNoPolicy.IsYes(publish.OpenIndc) && data.FamilyGroups.Length == 0)
|
||||
{
|
||||
throw new ValidatedException("没有权限.");
|
||||
}
|
||||
else if (publish.OwnerName != service.UserId && !YesNoPolicy.IsYes(publish.OpenIndc) && data.FamilyGroups.Length > 0)
|
||||
{
|
||||
IRepository<FamilyGroupManagerEntity> repositoryFamilyGroupManager = repository.GetRepository<IRepository<FamilyGroupManagerEntity>>();
|
||||
|
||||
IQueryable<string>? fgm = from e in repositoryFamilyGroupManager.DetachedEntities
|
||||
where e.UserName == service.UserId && data.FamilyGroups.Where(x => x.FamilyName == e.FamilyName).Count() > 0
|
||||
select e.UserName;
|
||||
|
||||
if (fgm.Count() == 0)
|
||||
throw new ValidatedException("没有权限.");
|
||||
}
|
||||
|
||||
data.PublishPhoto = publish;
|
||||
|
||||
IRepository<PublishPhotoDetailEntity> repositoryPublishPhotoDetail = repository.GetRepository<IRepository<PublishPhotoDetailEntity>>();
|
||||
data.Details = repositoryPublishPhotoDetail.DetachedEntities.Where(x => x.PublishName == publish.PublishName).OrderBy(x => x.OrderBy).ToArray();
|
||||
|
||||
|
||||
bool isAttached = Debugger.IsAttached;
|
||||
if (data.Details != null || data.Details.Length > 0)
|
||||
foreach (var item in data.Details)
|
||||
{
|
||||
item.FileName = (isAttached ? service.Configuration[AppsettingsPolicy.ApplicationUrl] : "") + item.FileName;
|
||||
}
|
||||
|
||||
|
||||
return data;
|
||||
}
|
||||
|
||||
|
||||
[PermissionOperate(name: MasterPermissionPolicy.PublishPhoto, operate: Operate.Find)]
|
||||
public PublishPhotoResultData FindBySearchCriteria(PublishPhotoSearchCriteria criteria)
|
||||
{
|
||||
PublishPhotoResultData data = new PublishPhotoResultData();
|
||||
PublishPhotoEntity[] list = null;
|
||||
|
||||
Int64 count = 0;
|
||||
|
||||
string sqlWhere = null;
|
||||
|
||||
if (criteria.Filter != null && criteria.Filter.Length > 0)
|
||||
{
|
||||
sqlWhere = SearchFilter.ComposeWhereClause(criteria.Filter);
|
||||
}
|
||||
|
||||
sqlWhere = sqlWhere + string.Format(" and ({0} ='{1}' or {2} ='{3}') ",
|
||||
PublishPhotoEntity.DB_OWNER_NAME, service.UserId,
|
||||
PublishPhotoEntity.DB_OPEN_INDC, criteria.IsModal ? service.UserId : YesNoPolicy.YES);
|
||||
|
||||
PublishPhotoEntity entity = PublishPhotoEntity.GetInstance(repository.GetDbContext().Database.ProviderName);
|
||||
string sql = entity.GetSelectTopFrom(criteria.limit, criteria.page, criteria.orderby.StringToDbField(), criteria.orderbytag, sqlWhere);
|
||||
|
||||
string err = null;
|
||||
try
|
||||
{
|
||||
list = repository.FromSql(sql).ToArray();
|
||||
}
|
||||
catch (System.Exception ex)
|
||||
{
|
||||
err = ex.Message;
|
||||
}
|
||||
|
||||
|
||||
if (list != null && list.Length > 0)
|
||||
{
|
||||
sql = entity.GetSelectCountFrom(sqlWhere);
|
||||
count = Convert.ToInt64(repository.ExecuteScalar(sql));
|
||||
}
|
||||
|
||||
data.Limit = criteria.limit;
|
||||
data.Page = criteria.page;
|
||||
data.Publishs = list;
|
||||
data.Total = count;
|
||||
//data.Sql = sql;
|
||||
data.ErrorMessage = err;
|
||||
return data;
|
||||
}
|
||||
|
||||
[PermissionOperate(name: MasterPermissionPolicy.PublishPhoto, operate: Operate.Print)]
|
||||
public dynamic PrintBySearchCriteria(PublishPhotoSearchCriteria criteria)
|
||||
{
|
||||
throw new NotImplementedException();
|
||||
}
|
||||
|
||||
[PermissionOperate(name: MasterPermissionPolicy.PublishPhoto, operate: Operate.Insert)]
|
||||
[UnitOfWork]
|
||||
public PublishPhotoData Insert(PublishPhotoData data)
|
||||
{
|
||||
PublishPhotoEntity publishPhoto = repository.DetachedEntities.Where(x => x.PublishLocalName == data.PublishPhoto.PublishLocalName).FirstOrDefault();
|
||||
if (publishPhoto != null)
|
||||
{
|
||||
throw new ValidatedException($"[{publishPhoto.PublishLocalName}]已发布.");
|
||||
}
|
||||
|
||||
Validate(data.PublishPhoto);
|
||||
|
||||
if (data.PublishPhoto.DefaultIndc == YesNoPolicy.YES)
|
||||
{
|
||||
CancelDefaultIndc(null);
|
||||
}
|
||||
|
||||
publishPhoto = new PublishPhotoEntity();
|
||||
ObjectCopyHelper.Copy(data.PublishPhoto, publishPhoto);
|
||||
|
||||
ISecurityGeneratorNumberService securityGeneratorNumberService = service.ServiceProvider.GetService<ISecurityGeneratorNumberService>()!;
|
||||
|
||||
publishPhoto.PublishName = securityGeneratorNumberService.GetNo(MasterPrefixPolicy.PHOTO_PUBLISH, MasterPrefixPolicy.PHOTO_PUBLISH_PUBLISH_NAME, "PP", YesNoPolicy.YES, "yymmdd00000");
|
||||
publishPhoto.OwnerName = service.UserId;
|
||||
|
||||
repository.InsertNow(publishPhoto);
|
||||
|
||||
SavePublishPhotoFamilyGroup(publishPhoto.PublishName, data.FamilyGroups);
|
||||
|
||||
return FindByKey(publishPhoto.PublishName);
|
||||
}
|
||||
|
||||
public void CancelDefaultIndc(string publishLocalName)
|
||||
{
|
||||
PublishPhotoEntity[] orgs = repository.DetachedEntities.Where(x => x.PublishName != publishLocalName && x.OwnerName == service.UserId && x.DefaultIndc == YesNoPolicy.YES).ToArray();
|
||||
foreach (PublishPhotoEntity org in orgs)
|
||||
{
|
||||
org.DefaultIndc = YesNoPolicy.NO;
|
||||
}
|
||||
|
||||
if (orgs != null && orgs.Length > 0)
|
||||
repository.UpdateNow(orgs);
|
||||
}
|
||||
|
||||
private void Validate(PublishPhotoEntity publishPhoto)
|
||||
{
|
||||
List<SysTableSchemaViewEntity> sysTableSchemas = service.ServiceProvider.GetRequiredService<ISysTableSchemaViewService>().FindByTableName(PublishPhotoEntity.DB_NAME_PUBLISH_PHOTO);
|
||||
ValidateHelper.ValidateString(publishPhoto, sysTableSchemas.ToArray());
|
||||
}
|
||||
|
||||
|
||||
[PermissionOperate(name: MasterPermissionPolicy.PublishPhoto, operate: Operate.Update)]
|
||||
[UnitOfWork]
|
||||
public PublishPhotoData Update(PublishPhotoData data)
|
||||
{
|
||||
//只有自己创建的才能修改
|
||||
PublishPhotoEntity publishEntity = repository.DetachedEntities.Where(x => x.OwnerName == service.UserId && x.PublishName == data.PublishPhoto.PublishName).FirstOrDefault();
|
||||
if (publishEntity == null)
|
||||
{
|
||||
throw new ValidatedException("记录不存在.");
|
||||
}
|
||||
|
||||
ValidateHelper.Validate(service, data.PublishPhoto, PublishPhotoEntity.DB_NAME_PUBLISH_PHOTO);
|
||||
|
||||
if (data.PublishPhoto.DefaultIndc == YesNoPolicy.YES)
|
||||
{
|
||||
CancelDefaultIndc(data.PublishPhoto.PublishName);
|
||||
}
|
||||
|
||||
publishEntity = new PublishPhotoEntity();
|
||||
ObjectCopyHelper.Copy(data.PublishPhoto, publishEntity);
|
||||
|
||||
repository.UpdateNow(publishEntity);
|
||||
|
||||
//只有删除和更新，没有插入
|
||||
SavePublishPhotoDetails(publishEntity.PublishName, data.Details);
|
||||
|
||||
SavePublishPhotoFamilyGroup(publishEntity.PublishName, data.FamilyGroups);
|
||||
|
||||
return FindByKey(publishEntity.PublishName);
|
||||
}
|
||||
|
||||
private void SavePublishPhotoFamilyGroup(string publishName, PublishPhotoFamilyGroupEntity[] familyGroups)
|
||||
{
|
||||
IRepository<PublishPhotoFamilyGroupEntity> repositoryPublishPhotoFamilyGroup = repository.GetRepository<IRepository<PublishPhotoFamilyGroupEntity>>();
|
||||
|
||||
PublishPhotoFamilyGroupEntity[] olds = repositoryPublishPhotoFamilyGroup.Entities.Where(x => x.PublishName == publishName).ToArray();
|
||||
if (olds != null && olds.Length > 0)
|
||||
{
|
||||
//存在更新，不存在删除
|
||||
|
||||
foreach (PublishPhotoFamilyGroupEntity old in olds)
|
||||
{
|
||||
if (familyGroups != null && familyGroups.Length > 0 && familyGroups.Where(x => x.FamilyName == old.FamilyName).Count() > 0)
|
||||
{
|
||||
//只有主键，无需更新
|
||||
//repositoryPpf.UpdateNow(old);
|
||||
}
|
||||
else
|
||||
{
|
||||
repositoryPublishPhotoFamilyGroup.DeleteNow(old);
|
||||
}
|
||||
}
|
||||
}
|
||||
if (familyGroups != null && familyGroups.Length > 0)
|
||||
foreach (PublishPhotoFamilyGroupEntity dto in familyGroups)
|
||||
{
|
||||
if (string.IsNullOrEmpty(dto.CreatedBy))
|
||||
repositoryPublishPhotoFamilyGroup.InsertNow(new PublishPhotoFamilyGroupEntity()
|
||||
{
|
||||
PublishName = publishName,
|
||||
FamilyName = dto.FamilyName,
|
||||
});
|
||||
}
|
||||
}
|
||||
|
||||
private void SavePublishPhotoDetails(string publishName, PublishPhotoDetailEntity[] details)
|
||||
{
|
||||
if (details != null && details.Length > 0)
|
||||
{
|
||||
int i = 1;
|
||||
foreach (PublishPhotoDetailEntity dtl in details)
|
||||
{
|
||||
dtl.OrderBy = i++;
|
||||
}
|
||||
}
|
||||
|
||||
IRepository<PublishPhotoDetailEntity> repositoryPublishPhotoDetail = repository.GetRepository<IRepository<PublishPhotoDetailEntity>>();
|
||||
|
||||
PublishPhotoDetailEntity[] olds = repositoryPublishPhotoDetail.Entities.Where(x => x.PublishName == publishName).ToArray();
|
||||
if (olds != null && olds.Length > 0)
|
||||
{
|
||||
//存在更新，不存在删除
|
||||
|
||||
foreach (PublishPhotoDetailEntity old in olds)
|
||||
{
|
||||
if (details != null && details.Length > 0 && details.Where(x => x.DetailId == old.DetailId).Count() > 0)
|
||||
{
|
||||
PublishPhotoDetailEntity dtl = details.Where(x => x.DetailId == old.DetailId).FirstOrDefault();
|
||||
|
||||
old.OrderBy = dtl.OrderBy;
|
||||
old.Notice = dtl.Notice;
|
||||
|
||||
repositoryPublishPhotoDetail.UpdateNow(old);
|
||||
}
|
||||
else
|
||||
{
|
||||
repositoryPublishPhotoDetail.DeleteNow(old);
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
[PermissionOperate(name: MasterPermissionPolicy.PublishPhoto, operate: Operate.Delete)]
|
||||
[UnitOfWork]
|
||||
public void Delete(string key)
|
||||
{
|
||||
PublishPhotoEntity publishEntity = repository.DetachedEntities.Where(x => x.OwnerName == service.UserId && x.PublishName == key).FirstOrDefault();
|
||||
if (publishEntity == null)
|
||||
{
|
||||
throw new ValidatedException("记录不存在.");
|
||||
}
|
||||
|
||||
repository.DeleteNow(publishEntity);
|
||||
|
||||
IRepository<PublishPhotoDetailEntity> repositoryDetail = repository.GetRepository<IRepository<PublishPhotoDetailEntity>>();
|
||||
|
||||
PublishPhotoDetailEntity[] detail = repositoryDetail.Entities.Where(x => x.PublishName == key).ToArray();
|
||||
if (detail != null && detail.Length > 0)
|
||||
{
|
||||
foreach (PublishPhotoDetailEntity dtl in detail)
|
||||
{
|
||||
repositoryDetail.DeleteNow(dtl);
|
||||
}
|
||||
}
|
||||
|
||||
IRepository<PublishPhotoFamilyGroupEntity> repositoryFamilyGroup = repository.GetRepository<IRepository<PublishPhotoFamilyGroupEntity>>();
|
||||
|
||||
PublishPhotoFamilyGroupEntity[] groups = repositoryFamilyGroup.Entities.Where(x => x.PublishName == key).ToArray();
|
||||
if (groups != null && groups.Length > 0)
|
||||
{
|
||||
foreach (PublishPhotoFamilyGroupEntity gp in groups)
|
||||
{
|
||||
repositoryFamilyGroup.DeleteNow(gp);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
[AllowAnonymous]
|
||||
public PublishPhotoDetailEntity[] FindPublishPhotoDetailByPublishName(string publishName)
|
||||
{
|
||||
List<PublishPhotoDetailEntity> publishPhotoDetails = new List<PublishPhotoDetailEntity>();
|
||||
if (string.IsNullOrEmpty(publishName)) return publishPhotoDetails.ToArray();
|
||||
|
||||
IRepository<PublishPhotoEntity> repositoryPublishPhoto = repository.GetRepository<IRepository<PublishPhotoEntity>>();
|
||||
PublishPhotoEntity publishPhoto = repositoryPublishPhoto.DetachedEntities.Where(x => x.OwnerName == service.UserId && x.PublishName == publishName).FirstOrDefault();
|
||||
|
||||
if (publishPhoto == null)
|
||||
return publishPhotoDetails.ToArray();
|
||||
|
||||
IRepository<PublishPhotoDetailEntity> repositoryPublishPhotoDetail = repository.GetRepository<IRepository<PublishPhotoDetailEntity>>();
|
||||
PublishPhotoDetailEntity[] dtls = repositoryPublishPhotoDetail.DetachedEntities.Where(x => x.PublishName == publishName).OrderBy(x => x.OrderBy).ToArray();
|
||||
|
||||
if (dtls == null || dtls.Length == 0) return publishPhotoDetails.ToArray();
|
||||
|
||||
bool isAttached = Debugger.IsAttached;
|
||||
foreach (var item in dtls)
|
||||
{
|
||||
if (item.FileName.ToLower().StartsWith("http")) continue;
|
||||
|
||||
item.FileName = (isAttached ? service.Configuration[AppsettingsPolicy.ApplicationUrl] : "") + item.FileName;
|
||||
}
|
||||
|
||||
return dtls;
|
||||
}
|
||||
|
||||
[AllowAnonymous]
|
||||
public PublishPhotoDetailEntity[] FindPublishPhotoDetail()
|
||||
{
|
||||
PublishPhotoEntity publishPhoto = repository.DetachedEntities.Where(x => x.OwnerName == service.UserId && x.DefaultIndc == YesNoPolicy.YES).FirstOrDefault();
|
||||
List<PublishPhotoDetailEntity> publishPhotoDetails = new List<PublishPhotoDetailEntity>();
|
||||
if (publishPhoto == null)
|
||||
return publishPhotoDetails.ToArray();
|
||||
|
||||
IRepository<PublishPhotoDetailEntity> repositoryPublishPhotoDetail = repository.GetRepository<IRepository<PublishPhotoDetailEntity>>();
|
||||
|
||||
PublishPhotoDetailEntity[] dtls = repositoryPublishPhotoDetail.DetachedEntities.Where(x => x.PublishName == publishPhoto.PublishName).OrderBy(x => x.OrderBy).ToArray();
|
||||
|
||||
if (dtls == null || dtls.Length == 0) return dtls;
|
||||
|
||||
bool isAttached = Debugger.IsAttached;
|
||||
foreach (var item in dtls)
|
||||
{
|
||||
if (item.FileName.ToLower().StartsWith("http")) continue;
|
||||
|
||||
item.FileName = (isAttached ? service.Configuration[AppsettingsPolicy.ApplicationUrl] : "") + item.FileName;
|
||||
}
|
||||
|
||||
return dtls;
|
||||
}
|
||||
|
||||
[PermissionOperate(name: MasterPermissionPolicy.PublishAudio, operate: Operate.Insert)]
|
||||
public void InsertPublishPhotoDetail(PublishData publishData)
|
||||
{
|
||||
IRepository<DmsFileEntity> repositoryDmsFile = repository.GetRepository<IRepository<DmsFileEntity>>();
|
||||
DmsFileEntity dmsFile = repositoryDmsFile.DetachedEntities.Where(x => x.FileId == publishData.FileId).FirstOrDefault();
|
||||
|
||||
if (dmsFile == null) return;
|
||||
if (!FileTypePolicy.IsPhoto(dmsFile.OrderKey)) return;
|
||||
|
||||
InsertPublishPhotoDetail(dmsFile, publishData.PublishName);
|
||||
}
|
||||
|
||||
[PermissionOperate(name: MasterPermissionPolicy.PublishAudio, operate: Operate.Insert)]
|
||||
public void InsertPublishPhotoDetailByFamilyGroup(PublishData publishData)
|
||||
{
|
||||
IRepository<FamilyDmsFileViewEntity> repositoryDmsFile = repository.GetRepository<IRepository<FamilyDmsFileViewEntity>>();
|
||||
FamilyDmsFileViewEntity dmsFile = repositoryDmsFile.DetachedEntities.Where(x => x.FileId == publishData.FileId).FirstOrDefault();
|
||||
|
||||
if (dmsFile == null) return;
|
||||
if (!(dmsFile.OrderKey.ToLower().Contains(".jpg") || dmsFile.OrderKey.ToLower().Contains(".png") ||
|
||||
dmsFile.OrderKey.ToLower().Contains(".gif") || dmsFile.OrderKey.ToLower().Contains(".jpeg"))) return;
|
||||
|
||||
DmsFileEntity dmsFileEntity = new DmsFileEntity();
|
||||
ObjectCopyHelper.Copy(dmsFile, dmsFileEntity);
|
||||
InsertPublishPhotoDetail(dmsFileEntity, publishData.PublishName);
|
||||
}
|
||||
|
||||
private void InsertPublishPhotoDetail(DmsFileEntity dmsFile, string publishName)
|
||||
{
|
||||
IRepository<PublishPhotoDetailEntity> repositoryPublishPhotoDetail = repository.GetRepository<IRepository<PublishPhotoDetailEntity>>();
|
||||
|
||||
var webRootPath = service.Configuration[ServiceSettingsPolicy.RequestPath];
|
||||
var phy = service.Configuration[ServiceSettingsPolicy.PhysicalFileDirectory];
|
||||
var scale = service.Configuration[ServiceSettingsPolicy.DmsFileScaleDirectory].Replace(phy, "");
|
||||
|
||||
var fileExtension = Path.GetExtension(dmsFile.OrderKey);
|
||||
var filePathRel = Path.Combine(scale, dmsFile.CreatedBy, fileExtension.Replace(".", ""), "");
|
||||
var filePath = filePathRel.Replace(Path.DirectorySeparatorChar, '/');
|
||||
string path = Path.Combine(webRootPath, filePathRel, dmsFile.OrderKey);
|
||||
|
||||
|
||||
PublishPhotoDetailEntity[] dtls = repositoryPublishPhotoDetail.DetachedEntities.Where(x => x.PublishName == publishName).ToArray();
|
||||
|
||||
if (dtls != null && dtls.Where(x => x.FileName == path).Count() > 0) return;
|
||||
|
||||
PublishPhotoDetailEntity dtl = new PublishPhotoDetailEntity();
|
||||
dtl.PublishName = publishName;
|
||||
dtl.OwnerName = dmsFile.OwerId;
|
||||
if (dtls != null && dtls.Length > 0)
|
||||
dtl.OrderBy = dtls.Sum(x => x.OrderBy) + 1;
|
||||
dtl.FileName = path;
|
||||
|
||||
repositoryPublishPhotoDetail.InsertNow(dtl);
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,402 @@
|
||||
|
||||
using CloudBuilder.Core.DatabaseAccessor;
|
||||
using CloudBuilder.Core.DatabaseAccessor.Entity;
|
||||
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;
|
||||
namespace CloudBuilder.Master.Service
|
||||
{
|
||||
public class PublishVideoService : IPublishVideoService
|
||||
{
|
||||
private readonly IApplicationService service;
|
||||
|
||||
private IRepository<PublishVideoEntity> repository;
|
||||
public PublishVideoService(IApplicationService service)
|
||||
{
|
||||
this.service = service;
|
||||
repository = service.GetRepository<IRepository<PublishVideoEntity>>();
|
||||
}
|
||||
|
||||
[PermissionOperate(name: MasterPermissionPolicy.PublishVideo, operate: Operate.Find)]
|
||||
public PublishVideoData FindByKey(string key)
|
||||
{
|
||||
PublishVideoData data = new PublishVideoData();
|
||||
if (string.IsNullOrEmpty(key)) return data;
|
||||
|
||||
PublishVideoEntity publish = repository.DetachedEntities.Where(x => x.PublishName == key).FirstOrDefault();
|
||||
|
||||
if (publish == null) return data;
|
||||
|
||||
IRepository<PublishVideoFamilyGroupEntity> repositoryPublishVideoFamilyGroup = repository.GetRepository<IRepository<PublishVideoFamilyGroupEntity>>();
|
||||
IRepository<FamilyGroupEntity> repositoryFamilyGroup = repository.GetRepository<IRepository<FamilyGroupEntity>>();
|
||||
|
||||
|
||||
IQueryable<PublishVideoFamilyGroupDisplayData>? q = from e in repositoryPublishVideoFamilyGroup.DetachedEntities
|
||||
join fg in repositoryFamilyGroup.DetachedEntities on e.FamilyName equals fg.FamilyName
|
||||
where e.PublishName == key
|
||||
select new PublishVideoFamilyGroupDisplayData(fg)
|
||||
{
|
||||
CreatedBy = e.CreatedBy,
|
||||
CreatedDatetime = e.CreatedDatetime,
|
||||
UpdatedBy = e.UpdatedBy,
|
||||
UpdatedDatetime = e.UpdatedDatetime,
|
||||
PublishName = e.PublishName,
|
||||
};
|
||||
|
||||
data.FamilyGroups = q.ToArray();
|
||||
if (publish.OwnerName != service.UserId && !YesNoPolicy.IsYes(publish.OpenIndc) && data.FamilyGroups.Length == 0)
|
||||
{
|
||||
throw new ValidatedException("没有权限.");
|
||||
}
|
||||
else if (publish.OwnerName != service.UserId && !YesNoPolicy.IsYes(publish.OpenIndc) && data.FamilyGroups.Length > 0)
|
||||
{
|
||||
IRepository<FamilyGroupManagerEntity> repositoryFamilyGroupManager = repository.GetRepository<IRepository<FamilyGroupManagerEntity>>();
|
||||
|
||||
IQueryable<string>? fgm = from e in repositoryFamilyGroupManager.DetachedEntities
|
||||
where e.UserName == service.UserId && data.FamilyGroups.Where(x => x.FamilyName == e.FamilyName).Count() > 0
|
||||
select e.UserName;
|
||||
|
||||
if (fgm.Count() == 0)
|
||||
throw new ValidatedException("没有权限.");
|
||||
}
|
||||
|
||||
data.PublishVideo = publish;
|
||||
|
||||
IRepository<PublishVideoDetailEntity> repositoryPublishVideoDetail = repository.GetRepository<IRepository<PublishVideoDetailEntity>>();
|
||||
data.Details = repositoryPublishVideoDetail.DetachedEntities.Where(x => x.PublishName == publish.PublishName).OrderBy(x => x.OrderBy).Select(x => new PublishVideoDetailDisplayData(x)).ToArray();
|
||||
|
||||
if (data.Details != null && data.Details.Length > 0)
|
||||
{
|
||||
var webRootPath = service.Configuration[ServiceSettingsPolicy.RequestPath];
|
||||
var phy = service.Configuration[ServiceSettingsPolicy.PhysicalFileDirectory];
|
||||
var scale = service.Configuration[ServiceSettingsPolicy.DmsFileScaleDirectory].Replace(phy, "");
|
||||
|
||||
IRepository<DmsFileEntity> repositoryDmsFile = repository.GetRepository<IRepository<DmsFileEntity>>();
|
||||
|
||||
foreach (var item in data.Details)
|
||||
{
|
||||
if (!string.IsNullOrEmpty(item.Url) && FileTypePolicy.GetType(item.Url!) == FileTypePolicy.VIDEO)
|
||||
{
|
||||
var upload = service.Configuration[ServiceSettingsPolicy.DmsFileUploadDirectory].Replace(phy, "");
|
||||
|
||||
var filePathRel = Path.Combine(upload, item.CreatedBy, "m3u8", "");
|
||||
var filePath = filePathRel.Replace(Path.DirectorySeparatorChar, '/');
|
||||
item.FormattedUrl = service.Configuration[AppsettingsPolicy.ApplicationUrl] + webRootPath + filePath + Path.GetFileNameWithoutExtension(item.Url) + "/main.m3u8";
|
||||
|
||||
item.FormattedPic = item.FormattedUrl.Replace("main.m3u8", "main.png");
|
||||
|
||||
DmsFileEntity dmsFileEntity = repositoryDmsFile.DetachedEntities.Where(x => x.OrderKey == Path.GetFileNameWithoutExtension(item.Url)).FirstOrDefault();
|
||||
string transcodeIndc = YesNoPolicy.NO;
|
||||
if (dmsFileEntity != null) transcodeIndc = dmsFileEntity.TranscodeIndc;
|
||||
item.FormattedUrl = FileTypePolicy.PackUrl(service, item.CreatedBy, item.Url, transcodeIndc);
|
||||
|
||||
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
return data;
|
||||
}
|
||||
|
||||
[PermissionOperate(name: MasterPermissionPolicy.PublishVideo, operate: Operate.Find)]
|
||||
public PublishVideoResultData FindBySearchCriteria(PublishVideoSearchCriteria criteria)
|
||||
{
|
||||
PublishVideoResultData data = new PublishVideoResultData();
|
||||
PublishVideoEntity[] list = null;
|
||||
|
||||
Int64 count = 0;
|
||||
|
||||
string sqlWhere = null;
|
||||
|
||||
if (criteria.Filter != null && criteria.Filter.Length > 0)
|
||||
{
|
||||
sqlWhere = SearchFilter.ComposeWhereClause(criteria.Filter);
|
||||
}
|
||||
|
||||
sqlWhere = sqlWhere + string.Format(" and ({0} ='{1}' or {2} ='{3}') ",
|
||||
PublishVideoEntity.DB_OWNER_NAME, service.UserId,
|
||||
PublishVideoEntity.DB_OPEN_INDC, criteria.IsModal ? service.UserId : YesNoPolicy.YES);
|
||||
|
||||
PublishVideoEntity entity = PublishVideoEntity.GetInstance(repository.GetDbContext().Database.ProviderName);
|
||||
string sql = entity.GetSelectTopFrom(criteria.limit, criteria.page, criteria.orderby.StringToDbField(), criteria.orderbytag, sqlWhere);
|
||||
|
||||
string err = null;
|
||||
try
|
||||
{
|
||||
list = repository.FromSql(sql).ToArray();
|
||||
}
|
||||
catch (System.Exception ex)
|
||||
{
|
||||
err = ex.Message;
|
||||
}
|
||||
|
||||
|
||||
if (list != null && list.Length > 0)
|
||||
{
|
||||
sql = entity.GetSelectCountFrom(sqlWhere);
|
||||
count = Convert.ToInt64(repository.ExecuteScalar(sql));
|
||||
}
|
||||
|
||||
data.Limit = criteria.limit;
|
||||
data.Page = criteria.page;
|
||||
data.Datas = list;
|
||||
data.Total = count;
|
||||
//data.Sql = sql;
|
||||
data.ErrorMessage = err;
|
||||
return data;
|
||||
}
|
||||
|
||||
[PermissionOperate(name: MasterPermissionPolicy.PublishVideo, operate: Operate.Find)]
|
||||
public PublishVideoData FindPublishVideoDefault()
|
||||
{
|
||||
PublishVideoEntity publish = repository.DetachedEntities.Where(x => x.OwnerName == service.UserId && x.DefaultIndc == YesNoPolicy.YES).FirstOrDefault();
|
||||
if (publish == null) return null;
|
||||
return FindByKey(publish.PublishName);
|
||||
}
|
||||
|
||||
[PermissionOperate(name: MasterPermissionPolicy.PublishVideo, operate: Operate.Print)]
|
||||
public dynamic PrintBySearchCriteria(PublishVideoSearchCriteria criteria)
|
||||
{
|
||||
throw new NotImplementedException();
|
||||
}
|
||||
|
||||
[PermissionOperate(name: MasterPermissionPolicy.PublishVideo, operate: Operate.Insert)]
|
||||
[UnitOfWork]
|
||||
public PublishVideoData Insert(PublishVideoData data)
|
||||
{
|
||||
PublishVideoEntity photoPublish = repository.DetachedEntities.Where(x => x.PublishLocalName == data.PublishVideo.PublishLocalName).FirstOrDefault();
|
||||
if (photoPublish != null)
|
||||
{
|
||||
throw new ValidatedException($"[{photoPublish.PublishLocalName}]已发布.");
|
||||
}
|
||||
|
||||
Validate(data.PublishVideo);
|
||||
|
||||
if (data.PublishVideo.DefaultIndc == YesNoPolicy.YES)
|
||||
{
|
||||
CancelDefaultIndc(null);
|
||||
}
|
||||
|
||||
photoPublish = new PublishVideoEntity();
|
||||
ObjectCopyHelper.Copy(data.PublishVideo, photoPublish);
|
||||
|
||||
ISecurityGeneratorNumberService securityGeneratorNumberService = service.ServiceProvider.GetService<ISecurityGeneratorNumberService>()!;
|
||||
|
||||
photoPublish.PublishName = securityGeneratorNumberService.GetNo(MasterPrefixPolicy.AUDIO_PUBLISH, MasterPrefixPolicy.AUDIO_PUBLISH_PUBLISH_NAME, "AP", YesNoPolicy.YES, "yymmdd00000");
|
||||
photoPublish.OwnerName = service.UserId;
|
||||
|
||||
repository.InsertNow(photoPublish);
|
||||
|
||||
SavePublishVideoFamilyGroup(photoPublish.PublishName, data.FamilyGroups);
|
||||
|
||||
return FindByKey(photoPublish.PublishName);
|
||||
}
|
||||
|
||||
[PermissionOperate(name: MasterPermissionPolicy.PublishVideo, operate: Operate.Update)]
|
||||
[UnitOfWork]
|
||||
public PublishVideoData Update(PublishVideoData data)
|
||||
{
|
||||
PublishVideoEntity publishEntity = repository.DetachedEntities.Where(x => x.OwnerName == service.UserId && x.PublishName == data.PublishVideo.PublishName).FirstOrDefault();
|
||||
if (publishEntity == null)
|
||||
{
|
||||
throw new ValidatedException("记录不存在.");
|
||||
}
|
||||
|
||||
ValidateHelper.Validate(service, data.PublishVideo, PublishVideoEntity.DB_NAME_PUBLISH_VIDEO);
|
||||
|
||||
if (data.PublishVideo.DefaultIndc == YesNoPolicy.YES)
|
||||
{
|
||||
CancelDefaultIndc(data.PublishVideo.PublishName);
|
||||
}
|
||||
|
||||
publishEntity = new PublishVideoEntity();
|
||||
ObjectCopyHelper.Copy(data.PublishVideo, publishEntity);
|
||||
|
||||
repository.UpdateNow(publishEntity);
|
||||
|
||||
//只有删除和更新，没有插入
|
||||
SavePublishVideoDetails(publishEntity.PublishName, data.Details);
|
||||
|
||||
SavePublishVideoFamilyGroup(publishEntity.PublishName, data.FamilyGroups);
|
||||
|
||||
return FindByKey(publishEntity.PublishName);
|
||||
}
|
||||
|
||||
private void SavePublishVideoDetails(string publishName, PublishVideoDetailEntity[] details)
|
||||
{
|
||||
if (details != null && details.Length > 0)
|
||||
{
|
||||
int i = 1;
|
||||
foreach (PublishVideoDetailEntity dtl in details)
|
||||
{
|
||||
dtl.OrderBy = i++;
|
||||
}
|
||||
}
|
||||
|
||||
IRepository<PublishVideoDetailEntity> repositoryPublishVideoDetail = repository.GetRepository<IRepository<PublishVideoDetailEntity>>();
|
||||
|
||||
PublishVideoDetailEntity[] olds = repositoryPublishVideoDetail.Entities.Where(x => x.PublishName == publishName).ToArray();
|
||||
if (olds != null && olds.Length > 0)
|
||||
{
|
||||
//存在更新，不存在删除
|
||||
|
||||
foreach (PublishVideoDetailEntity old in olds)
|
||||
{
|
||||
if (details != null && details.Length > 0 && details.Where(x => x.DetailId == old.DetailId).Count() > 0)
|
||||
{
|
||||
PublishVideoDetailEntity dtl = details.Where(x => x.DetailId == old.DetailId).FirstOrDefault();
|
||||
|
||||
old.Title = dtl.Title;
|
||||
old.Author = dtl.Author;
|
||||
old.Pic = dtl.Pic;
|
||||
old.Url = dtl.Url;
|
||||
old.Lrc = dtl.Lrc;
|
||||
old.OrderBy = dtl.OrderBy;
|
||||
old.Notice = dtl.Notice;
|
||||
|
||||
repositoryPublishVideoDetail.UpdateNow(old);
|
||||
}
|
||||
else
|
||||
{
|
||||
repositoryPublishVideoDetail.DeleteNow(old);
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
private void Validate(PublishVideoEntity photoPublish)
|
||||
{
|
||||
List<SysTableSchemaViewEntity> sysTableSchemas = service.ServiceProvider.GetRequiredService<ISysTableSchemaViewService>().FindByTableName(PublishVideoEntity.DB_NAME_PUBLISH_VIDEO);
|
||||
ValidateHelper.ValidateString(photoPublish, sysTableSchemas.ToArray());
|
||||
}
|
||||
|
||||
private void SavePublishVideoFamilyGroup(string publishName, PublishVideoFamilyGroupEntity[] familyGroups)
|
||||
{
|
||||
IRepository<PublishVideoFamilyGroupEntity> repositoryPublishVideoFamilyGroup = repository.GetRepository<IRepository<PublishVideoFamilyGroupEntity>>();
|
||||
|
||||
PublishVideoFamilyGroupEntity[] olds = repositoryPublishVideoFamilyGroup.Entities.Where(x => x.PublishName == publishName).ToArray();
|
||||
if (olds != null && olds.Length > 0)
|
||||
{
|
||||
//存在更新，不存在删除
|
||||
|
||||
foreach (PublishVideoFamilyGroupEntity old in olds)
|
||||
{
|
||||
if (familyGroups != null && familyGroups.Length > 0 && familyGroups.Where(x => x.FamilyName == old.FamilyName).Count() > 0)
|
||||
{
|
||||
//只有主键，无需更新
|
||||
//repositoryPpf.UpdateNow(old);
|
||||
}
|
||||
else
|
||||
{
|
||||
repositoryPublishVideoFamilyGroup.DeleteNow(old);
|
||||
}
|
||||
}
|
||||
}
|
||||
if (familyGroups != null && familyGroups.Length > 0)
|
||||
foreach (PublishVideoFamilyGroupEntity dto in familyGroups)
|
||||
{
|
||||
if (string.IsNullOrEmpty(dto.CreatedBy))
|
||||
repositoryPublishVideoFamilyGroup.InsertNow(new PublishVideoFamilyGroupEntity()
|
||||
{
|
||||
PublishName = publishName,
|
||||
FamilyName = dto.FamilyName,
|
||||
});
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
public void CancelDefaultIndc(string publishLocalName)
|
||||
{
|
||||
PublishVideoEntity[] orgs = repository.DetachedEntities.Where(x => x.PublishName != publishLocalName && x.OwnerName == service.UserId && x.DefaultIndc == YesNoPolicy.YES).ToArray();
|
||||
foreach (PublishVideoEntity org in orgs)
|
||||
{
|
||||
org.DefaultIndc = YesNoPolicy.NO;
|
||||
}
|
||||
|
||||
if (orgs != null && orgs.Length > 0)
|
||||
repository.UpdateNow(orgs);
|
||||
}
|
||||
|
||||
[PermissionOperate(name: MasterPermissionPolicy.PublishVideo, operate: Operate.Delete)]
|
||||
[UnitOfWork]
|
||||
public void Delete(string key)
|
||||
{
|
||||
PublishVideoEntity publishEntity = repository.DetachedEntities.Where(x => x.OwnerName == service.UserId && x.PublishName == key).FirstOrDefault();
|
||||
if (publishEntity == null)
|
||||
{
|
||||
throw new ValidatedException("记录不存在.");
|
||||
}
|
||||
|
||||
repository.DeleteNow(publishEntity);
|
||||
|
||||
|
||||
IRepository<PublishVideoDetailEntity> repositoryDetail = repository.GetRepository<IRepository<PublishVideoDetailEntity>>();
|
||||
|
||||
PublishVideoDetailEntity[] detail = repositoryDetail.Entities.Where(x => x.PublishName == key).ToArray();
|
||||
if (detail != null && detail.Length > 0)
|
||||
{
|
||||
foreach (PublishVideoDetailEntity dtl in detail)
|
||||
{
|
||||
repositoryDetail.DeleteNow(dtl);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
IRepository<PublishVideoFamilyGroupEntity> repositoryFamilyGroup = repository.GetRepository<IRepository<PublishVideoFamilyGroupEntity>>();
|
||||
|
||||
PublishVideoFamilyGroupEntity[] groups = repositoryFamilyGroup.Entities.Where(x => x.PublishName == key).ToArray();
|
||||
if (groups != null && groups.Length > 0)
|
||||
{
|
||||
foreach (PublishVideoFamilyGroupEntity gp in groups)
|
||||
{
|
||||
repositoryFamilyGroup.DeleteNow(gp);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
[PermissionOperate(name: MasterPermissionPolicy.PublishVideo, operate: Operate.Insert)]
|
||||
public void InsertPublishVideoDetail(PublishData publishData)
|
||||
{
|
||||
IRepository<DmsFileUploadViewEntity> repositoryDmsFile = repository.GetRepository<IRepository<DmsFileUploadViewEntity>>();
|
||||
DmsFileUploadViewEntity dmsFile = repositoryDmsFile.DetachedEntities.Where(x => x.FileId == publishData.FileId).FirstOrDefault();
|
||||
|
||||
if (dmsFile == null) return;
|
||||
if (!FileTypePolicy.IsVideo(dmsFile.OrderKey)) return;
|
||||
|
||||
InsertPublishVideoDetail(dmsFile, publishData.PublishName);
|
||||
}
|
||||
|
||||
private void InsertPublishVideoDetail(DmsFileUploadViewEntity dmsFile, string publishName)
|
||||
{
|
||||
IRepository<PublishVideoDetailEntity> repositoryPublishVideoDetail = repository.GetRepository<IRepository<PublishVideoDetailEntity>>();
|
||||
|
||||
PublishVideoDetailEntity[] dtls = repositoryPublishVideoDetail.DetachedEntities.Where(x => x.PublishName == publishName).ToArray();
|
||||
|
||||
if (dtls != null && dtls.Where(x => x.Url == dmsFile.OrderKey).Count() > 0) return;
|
||||
|
||||
PublishVideoDetailEntity dtl = new PublishVideoDetailEntity();
|
||||
dtl.PublishName = publishName;
|
||||
string orgFileName = Path.GetFileNameWithoutExtension(dmsFile.OrgFileName);
|
||||
string[] tts = orgFileName.Split('-');
|
||||
dtl.Title = tts[0].Trim();
|
||||
if (tts.Length > 1) dtl.Author = tts[1].Trim();
|
||||
|
||||
dtl.OwnerName = dmsFile.OwerId;
|
||||
if (dtls != null && dtls.Length > 0)
|
||||
dtl.OrderBy = dtls.Sum(x => x.OrderBy) + 1;
|
||||
dtl.Url = dmsFile.OrderKey;
|
||||
|
||||
repositoryPublishVideoDetail.InsertNow(dtl);
|
||||
}
|
||||
}
|
||||
}
|
||||
Reference in new issue
Block a user