NetActionPropertysController.cs 3.12 KB
using Microsoft.AspNetCore.Mvc;
using Rcs.Application.Common;
using MassTransit.Mediator;
using Rcs.Application.DTOs;
using Rcs.Application.MessageBus.Commands;
using Rcs.Infrastructure.MessageBus.Handlers.Commands;

namespace Rcs.Api.Controllers
{
    /// <summary>
    /// 网络动作属性控制器
    /// @author zzy
    /// </summary>
    [ApiController]
    [Route("api/[controller]")]
    public class NetActionPropertysController : ControllerBase
    {
        private readonly IMediator _mediator;

        public NetActionPropertysController(IMediator mediator)
        {
            _mediator = mediator;
        }

        /// <summary>
        /// 获取网络动作属性列表
        /// @author zzy
        /// </summary>
        [HttpGet("list")]
        public async Task<IActionResult> GetList([FromQuery] GetNetActionPropertysListQuery query, CancellationToken cancellationToken = default)
        {
            var client = _mediator.CreateRequestClient<GetNetActionPropertysListQuery>();
            var response = await client.GetResponse<PagedResponse<NetActionPropertysListItemDto>>(query, cancellationToken);
            return Ok(response.Message);
        }

        /// <summary>
        /// 获取网络动作属性详情
        /// @author zzy
        /// </summary>
        [HttpGet("{id}")]
        public async Task<IActionResult> Get(string id, CancellationToken cancellationToken = default)
        {
            if (!Guid.TryParse(id, out Guid netActionId))
            {
                return BadRequest(ApiResponse.Failed("无效的ID格式"));
            }
            var client = _mediator.CreateRequestClient<GetNetActionPropertysQuery>();
            var response = await client.GetResponse<ApiResponse<NetActionPropertysDto>>(new GetNetActionPropertysQuery
            {
                NetActionId = netActionId
            }, cancellationToken);
            return Ok(response.Message);
        }

        /// <summary>
        /// 创建或更新网络动作属性
        /// @author zzy
        /// </summary>
        [HttpPost]
        public async Task<IActionResult> CreateOrUpdate([FromBody] CreateOrUpdateNetActionPropertysCommand command)
        {
            var client = _mediator.CreateRequestClient<CreateOrUpdateNetActionPropertysCommand>();
            var response = await client.GetResponse<ApiResponse>(command);
            return Ok(response.Message);
        }

        /// <summary>
        /// 删除网络动作属性
        /// @author zzy
        /// </summary>
        [HttpPost("{id}")]
        public async Task<IActionResult> Delete(string id, CancellationToken cancellationToken = default)
        {
            if (!Guid.TryParse(id, out Guid netActionId))
            {
                return BadRequest(ApiResponse.Failed("无效的ID格式"));
            }
            var client = _mediator.CreateRequestClient<DeleteNetActionPropertysCommand>();
            var response = await client.GetResponse<ApiResponse>(new DeleteNetActionPropertysCommand
            {
                NetActionId = netActionId
            }, cancellationToken);
            return Ok(response.Message);
        }
    }
}