using CloudBuilder.AI.Data;
using CloudBuilder.AI.Entity;
using CloudBuilder.AI.Policy;
using CloudBuilder.AI.SearchCriteria;
using CloudBuilder.Core.DatabaseAccessor;
using CloudBuilder.Core.DatabaseAccessor.Entity;
using CloudBuilder.Core.Service;
using CloudBuilder.Security.Policy;
using CloudBuilder.Security.Service;
using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.DependencyInjection;
namespace CloudBuilder.AI.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: AIPermissionPolicy.DmsFile, operate: Operate.Find)]
        public DmsFileEntity FindByKey(int key)
        {
            return repository.DetachedEntities.Where(x => x.FileId == key).FirstOrDefault()!;
        }

        [PermissionOperate(name: AIPermissionPolicy.DmsFile, operate: Operate.Find)]
        public DmsFileResultData FindBySearchCriteria(DmsFileSearchCriteria criteria)
        {
            DmsFileResultData data = new DmsFileResultData();
            BookDmsFileViewEntity[] list = null;

            int 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}' ", BookDmsFileViewEntity.DB_CREATED_BY, service.UserId);

            BookDmsFileViewEntity entity = BookDmsFileViewEntity.GetInstance();
            string sql = entity.GetSelectTopFrom(criteria.limit, criteria.page, criteria.orderby.StringToDbField(), criteria.orderbytag, sqlWhere);

            IRepository<BookDmsFileViewEntity> repositoryView = repository.GetRepository<IRepository<BookDmsFileViewEntity>>();

            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 = (int)repository.ExecuteScalar(sql);

                var webRootPath = service.Configuration["FileServiceSettings:RequestPath"];
                var phy = service.Configuration["FileServiceSettings:PhysicalFileDirectory"];
                var scale = service.Configuration["FileServiceSettings:ScaleDmsFileDirectory"].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 BookDmsFileViewDisplayData(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: AIPermissionPolicy.DmsFile, operate: Operate.Find)]
        public DmsFileResultData FindDatasBySearchCriteria(DmsFileSearchCriteria criteria)
        {
            DmsFileResultData data = new DmsFileResultData();
            BookDmsFileViewEntity[] list = null;

            int 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}' ",
                BookDmsFileViewEntity.DB_CREATED_BY, service.UserId,
                BookDmsFileViewEntity.DB_IS_DIRECTORY_INDC, YesNoPolicy.NO
                );

            BookDmsFileViewEntity entity = BookDmsFileViewEntity.GetInstance();
            string sql = entity.GetSelectTopFrom(criteria.limit, criteria.page, criteria.orderby.StringToDbField(), criteria.orderbytag, sqlWhere);

            IRepository<BookDmsFileViewEntity> repositoryView = repository.GetRepository<IRepository<BookDmsFileViewEntity>>();

            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 = (int)repository.ExecuteScalar(sql);

                var webRootPath = service.Configuration["FileServiceSettings:RequestPath"];
                var phy = service.Configuration["FileServiceSettings:PhysicalFileDirectory"];
                var scale = service.Configuration["FileServiceSettings:ScaleDmsFileDirectory"].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 BookDmsFileViewDisplayData(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: AIPermissionPolicy.DmsFile, operate: Operate.Print)]
        public dynamic PrintBySearchCriteria(DmsFileSearchCriteria criteria)
        {
            throw new NotImplementedException();
        }

        [PermissionOperate(name: AIPermissionPolicy.DmsFile, operate: Operate.Insert)]
        [UnitOfWork]
        public DmsFileEntity Insert(DmsFileEntity data)
        {
            throw new NotImplementedException();
        }

        [PermissionOperate(name: AIPermissionPolicy.DmsFile, operate: Operate.Update)]
        [UnitOfWork]
        public DmsFileEntity Update(DmsFileEntity data)
        {
            throw new NotImplementedException();
        }


        [PermissionOperate(name: AIPermissionPolicy.DmsFile, operate: Operate.Delete)]
        [UnitOfWork]
        public void Delete(int key)
        {
            DmsFileEntity dmsFile = repository.DetachedEntities.Where(x => x.FileId == key).FirstOrDefault()!;

            if (dmsFile == null) return;

            IRepository<BookDmsFileEntity> repositoryUpload = repository.GetRepository<IRepository<BookDmsFileEntity>>();
            IRepository<DmsFolderMapEntity> repositoryFolderMap = repository.GetRepository<IRepository<DmsFolderMapEntity>>();
            IRepository<DmsFolderEntity> repositoryFolder = repository.GetRepository<IRepository<DmsFolderEntity>>();

            repository.DeleteNow(dmsFile);


            BookDmsFileEntity uploadDmsFile = repositoryUpload.DetachedEntities.Where(x => x.FileId == key).FirstOrDefault()!;


            if (uploadDmsFile != null)
            {
                repositoryUpload.DeleteNow(uploadDmsFile);
            }

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

        }


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

        [PermissionOperate(name: AIPermissionPolicy.DmsFile, operate: Operate.Insert)]
        [UnitOfWork]
        public string GetFolderName(string folderLocalName)
        {
            IRepository<DmsFolderEntity> repositoryFolder = repository.GetRepository<IRepository<DmsFolderEntity>>();
            DmsFolderEntity folder = repositoryFolder.DetachedEntities.Where(x => x.FolderLocalName == service.UserId).FirstOrDefault()!;

            if (folder != null) return folder.FolderName;

            DmsFileEntity dmsFile = new DmsFileEntity();
            dmsFile.FilePath = null;
            dmsFile.FileName = folderLocalName;

            return CreateDmsFolder(dmsFile);
        }

        [PermissionOperate(name: AIPermissionPolicy.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(AIPrefixPolicy.DMS_FOLDER, AIPrefixPolicy.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(AIPrefixPolicy.DMS_FOLDER, AIPrefixPolicy.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);

            BookDmsFileEntity upload = new BookDmsFileEntity();
            upload.FileId = entity.FileId;
            upload.FileCategory = typeof(AiBookEntity).Name;
            upload.UploadName = securityGeneratorNumberService.GetNo(AIPrefixPolicy.BOOK_DMS_FILE, AIPrefixPolicy.BOOK_DMS_FILE_BOOK_NAME, "DR", YesNoPolicy.NO, AIPrefixPolicy.BOOK_DMS_FILE_FORMAT);
            upload.OrgFileName = entity.OrgFileName;

            IRepository<BookDmsFileEntity> repositoryUpload = repository.GetRepository<IRepository<BookDmsFileEntity>>();

            repositoryUpload.InsertNow(upload);

            return folder.FolderName;
        }

        [PermissionOperate(name: AIPermissionPolicy.DmsFile, operate: Operate.Update)]
        [UnitOfWork]
        public DmsFileEntity UpdateDmsFolder(DmsFileEntity dmsFile)
        {
            IRepository<BookDmsFileEntity> repositoryUpload = repository.GetRepository<IRepository<BookDmsFileEntity>>();

            BookDmsFileEntity 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 dmsFile;
            dmsFolder.FolderLocalName = upload.OrgFileName;

            repositoryFolder.UpdateNow(dmsFolder);

            return dmsFile;
        }

        [PermissionOperate(name: AIPermissionPolicy.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: AIPermissionPolicy.DmsFile, operate: Operate.Find)]
        public DmsFolderTreeData FindDmsFolderTreeData()
        {
            DmsFolderTreeData data = new DmsFolderTreeData();

            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: AIPermissionPolicy.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: AIPermissionPolicy.DmsFile, operate: Operate.Insert)]
        [UnitOfWork]
        public BookDmsFileViewEntity UploadFile()
        {
            //采用分片上传文件（以及后面分片下载）
            DmsFileEntity dmsFile = null;

            var files = httpContextAccessor.HttpContext.Request.Form.Files;

            var currentDate = DateTime.Now;
            if (files.Any())
            {
                foreach (var file in files)
                {
                    string folderName = null;
                    if (httpContextAccessor.HttpContext.Request.Headers.ContainsKey("FilePath"))
                        folderName = httpContextAccessor.HttpContext.Request.Headers["FilePath"].ToString();
                    dmsFile = PackUploadFile(file, folderName);
                    break;
                }
            }
            else
            {
                return null!;
            }

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

            IRepository<BookDmsFileViewEntity> repositoryUploadDmsFile = service.GetRepository<IRepository<BookDmsFileViewEntity>>();
            return repositoryUploadDmsFile.DetachedEntities.Where(x => x.FileId == dmsFile.FileId).FirstOrDefault()!;
        }

        public DmsFileEntity PackUploadFile(IFormFile file, string folderName)
        {
            var webRootPath = service.Configuration["FileServiceSettings:UploadDmsFileDirectory"];

            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 = $"\\{service.UserId}\\{fileExtension.Replace(".", "")}\\";

            //创建存储文件夹
            if (!Directory.Exists(webRootPath + filePath))
            {
                Directory.CreateDirectory(webRootPath + filePath);
            }

            //判断文件大小
            var fileSize = file.Length;

            if (fileSize > 1024 * 1024 * 100) //100M TODO:(1mb=1024X1024b)
            {
                return null;
            }

            //保存的文件名称
            string fullName = 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;
                //只有單一文件，不需合并，只有超過1個才要合并
                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["FileServiceSettings:BackupDmsFileDirectory"];
                    string backupName = backupRootPath + filePath + dmsFile.FileName;

                    if (!Directory.Exists(backupRootPath + filePath))
                    {
                        Directory.CreateDirectory(backupRootPath + filePath);
                    }

                    if (File.Exists(backupName)) File.Delete(backupName);

                    File.Copy(fullName, backupName, true);

                    //生成缩略图
                    if (FileTypePolicy.GetType(fileExtension.ToLower()) == FileTypePolicy.PHOTO)
                    {
                        RunMyProcess(service.Configuration["CloudBuilder.Topshelf:Path"], PackParameters(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();
                        //FileName上传Uid:xxxx-<1>-1.xxx
                        fileNames.Add(webRootPath + filePath + fns.ToDelimiteredList('-'));
                    }

                    dmsFile.FileName = Path.GetFileName(fullName);// Path.GetFileNameWithoutExtension(fullName) + "_" + file.Name.Replace(" ", "");
                    var backupRootPath = service.Configuration["FileServiceSettings:BackupDmsFileDirectory"];
                    fullName = backupRootPath + filePath + dmsFile.FileName;

                    if (!Directory.Exists(backupRootPath + filePath))
                    {
                        Directory.CreateDirectory(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)
                    {
                        RunMyProcess(service.Configuration["CloudBuilder.Topshelf:Path"], PackParameters(dmsFile));
                    }
                    else if (FileTypePolicy.GetType(fullName.ToLower()) == FileTypePolicy.VIDEO)
                    {
                        foreach (string fileName in fileNames)
                        {
                            if (File.Exists(fileName)) File.Delete(fileName);
                        }
                        string m3u8FilePath = webRootPath + $"\\{service.UserId}\\m3u8\\" + Path.GetFileNameWithoutExtension(dmsFile.OrderKey);
                        if (!Directory.Exists(m3u8FilePath))
                        {
                            Directory.CreateDirectory(m3u8FilePath);
                        }
                        //生成m3u8
                        TsToM3u8(dmsFile.OrderKey, fullName, m3u8FilePath + "\\main.m3u8");
                    }
                }
            }

            return dmsFile;
        }

        public string FindM3u8Path(int 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);
        }

        public string FindSourceVideoPath(int fileId)
        {
            DmsFileEntity entity = repository.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["Ffmpeg:Pictrue"], mp4Url, m3u8Url);
            //RunMyProcess(service.Configuration["Ffmpeg:Path"], para.Replace(".m3u8", ".png"));

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

        /// <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(AIPrefixPolicy.DMS_FOLDER, AIPrefixPolicy.DMS_FOLDER_FOLDER_NAME, null, YesNoPolicy.NO, "00000000");
                    folder.FolderLocalName = service.UserId;
                    repositoryFolder.InsertNow(folder);
                }
                folderNameParent = folder.FolderName;
            }

            BookDmsFileEntity upload = new BookDmsFileEntity();

            upload.FileCategory = typeof(AiBookEntity).Name;
            upload.UploadName = securityGeneratorNumberService.GetNo(AIPrefixPolicy.BOOK_DMS_FILE, AIPrefixPolicy.BOOK_DMS_FILE_BOOK_NAME, "FL", YesNoPolicy.NO, AIPrefixPolicy.BOOK_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<BookDmsFileEntity> repositoryUpload = repository.GetRepository<IRepository<BookDmsFileEntity>>();
            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: AIPermissionPolicy.DmsFile, operate: Operate.Find)]
        public dynamic DownloadFile(int 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<BookDmsFileEntity> repositoryUpload = repository.GetRepository<IRepository<BookDmsFileEntity>>();
            BookDmsFileEntity uploadDmsFile = repositoryUpload.DetachedEntities.Where(x => x.FileId == fileId).FirstOrDefault()!;

            if (uploadDmsFile == 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 = uploadDmsFile.OrgFileName };
        }

        [PermissionOperate(name: AIPermissionPolicy.DmsFile, operate: Operate.Find)]
        public dynamic DownloadFilePreview(DmsFileEntity dmsFile)
        {
            var webRootPath = service.Configuration["FileServiceSettings:ScaleDmsFileDirectory"];

            var fileExtension = Path.GetExtension(dmsFile.OrderKey);//获取文件格式，拓展名

            var filePath = $"\\{dmsFile.CreatedBy}\\{fileExtension.Replace(".", "")}\\";

            string path = 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: AIPermissionPolicy.DmsFile, operate: Operate.Find)]
        public dynamic DownloadFileCombine(string fileName)
        {
            var webRootPath = service.Configuration["FileServiceSettings:UploadDmsFileDirectory"];

            var fileExtension = Path.GetExtension(fileName);//获取文件格式，拓展名

            var filePath = $"\\{service.UserId}\\{fileExtension.Replace(".", "")}\\";

            string path = 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: AIPermissionPolicy.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: AIPermissionPolicy.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;
        }

    }
}