SysCodeGenService.cs 34 KB

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