AiDOPWarehouse/server/Plugins/Admin.NET.Plugin.AiDOP/Controllers/AdoSmartOpsKpiDimensionConfigController.cs

using System.Security.Claims;
using Admin.NET.Core;
using Admin.NET.Plugin.AiDOP.Dto.SmartOps;
using Admin.NET.Plugin.AiDOP.Entity;
using Admin.NET.Plugin.AiDOP.SmartOps;
using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Mvc;
using SqlSugar;

namespace Admin.NET.Plugin.AiDOP.Controllers;

/// <summary>
/// KPI 维度计算配置（DIMENSION_SQL 配置化）接口。**要求登录**——SQL 编辑/发布是高危面。
/// 租户由服务端按 moduleCode 解析；操作人取自 JWT。
/// </summary>
[ApiController]
[Route("api/[controller]")]
[Authorize]
public class AdoSmartOpsKpiDimensionConfigController : ControllerBase
{
    private readonly AdoSmartOpsKpiDimensionConfigService _service;
    private readonly ISqlSugarClient _db;

    public AdoSmartOpsKpiDimensionConfigController(AdoSmartOpsKpiDimensionConfigService service, ISqlSugarClient db)
    {
        _service = service;
        _db = db;
    }

    private string Operator() =>
        User?.FindFirstValue("RealName") ?? User?.FindFirstValue("Account") ?? User?.Identity?.Name ?? "unknown";

    /// <summary>某 KPI 的全部维度配置版本。</summary>
    [HttpGet("by-metric/{metricCode}")]
    public async Task<IActionResult> GetByMetric(string metricCode, [FromQuery] string moduleCode)
    {
        if (string.IsNullOrWhiteSpace(moduleCode))
            return BadRequest(new { message = "moduleCode 必填" });
        return Ok(await _service.GetByMetricAsync(metricCode, moduleCode));
    }

    /// <summary>已登记数据源列表。</summary>
    [HttpGet("data-sources")]
    public IActionResult DataSources() => Ok(_service.ListDataSources());

    /// <summary>KPI 维度能力（驱动前端筛选/下钻可用性）。</summary>
    [HttpGet("capability/{metricCode}")]
    public async Task<IActionResult> Capability(string metricCode, [FromQuery] string moduleCode)
    {
        if (string.IsNullOrWhiteSpace(moduleCode))
            return BadRequest(new { message = "moduleCode 必填" });
        return Ok(await _service.GetCapabilityAsync(metricCode, moduleCode));
    }

    /// <summary>新增草稿。</summary>
    [HttpPost]
    public async Task<IActionResult> Create([FromBody] KpiDimensionConfigUpsertDto dto)
    {
        if (string.IsNullOrWhiteSpace(dto.MetricCode) || string.IsNullOrWhiteSpace(dto.ModuleCode))
            return BadRequest(new { message = "metricCode / moduleCode 必填" });
        return Ok(await _service.CreateDraftAsync(dto, Operator()));
    }

    /// <summary>编辑草稿。</summary>
    [HttpPut("{id:long}")]
    public async Task<IActionResult> Update(long id, [FromBody] KpiDimensionConfigUpsertDto dto)
    {
        await _service.UpdateDraftAsync(id, dto, Operator());
        return Ok(new { ok = true });
    }

    /// <summary>删除草稿。</summary>
    [HttpDelete("{id:long}")]
    public async Task<IActionResult> Delete(long id)
    {
        await _service.DeleteAsync(id);
        return Ok(new { ok = true });
    }

    /// <summary>SQL 安全校验。</summary>
    [HttpPost("validate")]
    public IActionResult Validate([FromBody] KpiSqlValidateDto dto) => Ok(_service.Validate(dto.SqlScript));

    /// <summary>试算（不写维度结果；服务端重校验 + 只读多行执行）。</summary>
    [HttpPost("preview")]
    public async Task<IActionResult> Preview([FromBody] KpiDimensionPreviewDto dto, CancellationToken ct)
    {
        if (string.IsNullOrWhiteSpace(dto.MetricCode) || string.IsNullOrWhiteSpace(dto.ModuleCode))
            return BadRequest(new { message = "metricCode / moduleCode 必填" });
        return Ok(await _service.PreviewAsync(dto, ct));
    }

    /// <summary>发布（事务：单生效版本 + 绑定汇总版本一致性）。</summary>
    [HttpPost("{id:long}/publish")]
    public async Task<IActionResult> Publish(long id)
    {
        await _service.PublishAsync(id, Operator());
        return Ok(new { ok = true });
    }

    /// <summary>激活/回滚。</summary>
    [HttpPost("{id:long}/activate")]
    public async Task<IActionResult> Activate(long id)
    {
        await _service.ActivateAsync(id, Operator());
        return Ok(new { ok = true });
    }

    /// <summary>停用。</summary>
    [HttpPost("{id:long}/retire")]
    public async Task<IActionResult> Retire(long id)
    {
        await _service.RetireAsync(id, Operator());
        return Ok(new { ok = true });
    }

    /// <summary>某 KPI 的维度运行日志（分页，脱敏，租户后端解析）。</summary>
    [HttpGet("run-log/{metricCode}")]
    public async Task<IActionResult> RunLog(
        string metricCode, [FromQuery] string moduleCode,
        [FromQuery] int page = 1, [FromQuery] int pageSize = 20, [FromQuery] string? status = null)
    {
        if (string.IsNullOrWhiteSpace(metricCode) || string.IsNullOrWhiteSpace(moduleCode))
            return BadRequest(new { message = "metricCode / moduleCode 必填" });
        var tenantId = AdoSmartOpsKpiCalcConfigService.ResolveKpiTenantId(moduleCode);
        RefAsync<int> total = 0;
        var list = await _db.Queryable<AdoSmartOpsKpiDimensionRunLog>().ClearFilter<ITenantIdFilter>()
            .Where(x => x.MetricCode == metricCode && x.TenantId == tenantId)
            .WhereIF(!string.IsNullOrWhiteSpace(status), x => x.Status == status)
            .OrderBy(x => x.StartedAt, OrderByType.Desc)
            .ToPageListAsync(page <= 0 ? 1 : page, pageSize <= 0 ? 20 : pageSize, total);
        return Ok(new { list, total = total.Value });
    }
}