ParameterService.cs 12 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241
  1. using DapperORMCore.Context.DataContext;
  2. using DapperORMCore.Model.BaseModel;
  3. using DapperORMCore.Model.CoreModel;
  4. using DapperORMCore.Repository.IRepositorys;
  5. using DapperORMCore.String.Consts;
  6. using DapperORMCore.String.Enums;
  7. using Microsoft.Extensions.Configuration;
  8. using NXWMS.Code;
  9. using NXWMS.DataAccess.Entity;
  10. using NXWMS.IService.NXWMS.SysSettings;
  11. using NXWMS.Model.AppModels.Condition.SysSettings;
  12. using NXWMS.Model.AppModels.Result.SysSettings;
  13. using NXWMS.Model.Common;
  14. using NXWMS.String.Enums;
  15. using System;
  16. using System.Collections.Generic;
  17. using System.Linq;
  18. using System.Text;
  19. using System.Threading.Tasks;
  20. using WestDistance.DapperORM.Repository.Repositorys;
  21. namespace NXWMS.Service.NXWMS.SysSettings
  22. {
  23. /// <summary>
  24. /// 参数服务
  25. /// </summary>
  26. [AutoInject(typeof(IParameterService), InjectType.Scope)]
  27. public class ParameterService : ServiceBase, IParameterService
  28. {
  29. /// <summary>
  30. /// 系统操作仓储中转
  31. /// </summary>
  32. private IDataRepositoryContext _dataContext;
  33. /// <summary>
  34. /// SQL节点仓储
  35. /// </summary>
  36. private ISQLNodeRepository _iSQLNodeRepository;
  37. /// <summary>
  38. /// 配置
  39. /// </summary>
  40. private IConfiguration _configuration;
  41. public ParameterService(IDataRepositoryContext dataRepositoryContext, IConfiguration configuration, ISQLNodeRepository iSQLNodeRepository)
  42. {
  43. this._dataContext = dataRepositoryContext;
  44. this._configuration = configuration;
  45. this._iSQLNodeRepository = iSQLNodeRepository;
  46. }
  47. /// <summary>
  48. /// 分页列表 案例
  49. /// </summary>
  50. /// <param name="info"></param>
  51. /// <returns></returns>
  52. public OperateResultInfo<PageQueryResultInfo<SYS_PARAMETER>> GetPageList(ParameterSearchCondition info)
  53. {
  54. var result = new DataRepository<SYS_PARAMETER>(_dataContext).QueryPage(
  55. "PARAMETER_ID", info.PageSize, info.PageIndex
  56. );
  57. return SuccessStatus(new PageQueryResultInfo<SYS_PARAMETER>
  58. {
  59. RowData = result,
  60. PageConditionInfo = info,
  61. });
  62. }
  63. public OperateResultInfo<PageQueryResultInfo<ParameterResult>> GetList(ParameterSearchCondition info)
  64. {
  65. var sqlAndBuilder = new StringBuilder();
  66. var sqlOrBuilder = new StringBuilder();
  67. var sql = $@"SELECT
  68. CreateName = (SELECT USER_NAME FROM SYS_USER A WHERE A.USER_ID=CREATE_BY),
  69. UpdateName = (SELECT USER_NAME FROM SYS_USER B WHERE B.USER_ID=UPDATE_BY),
  70. UsedFlagName = {_iSQLNodeRepository.GetEnumIntCaseString<UsedFlag>("USED_FLAG")},
  71. {info.ItemSQL} FROM SYS_PARAMETER WHERE 1=1 AND DEL_FLAG = 0 ";
  72. sqlAndBuilder = string.IsNullOrWhiteSpace(info.ParameterCode) ?
  73. sqlAndBuilder :
  74. sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("PARAMETER_CODE", info.ParameterCode, DBOperationString._ContainIn));
  75. sqlAndBuilder = info.ParameterId != null ?
  76. info.ParameterId > 0 ?
  77. sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("PARAMETER_ID", info.ParameterId, DBOperationString._ContainIn)) :
  78. sqlAndBuilder : sqlAndBuilder;
  79. sqlAndBuilder = string.IsNullOrWhiteSpace(info.ParameterName) ?
  80. sqlAndBuilder :
  81. sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("PARAMETER_NAME", info.ParameterName, DBOperationString._ContainIn));
  82. sqlAndBuilder = string.IsNullOrWhiteSpace(info.ParameterType) ?
  83. sqlAndBuilder :
  84. sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("PARAMETER_TYPE", info.ParameterType, DBOperationString._ContainIn));
  85. sqlAndBuilder = info.AllowEditFlag != null ?
  86. sqlAndBuilder :
  87. sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("ALLOW_EDIT_FLAG", info.AllowEditFlag, DBOperationString._Equal));
  88. sqlAndBuilder = info.IsUsed == null ?
  89. sqlAndBuilder :
  90. sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("USED_FLAG", info.IsUsed, DBOperationString._Equal));
  91. sql = sql + (sqlAndBuilder.Length > 0 ? _iSQLNodeRepository.GetAndString(sqlAndBuilder, false) : "");
  92. IEnumerable<ParameterResult> result;
  93. IEnumerable<ParameterResult> totalResult;
  94. totalResult = new DataRepository<ParameterResult>(_dataContext).Query(sql);
  95. if (info.PageIndex == 0 || info.PageSize == 0)
  96. {
  97. result = totalResult.ToList();
  98. }
  99. else
  100. {
  101. result = new DataRepository<ParameterResult>(_dataContext).QueryPage(sql,
  102. "CREATE_TIME", info.PageSize, info.PageIndex, true);
  103. }
  104. return SuccessStatus(new PageQueryResultInfo<ParameterResult>
  105. {
  106. RowData = result,
  107. PageConditionInfo = info,
  108. TotalCount = totalResult.Count(),
  109. TotalPageCount = (int)Math.Ceiling((double)totalResult.Count() / info.PageSize)
  110. });
  111. }
  112. public OperateResultInfo Add(ParameterCondition info)
  113. {
  114. if (info == null)
  115. {
  116. return FailStatus();
  117. }
  118. //接口中特定错误状态不加了,,既然要简单.
  119. if (new DataRepository<SYS_PARAMETER>(_dataContext).Query().Where(m => m.PARAMETER_CODE == info.ParameterCode
  120. && m.DEL_FLAG == 0 && m.USED_FLAG == 1).Any())
  121. {
  122. return FailMessageStatus("参数编码已经存在,请输入其它编码!");
  123. }
  124. var now = DateTime.Now;
  125. var entity = new SYS_PARAMETER();
  126. entity.CREATE_BY = info.OperationUserId;
  127. entity.CREATE_TIME = now;
  128. entity.UPDATE_BY = info.OperationUserId;
  129. entity.UPDATE_TIME = now;
  130. entity.PARAMETER_CODE = info.ParameterCode;
  131. entity.PARAMETER_NAME = info.ParameterName;
  132. entity.PARAMETER_TYPE = info.ParameterType;
  133. entity.PARAMETER_VALUE = info.ParameterValue;
  134. entity.DESCRIBE = info.Describe;
  135. entity.USED_FLAG = Convert.ToInt32(info.IsUsed);
  136. entity.SHOW_FLAG = info.IsShow ? 0 : 1;
  137. entity.DEL_FLAG = 0;
  138. entity.ALLOW_EDIT_FLAG = Convert.ToInt32(info.AllowEditFlag);
  139. var affectedRows = new DataRepository<SYS_PARAMETER>(_dataContext).Add(entity, new string[1] { "PARAMETER_ID" });
  140. return GetStatus(affectedRows);
  141. }
  142. public OperateResultInfo Edit(ParameterCondition info)
  143. {
  144. if (info.ParameterId == null && string.IsNullOrWhiteSpace(info.ParameterCode))
  145. {
  146. return FailMessageStatus("参数错误!");
  147. }
  148. var whereList = new List<FieldKeyInfo>()
  149. .AddFieldKeyInfo(nameof(SYS_PARAMETER.PARAMETER_ID), info.ParameterId, EnumCSharpPropertyType.INT, DBOperationString._Equal,
  150. info.ParameterId != null)
  151. .AddFieldKeyInfo(nameof(SYS_PARAMETER.PARAMETER_CODE), info.ParameterCode, EnumCSharpPropertyType.STRING, DBOperationString._In,
  152. string.IsNullOrWhiteSpace(info.ParameterCode));
  153. var result = new DataRepository<SYS_PARAMETER>(_dataContext).Query(whereList).FirstOrDefault();
  154. if (result != null)
  155. {
  156. var now = DateTime.Now;
  157. result.DESCRIBE = info.Describe;
  158. result.ALLOW_EDIT_FLAG = info.AllowEditFlag;
  159. result.PARAMETER_CODE = info.ParameterCode;
  160. result.PARAMETER_NAME = info.ParameterName;
  161. result.UPDATE_BY = info.OperationUserId;
  162. result.UPDATE_TIME = now;
  163. result.PARAMETER_TYPE = info.ParameterType;
  164. result.PARAMETER_VALUE = info.ParameterValue;
  165. result.USED_FLAG = info.IsUsed ? 1 : 0;
  166. result.SHOW_FLAG = info.IsShow ? 1 : 0;
  167. var affectedRows = new DataRepository<SYS_PARAMETER>(_dataContext).Update(result, "PARAMETER_ID", "NEWID");
  168. return GetStatus(affectedRows);
  169. }
  170. return FailMessageStatus("未查找到数据!");
  171. }
  172. public OperateResultInfo Deleted(ParameterCondition info)
  173. {
  174. var sqlAndBuilder = new StringBuilder();
  175. sqlAndBuilder = info.ParameterId != null ?
  176. info.ParameterId > 0 ?
  177. sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("PARAMETER_ID", info.ParameterId, DBOperationString._Equal)) :
  178. sqlAndBuilder : sqlAndBuilder;
  179. sqlAndBuilder = string.IsNullOrWhiteSpace(info.ParameterCode) ?
  180. sqlAndBuilder :
  181. sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("PARAMETER_CODE", info.ParameterCode, DBOperationString._Equal));
  182. sqlAndBuilder = string.IsNullOrWhiteSpace(info.ParameterIds) ?
  183. sqlAndBuilder :
  184. sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("PARAMETER_ID", info.ParameterIds, DBOperationString._In));
  185. if (sqlAndBuilder.Length == 0)
  186. {
  187. return FailMessageStatus("参数错误!");
  188. }
  189. var now = DateTime.Now;
  190. var sql = $@"UPDATE SYS_PARAMETER SET DEL_FLAG=1,UPDATE_BY={info.OperationUserId},UPDATE_TIME='{now}'
  191. WHERE 1=1 {sqlAndBuilder}";
  192. var affectedRows = new DataRepository<SYS_PARAMETER>(_dataContext).Execute(sql);
  193. return GetStatus(affectedRows, info.ParameterIds.Split(',').Length);
  194. }
  195. public OperateResultInfo Remove(ParameterCondition info)
  196. {
  197. var whereList = GetFieldKeyList(info);
  198. var result = new DataRepository<SYS_PARAMETER>(_dataContext).Query(whereList).FirstOrDefault();
  199. if (result != null)
  200. {
  201. var affectedRows = new DataRepository<SYS_MENU>(_dataContext).Remove("PARAMETER_ID", result.PARAMETER_ID.ToString());
  202. return GetStatus(affectedRows);
  203. }
  204. return FailMessageStatus("未查找到数据!");
  205. }
  206. #region Private
  207. /// <summary>
  208. /// 条件统一下,用统一筛选
  209. /// </summary>
  210. /// <param name="RoleCondition"></param>
  211. /// <returns></returns>
  212. private List<FieldKeyInfo> GetFieldKeyList(ParameterCondition info)
  213. {
  214. var whereList = new List<FieldKeyInfo>()
  215. .AddFieldKeyInfo(nameof(SYS_PARAMETER.PARAMETER_ID), info.ParameterId, EnumCSharpPropertyType.INT32, DBOperationString._Equal,
  216. info.ParameterId != null)
  217. .AddFieldKeyInfo(nameof(SYS_PARAMETER.PARAMETER_CODE), info.ParameterCode, EnumCSharpPropertyType.STRING, DBOperationString._Equal,
  218. !string.IsNullOrWhiteSpace(info.ParameterCode))
  219. .AddFieldKeyInfo(nameof(SYS_PARAMETER.PARAMETER_NAME), info.ParameterName, EnumCSharpPropertyType.STRING, DBOperationString._Equal,
  220. !string.IsNullOrWhiteSpace(info.ParameterName));
  221. return whereList;
  222. }
  223. #endregion
  224. }
  225. }