/////////////////////////////////////////////////////////////////////////////////
// 宁波拓通e智造平台 ToTong Next Builder                                        //
// https://git.tuotong-tech.com/tnb/tnb.server                                 //
/////////////////////////////////////////////////////////////////////////////////

using Mapster;
using Microsoft.AspNetCore.Mvc;
using SqlSugar;
using Tnb.Vengine.DataAccess;
using Tnb.Vengine.Domain;

namespace Tnb.Vengine.AppService;

/// <summary>
/// 视图模型服务类
/// </summary>
public class VmodelAppService : VmAppService<Vmodel>, IVmodelAppService
{

  /// <summary>
  /// 构造函数
  /// </summary>
  public VmodelAppService(IDataAccess da) : base(da)
  {
  }

  /// <summary>
  /// 获取一条 数据信息
  /// </summary>
  public override async Task<dynamic> GetAsync(VmGetInput input)
  {
    //return await _dataAccess.GetVmodelAsync(input.id);
    var query = _db.Queryable<Vmodel>().Where(a => a.deleted == 0);
    Vmodel vm;
    if (long.TryParse(input.id, out long id))
    {
      vm = await query.FirstAsync(a => a.id == input.id);
    }
    else
    {
      vm = await query.FirstAsync(a => a.vmCode == input.id);
    }
    return vm;
  }

  /// <summary>
  /// 获取多条 数据列表
  /// </summary>
  public override async Task<VmPagedOutput> GetListAsync(VmGetListInput input)
  {
    VmPagedOutput ret = new();
    var q = _db.Queryable<Vmodel>().WhereIF(!string.IsNullOrEmpty(input.k), a => a.vmCode.Contains(input.k!) || a.vmName.Contains(input.k!));
    RefAsync<int> total = 0;
    var data = await q.OrderBy(input.sort).ToPageListAsync((input.pnum - 1) * input.psize, input.psize, total);
    ret.total = total;
    ret.items = data.ConvertAll<dynamic>(a => a);
    return ret;
  }

  [NonAction]
  public override Task<VmPagedOutput> QueryAsync(VmQueryInput input)
  {
    return base.QueryAsync(input);
  }

  /// <summary>
  /// 新增 模型
  /// </summary>
  public override async Task<dynamic> CreateAsync(VmCreateInput input)
  {
    //ThrowIf.IsNull(input.data, nameof(input));
    ArgumentNullException.ThrowIfNull(input.data);
    Vmodel vm = input.data.Adapt<Vmodel>();
    await _db.Insertable(vm).ExecuteCommandAsync();
    return input;
  }

  /// <summary>
  /// 更新 数据
  /// </summary>
  public override async Task<dynamic> UpdateAsync(VmUpdateInput input)
  {
    ArgumentNullException.ThrowIfNull(input.data);
    Vmodel vm = input.data.Adapt<Vmodel>();
    await _db.Updateable(vm).WhereColumns(a => a.id).ExecuteCommandAsync();
    return input;
  }

  /// <summary>
  /// 删除 数据
  /// </summary>
  public override async Task<dynamic> DeleteAsync(VmDeleteInput input)
  {
    var ret = await _db.Deleteable<Vmodel>(input.id).ExecuteCommandAsync();
    return ret;
  }

  /// <summary>
  /// 从数据表创建模型
  /// </summary>
  public async Task<List<Vmodel>> CreateFromTable(VmodelCreateFromTableInput input)
  {
    ThrowIf.IsNull(input.tableName, nameof(input.tableName));
    var sugar = _dataAccess.GetSqlSugar(input.dbCode);
    var lsTable = sugar.DbMaintenance.GetTableInfoList().WhereIF(input.tableName != "ALL", a => a.Name == input.tableName);

    List<Vmodel> lsToAdd = new List<Vmodel>();
    List<Vmodel> lsToUpdate = new List<Vmodel>();
    foreach (var tb in lsTable)
    {
      if (!string.IsNullOrEmpty(input.removePrefix) && !tb.Name.StartsWith(input.removePrefix)) continue;
      var colInfo = sugar.DbMaintenance.GetColumnInfosByTableName(tb.Name);
      Vmodel model = new() { dbCode = input.dbCode, vmName = tb.Description, tableName = tb.Name };
      model.area = input.area;
      model.vmCode = (string.IsNullOrEmpty(input.removePrefix) ? tb.Name : tb.Name.RemovePreFix(input.removePrefix)).SnakeToPascalCase();
      //model.createId = CurrentUser.Id;
      int n = 1;
      foreach (var p in colInfo)
      {
        var prop = p.Adapt<VmDbProp>();
        prop.ordinal = n++;
        prop.csType = sugar.Ado.DbBind.GetPropertyTypeName(p.DataType);
        model.dbProps.Add(prop);
      }
      var exist = await _db.Queryable<Vmodel>().FirstAsync(a => a.dbCode == input.dbCode && a.tableName == tb.Name);
      if (exist == null)
      {
        lsToAdd.Add(model);
      }
      else
      {
        exist.area = model.area;
        model.dbProps.Adapt(exist.dbProps);
        //exist.dbProps.Clear();
        //exist.dbProps.AddRange(model.dbProps.OrderBy(a => a.ordinal));
        lsToUpdate.Add(exist);
      }
    }
    if (lsToAdd.Count > 0)
    {
      await _db.Insertable(lsToAdd).ExecuteCommandAsync();
    }
    if (lsToUpdate.Count > 0)
    {
      await _db.Updateable(lsToUpdate).ExecuteCommandAsync();
    }
    return lsToAdd.Union(lsToUpdate).ToList();
  }


}