using Infrastructure; using Infrastructure.Attribute; using Infrastructure.Enums; using Infrastructure.Extensions; using Infrastructure.Model; using Microsoft.AspNetCore.Hosting; using Microsoft.AspNetCore.Http; using Microsoft.AspNetCore.Mvc; using Microsoft.Extensions.Options; using Newtonsoft.Json; using System; using System.IO; using System.Linq; using System.Threading.Tasks; using ARW.Admin.WebApi.Extensions; using ARW.Admin.WebApi.Filters; using ARW.Common; using ARW.Model.System; using ARW.Service.System.IService; namespace ARW.Admin.WebApi.Controllers { /// /// 公共模块 /// [Route("[controller]/[action]")] public class CommonController : BaseController { private OptionsSetting OptionsSetting; private NLog.Logger logger = NLog.LogManager.GetCurrentClassLogger(); private IWebHostEnvironment WebHostEnvironment; private ISysFileService SysFileService; public CommonController(IOptions options, IWebHostEnvironment webHostEnvironment, ISysFileService fileService) { WebHostEnvironment = webHostEnvironment; SysFileService = fileService; OptionsSetting = options.Value; } /// /// hello /// /// [Route("/")] [HttpGet] public IActionResult Index() { return Content("Hello看到这里页面说明你已经成功启动了本项目,加油吧 少年。"); } /// /// 发送邮件 /// /// 请求参数接收实体 /// [ActionPermissionFilter(Permission = "tool:email:send")] [Log(Title = "发送邮件", IsSaveRequestData = false)] [HttpPost] public IActionResult SendEmail([FromBody] SendEmailDto sendEmailVo) { if (sendEmailVo == null || string.IsNullOrEmpty(sendEmailVo.Subject) || string.IsNullOrEmpty(sendEmailVo.ToUser)) { return ToResponse(ApiResult.Error($"请求参数不完整")); } if (string.IsNullOrEmpty(OptionsSetting.MailOptions.From) || string.IsNullOrEmpty(OptionsSetting.MailOptions.Password)) { return ToResponse(ApiResult.Error($"请配置邮箱信息")); } MailHelper mailHelper = new(); string[] toUsers = sendEmailVo.ToUser.Split(",", StringSplitOptions.RemoveEmptyEntries); if (sendEmailVo.SendMe) { toUsers.Append(mailHelper.FromEmail); } mailHelper.SendMail(toUsers, sendEmailVo.Subject, sendEmailVo.Content, sendEmailVo.FileUrl, sendEmailVo.HtmlContent); logger.Info($"发送邮件{JsonConvert.SerializeObject(sendEmailVo)}"); return SUCCESS(true); } #region 上传 /// /// 存储文件 /// /// /// 存储目录 /// 自定义文件名 /// 上传类型1、保存到本地 2、保存到阿里云 /// [HttpPost()] [Verify] [ActionPermissionFilter(Permission = "common")] public async Task UploadFile([FromForm(Name = "file")] IFormFile formFile, string? fileName = "", string? fileDir = "", StoreType storeType = StoreType.LOCAL) { if (formFile == null) throw new CustomException(ResultCode.PARAM_ERROR, "上传文件不能为空"); SysFile file = new(); string fileExt = Path.GetExtension(formFile.FileName);//文件后缀 // 文件名称(不包括后缀) //fileName = Path.GetFileNameWithoutExtension(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, "上传失败,未经允许上传类型"); } switch (storeType) { case StoreType.LOCAL: string savePath = Path.Combine(WebHostEnvironment.WebRootPath); if (fileDir.IsEmpty()) { fileDir = AppSettings.App(new string[] { "Upload", "localSavePath" }); } file = await SysFileService.SaveFileToLocal(savePath, fileName, "Uploads/" + fileDir, HttpContext.GetName(), formFile); break; case StoreType.REMOTE: break; case StoreType.AARWYUN: if ((fileSize / 1024) > MaxContentLength) { return ToResponse(ResultCode.CUSTOM_ERROR, "上传文件过大,不能超过 " + MaxContentLength + " MB"); } file = new(formFile.FileName, fileName, fileExt, fileSize + "kb", "Uploads/" + fileDir, HttpContext.GetName()) { StoreType = (int)StoreType.AARWYUN, FileType = formFile.ContentType }; file = await SysFileService.SaveFileToAliyun(file, formFile); if (file.Id <= 0) { return ToResponse(ApiResult.Error("阿里云连接失败")); } break; case StoreType.TENCENT: break; case StoreType.QINIU: break; default: break; } return SUCCESS(new { url = file.AccessUrl, fileName = file.FileName, fileId = file.Id.ToString() }); } /// /// 存储文件到阿里云(已弃用) /// /// /// 自定义文件名 /// 上传文件夹路径 /// [HttpPost] [Verify] [ActionPermissionFilter(Permission = "common")] public async Task 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.AARWYUN, 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 } }