添加Tnb.Vengine

visualdev/Tnb.Vengine/AppService/VmodelAppService.cs

@@ -0,0 +1,151 @@
+/////////////////////////////////////////////////////////////////////////////////
+// 宁波拓通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();
+  }
+
+
+}