优化文件存储

This commit is contained in:
不做码农 2022-07-12 21:12:52 +08:00
parent 262e593ff6
commit 855a7f64e0
3 changed files with 57 additions and 61 deletions

View File

@ -12,7 +12,7 @@ namespace Infrastructure
public bool DemoMode { get; set; } public bool DemoMode { get; set; }
public MailOptions MailOptions { get; set; } public MailOptions MailOptions { get; set; }
public Upload Upload { get; set; } public Upload Upload { get; set; }
public ALYUN_OCS ALYUN_OCS { get; set; } public ALIYUN_OSS ALIYUN_OSS { get; set; }
public JwtSettings JwtSettings { get; set; } public JwtSettings JwtSettings { get; set; }
} }
/// <summary> /// <summary>
@ -33,15 +33,20 @@ namespace Infrastructure
{ {
public string UploadUrl { get; set; } public string UploadUrl { get; set; }
public string LocalSavePath { get; set; } public string LocalSavePath { get; set; }
public int MaxSize { get; set; }
public string[] NotAllowedExt { get; set; } = new string[0];
} }
/// <summary> /// <summary>
/// 阿里云存储 /// 阿里云存储
/// </summary> /// </summary>
public class ALYUN_OCS public class ALIYUN_OSS
{ {
public string REGIONID { get; set; } public string REGIONID { get; set; }
public string KEY { get; set; } public string KEY { get; set; }
public string SECRET { get; set; } public string SECRET { get; set; }
public string BucketName { get; set; }
public string DomainUrl { get; set; }
public int MaxSize { get; set; } = 100;
} }
/// <summary> /// <summary>

View File

@ -16,6 +16,7 @@ using ZR.Admin.WebApi.Extensions;
using ZR.Admin.WebApi.Filters; using ZR.Admin.WebApi.Filters;
using ZR.Common; using ZR.Common;
using ZR.Model.System; using ZR.Model.System;
using ZR.Model.System.Dto;
using ZR.Service.System.IService; using ZR.Service.System.IService;
namespace ZR.Admin.WebApi.Controllers namespace ZR.Admin.WebApi.Controllers
@ -88,44 +89,55 @@ namespace ZR.Admin.WebApi.Controllers
/// <summary> /// <summary>
/// 存储文件 /// 存储文件
/// </summary> /// </summary>
/// <param name="formFile"></param> /// <param name="uploadDto">自定义文件名</param>
/// <param name="fileDir">存储目录</param>
/// <param name="fileName">自定义文件名</param>
/// <param name="storeType">上传类型1、保存到本地 2、保存到阿里云</param> /// <param name="storeType">上传类型1、保存到本地 2、保存到阿里云</param>
/// <returns></returns> /// <returns></returns>
[HttpPost()] [HttpPost()]
[Verify] [Verify]
[ActionPermissionFilter(Permission = "common")] [ActionPermissionFilter(Permission = "common")]
public async Task<IActionResult> UploadFile([FromForm(Name = "file")] IFormFile formFile, string? fileName = "", string? fileDir = "", StoreType storeType = StoreType.LOCAL) public async Task<IActionResult> UploadFile([FromForm] UploadDto uploadDto, StoreType storeType = StoreType.LOCAL)
{ {
IFormFile formFile = uploadDto.File;
if (formFile == null) throw new CustomException(ResultCode.PARAM_ERROR, "上传文件不能为空"); if (formFile == null) throw new CustomException(ResultCode.PARAM_ERROR, "上传文件不能为空");
SysFile file = new(); SysFile file = new();
string fileExt = Path.GetExtension(formFile.FileName);//文件后缀 string fileExt = Path.GetExtension(formFile.FileName);//文件后缀
double fileSize = Math.Round(formFile.Length / 1024.0, 2);//文件大小KB double fileSize = Math.Round(formFile.Length / 1024.0, 2);//文件大小KB
string[] NotAllowedFileExtensions = new string[] { ".bat", ".exe", ".jar", ".js" };
int MaxContentLength = 15; if (OptionsSetting.Upload.NotAllowedExt.Contains(fileExt))
if (NotAllowedFileExtensions.Contains(fileExt))
{ {
return ToResponse(ResultCode.CUSTOM_ERROR, "上传失败,未经允许上传类型"); return ToResponse(ResultCode.CUSTOM_ERROR, "上传失败,未经允许上传类型");
} }
if (uploadDto.FileNameType == 1)
{
uploadDto.FileName = Path.GetFileNameWithoutExtension(formFile.FileName);
}
else if (uploadDto.FileNameType == 3)
{
uploadDto.FileName = SysFileService.HashFileName();
}
switch (storeType) switch (storeType)
{ {
case StoreType.LOCAL: case StoreType.LOCAL:
string savePath = Path.Combine(WebHostEnvironment.WebRootPath); string savePath = Path.Combine(WebHostEnvironment.WebRootPath);
if (fileDir.IsEmpty()) if (uploadDto.FileDir.IsEmpty())
{ {
fileDir = AppSettings.App(new string[] { "Upload", "localSavePath" }); uploadDto.FileDir = OptionsSetting.Upload.LocalSavePath;
} }
file = await SysFileService.SaveFileToLocal(savePath, fileName, fileDir, HttpContext.GetName(), formFile); file = await SysFileService.SaveFileToLocal(savePath, uploadDto.FileName, uploadDto.FileDir, HttpContext.GetName(), formFile);
break; break;
case StoreType.REMOTE: case StoreType.REMOTE:
break; break;
case StoreType.ALIYUN: case StoreType.ALIYUN:
if ((fileSize / 1024) > MaxContentLength) int AlimaxContentLength = OptionsSetting.ALIYUN_OSS.MaxSize;
if (OptionsSetting.ALIYUN_OSS.REGIONID.IsEmpty())
{ {
return ToResponse(ResultCode.CUSTOM_ERROR, "上传文件过大,不能超过 " + MaxContentLength + " MB"); return ToResponse(ResultCode.CUSTOM_ERROR, "配置文件缺失");
} }
file = new(formFile.FileName, fileName, fileExt, fileSize + "kb", fileDir, HttpContext.GetName()) if ((fileSize / 1024) > AlimaxContentLength)
{
return ToResponse(ResultCode.CUSTOM_ERROR, "上传文件过大,不能超过 " + AlimaxContentLength + " MB");
}
file = new(formFile.FileName, uploadDto.FileName, fileExt, fileSize + "kb", uploadDto.FileDir, HttpContext.GetName())
{ {
StoreType = (int)StoreType.ALIYUN, StoreType = (int)StoreType.ALIYUN,
FileType = formFile.ContentType FileType = formFile.ContentType
@ -149,47 +161,23 @@ namespace ZR.Admin.WebApi.Controllers
}); });
} }
/// <summary>
/// 存储文件到阿里云(已弃用)
/// </summary>
/// <param name="formFile"></param>
/// <param name="fileName">自定义文件名</param>
/// <param name="fileDir">上传文件夹路径</param>
/// <returns></returns>
[HttpPost]
[Verify]
[ActionPermissionFilter(Permission = "common")]
public async Task<IActionResult> UploadFileAliyun([FromForm(Name = "file")] IFormFile formFile, string fileName = "", string fileDir = "")
{
if (formFile == null) throw new CustomException(ResultCode.PARAM_ERROR, "上传文件不能为空");
string fileExt = Path.GetExtension(formFile.FileName);//文件后缀
double fileSize = Math.Round(formFile.Length / 1024.0, 2);//文件大小KB
string[] NotAllowedFileExtensions = new string[] { ".bat", ".exe", ".jar", ".js" };
int MaxContentLength = 15;
if (NotAllowedFileExtensions.Contains(fileExt))
{
return ToResponse(ResultCode.CUSTOM_ERROR, "上传失败,未经允许上传类型");
}
if ((fileSize / 1024) > MaxContentLength)
{
return ToResponse(ResultCode.CUSTOM_ERROR, "上传文件过大,不能超过 " + MaxContentLength + " MB");
}
SysFile file = new(formFile.FileName, fileName, fileExt, fileSize + "kb", fileDir, HttpContext.GetName())
{
StoreType = (int)StoreType.ALIYUN,
FileType = formFile.ContentType
};
file = await SysFileService.SaveFileToAliyun(file, formFile);
if (file.Id <= 0) { return ToResponse(ApiResult.Error("阿里云连接失败")); }
return SUCCESS(new
{
url = file.AccessUrl,
fileName = file.FileName,
fileId = file.Id.ToString()
});
}
#endregion #endregion
} }
public class UploadDto
{
/// <summary>
/// 自定文件名
/// </summary>
public string? FileName { get; set; }
/// <summary>
/// 存储目录
/// </summary>
public string? FileDir { get; set; }
/// <summary>
/// 文件名生成类型 1 原文件名 2 自定义 3 自动生成
/// </summary>
public int FileNameType { get; set; }
public IFormFile File { get; set; }
}
} }

View File

@ -21,16 +21,19 @@
"InitDb": false,//db "InitDb": false,//db
"DemoMode": false, // "DemoMode": false, //
"Upload": { "Upload": {
"UploadUrl": "http://localhost:8888", //访 "uploadUrl": "http://localhost:8888", //访
"localSavePath": "uploads" // wwwroot/uploads "localSavePath": "uploads", // wwwroot/uploads
"maxSize": 15, // 15M
"notAllowedExt": [ ".bat", ".exe", ".jar", ".js"]
}, },
// //
"ALIYUN_OSS": { "ALIYUN_OSS": {
"REGIONID": "cn-hangzhou", "REGIONID": "", //egcn-hangzhou
"KEY": "XX", "KEY": "XX",
"SECRET": "XX", "SECRET": "XX",
"bucketName": "bucketName", "bucketName": "bucketName",
"domainUrl": "http://xxx.xxx.com" //访 "domainUrl": "http://xxx.xxx.com", //访
"maxSize": 100 // 100M
}, },
// //
"WxCorp": { "WxCorp": {
@ -70,7 +73,7 @@
"RealIpHeader": "X-Real-IP", "RealIpHeader": "X-Real-IP",
"ClientIdHeader": "X-ClientId", "ClientIdHeader": "X-ClientId",
"HttpStatusCode": 429, "HttpStatusCode": 429,
"EndpointWhitelist": [ "post:/system/dict/data/types", "*:/msghub/negotiate", "*:/LogOut" ], "EndpointWhitelist": [ "post:/system/dict/data/types", "*:/msghub/negotiate", "*:/LogOut", "*:/common/uploadfile" ],
"QuotaExceededResponse": { "QuotaExceededResponse": {
"Content": "{{\"code\":429,\"msg\":\"访问过于频繁,请稍后重试\"}}", "Content": "{{\"code\":429,\"msg\":\"访问过于频繁,请稍后重试\"}}",
"ContentType": "application/json", "ContentType": "application/json",