SysCodeGenService.cs 36 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856
  1. // Admin.NET 项目的版权、商标、专利和其他相关权利均受相应法律法规的保护。使用本项目应遵守相关法律法规和许可证的要求。
  2. //
  3. // 本项目主要遵循 MIT 许可证和 Apache 许可证(版本 2.0)进行分发和使用。许可证位于源代码树根目录中的 LICENSE-MIT 和 LICENSE-APACHE 文件。
  4. //
  5. // 不得利用本项目从事危害国家安全、扰乱社会秩序、侵犯他人合法权益等法律法规禁止的活动!任何基于本项目二次开发而产生的一切法律纠纷和责任,我们不承担任何责任!
  6. using System.IO.Compression;
  7. using NewLife.Serialization;
  8. namespace Admin.NET.Core.Service;
  9. /// <summary>
  10. /// 系统代码生成器服务 🧩
  11. /// </summary>
  12. [ApiDescriptionSettings(Order = 270)]
  13. public class SysCodeGenService : IDynamicApiController, ITransient
  14. {
  15. private readonly ISqlSugarClient _db;
  16. private readonly SysCodeGenConfigService _codeGenConfigService;
  17. private readonly IViewEngine _viewEngine;
  18. private readonly CodeGenOptions _codeGenOptions;
  19. public SysCodeGenService(ISqlSugarClient db,
  20. SysCodeGenConfigService codeGenConfigService,
  21. IViewEngine viewEngine,
  22. IOptions<CodeGenOptions> codeGenOptions)
  23. {
  24. _db = db;
  25. _codeGenConfigService = codeGenConfigService;
  26. _viewEngine = viewEngine;
  27. _codeGenOptions = codeGenOptions.Value;
  28. }
  29. /// <summary>
  30. /// 获取代码生成分页列表 🔖
  31. /// </summary>
  32. /// <param name="input"></param>
  33. /// <returns></returns>
  34. [DisplayName("获取代码生成分页列表")]
  35. public async Task<SqlSugarPagedList<SysCodeGen>> Page(CodeGenInput input)
  36. {
  37. return await _db.Queryable<SysCodeGen>()
  38. .WhereIF(!string.IsNullOrWhiteSpace(input.TableName), u => u.TableName.Contains(input.TableName.Trim()))
  39. .WhereIF(!string.IsNullOrWhiteSpace(input.BusName), u => u.BusName.Contains(input.BusName.Trim()))
  40. .ToPagedListAsync(input.Page, input.PageSize);
  41. }
  42. /// <summary>
  43. /// 增加代码生成 🔖
  44. /// </summary>
  45. /// <param name="input"></param>
  46. /// <returns></returns>
  47. [ApiDescriptionSettings(Name = "Add"), HttpPost]
  48. [DisplayName("增加代码生成")]
  49. public async Task AddCodeGen(AddCodeGenInput input)
  50. {
  51. var isExist = await _db.Queryable<SysCodeGen>().Where(u => u.TableName == input.TableName).AnyAsync();
  52. if (isExist)
  53. throw Oops.Oh(ErrorCodeEnum.D1400);
  54. var codeGen = input.Adapt<SysCodeGen>();
  55. var newCodeGen = await _db.Insertable(codeGen).ExecuteReturnEntityAsync();
  56. // 增加配置表
  57. _codeGenConfigService.AddList(GetColumnList(input), newCodeGen);
  58. }
  59. /// <summary>
  60. /// 更新代码生成 🔖
  61. /// </summary>
  62. /// <param name="input"></param>
  63. /// <returns></returns>
  64. [ApiDescriptionSettings(Name = "Update"), HttpPost]
  65. [DisplayName("更新代码生成")]
  66. public async Task UpdateCodeGen(UpdateCodeGenInput input)
  67. {
  68. var isExist = await _db.Queryable<SysCodeGen>().AnyAsync(u => u.TableName == input.TableName && u.Id != input.Id);
  69. if (isExist)
  70. throw Oops.Oh(ErrorCodeEnum.D1400);
  71. var codeGen = input.Adapt<SysCodeGen>();
  72. await _db.Updateable(codeGen).ExecuteCommandAsync();
  73. // 更新配置表
  74. await _codeGenConfigService.DeleteCodeGenConfig(codeGen.Id);
  75. _codeGenConfigService.AddList(GetColumnList(input.Adapt<AddCodeGenInput>()), codeGen);
  76. }
  77. /// <summary>
  78. /// 删除代码生成 🔖
  79. /// </summary>
  80. /// <param name="inputs"></param>
  81. /// <returns></returns>
  82. [ApiDescriptionSettings(Name = "Delete"), HttpPost]
  83. [DisplayName("删除代码生成")]
  84. public async Task DeleteCodeGen(List<DeleteCodeGenInput> inputs)
  85. {
  86. if (inputs == null || inputs.Count < 1) return;
  87. var codeGenConfigTaskList = new List<Task>();
  88. inputs.ForEach(u =>
  89. {
  90. _db.Deleteable<SysCodeGen>().In(u.Id).ExecuteCommand();
  91. // 删除配置表
  92. codeGenConfigTaskList.Add(_codeGenConfigService.DeleteCodeGenConfig(u.Id));
  93. });
  94. await Task.WhenAll(codeGenConfigTaskList);
  95. }
  96. /// <summary>
  97. /// 获取代码生成详情 🔖
  98. /// </summary>
  99. /// <param name="input"></param>
  100. /// <returns></returns>
  101. [DisplayName("获取代码生成详情")]
  102. public async Task<SysCodeGen> GetDetail([FromQuery] QueryCodeGenInput input)
  103. {
  104. return await _db.Queryable<SysCodeGen>().SingleAsync(u => u.Id == input.Id);
  105. }
  106. /// <summary>
  107. /// 获取数据库库集合 🔖
  108. /// </summary>
  109. /// <returns></returns>
  110. [DisplayName("获取数据库库集合")]
  111. public async Task<List<DatabaseOutput>> GetDatabaseList()
  112. {
  113. var dbConfigs = App.GetOptions<DbConnectionOptions>().ConnectionConfigs;
  114. return await Task.FromResult(dbConfigs.Adapt<List<DatabaseOutput>>());
  115. }
  116. /// <summary>
  117. /// 获取数据库表(实体)集合 🔖
  118. /// </summary>
  119. /// <returns></returns>
  120. [DisplayName("获取数据库表(实体)集合")]
  121. public async Task<List<TableOutput>> GetTableList(string configId = SqlSugarConst.MainConfigId)
  122. {
  123. var provider = _db.AsTenant().GetConnectionScope(configId);
  124. var dbTableInfos = provider.DbMaintenance.GetTableInfoList(false); // 不能走缓存,否则切库不起作用
  125. var config = App.GetOptions<DbConnectionOptions>().ConnectionConfigs.FirstOrDefault(u => configId.Equals(u.ConfigId));
  126. var dbTableNames = dbTableInfos.Select(u => u.Name.ToLower()).ToList();
  127. IEnumerable<EntityInfo> entityInfos = await GetEntityInfos();
  128. var tableOutputList = new List<TableOutput>();
  129. foreach (var item in entityInfos)
  130. {
  131. var table = dbTableInfos.FirstOrDefault(u => u.Name.ToLower() == (config.DbSettings.EnableUnderLine ? UtilMethods.ToUnderLine(item.DbTableName) : item.DbTableName).ToLower());
  132. if (table == null) continue;
  133. tableOutputList.Add(new TableOutput
  134. {
  135. ConfigId = configId,
  136. EntityName = item.EntityName,
  137. TableName = table.Name,
  138. TableComment = item.TableDescription
  139. });
  140. }
  141. return tableOutputList;
  142. }
  143. /// <summary>
  144. /// 根据表名获取列集合 🔖
  145. /// </summary>
  146. /// <returns></returns>
  147. [DisplayName("根据表名获取列集合")]
  148. public List<ColumnOuput> GetColumnListByTableName([Required] string tableName, string configId = SqlSugarConst.MainConfigId)
  149. {
  150. // 切库---多库代码生成用
  151. var provider = _db.AsTenant().GetConnectionScope(configId);
  152. var config = App.GetOptions<DbConnectionOptions>().ConnectionConfigs.FirstOrDefault(u => u.ConfigId.ToString() == configId);
  153. // 获取实体类型属性
  154. var entityType = provider.DbMaintenance.GetTableInfoList(false).FirstOrDefault(u => u.Name == tableName);
  155. if (entityType == null) return null;
  156. var entityBasePropertyNames = _codeGenOptions.EntityBaseColumn[nameof(EntityTenant)];
  157. // 按原始类型的顺序获取所有实体类型属性(不包含导航属性,会返回null)
  158. return provider.DbMaintenance.GetColumnInfosByTableName(entityType.Name).Select(u => new ColumnOuput
  159. {
  160. ColumnName = config.DbSettings.EnableUnderLine ? CodeGenUtil.CamelColumnName(u.DbColumnName, entityBasePropertyNames) : u.DbColumnName,
  161. ColumnKey = u.IsPrimarykey.ToString(),
  162. DataType = u.DataType.ToString(),
  163. NetType = CodeGenUtil.ConvertDataType(u, provider.CurrentConnectionConfig.DbType),
  164. ColumnComment = u.ColumnDescription
  165. }).ToList();
  166. }
  167. /// <summary>
  168. /// 获取数据表列(实体属性)集合
  169. /// </summary>
  170. /// <returns></returns>
  171. private List<ColumnOuput> GetColumnList([FromQuery] AddCodeGenInput input)
  172. {
  173. var entityType = GetEntityInfos().GetAwaiter().GetResult().FirstOrDefault(u => u.EntityName == input.TableName);
  174. if (entityType == null)
  175. return null;
  176. var config = App.GetOptions<DbConnectionOptions>().ConnectionConfigs.FirstOrDefault(u => u.ConfigId.ToString() == input.ConfigId);
  177. var dbTableName = config.DbSettings.EnableUnderLine ? UtilMethods.ToUnderLine(entityType.DbTableName) : entityType.DbTableName;
  178. // 切库---多库代码生成用
  179. var provider = _db.AsTenant().GetConnectionScope(!string.IsNullOrEmpty(input.ConfigId) ? input.ConfigId : SqlSugarConst.MainConfigId);
  180. var entityBasePropertyNames = _codeGenOptions.EntityBaseColumn[nameof(EntityTenant)];
  181. var columnInfos = provider.DbMaintenance.GetColumnInfosByTableName(dbTableName, false);
  182. var result = columnInfos.Select(u => new ColumnOuput
  183. {
  184. // 转下划线后的列名需要再转回来(暂时不转)
  185. //ColumnName = config.DbSettings.EnableUnderLine ? CodeGenUtil.CamelColumnName(u.DbColumnName, entityBasePropertyNames) : u.DbColumnName,
  186. ColumnName = u.DbColumnName,
  187. ColumnLength = u.Length,
  188. IsPrimarykey = u.IsPrimarykey,
  189. IsNullable = u.IsNullable,
  190. ColumnKey = u.IsPrimarykey.ToString(),
  191. NetType = CodeGenUtil.ConvertDataType(u, provider.CurrentConnectionConfig.DbType),
  192. DataType = CodeGenUtil.ConvertDataType(u, provider.CurrentConnectionConfig.DbType),
  193. ColumnComment = string.IsNullOrWhiteSpace(u.ColumnDescription) ? u.DbColumnName : u.ColumnDescription
  194. }).ToList();
  195. // 获取实体的属性信息,赋值给PropertyName属性(CodeFirst模式应以PropertyName为实际使用名称)
  196. var entityProperties = entityType.Type.GetProperties();
  197. for (int i = result.Count - 1; i >= 0; i--)
  198. {
  199. var columnOutput = result[i];
  200. // 先找自定义字段名的,如果找不到就再找自动生成字段名的(并且过滤掉没有SugarColumn的属性)
  201. var propertyInfo = entityProperties.FirstOrDefault(u => (u.GetCustomAttribute<SugarColumn>()?.ColumnName ?? "").ToLower() == columnOutput.ColumnName.ToLower()) ??
  202. entityProperties.FirstOrDefault(u => u.GetCustomAttribute<SugarColumn>() != null && u.Name.ToLower() == (config.DbSettings.EnableUnderLine
  203. ? CodeGenUtil.CamelColumnName(columnOutput.ColumnName, entityBasePropertyNames).ToLower()
  204. : columnOutput.ColumnName.ToLower()));
  205. if (propertyInfo != null)
  206. {
  207. columnOutput.PropertyName = propertyInfo.Name;
  208. columnOutput.ColumnComment = propertyInfo.GetCustomAttribute<SugarColumn>().ColumnDescription;
  209. var propertyType = Nullable.GetUnderlyingType(propertyInfo.PropertyType);
  210. if (propertyInfo.PropertyType.IsEnum || (propertyType?.IsEnum ?? false))
  211. {
  212. columnOutput.DictTypeCode = (propertyType ?? propertyInfo.PropertyType).Name;
  213. }
  214. else
  215. {
  216. var dict = propertyInfo.GetCustomAttribute<DictAttribute>();
  217. if (dict != null) columnOutput.DictTypeCode = dict.DictTypeCode;
  218. }
  219. }
  220. else
  221. {
  222. result.RemoveAt(i); // 移除没有定义此属性的字段
  223. }
  224. }
  225. return result;
  226. }
  227. /// <summary>
  228. /// 获取库表信息
  229. /// </summary>
  230. /// <returns></returns>
  231. private async Task<IEnumerable<EntityInfo>> GetEntityInfos()
  232. {
  233. var entityInfos = new List<EntityInfo>();
  234. var type = typeof(SugarTable);
  235. var types = new List<Type>();
  236. if (_codeGenOptions.EntityAssemblyNames != null)
  237. {
  238. var assemblies = AppDomain.CurrentDomain.GetAssemblies();
  239. foreach (var assembly in assemblies)
  240. {
  241. var assemblyName = assembly.GetName().Name;
  242. if (_codeGenOptions.EntityAssemblyNames.Contains(assemblyName) || _codeGenOptions.EntityAssemblyNames.Any(name => assemblyName.Contains(name)))
  243. {
  244. Assembly asm = Assembly.Load(assemblyName);
  245. types.AddRange(asm.GetExportedTypes().ToList());
  246. }
  247. }
  248. }
  249. bool IsMyAttribute(Attribute[] o)
  250. {
  251. foreach (Attribute a in o)
  252. {
  253. if (a.GetType() == type)
  254. return true;
  255. }
  256. return false;
  257. }
  258. Type[] cosType = types.Where(o =>
  259. {
  260. return IsMyAttribute(Attribute.GetCustomAttributes(o, true));
  261. }
  262. ).ToArray();
  263. foreach (var ct in cosType)
  264. {
  265. var sugarAttribute = ct.GetCustomAttributes(type, true)?.FirstOrDefault();
  266. var des = ct.GetCustomAttributes(typeof(DescriptionAttribute), true);
  267. var description = "";
  268. if (des.Length > 0)
  269. {
  270. description = ((DescriptionAttribute)des[0]).Description;
  271. }
  272. entityInfos.Add(new EntityInfo()
  273. {
  274. EntityName = ct.Name,
  275. DbTableName = sugarAttribute == null ? ct.Name : ((SugarTable)sugarAttribute).TableName,
  276. TableDescription = sugarAttribute == null ? description : ((SugarTable)sugarAttribute).TableDescription,
  277. Type = ct
  278. });
  279. }
  280. return await Task.FromResult(entityInfos);
  281. }
  282. /// <summary>
  283. /// 获取程序保存位置 🔖
  284. /// </summary>
  285. /// <returns></returns>
  286. [DisplayName("获取程序保存位置")]
  287. public List<string> GetApplicationNamespaces()
  288. {
  289. return _codeGenOptions.BackendApplicationNamespaces;
  290. }
  291. /// <summary>
  292. /// 代码生成到本地 🔖
  293. /// </summary>
  294. /// <returns></returns>
  295. [DisplayName("代码生成到本地")]
  296. public async Task<dynamic> RunLocal(SysCodeGen input)
  297. {
  298. if (string.IsNullOrEmpty(input.GenerateType))
  299. input.GenerateType = "200";
  300. // 先删除该表已生成的菜单列表
  301. List<string> targetPathList;
  302. var zipPath = Path.Combine(App.WebHostEnvironment.WebRootPath, "CodeGen", input.TableName);
  303. if (input.GenerateType.StartsWith('1'))
  304. {
  305. targetPathList = GetZipPathList(input);
  306. if (Directory.Exists(zipPath))
  307. Directory.Delete(zipPath, true);
  308. }
  309. else
  310. targetPathList = GetTargetPathList(input);
  311. var tableFieldList = await _codeGenConfigService.GetList(new CodeGenConfig() { CodeGenId = input.Id }); // 字段集合
  312. var queryWhetherList = tableFieldList.Where(u => u.QueryWhether == YesNoEnum.Y.ToString()).ToList(); // 前端查询集合
  313. var joinTableList = tableFieldList.Where(u => u.EffectType == "Upload" || u.EffectType == "ForeignKey" || u.EffectType == "ApiTreeSelector").ToList(); // 需要连表查询的字段
  314. (string joinTableNames, string lowerJoinTableNames) = GetJoinTableStr(joinTableList); // 获取连表的实体名和别名
  315. var data = new CustomViewEngine(_db)
  316. {
  317. ConfigId = input.ConfigId,
  318. AuthorName = input.AuthorName,
  319. BusName = input.BusName,
  320. NameSpace = input.NameSpace,
  321. ClassName = input.TableName,
  322. PagePath = input.PagePath,
  323. TableUniqueList = input.TableUniqueConfig?.ToJsonEntity<List<TableUniqueConfigItem>>() ?? new(),
  324. ProjectLastName = input.NameSpace.Split('.').Last(),
  325. QueryWhetherList = queryWhetherList,
  326. TableField = tableFieldList,
  327. IsJoinTable = joinTableList.Count > 0,
  328. IsUpload = joinTableList.Where(u => u.EffectType == "Upload").Any(),
  329. PrintType = input.PrintType,
  330. PrintName = input.PrintName,
  331. };
  332. // 模板目录
  333. var templatePathList = GetTemplatePathList(input);
  334. var templatePath = Path.Combine(App.WebHostEnvironment.WebRootPath, "template");
  335. for (var i = 0; i < templatePathList.Count; i++)
  336. {
  337. var templateFilePath = Path.Combine(templatePath, templatePathList[i]);
  338. if (!File.Exists(templateFilePath)) continue;
  339. var tContent = File.ReadAllText(templateFilePath);
  340. var tResult = await _viewEngine.RunCompileFromCachedAsync(tContent, data, builderAction: builder =>
  341. {
  342. builder.AddAssemblyReferenceByName("System.Linq");
  343. builder.AddAssemblyReferenceByName("System.Collections");
  344. builder.AddAssemblyReferenceByName("System.Text.RegularExpressions");
  345. builder.AddUsing("System.Text.RegularExpressions");
  346. builder.AddUsing("System.Collections.Generic");
  347. builder.AddUsing("System.Linq");
  348. });
  349. var dirPath = new DirectoryInfo(targetPathList[i]).Parent.FullName;
  350. if (!Directory.Exists(dirPath))
  351. Directory.CreateDirectory(dirPath);
  352. File.WriteAllText(targetPathList[i], tResult, Encoding.UTF8);
  353. }
  354. if (input.GenerateMenu)
  355. await AddMenu(input.TableName, input.BusName, input.MenuPid ?? 0, input.MenuIcon, input.PagePath, tableFieldList);
  356. // 非ZIP压缩返回空
  357. if (!input.GenerateType.StartsWith('1'))
  358. return null;
  359. else
  360. {
  361. string downloadPath = zipPath + ".zip";
  362. // 判断是否存在同名称文件
  363. if (File.Exists(downloadPath))
  364. File.Delete(downloadPath);
  365. ZipFile.CreateFromDirectory(zipPath, downloadPath);
  366. return new { url = $"{App.HttpContext.Request.Scheme}://{App.HttpContext.Request.Host.Value}/codeGen/{input.TableName}.zip" };
  367. }
  368. }
  369. /// <summary>
  370. /// 获取代码生成预览 🔖
  371. /// </summary>
  372. /// <returns></returns>
  373. [DisplayName("获取代码生成预览")]
  374. public async Task<Dictionary<string, string>> Preview(SysCodeGen input)
  375. {
  376. var tableFieldList = await _codeGenConfigService.GetList(new CodeGenConfig() { CodeGenId = input.Id }); // 字段集合
  377. var queryWhetherList = tableFieldList.Where(u => u.QueryWhether == YesNoEnum.Y.ToString()).ToList(); // 前端查询集合
  378. var joinTableList = tableFieldList.Where(u => u.EffectType == "Upload" || u.EffectType == "ForeignKey" || u.EffectType == "ApiTreeSelector").ToList(); // 需要连表查询的字段
  379. (string joinTableNames, string lowerJoinTableNames) = GetJoinTableStr(joinTableList); // 获取连表的实体名和别名
  380. var data = new CustomViewEngine(_db)
  381. {
  382. ConfigId = input.ConfigId,
  383. AuthorName = input.AuthorName,
  384. BusName = input.BusName,
  385. NameSpace = input.NameSpace,
  386. ClassName = input.TableName,
  387. PagePath = input.PagePath,
  388. TableUniqueList = input.TableUniqueConfig?.ToJsonEntity<List<TableUniqueConfigItem>>() ?? new(),
  389. ProjectLastName = input.NameSpace.Split('.').Last(),
  390. QueryWhetherList = queryWhetherList,
  391. TableField = tableFieldList,
  392. IsJoinTable = joinTableList.Count > 0,
  393. IsUpload = joinTableList.Where(u => u.EffectType == "Upload").Any(),
  394. PrintType = input.PrintType,
  395. PrintName = input.PrintName,
  396. };
  397. // 获取模板文件并替换
  398. var templatePathList = GetTemplatePathList();
  399. var templatePath = Path.Combine(App.WebHostEnvironment.WebRootPath, "template");
  400. var result = new Dictionary<string, string>();
  401. for (var i = 0; i < templatePathList.Count; i++)
  402. {
  403. var templateFilePath = Path.Combine(templatePath, templatePathList[i]);
  404. if (!File.Exists(templateFilePath)) continue;
  405. var tContent = File.ReadAllText(templateFilePath);
  406. var tResult = await _viewEngine.RunCompileFromCachedAsync(tContent, data, builderAction: builder =>
  407. {
  408. builder.AddAssemblyReferenceByName("System.Linq");
  409. builder.AddAssemblyReferenceByName("System.Collections");
  410. builder.AddAssemblyReferenceByName("System.Text.RegularExpressions");
  411. builder.AddUsing("System.Text.RegularExpressions");
  412. builder.AddUsing("System.Collections.Generic");
  413. builder.AddUsing("System.Linq");
  414. });
  415. result.Add(templatePathList[i]?.TrimEnd(".vm"), tResult);
  416. }
  417. return result;
  418. }
  419. /// <summary>
  420. /// 获取连表的实体名和别名
  421. /// </summary>
  422. /// <param name="configs"></param>
  423. /// <returns></returns>
  424. private static (string, string) GetJoinTableStr(List<CodeGenConfig> configs)
  425. {
  426. var uploads = configs.Where(u => u.EffectType == "Upload").ToList();
  427. var fks = configs.Where(u => u.EffectType == "ForeignKey").ToList();
  428. string str = ""; // <Order, OrderItem, Custom>
  429. string lowerStr = ""; // (o, i, c)
  430. foreach (var item in uploads)
  431. {
  432. lowerStr += "sysFile_FK_" + item.LowerPropertyName + ",";
  433. str += "SysFile,";
  434. }
  435. foreach (var item in fks)
  436. {
  437. lowerStr += item.LowerFkEntityName + "_FK_" + item.LowerFkColumnName + ",";
  438. str += item.FkEntityName + ",";
  439. }
  440. return (str.TrimEnd(','), lowerStr.TrimEnd(','));
  441. }
  442. /// <summary>
  443. /// 增加菜单
  444. /// </summary>
  445. /// <param name="className"></param>
  446. /// <param name="busName"></param>
  447. /// <param name="pid"></param>
  448. /// <param name="menuIcon"></param>
  449. /// <param name="pagePath"></param>
  450. /// <param name="tableFieldList"></param>
  451. /// <returns></returns>
  452. private async Task AddMenu(string className, string busName, long pid, string menuIcon, string pagePath, List<CodeGenConfig> tableFieldList)
  453. {
  454. var pPath = string.Empty;
  455. // 若 pid=0 为顶级则创建菜单目录
  456. if (pid == 0)
  457. {
  458. // 目录
  459. var menuType0 = new SysMenu
  460. {
  461. Pid = 0,
  462. Title = busName + "管理",
  463. Type = MenuTypeEnum.Dir,
  464. Icon = "robot",
  465. Path = "/" + className.ToLower(),
  466. Component = "Layout",
  467. };
  468. // 若先前存在则删除本级和下级
  469. var menuList0 = await _db.Queryable<SysMenu>().Where(u => u.Title == menuType0.Title && u.Type == menuType0.Type).ToListAsync();
  470. if (menuList0.Count > 0)
  471. {
  472. var listIds = menuList0.Select(u => u.Id).ToList();
  473. var childlistIds = new List<long>();
  474. foreach (var item in listIds)
  475. {
  476. var childlist = await _db.Queryable<SysMenu>().ToChildListAsync(u => u.Pid, item);
  477. childlistIds.AddRange(childlist.Select(u => u.Id).ToList());
  478. }
  479. listIds.AddRange(childlistIds);
  480. await _db.Deleteable<SysMenu>().Where(u => listIds.Contains(u.Id)).ExecuteCommandAsync();
  481. await _db.Deleteable<SysRoleMenu>().Where(u => listIds.Contains(u.MenuId)).ExecuteCommandAsync();
  482. }
  483. pid = (await _db.Insertable(menuType0).ExecuteReturnEntityAsync()).Id;
  484. }
  485. else
  486. {
  487. var pMenu = await _db.Queryable<SysMenu>().FirstAsync(u => u.Id == pid) ?? throw Oops.Oh(ErrorCodeEnum.D1505);
  488. pPath = pMenu.Path;
  489. }
  490. // 菜单
  491. var menuType = new SysMenu
  492. {
  493. Pid = pid,
  494. Title = busName + "管理",
  495. Name = className[..1].ToLower() + className[1..],
  496. Type = MenuTypeEnum.Menu,
  497. Icon = menuIcon,
  498. Path = pPath + "/" + className.ToLower(),
  499. Component = "/" + pagePath + "/" + className[..1].ToLower() + className[1..] + "/index",
  500. };
  501. // 若先前存在则删除本级和下级
  502. var menuListCurrent = await _db.Queryable<SysMenu>().Where(u => u.Title == menuType.Title && u.Type == menuType.Type).ToListAsync();
  503. if (menuListCurrent.Count > 0)
  504. {
  505. var listIds = menuListCurrent.Select(u => u.Id).ToList();
  506. var childListIds = new List<long>();
  507. foreach (var item in listIds)
  508. {
  509. var childList = await _db.Queryable<SysMenu>().ToChildListAsync(u => u.Pid, item);
  510. childListIds.AddRange(childList.Select(u => u.Id).ToList());
  511. }
  512. listIds.AddRange(childListIds);
  513. await _db.Deleteable<SysMenu>().Where(u => listIds.Contains(u.Id)).ExecuteCommandAsync();
  514. await _db.Deleteable<SysRoleMenu>().Where(u => listIds.Contains(u.MenuId)).ExecuteCommandAsync();
  515. }
  516. var menuPid = (await _db.Insertable(menuType).ExecuteReturnEntityAsync()).Id;
  517. int menuOrder = 100;
  518. // 按钮-page
  519. var menuTypePage = new SysMenu
  520. {
  521. Pid = menuPid,
  522. Title = "查询",
  523. Type = MenuTypeEnum.Btn,
  524. Permission = className[..1].ToLower() + className[1..] + ":page",
  525. OrderNo = menuOrder
  526. };
  527. menuOrder += 10;
  528. // 按钮-detail
  529. var menuTypeDetail = new SysMenu
  530. {
  531. Pid = menuPid,
  532. Title = "详情",
  533. Type = MenuTypeEnum.Btn,
  534. Permission = className[..1].ToLower() + className[1..] + ":detail",
  535. OrderNo = menuOrder
  536. };
  537. menuOrder += 10;
  538. // 按钮-add
  539. var menuTypeAdd = new SysMenu
  540. {
  541. Pid = menuPid,
  542. Title = "增加",
  543. Type = MenuTypeEnum.Btn,
  544. Permission = className[..1].ToLower() + className[1..] + ":add",
  545. OrderNo = menuOrder
  546. };
  547. menuOrder += 10;
  548. // 按钮-delete
  549. var menuTypeDelete = new SysMenu
  550. {
  551. Pid = menuPid,
  552. Title = "删除",
  553. Type = MenuTypeEnum.Btn,
  554. Permission = className[..1].ToLower() + className[1..] + ":delete",
  555. OrderNo = menuOrder
  556. };
  557. menuOrder += 10;
  558. // 按钮-update
  559. var menuTypeUpdate = new SysMenu
  560. {
  561. Pid = menuPid,
  562. Title = "编辑",
  563. Type = MenuTypeEnum.Btn,
  564. Permission = className[..1].ToLower() + className[1..] + ":update",
  565. OrderNo = menuOrder
  566. };
  567. menuOrder += 10;
  568. // 按钮-Status
  569. var menuTypeStatus = new SysMenu
  570. {
  571. Pid = menuPid,
  572. Title = "状态",
  573. Type = MenuTypeEnum.Btn,
  574. Permission = className[..1].ToLower() + className[1..] + ":setStatus",
  575. OrderNo = menuOrder
  576. };
  577. menuOrder += 10;
  578. // 按钮-batchDelete
  579. var menuTypeBatchDelete = new SysMenu
  580. {
  581. Pid = menuPid,
  582. Title = "批量删除",
  583. Type = MenuTypeEnum.Btn,
  584. Permission = className[..1].ToLower() + className[1..] + ":batchDelete",
  585. OrderNo = menuOrder
  586. };
  587. menuOrder += 10;
  588. // 按钮-print
  589. var menuTypePrint = new SysMenu
  590. {
  591. Pid = menuPid,
  592. Title = "打印",
  593. Type = MenuTypeEnum.Btn,
  594. Permission = className[..1].ToLower() + className[1..] + ":print",
  595. OrderNo = menuOrder
  596. };
  597. menuOrder += 10;
  598. // 按钮-import
  599. var menuTypeImport = new SysMenu
  600. {
  601. Pid = menuPid,
  602. Title = "导入",
  603. Type = MenuTypeEnum.Btn,
  604. Permission = className[..1].ToLower() + className[1..] + ":import",
  605. OrderNo = menuOrder
  606. };
  607. menuOrder += 10;
  608. // 按钮-export
  609. var menuTypeExport = new SysMenu
  610. {
  611. Pid = menuPid,
  612. Title = "导出",
  613. Type = MenuTypeEnum.Btn,
  614. Permission = className[..1].ToLower() + className[1..] + ":export",
  615. OrderNo = menuOrder
  616. };
  617. menuOrder += 10;
  618. var menuList = new List<SysMenu> { menuTypePage, menuTypeDetail, menuTypeAdd, menuTypeStatus, menuTypeDelete, menuTypeBatchDelete, menuTypeUpdate, menuTypePrint, menuTypeImport, menuTypeExport };
  619. // 加入ForeignKey、Upload、ApiTreeSelector 等接口的权限
  620. // 在生成表格时,有些字段只是查询时显示,不需要填写(WhetherAddUpdate),所以这些字段没必要生成相应接口
  621. var fkTableList = tableFieldList.Where(u => u.EffectType == "ForeignKey" && (u.WhetherAddUpdate == "Y" || u.QueryWhether == "Y")).ToList();
  622. foreach (var @column in fkTableList)
  623. {
  624. var menuType1 = new SysMenu
  625. {
  626. Pid = menuPid,
  627. Title = "外键" + @column.ColumnName,
  628. Type = MenuTypeEnum.Btn,
  629. Permission = className[..1].ToLower() + className[1..] + ":" + column.FkEntityName + column.ColumnName + "Dropdown",
  630. OrderNo = menuOrder
  631. };
  632. menuOrder += 10;
  633. menuList.Add(menuType1);
  634. }
  635. var treeSelectTableList = tableFieldList.Where(u => u.EffectType == "ApiTreeSelector").ToList();
  636. foreach (var @column in treeSelectTableList)
  637. {
  638. var menuType1 = new SysMenu
  639. {
  640. Pid = menuPid,
  641. Title = "树型" + @column.ColumnName,
  642. Type = MenuTypeEnum.Btn,
  643. Permission = className[..1].ToLower() + className[1..] + ":" + column.FkEntityName + "Tree",
  644. OrderNo = menuOrder
  645. };
  646. menuOrder += 10;
  647. menuList.Add(menuType1);
  648. }
  649. var uploadTableList = tableFieldList.Where(u => u.EffectType == "Upload").ToList();
  650. foreach (var @column in uploadTableList)
  651. {
  652. var menuType1 = new SysMenu
  653. {
  654. Pid = menuPid,
  655. Title = "上传" + @column.ColumnName,
  656. Type = MenuTypeEnum.Btn,
  657. Permission = className[..1].ToLower() + className[1..] + ":Upload" + column.ColumnName,
  658. OrderNo = menuOrder
  659. };
  660. menuOrder += 10;
  661. menuList.Add(menuType1);
  662. }
  663. await _db.Insertable(menuList).ExecuteCommandAsync();
  664. }
  665. /// <summary>
  666. /// 获取模板文件路径集合
  667. /// </summary>
  668. /// <returns></returns>
  669. private static List<string> GetTemplatePathList(SysCodeGen input)
  670. {
  671. if (input.GenerateType.Substring(1, 1).Contains('1'))
  672. {
  673. return new() { "index.vue.vm", "editDialog.vue.vm", "manage.js.vm" };
  674. }
  675. else if (input.GenerateType.Substring(1, 1).Contains('2'))
  676. {
  677. return new() { "Service.cs.vm", "Input.cs.vm", "Output.cs.vm", "Dto.cs.vm" };
  678. }
  679. else
  680. {
  681. return new() { "Service.cs.vm", "Input.cs.vm", "Output.cs.vm", "Dto.cs.vm", "index.vue.vm", "editDialog.vue.vm", "manage.js.vm" };
  682. }
  683. }
  684. /// <summary>
  685. /// 获取模板文件路径集合
  686. /// </summary>
  687. /// <returns></returns>
  688. private static List<string> GetTemplatePathList() => new() { "Service.cs.vm", "Input.cs.vm", "Output.cs.vm", "Dto.cs.vm", "index.vue.vm", "editDialog.vue.vm", "manage.js.vm" };
  689. /// <summary>
  690. /// 设置生成文件路径
  691. /// </summary>
  692. /// <param name="input"></param>
  693. /// <returns></returns>
  694. private List<string> GetTargetPathList(SysCodeGen input)
  695. {
  696. //var backendPath = Path.Combine(new DirectoryInfo(App.WebHostEnvironment.ContentRootPath).Parent.FullName, _codeGenOptions.BackendApplicationNamespace, "Service", input.TableName);
  697. var backendPath = Path.Combine(new DirectoryInfo(App.WebHostEnvironment.ContentRootPath).Parent.FullName, input.NameSpace, "Service", input.TableName);
  698. var servicePath = Path.Combine(backendPath, input.TableName + "Service.cs");
  699. var inputPath = Path.Combine(backendPath, "Dto", input.TableName + "Input.cs");
  700. var outputPath = Path.Combine(backendPath, "Dto", input.TableName + "Output.cs");
  701. var viewPath = Path.Combine(backendPath, "Dto", input.TableName + "Dto.cs");
  702. var frontendPath = Path.Combine(new DirectoryInfo(App.WebHostEnvironment.ContentRootPath).Parent.Parent.FullName, _codeGenOptions.FrontRootPath, "src", "views", input.PagePath);
  703. var indexPath = Path.Combine(frontendPath, input.TableName[..1].ToLower() + input.TableName[1..], "index.vue");//
  704. var formModalPath = Path.Combine(frontendPath, input.TableName[..1].ToLower() + input.TableName[1..], "component", "editDialog.vue");
  705. var apiJsPath = Path.Combine(new DirectoryInfo(App.WebHostEnvironment.ContentRootPath).Parent.Parent.FullName, _codeGenOptions.FrontRootPath, "src", "api", input.PagePath, input.TableName[..1].ToLower() + input.TableName[1..] + ".ts");
  706. if (input.GenerateType.Substring(1, 1).Contains('1'))
  707. {
  708. // 生成到本项目(前端)
  709. return new List<string>()
  710. {
  711. indexPath,
  712. formModalPath,
  713. apiJsPath
  714. };
  715. }
  716. else if (input.GenerateType.Substring(1, 1).Contains('2'))
  717. {
  718. // 生成到本项目(后端)
  719. return new List<string>()
  720. {
  721. servicePath,
  722. inputPath,
  723. outputPath,
  724. viewPath,
  725. };
  726. }
  727. else
  728. {
  729. // 前后端同时生成到本项目
  730. return new List<string>()
  731. {
  732. servicePath,
  733. inputPath,
  734. outputPath,
  735. viewPath,
  736. indexPath,
  737. formModalPath,
  738. apiJsPath
  739. };
  740. }
  741. }
  742. /// <summary>
  743. /// 设置生成文件路径
  744. /// </summary>
  745. /// <param name="input"></param>
  746. /// <returns></returns>
  747. private List<string> GetZipPathList(SysCodeGen input)
  748. {
  749. var zipPath = Path.Combine(App.WebHostEnvironment.WebRootPath, "CodeGen", input.TableName);
  750. //var backendPath = Path.Combine(zipPath, _codeGenOptions.BackendApplicationNamespace, "Service", input.TableName);
  751. var backendPath = Path.Combine(zipPath, input.NameSpace, "Service", input.TableName);
  752. var servicePath = Path.Combine(backendPath, input.TableName + "Service.cs");
  753. var inputPath = Path.Combine(backendPath, "Dto", input.TableName + "Input.cs");
  754. var outputPath = Path.Combine(backendPath, "Dto", input.TableName + "Output.cs");
  755. var viewPath = Path.Combine(backendPath, "Dto", input.TableName + "Dto.cs");
  756. var frontendPath = Path.Combine(zipPath, _codeGenOptions.FrontRootPath, "src", "views", input.PagePath);
  757. var indexPath = Path.Combine(frontendPath, input.TableName[..1].ToLower() + input.TableName[1..], "index.vue");
  758. var formModalPath = Path.Combine(frontendPath, input.TableName[..1].ToLower() + input.TableName[1..], "component", "editDialog.vue");
  759. var apiJsPath = Path.Combine(zipPath, _codeGenOptions.FrontRootPath, "src", "api", input.PagePath, input.TableName[..1].ToLower() + input.TableName[1..] + ".ts");
  760. if (input.GenerateType.StartsWith("11"))
  761. {
  762. return new List<string>()
  763. {
  764. indexPath,
  765. formModalPath,
  766. apiJsPath
  767. };
  768. }
  769. else if (input.GenerateType.StartsWith("12"))
  770. {
  771. return new List<string>()
  772. {
  773. servicePath,
  774. inputPath,
  775. outputPath,
  776. viewPath
  777. };
  778. }
  779. else
  780. {
  781. return new List<string>()
  782. {
  783. servicePath,
  784. inputPath,
  785. outputPath,
  786. viewPath,
  787. indexPath,
  788. formModalPath,
  789. apiJsPath
  790. };
  791. }
  792. }
  793. }