MenuService.cs 13 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280
  1. using DapperORMCore.Context.DataContext;
  2. using DapperORMCore.Context.Extend;
  3. using DapperORMCore.Model.BaseModel;
  4. using DapperORMCore.Model.CoreModel;
  5. using DapperORMCore.String.Consts;
  6. using DapperORMCore.String.Enums;
  7. using NXWMS.IService.NXWMS;
  8. using NXWMS.Model.AppModels.Condition;
  9. using System;
  10. using System.Collections.Generic;
  11. using System.Text;
  12. using WestDistance.DapperORM.Repository.Repositorys;
  13. using DapperORMCore.Context;
  14. using NXWMS.Code;
  15. using System.Linq;
  16. using System.Security.Claims;
  17. using System.IdentityModel.Tokens.Jwt;
  18. using Microsoft.IdentityModel.Tokens;
  19. using Microsoft.IdentityModel.Logging;
  20. using Microsoft.Extensions.Configuration;
  21. using NXWMS.String.Enums;
  22. using System.Data;
  23. using NXWMS.Code.Converter;
  24. using NXWMS.DataAccess.Entity;
  25. using DapperORMCore.Repository.IRepositorys;
  26. using DapperORMCore.Dapper.BaseModel;
  27. using NXWMS.IService.NXWMS.SysSettings;
  28. using NXWMS.Model.AppModels.Condition.SysSettings;
  29. using NXWMS.Model.AppModels.Result.SysSettings;
  30. using NXWMS.Model.Common;
  31. namespace NXWMS.Service.NXWMS.SysSettings
  32. {
  33. /// <summary>
  34. /// 菜单服务
  35. /// </summary>
  36. [AutoInject(typeof(IMenuService), InjectType.Scope)]
  37. public class MenuService : ServiceBase, IMenuService
  38. {
  39. /// <summary>
  40. /// 系统操作仓储中转
  41. /// </summary>
  42. private IDataRepositoryContext _dataContext;
  43. /// <summary>
  44. /// SQL节点仓储
  45. /// </summary>
  46. private ISQLNodeRepository _iSQLNodeRepository;
  47. /// <summary>
  48. /// 配置
  49. /// </summary>
  50. private IConfiguration _configuration;
  51. public MenuService(IDataRepositoryContext dataRepositoryContext, IConfiguration configuration, ISQLNodeRepository iSQLNodeRepository)
  52. {
  53. this._dataContext = dataRepositoryContext;
  54. this._configuration = configuration;
  55. this._iSQLNodeRepository = iSQLNodeRepository;
  56. }
  57. public OperateResultInfo<PageQueryResultInfo<MenuResult>> GetList(MenuSearchCondition info)
  58. {
  59. var sqlAndBuilder = new StringBuilder();
  60. var sqlOrBuilder = new StringBuilder();
  61. var sql = $@"SELECT
  62. MenuPIDName = (SELECT A.MENU_NAME FROM SYS_MENU A WHERE A.MENU_ID=SYS_MENU.MENU_PID),
  63. CreateName = (SELECT USER_NAME FROM SYS_USER A WHERE A.USER_ID=CREATE_BY),
  64. UpdateName = (SELECT USER_NAME FROM SYS_USER B WHERE B.USER_ID=UPDATE_BY),
  65. UsedFlagName = {_iSQLNodeRepository.GetEnumIntCaseString<UsedFlag>("USED_FLAG")},
  66. {info.ItemSQL} FROM SYS_MENU WHERE 1=1 AND DEL_FLAG = 0 ";
  67. sqlAndBuilder = info.Id != null ?
  68. info.Id > 0 ?
  69. sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("MENU_ID", info.Id, DBOperationString._Equal)) :
  70. sqlAndBuilder : sqlAndBuilder;
  71. sqlAndBuilder = info.IsUsed == null ?
  72. sqlAndBuilder :
  73. sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("USED_FLAG", info.IsUsed, DBOperationString._Equal));
  74. sqlAndBuilder = string.IsNullOrWhiteSpace(info.MenuCode) ?
  75. sqlAndBuilder :
  76. sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("MENU_CODE", info.MenuCode, DBOperationString._ContainIn));
  77. sqlAndBuilder = string.IsNullOrWhiteSpace(info.MenuName) ?
  78. sqlAndBuilder :
  79. sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("MENU_NAME", info.MenuName, DBOperationString._ContainIn));
  80. sql = sql + (sqlAndBuilder.Length > 0 ? _iSQLNodeRepository.GetAndString(sqlAndBuilder, false) : "");
  81. IEnumerable<MenuResult> result;
  82. IEnumerable<MenuResult> totalResult;
  83. totalResult = new DataRepository<MenuResult>(_dataContext).Query(sql);
  84. if (info.PageIndex == 0 || info.PageSize == 0)
  85. {
  86. result = totalResult.ToList();
  87. }
  88. else
  89. {
  90. result = new DataRepository<MenuResult>(_dataContext).QueryPage(sql,
  91. "CREATE_TIME", info.PageSize, info.PageIndex, true);
  92. }
  93. return SuccessStatus(new PageQueryResultInfo<MenuResult>
  94. {
  95. RowData = result,
  96. PageConditionInfo = info,
  97. TotalCount = totalResult.Count(),
  98. TotalPageCount = (int)Math.Ceiling((double)totalResult.Count() / info.PageSize)
  99. });
  100. }
  101. public OperateResultInfo<List<MenuLevelResult>> GetLevelList(MenuLevelCondition info)
  102. {
  103. var sql = @"
  104. SELECT
  105. MainMenuId = A.MENU_ID,
  106. MainMenuCode = A.MENU_CODE,
  107. MainMenuName = A.MENU_NAME,
  108. MainMenuPid = A.MENU_PID,
  109. MainMenuOrder = A.MENU_ORDER,
  110. MainMenuURL = A.MENU_URL,
  111. MainMenuUsedFlag = A.USED_FLAG,
  112. MenuId = B.MENU_ID,
  113. MenuCode = B.MENU_CODE,
  114. MenuName = B.MENU_NAME,
  115. MenuPid = B.MENU_PID,
  116. MenuOrder = B.MENU_ORDER,
  117. MenuURL = B.MENU_URL,
  118. MenuUsedFlag = B.USED_FLAG,
  119. FunctionId = C.MENU_ID,
  120. FunctionCode = C.MENU_CODE,
  121. FunctionName = C.MENU_NAME,
  122. FunctionPid = C.MENU_PID,
  123. FunctionOrder = C.MENU_ORDER,
  124. FunctionURL = C.MENU_URL,
  125. FunctionUsedFlag = C.USED_FLAG
  126. FROM
  127. SYS_MENU A
  128. LEFT JOIN SYS_MENU B ON A.MENU_PID =- 1
  129. AND B.MENU_PID = A.MENU_ID
  130. AND B.USED_FLAG = 1
  131. AND B.DEL_FLAG = 0
  132. AND A.DEL_FLAG = 0
  133. AND A.USED_FLAG = 1
  134. AND B.MENU_PID !=- 1
  135. LEFT JOIN SYS_MENU C ON C.USED_FLAG = 1
  136. AND C.MENU_PID !=- 1
  137. AND C.MENU_PID = B.MENU_ID
  138. AND C.USED_FLAG = 1
  139. AND C.DEL_FLAG = 0
  140. ";
  141. var result = new DataRepository<MenuLevelResult>(_dataContext).Query(sql);
  142. return SuccessStatus(result.ToList());
  143. }
  144. public OperateResultInfo Deleted(MenuCondition info)
  145. {
  146. var sqlAndBuilder = new StringBuilder();
  147. sqlAndBuilder = info.MenuId != null ?
  148. info.MenuId > 0 ?
  149. sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("MENU_ID", info.MenuId, DBOperationString._Equal)) :
  150. sqlAndBuilder : sqlAndBuilder;
  151. sqlAndBuilder = string.IsNullOrWhiteSpace(info.MenuCode) ?
  152. sqlAndBuilder :
  153. sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("MENU_CODE", info.MenuCode, DBOperationString._Equal));
  154. sqlAndBuilder = string.IsNullOrWhiteSpace(info.MenuIds) ?
  155. sqlAndBuilder :
  156. sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("MENU_ID", info.MenuIds, DBOperationString._In));
  157. if (sqlAndBuilder.Length == 0)
  158. {
  159. return FailMessageStatus("参数错误!");
  160. }
  161. var now = DateTime.Now;
  162. var sql = $@"UPDATE SYS_MENU SET DEL_FLAG=1,UPDATE_BY={info.OperationUserId},UPDATE_TIME='{now}'
  163. WHERE 1=1 {sqlAndBuilder}";
  164. var affectedRows = new DataRepository<SYS_MENU>(_dataContext).Execute(sql);
  165. return SuccessStatus();
  166. }
  167. public OperateResultInfo Remove(MenuCondition info)
  168. {
  169. var whereList = GetFieldKeyList(info);
  170. var result = new DataRepository<SYS_MENU>(_dataContext).Query(whereList).FirstOrDefault();
  171. if (result != null)
  172. {
  173. var affectedRows = 0;
  174. if (info.MenuId != null)
  175. {
  176. affectedRows = new DataRepository<SYS_MENU>(_dataContext).Remove("MENU_ID", info.MenuId.ToString());
  177. }
  178. if (!string.IsNullOrWhiteSpace(info.MenuCode))
  179. {
  180. affectedRows = new DataRepository<SYS_MENU>(_dataContext).Remove("MENU_CODE", info.MenuCode);
  181. }
  182. return GetStatus(affectedRows);
  183. }
  184. return FailMessageStatus("未查找到数据!");
  185. }
  186. public OperateResultInfo Add(MenuCondition info)
  187. {
  188. if (info == null)
  189. {
  190. return FailStatus();
  191. }
  192. //接口中特定错误状态不加了,,既然要简单.
  193. if (new DataRepository<SYS_MENU>(_dataContext).Query().Where(m => m.MENU_CODE == info.MenuCode
  194. && m.DEL_FLAG == 0 && m.USED_FLAG == 1).Any())
  195. {
  196. return FailMessageStatus("角色编码已经存在,请输入其它编码!");
  197. }
  198. var now = DateTime.Now;
  199. var entity = new SYS_MENU();
  200. entity.CREATE_BY = info.OperationUserId;
  201. entity.CREATE_TIME = now;
  202. entity.UPDATE_BY = info.OperationUserId;
  203. entity.UPDATE_TIME = now;
  204. entity.MENU_CODE = info.MenuCode;
  205. entity.MENU_NAME = info.MenuName;
  206. entity.MENU_ICON = info.IconPath;
  207. entity.MENU_PID = info.MenuPID;
  208. entity.MENU_URL = info.MenuURL;
  209. entity.DESCRIBE = info.Describe;
  210. entity.USED_FLAG = Convert.ToInt32(info.IsUsed);
  211. var affectedRows = new DataRepository<SYS_MENU>(_dataContext).Add(entity, new string[1] { "MENU_ID" });
  212. return GetStatus(affectedRows);
  213. }
  214. public OperateResultInfo Edit(MenuCondition info)
  215. {
  216. if (info.MenuId == null && string.IsNullOrWhiteSpace(info.MenuCode))
  217. {
  218. return FailMessageStatus("参数错误!");
  219. }
  220. var whereList = new List<FieldKeyInfo>()
  221. .AddFieldKeyInfo(nameof(SYS_MENU.MENU_ID), info.MenuId, EnumCSharpPropertyType.STRING, DBOperationString._Equal,
  222. info.MenuId != null)
  223. .AddFieldKeyInfo(nameof(SYS_MENU.MENU_CODE), info.MenuCode, EnumCSharpPropertyType.STRING, DBOperationString._Equal,
  224. !string.IsNullOrWhiteSpace(info.MenuCode)); ;
  225. var result = new DataRepository<SYS_MENU>(_dataContext).Query(whereList).FirstOrDefault();
  226. if (result != null)
  227. {
  228. var now = DateTime.Now;
  229. result.USED_FLAG = Convert.ToInt32(info.IsUsed);
  230. result.MENU_ID = result.MENU_ID;
  231. result.UPDATE_BY = info.OperationUserId;
  232. result.UPDATE_TIME = now;
  233. result.USED_FLAG = Convert.ToInt32(info.IsUsed);
  234. result.MENU_CODE = info.MenuCode;
  235. result.MENU_NAME = info.MenuName;
  236. result.MENU_ICON = info.IconPath;
  237. result.MENU_PID = info.MenuPID;
  238. result.MENU_URL = info.MenuURL;
  239. result.DESCRIBE = info.Describe;
  240. var affectedRows = new DataRepository<SYS_MENU>(_dataContext).Update(result, "MENU_ID", "NEWID");
  241. return GetStatus(affectedRows);
  242. }
  243. return FailMessageStatus("未查找到数据!");
  244. }
  245. #region Private
  246. /// <summary>
  247. /// 条件统一下,用统一筛选
  248. /// </summary>
  249. /// <param name="userCondition"></param>
  250. /// <returns></returns>
  251. private List<FieldKeyInfo> GetFieldKeyList(MenuCondition info)
  252. {
  253. var whereList = new List<FieldKeyInfo>()
  254. .AddFieldKeyInfo(nameof(SYS_MENU.MENU_ID), info.MenuId, EnumCSharpPropertyType.STRING, DBOperationString._Equal,
  255. info.MenuId != null)
  256. .AddFieldKeyInfo(nameof(SYS_MENU.MENU_ID), info.MenuIds, EnumCSharpPropertyType.STRING, DBOperationString._In,
  257. string.IsNullOrWhiteSpace(info.MenuIds))
  258. .AddFieldKeyInfo(nameof(SYS_MENU.MENU_CODE), info.MenuCode, EnumCSharpPropertyType.STRING, DBOperationString._Equal,
  259. string.IsNullOrWhiteSpace(info.MenuCode));
  260. return whereList;
  261. }
  262. #endregion
  263. }
  264. }