using iWare.Wms.Application;
|
using iWare.Wms.Application.Service.System.LowCode.Dto;
|
using iWare.Wms.Core;
|
using iWare.Wms.Core.Util.LowCode.Front.Code;
|
using iWare.Wms.Core.Util.LowCode.Front.Model;
|
using Furion.DatabaseAccessor;
|
using Furion.DatabaseAccessor.Extensions;
|
using Furion.DependencyInjection;
|
using Furion.DynamicApiController;
|
using Furion.Extras.iWare.Wms.Entity;
|
using Furion.Extras.iWare.Wms.Service.LowCode.Dto;
|
using Furion.Extras.iWare.Wms.Util;
|
using Furion.Extras.iWare.Wms.Util.LowCode.Front.Code;
|
using Furion.Extras.iWare.Wms.Util.LowCode.Front.Interface;
|
using Furion.FriendlyException;
|
using Furion.ViewEngine;
|
using Mapster;
|
using Microsoft.AspNetCore.Mvc;
|
using Microsoft.EntityFrameworkCore;
|
using Microsoft.Extensions.Configuration;
|
using Newtonsoft.Json;
|
using NString;
|
using System.Linq.Dynamic.Core;
|
using System.Text;
|
|
namespace Furion.Extras.iWare.Wms.Service.LowCode
|
{
|
/// <summary>
|
/// 低代码模块服务
|
/// </summary>
|
[ApiDescriptionSettings(Name = "LowCode", Order = 100)]
|
[Route("api/lowcode")]
|
public class LowCodeService : ILowCodeService, IDynamicApiController, ITransient
|
{
|
private readonly IRepository<SysLowCode> _sysLowCodeRep;
|
private readonly IRepository<SysLowCodeDataBase> _sysLowCodeDataBaseRep;
|
private readonly IRepository<SysMenu> _sysMenuRep; // 菜单表仓储
|
private readonly IConfiguration _configuration;
|
private readonly IViewEngine _viewEngine;
|
|
public LowCodeService(IRepository<SysLowCode> sysLowCodeRep,
|
IRepository<SysLowCodeDataBase> sysLowCodeDataBaseRep,
|
IRepository<SysMenu> sysMenuRep,
|
IConfiguration configuration,
|
IViewEngine viewEngine)
|
{
|
_sysLowCodeRep = sysLowCodeRep;
|
_sysLowCodeDataBaseRep = sysLowCodeDataBaseRep;
|
_sysMenuRep = sysMenuRep;
|
_configuration = configuration;
|
_viewEngine = viewEngine;
|
}
|
|
/// <summary>
|
/// 分页查询
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
/// <exception cref="NotImplementedException"></exception>
|
[HttpGet("page")]
|
public async Task<PageResult<SysLowCode>> QueryPageList([FromQuery] LowCodePageInput input)
|
{
|
var busName = !string.IsNullOrEmpty(input.BusName?.Trim());
|
var lowCodes = await _sysLowCodeRep.DetachedEntities
|
.Where((busName, u => EF.Functions.Like(u.BusName, $"%{input.BusName.Trim()}%")))
|
.ToADPagedListAsync(input.PageNo, input.PageSize);
|
return lowCodes;
|
}
|
|
/// <summary>
|
/// 获取模块详情
|
/// </summary>
|
/// <param name="id"></param>
|
/// <returns></returns>
|
[HttpGet("info/{id}")]
|
public SysLowCode Info(long id)
|
{
|
return _sysLowCodeRep.Where(x => x.Id == id).Include(x => x.Databases).FirstOrDefault();
|
}
|
|
/// <summary>
|
/// 添加
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
/// <exception cref="NotImplementedException"></exception>
|
[HttpPost("add")]
|
public async Task Add(AddLowCodeInput input)
|
{
|
var isExist = await _sysLowCodeRep.DetachedEntities.AnyAsync(u => u.BusName == input.BusName);
|
if (isExist)
|
throw Oops.Oh(ErrorCode.D1600);
|
|
var lowCode = input.Adapt<SysLowCode>();
|
var newLowCode = await lowCode.InsertNowAsync();
|
}
|
|
/// <summary>
|
/// 删除
|
/// </summary>
|
/// <param name="inputs"></param>
|
/// <returns></returns>
|
/// <exception cref="NotImplementedException"></exception>
|
[HttpPost("del")]
|
public async Task Delete(List<DeleteLowCodeInput> inputs)
|
{
|
if (inputs == null || inputs.Count < 1) return;
|
|
foreach (var u in inputs)
|
{
|
_sysLowCodeDataBaseRep.Where(x => x.SysLowCodeId == u.Id).DeleteRange(_sysLowCodeDataBaseRep.Context);
|
await _sysLowCodeRep.DeleteAsync(u.Id);
|
}
|
}
|
|
/// <summary>
|
/// 更新
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
/// <exception cref="NotImplementedException"></exception>
|
[HttpPost("edit")]
|
public async Task Update(UpdateLowCodeInput input)
|
{
|
var lowCode = input.Adapt<SysLowCode>();
|
await lowCode.UpdateAsync();
|
|
await _sysLowCodeDataBaseRep.Context.DeleteRangeAsync<SysLowCodeDataBase>(x => x.SysLowCodeId == input.Id);
|
await _sysLowCodeDataBaseRep.InsertAsync(lowCode.Databases);
|
}
|
|
/// <summary>
|
/// 对比组件
|
/// </summary>
|
/// <param name="contrast"></param>
|
/// <returns></returns>
|
/// <exception cref="NotImplementedException"></exception>
|
[HttpPost("contrast")]
|
public ContrasOutput Contrast(ContrastLowCode contrast)
|
{
|
List<IFront> fronts = contrast.Controls.ConvertToFront().AllFront();
|
|
DataCompareUtil<IFront, ContrastLowCode_Database> dataCompare
|
= new DataCompareUtil<IFront, ContrastLowCode_Database>(x => x.Key, x => x.Id);
|
|
dataCompare.PushCompare(x => x.Key, x => x.Control_Key);
|
dataCompare.PushCompare(x => x.Label, x => x.Control_Label);
|
dataCompare.PushCompare(x => x.Model, x => x.Control_Model);
|
dataCompare.PushCompare(x => x.Type, x => x.Control_Type);
|
|
var compare = dataCompare.Compare(fronts, contrast.Databases);
|
|
List<ContrastLowCode_Database> list = new List<ContrastLowCode_Database>();
|
|
var tables = contrast.Databases.Where(x => !string.IsNullOrEmpty(x.TableName) && !string.IsNullOrEmpty(x.TableName))
|
.Select(x => new { x.TableName, x.ClassName, x.TableDesc })
|
.Distinct()
|
.ToList();
|
|
if (tables.Count != 1)
|
{
|
tables.Clear();
|
}
|
|
compare.NoContain_2.ForEach(item =>
|
{
|
list.AddRange(item.ReadFront_BindDatabase(_sysLowCodeRep.ProviderName).Select(x => new ContrastLowCode_Database()
|
{
|
Control_Key = item.Key,
|
Control_Label = item.Label,
|
Control_Model = item.Model,
|
Control_Type = item.Type,
|
DbParam = x.DbParam,
|
DbType = x.DbType,
|
DbTypeName = x.DbType.Name,
|
DtoTypeName = x.DtoType == null ? x.DbType.Name : x.DtoType.Name,
|
FieldName = $"{item.Model}{x.Suffix}",
|
IsRequired = true,
|
Id = Guid.NewGuid(),
|
TableName = tables.Select(x => x.TableName).FirstOrDefault(),
|
ClassName = tables.Select(x => x.ClassName).FirstOrDefault(),
|
TableDesc = tables.Select(x => x.TableDesc).FirstOrDefault(),
|
QueryType = "equery",
|
QueryWhether = true,
|
whetherAddUpdate = true,
|
WhetherOrderBy = true,
|
WhetherTable = true
|
}));
|
});
|
|
return new ContrasOutput()
|
{
|
Add = list,
|
Del = compare.NoContain_1
|
};
|
}
|
|
/// <summary>
|
/// 生成代码
|
/// </summary>
|
/// <param name="id"></param>
|
/// <returns></returns>
|
[HttpGet("runLocal/{id}")]
|
public async Task<bool> RunLocal(long id)
|
{
|
var info = Info(id);
|
|
var list = info.Databases.Select(x => new GenEntity()
|
{
|
NameSpace = info.NameSpace,
|
ClassName = x.ClassName,
|
TableDesc = x.TableDesc,
|
TableName = x.TableName,
|
DatabaseName = info.DatabaseName,
|
AuthorName = info.AuthorName,
|
BusName = info.BusName,
|
ProName = info.ProName,
|
FormDesign = info.FormDesign
|
}).Distinct(new GenEntityComparer()).ToList();
|
|
list.ForEach(item =>
|
{
|
item.DataBase = info.Databases.ToList();
|
item.Fields = info.Databases.Where(x => x.ClassName == item.ClassName).Select(x => new GenEntity_Field()
|
{
|
ColumnComment = x.Control_Label,
|
DbParam = x.DbParam,
|
FieldName = x.FieldName,
|
IsRequired = x.IsRequired == null ? false : x.IsRequired.Value,
|
NetType = x.DbTypeName,
|
DtoNetType = x.DtoTypeName == null ? x.DbTypeName : x.DtoTypeName,
|
}).ToList();
|
});
|
|
string TableName = string.Empty;
|
|
list.ForEach(item =>
|
{
|
TableName = item.TableName;
|
|
var AllDynamic = item.FormDesign.ConvertToFront().AllFront().AllDynamic();
|
Dictionary<string, List<string>> dynamicData = new Dictionary<string, List<string>>();
|
List<Front_Dynamic> dynamicLoad_dict = new List<Front_Dynamic>();
|
|
AllDynamic.Where(x => x.Dynamic).Select(x => x.DynamicKey).ToList().ForEach(item =>
|
{
|
dynamicData.Add(item, new List<string>());
|
var d = item.GetDynamic();
|
if (d != null)
|
{
|
if (d.Head == "dict")
|
{
|
dynamicLoad_dict.Add(d);
|
}
|
}
|
});
|
|
List<CodeGenConfig> tableFieldList = item.DataBase.Select(x => new CodeGenConfig()
|
{
|
ColumnComment = x.Control_Label,
|
ColumnKey = String.Empty,
|
ColumnName = x.FieldName,
|
DataType = x.DbTypeName,
|
DtoNetType = x.DtoTypeName,
|
NetType = x.DbTypeName,
|
OriginalColumnName = x.FieldName,
|
QueryType = x.QueryType,
|
QueryWhether = x.QueryWhether.HasValue && x.QueryWhether.Value ? YesOrNot.Y.ToString() : YesOrNot.N.ToString(),
|
WhetherAddUpdate = x.WhetherAddUpdate.HasValue && x.WhetherAddUpdate.Value ? YesOrNot.Y.ToString() : YesOrNot.N.ToString(),
|
WhetherOrderBy = x.WhetherOrderBy.HasValue && x.WhetherOrderBy.Value ? YesOrNot.Y.ToString() : YesOrNot.N.ToString(),
|
WhetherRequired = x.IsRequired.HasValue && x.IsRequired.Value ? YesOrNot.Y.ToString() : YesOrNot.N.ToString(),
|
WhetherTable = x.WhetherTable.HasValue && x.WhetherTable.Value ? YesOrNot.Y.ToString() : YesOrNot.N.ToString(),
|
WhetherRetract = YesOrNot.N.ToString(),
|
WhetherCommon = YesOrNot.Y.ToString(),
|
NetTypeIsNullLable = String.Empty,
|
Id = 0,
|
FkEntityName = null,
|
FkColumnNetType = null,
|
FkColumnName = null,
|
EffectType = null,
|
DictTypeCode = null,
|
CodeGen = null,
|
CodeGenId = 0,
|
}).ToList();
|
|
tableFieldList.Add(new CodeGenConfig()
|
{
|
ColumnComment = "Id",
|
ColumnKey = "True",
|
ColumnName = "Id",
|
DataType = null,
|
DtoNetType = "long",
|
NetType = "long",
|
OriginalColumnName = "Id",
|
QueryType = null,
|
QueryWhether = YesOrNot.N.ToString(),
|
WhetherAddUpdate = YesOrNot.N.ToString(),
|
WhetherOrderBy = YesOrNot.N.ToString(),
|
WhetherRequired = YesOrNot.N.ToString(),
|
WhetherTable = YesOrNot.N.ToString(),
|
WhetherRetract = YesOrNot.N.ToString(),
|
WhetherCommon = YesOrNot.Y.ToString(),
|
NetTypeIsNullLable = String.Empty,
|
Id = 0,
|
FkEntityName = null,
|
FkColumnNetType = null,
|
FkColumnName = null,
|
EffectType = null,
|
DictTypeCode = null,
|
CodeGen = null,
|
CodeGenId = 0,
|
});
|
|
tableFieldList.ForEach(u =>
|
{
|
switch (u.NetType.ToLower())
|
{
|
case "int":
|
case "int32":
|
case "long":
|
case "guid":
|
case "decimal":
|
case "datetime":
|
case "datetimeoffset":
|
u.NetTypeIsNullLable = "?";
|
break;
|
}
|
u.OriginalColumnName = u.ColumnName;
|
});
|
|
var queryWhetherList = tableFieldList.Where(u => u.QueryWhether == YesOrNot.Y.ToString()).ToList(); // 前端查询集合
|
|
var ss = App.Configuration.GetSection("CodeGenConfig");
|
|
int config_index = 0;
|
string ResultHead = "@model iWare.Wms.Application.Service.System.LowCode.Dto.Front_CodeGenerate\r\n";
|
while (!string.IsNullOrEmpty(_configuration.GetValue<string>($"LowCodeConfig:{config_index}:Name")))
|
{
|
var config_data = new
|
{
|
HostPath = App.WebHostEnvironment.WebRootPath,
|
CodePath = new DirectoryInfo(App.WebHostEnvironment.ContentRootPath).Parent.FullName,
|
FrontendPath = new DirectoryInfo(App.WebHostEnvironment.ContentRootPath).Parent.Parent.FullName + @"\iwara-wms-web\src\views\main\",
|
ApiJsPath = new DirectoryInfo(App.WebHostEnvironment.ContentRootPath).Parent.Parent.FullName + @"\iwara-wms-web\src\api\modular\main\",
|
NameSpace = item.NameSpace,
|
ClassName = item.ClassName
|
};
|
var SourceFile = StringTemplate.Format(_configuration.GetValue<string>($"LowCodeConfig:{config_index}:Source:File"), config_data);
|
var TargetFile = StringTemplate.Format(_configuration.GetValue<string>($"LowCodeConfig:{config_index}:Target:File"), config_data);
|
var TargetDir = StringTemplate.Format(_configuration.GetValue<string>($"LowCodeConfig:{config_index}:Target:Dir"), config_data);
|
var IsFrontend = _configuration.GetValue<bool?>($"LowCodeConfig:{config_index}:IsFrontend");
|
|
if (IsFrontend.HasValue && IsFrontend.Value == true) // 适应前端首字母小写
|
{
|
tableFieldList.ForEach(u =>
|
{
|
u.ColumnName = u.ColumnName.Substring(0, 1).ToLower() + u.ColumnName[1..];
|
});
|
}
|
|
#region 执行代码生成
|
|
var tContent = File.ReadAllText(SourceFile);
|
|
if (tContent.IndexOf(ResultHead) == 0) tContent = tContent.Substring(ResultHead.Length);
|
|
var data = new
|
{
|
TableName = item.TableName,
|
NameSpace = item.NameSpace,
|
Fields = item.Fields,
|
ClassName = item.ClassName,
|
TableDesc = item.TableDesc,
|
DatabaseName = item.DatabaseName,
|
AuthorName = item.AuthorName,
|
BusName = item.BusName,
|
ProName = item.ProName,
|
CamelizeClassName = item.TableName.Substring(0, 1).ToLower() + item.TableName[1..], //首字母小写
|
QueryWhetherList = queryWhetherList,
|
TableField = tableFieldList,
|
LowCodeId = id,
|
FormDesign = item.FormDesign,
|
DynamicData = JsonConvert.SerializeObject(dynamicData),
|
DynamicLoad_Dict = dynamicLoad_dict,
|
IsFile = tableFieldList.Where(x => x.DtoNetType.Contains("Front_FileDto")).Any(),
|
FileTableField = tableFieldList.Where(x => x.DtoNetType.Contains("Front_FileDto")).ToList()
|
};
|
|
var tResult = _viewEngine.RunCompileFromCached(tContent, data);
|
if (!Directory.Exists(TargetDir)) Directory.CreateDirectory(TargetDir);
|
File.WriteAllText($"{TargetDir}{TargetFile}", tResult, Encoding.UTF8);
|
|
#endregion 执行代码生成
|
|
config_index++;
|
}
|
});
|
|
if (!string.IsNullOrEmpty(TableName))
|
{
|
await AddMenu(info.DatabaseName.Substring(0, 5), TableName, info.BusName, info.MenuApplication, info.MenuPid);
|
}
|
|
return true;
|
}
|
|
private async Task AddMenu(string menucodePre, string className, string busName, string application, long pid)
|
{
|
// 定义菜单编码前缀
|
var codePrefix = menucodePre + "_" + className.ToLower();//改为取数据库定位器的前五个字母方便区分业务 //"dilon_" + className.ToLower();
|
|
// 先删除该表已生成的菜单列表
|
var menus = await _sysMenuRep.DetachedEntities.Where(u => u.Code == codePrefix || u.Code.StartsWith(codePrefix + "_")).ToListAsync();
|
await _sysMenuRep.DeleteAsync(menus);
|
|
// 如果 pid 为 0 说明为顶级菜单, 需要创建顶级目录
|
if (pid == 0)
|
{
|
// 目录
|
var menuType0 = new SysMenu
|
{
|
Pid = 0,
|
Pids = "[0],",
|
Name = busName + "管理",
|
Code = codePrefix,
|
Type = MenuType.DIR,
|
Icon = "robot",
|
Router = "/" + className.ToLower(),
|
Component = "PageView",
|
Application = application
|
};
|
pid = _sysMenuRep.InsertNowAsync(menuType0).GetAwaiter().GetResult().Entity.Id;
|
}
|
// 由于后续菜单会有修改, 需要判断下 pid 是否存在, 不存在报错
|
else if (!await _sysMenuRep.DetachedEntities.AnyAsync(e => e.Id == pid))
|
throw Oops.Oh(ErrorCode.D1505);
|
|
// 菜单
|
var menuType1 = new SysMenu
|
{
|
Pid = pid,
|
Pids = "[0],[" + pid + "],",
|
Name = busName + "管理",
|
Code = codePrefix + "_mgr",
|
Type = MenuType.MENU,
|
Router = "/" + className.ToLower(),
|
Component = "main/" + className + "/index",
|
Application = application,
|
OpenType = MenuOpenType.COMPONENT
|
};
|
var pid1 = _sysMenuRep.InsertNowAsync(menuType1).GetAwaiter().GetResult().Entity.Id;
|
|
// 按钮-page
|
var menuType2 = new SysMenu
|
{
|
Pid = pid1,
|
Pids = "[0],[" + pid + "],[" + pid1 + "],",
|
Name = busName + "查询",
|
Code = codePrefix + "_mgr_page",
|
Type = MenuType.BTN,
|
Permission = className + ":page",
|
Application = application,
|
}.InsertAsync();
|
|
// 按钮-detail
|
var menuType2_1 = new SysMenu
|
{
|
Pid = pid1,
|
Pids = "[0],[" + pid + "],[" + pid1 + "],",
|
Name = busName + "详情",
|
Code = codePrefix + "_mgr_detail",
|
Type = MenuType.BTN,
|
Permission = className + ":detail",
|
Application = application,
|
}.InsertAsync();
|
|
// 按钮-add
|
var menuType2_2 = new SysMenu
|
{
|
Pid = pid1,
|
Pids = "[0],[" + pid + "],[" + pid1 + "],",
|
Name = busName + "增加",
|
Code = codePrefix + "_mgr_add",
|
Type = MenuType.BTN,
|
Permission = className + ":add",
|
Application = application,
|
}.InsertAsync();
|
|
// 按钮-delete
|
var menuType2_3 = new SysMenu
|
{
|
Pid = pid1,
|
Pids = "[0],[" + pid + "],[" + pid1 + "],",
|
Name = busName + "删除",
|
Code = codePrefix + "_mgr_delete",
|
Type = MenuType.BTN,
|
Permission = className + ":delete",
|
Application = application,
|
}.InsertAsync();
|
|
// 按钮-edit
|
var menuType2_4 = new SysMenu
|
{
|
Pid = pid1,
|
Pids = "[0],[" + pid + "],[" + pid1 + "],",
|
Name = busName + "编辑",
|
Code = codePrefix + "_mgr_edit",
|
Type = MenuType.BTN,
|
Permission = className + ":edit",
|
Application = application,
|
}.InsertAsync();
|
}
|
|
private List<string> GetTemplatePathList()
|
{
|
var templatePath = App.WebHostEnvironment.WebRootPath + @"\Template\";
|
return new List<string>()
|
{
|
templatePath + "Entity.cs.cshtml"
|
};
|
}
|
|
/// <summary>
|
/// 设置生成文件路径
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
private List<string> GetTargetPathList(GenEntity input)
|
{
|
var backendPath = new DirectoryInfo(App.WebHostEnvironment.ContentRootPath).Parent.FullName + @"\" + input.NameSpace + @"\Entity\";
|
var outputPath = backendPath + @"\" + input.ClassName + ".cs";
|
|
return new List<string>()
|
{
|
outputPath
|
};
|
}
|
}
|
}
|
