using System.Text;

namespace SimpleAdmin.Web.Core;

/// <summary>
/// 接收契约锁服务器状态通知；第一版按平台要求使用明文回调。
/// </summary>
[ApiDescriptionSettings("Application", Tag = "入职电子签回调")]
[Route("open/onboarding/qiyuesuo")]
[AllowAnonymous]
public class OnboardingElectronicSignCallbackController
{
    private readonly IOnboardingElectronicSignService _service;
    private readonly IHttpContextAccessor _httpContextAccessor;

    public OnboardingElectronicSignCallbackController(
        IOnboardingElectronicSignService service,
        IHttpContextAccessor httpContextAccessor)
    {
        _service = service;
        _httpContextAccessor = httpContextAccessor;
    }

    /// <summary>
    /// 接收契约锁回调并返回平台可识别的非统一响应。
    /// </summary>
    [HttpPost("callback")]
    [NonUnify]
    public async Task<IActionResult> Callback()
    {
        try
        {
            var request = _httpContextAccessor.HttpContext?.Request
                          ?? throw new InvalidOperationException("当前请求上下文不存在");
            var payloadJson = await ReadPayload(request);
            await _service.HandleCallback(payloadJson);
            return new OkObjectResult(new
            {
                code = 0,
                message = "success"
            });
        }
        catch (global::System.Exception exception)
        {
            // 契约锁按 HTTP 状态码判断回调是否成功；返回 500 后平台会继续重试。
            return new ObjectResult(new
            {
                code = -1,
                message = exception.Message
            })
            {
                StatusCode = StatusCodes.Status500InternalServerError
            };
        }
    }

    /// <summary>
    /// 契约锁明文回调使用表单格式；同时兼容测试工具直接发送 JSON。
    /// </summary>
    private static async Task<string> ReadPayload(HttpRequest request)
    {
        if (request.HasFormContentType)
        {
            var form = await request.ReadFormAsync();
            var values = form
                .OrderBy(item => item.Key, StringComparer.Ordinal)
                .ToDictionary(
                    item => item.Key,
                    item => item.Value.ToString());
            return global::System.Text.Json.JsonSerializer.Serialize(values);
        }

        using var reader = new StreamReader(
            request.Body,
            Encoding.UTF8,
            true,
            leaveOpen: true);
        return await reader.ReadToEndAsync();
    }
}