using JNPF.Common.Core.Manager;
using JNPF.Common.Core.Manager.Files;
using JNPF.Common.Enums;
using JNPF.Common.Extension;
using JNPF.Common.Filter;
using JNPF.Common.Manager;
using JNPF.Common.Models;
using JNPF.Common.Options;
using JNPF.Common.Security;
using JNPF.DataEncryption;
using JNPF.DependencyInjection;
using JNPF.DynamicApiController;
using JNPF.Extend.Entitys;
using JNPF.Extend.Entitys.Dto.Document;
using JNPF.FriendlyException;
using JNPF.Systems.Entitys.Permission;
using Mapster;
using Microsoft.AspNetCore.Mvc;
using SqlSugar;
using Yitter.IdGenerator;

namespace JNPF.Extend;

/// <summary>
/// 知识管理
/// 版 本：V3.2
/// 版 权：拓通智联科技有限公司（http://www.tuotong-tech.com）
/// 日 期：2021-06-01 .
/// </summary>
[ApiDescriptionSettings(Tag = "Extend", Name = "Document", Order = 601)]
[Route("api/extend/[controller]")]
public class DocumentService : IDynamicApiController, ITransient
{
    private readonly ISqlSugarRepository<DocumentEntity> _repository;
    private readonly IFileManager _fileManager;
    private readonly ITenant _db;
    private readonly IUserManager _userManager;
    private readonly ICacheManager _cacheManager;

    public DocumentService(ISqlSugarRepository<DocumentEntity> repository, IFileManager fileManager, IUserManager userManager, ICacheManager cacheManager, ISqlSugarClient context)
    {
        _repository = repository;
        _fileManager = fileManager;
        _userManager = userManager;
        _cacheManager = cacheManager;
        _db = context.AsTenant();
    }

    #region Get

    /// <summary>
    /// 列表（文件夹树）.
    /// </summary>
    /// <returns></returns>
    [HttpGet("FolderTree/{id}")]
    public async Task<dynamic> GetFolderTree(string id)
    {
        var data = (await _repository.AsQueryable().Where(x => x.CreatorUserId == _userManager.UserId && x.Type == 0 && x.DeleteMark == 0).ToListAsync()).Adapt<List<DocumentFolderTreeOutput>>();
        data.Add(new DocumentFolderTreeOutput
        {
            id = "0",
            fullName = "全部文档",
            parentId = "-1",
            icon = "fa fa-folder",
        });
        if (!id.Equals("0"))
        {
            data.RemoveAll(x => x.id == id);
        }
        var treeList = data.ToTree("-1");
        return new { list = treeList };
    }

    /// <summary>
    /// 列表（全部文档）.
    /// </summary>
    /// <param name="input">请求参数.</param>
    /// <param name="parentId">文档层级.</param>
    /// <returns></returns>
    [HttpGet("")]
    public async Task<dynamic> GetAllList([FromQuery] KeywordInput input, string parentId)
    {
        var data = (await _repository.AsQueryable().Where(m => m.CreatorUserId == _userManager.UserId && m.ParentId == parentId && m.DeleteMark == 0)
            .WhereIF(input.keyword.IsNotEmptyOrNull(), t => t.FullName.Contains(input.keyword))
            .OrderBy(x => x.SortCode).OrderBy(x => x.CreatorTime, OrderByType.Desc)
            .OrderByIF(!string.IsNullOrEmpty(input.keyword), t => t.LastModifyTime, OrderByType.Desc).ToListAsync()).Adapt<List<DocumentListOutput>>();
        string[]? typeList = new string[] { "doc", "docx", "xls", "xlsx", "ppt", "pptx", "pdf", "jpg", "jpeg", "gif", "png", "bmp" };
        foreach (var item in data)
        {
            string? type = item.fullName.Split('.').LastOrDefault();
            item.isPreview = typeList.Contains(type) ? "1" : null;
        }
        return new { list = data };
    }

    /// <summary>
    /// 列表（我的分享）.
    /// </summary>
    /// <param name="input">请求参数.</param>
    /// <returns></returns>
    [HttpGet("Share")]
    public async Task<dynamic> GetShareOutList([FromQuery] KeywordInput input)
    {
        var data = (await _repository.AsQueryable()
            .Where(m => m.CreatorUserId == _userManager.UserId && m.IsShare > 0 && m.DeleteMark == 0)
            .WhereIF(input.keyword.IsNotEmptyOrNull(), t => t.FullName.Contains(input.keyword))
            .OrderBy(x => x.SortCode).OrderBy(x => x.CreatorTime, OrderByType.Desc)
            .OrderByIF(!string.IsNullOrEmpty(input.keyword), t => t.LastModifyTime, OrderByType.Desc).ToListAsync()).Adapt<List<DocumentShareOutput>>();
        return new { list = data };
    }

    /// <summary>
    /// 列表（共享给我）.
    /// </summary>
    /// <param name="input">请求参数.</param>
    /// <returns></returns>
    [HttpGet("ShareTome")]
    public async Task<dynamic> GetShareTomeList([FromQuery] KeywordInput input)
    {
        var output = await _repository.AsSugarClient().Queryable<DocumentEntity, DocumentShareEntity, UserEntity>((a, b, c) => new JoinQueryInfos(JoinType.Left, a.Id == b.DocumentId, JoinType.Left, a.CreatorUserId == c.Id)).Where((a, b, c) => a.DeleteMark == 0 && b.ShareUserId == _userManager.UserId).WhereIF(input.keyword.IsNotEmptyOrNull(), a => a.FullName.Contains(input.keyword)).Select((a, b, c) => new DocumentShareTomeOutput()
        {
            shareTime = a.ShareTime,
            fileSize = a.FileSize,
            fullName = a.FullName,
            id = a.Id,
            creatorUserId = SqlFunc.MergeString(c.RealName, "/", c.Account),
            fileExtension = a.FileExtension
        }).MergeTable().OrderBy(a => a.shareTime, OrderByType.Desc).ToListAsync();
        return new { list = output };
    }

    /// <summary>
    /// 列表（回收站）.
    /// </summary>
    /// <param name="input">请求参数.</param>
    /// <returns></returns>
    [HttpGet("Trash")]
    public async Task<dynamic> GetTrashList([FromQuery] KeywordInput input)
    {
        var data = (await _repository.AsQueryable()
            .Where(m => m.CreatorUserId == _userManager.UserId && m.DeleteMark == 1)
            .WhereIF(input.keyword.IsNotEmptyOrNull(), t => t.FullName.Contains(input.keyword))
            .OrderBy(x => x.SortCode).OrderBy(x => x.CreatorTime, OrderByType.Desc)
            .OrderByIF(!string.IsNullOrEmpty(input.keyword), t => t.LastModifyTime, OrderByType.Desc).ToListAsync()).Adapt<List<DocumentTrashOutput>>();
        return new { list = data };
    }

    /// <summary>
    /// 列表（共享人员）.
    /// </summary>
    /// <param name="documentId">文档主键.</param>
    /// <returns></returns>
    [HttpGet("ShareUser/{documentId}")]
    public async Task<dynamic> GetShareUserList(string documentId)
    {
        var data = (await _repository.AsSugarClient().Queryable<DocumentShareEntity>().Where(x => x.DocumentId == documentId).OrderBy(x => x.ShareTime, OrderByType.Desc).ToListAsync()).Adapt<List<DocumentShareUserOutput>>();
        return new { list = data };
    }

    /// <summary>
    /// 信息.
    /// </summary>
    /// <param name="id">主键值.</param>
    /// <returns></returns>
    [HttpGet("{id}")]
    public async Task<dynamic> GetInfo(string id)
    {
        var data = (await _repository.GetFirstAsync(x => x.Id == id && x.DeleteMark == 0)).Adapt<DocumentInfoOutput>();
        if (data.type == 1)
        {
            data.fullName = data.fullName.Replace("." + data.fileExtension, string.Empty);
        }
        return data;
    }
    #endregion

    #region Post

    /// <summary>
    /// 新建.
    /// </summary>
    /// <param name="input">实体对象.</param>
    /// <returns></returns>
    [HttpPost("")]
    public async Task Create([FromBody] DocumentCrInput input)
    {
        if (await _repository.IsAnyAsync(x => x.FullName == input.fullName && x.CreatorUserId == _userManager.UserId && x.Type == 0 && x.DeleteMark != 1))
            throw Oops.Oh(ErrorCode.COM1004);
        var entity = input.Adapt<DocumentEntity>();
        entity.DeleteMark = 0;
        var isOk = await _repository.AsSugarClient().Insertable(entity).IgnoreColumns(ignoreNullColumn: true).CallEntityMethod(m => m.Creator()).ExecuteCommandAsync();
        if (isOk < 1)
            throw Oops.Oh(ErrorCode.COM1000);
    }

    /// <summary>
    /// 更新.
    /// </summary>
    /// <param name="id">主键值.</param>
    /// <param name="input">实体对象.</param>
    /// <returns></returns>
    [HttpPut("{id}")]
    public async Task Update(string id, [FromBody] DocumentUpInput input)
    {
        if (await _repository.IsAnyAsync(x => x.Id != id && x.Type == input.type && x.FullName == input.fullName && x.DeleteMark != 1))
            throw Oops.Oh(ErrorCode.COM1004);
        var entity = await _repository.GetFirstAsync(x => x.Id == id);
        entity.FullName = string.Format("{0}.{1}", input.fullName, entity.FileExtension);
        var isOk = await _repository.AsSugarClient().Updateable(entity).IgnoreColumns(ignoreAllNullColumns: true).CallEntityMethod(m => m.LastModify()).ExecuteCommandHasChangeAsync();
        if (!isOk)
            throw Oops.Oh(ErrorCode.COM1001);
    }

    /// <summary>
    /// 删除.
    /// </summary>
    /// <param name="id">主键值.</param>
    /// <returns></returns>
    [HttpDelete("{id}")]
    public async Task Delete(string id)
    {
        if (await _repository.IsAnyAsync(x => x.ParentId == id && x.DeleteMark != 1))
            throw Oops.Oh(ErrorCode.Ex0006);
        var entity = await _repository.GetFirstAsync(x => x.Id == id && x.DeleteMark != 1);
        if (entity == null)
            throw Oops.Oh(ErrorCode.COM1005);
        var isOk = await _repository.AsSugarClient().Updateable(entity).CallEntityMethod(m => m.Delete()).UpdateColumns(it => new { it.DeleteMark, it.DeleteTime, it.DeleteUserId }).ExecuteCommandHasChangeAsync();
        if (!isOk)
            throw Oops.Oh(ErrorCode.COM1002);
    }

    /// <summary>
    /// 上传文件.
    /// </summary>
    /// <returns></returns>
    [HttpPost("Uploader")]
    public async Task Uploader([FromForm] DocumentUploaderInput input)
    {
        #region 上传图片
        if (await _repository.IsAnyAsync(x => x.FullName == input.file.FileName && x.Type == 1 && x.DeleteMark != 1))
            throw Oops.Oh(ErrorCode.D8002);
        var stream = input.file.OpenReadStream();
        var _filePath = _fileManager.GetPathByType("document");
        await _fileManager.UploadFileByType(stream, _filePath, input.file.FileName);
        Thread.Sleep(1000);
        #endregion

        #region 保存数据
        var entity = new DocumentEntity();
        entity.Type = 1;
        entity.FullName = input.file.FileName;
        entity.ParentId = input.parentId;
        entity.FileExtension = Path.GetExtension(input.file.FileName).Replace(".", string.Empty);
        entity.FilePath = Path.Combine(_filePath, input.file.FileName);
        entity.FileSize = input.file.Length.ToString();
        entity.DeleteMark = 0;
        entity.UploaderUrl = string.Format("/api/file/Image/document/{0}", entity.FilePath);
        var isOk = await _repository.AsSugarClient().Insertable(entity).CallEntityMethod(m => m.Creator()).ExecuteCommandAsync();
        if (isOk < 1)
            throw Oops.Oh(ErrorCode.D8001);
        #endregion
    }

    /// <summary>
    /// 分片组装.
    /// </summary>
    /// <param name="input">请求参数.</param>
    [HttpPost("merge")]
    public async Task<dynamic> merge([FromForm] ChunkModel input)
    {
        if (await _repository.IsAnyAsync(x =>x.CreatorUserId==_userManager.UserId && x.FullName == input.fileName && x.Type == 1 && x.DeleteMark != 1))
        {
            //string directoryPath = Path.Combine(App.GetConfig<AppOptions>("JNPF_App", true).SystemPath, "TemporaryFile", input.identifier);
            //FileHelper.DeleteDirectory(directoryPath);
            //throw Oops.Oh(ErrorCode.D8002);
            input.fileName = string.Format("{0}-{1}", DateTime.Now.ParseToUnixTime(), input.fileName);
        }
        input.isUpdateName = false;
        input.type = "document";
        var _filePath = _fileManager.GetPathByType(input.type);
        var output = await _fileManager.Merge(input);
        #region 保存数据
        var entity = new DocumentEntity();
        entity.Type = 1;
        entity.FullName = input.fileName;
        entity.ParentId = input.parentId;
        entity.FileExtension = input.extension;
        entity.FilePath = output.name;
        entity.FileSize = input.fileSize;
        entity.DeleteMark = 0;
        entity.UploaderUrl = string.Format("/api/file/Image/document/{0}", entity.FilePath);
        var isOk = await _repository.AsSugarClient().Insertable(entity).CallEntityMethod(m => m.Creator()).ExecuteCommandAsync();
        if (isOk < 1)
            throw Oops.Oh(ErrorCode.D8001);
        #endregion
        return output;
    }

    /// <summary>
    /// 下载文件.
    /// </summary>
    /// <param name="id">主键值.</param>
    [HttpPost("Download/{id}")]
    public async Task<dynamic> Download(string id)
    {
        var entity = await _repository.GetFirstAsync(x => x.Id == id && x.DeleteMark == 0);
        if (entity == null)
            throw Oops.Oh(ErrorCode.D8000);
        var fileName = _userManager.UserId + "|" + entity.FilePath + "|document";
        _cacheManager.Set(entity.FilePath, string.Empty);
        return new {
            name = entity.FullName,
            url = "/api/File/Download?encryption=" + DESCEncryption.Encrypt(fileName, "JNPF")
        };
    }

    /// <summary>
    /// 回收站（彻底删除）.
    /// </summary>
    /// <param name="id">主键值.</param>
    /// <returns></returns>
    [HttpDelete("Trash/{id}")]
    public async Task TrashDelete(string id)
    {
        var list = await _repository.AsQueryable().Where(m => m.ParentId == id && m.Type == 1 && m.CreatorUserId == _userManager.UserId && m.DeleteMark == 1).ToListAsync();
        foreach (var item in list)
        {
            if (item.Type == 1)
            {
                await _fileManager.DeleteFile(item.FilePath);
            }
            await _repository.AsSugarClient().Deleteable<DocumentEntity>().Where(m => m.Id == item.Id && m.CreatorUserId == _userManager.UserId).ExecuteCommandHasChangeAsync();
        }
        var isOk = await _repository.AsSugarClient().Deleteable<DocumentEntity>().Where(m => m.Id == id && m.CreatorUserId == _userManager.UserId).ExecuteCommandHasChangeAsync();
        if (!isOk)
            throw Oops.Oh(ErrorCode.COM1002);
    }

    /// <summary>
    /// 回收站（还原文件）.
    /// </summary>
    /// <param name="id">主键值.</param>
    /// <returns></returns>
    [HttpPost("Trash/{id}/Actions/Recovery")]
    public async Task TrashRecovery(string id)
    {
        var entity = await _repository.GetFirstAsync(x => x.Id == id);
        if (!await _repository.IsAnyAsync(x => x.Id == entity.ParentId && x.DeleteMark == 0) && entity.ParentId != "0") throw Oops.Oh(ErrorCode.Ex0007);
        entity.DeleteMark = 0;
        entity.DeleteTime = null;
        entity.DeleteUserId = null;
        var isOk = await _repository.AsSugarClient().Updateable(entity).IgnoreColumns(ignoreAllNullColumns: true).CallEntityMethod(m => m.LastModify()).ExecuteCommandHasChangeAsync();
        if (!isOk)
            throw Oops.Oh(ErrorCode.COM1001);
    }

    /// <summary>
    /// 共享文件（创建）.
    /// </summary>
    /// <param name="id">共享文件id.</param>
    /// <param name="input">共享人.</param>
    /// <returns></returns>
    [HttpPost("{id}/Actions/Share")]
    public async Task ShareCreate(string id, [FromBody] DocumentActionsShareInput input)
    {
        try
        {
            var userIds = input.userId.Split(",");
            List<DocumentShareEntity> documentShareEntityList = new List<DocumentShareEntity>();
            foreach (var item in userIds)
            {
                documentShareEntityList.Add(new DocumentShareEntity
                {
                    Id = YitIdHelper.NextId().ToString(),
                    DocumentId = id,
                    ShareUserId = item,
                    ShareTime = DateTime.Now,
                });
            }

            var entity = await _repository.GetFirstAsync(x => x.Id == id && x.DeleteMark == 0);
            entity.IsShare = documentShareEntityList.Count;
            entity.ShareTime = DateTime.Now;
            _db.BeginTran();
            _repository.AsSugarClient().Deleteable<DocumentShareEntity>().Where(x => x.DocumentId == id).ExecuteCommand();
            _repository.AsSugarClient().Insertable(documentShareEntityList).ExecuteCommand();
            var isOk = await _repository.AsSugarClient().Updateable(entity).IgnoreColumns(ignoreAllNullColumns: true).CallEntityMethod(m => m.LastModify()).ExecuteCommandHasChangeAsync();
            if (!isOk)
                throw Oops.Oh(ErrorCode.COM1001);
            _db.CommitTran();
        }
        catch (Exception ex)
        {
            _db.RollbackTran();
        }
    }

    /// <summary>
    /// 共享文件（取消）.
    /// </summary>
    /// <param name="id">主键值.</param>
    /// <returns></returns>
    [HttpDelete("{id}/Actions/Share")]
    public async Task ShareCancel(string id)
    {
        try
        {
            var entity = await _repository.GetFirstAsync(x => x.Id == id && x.DeleteMark == 0);
            entity.IsShare = 0;
            entity.ShareTime = DateTime.Now;
            _db.BeginTran();
            _repository.AsSugarClient().Deleteable<DocumentShareEntity>().Where(x => x.DocumentId == id).ExecuteCommand();
            var isOk = await _repository.AsSugarClient().Updateable(entity).IgnoreColumns(ignoreAllNullColumns: true).CallEntityMethod(m => m.LastModify()).ExecuteCommandHasChangeAsync();
            if (!isOk)
                throw Oops.Oh(ErrorCode.COM1001);
            _db.CommitTran();
        }
        catch (Exception)
        {

            throw;
        }
    }

    /// <summary>
    /// 文件/夹移动到.
    /// </summary>
    /// <param name="id">主键值</param>
    /// <param name="toId">将要移动到Id</param>
    /// <returns></returns>
    [HttpPut("{id}/Actions/MoveTo/{toId}")]
    public async Task MoveTo(string id, string toId)
    {
        var entity = await _repository.GetFirstAsync(x => x.Id == id);
        var entityTo = await _repository.GetFirstAsync(x => x.Id == toId);
        if (id == toId && entity.Type == 0 && entityTo.Type == 0)
            throw Oops.Oh(ErrorCode.Ex0002);
        if (entityTo.IsNotEmptyOrNull() && id == entityTo.ParentId && entity.Type == 0 && entityTo.Type == 0)
            throw Oops.Oh(ErrorCode.Ex0005);
        entity.ParentId = toId;
        var isOk = await _repository.AsSugarClient().Updateable(entity).IgnoreColumns(ignoreAllNullColumns: true).CallEntityMethod(m => m.LastModify()).ExecuteCommandHasChangeAsync();
        if (!isOk)
            throw Oops.Oh(ErrorCode.COM1001);
    }
    #endregion
}