XFEExtension.NetCore.ServerInteractive

using System.Net;
using System.Reflection;
using System.Text.Json;
using XFEExtension.NetCore.AutoConfig;
using XFEExtension.NetCore.Exceptions;
using XFEExtension.NetCore.ServerInteractive.Interfaces;
using XFEExtension.NetCore.ServerInteractive.Models;
using XFEExtension.NetCore.ServerInteractive.Models.ServerModels;
using XFEExtension.NetCore.ServerInteractive.Models.UserModels;
using XFEExtension.NetCore.ServerInteractive.Utilities.Helpers;
using XFEExtension.NetCore.StringExtension;
using XFEExtension.NetCore.XFETransform.JsonConverter;

namespace XFEExtension.NetCore.ServerInteractive.Utilities.DataTable;

/// <summary>
/// XFE数据表格
/// </summary>
/// <typeparam name="T"></typeparam>
public class XFEDataListTable<T> : IXFEDataTable where T : IIdModel
{
    /// <inheritdoc/>
    public Func<IEnumerable<EncryptedUserLoginModel>> GetEncryptedUserLoginModelFunction { get; set; } = () => [];
    /// <inheritdoc/>
    public Func<IEnumerable<IUserInfo>> GetUsersFunction { get; set; } = () => [];
    /// <summary>
    /// 获取列表的方法
    /// </summary>
    public Func<IEnumerable<T>> GetTableFunction { get; set; } = () => [];
    /// <summary>
    /// 添加元素至列表的方法
    /// </summary>
    public Action<T> AddToTableFunction { get; set; } = _ => { };
    /// <summary>
    /// 从列表中移除元素的方法
    /// </summary>
    public Action<string> RemoveFromTableFunction { get; set; } = _ => { };
    /// <summary>
    /// 更改列表中元素的方法
    /// </summary>
    public Action<T> ChangeItemTableFunction { get; set; } = _ => { };
    /// <inheritdoc/>
    public string TableShowName { get; set; } = typeof(T).Name;
    /// <inheritdoc/>
    public string TableName { get; set; } = typeof(T).Name;
    /// <inheritdoc/>
    public string TableNameInRequest { get; set; }
    /// <inheritdoc/>
    public int GetPermissionLevel { get; set; }
    /// <inheritdoc/>
    public int RemovePermissionLevel { get; set; }
    /// <inheritdoc/>
    public int ChangePermissionLevel { get; set; }
    /// <inheritdoc/>
    public int AddPermissionLevel { get; set; }
    /// <inheritdoc/>
    public JsonSerializerOptions? JsonSerializerOptions { get; set; }
    /// <inheritdoc/>
    public JsonSerializerOptions? UserJsonSerializerOptions { get; set; }

    /// <summary>
    /// 创建列表并手动设置Get Set方法等
    /// </summary>
    public XFEDataListTable() => TableNameInRequest = $"{TableName[0]}".ToLower() + TableName[1..];

    /// <summary>
    /// 根据指定type自动设置Get Set方法
    /// </summary>
    /// <param name="type">继承于XFEProfile的配置文件类型</param>
    /// <remarks>
    /// 对于自动设置Get Set方法的Table，请确保配置文件使用XFEProfile创建ProfileList，属性名称为XXXTable
    /// </remarks>
    public XFEDataListTable(Type type)
    {
        TableNameInRequest = $"{TableName[0]}".ToLower() + TableName[1..];
        var property = type.GetProperty($"{typeof(T).Name}Table", BindingFlags.Public | BindingFlags.Static);
        var profileListType = typeof(ProfileList<T>);
        var addMethod = profileListType.GetMethod("Add", [typeof(T)]);
        var removeMethod = profileListType.GetMethod("Remove", [typeof(T)]);
        var saveMethod = type.GetMethod("SaveProfile", BindingFlags.Public | BindingFlags.Static);
        if (property is null || addMethod is null || removeMethod is null || saveMethod is null) return;
        GetTableFunction = () => property.GetValue(null) as ProfileList<T> ?? [];
        AddToTableFunction = item => addMethod.Invoke(GetTableFunction(), [item]);
        RemoveFromTableFunction = id =>
        {
            var table = GetTableFunction();
            removeMethod.Invoke(table, [table.FirstOrDefault(item => item.Id == id)]);
        };
        ChangeItemTableFunction = item =>
        {
            var table = GetTableFunction();
            var targetItem = table.FirstOrDefault(originItem => originItem.Id == item.Id);
            if (targetItem is null) return;
            foreach (var itemProperty in targetItem.GetType().GetProperties())
            {
                itemProperty.SetValue(targetItem, itemProperty.GetValue(item));
            }
            saveMethod.Invoke(null, []);
        };
    }

    /// <summary>
    /// 获取列表
    /// </summary>
    /// <returns></returns>
    public IEnumerable<T> GetList() => GetTableFunction();

    /// <summary>
    /// 添加一个元素
    /// </summary>
    /// <param name="item"></param>
    public void Add(T item) => AddToTableFunction(item);

    /// <summary>
    /// 移除一个元素
    /// </summary>
    /// <param name="id"></param>
    public void Remove(string id) => RemoveFromTableFunction(id);

    /// <summary>
    /// 更改一个元素
    /// </summary>
    /// <param name="item"></param>
    public void Change(T item) => ChangeItemTableFunction(item);

    /// <inheritdoc/>
    public async Task<HttpStatusCode> Execute(string execute, QueryableJsonNode requestJsonNode, ServerCoreReturnArgs r)
    {
        var statusCode = HttpStatusCode.OK;
        try
        {
            switch (execute)
            {
                case "get":
                    Console.Write($"获取{TableShowName}列表请求");
                    UserHelper.ValidatePermission(requestJsonNode["session"], requestJsonNode["deviceInfo"], r.ClientIP, GetPermissionLevel, GetEncryptedUserLoginModelFunction(), GetUsersFunction(), r);
                    List<T> tableList = [.. GetTableFunction()];
                    var pageCount = requestJsonNode["pageCount"]?.GetValue<int>() ?? -1;
                    if (pageCount == -1)
                    {
                        await r.Args.ReplyAndClose(JsonSerializer.Serialize(new
                        {
                            totalCount = tableList.Count,
                            lastPage = -1,
                            dataList = tableList
                        }, JsonSerializerOptions));
                    }
                    else
                    {
                        var page = requestJsonNode["page"]?.GetValue<int>() ?? -1;
                        await r.Args.ReplyAndClose(JsonSerializer.Serialize(new
                        {
                            totalCount = tableList.Count,
                            lastPage = (int)Math.Ceiling((double)tableList.Count / pageCount),
                            dataList = tableList[(page * pageCount)..((page + 1) * pageCount)]
                        }, JsonSerializerOptions));
                    }
                    break;
                case "add":
                    Console.Write($"添加{TableShowName}请求");
                    var item = JsonSerializer.Deserialize<T>(Convert.FromBase64String(requestJsonNode["data"]?.ToString() ?? string.Empty), JsonSerializerOptions);
                    if (item is null)
                    {
                        statusCode = HttpStatusCode.BadRequest;
                        throw new StopAction(() => { }, $"\n无法使用Json转换目标{TableShowName}信息");
                    }
                    Console.Write($"：{item.Id}");
                    UserHelper.ValidatePermission(requestJsonNode["session"], requestJsonNode["deviceInfo"], r.ClientIP, AddPermissionLevel, GetEncryptedUserLoginModelFunction(), GetUsersFunction(), r);
                    if (item.Id.IsNullOrWhiteSpace())
                    {
                        statusCode = HttpStatusCode.BadRequest;
                        throw new StopAction(() => { }, $"{TableShowName}ID不能为空");
                    }
                    while (IdModelHelper.HasSameId(item.Id, GetTableFunction().Cast<IIdModel>()))
                        item.Id = Guid.NewGuid().ToString();
                    Add(item);
                    r.Args.Close();
                    break;
                case "remove":
                    Console.Write($"删除{TableShowName}请求");
                    var id = requestJsonNode["id"]?.ToString();
                    Console.Write($"：{id}");
                    UserHelper.ValidatePermission(requestJsonNode["session"], requestJsonNode["deviceInfo"], r.ClientIP, RemovePermissionLevel, GetEncryptedUserLoginModelFunction(), GetUsersFunction(), r);
                    if (id.IsNullOrWhiteSpace())
                    {
                        statusCode = HttpStatusCode.BadRequest;
                        throw new StopAction(() => { }, $"{TableShowName}ID不能为空");
                    }
                    Remove(id);
                    r.Args.Close();
                    break;
                case "change":
                    Console.Write($"更改{TableShowName}请求");
                    item = JsonSerializer.Deserialize<T>(Convert.FromBase64String(requestJsonNode["data"]?.ToString() ?? string.Empty), JsonSerializerOptions);
                    if (item is null)
                    {
                        statusCode = HttpStatusCode.BadRequest;
                        throw new StopAction(() => { }, $"\n无法使用Json转换目标{TableShowName}信息");
                    }
                    Console.Write($"：{item.Id}");
                    if (item.Id.IsNullOrWhiteSpace() || item.Id.IsNullOrWhiteSpace())
                    {
                        statusCode = HttpStatusCode.BadRequest;
                        throw new StopAction(() => { }, $"\n{TableShowName}ID不能为空");
                    }
                    UserHelper.ValidatePermission(requestJsonNode["session"], requestJsonNode["deviceInfo"], r.ClientIP, ChangePermissionLevel, GetEncryptedUserLoginModelFunction(), GetUsersFunction(), r);
                    Change(item);
                    r.Args.Close();
                    break;
                default:
                    Console.WriteLine($"[ERROR] 试图查询不存在的表格：{execute}");
                    await r.Args.ReplyAndClose($"试图查询不存在的表格：{execute}", HttpStatusCode.BadRequest);
                    break;
            }
        }
        catch (ServerCoreReturnArgs returnArgs)
        {
            Console.WriteLine($"[WARN]({r.ServerCore.ServerCoreName}){returnArgs.ReturnMessage}");
            await returnArgs.Args.ReplyAndClose(returnArgs.ReturnMessage, returnArgs.StatusCode);
        }
        catch (Exception ex)
        {
            Console.WriteLine($"[WARN]({r.ServerCore.ServerCoreName}){ExceptionHelper.GetExceptionMessage(ex)}");
            Console.WriteLine($"[TRACE]{ex.StackTrace}");
            await r.Args.ReplyAndClose(ex.Message, statusCode);
        }
        return statusCode;
    }
}