Wms_WebApi/NXWMS.WebApi/NXWMS.Service/NXWMS/SysSettings/ParameterService.cs

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
    }
}