using Dpz.Core.MessageQueue.Abstractions;
using Dpz.Core.Public.ViewModel.Messages;
using Dpz.Core.Public.ViewModel.Response;
using Microsoft.AspNetCore.RateLimiting;

namespace Dpz.Core.WebApi.Controllers;

/// <summary>
/// 评论
/// </summary>
[ApiController, Route("api/[controller]")]
public class CommentController(
    ICommentService commentService,
    IMessagePublisher<SendMasterEmailMessage> masterEmailPublisher,
    IMessagePublisher<SendReplyEmailMessage> replyEmailPublisher,
    IConfiguration configuration,
    IFusionCache fusionCache,
    ILogger<CommentController> logger
) : ControllerBase
{
    private readonly bool _emailVerifyEnabled =
        configuration.GetSection("EmailVerifyServiceOpen").Get<bool?>() ?? false;

    /// <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;
        }

        if (_emailVerifyEnabled)
        {
            if (string.IsNullOrWhiteSpace(comment.Email))
            {
                return BadRequest(new { message = "邮箱不能为空" });
            }

            var verified = await fusionCache.GetOrDefaultAsync<bool>(
                Request.BuildEmailVerifyPassedCacheKey(comment.Email)
            );

            if (!verified)
            {
                return BadRequest(new { message = "请先完成邮箱验证后再提交评论" });
            }
        }

        try
        {
            await commentService.PublishCommentAsync(comment);
        }
        catch (Exception e)
        {
            return BadRequest(e.Message);
        }

        // 发布邮件消息
        try
        {
            // 发送给管理员
            await masterEmailPublisher.PublishAsync(
                new SendMasterEmailMessage
                {
                    NickName = comment.NickName,
                    Email = comment.Email,
                    CommentText = comment.CommentText,
                    SendTime = comment.SendTime,
                    Source = nameof(CommentController),
                }
            );

            // 如果是回复，发送给被回复者
            if (!string.IsNullOrEmpty(comment.ReplyId))
            {
                await PublishReplyEmailMessageAsync(
                    comment.ReplyId,
                    comment.NickName,
                    comment.CommentText,
                    comment.Email
                );
            }
        }
        catch (Exception e)
        {
            logger.LogError(e, "评论邮件消息发送失败");
        }

        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();
    }

    private Task PublishReplyEmailMessageAsync(
        string targetCommentId,
        string replierNickname,
        string replyText,
        string? replierEmail
    ) =>
        replyEmailPublisher.PublishAsync(
            new SendReplyEmailMessage
            {
                TargetCommentId = targetCommentId,
                ReplierNickname = replierNickname,
                ReplierEmail = replierEmail,
                ReplyText = replyText,
                Source = nameof(CommentController),
            }
        );
}