CustomGenerateData.cs 6.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220
  1. using System.Collections.Generic;
  2. using System.Linq;
  3. using System.Threading.Tasks;
  4. using ZhonTai.Admin.Core.Db;
  5. using ZhonTai.Admin.Domain.DictType;
  6. using ZhonTai.Admin.Domain.Dict;
  7. using ZhonTai.Admin.Domain.Api;
  8. using ZhonTai.Admin.Domain.Permission;
  9. using ZhonTai.Admin.Domain.User;
  10. using ZhonTai.Admin.Domain.Role;
  11. using ZhonTai.Admin.Domain.UserRole;
  12. using ZhonTai.Admin.Domain.RolePermission;
  13. using ZhonTai.Admin.Domain.Tenant;
  14. using ZhonTai.Admin.Domain.TenantPermission;
  15. using ZhonTai.Admin.Domain.PermissionApi;
  16. using ZhonTai.Admin.Domain.View;
  17. using ZhonTai.Admin.Core.Configs;
  18. using ZhonTai.Common.Extensions;
  19. using ZhonTai.Admin.Domain.UserStaff;
  20. using ZhonTai.Admin.Domain.Org;
  21. using ZhonTai.Admin.Core.Db.Data;
  22. using FreeSql;
  23. using ZhonTai.Admin.Domain.UserOrg;
  24. using System.Reflection;
  25. using ZhonTai.Admin.Core.Attributes;
  26. using ZhonTai.Admin.Core.Helpers;
  27. namespace ZhonTai.Admin.Repositories;
  28. public class CustomGenerateData : GenerateData, IGenerateData
  29. {
  30. public virtual async Task GenerateDataAsync(IFreeSql db, AppConfig appConfig)
  31. {
  32. #region 读取数据
  33. //admin
  34. #region 数据字典
  35. var dictionaryTypes = await db.Queryable<DictTypeEntity>().ToListAsync();
  36. var dictionaries = await db.Queryable<DictEntity>().ToListAsync();
  37. #endregion
  38. #region 接口
  39. var apis = await db.Queryable<ApiEntity>().ToListAsync();
  40. var apiTree = apis.Clone().ToTree((r, c) =>
  41. {
  42. return c.ParentId == 0;
  43. },
  44. (r, c) =>
  45. {
  46. return r.Id == c.ParentId;
  47. },
  48. (r, datalist) =>
  49. {
  50. r.Childs ??= new List<ApiEntity>();
  51. r.Childs.AddRange(datalist);
  52. });
  53. #endregion
  54. #region 视图
  55. var views = await db.Queryable<ViewEntity>().ToListAsync();
  56. var viewTree = views.Clone().ToTree((r, c) =>
  57. {
  58. return c.ParentId == 0;
  59. },
  60. (r, c) =>
  61. {
  62. return r.Id == c.ParentId;
  63. },
  64. (r, datalist) =>
  65. {
  66. r.Childs ??= new List<ViewEntity>();
  67. r.Childs.AddRange(datalist);
  68. });
  69. #endregion
  70. #region 权限
  71. var permissions = await db.Queryable<PermissionEntity>().ToListAsync();
  72. var permissionTree = permissions.Clone().ToTree((r, c) =>
  73. {
  74. return c.ParentId == 0;
  75. },
  76. (r, c) =>
  77. {
  78. return r.Id == c.ParentId;
  79. },
  80. (r, datalist) =>
  81. {
  82. r.Childs ??= new List<PermissionEntity>();
  83. r.Childs.AddRange(datalist);
  84. });
  85. #endregion
  86. #region 用户
  87. var users = await db.Queryable<UserEntity>().ToListAsync();
  88. #endregion
  89. #region 员工
  90. var staffs = await db.Queryable<UserStaffEntity>().ToListAsync();
  91. #endregion
  92. #region 部门
  93. var orgs = await db.Queryable<OrgEntity>().ToListAsync();
  94. var orgTree = orgs.Clone().ToTree((r, c) =>
  95. {
  96. return c.ParentId == 0;
  97. },
  98. (r, c) =>
  99. {
  100. return r.Id == c.ParentId;
  101. },
  102. (r, datalist) =>
  103. {
  104. r.Childs ??= new List<OrgEntity>();
  105. r.Childs.AddRange(datalist);
  106. });
  107. #endregion
  108. #region 角色
  109. var roles = await db.Queryable<RoleEntity>().ToListAsync();
  110. #endregion
  111. #region 用户角色
  112. var userRoles = await db.Queryable<UserRoleEntity>().ToListAsync();
  113. #endregion
  114. #region 用户部门
  115. var userOrgs = await db.Queryable<UserOrgEntity>().ToListAsync();
  116. #endregion
  117. #region 角色权限
  118. var rolePermissions = await db.Queryable<RolePermissionEntity>().ToListAsync();
  119. #endregion
  120. #region 租户
  121. var tenants = await db.Queryable<TenantEntity>().ToListAsync();
  122. #endregion
  123. #region 租户权限
  124. var tenantPermissions = await db.Queryable<TenantPermissionEntity>().ToListAsync();
  125. #endregion
  126. #region 权限接口
  127. var permissionApis = await db.Queryable<PermissionApiEntity>().ToListAsync();
  128. #endregion
  129. #endregion
  130. #region 生成数据
  131. var isTenant = appConfig.Tenant;
  132. if (isTenant)
  133. {
  134. var tenantIds = tenants?.Select(a => a.Id)?.ToList();
  135. SaveDataToJsonFile<UserEntity>(users.Where(a => tenantIds.Contains(a.TenantId.Value)));
  136. SaveDataToJsonFile<RoleEntity>(roles.Where(a => tenantIds.Contains(a.TenantId.Value)));
  137. orgTree = orgs.Clone().Where(a => tenantIds.Contains(a.TenantId.Value)).ToList().ToTree((r, c) =>
  138. {
  139. return c.ParentId == 0;
  140. },
  141. (r, c) =>
  142. {
  143. return r.Id == c.ParentId;
  144. },
  145. (r, datalist) =>
  146. {
  147. r.Childs ??= new List<OrgEntity>();
  148. r.Childs.AddRange(datalist);
  149. });
  150. SaveDataToJsonFile<OrgEntity>(orgTree);
  151. SaveDataToJsonFile<UserStaffEntity>(staffs.Where(a => tenantIds.Contains(a.TenantId.Value)));
  152. }
  153. SaveDataToJsonFile<UserEntity>(users, isTenant);
  154. SaveDataToJsonFile<RoleEntity>(roles, isTenant);
  155. SaveDataToJsonFile<OrgEntity>(orgTree, isTenant);
  156. SaveDataToJsonFile<UserStaffEntity>(staffs, isTenant);
  157. SaveDataToJsonFile<DictEntity>(dictionaries);
  158. SaveDataToJsonFile<DictTypeEntity>(dictionaryTypes);
  159. SaveDataToJsonFile<UserRoleEntity>(userRoles);
  160. SaveDataToJsonFile<UserOrgEntity>(userOrgs);
  161. SaveDataToJsonFile<ApiEntity>(apiTree);
  162. SaveDataToJsonFile<ViewEntity>(viewTree);
  163. SaveDataToJsonFile<PermissionEntity>(permissionTree);
  164. SaveDataToJsonFile<PermissionApiEntity>(permissionApis);
  165. SaveDataToJsonFile<RolePermissionEntity>(rolePermissions);
  166. SaveDataToJsonFile<TenantEntity>(tenants);
  167. SaveDataToJsonFile<TenantPermissionEntity>(tenantPermissions);
  168. #endregion
  169. }
  170. }