using Dpz.Core.Hangfire;
using Dpz.Core.Public.ViewModel.Response;
using Hangfire;
using Microsoft.AspNetCore.RateLimiting;

namespace Dpz.Core.WebApi.Controllers;

/// <summary>
/// 评论
/// </summary>
[ApiController, Route("api/[controller]")]
public class CommentController(ICommentService commentService, ILogger<CommentController> logger)
    : ControllerBase
{
    /// <summary>
    /// 获取评论
    /// </summary>
    /// <returns></returns>
    [HttpGet, Authorize(Policy = "System")]
    [ProducesResponseType<List<VmCommentFlat>>(StatusCodes.Status200OK)]
    [ProducesResponseType(StatusCodes.Status401Unauthorized)]
    public async Task<IActionResult> GetComments([FromQuery] CommentQueryDto query)
    {
        var list = await commentService.GetPageAsync(
            query.Node,
            query.Relation,
            query.PageIndex,
            query.PageSize
        );
        list.AddPaginationMetadata(Response.Headers);
        return Ok(list);
    }

    /// <summary>
    /// 评论分页信息
    /// </summary>
    /// <param name="query"></param>
    /// <returns></returns>
    [HttpGet("page")]
    [ProducesResponseType<List<CommentViewModel>>(StatusCodes.Status200OK)]
    public async Task<IActionResult> GetCommentPage([FromQuery] CommentPageQuery query)
    {
        var list = await commentService.GetCommentsAsync(
            query.Node,
            query.Relation,
            query.PageIndex,
            query.PageSize
        );
        list.AddPaginationMetadata(Response.Headers);
        return Ok(list);
    }

    /// <summary>
    /// 匿名发送评论
    /// </summary>
    /// <param name="comment"></param>
    /// <param name="pageSize"></param>
    /// <returns></returns>
    [HttpPost, EnableRateLimiting("comment")]
    [ProducesResponseType<List<CommentViewModel>>(StatusCodes.Status200OK)]
    public async Task<IActionResult> SendComment(
        [FromBody] VmPublishComment comment,
        [FromQuery] int pageSize = 5
    )
    {
        if (pageSize > 100)
        {
            pageSize = 100;
        }

        try
        {
            await commentService.PublishCommentAsync(comment);
        }
        catch (Exception e)
        {
            return BadRequest(e.Message);
        }
        try
        {
            BackgroundJob.Enqueue<EmailSenderActivator>(x => x.SendMasterAsync(comment));
            if (!string.IsNullOrEmpty(comment.ReplyId))
            {
                BackgroundJob.Enqueue<EmailSenderActivator>(x => x.SendCommenterAsync(comment));
            }
        }
        catch (Exception e)
        {
            logger.LogError(e, "comment send email fail");
        }

        var list = await commentService.GetCommentsAsync(
            comment.Node,
            comment.Relation,
            1,
            pageSize
        );
        list.AddPaginationMetadata(Response.Headers);
        return Ok(list);
    }

    /// <summary>
    /// 文章关联
    /// </summary>
    /// <returns></returns>
    [HttpGet("relation/article"), Authorize(Policy = "System")]
    public async Task<ActionResult<List<CommentRelationResponse>>> GetArticleRelationTitle()
    {
        var dic = await commentService.HasCommentForArticleAsync();
        return Ok(dic);
    }

    /// <summary>
    /// 源码关联
    /// </summary>
    /// <returns></returns>
    [HttpGet("relation/code"), Authorize(Policy = "System")]
    public async Task<ActionResult<List<CommentRelationResponse>>> CodeRelation()
    {
        var dic = await commentService.CodeRelationAsync();
        return Ok(dic);
    }

    /// <summary>
    /// 其他关联
    /// </summary>
    /// <returns></returns>
    [HttpGet("relation/other"), Authorize(Policy = "System")]
    public async Task<ActionResult<List<CommentRelationResponse>>> OtherRelation()
    {
        var dic = await commentService.OtherRelationAsync();
        return Ok(dic);
    }

    /// <summary>
    /// 逻辑删除
    /// </summary>
    /// <param name="id"></param>
    /// <returns></returns>
    [HttpDelete("{id}"), Authorize(Policy = "System")]
    [ProducesResponseType(StatusCodes.Status204NoContent)]
    [ProducesResponseType(StatusCodes.Status401Unauthorized)]
    public async Task<IActionResult> Delete(string id)
    {
        await commentService.ClearAsync(id);
        return NoContent();
    }

    /// <summary>
    /// 物理删除
    /// </summary>
    /// <param name="id"></param>
    /// <returns></returns>
    [HttpDelete("{id}/physical"), Authorize(Policy = "System")]
    [ProducesResponseType(StatusCodes.Status204NoContent)]
    [ProducesResponseType(StatusCodes.Status401Unauthorized)]
    public async Task<IActionResult> PhysicalDelete(string id)
    {
        await commentService.DeleteAsync(id);
        return NoContent();
    }
}