1831 lines
83 KiB
C#
1831 lines
83 KiB
C#
|
||
using CliWrap;
|
||
using CloudBuilder.Core.DatabaseAccessor;
|
||
using CloudBuilder.Core.DatabaseAccessor.Entity;
|
||
using CloudBuilder.Core.Extensions;
|
||
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 Microsoft.AspNetCore.Authorization;
|
||
using Microsoft.AspNetCore.Http;
|
||
using Microsoft.AspNetCore.Mvc;
|
||
using Microsoft.Extensions.DependencyInjection;
|
||
using SixLabors.ImageSharp;
|
||
using SixLabors.ImageSharp.PixelFormats;
|
||
using SixLabors.ImageSharp.Processing;
|
||
using System;
|
||
using System.Linq;
|
||
using static System.Net.Mime.MediaTypeNames;
|
||
using Image = SixLabors.ImageSharp.Image;
|
||
namespace CloudBuilder.Master.Service
|
||
{
|
||
public class DmsFileService : IDmsFileService
|
||
{
|
||
private readonly IApplicationService service;
|
||
private readonly IHttpContextAccessor httpContextAccessor;
|
||
private IRepository<DmsFileEntity> repository;
|
||
public DmsFileService(IApplicationService service, IHttpContextAccessor httpContextAccessor)
|
||
{
|
||
this.service = service;
|
||
this.httpContextAccessor = httpContextAccessor;
|
||
repository = service.GetRepository<IRepository<DmsFileEntity>>();
|
||
}
|
||
|
||
[PermissionOperate(name: MasterPermissionPolicy.DmsFile, operate: Operate.Find)]
|
||
public DmsFileEntity FindByKey(long key)
|
||
{
|
||
return repository.DetachedEntities.Where(x => x.FileId == key).FirstOrDefault()!;
|
||
}
|
||
|
||
[PermissionOperate(name: MasterPermissionPolicy.DmsFile, operate: Operate.Find)]
|
||
public DmsFileResultData FindBySearchCriteria(DmsFileSearchCriteria criteria)
|
||
{
|
||
DmsFileResultData data = new DmsFileResultData();
|
||
DmsFileUploadViewEntity[] 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}' ", DmsFileUploadViewEntity.DB_CREATED_BY, service.UserId);
|
||
|
||
DmsFileUploadViewEntity entity = DmsFileUploadViewEntity.GetInstance(repository.GetDbContext().Database.ProviderName);
|
||
string sql = entity.GetSelectTopFrom(criteria.limit, criteria.page, criteria.orderby.StringToDbField(), criteria.orderbytag, sqlWhere);
|
||
|
||
IRepository<DmsFileUploadViewEntity> repositoryView = repository.GetRepository<IRepository<DmsFileUploadViewEntity>>();
|
||
|
||
string err = null;
|
||
try
|
||
{
|
||
list = repositoryView.FromSql(sql).ToArray();
|
||
}
|
||
catch (System.Exception ex)
|
||
{
|
||
err = ex.Message;
|
||
}
|
||
|
||
|
||
|
||
if (list != null && list.Length > 0)
|
||
{
|
||
//list = list.OrderByDescending(x => x.IsDirectoryIndc).ThenByDescending(x => x.CreatedDatetime).ToArray();
|
||
sql = entity.GetSelectCountFrom(sqlWhere);
|
||
count = Convert.ToInt64(repository.ExecuteScalar(sql));
|
||
|
||
var webRootPath = service.Configuration[ServiceSettingsPolicy.RequestPath];
|
||
var phy = service.Configuration[ServiceSettingsPolicy.PhysicalFileDirectory];
|
||
var scale = ServiceSettingsPolicy.GetDmsFileScaleDirectory(service).Replace(phy, "");
|
||
List<string> prvs = new List<string>();
|
||
//bool isAttached = Debugger.IsAttached;
|
||
foreach (var item in list)
|
||
{
|
||
item.Url = FileTypePolicy.PackUrl(service, item.CreatedBy, item.OrderKey);
|
||
}
|
||
|
||
data.Datas = list.Select(x => new DmsFileUploadViewDisplayData(x)
|
||
{
|
||
FormattedPic = FileTypePolicy.PackPicUrl(service, x.CreatedBy, x.OrderKey),
|
||
FormattedM3u8 = FileTypePolicy.PackM3u8Url(service, x.CreatedBy, x.OrderKey)
|
||
}).ToArray();
|
||
}
|
||
|
||
data.Limit = criteria.limit;
|
||
data.Page = criteria.page;
|
||
|
||
data.Total = count;
|
||
//data.Sql = sql;
|
||
data.ErrorMessage = err;
|
||
return data;
|
||
}
|
||
|
||
[PermissionOperate(name: MasterPermissionPolicy.DmsFile, operate: Operate.Find)]
|
||
public DmsFileResultData FindDatasBySearchCriteria(DmsFileSearchCriteria criteria)
|
||
{
|
||
DmsFileResultData data = new DmsFileResultData();
|
||
DmsFileUploadViewEntity[] 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}' and {2} ='{3}' ",
|
||
DmsFileUploadViewEntity.DB_CREATED_BY, service.UserId,
|
||
DmsFileUploadViewEntity.DB_IS_DIRECTORY_INDC, YesNoPolicy.NO
|
||
);
|
||
|
||
DmsFileUploadViewEntity entity = DmsFileUploadViewEntity.GetInstance(repository.GetDbContext().Database.ProviderName);
|
||
string sql = entity.GetSelectTopFrom(criteria.limit, criteria.page, criteria.orderby.StringToDbField(), criteria.orderbytag, sqlWhere);
|
||
|
||
IRepository<DmsFileUploadViewEntity> repositoryView = repository.GetRepository<IRepository<DmsFileUploadViewEntity>>();
|
||
|
||
string err = null;
|
||
try
|
||
{
|
||
list = repositoryView.FromSql(sql).ToArray();
|
||
}
|
||
catch (System.Exception ex)
|
||
{
|
||
err = ex.Message;
|
||
}
|
||
|
||
|
||
|
||
if (list != null && list.Length > 0)
|
||
{
|
||
//list = list.OrderByDescending(x => x.IsDirectoryIndc).ThenByDescending(x => x.CreatedDatetime).ToArray();
|
||
sql = entity.GetSelectCountFrom(sqlWhere);
|
||
count = Convert.ToInt64(repository.ExecuteScalar(sql));
|
||
|
||
var webRootPath = service.Configuration[ServiceSettingsPolicy.RequestPath];
|
||
var phy = service.Configuration[ServiceSettingsPolicy.PhysicalFileDirectory];
|
||
var scale = ServiceSettingsPolicy.GetDmsFileScaleDirectory(service).Replace(phy, "");
|
||
List<string> prvs = new List<string>();
|
||
//bool isAttached = Debugger.IsAttached;
|
||
foreach (var item in list)
|
||
{
|
||
item.Url = FileTypePolicy.PackUrl(service, item.CreatedBy, item.OrderKey);
|
||
}
|
||
|
||
data.Datas = list.Select(x => new DmsFileUploadViewDisplayData(x)
|
||
{
|
||
FormattedPic = FileTypePolicy.PackPicUrl(service, x.CreatedBy, x.OrderKey),
|
||
FormattedM3u8 = FileTypePolicy.PackM3u8Url(service, x.CreatedBy, x.OrderKey)
|
||
}).ToArray();
|
||
}
|
||
|
||
data.Limit = criteria.limit;
|
||
data.Page = criteria.page;
|
||
|
||
data.Total = count;
|
||
//data.Sql = sql;
|
||
data.ErrorMessage = err;
|
||
return data;
|
||
}
|
||
|
||
|
||
[PermissionOperate(name: MasterPermissionPolicy.DmsFile, operate: Operate.Find)]
|
||
public DmsFileResultData FindDeleteLogBySearchCriteria(DmsFileSearchCriteria criteria)
|
||
{
|
||
DmsFileResultData data = new DmsFileResultData();
|
||
DmsFileUploadDeleteLogViewEntity[] 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}' ", DmsFileUploadViewEntity.DB_CREATED_BY, service.UserId);
|
||
|
||
DmsFileUploadDeleteLogViewEntity entity = DmsFileUploadDeleteLogViewEntity.GetInstance(repository.GetDbContext().Database.ProviderName);
|
||
string sql = entity.GetSelectTopFrom(criteria.limit, criteria.page, criteria.orderby.StringToDbField(), criteria.orderbytag, sqlWhere);
|
||
|
||
IRepository<DmsFileUploadDeleteLogViewEntity> repositoryView = repository.GetRepository<IRepository<DmsFileUploadDeleteLogViewEntity>>();
|
||
|
||
string err = null;
|
||
try
|
||
{
|
||
list = repositoryView.FromSql(sql).ToArray();
|
||
}
|
||
catch (System.Exception ex)
|
||
{
|
||
err = ex.Message;
|
||
}
|
||
|
||
|
||
if (list != null && list.Length > 0)
|
||
{
|
||
//list = list.OrderByDescending(x => x.IsDirectoryIndc).ThenByDescending(x => x.CreatedDatetime).ToArray();
|
||
sql = entity.GetSelectCountFrom(sqlWhere);
|
||
count = Convert.ToInt64(repository.ExecuteScalar(sql));
|
||
|
||
var webRootPath = service.Configuration[ServiceSettingsPolicy.RequestPath];
|
||
var phy = service.Configuration[ServiceSettingsPolicy.PhysicalFileDirectory];
|
||
var scale = ServiceSettingsPolicy.GetDmsFileScaleDirectory(service).Replace(phy, "");
|
||
|
||
foreach (var item in list)
|
||
{
|
||
item.Url = FileTypePolicy.PackUrl(service, item.CreatedBy, item.OrderKey);
|
||
}
|
||
|
||
data.Logs = list.Select(x => new DmsFileUploadDeleteLogViewDisplayData(x)
|
||
{
|
||
FormattedPic = FileTypePolicy.PackPicUrl(service, x.CreatedBy, x.OrderKey),
|
||
FormattedM3u8 = FileTypePolicy.PackM3u8Url(service, x.CreatedBy, x.OrderKey)
|
||
}).ToArray();
|
||
}
|
||
|
||
data.Limit = criteria.limit;
|
||
data.Page = criteria.page;
|
||
|
||
data.Total = count;
|
||
//data.Sql = sql;
|
||
data.ErrorMessage = err;
|
||
return data;
|
||
}
|
||
|
||
[PermissionOperate(name: MasterPermissionPolicy.DmsFile, operate: Operate.Find)]
|
||
public DmsFileResultData FindFamilyBySearchCriteria(DmsFileSearchCriteria criteria)
|
||
{
|
||
DmsFileResultData data = new DmsFileResultData();
|
||
FamilyDmsFileViewEntity[] list = null;
|
||
|
||
Int64 count = 0;
|
||
|
||
string sqlWhere = null;
|
||
|
||
if (criteria.Filter != null && criteria.Filter.Length > 0)
|
||
{
|
||
sqlWhere = SearchFilter.ComposeWhereClause(criteria.Filter);
|
||
}
|
||
|
||
if (criteria.UserIdIndc == true || criteria.Filter.Where(x => x.Column == FamilyDmsFileViewEntity.DB_FAMILY_NAME).Count() == 0)
|
||
{
|
||
sqlWhere = sqlWhere + string.Format(" and {0} ='{1}' ", FamilyDmsFileViewEntity.DB_CREATED_BY, service.UserId);
|
||
}
|
||
//取了顶级目录
|
||
if (string.IsNullOrEmpty(sqlWhere)) sqlWhere = string.Format(" and {0} ={1} ", FamilyDmsFileViewEntity.DB_FAMILY_NAME, FamilyDmsFileViewEntity.DB_FILE_PATH);
|
||
|
||
FamilyDmsFileViewEntity entity = FamilyDmsFileViewEntity.GetInstance(repository.GetDbContext().Database.ProviderName);
|
||
string sql = entity.GetSelectTopFrom(criteria.limit, criteria.page, criteria.orderby.StringToDbField(), criteria.orderbytag, sqlWhere);
|
||
|
||
IRepository<FamilyDmsFileViewEntity> repositoryView = repository.GetRepository<IRepository<FamilyDmsFileViewEntity>>();
|
||
IRepository<FamilyGroupPermissionEntity> repositoryFamilyGroupPermission = repository.GetRepository<IRepository<FamilyGroupPermissionEntity>>();
|
||
IRepository<FamilyFolderFavoriteEntity> repositoryFamilyFolderFavorite = repository.GetRepository<IRepository<FamilyFolderFavoriteEntity>>();
|
||
|
||
FamilyGroupPermissionEntity[] permissionEntities = repositoryFamilyGroupPermission.DetachedEntities.Where(x => x.UserName == service.UserId).ToArray();
|
||
FamilyFolderFavoriteEntity[] favorites = repositoryFamilyFolderFavorite.DetachedEntities.Where(x => x.UserName == service.UserId).ToArray();
|
||
|
||
string err = null;
|
||
try
|
||
{
|
||
list = repositoryView.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));
|
||
|
||
foreach (var item in list)
|
||
{
|
||
if (permissionEntities != null && permissionEntities.Length > 0)
|
||
{
|
||
foreach (var p in permissionEntities)
|
||
{
|
||
if (item.TopFolderName == p.FolderName)
|
||
{
|
||
item.PermissionIndc = YesNoPolicy.YES;
|
||
break;
|
||
}
|
||
}
|
||
}
|
||
|
||
if (favorites != null && favorites.Length > 0)
|
||
{
|
||
foreach (var f in favorites)
|
||
{
|
||
if (item.FolderName == f.FolderName)
|
||
{
|
||
item.FavoriteIndc = YesNoPolicy.YES;
|
||
break;
|
||
}
|
||
}
|
||
}
|
||
}
|
||
|
||
var webRootPath = service.Configuration[ServiceSettingsPolicy.RequestPath];
|
||
var phy = service.Configuration[ServiceSettingsPolicy.PhysicalFileDirectory];
|
||
var scale = ServiceSettingsPolicy.GetDmsFileScaleDirectory(service).Replace(phy, "");
|
||
|
||
|
||
foreach (var item in list)
|
||
{
|
||
item.Url = FileTypePolicy.PackUrl(service, item.CreatedBy, item.OrderKey);
|
||
}
|
||
|
||
data.Families = list.Select(x => new FamilyDmsFileViewDisplayData(x)
|
||
{
|
||
FileType = FileTypePolicy.GetType(x.OrderKey),
|
||
FormattedPic = FileTypePolicy.PackPicUrl(service, x.CreatedBy, x.OrderKey),
|
||
FormattedM3u8 = FileTypePolicy.PackM3u8Url(service, x.CreatedBy, x.OrderKey)
|
||
}).ToArray();
|
||
}
|
||
|
||
data.Limit = criteria.limit;
|
||
data.Page = criteria.page;
|
||
data.Total = count;
|
||
//data.Sql = sql;
|
||
data.ErrorMessage = err;
|
||
return data;
|
||
}
|
||
|
||
|
||
[PermissionOperate(name: MasterPermissionPolicy.DmsFile, operate: Operate.Find)]
|
||
public DmsFileDeleteLogEntity FindDmsFileDeleteLogByKey(long key)
|
||
{
|
||
IRepository<DmsFileDeleteLogEntity> repositoryDmsFileDeleteLog = repository.GetRepository<IRepository<DmsFileDeleteLogEntity>>();
|
||
|
||
return repositoryDmsFileDeleteLog.DetachedEntities.Where(x => x.FileId == key).FirstOrDefault()!;
|
||
}
|
||
|
||
[PermissionOperate(name: MasterPermissionPolicy.DmsFile, operate: Operate.Print)]
|
||
public dynamic PrintBySearchCriteria(DmsFileSearchCriteria criteria)
|
||
{
|
||
throw new NotImplementedException();
|
||
}
|
||
|
||
[PermissionOperate(name: MasterPermissionPolicy.DmsFile, operate: Operate.Insert)]
|
||
[UnitOfWork]
|
||
public DmsFileEntity Insert(DmsFileEntity data)
|
||
{
|
||
throw new NotImplementedException();
|
||
}
|
||
|
||
[PermissionOperate(name: MasterPermissionPolicy.DmsFile, operate: Operate.Update)]
|
||
[UnitOfWork]
|
||
public DmsFileEntity Update(DmsFileEntity data)
|
||
{
|
||
throw new NotImplementedException();
|
||
}
|
||
|
||
|
||
[PermissionOperate(name: MasterPermissionPolicy.DmsFile, operate: Operate.Delete)]
|
||
[UnitOfWork]
|
||
public void Delete(long key)
|
||
{
|
||
Delete(key, false);
|
||
}
|
||
|
||
private void Delete(long key, bool hasCreateDmsFileDeleteLog)
|
||
{
|
||
DmsFileEntity dmsFile = repository.DetachedEntities.Where(x => x.FileId == key).FirstOrDefault()!;
|
||
|
||
if (dmsFile == null) return;
|
||
|
||
if (!hasCreateDmsFileDeleteLog) CreateDmsFileDeleteLog(dmsFile, null);
|
||
|
||
IRepository<DmsFileUploadEntity> repositoryUpload = repository.GetRepository<IRepository<DmsFileUploadEntity>>();
|
||
IRepository<DmsFolderMapEntity> repositoryFolderMap = repository.GetRepository<IRepository<DmsFolderMapEntity>>();
|
||
IRepository<DmsFolderEntity> repositoryFolder = repository.GetRepository<IRepository<DmsFolderEntity>>();
|
||
|
||
repository.DeleteNow(dmsFile);
|
||
|
||
DmsFileUploadEntity DmsFileUpload = repositoryUpload.DetachedEntities.Where(x => x.FileId == key).FirstOrDefault()!;
|
||
|
||
if (DmsFileUpload != null)
|
||
{
|
||
repositoryUpload.DeleteNow(DmsFileUpload);
|
||
}
|
||
|
||
if (dmsFile.IsDirectoryIndc == YesNoPolicy.YES)
|
||
{
|
||
DmsFolderEntity folder = repositoryFolder.DetachedEntities.Where(x => x.FolderName == dmsFile.FileName).FirstOrDefault()!;
|
||
|
||
if (folder == null) return;
|
||
|
||
if (folder != null)
|
||
{
|
||
repositoryFolder.DeleteNow(folder);
|
||
}
|
||
|
||
DmsFolderMapEntity[] folderMaps = repositoryFolderMap.DetachedEntities.Where(x => x.FolderNameSon == dmsFile.FileName || x.FolderNameParent == dmsFile.FileName).ToArray();
|
||
|
||
if (folderMaps != null && folderMaps.Length > 0)
|
||
{
|
||
foreach (var map in folderMaps)
|
||
{
|
||
repositoryFolderMap.DeleteNow(map);
|
||
|
||
if (map.FolderNameSon == folder.FolderName) continue;
|
||
//刪除dmsfoler下的所有內容
|
||
DeleteFolder(map.FolderNameSon);
|
||
}
|
||
}
|
||
}
|
||
else
|
||
{
|
||
//删除文件与文件夹的映射关系
|
||
DmsFolderMapEntity folderMap = repositoryFolderMap.DetachedEntities.Where(x => x.FolderNameSon == dmsFile.FileName).FirstOrDefault();
|
||
if (folderMap != null)
|
||
repositoryFolderMap.DeleteNow(folderMap);
|
||
}
|
||
}
|
||
|
||
|
||
private void CreateDmsFileDeleteLogByDirectory(DmsFileEntity dmsFile, DmsFolderDeleteLogEntity folder)
|
||
{
|
||
IRepository<DmsFolderDeleteLogEntity> repositoryFolder = repository.GetRepository<IRepository<DmsFolderDeleteLogEntity>>();
|
||
ISecurityGeneratorNumberService securityGeneratorNumberService = service.ServiceProvider.GetService<ISecurityGeneratorNumberService>()!;
|
||
|
||
string folderNameParent = folder.FolderName;
|
||
|
||
//创建当前目录
|
||
folder = new DmsFolderDeleteLogEntity();
|
||
folder.FolderName = securityGeneratorNumberService.GetNo(MasterPrefixPolicy.DMS_FOLDER_DELETE_LOG, MasterPrefixPolicy.DMS_FOLDER_DELETE_LOG_FOLDER_NAME, "DR", YesNoPolicy.NO, "00000000");
|
||
folder.FolderLocalName = dmsFile.OrgFileName;//如果是目录，这个就是目录名称
|
||
repositoryFolder.InsertNow(folder);
|
||
//创建目录关系表
|
||
DmsFolderMapDeleteLogEntity map = new DmsFolderMapDeleteLogEntity();
|
||
IRepository<DmsFolderMapDeleteLogEntity> repositoryFolderMap = repository.GetRepository<IRepository<DmsFolderMapDeleteLogEntity>>();
|
||
map.FolderNameParent = folderNameParent;
|
||
map.FolderNameSon = folder.FolderName;
|
||
repositoryFolderMap.InsertNow(map);
|
||
|
||
//创建Dms目录
|
||
IRepository<DmsFileDeleteLogEntity> repositoryDmsFileDeleteLog = repository.GetRepository<IRepository<DmsFileDeleteLogEntity>>();
|
||
DmsFileDeleteLogEntity entity = new DmsFileDeleteLogEntity();
|
||
ObjectCopyHelper.Copy(dmsFile, entity);
|
||
entity.OrderKey = entity.FileName = folder.FolderName;
|
||
|
||
entity.FileId = 0;
|
||
entity.FilePath = folderNameParent;
|
||
repositoryDmsFileDeleteLog.InsertNow(entity);
|
||
|
||
DmsFileUploadDeleteLogEntity upload = new DmsFileUploadDeleteLogEntity();
|
||
upload.FileId = entity.FileId;
|
||
upload.FileCategory = "MASTER";
|
||
upload.UploadName = securityGeneratorNumberService.GetNo(MasterPrefixPolicy.UPLOAD_DMS_FILE_DELETE_LOG, MasterPrefixPolicy.UPLOAD_DMS_FILE_DELETE_LOG_UPLOAD_NAME, "DR", YesNoPolicy.NO, MasterPrefixPolicy.UPLOAD_DMS_FILE_DELETE_LOG_FORMAT);
|
||
upload.OrgFileName = entity.OrgFileName;
|
||
|
||
IRepository<DmsFileUploadDeleteLogEntity> repositoryUpload = repository.GetRepository<IRepository<DmsFileUploadDeleteLogEntity>>();
|
||
|
||
repositoryUpload.InsertNow(upload);
|
||
|
||
//创建所有目录下的内容
|
||
DmsFileEntity[] dmsFiles = repository.DetachedEntities.Where(x => x.FilePath == dmsFile.FileName).ToArray();
|
||
if (dmsFiles == null || dmsFiles.Length == 0) return;
|
||
|
||
foreach (var dms in dmsFiles)
|
||
{
|
||
CreateDmsFileDeleteLog(dms, folder);
|
||
}
|
||
}
|
||
|
||
private void CreateDmsFileDeleteLog(DmsFileEntity dmsFile, DmsFolderDeleteLogEntity folderLog)
|
||
{
|
||
IRepository<DmsFileDeleteLogEntity> repositoryDmsFileDeleteLog = repository.GetRepository<IRepository<DmsFileDeleteLogEntity>>();
|
||
IRepository<DmsFileUploadDeleteLogEntity> repositoryDmsFileUploadDeleteLog = repository.GetRepository<IRepository<DmsFileUploadDeleteLogEntity>>();
|
||
IRepository<DmsFolderDeleteLogEntity> repositoryDmsFolderDeleteLog = repository.GetRepository<IRepository<DmsFolderDeleteLogEntity>>();
|
||
IRepository<DmsFolderMapDeleteLogEntity> repositoryDmsFolderMapDeleteLog = repository.GetRepository<IRepository<DmsFolderMapDeleteLogEntity>>();
|
||
|
||
ISecurityGeneratorNumberService securityGeneratorNumberService = service.ServiceProvider.GetService<ISecurityGeneratorNumberService>()!;
|
||
|
||
//如果顶级目录不存在，创建顶级目录
|
||
if (folderLog == null)
|
||
folderLog = repositoryDmsFolderDeleteLog.DetachedEntities.Where(x => x.FolderLocalName == service.UserId).FirstOrDefault()!;
|
||
|
||
if (folderLog == null)
|
||
{
|
||
folderLog = new DmsFolderDeleteLogEntity();
|
||
folderLog.FolderName = securityGeneratorNumberService.GetNo(MasterPrefixPolicy.DMS_FOLDER_DELETE_LOG, MasterPrefixPolicy.DMS_FOLDER_DELETE_LOG_FOLDER_NAME, null, YesNoPolicy.NO, "00000000");
|
||
folderLog.FolderLocalName = service.UserId;
|
||
repositoryDmsFolderDeleteLog.InsertNow(folderLog);
|
||
}
|
||
|
||
string folderNameParent = folderLog.FolderName;
|
||
|
||
if (dmsFile.IsDirectoryIndc == YesNoPolicy.YES)
|
||
{
|
||
CreateDmsFileDeleteLogByDirectory(dmsFile, folderLog);
|
||
return;
|
||
}
|
||
|
||
IRepository<DmsFileUploadEntity> repositoryDmsFileUpload = repository.GetRepository<IRepository<DmsFileUploadEntity>>();
|
||
|
||
DmsFileUploadEntity upload = repositoryDmsFileUpload.DetachedEntities.Where(x => x.FileId == dmsFile.FileId).FirstOrDefault()!;
|
||
|
||
DmsFileUploadDeleteLogEntity uploadLog = new DmsFileUploadDeleteLogEntity();
|
||
|
||
uploadLog.FileCategory = "MASTER";
|
||
uploadLog.UploadName = securityGeneratorNumberService.GetNo(MasterPrefixPolicy.UPLOAD_DMS_FILE_DELETE_LOG, MasterPrefixPolicy.UPLOAD_DMS_FILE_DELETE_LOG_UPLOAD_NAME, "FL", YesNoPolicy.NO, MasterPrefixPolicy.UPLOAD_DMS_FILE_DELETE_LOG_FORMAT);
|
||
uploadLog.OrgFileName = upload.OrgFileName;
|
||
|
||
//创建Dms文件,需更新父目录
|
||
DmsFileDeleteLogEntity entityLog = new DmsFileDeleteLogEntity();
|
||
ObjectCopyHelper.Copy(dmsFile, entityLog);
|
||
entityLog.FilePath = folderNameParent;
|
||
entityLog.FileId = 0;
|
||
repositoryDmsFileDeleteLog.InsertNow(entityLog);
|
||
|
||
uploadLog.FileId = entityLog.FileId;
|
||
repositoryDmsFileUploadDeleteLog.InsertNow(uploadLog);
|
||
|
||
//创建目录关系表
|
||
DmsFolderMapDeleteLogEntity mapLog = new DmsFolderMapDeleteLogEntity();
|
||
mapLog.FolderNameParent = folderNameParent;
|
||
mapLog.FolderNameSon = entityLog.FileName;
|
||
repositoryDmsFolderMapDeleteLog.InsertNow(mapLog);
|
||
}
|
||
|
||
|
||
[PermissionOperate(name: MasterPermissionPolicy.DmsFile, operate: Operate.Insert)]
|
||
[UnitOfWork]
|
||
public void RestoreDmsFile(long key)
|
||
{
|
||
DeleteLog(key, true);
|
||
}
|
||
|
||
|
||
private void RestoreDmsFileByDirectory(DmsFileDeleteLogEntity dmsFile, DmsFolderEntity folder)
|
||
{
|
||
IRepository<DmsFolderEntity> repositoryFolder = repository.GetRepository<IRepository<DmsFolderEntity>>();
|
||
ISecurityGeneratorNumberService securityGeneratorNumberService = service.ServiceProvider.GetService<ISecurityGeneratorNumberService>()!;
|
||
|
||
string folderNameParent = folder.FolderName;
|
||
|
||
//创建当前目录
|
||
folder = new DmsFolderEntity();
|
||
folder.FolderName = securityGeneratorNumberService.GetNo(MasterPrefixPolicy.DMS_FOLDER_DELETE_LOG, MasterPrefixPolicy.DMS_FOLDER_DELETE_LOG_FOLDER_NAME, "DR", YesNoPolicy.NO, "00000000");
|
||
folder.FolderLocalName = dmsFile.OrgFileName;//如果是目录，这个就是目录名称
|
||
repositoryFolder.InsertNow(folder);
|
||
//创建目录关系表
|
||
DmsFolderMapEntity map = new DmsFolderMapEntity();
|
||
IRepository<DmsFolderMapEntity> repositoryFolderMap = repository.GetRepository<IRepository<DmsFolderMapEntity>>();
|
||
map.FolderNameParent = folderNameParent;
|
||
map.FolderNameSon = folder.FolderName;
|
||
repositoryFolderMap.InsertNow(map);
|
||
|
||
//创建Dms目录，要更新目录名
|
||
IRepository<DmsFileEntity> repositoryDmsFile = repository.GetRepository<IRepository<DmsFileEntity>>();
|
||
DmsFileEntity entity = new DmsFileEntity();
|
||
ObjectCopyHelper.Copy(dmsFile, entity);
|
||
entity.OrderKey = entity.FileName = folder.FolderName;
|
||
|
||
entity.FileId = 0;
|
||
entity.FilePath = folderNameParent;
|
||
repositoryDmsFile.InsertNow(entity);
|
||
|
||
DmsFileUploadEntity upload = new DmsFileUploadEntity();
|
||
upload.FileId = entity.FileId;
|
||
upload.FileCategory = "MASTER";
|
||
upload.UploadName = securityGeneratorNumberService.GetNo(MasterPrefixPolicy.UPLOAD_DMS_FILE_DELETE_LOG, MasterPrefixPolicy.UPLOAD_DMS_FILE_DELETE_LOG_UPLOAD_NAME, "DR", YesNoPolicy.NO, MasterPrefixPolicy.UPLOAD_DMS_FILE_DELETE_LOG_FORMAT);
|
||
upload.OrgFileName = entity.OrgFileName;
|
||
|
||
IRepository<DmsFileUploadEntity> repositoryUpload = repository.GetRepository<IRepository<DmsFileUploadEntity>>();
|
||
|
||
repositoryUpload.InsertNow(upload);
|
||
|
||
IRepository<DmsFileDeleteLogEntity> repositoryDmsFileDeleteLog = repository.GetRepository<IRepository<DmsFileDeleteLogEntity>>();
|
||
//创建所有目录下的内容
|
||
DmsFileDeleteLogEntity[] dmsFiles = repositoryDmsFileDeleteLog.DetachedEntities.Where(x => x.FilePath == dmsFile.FileName).ToArray();
|
||
if (dmsFiles == null || dmsFiles.Length == 0) return;
|
||
|
||
foreach (var dms in dmsFiles)
|
||
{
|
||
RestoreDmsFile(dms, folder);
|
||
}
|
||
}
|
||
|
||
private void RestoreDmsFile(DmsFileDeleteLogEntity dmsFile, DmsFolderEntity folder)
|
||
{
|
||
IRepository<DmsFileEntity> repositoryDmsFile = repository.GetRepository<IRepository<DmsFileEntity>>();
|
||
IRepository<DmsFileUploadEntity> repositoryDmsFileUpload = repository.GetRepository<IRepository<DmsFileUploadEntity>>();
|
||
IRepository<DmsFolderEntity> repositoryDmsFolder = repository.GetRepository<IRepository<DmsFolderEntity>>();
|
||
IRepository<DmsFolderMapEntity> repositoryDmsFolderMap = repository.GetRepository<IRepository<DmsFolderMapEntity>>();
|
||
|
||
ISecurityGeneratorNumberService securityGeneratorNumberService = service.ServiceProvider.GetService<ISecurityGeneratorNumberService>()!;
|
||
|
||
//如果顶级目录不存在，创建顶级目录
|
||
if (folder == null)
|
||
folder = repositoryDmsFolder.DetachedEntities.Where(x => x.FolderLocalName == service.UserId).FirstOrDefault()!;
|
||
|
||
if (folder == null)
|
||
{
|
||
folder = new DmsFolderEntity();
|
||
folder.FolderName = securityGeneratorNumberService.GetNo(MasterPrefixPolicy.DMS_FOLDER_DELETE_LOG, MasterPrefixPolicy.DMS_FOLDER_DELETE_LOG_FOLDER_NAME, null, YesNoPolicy.NO, "00000000");
|
||
folder.FolderLocalName = service.UserId;
|
||
repositoryDmsFolder.InsertNow(folder);
|
||
}
|
||
|
||
string folderNameParent = folder.FolderName;
|
||
|
||
if (dmsFile.IsDirectoryIndc == YesNoPolicy.YES)
|
||
{
|
||
RestoreDmsFileByDirectory(dmsFile, folder);
|
||
return;
|
||
}
|
||
|
||
DmsFileUploadEntity uploadLog = new DmsFileUploadEntity();
|
||
|
||
IRepository<DmsFileUploadDeleteLogEntity> repositoryDmsFileUploadDeleteLog = repository.GetRepository<IRepository<DmsFileUploadDeleteLogEntity>>();
|
||
DmsFileUploadDeleteLogEntity dmsFileUploadDeleteLog = repositoryDmsFileUploadDeleteLog.DetachedEntities.Where(x => x.FileId == dmsFile.FileId).FirstOrDefault()!;
|
||
|
||
uploadLog.FileCategory = "MASTER";
|
||
uploadLog.UploadName = securityGeneratorNumberService.GetNo(MasterPrefixPolicy.UPLOAD_DMS_FILE_DELETE_LOG, MasterPrefixPolicy.UPLOAD_DMS_FILE_DELETE_LOG_UPLOAD_NAME, "FL", YesNoPolicy.NO, MasterPrefixPolicy.UPLOAD_DMS_FILE_DELETE_LOG_FORMAT);
|
||
uploadLog.OrgFileName = dmsFileUploadDeleteLog.OrgFileName;
|
||
|
||
//创建Dms文件,需更新父目录
|
||
DmsFileEntity entityLog = new DmsFileEntity();
|
||
ObjectCopyHelper.Copy(dmsFile, entityLog);
|
||
entityLog.FilePath = folderNameParent;
|
||
entityLog.FileId = 0;
|
||
repositoryDmsFile.InsertNow(entityLog);
|
||
|
||
uploadLog.FileId = entityLog.FileId;
|
||
repositoryDmsFileUpload.InsertNow(uploadLog);
|
||
|
||
//创建目录关系表
|
||
DmsFolderMapEntity mapLog = new DmsFolderMapEntity();
|
||
mapLog.FolderNameParent = folderNameParent;
|
||
mapLog.FolderNameSon = entityLog.FileName;
|
||
repositoryDmsFolderMap.InsertNow(mapLog);
|
||
}
|
||
|
||
|
||
[PermissionOperate(name: MasterPermissionPolicy.DmsFile, operate: Operate.Delete)]
|
||
[UnitOfWork]
|
||
public void DeleteLog(long key)
|
||
{
|
||
DeleteLog(key, false);
|
||
}
|
||
private void DeleteLog(long key, bool isRestore)
|
||
{
|
||
IRepository<DmsFileDeleteLogEntity> repositoryDmsFileDeleteLog = repository.GetRepository<IRepository<DmsFileDeleteLogEntity>>();
|
||
|
||
DmsFileDeleteLogEntity dmsFile = repositoryDmsFileDeleteLog.DetachedEntities.Where(x => x.FileId == key).FirstOrDefault()!;
|
||
|
||
if (dmsFile == null) return;
|
||
|
||
if (isRestore) RestoreDmsFile(dmsFile, null);
|
||
|
||
repositoryDmsFileDeleteLog.DeleteNow(dmsFile);
|
||
|
||
IRepository<DmsFileUploadDeleteLogEntity> repositoryDmsFileUploadDeleteLog = repository.GetRepository<IRepository<DmsFileUploadDeleteLogEntity>>();
|
||
|
||
DmsFileUploadDeleteLogEntity DmsFileUpload = repositoryDmsFileUploadDeleteLog.DetachedEntities.Where(x => x.FileId == key).FirstOrDefault()!;
|
||
|
||
IRepository<DmsFolderMapDeleteLogEntity> repositoryDmsFolderMapDeleteLog = repository.GetRepository<IRepository<DmsFolderMapDeleteLogEntity>>();
|
||
|
||
if (DmsFileUpload != null)
|
||
{
|
||
repositoryDmsFileUploadDeleteLog.DeleteNow(DmsFileUpload);
|
||
}
|
||
|
||
if (dmsFile.IsDirectoryIndc == YesNoPolicy.YES)
|
||
{
|
||
IRepository<DmsFolderDeleteLogEntity> repositoryDmsFolderDeleteLog = repository.GetRepository<IRepository<DmsFolderDeleteLogEntity>>();
|
||
DmsFolderDeleteLogEntity folder = repositoryDmsFolderDeleteLog.DetachedEntities.Where(x => x.FolderName == dmsFile.FileName).FirstOrDefault()!;
|
||
|
||
if (folder == null) return;
|
||
|
||
if (folder != null)
|
||
{
|
||
repositoryDmsFolderDeleteLog.DeleteNow(folder);
|
||
}
|
||
|
||
|
||
DmsFolderMapDeleteLogEntity[] folderMaps = repositoryDmsFolderMapDeleteLog.DetachedEntities.Where(x => x.FolderNameSon == dmsFile.FileName || x.FolderNameParent == dmsFile.FileName).ToArray();
|
||
|
||
if (folderMaps != null && folderMaps.Length > 0)
|
||
{
|
||
foreach (var map in folderMaps)
|
||
{
|
||
repositoryDmsFolderMapDeleteLog.DeleteNow(map);
|
||
|
||
if (map.FolderNameSon == folder.FolderName) continue;
|
||
//刪除dmsfoler下的所有內容
|
||
DeleteFolderDeleteLog(map.FolderNameSon);
|
||
}
|
||
}
|
||
|
||
|
||
}
|
||
else
|
||
{
|
||
//删除文件与文件夹的映射关系
|
||
DmsFolderMapDeleteLogEntity folderMap = repositoryDmsFolderMapDeleteLog.DetachedEntities.Where(x => x.FolderNameSon == dmsFile.FileName).FirstOrDefault();
|
||
if (folderMap != null)
|
||
repositoryDmsFolderMapDeleteLog.DeleteNow(folderMap);
|
||
}
|
||
}
|
||
|
||
private void DeleteFolderDeleteLog(string folderName)
|
||
{
|
||
IRepository<DmsFileDeleteLogEntity> repositoryDmsFileDeleteLog = repository.GetRepository<IRepository<DmsFileDeleteLogEntity>>();
|
||
|
||
DmsFileDeleteLogEntity[] dmsFiles = repositoryDmsFileDeleteLog.DetachedEntities.Where(x => x.FileName == folderName).ToArray();
|
||
if (dmsFiles == null || dmsFiles.Length == 0) return;
|
||
foreach (var dmsFile in dmsFiles)
|
||
{
|
||
DeleteLog(dmsFile.FileId, false);
|
||
}
|
||
}
|
||
|
||
public void DeleteFolder(string folderName)
|
||
{
|
||
DmsFileEntity[] dmsFiles = repository.DetachedEntities.Where(x => x.FileName == folderName).ToArray();
|
||
if (dmsFiles == null || dmsFiles.Length == 0) return;
|
||
foreach (var dmsFile in dmsFiles)
|
||
{
|
||
Delete(dmsFile.FileId, true);
|
||
}
|
||
}
|
||
|
||
[PermissionOperate(name: MasterPermissionPolicy.DmsFile, operate: Operate.Insert)]
|
||
[UnitOfWork]
|
||
public string CreateDmsFolder(DmsFileEntity dmsFile)
|
||
{
|
||
IRepository<DmsFolderEntity> repositoryFolder = repository.GetRepository<IRepository<DmsFolderEntity>>();
|
||
ISecurityGeneratorNumberService securityGeneratorNumberService = service.ServiceProvider.GetService<ISecurityGeneratorNumberService>()!;
|
||
DmsFolderEntity folder = null;
|
||
string folderNameParent = dmsFile.FilePath;
|
||
//父目录是空，创建顶级目录
|
||
|
||
folder = repositoryFolder.DetachedEntities.Where(x => x.FolderLocalName == service.UserId).FirstOrDefault()!;
|
||
if (folder == null)
|
||
{
|
||
folder = new DmsFolderEntity();
|
||
folder.FolderName = securityGeneratorNumberService.GetNo(MasterPrefixPolicy.DMS_FOLDER, MasterPrefixPolicy.DMS_FOLDER_FOLDER_NAME, "DR", YesNoPolicy.NO, "00000000");
|
||
folder.FolderLocalName = service.UserId;
|
||
repositoryFolder.InsertNow(folder);
|
||
}
|
||
|
||
if (string.IsNullOrEmpty(dmsFile.FilePath))
|
||
{
|
||
folderNameParent = folder.FolderName;
|
||
}
|
||
|
||
//创建当前目录
|
||
folder = new DmsFolderEntity();
|
||
folder.FolderName = securityGeneratorNumberService.GetNo(MasterPrefixPolicy.DMS_FOLDER, MasterPrefixPolicy.DMS_FOLDER_FOLDER_NAME, "DR", YesNoPolicy.NO, "00000000");
|
||
folder.FolderLocalName = dmsFile.FileName;
|
||
repositoryFolder.InsertNow(folder);
|
||
//创建目录关系表
|
||
DmsFolderMapEntity map = new DmsFolderMapEntity();
|
||
IRepository<DmsFolderMapEntity> repositoryFolderMap = repository.GetRepository<IRepository<DmsFolderMapEntity>>();
|
||
map.FolderNameParent = folderNameParent;
|
||
map.FolderNameSon = folder.FolderName;
|
||
repositoryFolderMap.InsertNow(map);
|
||
|
||
//创建Dms目录
|
||
DmsFileEntity entity = new DmsFileEntity();
|
||
entity.OrderKey = entity.FileName = folder.FolderName;
|
||
entity.OrgFileName = dmsFile.FileName;
|
||
entity.AllowDeleteIndc = entity.AllowRenameIndc = entity.IsDirectoryIndc = YesNoPolicy.YES;
|
||
|
||
entity.FilePath = folderNameParent;
|
||
|
||
entity.OwerId = service.UserId;
|
||
entity.IsLinkIndc = YesNoPolicy.NO;
|
||
|
||
repository.InsertNow(entity);
|
||
|
||
DmsFileUploadEntity upload = new DmsFileUploadEntity();
|
||
upload.FileId = entity.FileId;
|
||
upload.FileCategory = "MASTER";
|
||
upload.UploadName = securityGeneratorNumberService.GetNo(MasterPrefixPolicy.UPLOAD_DMS_FILE, MasterPrefixPolicy.UPLOAD_DMS_FILE_UPLOAD_NAME, "DR", YesNoPolicy.NO, MasterPrefixPolicy.UPLOAD_DMS_FILE_FORMAT);
|
||
upload.OrgFileName = entity.OrgFileName;
|
||
|
||
IRepository<DmsFileUploadEntity> repositoryUpload = repository.GetRepository<IRepository<DmsFileUploadEntity>>();
|
||
|
||
repositoryUpload.InsertNow(upload);
|
||
|
||
return folder.FolderName;
|
||
}
|
||
|
||
public void CreateFamilyDmsFolder(FamilyGroupEntity familyGroup, FamilyGroupFolderEntity[] familyGroupFolders)
|
||
{
|
||
ISecurityGeneratorNumberService securityGeneratorNumberService = service.ServiceProvider.GetService<ISecurityGeneratorNumberService>()!;
|
||
IRepository<DmsFolderEntity> repositoryFolder = repository.GetRepository<IRepository<DmsFolderEntity>>();
|
||
DmsFolderEntity folder = repositoryFolder.DetachedEntities.Where(x => x.FolderLocalName == familyGroup.FamilyName).FirstOrDefault()!;
|
||
if (folder == null)
|
||
{
|
||
folder = new DmsFolderEntity();
|
||
folder.FolderName = familyGroup.FamilyName;
|
||
folder.FolderLocalName = familyGroup.FamilyName;
|
||
repositoryFolder.InsertNow(folder);
|
||
}
|
||
|
||
if (familyGroupFolders != null && familyGroupFolders.Length > 0)
|
||
CreateFamilyGroupFolderDetail(folder, familyGroupFolders);
|
||
}
|
||
|
||
[PermissionOperate(name: MasterPermissionPolicy.DmsFile, operate: Operate.Insert)]
|
||
[UnitOfWork]
|
||
public void DeleteFamilyDmsFolder(FamilyDmsFileViewEntity familyDmsFile)
|
||
{
|
||
ISecurityGeneratorNumberService securityGeneratorNumberService = service.ServiceProvider.GetService<ISecurityGeneratorNumberService>()!;
|
||
IRepository<FamilyGroupFolderEntity> repositoryFamilyGroupFolder = repository.GetRepository<IRepository<FamilyGroupFolderEntity>>();
|
||
|
||
IRepository<DmsFolderEntity> repositoryFolder = repository.GetRepository<IRepository<DmsFolderEntity>>();
|
||
IRepository<DmsFolderMapEntity> repositoryFolderMap = repository.GetRepository<IRepository<DmsFolderMapEntity>>();
|
||
|
||
DmsFolderEntity folder;
|
||
DmsFolderMapEntity map;
|
||
DmsFileEntity entity;
|
||
|
||
FamilyGroupFolderEntity familyGroupFolder = repositoryFamilyGroupFolder.DetachedEntities.Where(x => x.FolderName == familyDmsFile.FolderName).FirstOrDefault()!;
|
||
|
||
repositoryFamilyGroupFolder.DeleteNow(familyGroupFolder);
|
||
|
||
//如果只是文件分享，则返回
|
||
if (familyDmsFile.IsDirectoryIndc == YesNoPolicy.NO) return;
|
||
|
||
folder = repositoryFolder.DetachedEntities.Where(x => x.FolderName == familyDmsFile.FolderName).FirstOrDefault()!;
|
||
|
||
repositoryFolder.DeleteNow(folder);
|
||
|
||
map = repositoryFolderMap.DetachedEntities.Where(x => x.FolderNameSon == folder.FolderName).FirstOrDefault()!;
|
||
|
||
repositoryFolderMap.DeleteNow(map);
|
||
|
||
entity = repository.DetachedEntities.Where(x => x.FileName == folder.FolderName).FirstOrDefault()!;
|
||
|
||
repository.DeleteNow(entity);
|
||
|
||
IRepository<FamilyFolderFavoriteEntity> repositoryFamilyFolderFavorite = repository.GetRepository<IRepository<FamilyFolderFavoriteEntity>>();
|
||
FamilyFolderFavoriteEntity[] folderFavorite = repositoryFamilyFolderFavorite.DetachedEntities.Where(x => x.FolderName == folder.FolderName).ToArray();
|
||
|
||
repositoryFamilyFolderFavorite.DeleteNow(folderFavorite);
|
||
}
|
||
|
||
[PermissionOperate(name: MasterPermissionPolicy.DmsFile, operate: Operate.Insert)]
|
||
[UnitOfWork]
|
||
public void CreateFamilyDmsFolder(FamilyDmsFileViewEntity familyDmsFile)
|
||
{
|
||
ISecurityGeneratorNumberService securityGeneratorNumberService = service.ServiceProvider.GetService<ISecurityGeneratorNumberService>()!;
|
||
IRepository<FamilyGroupFolderEntity> repositoryFolder = repository.GetRepository<IRepository<FamilyGroupFolderEntity>>();
|
||
|
||
//上级目录
|
||
FamilyGroupFolderEntity folder = repositoryFolder.DetachedEntities.Where(x => x.FolderName == familyDmsFile.FilePath).FirstOrDefault()!;
|
||
if (folder == null) return;
|
||
|
||
if (string.IsNullOrEmpty(familyDmsFile.FolderLocalName)) return;
|
||
|
||
CreateFamilyGroupFolder(folder, familyDmsFile);
|
||
}
|
||
|
||
private void CreateFamilyGroupFolder(FamilyGroupFolderEntity dmsFolder, FamilyDmsFileViewEntity familyDmsFile)
|
||
{
|
||
ISecurityGeneratorNumberService securityGeneratorNumberService = service.ServiceProvider.GetService<ISecurityGeneratorNumberService>()!;
|
||
IRepository<DmsFolderEntity> repositoryFolder = repository.GetRepository<IRepository<DmsFolderEntity>>();
|
||
IRepository<DmsFolderMapEntity> repositoryFolderMap = repository.GetRepository<IRepository<DmsFolderMapEntity>>();
|
||
|
||
DmsFolderEntity folder;
|
||
DmsFolderMapEntity map;
|
||
DmsFileEntity entity;
|
||
|
||
FamilyGroupFolderEntity familyGroupFolder = new FamilyGroupFolderEntity();
|
||
familyGroupFolder.FamilyName = familyDmsFile.FamilyName;
|
||
familyGroupFolder.FolderName = securityGeneratorNumberService.GetNo(MasterPrefixPolicy.DMS_FOLDER, MasterPrefixPolicy.DMS_FOLDER_FOLDER_NAME, "FG", YesNoPolicy.NO, "00000000");
|
||
familyGroupFolder.FolderLocalName = familyDmsFile.FolderLocalName;
|
||
familyGroupFolder.Notice = familyDmsFile.Notice;
|
||
//设置顶级目录
|
||
familyGroupFolder.TopFolderName = dmsFolder.TopFolderName;
|
||
|
||
IRepository<FamilyGroupFolderEntity> repositoryFamilyGroupFolder = repository.GetRepository<IRepository<FamilyGroupFolderEntity>>();
|
||
|
||
repositoryFamilyGroupFolder.InsertNow(familyGroupFolder);
|
||
|
||
folder = new DmsFolderEntity();
|
||
folder.FolderName = familyGroupFolder.FolderName;
|
||
folder.FolderLocalName = familyGroupFolder.FolderLocalName;
|
||
repositoryFolder.InsertNow(folder);
|
||
|
||
map = new DmsFolderMapEntity();
|
||
map.FolderNameParent = dmsFolder.FolderName;
|
||
map.FolderNameSon = folder.FolderName;
|
||
repositoryFolderMap.InsertNow(map);
|
||
|
||
//创建Dms目录
|
||
entity = new DmsFileEntity();
|
||
entity.OrderKey = entity.FileName = familyGroupFolder.FolderName;
|
||
entity.OrgFileName = folder.FolderLocalName;
|
||
entity.AllowDeleteIndc = entity.AllowRenameIndc = entity.IsDirectoryIndc = YesNoPolicy.YES;
|
||
|
||
entity.FilePath = map.FolderNameParent;
|
||
|
||
entity.OwerId = folder.FolderName;
|
||
entity.IsLinkIndc = YesNoPolicy.NO;
|
||
|
||
repository.InsertNow(entity);
|
||
}
|
||
|
||
|
||
private void CreateFamilyGroupFolderDetail(DmsFolderEntity dmsFolder, FamilyGroupFolderEntity[] familyGroupFolders)
|
||
{
|
||
ISecurityGeneratorNumberService securityGeneratorNumberService = service.ServiceProvider.GetService<ISecurityGeneratorNumberService>()!;
|
||
IRepository<DmsFolderEntity> repositoryFolder = repository.GetRepository<IRepository<DmsFolderEntity>>();
|
||
IRepository<DmsFolderMapEntity> repositoryFolderMap = repository.GetRepository<IRepository<DmsFolderMapEntity>>();
|
||
|
||
DmsFolderEntity folder;
|
||
DmsFolderMapEntity map;
|
||
DmsFileEntity entity;
|
||
foreach (var item in familyGroupFolders)
|
||
{
|
||
//如果是已创建,则跳过
|
||
if (!string.IsNullOrEmpty(item.CreatedBy)) continue;
|
||
|
||
folder = new DmsFolderEntity();
|
||
folder.FolderName = item.FolderName;
|
||
folder.FolderLocalName = item.FolderLocalName;
|
||
repositoryFolder.InsertNow(folder);
|
||
|
||
map = new DmsFolderMapEntity();
|
||
map.FolderNameParent = dmsFolder.FolderName;
|
||
map.FolderNameSon = folder.FolderName;
|
||
repositoryFolderMap.InsertNow(map);
|
||
|
||
//创建Dms目录
|
||
entity = new DmsFileEntity();
|
||
|
||
entity.OrderKey = entity.FileName = item.FolderName;
|
||
entity.OrgFileName = folder.FolderLocalName;
|
||
entity.AllowDeleteIndc = entity.AllowRenameIndc = entity.IsDirectoryIndc = YesNoPolicy.YES;
|
||
|
||
entity.FilePath = map.FolderNameParent;
|
||
|
||
entity.OwerId = folder.FolderName;
|
||
entity.IsLinkIndc = YesNoPolicy.NO;
|
||
|
||
repository.InsertNow(entity);
|
||
}
|
||
|
||
|
||
}
|
||
|
||
[PermissionOperate(name: MasterPermissionPolicy.DmsFile, operate: Operate.Update)]
|
||
[UnitOfWork]
|
||
public void UpdateDmsFolder(DmsFileEntity dmsFile)
|
||
{
|
||
IRepository<DmsFileUploadEntity> repositoryUpload = repository.GetRepository<IRepository<DmsFileUploadEntity>>();
|
||
|
||
DmsFileUploadEntity upload = repositoryUpload.DetachedEntities.Where(x => x.FileId == dmsFile.FileId).FirstOrDefault()!;
|
||
|
||
if (upload == null)
|
||
{
|
||
throw new ValidatedException("记录不存在.");
|
||
}
|
||
|
||
upload.OrgFileName = dmsFile.FileName;
|
||
|
||
repositoryUpload.UpdateNow(upload);
|
||
|
||
DmsFileEntity file = repository.DetachedEntities.Where(x => x.FileId == dmsFile.FileId).FirstOrDefault()!;
|
||
//修改目录档对应的名称
|
||
IRepository<DmsFolderEntity> repositoryFolder = repository.GetRepository<IRepository<DmsFolderEntity>>();
|
||
DmsFolderEntity dmsFolder = repositoryFolder.DetachedEntities.Where(x => x.FolderName == file.FileName).FirstOrDefault()!;
|
||
|
||
if (dmsFolder == null) return;
|
||
dmsFolder.FolderLocalName = upload.OrgFileName;
|
||
|
||
repositoryFolder.UpdateNow(dmsFolder);
|
||
|
||
|
||
}
|
||
|
||
[PermissionOperate(name: MasterPermissionPolicy.DmsFile, operate: Operate.Find)]
|
||
public SelectOption[] FindDmsFolders()
|
||
{
|
||
IRepository<DmsFolderEntity> repositoryFolder = repository.GetRepository<IRepository<DmsFolderEntity>>();
|
||
//排除FamilyGroup创建的目录
|
||
DmsFolderEntity[] ents = repositoryFolder.DetachedEntities.Where(x => x.FolderName.StartsWith("DR") && x.CreatedBy == service.UserId && x.FolderLocalName != service.UserId).ToArray();
|
||
List<SelectOption> l = new List<SelectOption>();
|
||
SelectOption selectOption;
|
||
|
||
DmsFolderEntity my = repositoryFolder.DetachedEntities.Where(x => x.CreatedBy == service.UserId && x.FolderLocalName == service.UserId).FirstOrDefault()!;
|
||
|
||
selectOption = new SelectOption();
|
||
selectOption.BindValue = string.Empty;
|
||
if (my == null)
|
||
{
|
||
selectOption.DisplayName = "我的网盘";
|
||
}
|
||
else
|
||
{
|
||
selectOption.DisplayName = "所有文件(夹)";
|
||
}
|
||
|
||
l.Add(selectOption);
|
||
|
||
if (my != null)
|
||
{
|
||
selectOption = new SelectOption();
|
||
selectOption.BindValue = my.FolderName;
|
||
selectOption.DisplayName = "我的网盘";
|
||
l.Add(selectOption);
|
||
}
|
||
|
||
if (ents == null || ents.Length == 0) return l.ToArray();
|
||
|
||
foreach (DmsFolderEntity ent in ents)
|
||
{
|
||
selectOption = new SelectOption();
|
||
selectOption.BindValue = ent.FolderName;
|
||
selectOption.DisplayName = ent.FolderLocalName;
|
||
l.Add(selectOption);
|
||
}
|
||
return l.ToArray();
|
||
}
|
||
|
||
[PermissionOperate(name: MasterPermissionPolicy.DmsFile, operate: Operate.Find)]
|
||
public SelectOption[] FindDmsFolderDeleteLogs()
|
||
{
|
||
IRepository<DmsFolderDeleteLogEntity> repositoryFolder = repository.GetRepository<IRepository<DmsFolderDeleteLogEntity>>();
|
||
//排除FamilyGroup创建的目录
|
||
DmsFolderDeleteLogEntity[] ents = repositoryFolder.DetachedEntities.Where(x => x.FolderName.StartsWith("DR") && x.CreatedBy == service.UserId && x.FolderLocalName != service.UserId).ToArray();
|
||
List<SelectOption> l = new List<SelectOption>();
|
||
SelectOption selectOption;
|
||
|
||
DmsFolderDeleteLogEntity my = repositoryFolder.DetachedEntities.Where(x => x.CreatedBy == service.UserId && x.FolderLocalName == service.UserId).FirstOrDefault()!;
|
||
|
||
selectOption = new SelectOption();
|
||
selectOption.BindValue = string.Empty;
|
||
if (my == null)
|
||
{
|
||
selectOption.DisplayName = "我的网盘";
|
||
}
|
||
else
|
||
{
|
||
selectOption.DisplayName = "所有文件(夹)";
|
||
}
|
||
|
||
l.Add(selectOption);
|
||
|
||
if (my != null)
|
||
{
|
||
selectOption = new SelectOption();
|
||
selectOption.BindValue = my.FolderName;
|
||
selectOption.DisplayName = "我的网盘";
|
||
l.Add(selectOption);
|
||
}
|
||
|
||
if (ents == null || ents.Length == 0) return l.ToArray();
|
||
|
||
foreach (DmsFolderDeleteLogEntity ent in ents)
|
||
{
|
||
selectOption = new SelectOption();
|
||
selectOption.BindValue = ent.FolderName;
|
||
selectOption.DisplayName = ent.FolderLocalName;
|
||
l.Add(selectOption);
|
||
}
|
||
return l.ToArray();
|
||
}
|
||
|
||
|
||
[PermissionOperate(name: MasterPermissionPolicy.DmsFile, operate: Operate.Find)]
|
||
public DmsFolderData FindDmsFolderData()
|
||
{
|
||
DmsFolderData data = new DmsFolderData();
|
||
|
||
IRepository<DmsFolderEntity> repositoryFolder = repository.GetRepository<IRepository<DmsFolderEntity>>();
|
||
DmsFolderEntity[] dmsFolders = repositoryFolder.DetachedEntities.Where(x => x.CreatedBy == service.UserId).ToArray();
|
||
|
||
data.DmsFolders = dmsFolders;
|
||
|
||
IRepository<DmsFolderMapEntity> repositoryFolderMap = repository.GetRepository<IRepository<DmsFolderMapEntity>>();
|
||
DmsFolderMapEntity[] dmsFolderMaps = repositoryFolderMap.DetachedEntities.Where(x => x.CreatedBy == service.UserId).ToArray();
|
||
data.DmsFoldersMaps = dmsFolderMaps;
|
||
|
||
return data;
|
||
}
|
||
|
||
[PermissionOperate(name: MasterPermissionPolicy.DmsFile, operate: Operate.Update)]
|
||
[UnitOfWork]
|
||
public void MoveDmsFolder(DmsFileEntity dmsFile)
|
||
{
|
||
DmsFileEntity file = repository.DetachedEntities.Where(x => x.FileId == dmsFile.FileId).FirstOrDefault()!;
|
||
|
||
if (file == null) return;
|
||
if (file.FilePath == dmsFile.FilePath) return;
|
||
|
||
file.FilePath = dmsFile.FilePath;
|
||
|
||
repository.UpdateNow(file);
|
||
|
||
IRepository<DmsFolderMapEntity> repositoryFolderMap = repository.GetRepository<IRepository<DmsFolderMapEntity>>();
|
||
|
||
DmsFolderMapEntity map = repositoryFolderMap.Entities.Where(x => x.FolderNameSon == file.FileName).FirstOrDefault()!;
|
||
if (map == null) return;
|
||
repositoryFolderMap.DeleteNow(map);
|
||
|
||
map = new DmsFolderMapEntity();
|
||
map.FolderNameSon = file.FileName;
|
||
map.FolderNameParent = dmsFile.FilePath;
|
||
repositoryFolderMap.InsertNow(map);
|
||
}
|
||
|
||
[PermissionOperate(name: MasterPermissionPolicy.DmsFile, operate: Operate.Insert)]
|
||
[UnitOfWork]
|
||
public void UploadFile()
|
||
{
|
||
//采用分片上传文件（以及后面分片下载）
|
||
DmsFileEntity dmsFile = null;
|
||
|
||
var files = httpContextAccessor.HttpContext.Request.Form.Files;
|
||
|
||
var currentDate = DateTime.Now;
|
||
if (files.Any())
|
||
{
|
||
foreach (var file in files)
|
||
{
|
||
string filePath = null;
|
||
if (httpContextAccessor.HttpContext.Request.Headers.ContainsKey("FilePath"))
|
||
filePath = httpContextAccessor.HttpContext.Request.Headers["FilePath"].ToString();
|
||
PackUploadFile(file, filePath);
|
||
break;
|
||
}
|
||
}
|
||
}
|
||
|
||
|
||
public void PackUploadFile(IFormFile file, string folderName)
|
||
{
|
||
var uploadFileRootPath = ServiceSettingsPolicy.GetUploadFileDirectory(service);
|
||
|
||
//文件后缀
|
||
var fileExtension = Path.GetExtension(file.Name.Replace(" ", "")).ToLower();//获取文件格式，拓展名
|
||
if (string.IsNullOrEmpty(fileExtension)) fileExtension = "ext";
|
||
|
||
var filePath = Path.Combine(folderName, fileExtension.Replace(".", ""), "");
|
||
|
||
//创建存储文件夹
|
||
if (!Directory.Exists(Path.Combine(uploadFileRootPath, filePath)))
|
||
{
|
||
Directory.CreateDirectory(Path.Combine(uploadFileRootPath, filePath));
|
||
}
|
||
//判断文件大小
|
||
var fileSize = file.Length;
|
||
if (fileSize > 1024 * 1024 * 100) //100M TODO:(1mb=1024X1024b)
|
||
{
|
||
return;
|
||
}
|
||
//保存的文件名称
|
||
string fullName = Path.Combine(uploadFileRootPath, filePath, file.FileName);
|
||
if (File.Exists(fullName)) File.Delete(fullName);
|
||
//文件保存
|
||
using (var fs = System.IO.File.Create(fullName))
|
||
{
|
||
file.CopyTo(fs);
|
||
fs.Flush();
|
||
}
|
||
//FileName上传Uid:xxxx-1-1.xxx
|
||
string[] fns = file.FileName.Split('-');
|
||
//如果上传的不是最后一个分片
|
||
if (fns[fns.Length - 2] != fns[fns.Length - 1].Split('.')[0])
|
||
{
|
||
return;
|
||
}
|
||
else
|
||
{
|
||
string backupRootPath = ServiceSettingsPolicy.GetBackupFileDirectory(service);
|
||
string backupFileName = Path.Combine(backupRootPath, filePath, file.FileName);
|
||
if (!Directory.Exists(Path.Combine(backupRootPath, filePath)))
|
||
{
|
||
Directory.CreateDirectory(Path.Combine(backupRootPath, filePath));
|
||
}
|
||
|
||
if (fns[fns.Length - 1].Split('.')[0] == "1")
|
||
{
|
||
if (File.Exists(backupFileName)) File.Delete(backupFileName);
|
||
File.Copy(fullName, backupFileName, true);
|
||
}
|
||
else//合并文件
|
||
{
|
||
List<byte[]> all = new List<byte[]>();
|
||
List<string> fileNames = new List<string>();
|
||
//文件分片从1开始
|
||
for (int i = 1; i <= Convert.ToInt32(fns[fns.Length - 1].Split('.')[0]); i++)
|
||
{
|
||
fns[fns.Length - 2] = i.ToString();
|
||
|
||
fileNames.Add(Path.Combine(uploadFileRootPath, filePath, fns.ToDelimiteredList('-')));
|
||
}
|
||
|
||
if (File.Exists(backupFileName)) File.Delete(backupFileName);
|
||
|
||
using (FileStream outputFile = File.Create(backupFileName)) // 创建输出文件流
|
||
{
|
||
foreach (string fileName in fileNames)
|
||
{
|
||
byte[] buffer = File.ReadAllBytes(fileName); // 读取每个文件内容到字节数组
|
||
outputFile.Write(buffer, 0, buffer.Length); // 将字节数组写入输出文件流
|
||
}
|
||
}
|
||
}
|
||
}
|
||
}
|
||
|
||
|
||
[PermissionOperate(name: MasterPermissionPolicy.DmsFile, operate: Operate.Insert)]
|
||
[UnitOfWork]
|
||
public void UploadDmsFile()
|
||
{
|
||
//采用分片上传文件（以及后面分片下载）
|
||
DmsFileEntity dmsFile = null;
|
||
|
||
var files = httpContextAccessor.HttpContext.Request.Form.Files;
|
||
|
||
var currentDate = DateTime.Now;
|
||
if (files.Any())
|
||
{
|
||
foreach (var file in files)
|
||
{
|
||
string filePath = null;
|
||
if (httpContextAccessor.HttpContext.Request.Headers.ContainsKey("FilePath"))
|
||
filePath = httpContextAccessor.HttpContext.Request.Headers["FilePath"].ToString();
|
||
dmsFile = PackUploadDmsFile(file, filePath);
|
||
break;
|
||
}
|
||
}
|
||
|
||
if (dmsFile != null)
|
||
{
|
||
CreateDmsFile(dmsFile);
|
||
}
|
||
}
|
||
|
||
public DmsFileEntity PackUploadDmsFile(IFormFile file, string folderName)
|
||
{
|
||
var webRootPath = ServiceSettingsPolicy.GetDmsFileUploadDirectory(service);
|
||
DmsFileEntity dmsFile = new DmsFileEntity();
|
||
dmsFile.OrgFileName = file.Name.Replace(" ", "");
|
||
dmsFile.FilePath = folderName;
|
||
//文件后缀
|
||
var fileExtension = Path.GetExtension(file.Name.Replace(" ", "")).ToLower();//获取文件格式，拓展名
|
||
if (string.IsNullOrEmpty(fileExtension)) fileExtension = "ext";
|
||
|
||
var filePath = Path.Combine(service.UserId, fileExtension.Replace(".", ""), "");
|
||
|
||
//创建存储文件夹
|
||
if (!Directory.Exists(Path.Combine(webRootPath, filePath)))
|
||
{
|
||
Directory.CreateDirectory(Path.Combine(webRootPath, filePath));
|
||
}
|
||
//判断文件大小
|
||
var fileSize = file.Length;
|
||
if (fileSize > 1024 * 1024 * 100) //100M TODO:(1mb=1024X1024b)
|
||
{
|
||
return null;
|
||
}
|
||
//保存的文件名称
|
||
string fullName = Path.Combine(webRootPath, filePath, file.FileName);
|
||
if (File.Exists(fullName)) File.Delete(fullName);
|
||
//文件保存
|
||
using (var fs = System.IO.File.Create(fullName))
|
||
{
|
||
file.CopyTo(fs);
|
||
fs.Flush();
|
||
}
|
||
//FileName上传Uid:xxxx-1-1.xxx
|
||
string[] fns = file.FileName.Split('-');
|
||
//如果上传的不是最后一个分片，不写入表
|
||
if (fns[fns.Length - 2] != fns[fns.Length - 1].Split('.')[0])
|
||
{
|
||
dmsFile = null;
|
||
return null;
|
||
}
|
||
else
|
||
{
|
||
dmsFile.OrderKey = file.FileName;
|
||
if (fns[fns.Length - 1].Split('.')[0] == "1")
|
||
{
|
||
dmsFile.OrderKey = file.FileName;
|
||
dmsFile.FileName = file.FileName;
|
||
dmsFile.FileSize = Convert.ToInt32(fileSize / 1024);
|
||
var backupRootPath = ServiceSettingsPolicy.GetDmsFileBackupDirectory(service);
|
||
string backupName = Path.Combine(backupRootPath, filePath, dmsFile.FileName);
|
||
if (!Directory.Exists(Path.Combine(backupRootPath, filePath)))
|
||
{
|
||
Directory.CreateDirectory(Path.Combine(backupRootPath, filePath));
|
||
}
|
||
if (File.Exists(backupName)) File.Delete(backupName);
|
||
File.Copy(fullName, backupName, true);
|
||
//生成缩略图
|
||
if (FileTypePolicy.GetType(fileExtension.ToLower()) == FileTypePolicy.PHOTO)
|
||
{
|
||
ImageToScare(fullName, dmsFile);
|
||
}
|
||
}
|
||
else//合并文件
|
||
{
|
||
List<byte[]> all = new List<byte[]>();
|
||
List<string> fileNames = new List<string>();
|
||
//文件分片从1开始
|
||
for (int i = 1; i <= Convert.ToInt32(fns[fns.Length - 1].Split('.')[0]); i++)
|
||
{
|
||
fns[fns.Length - 2] = i.ToString();
|
||
|
||
fileNames.Add(Path.Combine(webRootPath, filePath, fns.ToDelimiteredList('-')));
|
||
}
|
||
dmsFile.FileName = Path.GetFileName(fullName);
|
||
var backupRootPath = ServiceSettingsPolicy.GetDmsFileBackupDirectory(service);
|
||
|
||
fullName = Path.Combine(backupRootPath, filePath, dmsFile.FileName);
|
||
if (!Directory.Exists(Path.Combine(backupRootPath, filePath)))
|
||
{
|
||
Directory.CreateDirectory(Path.Combine(backupRootPath, filePath));
|
||
}
|
||
if (File.Exists(fullName)) File.Delete(fullName);
|
||
using (FileStream outputFile = File.Create(fullName)) // 创建输出文件流
|
||
{
|
||
foreach (string fileName in fileNames)
|
||
{
|
||
byte[] buffer = File.ReadAllBytes(fileName); // 读取每个文件内容到字节数组
|
||
outputFile.Write(buffer, 0, buffer.Length); // 将字节数组写入输出文件流
|
||
dmsFile.FileSize += buffer.Length;
|
||
}
|
||
dmsFile.FileSize = Convert.ToInt32(dmsFile.FileSize / 1024);//kb
|
||
}
|
||
//task:ImageSharpTask uid:SYSTEM file_size:5351 file_name:vc-upload-1709274146458-2-11-11_DSC_6141.JPG order_key:vc-upload-1709257162571-2-6-6.JPG
|
||
//生成缩略图
|
||
if (FileTypePolicy.GetType(fullName.ToLower()) == FileTypePolicy.PHOTO)
|
||
{
|
||
ImageToScare(fullName, dmsFile);
|
||
}
|
||
else if (FileTypePolicy.GetType(fullName.ToLower()) == FileTypePolicy.VIDEO)
|
||
{
|
||
foreach (string fileName in fileNames)
|
||
{
|
||
if (File.Exists(fileName)) File.Delete(fileName);
|
||
}
|
||
string m3u8FilePath = fullName.Replace(fileExtension, FileTypePolicy.JPG);
|
||
//生成m3u8(生成10秒视频，只生成截图)
|
||
dmsFile.TranscodeIndc = YesNoPolicy.YES;
|
||
TsToM3u8(dmsFile.OrderKey, fullName, m3u8FilePath);
|
||
}
|
||
}
|
||
}
|
||
return dmsFile;
|
||
}
|
||
|
||
[PermissionOperate(name: MasterPermissionPolicy.DmsFile, operate: Operate.Find)]
|
||
public string FindM3u8Path(long fileId)
|
||
{
|
||
DmsFileEntity entity = repository.DetachedEntities.Where(x => x.FileId == fileId && x.CreatedBy == service.UserId).FirstOrDefault()!;
|
||
|
||
return FileTypePolicy.PackSourceVideoUrl(service, entity.CreatedBy, entity.OrderKey, entity.TranscodeIndc);
|
||
}
|
||
|
||
[PermissionOperate(name: MasterPermissionPolicy.DmsFile, operate: Operate.Find)]
|
||
public string FindSourceVideoPath(long fileId)
|
||
{
|
||
DmsFileEntity entity = repository.DetachedEntities.Where(x => x.FileId == fileId && x.CreatedBy == service.UserId).FirstOrDefault()!;
|
||
|
||
return FileTypePolicy.PackSourceVideoUrl(service, entity.CreatedBy, entity.OrderKey,entity.TranscodeIndc);
|
||
}
|
||
|
||
[PermissionOperate(name: MasterPermissionPolicy.DmsFile, operate: Operate.Find)]
|
||
public string FindDeleteLogM3u8Path(long fileId)
|
||
{
|
||
IRepository<DmsFileDeleteLogEntity> repositoryDmsFileDeleteLog = repository.GetRepository<IRepository<DmsFileDeleteLogEntity>>();
|
||
DmsFileDeleteLogEntity entity = repositoryDmsFileDeleteLog.DetachedEntities.Where(x => x.FileId == fileId && x.CreatedBy == service.UserId).FirstOrDefault()!;
|
||
|
||
return FileTypePolicy.PackSourceVideoUrl(service, entity.CreatedBy, entity.OrderKey,entity.TranscodeIndc);
|
||
}
|
||
|
||
private string PackParameters(DmsFileEntity dmsFile)
|
||
{
|
||
List<string> para = new List<string>();
|
||
para.Add("task:" + "ImageSharpTask");
|
||
para.Add("uid:" + service.UserId);
|
||
para.Add("file_size:" + dmsFile.FileSize);
|
||
para.Add("file_name:" + dmsFile.FileName);
|
||
para.Add("order_key:" + dmsFile.OrderKey);
|
||
return para.ToArray().ToDelimiteredList(' ');
|
||
}
|
||
|
||
public void TsToM3u8(string documentId, string mp4Url, string m3u8Url)
|
||
{
|
||
string para = string.Format(service.Configuration[ServiceSettingsPolicy.FfmpegPictrue], mp4Url, m3u8Url);
|
||
try
|
||
{
|
||
RunMyProcess(service.Configuration[ServiceSettingsPolicy.FfmpegPath], para);
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
new FileLog(service.Configuration).WriteToFile(ex.Message);
|
||
}
|
||
|
||
var backupRootPath = ServiceSettingsPolicy.GetDmsFileBackupDirectory(service);
|
||
|
||
var fileExtension = "m3u8";
|
||
var filePath = Path.Combine(service.UserId, fileExtension.Replace(".", ""), "");
|
||
var orgFileExtension = Path.GetExtension(documentId);
|
||
var fullName = Path.Combine(backupRootPath, filePath, documentId.Replace(orgFileExtension, ".m3u8"));
|
||
|
||
string targetDir = Path.GetDirectoryName(fullName);
|
||
|
||
if (!Directory.Exists(targetDir))
|
||
{
|
||
Directory.CreateDirectory(targetDir);
|
||
}
|
||
|
||
para = string.Format(service.Configuration[ServiceSettingsPolicy.FfmpegArguments], mp4Url, "", fullName);
|
||
|
||
IRepository<SecurityScheduleTaskQueueEntity> logRepository = repository.GetRepository<IRepository<SecurityScheduleTaskQueueEntity>>();
|
||
SecurityScheduleTaskQueueEntity task = new SecurityScheduleTaskQueueEntity();
|
||
|
||
task.DocumentId = documentId;
|
||
task.TaskId = service.Configuration[ServiceSettingsPolicy.FfmpegPath];
|
||
task.TaskParam = para;
|
||
|
||
logRepository.InsertNow(task);
|
||
|
||
para = string.Format(service.Configuration[ServiceSettingsPolicy.FfmpegArguments], mp4Url, " -t 10", fullName);
|
||
|
||
//直接转码视频文件10秒，影响服务器性能，改为在闭时自动生成全部
|
||
RunMyProcess(task.TaskId, para);
|
||
}
|
||
|
||
public void ImageToScare(string fullName, DmsFileEntity dmsFile)
|
||
{
|
||
var fileExtension = Path.GetExtension(fullName).ToLower();//获取文件格式，拓展名
|
||
if (string.IsNullOrEmpty(fileExtension)) fileExtension = "ext";
|
||
// 仅修改这一行，替换硬编码反斜杠字符串拼接
|
||
var filePath = Path.Combine(service.UserId, fileExtension.Replace(".", ""), "");
|
||
// 这里同步改成Path.Combine，不要直接+字符串拼接
|
||
string saveName = Path.Combine(ServiceSettingsPolicy.GetDmsFileScaleDirectory(service), filePath, dmsFile.OrderKey);
|
||
|
||
if (!Directory.Exists(Path.GetDirectoryName(saveName)))
|
||
{
|
||
Directory.CreateDirectory(Path.GetDirectoryName(saveName));
|
||
}
|
||
|
||
using (Image image = Image.Load(fullName))
|
||
{
|
||
decimal scale = 1;
|
||
if (image.Width > 932 && image.Width > image.Height)
|
||
{
|
||
if (dmsFile != null)
|
||
{
|
||
dmsFile.LandscapeIndc = YesNoPolicy.YES;
|
||
}
|
||
|
||
scale = image.Width / 932m;
|
||
|
||
int newWidth = Convert.ToInt32(image.Width / scale);
|
||
int newHeight = Convert.ToInt32(image.Height / scale);
|
||
image.Mutate(x => x.Resize(newWidth, newHeight, KnownResamplers.Lanczos3));
|
||
|
||
if (newWidth > 932)
|
||
image.Mutate(a => a.Crop(new Rectangle((newWidth - 932) / 2, 0, 932, 430)));
|
||
}
|
||
else if (image.Height > 932 && image.Height > image.Width)
|
||
{
|
||
if (dmsFile != null)
|
||
{
|
||
dmsFile.LandscapeIndc = YesNoPolicy.NO;
|
||
}
|
||
|
||
scale = image.Height / 932m;
|
||
|
||
int newWidth = Convert.ToInt32(image.Width / scale);
|
||
int newHeight = Convert.ToInt32(image.Height / scale);
|
||
image.Mutate(x => x.Resize(newWidth, newHeight, KnownResamplers.Lanczos3));
|
||
|
||
if (newWidth > 430)
|
||
image.Mutate(a => a.Crop(new Rectangle((newWidth - 430) / 2, 0, 430, 932)));
|
||
}
|
||
|
||
image.Save(saveName);
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 执行cmd指令(异步不等待，await要求等待返回，转码太耗时)
|
||
/// </summary>
|
||
/// <param name="Parameters"></param>
|
||
public void RunMyProcess(string exePath, string Parameters)
|
||
{
|
||
FileLog log = new FileLog(service.Configuration);
|
||
try
|
||
{
|
||
log.WriteToFile(exePath + Parameters);
|
||
if (string.IsNullOrEmpty(exePath)) return;
|
||
|
||
// 必须等 ffmpeg 真正退出：视频封面(jpg)要在接口返回前落盘，
|
||
// 否则前端刷新列表时文件还没生成，<img> 请求 404 且不会自动重试，
|
||
// 表现为"上传完看不到封面，手动刷新才有"。
|
||
// 最多等 25 秒，超时就交给前端的封面重试机制兜底，不再死等拖住上传请求。
|
||
// CliWrap 的 ExecuteAsync 返回 CommandTask<CommandResult>，取它的 Task 才能等待
|
||
var task = Cli.Wrap(exePath)
|
||
.WithArguments(Parameters)
|
||
.ExecuteAsync()
|
||
.Task;
|
||
|
||
if (!task.Wait(TimeSpan.FromSeconds(25)))
|
||
{
|
||
log.WriteToFile("ffmpeg 执行超时(25s)：" + Parameters);
|
||
return;
|
||
}
|
||
|
||
log.WriteToFile("ffmpeg 执行完成，ExitCode：" + task.Result.ExitCode);
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
// 截图失败不影响上传本身，这里只记日志，封面由前端重试兜底
|
||
log.WriteToFile(ex.Message);
|
||
}
|
||
}
|
||
|
||
public DmsFileEntity CreateDmsFile(DmsFileEntity dmsFile)
|
||
{
|
||
IRepository<DmsFolderEntity> repositoryFolder = repository.GetRepository<IRepository<DmsFolderEntity>>();
|
||
ISecurityGeneratorNumberService securityGeneratorNumberService = service.ServiceProvider.GetService<ISecurityGeneratorNumberService>()!;
|
||
DmsFolderEntity folder = null;
|
||
string folderNameParent = dmsFile.FilePath;
|
||
//父目录是空，创建顶级目录
|
||
if (string.IsNullOrEmpty(dmsFile.FilePath))
|
||
{
|
||
folder = repositoryFolder.DetachedEntities.Where(x => x.FolderLocalName == service.UserId).FirstOrDefault()!;
|
||
if (folder == null)
|
||
{
|
||
folder = new DmsFolderEntity();
|
||
folder.FolderName = securityGeneratorNumberService.GetNo(MasterPrefixPolicy.DMS_FOLDER, MasterPrefixPolicy.DMS_FOLDER_FOLDER_NAME, null, YesNoPolicy.NO, "00000000");
|
||
folder.FolderLocalName = service.UserId;
|
||
repositoryFolder.InsertNow(folder);
|
||
}
|
||
folderNameParent = folder.FolderName;
|
||
}
|
||
|
||
DmsFileUploadEntity upload = new DmsFileUploadEntity();
|
||
|
||
upload.FileCategory = "MASTER";
|
||
upload.UploadName = securityGeneratorNumberService.GetNo(MasterPrefixPolicy.UPLOAD_DMS_FILE, MasterPrefixPolicy.UPLOAD_DMS_FILE_UPLOAD_NAME, "FL", YesNoPolicy.NO, MasterPrefixPolicy.UPLOAD_DMS_FILE_FORMAT);
|
||
upload.OrgFileName = dmsFile.OrgFileName;
|
||
|
||
//创建Dms文件
|
||
DmsFileEntity entity = new DmsFileEntity();
|
||
entity.OrderKey = dmsFile.OrderKey;
|
||
entity.FileName = upload.UploadName;
|
||
entity.FileType = FileTypePolicy.GetType(entity.OrderKey);
|
||
entity.OrgFileName = dmsFile.FileName;
|
||
entity.FileSize = dmsFile.FileSize;
|
||
entity.AllowDeleteIndc = entity.AllowRenameIndc = YesNoPolicy.YES;
|
||
entity.IsDirectoryIndc = YesNoPolicy.NO;
|
||
|
||
entity.FilePath = folderNameParent;
|
||
entity.TranscodeIndc = dmsFile.TranscodeIndc;
|
||
entity.OwerId = service.UserId;
|
||
entity.IsLinkIndc = YesNoPolicy.NO;
|
||
|
||
repository.InsertNow(entity);
|
||
|
||
IRepository<DmsFileUploadEntity> repositoryUpload = repository.GetRepository<IRepository<DmsFileUploadEntity>>();
|
||
upload.FileId = entity.FileId;
|
||
repositoryUpload.InsertNow(upload);
|
||
|
||
//创建目录关系表
|
||
DmsFolderMapEntity map = new DmsFolderMapEntity();
|
||
IRepository<DmsFolderMapEntity> repositoryFolderMap = repository.GetRepository<IRepository<DmsFolderMapEntity>>();
|
||
map.FolderNameParent = folderNameParent;
|
||
map.FolderNameSon = entity.FileName;
|
||
repositoryFolderMap.InsertNow(map);
|
||
|
||
|
||
return entity;
|
||
}
|
||
|
||
[PermissionOperate(name: MasterPermissionPolicy.DmsFile, operate: Operate.Find)]
|
||
public dynamic DownloadFile(long fileId)
|
||
{
|
||
DmsFileEntity entity = repository.DetachedEntities.Where(x => x.FileId == fileId && x.CreatedBy == service.UserId).FirstOrDefault()!;
|
||
|
||
if (entity == null) throw new ValidatedException("文件不存在.");
|
||
|
||
var fileExtension = Path.GetExtension(entity.OrderKey);//获取文件格式，拓展名
|
||
|
||
string path = FileTypePolicy.PackFilePath(service, entity.CreatedBy, entity.OrderKey);
|
||
|
||
IRepository<DmsFileUploadEntity> repositoryUpload = repository.GetRepository<IRepository<DmsFileUploadEntity>>();
|
||
DmsFileUploadEntity DmsFileUpload = repositoryUpload.DetachedEntities.Where(x => x.FileId == fileId).FirstOrDefault()!;
|
||
|
||
if (DmsFileUpload == null || !File.Exists(path)) throw new ValidatedException("文件不存在.");
|
||
|
||
var stream = System.IO.File.OpenRead(path);
|
||
|
||
string contentType = "application/octet-stream";
|
||
|
||
switch (fileExtension.Replace(".", "").ToLower())
|
||
{
|
||
case "xls":
|
||
case "xlt":
|
||
case "xla":
|
||
contentType = "application/vnd.ms-excel";
|
||
break;
|
||
case "xlsx":
|
||
case "xltx":
|
||
contentType = "application/vnd.openxmlformats-officedocument.spreadsheetml.sheet";
|
||
break;
|
||
case "doc":
|
||
contentType = "application/msword";
|
||
break;
|
||
case "docx":
|
||
contentType = "application/vnd.openxmlformats-officedocument.wordprocessingml.document";
|
||
break;
|
||
case "txt":
|
||
contentType = "text/plain";
|
||
break;
|
||
case "png":
|
||
case "jpg":
|
||
case "jpeg":
|
||
case "gif":
|
||
contentType = "image/*";
|
||
break;
|
||
case "mp4":
|
||
case "mpg":
|
||
case "mpeg":
|
||
case "avi":
|
||
contentType = "video/*";
|
||
break;
|
||
case "pdf":
|
||
contentType = "application/pdf";
|
||
break;
|
||
default:
|
||
break;
|
||
}
|
||
|
||
return new FileStreamResult(stream, contentType) { FileDownloadName = DmsFileUpload.OrgFileName };
|
||
}
|
||
|
||
[PermissionOperate(name: MasterPermissionPolicy.DmsFile, operate: Operate.Find)]
|
||
public dynamic DownloadFilePreview(DmsFileEntity dmsFile)
|
||
{
|
||
var webRootPath = ServiceSettingsPolicy.GetDmsFileScaleDirectory(service);
|
||
var fileExtension = Path.GetExtension(dmsFile.OrderKey);
|
||
|
||
var filePath = Path.Combine(dmsFile.CreatedBy, fileExtension.Replace(".", ""), "");
|
||
string path = Path.Combine(webRootPath, filePath, dmsFile.OrderKey);
|
||
|
||
if (!File.Exists(path)) throw new ValidatedException("文件不存在.");
|
||
|
||
var stream = System.IO.File.OpenRead(path);
|
||
|
||
//string contentType = "image/*";
|
||
string contentType = "application/octet-stream";
|
||
|
||
return new FileStreamResult(stream, contentType) { FileDownloadName = dmsFile.OrderKey };
|
||
|
||
}
|
||
|
||
[PermissionOperate(name: MasterPermissionPolicy.DmsFile, operate: Operate.Find)]
|
||
public dynamic DownloadFileCombine(string fileName)
|
||
{
|
||
var webRootPath = ServiceSettingsPolicy.GetDmsFileUploadDirectory(service);
|
||
var fileExtension = Path.GetExtension(fileName);
|
||
|
||
var filePath = Path.Combine(service.UserId, fileExtension.Replace(".", ""), "");
|
||
string path = Path.Combine(webRootPath, filePath, fileName);
|
||
|
||
if (!File.Exists(path)) throw new ValidatedException("文件不存在.");
|
||
|
||
var stream = System.IO.File.OpenRead(path);
|
||
|
||
//string contentType = "image/*";
|
||
string contentType = "application/octet-stream";
|
||
|
||
return new FileStreamResult(stream, contentType) { FileDownloadName = fileName };
|
||
}
|
||
|
||
[PermissionOperate(name: MasterPermissionPolicy.DmsFile, operate: Operate.Find)]
|
||
public SelectOption[] FindFamilyDmsFolders()
|
||
{
|
||
IRepository<FamilyGroupManagerUserViewEntity> repositoryFamilyGroupManager = repository.GetRepository<IRepository<FamilyGroupManagerUserViewEntity>>();
|
||
|
||
FamilyGroupManagerUserViewEntity[] ents = repositoryFamilyGroupManager.DetachedEntities.Where(x => x.UserName == service.UserId && x.ValidIndc == "Y").ToArray();
|
||
List<SelectOption> l = new List<SelectOption>();
|
||
SelectOption selectOption;
|
||
|
||
if (ents == null || ents.Length == 0) return l.ToArray();
|
||
|
||
foreach (FamilyGroupManagerUserViewEntity ent in ents)
|
||
{
|
||
selectOption = new SelectOption();
|
||
selectOption.BindValue = ent.FamilyName;
|
||
selectOption.DisplayName = ent.FamilyLocalName;
|
||
l.Add(selectOption);
|
||
}
|
||
return l.ToArray();
|
||
}
|
||
|
||
[PermissionOperate(name: MasterPermissionPolicy.DmsFile, operate: Operate.Find)]
|
||
public SelectOption[] FindFamilyDmsFoldersByFamilyName(string familyName)
|
||
{
|
||
List<SelectOption> l = new List<SelectOption>();
|
||
SelectOption selectOption;
|
||
|
||
if (string.IsNullOrEmpty(familyName)) return l.ToArray();
|
||
|
||
IRepository<FamilyGroupEntity> repositoryFamilyGroup = repository.GetRepository<IRepository<FamilyGroupEntity>>();
|
||
|
||
FamilyGroupEntity group = repositoryFamilyGroup.DetachedEntities.Where(x => x.FamilyName == familyName && x.ValidIndc == YesNoPolicy.YES).FirstOrDefault()!;
|
||
if (group == null) return l.ToArray();
|
||
|
||
selectOption = new SelectOption();
|
||
selectOption.BindValue = group.FamilyName;
|
||
selectOption.DisplayName = group.FamilyLocalName;
|
||
l.Add(selectOption);
|
||
|
||
IRepository<FamilyGroupFolderEntity> repositoryFamilyGroupFolder = repository.GetRepository<IRepository<FamilyGroupFolderEntity>>();
|
||
|
||
FamilyGroupFolderEntity[] ents = repositoryFamilyGroupFolder.DetachedEntities.Where(x => x.FamilyName == familyName && string.IsNullOrEmpty(x.FilePath)).ToArray();
|
||
if (ents == null || ents.Length == 0) return l.ToArray();
|
||
|
||
|
||
|
||
foreach (FamilyGroupFolderEntity ent in ents)
|
||
{
|
||
selectOption = new SelectOption();
|
||
selectOption.BindValue = ent.FolderName;
|
||
selectOption.DisplayName = ent.FolderLocalName;
|
||
l.Add(selectOption);
|
||
}
|
||
return l.ToArray();
|
||
}
|
||
|
||
[PermissionOperate(name: MasterPermissionPolicy.DmsFile, operate: Operate.Find)]
|
||
public int FindDmsFolderMapByFolderName(string folderName)
|
||
{
|
||
IRepository<DmsFolderMapEntity> repositoryFolderMap = repository.GetRepository<IRepository<DmsFolderMapEntity>>();
|
||
|
||
return repositoryFolderMap.DetachedEntities.Where(x => x.FolderNameParent == folderName).Count();
|
||
}
|
||
|
||
[PermissionOperate(name: MasterPermissionPolicy.DmsFile, operate: Operate.Find)]
|
||
public string FindFolderNameParentByFolderName(string folderName)
|
||
{
|
||
IRepository<DmsFolderMapEntity> repositoryFolderMap = repository.GetRepository<IRepository<DmsFolderMapEntity>>();
|
||
if (repositoryFolderMap.DetachedEntities.Where(x => x.FolderNameSon == folderName).Count() == 0) return string.Empty;
|
||
|
||
return repositoryFolderMap.DetachedEntities.Where(x => x.FolderNameSon == folderName).FirstOrDefault()!.FolderNameParent;
|
||
}
|
||
|
||
[PermissionOperate(name: MasterPermissionPolicy.DmsFile, operate: Operate.Insert)]
|
||
public void CreateFamilyGroupFolder(FamilyGroupFolderEntity[] familyGroupFolder)
|
||
{
|
||
FamilyGroupFolderEntity folder;
|
||
IRepository<FamilyGroupFolderEntity> repositoryFamilyGroupFolder = repository.GetRepository<IRepository<FamilyGroupFolderEntity>>();
|
||
|
||
foreach (var item in familyGroupFolder)
|
||
{
|
||
folder = repositoryFamilyGroupFolder.DetachedEntities.Where(x => x.FolderName == item.FolderName
|
||
&& x.FamilyName == item.FamilyName && x.FilePath == item.FilePath).FirstOrDefault()!;
|
||
if (folder != null) continue;
|
||
folder = new FamilyGroupFolderEntity();
|
||
|
||
folder.FolderName = item.FolderName;
|
||
folder.FamilyName = item.FamilyName;
|
||
folder.TopFolderName = item.TopFolderName;
|
||
|
||
folder.FolderLocalName = item.FolderLocalName;
|
||
folder.FilePath = item.FilePath;
|
||
|
||
repositoryFamilyGroupFolder.InsertNow(folder);
|
||
}
|
||
|
||
}
|
||
|
||
[PermissionOperate(name: MasterPermissionPolicy.DmsFile, operate: Operate.Delete)]
|
||
public void DeleteFamilyGroupFolder(FamilyGroupFolderEntity[] familyGroupFolder)
|
||
{
|
||
FamilyGroupFolderEntity folder;
|
||
IRepository<FamilyGroupFolderEntity> repositoryFamilyGroupFolder = repository.GetRepository<IRepository<FamilyGroupFolderEntity>>();
|
||
|
||
IRepository<FamilyGroupPermissionEntity> repositoryFamilyGroupPermission = repository.GetRepository<IRepository<FamilyGroupPermissionEntity>>();
|
||
FamilyGroupPermissionEntity fgp;
|
||
foreach (var item in familyGroupFolder)
|
||
{
|
||
folder = repositoryFamilyGroupFolder.DetachedEntities.Where(x => x.FolderName == item.FolderName
|
||
&& x.FamilyName == item.FamilyName && x.FilePath == (string.IsNullOrEmpty(item.FilePath) ? null : item.FilePath)).FirstOrDefault()!;
|
||
if (folder == null) continue;
|
||
|
||
//再分析是否有权限
|
||
|
||
fgp = repositoryFamilyGroupPermission.DetachedEntities.Where(x => x.FamilyName == folder.FamilyName
|
||
&& x.FolderName == folder.TopFolderName && x.UserName == service.UserId).FirstOrDefault()!;
|
||
|
||
if (fgp == null) throw new ValidatedException("你没有权限删除.");
|
||
|
||
repositoryFamilyGroupFolder.DeleteNow(folder);
|
||
}
|
||
|
||
}
|
||
|
||
}
|
||
}
|