AiDOPWarehouse/server/Plugins/Admin.NET.Plugin.AiDOP/Supply/DeliveryExceptionService.cs

namespace Admin.NET.Plugin.AiDOP.Supply;

/// <summary>
/// 交货单异常记录服务
///
/// 【租户安全边界】租户一律经 <see cref="AidopTenantScope.ResolveOrThrow"/> 从认证后 JWT 解析，
/// 无有效租户即拒绝，不读前端 tenantId、无默认回退（原实现：类级 <c>[AllowAnonymous]</c> +
/// <c>_userManager.TenantId &gt; 0</c> 跳过分支，匿名时 TenantId=0 使租户过滤整体失效）。
/// </summary>
[ApiDescriptionSettings(Order = 307, Description = "交货单异常记录")]
[Route("api/Supply")]
[NonUnify]
public class DeliveryExceptionService : IDynamicApiController, ITransient
{
    private const string C = "utf8mb4_general_ci";
    private readonly ISqlSugarClient _db;
    private readonly UserManager _userManager;

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

    /// <summary>交货单异常记录分页列表</summary>
    [DisplayName("交货单异常记录列表")]
    [HttpGet("delivery-exception/list")]
    public async Task<object> GetList([FromQuery] DeliveryExceptionListInput input)
    {
        var page = input.Page <= 0 ? 1 : input.Page;
        var pageSize = input.PageSize <= 0 ? 20 : input.PageSize;
        var offset = (page - 1) * pageSize;

        var tenantId = AidopTenantScope.ResolveOrThrow(_userManager);
        var pars = new List<SugarParameter> { new("@TenantId", tenantId) };
        var where = new List<string> { "1=1", "dm.tenant_id = @TenantId" };
        if (!string.IsNullOrWhiteSpace(input.OptTime))
        {
            where.Add($"(CAST(dm.OptTime AS CHAR(50)) COLLATE {C}) LIKE @OptTimeLike");
            pars.Add(new SugarParameter("@OptTimeLike", $"%{input.OptTime.Trim()}%"));
        }
        if (!string.IsNullOrWhiteSpace(input.ItemNum))
        {
            where.Add($"(dm.ItemNum COLLATE {C}) = @ItemNum");
            pars.Add(new SugarParameter("@ItemNum", input.ItemNum.Trim()));
        }

        var baseSql = BuildListBaseSql(string.Join(" AND ", where));
        var total = await _db.Ado.GetIntAsync($"SELECT COUNT(*) FROM ({baseSql}) AS t", pars);
        var list = await _db.Ado.SqlQueryAsync<DeliveryExceptionListRow>(
            $"SELECT * FROM ({baseSql}) AS t ORDER BY t.Id DESC LIMIT {pageSize} OFFSET {offset}", pars);

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

    private static string BuildListBaseSql(string innerWhere) => $"""
        SELECT
            dm.RecID                     AS Id,
            dm.Domain                    AS Domain,
            dm.Icdsid                    AS IcdsId,
            dm.OptTime                   AS OptTime,
            dm.ItemNum                   AS ItemNum,
            im.Descr                     AS Descr,
            dm.Remark                    AS Remark,
            IFNULL(dm.NeedQty, 0)        AS NeedQty
        FROM DeliveryExceptionMaster dm
        LEFT JOIN ItemMaster im
            ON (dm.Domain COLLATE {C}) = (im.Domain COLLATE {C})
            AND (dm.ItemNum COLLATE {C}) = (im.ItemNum COLLATE {C})
            AND im.tenant_id = @TenantId
        WHERE {innerWhere}
        """;

    private sealed class DeliveryExceptionListRow
    {
        public long Id { get; set; }
        public string? Domain { get; set; }
        public long? IcdsId { get; set; }
        public DateTime? OptTime { get; set; }
        public string? ItemNum { get; set; }
        public string? Descr { get; set; }
        public decimal? NeedQty { get; set; }
        public string? Remark { get; set; }
    }
}