123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241 |
- using DapperORMCore.Context.DataContext;
- using DapperORMCore.Model.BaseModel;
- using DapperORMCore.Model.CoreModel;
- using DapperORMCore.Repository.IRepositorys;
- using DapperORMCore.String.Consts;
- using DapperORMCore.String.Enums;
- using Microsoft.Extensions.Configuration;
- using NXWMS.Code;
- using NXWMS.DataAccess.Entity;
- using NXWMS.IService.NXWMS.SysSettings;
- using NXWMS.Model.AppModels.Condition.SysSettings;
- using NXWMS.Model.AppModels.Result.SysSettings;
- using NXWMS.Model.Common;
- using NXWMS.String.Enums;
- using System;
- using System.Collections.Generic;
- using System.Linq;
- using System.Text;
- using System.Threading.Tasks;
- using WestDistance.DapperORM.Repository.Repositorys;
- namespace NXWMS.Service.NXWMS.SysSettings
- {
- /// <summary>
- /// 参数服务
- /// </summary>
- [AutoInject(typeof(IParameterService), InjectType.Scope)]
- public class ParameterService : ServiceBase, IParameterService
- {
- /// <summary>
- /// 系统操作仓储中转
- /// </summary>
- private IDataRepositoryContext _dataContext;
- /// <summary>
- /// SQL节点仓储
- /// </summary>
- private ISQLNodeRepository _iSQLNodeRepository;
- /// <summary>
- /// 配置
- /// </summary>
- private IConfiguration _configuration;
- public ParameterService(IDataRepositoryContext dataRepositoryContext, IConfiguration configuration, ISQLNodeRepository iSQLNodeRepository)
- {
- this._dataContext = dataRepositoryContext;
- this._configuration = configuration;
- this._iSQLNodeRepository = iSQLNodeRepository;
- }
- /// <summary>
- /// 分页列表 案例
- /// </summary>
- /// <param name="info"></param>
- /// <returns></returns>
- public OperateResultInfo<PageQueryResultInfo<SYS_PARAMETER>> GetPageList(ParameterSearchCondition info)
- {
- var result = new DataRepository<SYS_PARAMETER>(_dataContext).QueryPage(
- "PARAMETER_ID", info.PageSize, info.PageIndex
- );
- return SuccessStatus(new PageQueryResultInfo<SYS_PARAMETER>
- {
- RowData = result,
- PageConditionInfo = info,
- });
- }
- public OperateResultInfo<PageQueryResultInfo<ParameterResult>> GetList(ParameterSearchCondition info)
- {
- var sqlAndBuilder = new StringBuilder();
- var sqlOrBuilder = new StringBuilder();
- var sql = $@"SELECT
- CreateName = (SELECT USER_NAME FROM SYS_USER A WHERE A.USER_ID=CREATE_BY),
- UpdateName = (SELECT USER_NAME FROM SYS_USER B WHERE B.USER_ID=UPDATE_BY),
- UsedFlagName = {_iSQLNodeRepository.GetEnumIntCaseString<UsedFlag>("USED_FLAG")},
- {info.ItemSQL} FROM SYS_PARAMETER WHERE 1=1 AND DEL_FLAG = 0 ";
- sqlAndBuilder = string.IsNullOrWhiteSpace(info.ParameterCode) ?
- sqlAndBuilder :
- sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("PARAMETER_CODE", info.ParameterCode, DBOperationString._ContainIn));
- sqlAndBuilder = info.ParameterId != null ?
- info.ParameterId > 0 ?
- sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("PARAMETER_ID", info.ParameterId, DBOperationString._ContainIn)) :
- sqlAndBuilder : sqlAndBuilder;
- sqlAndBuilder = string.IsNullOrWhiteSpace(info.ParameterName) ?
- sqlAndBuilder :
- sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("PARAMETER_NAME", info.ParameterName, DBOperationString._ContainIn));
- sqlAndBuilder = string.IsNullOrWhiteSpace(info.ParameterType) ?
- sqlAndBuilder :
- sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("PARAMETER_TYPE", info.ParameterType, DBOperationString._ContainIn));
- sqlAndBuilder = info.AllowEditFlag != null ?
- sqlAndBuilder :
- sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("ALLOW_EDIT_FLAG", info.AllowEditFlag, DBOperationString._Equal));
- sqlAndBuilder = info.IsUsed == null ?
- sqlAndBuilder :
- sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("USED_FLAG", info.IsUsed, DBOperationString._Equal));
- sql = sql + (sqlAndBuilder.Length > 0 ? _iSQLNodeRepository.GetAndString(sqlAndBuilder, false) : "");
-
- IEnumerable<ParameterResult> result;
- IEnumerable<ParameterResult> totalResult;
- totalResult = new DataRepository<ParameterResult>(_dataContext).Query(sql);
- if (info.PageIndex == 0 || info.PageSize == 0)
- {
- result = totalResult.ToList();
- }
- else
- {
- result = new DataRepository<ParameterResult>(_dataContext).QueryPage(sql,
- "CREATE_TIME", info.PageSize, info.PageIndex, true);
- }
- return SuccessStatus(new PageQueryResultInfo<ParameterResult>
- {
- RowData = result,
- PageConditionInfo = info,
- TotalCount = totalResult.Count(),
- TotalPageCount = (int)Math.Ceiling((double)totalResult.Count() / info.PageSize)
- });
- }
- public OperateResultInfo Add(ParameterCondition info)
- {
- if (info == null)
- {
- return FailStatus();
- }
- //接口中特定错误状态不加了,,既然要简单.
- if (new DataRepository<SYS_PARAMETER>(_dataContext).Query().Where(m => m.PARAMETER_CODE == info.ParameterCode
- && m.DEL_FLAG == 0 && m.USED_FLAG == 1).Any())
- {
- return FailMessageStatus("参数编码已经存在,请输入其它编码!");
- }
- var now = DateTime.Now;
- var entity = new SYS_PARAMETER();
- entity.CREATE_BY = info.OperationUserId;
- entity.CREATE_TIME = now;
- entity.UPDATE_BY = info.OperationUserId;
- entity.UPDATE_TIME = now;
- entity.PARAMETER_CODE = info.ParameterCode;
- entity.PARAMETER_NAME = info.ParameterName;
- entity.PARAMETER_TYPE = info.ParameterType;
- entity.PARAMETER_VALUE = info.ParameterValue;
- entity.DESCRIBE = info.Describe;
- entity.USED_FLAG = Convert.ToInt32(info.IsUsed);
- entity.SHOW_FLAG = info.IsShow ? 0 : 1;
- entity.DEL_FLAG = 0;
- entity.ALLOW_EDIT_FLAG = Convert.ToInt32(info.AllowEditFlag);
- var affectedRows = new DataRepository<SYS_PARAMETER>(_dataContext).Add(entity, new string[1] { "PARAMETER_ID" });
- return GetStatus(affectedRows);
- }
- public OperateResultInfo Edit(ParameterCondition info)
- {
- if (info.ParameterId == null && string.IsNullOrWhiteSpace(info.ParameterCode))
- {
- return FailMessageStatus("参数错误!");
- }
- var whereList = new List<FieldKeyInfo>()
- .AddFieldKeyInfo(nameof(SYS_PARAMETER.PARAMETER_ID), info.ParameterId, EnumCSharpPropertyType.INT, DBOperationString._Equal,
- info.ParameterId != null)
- .AddFieldKeyInfo(nameof(SYS_PARAMETER.PARAMETER_CODE), info.ParameterCode, EnumCSharpPropertyType.STRING, DBOperationString._In,
- string.IsNullOrWhiteSpace(info.ParameterCode));
- var result = new DataRepository<SYS_PARAMETER>(_dataContext).Query(whereList).FirstOrDefault();
- if (result != null)
- {
- var now = DateTime.Now;
- result.DESCRIBE = info.Describe;
- result.ALLOW_EDIT_FLAG = info.AllowEditFlag;
- result.PARAMETER_CODE = info.ParameterCode;
- result.PARAMETER_NAME = info.ParameterName;
- result.UPDATE_BY = info.OperationUserId;
- result.UPDATE_TIME = now;
- result.PARAMETER_TYPE = info.ParameterType;
- result.PARAMETER_VALUE = info.ParameterValue;
- result.USED_FLAG = info.IsUsed ? 1 : 0;
- result.SHOW_FLAG = info.IsShow ? 1 : 0;
- var affectedRows = new DataRepository<SYS_PARAMETER>(_dataContext).Update(result, "PARAMETER_ID", "NEWID");
- return GetStatus(affectedRows);
- }
- return FailMessageStatus("未查找到数据!");
- }
- public OperateResultInfo Deleted(ParameterCondition info)
- {
- var sqlAndBuilder = new StringBuilder();
- sqlAndBuilder = info.ParameterId != null ?
- info.ParameterId > 0 ?
- sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("PARAMETER_ID", info.ParameterId, DBOperationString._Equal)) :
- sqlAndBuilder : sqlAndBuilder;
- sqlAndBuilder = string.IsNullOrWhiteSpace(info.ParameterCode) ?
- sqlAndBuilder :
- sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("PARAMETER_CODE", info.ParameterCode, DBOperationString._Equal));
- sqlAndBuilder = string.IsNullOrWhiteSpace(info.ParameterIds) ?
- sqlAndBuilder :
- sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("PARAMETER_ID", info.ParameterIds, DBOperationString._In));
- if (sqlAndBuilder.Length == 0)
- {
- return FailMessageStatus("参数错误!");
- }
- var now = DateTime.Now;
- var sql = $@"UPDATE SYS_PARAMETER SET DEL_FLAG=1,UPDATE_BY={info.OperationUserId},UPDATE_TIME='{now}'
- WHERE 1=1 {sqlAndBuilder}";
- var affectedRows = new DataRepository<SYS_PARAMETER>(_dataContext).Execute(sql);
- return GetStatus(affectedRows, info.ParameterIds.Split(',').Length);
- }
- public OperateResultInfo Remove(ParameterCondition info)
- {
- var whereList = GetFieldKeyList(info);
- var result = new DataRepository<SYS_PARAMETER>(_dataContext).Query(whereList).FirstOrDefault();
- if (result != null)
- {
- var affectedRows = new DataRepository<SYS_MENU>(_dataContext).Remove("PARAMETER_ID", result.PARAMETER_ID.ToString());
- return GetStatus(affectedRows);
- }
- return FailMessageStatus("未查找到数据!");
- }
- #region Private
- /// <summary>
- /// 条件统一下,用统一筛选
- /// </summary>
- /// <param name="RoleCondition"></param>
- /// <returns></returns>
- private List<FieldKeyInfo> GetFieldKeyList(ParameterCondition info)
- {
- var whereList = new List<FieldKeyInfo>()
- .AddFieldKeyInfo(nameof(SYS_PARAMETER.PARAMETER_ID), info.ParameterId, EnumCSharpPropertyType.INT32, DBOperationString._Equal,
- info.ParameterId != null)
- .AddFieldKeyInfo(nameof(SYS_PARAMETER.PARAMETER_CODE), info.ParameterCode, EnumCSharpPropertyType.STRING, DBOperationString._Equal,
- !string.IsNullOrWhiteSpace(info.ParameterCode))
- .AddFieldKeyInfo(nameof(SYS_PARAMETER.PARAMETER_NAME), info.ParameterName, EnumCSharpPropertyType.STRING, DBOperationString._Equal,
- !string.IsNullOrWhiteSpace(info.ParameterName));
- return whereList;
- }
- #endregion
- }
- }
|