AiDOPWarehouse/server/Plugins/Admin.NET.Plugin.AiDOP/Order/S1MdpMonitorService.cs

namespace Admin.NET.Plugin.AiDOP.Order;

/// <summary>
/// S1 MDP 运行监控。
///
/// 【租户安全边界】需认证访问（已移除类级 <c>[AllowAnonymous]</c>）；租户一律经
/// <c>AidopTenantScope.ResolveOrThrow</c> 从认证后 JWT 解析，无有效租户即拒绝，
/// 不读前端 tenantId、无默认回退（原实现：类级匿名 + 直接取 <c>_userManager.TenantId</c>，
/// 匿名时退化为 <c>tenant_id = 0</c> 平台行）。租户行与平台行可见性语义（<c>BuildMdpRunLogTenantWhere</c>）不变。
/// </summary>
[ApiDescriptionSettings(Order = 321, Description = "S1 MDP运行监控")]
[Route("api/Order")]
[NonUnify]
public class S1MdpMonitorService : IDynamicApiController, ITransient
{
    private const string JobCode = "S1_MDP_SYNC_TRANSFORM";
    private readonly ISqlSugarClient _db;
    private readonly UserManager _userManager;

    public S1MdpMonitorService(ISqlSugarClient db, UserManager userManager)
    {
        _db = db;
        _userManager = userManager;
    }

    [DisplayName("S1 MDP最近运行状态")]
    [HttpGet("s1-mdp-monitor/latest")]
    public async Task<object> GetLatest()
    {
        var tenantId = AidopTenantScope.ResolveOrThrow(_userManager);
        return await _db.Ado.SqlQuerySingleAsync<S1MdpRunLogRow>(
            $"{SelectColumnsSql()} FROM mdp_transform_run_log WHERE job_code=@JobCode AND {MdpMonitorService.BuildMdpRunLogTenantWhere(tenantId)} ORDER BY start_time DESC, id DESC LIMIT 1",
            new SugarParameter("@JobCode", JobCode),
            new SugarParameter("@TenantId", tenantId))
            ?? new S1MdpRunLogRow();
    }

    [DisplayName("S1 MDP运行日志列表")]
    [HttpGet("s1-mdp-monitor/list")]
    public async Task<object> GetList([FromQuery] S1MdpMonitorListInput input)
    {
        var tenantId = AidopTenantScope.ResolveOrThrow(_userManager);
        var page = input.Page <= 0 ? 1 : input.Page;
        var pageSize = input.PageSize <= 0 ? 10 : input.PageSize;
        var offset = (page - 1) * pageSize;
        var where = new List<string> { "job_code=@JobCode", MdpMonitorService.BuildMdpRunLogTenantWhere(tenantId) };
        var pars = new List<SugarParameter> { new("@JobCode", JobCode), new("@TenantId", tenantId) };

        if (!string.IsNullOrWhiteSpace(input.BatchId))
        {
            where.Add("batch_id LIKE @BatchId");
            pars.Add(new SugarParameter("@BatchId", $"%{input.BatchId.Trim()}%"));
        }
        if (!string.IsNullOrWhiteSpace(input.Status))
        {
            where.Add("status=@Status");
            pars.Add(new SugarParameter("@Status", input.Status.Trim().ToUpperInvariant()));
        }
        if (input.StartTime.HasValue)
        {
            where.Add("start_time >= @StartTime");
            pars.Add(new SugarParameter("@StartTime", input.StartTime.Value));
        }
        if (input.EndTime.HasValue)
        {
            where.Add("start_time <= @EndTime");
            pars.Add(new SugarParameter("@EndTime", input.EndTime.Value));
        }

        var whereSql = string.Join(" AND ", where);
        var total = await _db.Ado.GetIntAsync($"SELECT COUNT(1) FROM mdp_transform_run_log WHERE {whereSql}", pars);
        var list = await _db.Ado.SqlQueryAsync<S1MdpRunLogRow>(
            $"""
            {SelectColumnsSql()}
            FROM mdp_transform_run_log
            WHERE {whereSql}
            ORDER BY start_time DESC, id DESC
            LIMIT {pageSize} OFFSET {offset}
            """,
            pars);

        return new { total, page, pageSize, list };
    }

    [DisplayName("S1 MDP运行日志详情")]
    [HttpGet("s1-mdp-monitor/detail/{id}")]
    public async Task<object> GetDetail(long id)
    {
        var tenantId = AidopTenantScope.ResolveOrThrow(_userManager);
        var row = await _db.Ado.SqlQuerySingleAsync<S1MdpRunLogRow>(
            $"{SelectColumnsSql()} FROM mdp_transform_run_log WHERE id=@Id AND job_code=@JobCode AND {MdpMonitorService.BuildMdpRunLogTenantWhere(tenantId)} LIMIT 1",
            new SugarParameter("@Id", id),
            new SugarParameter("@JobCode", JobCode),
            new SugarParameter("@TenantId", tenantId));
        return row ?? throw Oops.Oh("运行日志不存在");
    }

    private static string SelectColumnsSql()
    {
        return """
            SELECT id AS Id, tenant_id AS TenantId, job_code AS JobCode, job_name AS JobName, trigger_type AS TriggerType,
                   batch_id AS BatchId, status AS Status, start_time AS StartTime, end_time AS EndTime, duration_ms AS DurationMs,
                   stage_rows AS StageRows, standard_rows AS StandardRows, dwd_rows AS DwdRows,
                   error_message AS ErrorMessage, summary_json AS SummaryJson, create_time AS CreateTime, update_time AS UpdateTime
            """;
    }
}

public sealed class S1MdpMonitorListInput
{
    public string? BatchId { get; set; }
    public string? Status { get; set; }
    public DateTime? StartTime { get; set; }
    public DateTime? EndTime { get; set; }
    public int Page { get; set; } = 1;
    public int PageSize { get; set; } = 10;
}

public sealed class S1MdpRunLogRow
{
    public long Id { get; set; }
    public long TenantId { get; set; }
    public string? JobCode { get; set; }
    public string? JobName { get; set; }
    public string? TriggerType { get; set; }
    public string? BatchId { get; set; }
    public string? Status { get; set; }
    public DateTime? StartTime { get; set; }
    public DateTime? EndTime { get; set; }
    public int? DurationMs { get; set; }
    public int? StageRows { get; set; }
    public int? StandardRows { get; set; }
    public int? DwdRows { get; set; }
    public string? ErrorMessage { get; set; }
    public string? SummaryJson { get; set; }
    public DateTime? CreateTime { get; set; }
    public DateTime? UpdateTime { get; set; }
}