AdminService.cs 14 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476
  1. 
  2. using System;
  3. using System.Collections.Generic;
  4. using System.ComponentModel;
  5. using System.Diagnostics.Eventing.Reader;
  6. using System.Linq;
  7. using System.Reflection;
  8. using System.Text;
  9. using Mysqlx.Crud;
  10. using SqlSugar;
  11. using System.Threading.Tasks;
  12. using IoTIntegrationPlatform.Interface;
  13. using IoTIntegrationPlatform.Model.Model;
  14. using IoTIntegrationPlatform.Model.common;
  15. using IoTIntegrationPlatform.Common;
  16. namespace IoTIntegrationPlatform.Services
  17. {
  18. public class AdminService : IAdminService
  19. {
  20. private ISqlSugarClient db { get; }
  21. public AdminService(ISqlSugarClient _db)
  22. {
  23. db = _db;
  24. }
  25. #region 类句柄操作
  26. private IntPtr handle;
  27. private bool disposed = false;
  28. //关闭句柄
  29. [System.Diagnostics.CodeAnalysis.SuppressMessage("Microsoft.Design", "CA1060:MovePInvokesToNativeMethodsClass"), System.Diagnostics.CodeAnalysis.SuppressMessage("Microsoft.Interoperability", "CA1401:PInvokesShouldNotBeVisible"), System.Runtime.InteropServices.DllImport("Kernel32")]
  30. public extern static Boolean CloseHandle(IntPtr handle);
  31. /// <summary>
  32. /// 释放对象资源
  33. /// </summary>
  34. public void Dispose()
  35. {
  36. Dispose(true);
  37. GC.SuppressFinalize(this);
  38. }
  39. /// <summary>
  40. /// 释放对象资源
  41. /// </summary>
  42. /// <param name="disposing"></param>
  43. protected virtual void Dispose(bool disposing)
  44. {
  45. if (!this.disposed)
  46. {
  47. if (handle != IntPtr.Zero)
  48. {
  49. CloseHandle(handle);
  50. handle = IntPtr.Zero;
  51. }
  52. }
  53. disposed = true;
  54. }
  55. ~AdminService()
  56. {
  57. Dispose(false);
  58. }
  59. #endregion
  60. #region 角色管理
  61. /// <summary>
  62. /// 获取角色信息
  63. /// </summary>
  64. /// <param name="email"></param>
  65. /// <param name="passWord"></param>
  66. /// <param name="mobile"></param>
  67. /// <returns></returns>
  68. public AdminRole GetRoleInfo(BaseParm parm)
  69. {
  70. AdminRole model = new AdminRole();
  71. try
  72. {
  73. model = db.Queryable<AdminRole>()
  74. .Where(it => it.IsValid == true)
  75. .WhereIF(!string.IsNullOrEmpty(parm.Name), it => it.RoleName.Equals(parm.Name))
  76. .WhereIF(!string.IsNullOrEmpty(parm.Code), it => it.RoleCode == parm.Code)
  77. .First();
  78. }
  79. catch (Exception ex)
  80. {
  81. Logging.Error(ex, ex.Message);
  82. }
  83. return model;
  84. }
  85. /// <summary>
  86. /// 获取角色列表
  87. /// </summary>
  88. /// <param name="parm"></param>
  89. /// <param name="page"></param>
  90. /// <returns></returns>
  91. public List<AdminRole> GetRoleList(BaseParm parm, ref int page)
  92. {
  93. List<AdminRole> list = new List<AdminRole>();
  94. try
  95. {
  96. list = db.Queryable<AdminRole>()
  97. .Where(it => it.IsValid == true)
  98. .WhereIF(!string.IsNullOrEmpty(parm.Code), it => it.RoleCode.Equals(parm.Code))
  99. .WhereIF(!string.IsNullOrEmpty(parm.Name), it => it.RoleName.Contains(parm.Name))
  100. .ToPageList(parm.PageIndex, parm.PageSize, ref page);
  101. }
  102. catch (Exception ex)
  103. {
  104. Logging.Error(ex, ex.Message);
  105. }
  106. return list;
  107. }
  108. /// <summary>
  109. /// 添加管理-角色
  110. /// </summary>
  111. /// <param name="model"></param>
  112. /// <returns></returns>
  113. public bool AddRole(AdminRole model)
  114. {
  115. bool result = false;
  116. try
  117. {
  118. model.CreateTime = DateTime.Now;
  119. model.UpdateTime = DateTime.Now;
  120. model.IsValid = true;
  121. int row = db.Insertable(model).ExecuteCommand();
  122. if (row > 0)
  123. {
  124. result = true;
  125. }
  126. }
  127. catch (Exception ex)
  128. {
  129. Logging.Error(ex, "添加角色");
  130. }
  131. return result;
  132. }
  133. /// <summary>
  134. /// 编辑管理-角色
  135. /// </summary>
  136. /// <param name="model"></param>
  137. /// <returns></returns>
  138. public bool UpdateRole(AdminRole model)
  139. {
  140. bool result = false;
  141. try
  142. {
  143. var row = db.Updateable(model).IgnoreColumns(it => new { it.Id, it.CreateTime, it.IsValid })
  144. .Where(it => it.Id == model.Id)
  145. .ExecuteCommand();
  146. if (row > 0)
  147. {
  148. result = true;
  149. }
  150. }
  151. catch (Exception ex)
  152. {
  153. Logging.Error(ex, ex.Message);
  154. }
  155. return result;
  156. }
  157. /// <summary>
  158. /// 删除管理-角色
  159. /// </summary>
  160. /// <param name="parm"></param>
  161. /// <returns></returns>
  162. public bool DeleteRole(BaseParm parm)
  163. {
  164. bool result = false;
  165. try
  166. {
  167. int row = db.Updateable<AdminRole>()
  168. .SetColumns(it => new AdminRole { UpdateTime = DateTime.Now, IsValid = false })
  169. .Where(it => it.Id == parm.Id)
  170. .ExecuteCommand();
  171. if (row > 0)
  172. {
  173. result = true;
  174. }
  175. }
  176. catch (Exception ex)
  177. {
  178. Logging.Error(ex, ex.Message);
  179. }
  180. return result;
  181. }
  182. #endregion
  183. #region 菜单管理
  184. /// <summary>
  185. /// 获取菜单信息
  186. /// </summary>
  187. /// <param name="email"></param>
  188. /// <param name="passWord"></param>
  189. /// <param name="mobile"></param>
  190. /// <returns></returns>
  191. public AdminMenu GetMenuInfo(BaseParm parm)
  192. {
  193. AdminMenu model = new AdminMenu();
  194. try
  195. {
  196. model = db.Queryable<AdminMenu>()
  197. .Where(it => it.IsValid == true)
  198. .WhereIF(!string.IsNullOrEmpty(parm.Name), it => it.MenuName.Equals(parm.Name))
  199. .WhereIF(!string.IsNullOrEmpty(parm.Code), it => it.MenuCode == parm.Code)
  200. .First();
  201. }
  202. catch (Exception ex)
  203. {
  204. Logging.Error(ex, ex.Message);
  205. }
  206. return model;
  207. }
  208. /// <summary>
  209. /// 获取菜单列表
  210. /// </summary>
  211. /// <param name="parm"></param>
  212. /// <param name="page"></param>
  213. /// <returns></returns>
  214. public List<AdminMenu> GetMenuList(BaseParm parm, ref int page)
  215. {
  216. List<AdminMenu> list = new List<AdminMenu>();
  217. try
  218. {
  219. list = db.Queryable<AdminMenu>()
  220. .Where(it => it.IsValid == true)
  221. .WhereIF(!string.IsNullOrEmpty(parm.Code), it => it.MenuCode.Equals(parm.Code))
  222. .WhereIF(!string.IsNullOrEmpty(parm.Name), it => it.MenuName.Contains(parm.Name))
  223. .ToPageList(parm.PageIndex, parm.PageSize, ref page);
  224. }
  225. catch (Exception ex)
  226. {
  227. Logging.Error(ex, ex.Message);
  228. }
  229. return list;
  230. }
  231. /// <summary>
  232. /// 添加管理-菜单
  233. /// </summary>
  234. /// <param name="model"></param>
  235. /// <returns></returns>
  236. public bool AddMenu(AdminMenu model)
  237. {
  238. bool result = false;
  239. try
  240. {
  241. model.CreateTime = DateTime.Now;
  242. model.UpdateTime = DateTime.Now;
  243. model.IsValid = true;
  244. int row = db.Insertable(model).ExecuteCommand();
  245. if (row > 0)
  246. {
  247. result = true;
  248. }
  249. }
  250. catch (Exception ex)
  251. {
  252. //Log4NetHelper.WriteLog(ex.Message);
  253. Logging.Error(ex, "添加菜单");
  254. }
  255. return result;
  256. }
  257. /// <summary>
  258. /// 编辑管理-菜单
  259. /// </summary>
  260. /// <param name="model"></param>
  261. /// <returns></returns>
  262. public bool UpdateMenu(AdminMenu model)
  263. {
  264. bool result = false;
  265. try
  266. {
  267. var row = db.Updateable(model).IgnoreColumns(it => new { it.Id, it.CreateTime, it.IsValid })
  268. .Where(it => it.Id == model.Id)
  269. .ExecuteCommand();
  270. if (row > 0)
  271. {
  272. result = true;
  273. }
  274. }
  275. catch (Exception ex)
  276. {
  277. Logging.Error(ex, ex.Message);
  278. }
  279. return result;
  280. }
  281. /// <summary>
  282. /// 删除管理-菜单
  283. /// </summary>
  284. /// <param name="parm"></param>
  285. /// <returns></returns>
  286. public bool DeleteMenu(BaseParm parm)
  287. {
  288. bool result = false;
  289. try
  290. {
  291. int row = db.Updateable<AdminMenu>()
  292. .SetColumns(it => new AdminMenu { UpdateTime = DateTime.Now, IsValid = false })
  293. .Where(it => it.Id == parm.Id)
  294. .ExecuteCommand();
  295. if (row > 0)
  296. {
  297. result = true;
  298. }
  299. }
  300. catch (Exception ex)
  301. {
  302. Logging.Error(ex, ex.Message);
  303. }
  304. return result;
  305. }
  306. /// <summary>
  307. /// 获取菜单权限列表
  308. /// </summary>
  309. /// <returns></returns>
  310. public List<MenuDetail> GetPowerMenuList()
  311. {
  312. List<MenuDetail> allMenuList = new List<MenuDetail>();
  313. try
  314. {
  315. List<AdminMenu> menuList = db.Queryable<AdminMenu>()
  316. .Where(it => it.IsValid == true)
  317. .ToList();
  318. allMenuList = MenuDetail.FromAdminMenu(menuList);
  319. }
  320. catch (Exception ex)
  321. {
  322. Logging.Error(ex, "GetPowerMenuList");
  323. }
  324. return allMenuList;
  325. }
  326. #endregion
  327. #region 角色菜单管理
  328. /// <summary>
  329. /// 获取角色菜单列表
  330. /// </summary>
  331. /// <param name="parm"></param>
  332. /// <param name="page"></param>
  333. /// <returns></returns>
  334. public List<AdminRoleMenu> GetRoleMenuList(BaseParm parm)
  335. {
  336. List<AdminRoleMenu> list = new List<AdminRoleMenu>();
  337. try
  338. {
  339. list = db.Queryable<AdminRoleMenu>()
  340. .Where(it => it.IsValid == true)
  341. .WhereIF(parm.Id > 0, it => it.RoleId == parm.Id)
  342. .WhereIF(!string.IsNullOrEmpty(parm.Code), it => it.RoleCode.Equals(parm.Code))
  343. .WhereIF(!string.IsNullOrEmpty(parm.Param1), it => it.MenuCode.Contains(parm.Name))
  344. .ToList();
  345. }
  346. catch (Exception ex)
  347. {
  348. Logging.Error(ex, "GetRoleMenuList");
  349. }
  350. return list;
  351. }
  352. /// <summary>
  353. /// 后台管理-编辑角色菜单权限
  354. /// </summary>
  355. /// <param name="parm"></param>
  356. /// <param name="list"></param>
  357. /// <returns></returns>
  358. public bool UpdateRoleMenu(BaseParm parm, List<AdminRoleMenu> list)
  359. {
  360. bool result = false;
  361. try
  362. {
  363. //根据角色id删除当前角色的所有权限
  364. int delrow = db.Deleteable<AdminRoleMenu>().Where(it => it.RoleId == parm.Id).ExecuteCommand();
  365. if (list.Count > 0)
  366. {
  367. int row = db.Insertable(list).ExecuteCommand();
  368. }
  369. result = true;
  370. }
  371. catch (Exception ex)
  372. {
  373. Logging.Error(ex, "UpdateRoleMenu");
  374. }
  375. return result;
  376. }
  377. #endregion
  378. #region 用户角色管理
  379. /// <summary>
  380. /// 获取用户角色列表
  381. /// </summary>
  382. /// <param name="parm"></param>
  383. /// <param name="page"></param>
  384. /// <returns></returns>
  385. public List<AdminUserRole> GetUserRoleList(BaseParm parm)
  386. {
  387. List<AdminUserRole> list = new List<AdminUserRole>();
  388. try
  389. {
  390. list = db.Queryable<AdminUserRole>()
  391. .Where(it => it.IsValid == true)
  392. .WhereIF(parm.Id > 0, it => it.UserId == parm.Id)
  393. .ToList();
  394. }
  395. catch (Exception ex)
  396. {
  397. Logging.Error(ex, "GetRoleMenuList");
  398. }
  399. return list;
  400. }
  401. /// <summary>
  402. /// 后台管理-编辑用户角色
  403. /// </summary>
  404. /// <param name="parm"></param>
  405. /// <param name="list"></param>
  406. /// <returns></returns>
  407. public bool UpdateUserRole(BaseParm parm, List<AdminUserRole> list)
  408. {
  409. bool result = false;
  410. try
  411. {
  412. //根据角色id删除当前角色的所有权限
  413. int delrow = db.Deleteable<AdminUserRole>().Where(it => it.UserId == parm.Id).ExecuteCommand();
  414. if (list.Count > 0)
  415. {
  416. int row = db.Insertable(list).ExecuteCommand();
  417. }
  418. result = true;
  419. }
  420. catch (Exception ex)
  421. {
  422. Logging.Error(ex, "UpdateRoleMenu");
  423. }
  424. return result;
  425. }
  426. #endregion
  427. }
  428. }