using CliWrap;
using CloudBuilder.Core.DatabaseAccessor;
using CloudBuilder.Core.DatabaseAccessor.Entity;
using CloudBuilder.Core.Service;
using CloudBuilder.Master.Data;
using CloudBuilder.Master.Entity;
using CloudBuilder.Master.Policy;
using CloudBuilder.Master.SearchCriteria;
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 = service.Configuration[ServiceSettingsPolicy.DmsFileScaleDirectory].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, item.TranscodeIndc);
                }

                data.Datas = list.Select(x => new DmsFileUploadViewDisplayData(x)
                {
                    FormattedPic = FileTypePolicy.PackUrl(service, x.CreatedBy, x.OrderKey, YesNoPolicy.YES)
                }).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 = service.Configuration[ServiceSettingsPolicy.DmsFileScaleDirectory].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, item.TranscodeIndc);
                }

                data.Datas = list.Select(x => new DmsFileUploadViewDisplayData(x)
                {
                    FormattedPic = FileTypePolicy.PackUrl(service, x.CreatedBy, x.OrderKey, YesNoPolicy.YES)
                }).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 = service.Configuration[ServiceSettingsPolicy.DmsFileScaleDirectory].Replace(phy, "");

                foreach (var item in list)
                {
                    item.Url = FileTypePolicy.PackUrl(service, item.CreatedBy, item.OrderKey, item.TranscodeIndc);
                }

                data.Logs = list.Select(x => new DmsFileUploadDeleteLogViewDisplayData(x)
                {
                    FormattedPic = FileTypePolicy.PackUrl(service, x.CreatedBy, x.OrderKey, YesNoPolicy.YES)
                }).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 = service.Configuration[ServiceSettingsPolicy.DmsFileScaleDirectory].Replace(phy, "");


                foreach (var item in list)
                {
                    item.Url = FileTypePolicy.PackUrl(service, item.CreatedBy, item.OrderKey, item.TranscodeIndc);
                }

                data.Families = list.Select(x => new FamilyDmsFileViewDisplayData(x)
                {
                    FileType = FileTypePolicy.GetType(x.OrderKey),
                    FormattedPic = FileTypePolicy.PackUrl(service, x.CreatedBy, x.OrderKey, YesNoPolicy.YES)
                }).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;
            }

            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 = dmsFile.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();

            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 = dmsFile.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()!;

            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);
                }

                IRepository<DmsFolderMapDeleteLogEntity> repositoryDmsFolderMapDeleteLog = repository.GetRepository<IRepository<DmsFolderMapDeleteLogEntity>>();
                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);
                    }
                }


            }

        }

        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();
                    dmsFile = PackUploadFile(file, filePath);
                    break;
                }
            }

            if (dmsFile != null)
            {
                CreateDmsFile(dmsFile);
            }
        }

        public DmsFileEntity PackUploadFile(IFormFile file, string folderName)
        {
            var webRootPath = service.Configuration[ServiceSettingsPolicy.DmsFileUploadDirectory];
            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 = service.Configuration[ServiceSettingsPolicy.DmsFileBackupDirectory];
                    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 = service.Configuration[ServiceSettingsPolicy.DmsFileBackupDirectory];

                    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, ".png");
                        //生成m3u8(暂不生成，只生成截图)
                        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.PackUrl(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);
        }

        [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);
        }

        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 orderKey, string mp4Url, string m3u8Url, int videoLength = 6)
        {
            string para = string.Format(service.Configuration[ServiceSettingsPolicy.FfmpegPictrue], mp4Url, m3u8Url);
            RunMyProcess(service.Configuration[ServiceSettingsPolicy.FfmpegPath], para);
            return;
            para = string.Format(service.Configuration["Ffmpeg:Arguments"], mp4Url, videoLength, m3u8Url);
            //不直接转码视频文件，影响服务器性能，改为在闭时自动生成
            //Task.Run(() =>
            //{
            //    Thread.Sleep(200);
            //    RunMyProcess(service.Configuration["Ffmpeg:Path"], para);
            //});
            //IRepository<VideoToM3u8LogEntity> logRepository = repository.GetRepository<IRepository<VideoToM3u8LogEntity>>();
            //VideoToM3u8LogEntity log = new VideoToM3u8LogEntity();
            //log.VideoName = para;
            //log.FilePath = Path.GetDirectoryName(m3u8Url)!;
            //log.OrderKey = orderKey;
            //log.Status = "S";
            //logRepository.InsertNow(log);
        }

        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(service.Configuration[ServiceSettingsPolicy.DmsFileScaleDirectory], 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)
        {
            try
            {
                if (string.IsNullOrEmpty(exePath)) return;
                Cli.Wrap(exePath)
               .WithArguments(Parameters)
               .ExecuteAsync();
            }
            catch (Exception ex)
            {
                throw new ValidatedException(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.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 = service.Configuration[ServiceSettingsPolicy.DmsFileScaleDirectory];
            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 = service.Configuration[ServiceSettingsPolicy.DmsFileUploadDirectory];
            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.FolderNameSon == 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);
            }

        }

    }
}