408 lines
19 KiB
C#
408 lines
19 KiB
C#
|
|
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);
|
|
}
|
|
}
|
|
}
|