// Admin.NET 项目的版æƒã€å•†æ ‡ã€ä¸“利和其他相关æƒåˆ©å‡å—ç›¸åº”æ³•å¾‹æ³•è§„çš„ä¿æŠ¤ã€‚ä½¿ç”¨æœ¬é¡¹ç›®åº”éµå®ˆç›¸å…³æ³•律法规和许å¯è¯çš„è¦æ±‚。 // // 本项目主è¦éµå¾ª MIT 许å¯è¯å’Œ Apache 许å¯è¯ï¼ˆç‰ˆæœ¬ 2.0)进行分å‘和使用。许å¯è¯ä½äºŽæºä»£ç æ ‘æ ¹ç›®å½•ä¸çš„ LICENSE-MIT å’Œ LICENSE-APACHE 文件。 // // ä¸å¾—利用本项目从事å±å®³å›½å®¶å®‰å…¨ã€æ‰°ä¹±ç¤¾ä¼šç§©åºã€ä¾µçŠ¯ä»–äººåˆæ³•æƒç›Šç‰æ³•å¾‹æ³•è§„ç¦æ¢çš„æ´»åЍï¼ä»»ä½•基于本项目二次开å‘è€Œäº§ç”Ÿçš„ä¸€åˆ‡æ³•å¾‹çº çº·å’Œè´£ä»»ï¼Œæˆ‘ä»¬ä¸æ‰¿æ‹…ä»»ä½•è´£ä»»ï¼ using Aliyun.OSS.Util; using OnceMi.AspNetCore.OSS; namespace Admin.NET.Core.Service; /// <summary> /// 系统文件æœåŠ¡ 🧩 /// </summary> [ApiDescriptionSettings(Order = 410)] public class SysFileService : IDynamicApiController, ITransient { private readonly UserManager _userManager; private readonly SqlSugarRepository<SysFile> _sysFileRep; private readonly OSSProviderOptions _OSSProviderOptions; private readonly UploadOptions _uploadOptions; private readonly IOSSService _OSSService; private readonly string _imageType = ".jpeg.jpg.png.bmp.gif.tif"; public SysFileService(UserManager userManager, SqlSugarRepository<SysFile> sysFileRep, IOptions<OSSProviderOptions> oSSProviderOptions, IOptions<UploadOptions> uploadOptions, IOSSServiceFactory ossServiceFactory) { _userManager = userManager; _sysFileRep = sysFileRep; _OSSProviderOptions = oSSProviderOptions.Value; _uploadOptions = uploadOptions.Value; if (_OSSProviderOptions.IsEnable) _OSSService = ossServiceFactory.Create(Enum.GetName(_OSSProviderOptions.Provider)); } /// <summary> /// èŽ·å–æ–‡ä»¶åˆ†é¡µåˆ—表 🔖 /// </summary> /// <param name="input"></param> /// <returns></returns> [DisplayName("èŽ·å–æ–‡ä»¶åˆ†é¡µåˆ—表")] public async Task<SqlSugarPagedList<SysFile>> Page(PageFileInput input) { return await _sysFileRep.AsQueryable() .WhereIF(!string.IsNullOrWhiteSpace(input.FileName), u => u.FileName.Contains(input.FileName.Trim())) .WhereIF(!string.IsNullOrWhiteSpace(input.StartTime.ToString()) && !string.IsNullOrWhiteSpace(input.EndTime.ToString()), u => u.CreateTime >= input.StartTime && u.CreateTime <= input.EndTime) .OrderBy(u => u.CreateTime, OrderByType.Desc) .ToPagedListAsync(input.Page, input.PageSize); } /// <summary> /// ä¸Šä¼ æ–‡ä»¶ 🔖 /// </summary> /// <param name="input"></param> /// <returns></returns> [DisplayName("ä¸Šä¼ æ–‡ä»¶")] public async Task<SysFile> UploadFile([FromForm] FileUploadInput input) { return await HandleUploadFile(input.File, input.Path, fileType: input.FileType); } /// <summary> /// ä¸Šä¼ æ–‡ä»¶Base64 🔖 /// </summary> /// <param name="input"></param> /// <returns></returns> [DisplayName("ä¸Šä¼ æ–‡ä»¶Base64")] public async Task<SysFile> UploadFileFromBase64(UploadFileFromBase64Input input) { byte[] fileData = Convert.FromBase64String(input.FileDataBase64); var ms = new MemoryStream(); ms.Write(fileData); ms.Seek(0, SeekOrigin.Begin); if (string.IsNullOrEmpty(input.FileName)) input.FileName = $"{YitIdHelper.NextId()}.jpg"; if (string.IsNullOrEmpty(input.ContentType)) input.ContentType = "image/jpg"; IFormFile formFile = new FormFile(ms, 0, fileData.Length, "file", input.FileName) { Headers = new HeaderDictionary(), ContentType = input.ContentType }; return await UploadFile(new FileUploadInput { File = formFile, Path = input.Path, FileType = input.FileType }); } /// <summary> /// ä¸Šä¼ å¤šæ–‡ä»¶ 🔖 /// </summary> /// <param name="files"></param> /// <returns></returns> [DisplayName("ä¸Šä¼ å¤šæ–‡ä»¶")] public async Task<List<SysFile>> UploadFiles([Required] List<IFormFile> files) { var filelist = new List<SysFile>(); foreach (var file in files) { filelist.Add(await UploadFile(new FileUploadInput { File = file })); } return filelist; } /// <summary> /// æ ¹æ®æ–‡ä»¶Id或Url下载 🔖 /// </summary> /// <param name="input"></param> /// <returns></returns> [DisplayName("æ ¹æ®æ–‡ä»¶Id或Url下载")] public async Task<IActionResult> DownloadFile(FileInput input) { var file = input.Id > 0 ? await GetFile(input) : await _sysFileRep.CopyNew().GetFirstAsync(u => u.Url == input.Url); var fileName = HttpUtility.UrlEncode(file.FileName, Encoding.GetEncoding("UTF-8")); var filePath = Path.Combine(file.FilePath, file.Id.ToString() + file.Suffix); if (_OSSProviderOptions.IsEnable) { var stream = await (await _OSSService.PresignedGetObjectAsync(file.BucketName.ToString(), filePath, 5)).GetAsStreamAsync(); return new FileStreamResult(stream.Stream, "application/octet-stream") { FileDownloadName = fileName + file.Suffix }; } else if (App.Configuration["SSHProvider:IsEnable"].ToBoolean()) { using (SSHHelper helper = new SSHHelper(App.Configuration["SSHProvider:Host"], App.Configuration["SSHProvider:Port"].ToInt(), App.Configuration["SSHProvider:Username"], App.Configuration["SSHProvider:Password"])) { return new FileStreamResult(helper.OpenRead(filePath), "application/octet-stream") { FileDownloadName = fileName + file.Suffix }; } } else { var path = Path.Combine(App.WebHostEnvironment.WebRootPath, filePath); return new FileStreamResult(new FileStream(path, FileMode.Open), "application/octet-stream") { FileDownloadName = fileName + file.Suffix }; } } /// <summary> /// 文件预览 🔖 /// </summary> /// <param name="Id"></param> /// <returns></returns> [DisplayName("文件预览")] [AllowAnonymous] public async Task<IActionResult> GetPreview([FromRoute] long Id) { var file = await GetFile(new FileInput { Id = Id }); //var fileName = HttpUtility.UrlEncode(file.FileName, Encoding.GetEncoding("UTF-8")); var filePath = Path.Combine(file.FilePath, file.Id.ToString() + file.Suffix); if (_OSSProviderOptions.IsEnable) { var stream = await (await _OSSService.PresignedGetObjectAsync(file.BucketName.ToString(), filePath, 5)).GetAsStreamAsync(); return new FileStreamResult(stream.Stream, "application/octet-stream"); } else if (App.Configuration["SSHProvider:IsEnable"].ToBoolean()) { using (SSHHelper helper = new SSHHelper(App.Configuration["SSHProvider:Host"], App.Configuration["SSHProvider:Port"].ToInt(), App.Configuration["SSHProvider:Username"], App.Configuration["SSHProvider:Password"])) { return new FileStreamResult(helper.OpenRead(filePath), "application/octet-stream"); } } else { var path = Path.Combine(App.WebHostEnvironment.WebRootPath, filePath); return new FileStreamResult(new FileStream(path, FileMode.Open), "application/octet-stream"); } } /// <summary> /// 下载指定文件Base64æ ¼å¼ ðŸ”– /// </summary> /// <param name="url"></param> /// <returns></returns> [AllowAnonymous] [DisplayName("下载指定文件Base64æ ¼å¼")] public async Task<string> DownloadFileBase64([FromBody] string url) { if (_OSSProviderOptions.IsEnable) { using var httpClient = new HttpClient(); HttpResponseMessage response = await httpClient.GetAsync(url); if (response.IsSuccessStatusCode) { // è¯»å–æ–‡ä»¶å†…容并将其转æ¢ä¸º Base64 å—符串 byte[] fileBytes = await response.Content.ReadAsByteArrayAsync(); return Convert.ToBase64String(fileBytes); } else { throw new HttpRequestException($"Request failed with status code: {response.StatusCode}"); } } else if (App.Configuration["SSHProvider:IsEnable"].ToBoolean()) { var sysFile = await _sysFileRep.CopyNew().GetFirstAsync(u => u.Url == url) ?? throw Oops.Oh($"文件ä¸å˜åœ¨"); using (SSHHelper helper = new SSHHelper(App.Configuration["SSHProvider:Host"], App.Configuration["SSHProvider:Port"].ToInt(), App.Configuration["SSHProvider:Username"], App.Configuration["SSHProvider:Password"])) { return Convert.ToBase64String(helper.ReadAllBytes(sysFile.FilePath)); } } else { var sysFile = await _sysFileRep.CopyNew().GetFirstAsync(u => u.Url == url) ?? throw Oops.Oh($"文件ä¸å˜åœ¨"); var filePath = Path.Combine(App.WebHostEnvironment.WebRootPath, sysFile.FilePath); if (!Directory.Exists(filePath)) Directory.CreateDirectory(filePath); var realFile = Path.Combine(filePath, $"{sysFile.Id}{sysFile.Suffix}"); if (!File.Exists(realFile)) { Log.Error($"DownloadFileBase64:文件[{realFile}]ä¸å˜åœ¨"); throw Oops.Oh($"文件[{sysFile.FilePath}]ä¸å˜åœ¨"); } byte[] fileBytes = File.ReadAllBytes(realFile); return Convert.ToBase64String(fileBytes); } } /// <summary> /// åˆ é™¤æ–‡ä»¶ 🔖 /// </summary> /// <param name="input"></param> /// <returns></returns> [ApiDescriptionSettings(Name = "Delete"), HttpPost] [DisplayName("åˆ é™¤æ–‡ä»¶")] public async Task DeleteFile(DeleteFileInput input) { var file = await _sysFileRep.GetFirstAsync(u => u.Id == input.Id); if (file != null) { await _sysFileRep.DeleteAsync(file); if (_OSSProviderOptions.IsEnable) { await _OSSService.RemoveObjectAsync(file.BucketName.ToString(), string.Concat(file.FilePath, "/", $"{input.Id}{file.Suffix}")); } else if (App.Configuration["SSHProvider:IsEnable"].ToBoolean()) { var fullPath = string.Concat(file.FilePath, "/", file.Id + file.Suffix); using (SSHHelper helper = new SSHHelper(App.Configuration["SSHProvider:Host"], App.Configuration["SSHProvider:Port"].ToInt(), App.Configuration["SSHProvider:Username"], App.Configuration["SSHProvider:Password"])) { helper.DeleteFile(fullPath); } } else { var filePath = Path.Combine(App.WebHostEnvironment.WebRootPath, file.FilePath, input.Id.ToString() + file.Suffix); if (File.Exists(filePath)) File.Delete(filePath); } } } /// <summary> /// 更新文件 🔖 /// </summary> /// <param name="input"></param> /// <returns></returns> [ApiDescriptionSettings(Name = "Update"), HttpPost] [DisplayName("更新文件")] public async Task UpdateFile(FileInput input) { var isExist = await _sysFileRep.IsAnyAsync(u => u.Id == input.Id); if (!isExist) throw Oops.Oh(ErrorCodeEnum.D8000); await _sysFileRep.UpdateAsync(u => new SysFile() { FileName = input.FileName, FileType = input.FileType }, u => u.Id == input.Id); } /// <summary> /// èŽ·å–æ–‡ä»¶ 🔖 /// </summary> /// <param name="input"></param> /// <returns></returns> [DisplayName("èŽ·å–æ–‡ä»¶")] public async Task<SysFile> GetFile([FromQuery] FileInput input) { var file = await _sysFileRep.CopyNew().GetFirstAsync(u => u.Id == input.Id); return file ?? throw Oops.Oh(ErrorCodeEnum.D8000); } /// <summary> /// ä¸Šä¼ æ–‡ä»¶ /// </summary> /// <param name="file">文件</param> /// <param name="savePath">路径</param> /// <param name="allowSuffix">å…è®¸æ ¼å¼ï¼š.jpg.png.gif.tif.bmp</param> /// <param name="fileType">类型</param> /// <returns></returns> private async Task<SysFile> HandleUploadFile(IFormFile file, string savePath, string allowSuffix = "", string fileType = "") { if (file == null) throw Oops.Oh(ErrorCodeEnum.D8000); // åˆ¤æ–æ˜¯å¦é‡å¤ä¸Šä¼ 的文件 var sizeKb = (long)(file.Length / 1024.0); // 大å°KB var fileMd5 = string.Empty; if (_uploadOptions.EnableMd5) { using (var fileStream = file.OpenReadStream()) { fileMd5 = OssUtils.ComputeContentMd5(fileStream, fileStream.Length); } /* * Mysql8 ä¸å¦‚果使用了 utf8mb4_general_ci 之外的编ç 会出错,尽é‡é¿å…在æ¡ä»¶é‡Œä½¿ç”¨.ToString() * å› ä¸º Squsugar 并䏿˜¯æŠŠå˜é‡è½¬æ¢ä¸ºå—ç¬¦ä¸²æ¥æž„é€ SQLè¯å¥ï¼Œè€Œæ˜¯æž„é€ äº†CAST(123 AS CHAR)è¿™æ ·çš„è¯å¥ï¼Œè¿™æ ·è¿™ä¸ªè¿”回值是utf8mb4_general_ci,所以容易出错。 */ var sysFile = await _sysFileRep.GetFirstAsync(u => u.FileMd5 == fileMd5 && u.SizeKb == sizeKb); if (sysFile != null) return sysFile; } // éªŒè¯æ–‡ä»¶ç±»åž‹ if (!_uploadOptions.ContentType.Contains(file.ContentType)) throw Oops.Oh($"{ErrorCodeEnum.D8001}:{file.ContentType}"); // éªŒè¯æ–‡ä»¶å¤§å° if (sizeKb > _uploadOptions.MaxSize) throw Oops.Oh($"{ErrorCodeEnum.D8002},å…许最大:{_uploadOptions.MaxSize}KB"); // èŽ·å–æ–‡ä»¶åŽç¼€ var suffix = Path.GetExtension(file.FileName).ToLower(); // åŽç¼€ if (string.IsNullOrWhiteSpace(suffix)) suffix = string.Concat(".", file.ContentType.AsSpan(file.ContentType.LastIndexOf('/') + 1)); if (!string.IsNullOrWhiteSpace(suffix)) { //var contentTypeProvider = FS.GetFileExtensionContentTypeProvider(); //suffix = contentTypeProvider.Mappings.FirstOrDefault(u => u.Value == file.ContentType).Key; // 修改 image/jpeg 类型返回的 .jpegã€jpe åŽç¼€ if (suffix == ".jpeg" || suffix == ".jpe") suffix = ".jpg"; } if (string.IsNullOrWhiteSpace(suffix)) throw Oops.Oh(ErrorCodeEnum.D8003); // 防æ¢å®¢æˆ·ç«¯ä¼ªé€ 文件类型 if (!string.IsNullOrWhiteSpace(allowSuffix) && !allowSuffix.Contains(suffix)) throw Oops.Oh(ErrorCodeEnum.D8003); //if (!VerifyFileExtensionName.IsSameType(file.OpenReadStream(), suffix)) // throw Oops.Oh(ErrorCodeEnum.D8001); var path = string.IsNullOrWhiteSpace(savePath) ? _uploadOptions.Path : savePath; path = path.ParseToDateTimeForRep(); var newFile = new SysFile { Id = YitIdHelper.NextId(), // BucketName = _OSSProviderOptions.IsEnable ? _OSSProviderOptions.Provider.ToString() : "Local", // 阿里云对bucketåç§°æœ‰è¦æ±‚,1.åªèƒ½åŒ…括å°å†™å—æ¯ï¼Œæ•°å—ï¼ŒçŸæ¨ªçº¿ï¼ˆ-)2.必须以å°å†™å—æ¯æˆ–者数å—开头 3.长度必须在3-63å—节之间 // æ— æ³•ä½¿ç”¨Provider BucketName = _OSSProviderOptions.IsEnable ? _OSSProviderOptions.Bucket : "Local", FileName = Path.GetFileNameWithoutExtension(file.FileName), Suffix = suffix, SizeKb = sizeKb, FilePath = path, FileMd5 = fileMd5, FileType = fileType }; var finalName = newFile.Id + suffix; // 文件最终åç§° if (_OSSProviderOptions.IsEnable) { newFile.Provider = Enum.GetName(_OSSProviderOptions.Provider); var filePath = string.Concat(path, "/", finalName); await _OSSService.PutObjectAsync(newFile.BucketName, filePath, file.OpenReadStream()); // http://<ä½ çš„bucketåå—>.oss.aliyuncs.com/<ä½ çš„objectåå—> // 生æˆå¤–é“¾åœ°å€ æ–¹ä¾¿å‰ç«¯é¢„览 switch (_OSSProviderOptions.Provider) { case OSSProvider.Aliyun: newFile.Url = $"{(_OSSProviderOptions.IsEnableHttps ? "https" : "http")}://{newFile.BucketName}.{_OSSProviderOptions.Endpoint}/{filePath}"; break; case OSSProvider.QCloud: newFile.Url = $"{(_OSSProviderOptions.IsEnableHttps ? "https" : "http")}://{newFile.BucketName}-{_OSSProviderOptions.Endpoint}.cos.{_OSSProviderOptions.Region}.myqcloud.com/{filePath}"; break; case OSSProvider.Minio: // 获å–Minioæ–‡ä»¶çš„ä¸‹è½½æˆ–è€…é¢„è§ˆåœ°å€ // newFile.Url = await GetMinioPreviewFileUrl(newFile.BucketName, filePath);// è¿™ç§æ–¹æ³•生æˆçš„Url是有7天有效期的,ä¸èƒ½è¿™æ ·ä½¿ç”¨ // 需è¦åœ¨MinIOä¸çš„Buckets开通对 Anonymous çš„readonlyæƒé™ newFile.Url = $"{(_OSSProviderOptions.IsEnableHttps ? "https" : "http")}://{_OSSProviderOptions.Endpoint}/{newFile.BucketName}/{filePath}"; break; } } else if (App.Configuration["SSHProvider:IsEnable"].ToBoolean()) { var fullPath = string.Concat(path.StartsWith('/') ? path : "/" + path, "/", finalName); using (SSHHelper helper = new SSHHelper(App.Configuration["SSHProvider:Host"], App.Configuration["SSHProvider:Port"].ToInt(), App.Configuration["SSHProvider:Username"], App.Configuration["SSHProvider:Password"])) { helper.UploadFile(file.OpenReadStream(), fullPath); } } else { newFile.Provider = ""; // 本地å˜å‚¨ Provider 显示为空 var filePath = Path.Combine(App.WebHostEnvironment.WebRootPath, path); if (!Directory.Exists(filePath)) Directory.CreateDirectory(filePath); var realFile = Path.Combine(filePath, finalName); using (var stream = File.Create(realFile)) { await file.CopyToAsync(stream); } // 生æˆå¤–链 var host = CommonUtil.GetLocalhost(); if (!host.EndsWith('/')) host += "/"; newFile.Url = $"{host}{newFile.FilePath}/{newFile.Id + newFile.Suffix}"; } await _sysFileRep.AsInsertable(newFile).ExecuteCommandAsync(); return newFile; } /// <summary> /// ä¸Šä¼ å¤´åƒ ðŸ”– /// </summary> /// <param name="file"></param> /// <returns></returns> [DisplayName("ä¸Šä¼ å¤´åƒ")] public async Task<SysFile> UploadAvatar([Required] IFormFile file) { var sysFile = await HandleUploadFile(file, "upload/avatar", _imageType); var sysUserRep = _sysFileRep.ChangeRepository<SqlSugarRepository<SysUser>>(); var user = sysUserRep.GetFirst(u => u.Id == _userManager.UserId); // åˆ é™¤å·²æœ‰å¤´åƒæ–‡ä»¶ if (!string.IsNullOrWhiteSpace(user.Avatar)) { var fileId = Path.GetFileNameWithoutExtension(user.Avatar); await DeleteFile(new DeleteFileInput { Id = long.Parse(fileId) }); } await sysUserRep.UpdateAsync(u => new SysUser() { Avatar = sysFile.Url }, u => u.Id == user.Id); return sysFile; } /// <summary> /// ä¸Šä¼ ç”µåç¾å 🔖 /// </summary> /// <param name="file"></param> /// <returns></returns> [DisplayName("ä¸Šä¼ ç”µåç¾å")] public async Task<SysFile> UploadSignature([Required] IFormFile file) { var sysFile = await HandleUploadFile(file, "upload/signature", _imageType); var sysUserRep = _sysFileRep.ChangeRepository<SqlSugarRepository<SysUser>>(); var user = sysUserRep.GetFirst(u => u.Id == _userManager.UserId); // åˆ é™¤å·²æœ‰ç”µåç¾å文件 if (!string.IsNullOrWhiteSpace(user.Signature) && user.Signature.EndsWith(".png")) { var fileId = Path.GetFileNameWithoutExtension(user.Signature); await DeleteFile(new DeleteFileInput { Id = long.Parse(fileId) }); } await sysUserRep.UpdateAsync(u => new SysUser() { Signature = sysFile.Url }, u => u.Id == user.Id); return sysFile; } /// <summary> /// 修改附件关è”对象 🔖 /// </summary> /// <param name="ids"></param> /// <param name="relationName"></param> /// <param name="relationId"></param> /// <param name="belongId"></param> /// <returns></returns> [NonAction] public async Task<int> UpdateRelation(List<long> ids, string relationName, long relationId, long belongId = 0) { if (ids == null || ids.Count == 0) return 0; return await _sysFileRep.AsUpdateable() .SetColumns(m => m.RelationName == relationName) .SetColumns(m => m.RelationId == relationId) .SetColumns(m => m.BelongId == belongId) .Where(m => ids.Contains(m.Id)) .ExecuteCommandAsync(); } /// <summary> /// æ ¹æ®å…³è”查询附件 /// </summary> /// <param name="input"></param> /// <returns></returns> /// <exception cref="ArgumentNullException"></exception> [DisplayName("æ ¹æ®å…³è”查询附件")] public async Task<List<FileOutput>> GetRelationFiles([FromQuery] RelationQueryInput input) { return await _sysFileRep.AsQueryable() .Where(m => !m.IsDelete) .WhereIF(input.RelationId.HasValue && input.RelationId > 0, m => m.RelationId == input.RelationId) .WhereIF(input.BelongId.HasValue && input.BelongId > 0, m => m.BelongId == input.BelongId.Value) .WhereIF(!string.IsNullOrWhiteSpace(input.RelationName), m => m.RelationName == input.RelationName) .WhereIF(!string.IsNullOrWhiteSpace(input.FileTypes), m => input.GetFileTypeBS().Contains(m.FileType)) .Select(m => new FileOutput { Id = m.Id, FileType = m.FileType, Name = m.FileName, RelationId = m.RelationId, BelongId = m.BelongId, FilePath = m.FilePath, SizeKb = m.SizeKb, Suffix = m.Suffix, RelationName = m.RelationName, Url = SqlFunc.MergeString("/api/sysFile/Preview/", m.Id.ToString()), CreateUserName = m.CreateUserName, CreateTime = m.CreateTime, }) .ToListAsync(); } }