using iWare.Wms.Core;
|
using Furion;
|
using Furion.DatabaseAccessor;
|
using Furion.DatabaseAccessor.Extensions;
|
using Furion.DependencyInjection;
|
using Furion.DynamicApiController;
|
using Furion.FriendlyException;
|
using Furion.RemoteRequest.Extensions;
|
using Mapster;
|
using Microsoft.AspNetCore.Authorization;
|
using Microsoft.AspNetCore.Http;
|
using Microsoft.AspNetCore.Mvc;
|
using Microsoft.EntityFrameworkCore;
|
using Microsoft.Extensions.Configuration;
|
using OnceMi.AspNetCore.OSS;
|
using System.Text;
|
using System.Web;
|
|
namespace iWare.Wms.Application
|
{
|
/// <summary>
|
/// 文件服务
|
/// </summary>
|
[ApiDescriptionSettings(Name = "File", Order = 100)]
|
[Route("api")]
|
public class SysFileService : ISysFileService, IDynamicApiController, ITransient
|
{
|
private readonly IRepository<SysFile> _sysFileInfoRep; // 文件信息表仓储
|
|
private readonly IConfiguration _configuration;
|
|
private readonly IOSSServiceFactory _oSSServiceFactory;
|
|
private readonly string bucketName = "bucketName";
|
|
public SysFileService(IRepository<SysFile> sysFileInfoRep,
|
IConfiguration configuration,
|
IOSSServiceFactory oSSServiceFactory)
|
{
|
_sysFileInfoRep = sysFileInfoRep;
|
_configuration = configuration;
|
_oSSServiceFactory = oSSServiceFactory;
|
}
|
|
/// <summary>
|
/// 分页获取文件列表
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpGet("sysFileInfo/page")]
|
public async Task<PageResult<FileOutput>> QueryFileInfoPageList([FromQuery] FilePageInput input)
|
{
|
var fileBucket = !string.IsNullOrEmpty(input.FileBucket?.Trim());
|
var fileOriginName = !string.IsNullOrEmpty(input.FileOriginName?.Trim());
|
var files = await _sysFileInfoRep.DetachedEntities
|
.Where(input.FileLocation > 0, u => u.FileLocation == input.FileLocation)
|
.Where(fileBucket, u => EF.Functions.Like(u.FileBucket, $"%{input.FileBucket.Trim()}%"))
|
.Where(fileOriginName, u => EF.Functions.Like(u.FileOriginName, $"%{input.FileOriginName.Trim()}%"))
|
.ProjectToType<FileOutput>()
|
.ToADPagedListAsync(input.PageNo, input.PageSize);
|
return files;
|
}
|
|
/// <summary>
|
/// 获取文件列表
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpGet("sysFileInfo/list")]
|
public async Task<List<SysFile>> GetFileInfoList([FromQuery] FileOutput input)
|
{
|
return await _sysFileInfoRep.DetachedEntities.ToListAsync();
|
}
|
|
/// <summary>
|
/// 删除文件
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpPost("sysFileInfo/delete")]
|
public async Task DeleteFileInfo(DeleteFileInfoInput input)
|
{
|
var file = await _sysFileInfoRep.FirstOrDefaultAsync(u => u.Id == input.Id);
|
if (file != null)
|
{
|
await file.DeleteAsync();
|
|
switch (file.FileLocation)
|
{
|
case (int)FileLocation.MINIO:
|
await _oSSServiceFactory.Create().RemoveObjectAsync(file.FileBucket, string.Concat(file.FilePath, "/", file.FileObjectName));
|
break;
|
|
case (int)FileLocation.ALIYUN:
|
await _oSSServiceFactory.Create("Aliyun").RemoveObjectAsync(file.FileBucket, string.Concat(file.FilePath, "/", file.FileObjectName));
|
break;
|
|
case (int)FileLocation.TENCENT:
|
await _oSSServiceFactory.Create("QCloud").RemoveObjectAsync(file.FileBucket, string.Concat(file.FilePath, "/", file.FileObjectName));
|
break;
|
|
default:
|
var filePath = Path.Combine(App.WebHostEnvironment.WebRootPath, file.FilePath, file.FileObjectName);
|
if (File.Exists(filePath))
|
File.Delete(filePath);
|
break;
|
}
|
}
|
}
|
|
/// <summary>
|
/// 获取文件详情
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpGet("sysFileInfo/detail")]
|
public async Task<SysFile> GetFileInfo([FromQuery] QueryFileInfoInput input)
|
{
|
var file = await _sysFileInfoRep.FirstOrDefaultAsync(u => u.Id == input.Id);
|
if (file == null)
|
throw Oops.Oh(ErrorCode.D8000);
|
return file;
|
}
|
|
/// <summary>
|
/// 预览文件
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpGet("sysFileInfo/preview")]
|
public async Task<IActionResult> PreviewFileInfo([FromQuery] QueryFileInfoInput input)
|
{
|
return await DownloadFileInfo(input);
|
}
|
|
/// <summary>
|
/// 上传文件
|
/// </summary>
|
/// <param name="file"></param>
|
/// <returns></returns>
|
[HttpPost("sysFileInfo/upload")]
|
public async Task<long> UploadFileDefault(IFormFile file)
|
{
|
//对象存储的key
|
const string key = "UploadFile:Default";
|
// 可以读取系统配置来决定将文件存储到什么地方
|
return await UploadFile(file, key, FileLocation.LOCAL);
|
}
|
|
/// <summary>
|
/// 上传文件(k-form-design)
|
/// </summary>
|
/// <param name="file"></param>
|
/// <param name="key"></param>
|
/// <returns></returns>
|
[HttpPost("sysFileInfo/kformormupload")]
|
[AllowAnonymous]//暂没找到k-form-design组件上传文件如何增加head
|
[NonUnify]//交给k-form-design组件处理数据不需要规范化返回数据
|
public async Task<KFormFileOutput> KFormUploadFileDefault(IFormFile file, string key)
|
{
|
long FileId = 0;
|
|
try
|
{
|
//对象存储的key
|
if (string.IsNullOrEmpty(key))
|
key = "UploadFile:Default";
|
// 可以读取系统配置来决定将文件存储到什么地方
|
FileId = await UploadFile(file, key, FileLocation.LOCAL);
|
}
|
catch
|
{
|
return new KFormFileOutput() { code = 1 };
|
}
|
|
return new KFormFileOutput()
|
{
|
code = 0,
|
Data = new KFormFileIrem()
|
{
|
FileId = FileId,
|
Url = $"/api/sysFileInfo/download?id={FileId}"
|
}
|
};
|
}
|
|
/// <summary>
|
/// 下载文件
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpGet("sysFileInfo/download")]
|
[AllowAnonymous]
|
public async Task<IActionResult> DownloadFileInfo([FromQuery] QueryFileInfoInput input)
|
{
|
var file = await GetFileInfo(input);
|
var fileName = HttpUtility.UrlEncode(file.FileOriginName, Encoding.GetEncoding("UTF-8"));
|
|
switch (file.FileLocation)
|
{
|
case (int)FileLocation.ALIYUN:
|
var filePath = string.Concat(file.FilePath, "/", file.FileObjectName);
|
var stream1 = await (await _oSSServiceFactory.Create("Aliyun").PresignedGetObjectAsync(bucketName, filePath, 5)).GetAsStreamAsync();
|
return new FileStreamResult(stream1, "application/octet-stream") { FileDownloadName = fileName };
|
|
case (int)FileLocation.TENCENT:
|
var filePath1 = string.Concat(file.FilePath, "/", file.FileObjectName);
|
var stream2 = await (await _oSSServiceFactory.Create("QCloud").PresignedGetObjectAsync(bucketName, filePath1, 5)).GetAsStreamAsync();
|
return new FileStreamResult(stream2, "application/octet-stream") { FileDownloadName = fileName };
|
|
case (int)FileLocation.MINIO:
|
var filePath2 = string.Concat(file.FilePath, "/", file.FileObjectName);
|
var stream3 = await (await _oSSServiceFactory.Create().PresignedGetObjectAsync(file.FileBucket, filePath2, 5)).GetAsStreamAsync();
|
return new FileStreamResult(stream3, "application/octet-stream") { FileDownloadName = fileName };
|
|
default:
|
var filePath4 = Path.Combine(file.FilePath, file.FileObjectName);
|
var path = Path.Combine(App.WebHostEnvironment.WebRootPath, filePath4);
|
return new FileStreamResult(new FileStream(path, FileMode.Open), "application/octet-stream") { FileDownloadName = fileName };
|
}
|
}
|
|
/// <summary>
|
/// 上传头像
|
/// </summary>
|
/// <param name="file"></param>
|
/// <returns></returns>
|
[HttpPost("sysFileInfo/uploadAvatar")]
|
public async Task<long> UploadFileAvatar(IFormFile file)
|
{
|
const string key = "UploadFile:Avatar";
|
return await UploadFile(file, key);
|
}
|
|
/// <summary>
|
/// 上传文档
|
/// </summary>
|
/// <param name="file"></param>
|
/// <returns></returns>
|
[HttpPost("sysFileInfo/uploadDocument")]
|
public async Task UploadFileDocument(IFormFile file)
|
{
|
const string key = "UploadFile:Document";
|
await UploadFile(file, key);
|
}
|
|
/// <summary>
|
/// 上传商店图片
|
/// </summary>
|
/// <param name="file"></param>
|
/// <returns></returns>
|
[HttpPost("sysFileInfo/uploadShop")]
|
public async Task UploadFileShop(IFormFile file)
|
{
|
const string key = "UploadFile:Shop";
|
await UploadFile(file, key);
|
}
|
|
/// <summary>
|
/// 上传文件
|
/// </summary>
|
/// <param name="file"></param>
|
/// <param name="key"></param>
|
/// <returns></returns>
|
[NonAction]//用户可以自定义要用的
|
public async Task<long> UploadFile(IFormFile file, string key)
|
{
|
string path = _configuration[$"{key}:path"];
|
var filePath = Path.Combine(App.WebHostEnvironment.WebRootPath, path);
|
if (!Directory.Exists(filePath))
|
Directory.CreateDirectory(filePath);
|
|
var allowContentType = _configuration.GetSection($"{key}:contentType").Get<IEnumerable<string>>();
|
|
if (!allowContentType.Contains(file.ContentType)) throw Oops.Oh(ErrorCode.D8001);
|
|
var allowMaxSize = long.Parse(_configuration[$"{key}:maxSize"]);
|
var fileSizeKb = (long)(file.Length / 1024.0); // 文件大小KB
|
if (fileSizeKb > allowMaxSize) throw Oops.Oh(ErrorCode.D8002);
|
|
var originalFilename = file.FileName; // 文件原始名称
|
var fileSuffix = Path.GetExtension(file.FileName).ToLower(); // 文件后缀
|
|
// 先存库获取Id
|
var newFile = await new SysFile
|
{
|
FileLocation = (int)FileLocation.LOCAL,
|
FileBucket = FileLocation.LOCAL.ToString(),
|
//FileObjectName = finalName,
|
FileOriginName = originalFilename,
|
FileSuffix = fileSuffix.TrimStart('.'),
|
FileSizeKb = fileSizeKb.ToString(),
|
FilePath = path
|
}.InsertNowAsync();
|
|
var finalName = newFile.Entity.Id + fileSuffix; // 生成文件的最终名称
|
using (var stream = File.Create(Path.Combine(filePath, finalName)))
|
{
|
await file.CopyToAsync(stream);
|
}
|
|
newFile.Entity.FileObjectName = finalName;
|
return newFile.Entity.Id; // 返回文件唯一标识
|
}
|
|
/// <summary>
|
/// 上传文件
|
/// </summary>
|
/// <param name="file">文件</param>
|
/// <param name="key">对象存储键</param>
|
/// <param name="fileLocation">文件存储位置</param>
|
/// <returns></returns>
|
private async Task<long> UploadFile(IFormFile file, string key, FileLocation fileLocation)
|
{
|
string path = _configuration[$"{key}:path"];
|
|
var allowContentType = _configuration.GetSection($"{key}:contentType").Get<IEnumerable<string>>();
|
if (!allowContentType.Contains(file.ContentType)) throw Oops.Oh(ErrorCode.D8001);
|
|
var allowMaxSize = long.Parse(_configuration[$"{key}:maxSize"]);
|
var fileSizeKb = (long)(file.Length / 1024.0); // 文件大小KB
|
if (fileSizeKb > allowMaxSize) throw Oops.Oh(ErrorCode.D8002);
|
|
var originalFilename = file.FileName; // 文件原始名称
|
var fileSuffix = Path.GetExtension(file.FileName).ToLower(); // 文件后缀
|
|
// 先存库获取Id
|
var newFile = await new SysFile
|
{
|
FileLocation = (int)fileLocation,
|
FileBucket = bucketName,
|
//FileObjectName = finalName,
|
FileOriginName = originalFilename,
|
FileSuffix = fileSuffix.TrimStart('.'),
|
FileSizeKb = fileSizeKb.ToString(),
|
FilePath = path
|
}.InsertNowAsync();
|
|
var finalName = newFile.Entity.Id + fileSuffix; // 生成文件的最终名称
|
newFile.Entity.FileObjectName = finalName;
|
switch (fileLocation)
|
{
|
case FileLocation.ALIYUN:
|
var filePath = string.Concat(path, "/", finalName);
|
var stream = file.OpenReadStream();
|
await _oSSServiceFactory.Create("aliyun").PutObjectAsync(bucketName, filePath, stream);
|
break;
|
|
case FileLocation.TENCENT:
|
var filePath1 = string.Concat(path, "/", finalName);
|
var stream1 = file.OpenReadStream();
|
await _oSSServiceFactory.Create("qcloud").PutObjectAsync(bucketName, filePath1, stream1);
|
break;
|
|
case FileLocation.MINIO:
|
var filePath2 = string.Concat(path, "/", finalName);
|
var stream2 = file.OpenReadStream();
|
await _oSSServiceFactory.Create().PutObjectAsync(bucketName, filePath2, stream2);
|
break;
|
|
default:
|
var filePath4 = Path.Combine(App.WebHostEnvironment.WebRootPath, path);
|
if (!Directory.Exists(filePath4))
|
Directory.CreateDirectory(filePath4);
|
using (var stream4 = File.Create(Path.Combine(filePath4, finalName)))
|
{
|
await file.CopyToAsync(stream4);
|
}
|
break;
|
}
|
return newFile.Entity.Id; // 返回文件唯一标识
|
}
|
}
|
}
|
