using F9WebAiTest.Application.Common; using F9WebAiTest.Application.Common.Exceptions; using F9WebAiTest.Application.CQRS.SYS.WuziMulus.Commands; using F9WebAiTest.Application.CQRS.SYS.WuziMulus.Queries; using MediatR; using Microsoft.AspNetCore.Authorization; using Microsoft.AspNetCore.Mvc; namespace F9WebAiTest.Api.Controllers; /// 物资目录管理(按分组维护物资) [ApiController] [Route("api/sys/wuzimulu")] [Authorize] public class SysWuziMuluController : ControllerBase { private readonly IMediator _mediator; public SysWuziMuluController(IMediator mediator) => _mediator = mediator; /// 按分组分页查询(groupId=0 表示全部分组) [HttpGet] public async Task GetPaged([FromQuery] long groupId = 0, [FromQuery] string keyword = "", [FromQuery] int pageIndex = 1, [FromQuery] int pageSize = 20) => Ok(ApiResult.Ok(await _mediator.Send(new GetWuziMuluPagedQuery(groupId, keyword ?? string.Empty, pageIndex, pageSize)))); /// 物资选项(供其它模块选择物资,如原料庄口选茧别) [HttpGet("options")] public async Task GetOptions([FromQuery] string keyword = "", [FromQuery] int limit = 200) => Ok(ApiResult.Ok(await _mediator.Send(new GetWuziMuluOptionsQuery(keyword ?? string.Empty, limit)))); /// 生成新编号(按所属分组) [HttpGet("new-code")] public async Task GetNewCode([FromQuery] long groupId) => Ok(ApiResult.Ok(await _mediator.Send(new GetWuziMuluNewCodeQuery(groupId)))); [HttpGet("{id}")] public async Task GetById(long id) { var result = await _mediator.Send(new GetWuziMuluByIdQuery(id)); return result == null ? NotFound(ApiResult.Fail("物资不存在", 404)) : Ok(ApiResult.Ok(result)); } [HttpPost] public async Task Create([FromBody] WuziMulu_CreateCommand command) { try { return Ok(ApiResult.Ok(new { id = await _mediator.Send(command) }, "新增成功")); } catch (F9NotFoundException ex) { return NotFound(ApiResult.Fail(ex.Message, 404)); } catch (F9OperationException ex) { return BadRequest(ApiResult.Fail(ex.Message, 400)); } } [HttpPut("{id}")] public async Task Update(long id, [FromBody] WuziMulu_UpdateCommand command) { try { return Ok(ApiResult.Ok(await _mediator.Send(command with { Id = id }), "修改成功")); } catch (F9NotFoundException ex) { return NotFound(ApiResult.Fail(ex.Message, 404)); } catch (F9OperationException ex) { return BadRequest(ApiResult.Fail(ex.Message, 400)); } } [HttpDelete("{id}")] public async Task Delete(long id) { try { return Ok(ApiResult.Ok(await _mediator.Send(new WuziMulu_DelCommand(id)), "删除成功")); } catch (F9NotFoundException ex) { return NotFound(ApiResult.Fail(ex.Message, 404)); } catch (F9OperationException ex) { return BadRequest(ApiResult.Fail(ex.Message, 400)); } } }