namespace Yw.Application { /// /// AttachFile /// [Route("DOCS/Attach/File")] [ApiDescriptionSettings("DOCS", Name = "附加文件", Order = 90000)] public class SysAttachFile_Controller : IDynamicApiController { /// /// /// public SysAttachFile_Controller(IHttpContextAccessor httpContextAccessor) { _httpContextAccessor = httpContextAccessor; } private readonly IHttpContextAccessor _httpContextAccessor; private readonly Service.SysAttachFile _service = new(); #region Query /// /// 获取所有 /// [Route("GetAll@V1.0")] [HttpGet] public List GetAll() { var list = _service.GetAll(); var vmList = list?.Select(x => new SysAttachFileDto(x)).ToList(); return vmList; } /// /// 通过 ID 获取 /// [Route("GetByID@V1.0")] [HttpGet] public SysAttachFileDto GetByID([FromQuery][Required] IDInput input) { var model = _service.GetByID(input.ID); return model == null ? null : new SysAttachFileDto(model); } /// /// 通过 Ids 获取 /// [Route("GetByIds@V1.0")] [HttpGet] public List GetByIds([FromQuery][Required] IdsInput input) { var ids = LongListHelper.ToList(input.Ids); var list = _service.GetByIds(ids); var vmList = list?.Select(x => new SysAttachFileDto(x)).ToList(); return vmList; } /// /// 通过 AttachType 和 AttachID 获取 /// [Route("GetByAttachTypeAndAttachID@V1.0")] [HttpGet] public List GetByAttachTypeAndAttachID([FromQuery][Required] AttachInput input) { var list = _service.GetByAttachTypeAndAttachID(input.AttachType, input.AttachID); var vmList = list?.Select(x => new SysAttachFileDto(x)).ToList(); return vmList; } #endregion #region Insert /// /// 插入一条 (同时上传文件) /// [Route("Insert@V1.0")] [HttpPost] public long Insert([Required] AddSysAttachFileInput input) { var request = _httpContextAccessor.HttpContext.Request; if (request.Form.Files == null || request.Form.Files.Count != 1) { throw YOops.Oh(eResultCode.Alert, InternalErrorCodes.V001, "文件验证错误"); } var uploadFile = request.Form.Files[0]; var model = input.Adapt(); if (string.IsNullOrEmpty(model.FileName)) { model.FileName = uploadFile.FileName; } model.FileSuffix = Path.GetExtension(uploadFile.FileName); model.StorageHouse = ConfigHelper.DataFolder; model.StorageCode = Yw.Service.FileHelper.UploadSubFile(ConfigHelper.DataFolder, uploadFile.OpenReadStream(), Path.GetExtension(uploadFile.FileName)); model.SortCode = _service.GetMaxSortCode(input.AttachType, input.AttachID) + 1; var filePath = Yw.Service.FileHelper.GetFilePath(model.StorageHouse, model.StorageCode); var fileInfo = new FileInfo(filePath); model.FileSize = fileInfo.Length; var id = _service.Insert(model); if (id < 1) { Yw.Service.FileHelper.Delete(model.StorageHouse, model.StorageCode); } return id; } #endregion #region Update /// /// 更新一条 /// [Route("Update@V1.0")] [HttpPut] public bool Update([Required] UpdateSysAttachFileInput input) { var model = _service.GetByID(input.ID); if (model == null) { throw YOops.Oh(eResultCode.Alert, InternalErrorCodes.D001, $"ID:{input.ID} 数据不存在"); } var rhs = new Model.SysAttachFile(model); input.Adapt(rhs); var bol = _service.Update(rhs); return bol; } /// /// 更新排序码 /// [Route("UpdateSortCode@V1.0")] [HttpPut] public bool UpdateSortCode([Required] UpdateSortCodeInput input) { var bol = _service.UpdateSortCode(input.ID, input.SortCode); return bol; } /// /// 更新排序 /// [Route("UpdateSorter@V1.0")] [HttpPut] public bool UpdateSorter([Required] List inputList) { var list = inputList.Select(x => x.Adapt()).ToList(); var bol = _service.UpdateSorter(list); return bol; } /// /// 更新 Flags /// [Route("UpdateFlags@V1.0")] [HttpPut] public bool UpdateFlags([Required] UpdateFlagsInput input) { var bol = _service.UpdateFlags(input.ID, input.Flags); return bol; } #endregion #region Exist /// /// 通过 AttachType 和 AttachID 判断是否存在 /// [Route("IsExistByAttachTypeAndAttachID@V1.0")] [HttpGet] public bool IsExistByAttachTypeAndAttachID([FromQuery][Required] AttachInput input) { var bol = _service.IsExistByAttachTypeAndAttachID(input.AttachType, input.AttachID); return bol; } #endregion #region Delete /// /// 通过 ID 删除 /// [Route("DeleteByID@V1.0")] [HttpDelete] public bool DeleteByID([FromQuery][Required] IDInput input) { var model = _service.GetByID(input.ID); if (model == null) { throw YOops.Oh(eResultCode.Alert, InternalErrorCodes.D001, "数据不存在"); } var bol = _service.DeleteByID(input.ID, out string msg); if (bol) { Service.FileHelper.Delete(model.StorageHouse, model.StorageCode); return bol; } throw YOops.Oh(eResultCode.Alert, InternalErrorCodes.D999, msg); } #endregion } }