|
|
@@ -7,6 +7,17 @@ using Microsoft.AspNetCore.Mvc;
|
|
|
using ZhonTai.Admin.Core.Consts;
|
|
|
using ZhonTai.Admin.Domain.File.Dto;
|
|
|
using ZhonTai.Admin.Domain.File;
|
|
|
+using Microsoft.AspNetCore.Http;
|
|
|
+using System.IO;
|
|
|
+using System;
|
|
|
+using ZhonTai.Admin.Core.Configs;
|
|
|
+using OnceMi.AspNetCore.OSS;
|
|
|
+using Microsoft.Extensions.Options;
|
|
|
+using System.Linq;
|
|
|
+using ZhonTai.Common.Files;
|
|
|
+using ZhonTai.Common.Helpers;
|
|
|
+using System.ComponentModel.DataAnnotations;
|
|
|
+using System.Collections.Generic;
|
|
|
|
|
|
namespace ZhonTai.Admin.Services.File;
|
|
|
|
|
|
@@ -17,6 +28,9 @@ namespace ZhonTai.Admin.Services.File;
|
|
|
public class FileService : BaseService, IFileService, IDynamicApi
|
|
|
{
|
|
|
private IFileRepository _fileRepository => LazyGetRequiredService<IFileRepository>();
|
|
|
+ private IOSSServiceFactory _oSSServiceFactory => LazyGetRequiredService<IOSSServiceFactory>();
|
|
|
+
|
|
|
+ private OSSConfig _oSSConfig => LazyGetRequiredService<IOptions<OSSConfig>>().Value;
|
|
|
|
|
|
public FileService()
|
|
|
{
|
|
|
@@ -39,7 +53,7 @@ public class FileService : BaseService, IFileService, IDynamicApi
|
|
|
.Count(out var total)
|
|
|
.OrderByDescending(true, c => c.Id)
|
|
|
.Page(input.CurrentPage, input.PageSize)
|
|
|
- .ToListAsync<FileGetPageOutput>();
|
|
|
+ .ToListAsync(a => new FileGetPageOutput { ProviderName = a.Provider.ToString() });
|
|
|
|
|
|
var data = new PageOutput<FileGetPageOutput>()
|
|
|
{
|
|
|
@@ -49,4 +63,102 @@ public class FileService : BaseService, IFileService, IDynamicApi
|
|
|
|
|
|
return data;
|
|
|
}
|
|
|
+
|
|
|
+ /// <summary>
|
|
|
+ /// 上传文件
|
|
|
+ /// </summary>
|
|
|
+ /// <param name="file"></param>
|
|
|
+ /// <param name="fileDirectory"></param>
|
|
|
+ /// <returns></returns>
|
|
|
+ public async Task<FileEntity> UploadFileAsync([Required] IFormFile file, string fileDirectory = "")
|
|
|
+ {
|
|
|
+ var oSSService = _oSSServiceFactory.Create(_oSSConfig.Provider.ToString());
|
|
|
+ var oSSOptions = _oSSConfig.OSSConfigs.Where(a => a.Enable && a.Provider == _oSSConfig.Provider).FirstOrDefault();
|
|
|
+
|
|
|
+ var md5 = string.Empty;
|
|
|
+ if (oSSOptions.Md5)
|
|
|
+ {
|
|
|
+ md5 = MD5Encrypt.GetHash(file.OpenReadStream());
|
|
|
+ var md5FileEntity = await _fileRepository.Where(a => a.Md5 == md5 && a.Provider == oSSOptions.Provider).FirstAsync();
|
|
|
+ if (md5FileEntity != null)
|
|
|
+ {
|
|
|
+ var sameFileEntity = new FileEntity
|
|
|
+ {
|
|
|
+ Provider = oSSOptions.Provider,
|
|
|
+ BucketName = oSSOptions.BucketName,
|
|
|
+ FileGuid = FreeUtil.NewMongodbId(),
|
|
|
+ FileName = Path.GetFileNameWithoutExtension(file.FileName),
|
|
|
+ Extension = Path.GetExtension(file.FileName).ToLower(),
|
|
|
+ FileDirectory = md5FileEntity.FileDirectory,
|
|
|
+ Size = md5FileEntity.Size,
|
|
|
+ SizeFormat = md5FileEntity.SizeFormat,
|
|
|
+ Md5 = md5,
|
|
|
+ LinkUrl = md5FileEntity.LinkUrl
|
|
|
+ };
|
|
|
+ sameFileEntity = await _fileRepository.InsertAsync(sameFileEntity);
|
|
|
+ return sameFileEntity;
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ if (fileDirectory.IsNull())
|
|
|
+ {
|
|
|
+ fileDirectory = DateTime.Now.ToString("yyyy/MM/dd");
|
|
|
+ }
|
|
|
+
|
|
|
+ var fileSize = new FileSize(file.Length);
|
|
|
+ var fileEntity = new FileEntity
|
|
|
+ {
|
|
|
+ Provider = oSSOptions.Provider,
|
|
|
+ BucketName = oSSOptions.BucketName,
|
|
|
+ FileGuid = FreeUtil.NewMongodbId(),
|
|
|
+ FileName = Path.GetFileNameWithoutExtension(file.FileName),
|
|
|
+ Extension = Path.GetExtension(file.FileName).ToLower(),
|
|
|
+ FileDirectory = fileDirectory,
|
|
|
+ Size = fileSize.Size,
|
|
|
+ SizeFormat = fileSize.ToString(),
|
|
|
+ Md5 = md5
|
|
|
+ };
|
|
|
+
|
|
|
+ var filePath = Path.Combine(fileDirectory, fileEntity.FileGuid + fileEntity.Extension).ToPath();
|
|
|
+ var url = oSSOptions.Url;
|
|
|
+ if (url.IsNull())
|
|
|
+ {
|
|
|
+ url = oSSOptions.Provider switch
|
|
|
+ {
|
|
|
+ OSSProvider.Minio => $"{oSSOptions.Endpoint}/{oSSOptions.BucketName}",
|
|
|
+ OSSProvider.Aliyun => $"{oSSOptions.BucketName}.{oSSOptions.Endpoint}",
|
|
|
+ OSSProvider.QCloud => $"{oSSOptions.BucketName}-{oSSOptions.Endpoint}.cos.{oSSOptions.Region}.myqcloud.com",
|
|
|
+ OSSProvider.Qiniu => $"{oSSOptions.BucketName}.{oSSOptions.Region}.qiniucs.com",
|
|
|
+ OSSProvider.HuaweiCloud => $"{oSSOptions.BucketName}.{oSSOptions.Endpoint}",
|
|
|
+ _ => ""
|
|
|
+ };
|
|
|
+ }
|
|
|
+ if (url.IsNull())
|
|
|
+ {
|
|
|
+ throw ResultOutput.Exception($"请配置{oSSOptions.Provider}的Url参数");
|
|
|
+ }
|
|
|
+
|
|
|
+ var urlProtocol = (oSSOptions.IsEnableHttps ? "https" : "http");
|
|
|
+ fileEntity.LinkUrl = $"{urlProtocol}://{url}/{filePath}";
|
|
|
+ await oSSService.PutObjectAsync(oSSOptions.BucketName, filePath, file.OpenReadStream());
|
|
|
+ fileEntity = await _fileRepository.InsertAsync(fileEntity);
|
|
|
+
|
|
|
+ return fileEntity;
|
|
|
+ }
|
|
|
+
|
|
|
+ /// <summary>
|
|
|
+ /// 上传多文件
|
|
|
+ /// </summary>
|
|
|
+ /// <param name="files"></param>
|
|
|
+ /// <param name="fileDirectory"></param>
|
|
|
+ /// <returns></returns>
|
|
|
+ public async Task<List<FileEntity>> UploadFilesAsync([Required] IFormFileCollection files, string fileDirectory = "")
|
|
|
+ {
|
|
|
+ var fileList = new List<FileEntity>();
|
|
|
+ foreach (var file in files)
|
|
|
+ {
|
|
|
+ fileList.Add(await UploadFileAsync(file, fileDirectory));
|
|
|
+ }
|
|
|
+ return fileList;
|
|
|
+ }
|
|
|
}
|
zhontai