446 lines
18 KiB
C#
446 lines
18 KiB
C#
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
|
||
} |