XFEExtension.NetCore.ServerInteractive

using System.Net;
using XFEExtension.NetCore.AutoImplement;
using XFEExtension.NetCore.ServerInteractive.Models.ServerModels;
using XFEExtension.NetCore.XFETransform.Json;

namespace XFEExtension.NetCore.ServerInteractive.Utilities.DataTable;

/// <summary>
/// XFE数据表格管理器
/// </summary>
[CreateImpl]
public abstract class XFEDataTableManager
{
    /// <summary>
    /// 数据表格列表
    /// </summary>
    public List<IXFEDataTable> TableList { get; set; } = [];
    /// <summary>
    /// 数据表格字典
    /// </summary>
    public Dictionary<string, IXFEDataTable> TableDictionary { get; set; } = [];

    /// <summary>
    /// 执行
    /// </summary>
    /// <param name="execute">请求语句</param>
    /// <param name="requestJsonNode">json节点</param>
    /// <param name="r">参数</param>
    /// <returns></returns>
    public async Task Execute(string execute, XFEJsonNode requestJsonNode, ServerCoreReturnArgs r)
    {
        var split = execute.Split('_');
        if (TableDictionary.TryGetValue(split[1], out var table))
        {
            _ = await table.Execute(split[0], requestJsonNode, r);
        }
        else
        {
            Console.WriteLine($"[ERROR]({r.ServerCore.ServerCoreName})【{r.ClientIP}】试图查询不存在的表格：{split[1]}");
            await r.Args.ReplyAndClose($"试图查询不存在的表格：{execute}", HttpStatusCode.BadRequest);
        }
    }
}