using F9WebAiTest.Application.Common;
using F9WebAiTest.Application.Common.Exceptions;
using F9WebAiTest.Application.CQRS.SYS.Employees.Commands;
using F9WebAiTest.Application.CQRS.SYS.Employees.Queries;
using F9WebAiTest.Domain.Enums.SYS.Employees;
using MediatR;
using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Mvc;

namespace F9WebAiTest.Api.Controllers;

/// <summary>职工档案管理（含转正/离职/调岗/重新入职/生产信息维护）</summary>
[ApiController]
[Route("api/sys/employee")]
[Authorize]
public class SysEmployeeController : ControllerBase
{
    private readonly IMediator _mediator;
    public SysEmployeeController(IMediator mediator) => _mediator = mediator;

    /// <summary>分页查询（部门含子部门；workStatus/banci 不传表示全部）</summary>
    [HttpGet]
    public async Task<IActionResult> GetPaged([FromQuery] long depId = 0, [FromQuery] long worktypeId = 0,
        [FromQuery] Employee_WorkStatus_Enum? workStatus = null, [FromQuery] Prod_Banci_Enum? banci = null,
        [FromQuery] string like = "", [FromQuery] int pageIndex = 1, [FromQuery] int pageSize = 20)
        => Ok(ApiResult<object>.Ok(await _mediator.Send(new GetEmployeePagedQuery(depId, worktypeId, workStatus,
            banci, like ?? string.Empty, pageIndex, pageSize))));

    [HttpGet("{id}")]
    public async Task<IActionResult> GetById(long id)
    {
        var result = await _mediator.Send(new GetEmployeeByIdQuery(id));
        return result == null
            ? NotFound(ApiResult<object>.Fail("职工不存在", 404))
            : Ok(ApiResult<object>.Ok(result));
    }

    /// <summary>变更记录</summary>
    [HttpGet("{id}/change-records")]
    public async Task<IActionResult> GetChangeRecords(long id)
        => Ok(ApiResult<object>.Ok(await _mediator.Send(new GetEmployeeChangeRecordsQuery(id))));

    /// <summary>调岗记录</summary>
    [HttpGet("{id}/tiaogang-records")]
    public async Task<IActionResult> GetTiaogangRecords(long id)
        => Ok(ApiResult<object>.Ok(await _mediator.Send(new GetEmployeeTiaogangRecordsQuery(id))));

    [HttpPost]
    public async Task<IActionResult> Create([FromBody] Employee_CreateCommand command)
    {
        try { return Ok(ApiResult<object>.Ok(new { id = await _mediator.Send(command) }, "新增成功")); }
        catch (F9NotFoundException ex) { return NotFound(ApiResult<object>.Fail(ex.Message, 404)); }
        catch (F9OperationException ex) { return BadRequest(ApiResult<object>.Fail(ex.Message, 400)); }
    }

    [HttpPut("{id}")]
    public async Task<IActionResult> Update(long id, [FromBody] Employee_UpdateCommand command)
    {
        try { return Ok(ApiResult<object>.Ok(await _mediator.Send(command with { Id = id }), "修改成功")); }
        catch (F9NotFoundException ex) { return NotFound(ApiResult<object>.Fail(ex.Message, 404)); }
        catch (F9OperationException ex) { return BadRequest(ApiResult<object>.Fail(ex.Message, 400)); }
    }

    [HttpDelete("{id}")]
    public async Task<IActionResult> Delete(long id)
    {
        try { return Ok(ApiResult<object>.Ok(await _mediator.Send(new Employee_DelCommand(id)), "删除成功")); }
        catch (F9NotFoundException ex) { return NotFound(ApiResult<object>.Fail(ex.Message, 404)); }
        catch (F9OperationException ex) { return BadRequest(ApiResult<object>.Fail(ex.Message, 400)); }
    }

    /// <summary>转正</summary>
    [HttpPut("{id}/zhuanzheng")]
    public async Task<IActionResult> Zhuanzheng(long id, [FromBody] Employee_ZhuanzhengCommand command)
    {
        try { return Ok(ApiResult<object>.Ok(await _mediator.Send(command with { Id = id }), "转正成功")); }
        catch (F9NotFoundException ex) { return NotFound(ApiResult<object>.Fail(ex.Message, 404)); }
        catch (F9OperationException ex) { return BadRequest(ApiResult<object>.Fail(ex.Message, 400)); }
    }

    /// <summary>取消转正</summary>
    [HttpPut("{id}/zhuanzheng-cancel")]
    public async Task<IActionResult> ZhuanzhengCancel(long id)
    {
        try { return Ok(ApiResult<object>.Ok(await _mediator.Send(new Employee_ZhuanzhengCancelCommand(id)), "已取消转正")); }
        catch (F9NotFoundException ex) { return NotFound(ApiResult<object>.Fail(ex.Message, 404)); }
        catch (F9OperationException ex) { return BadRequest(ApiResult<object>.Fail(ex.Message, 400)); }
    }

    /// <summary>离职</summary>
    [HttpPut("{id}/lizhi")]
    public async Task<IActionResult> Lizhi(long id, [FromBody] Employee_LizhiCommand command)
    {
        try { return Ok(ApiResult<object>.Ok(await _mediator.Send(command with { Id = id }), "已办理离职")); }
        catch (F9NotFoundException ex) { return NotFound(ApiResult<object>.Fail(ex.Message, 404)); }
        catch (F9OperationException ex) { return BadRequest(ApiResult<object>.Fail(ex.Message, 400)); }
    }

    /// <summary>取消离职</summary>
    [HttpPut("{id}/lizhi-cancel")]
    public async Task<IActionResult> LizhiCancel(long id)
    {
        try { return Ok(ApiResult<object>.Ok(await _mediator.Send(new Employee_LizhiCancelCommand(id)), "已取消离职")); }
        catch (F9NotFoundException ex) { return NotFound(ApiResult<object>.Fail(ex.Message, 404)); }
        catch (F9OperationException ex) { return BadRequest(ApiResult<object>.Fail(ex.Message, 400)); }
    }

    /// <summary>调岗</summary>
    [HttpPut("{id}/tiaogang")]
    public async Task<IActionResult> Tiaogang(long id, [FromBody] Employee_TiaogangCommand command)
    {
        try { return Ok(ApiResult<object>.Ok(await _mediator.Send(command with { Id = id }), "调岗成功")); }
        catch (F9NotFoundException ex) { return NotFound(ApiResult<object>.Fail(ex.Message, 404)); }
        catch (F9OperationException ex) { return BadRequest(ApiResult<object>.Fail(ex.Message, 400)); }
    }

    /// <summary>重新入职</summary>
    [HttpPut("{id}/renew-ruzhis")]
    public async Task<IActionResult> RenewRuzhi(long id, [FromBody] Employee_RenewRuzhiCommand command)
    {
        try { return Ok(ApiResult<object>.Ok(await _mediator.Send(command with { Id = id }), "重新入职成功")); }
        catch (F9NotFoundException ex) { return NotFound(ApiResult<object>.Fail(ex.Message, 404)); }
        catch (F9OperationException ex) { return BadRequest(ApiResult<object>.Fail(ex.Message, 400)); }
    }

    /// <summary>修改生产信息（工作组 / 顺序号）</summary>
    [HttpPut("{id}/sc")]
    public async Task<IActionResult> UpdateSc(long id, [FromBody] Employee_UpdateScCommand command)
    {
        try { return Ok(ApiResult<object>.Ok(await _mediator.Send(command with { Id = id }), "修改成功")); }
        catch (F9NotFoundException ex) { return NotFound(ApiResult<object>.Fail(ex.Message, 404)); }
        catch (F9OperationException ex) { return BadRequest(ApiResult<object>.Fail(ex.Message, 400)); }
    }
}