Wms_WebApi/NXWMS.WebApi/NXWMS.Service/NXWMS/Base/WarehouseService.cs

using DapperORMCore.Context.DataContext;
using DapperORMCore.Model.CoreModel;
using DapperORMCore.Repository.IRepositorys;
using DapperORMCore.String.Consts;
using Microsoft.Extensions.Configuration;
using NXWMS.IService.NXWMS.Base;
using NXWMS.Model.AppModels.Condition;
using NXWMS.Model.AppModels.Condition.Base;
using NXWMS.Model.AppModels.Condition.SysSettings;
using NXWMS.Model.AppModels.Result.Base;
using NXWMS.Model.AppModels.Result.SysSettings;
using NXWMS.Model.Common;
using NXWMS.String.Enums;
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Text;
using WestDistance.DapperORM.Repository.Repositorys;

namespace NXWMS.Service.NXWMS.Base
{
    /// <summary>
    /// 区域服务
    /// </summary>
    [AutoInject(typeof(IWarehouseService), InjectType.Scope)]
    public class WarehouseService : ServiceBase, IWarehouseService
    {
        /// <summary>
        /// 系统操作仓储中转
        /// </summary>
        private IDataRepositoryContext _dataContext;

        /// <summary>
        /// SQL节点仓储
        /// </summary>
        private ISQLNodeRepository _iSQLNodeRepository;

        /// <summary>
        /// 配置
        /// </summary>
        private IConfiguration _configuration;

        public WarehouseService(IDataRepositoryContext dataRepositoryContext, IConfiguration configuration, ISQLNodeRepository iSQLNodeRepository)
        {
            this._dataContext = dataRepositoryContext;
            this._configuration = configuration;
            this._iSQLNodeRepository = iSQLNodeRepository;
        }

        public OperateResultInfo Add(WarehouseCondition info)
        {
            throw new NotImplementedException();
        }

        public OperateResultInfo Deleted(WarehouseCondition info)
        {
            throw new NotImplementedException();
        }

        public OperateResultInfo Edit(WarehouseCondition info)
        {
            throw new NotImplementedException();
        }

        public OperateResultInfo<PageQueryResultInfo<WarehouseResult>> GetList(WarehouseSearchCondition 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 BAS_WAREHOUSE WHERE 1=1 AND DEL_FLAG = 0 ";
            sqlAndBuilder = info.Id != null ?
                        info.Id > 0 ?
                        sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("REGION_ID", info.Id, DBOperationString._Equal)) :
                        sqlAndBuilder : sqlAndBuilder;
            sqlAndBuilder = info.IsUsed == null ?
                        sqlAndBuilder :
                        sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("USED_FLAG", info.IsUsed, DBOperationString._Equal));
            sqlAndBuilder = string.IsNullOrWhiteSpace(info.WarehouseCode) ?
                        sqlAndBuilder :
                        sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("WAREHOUSE_CODE", info.WarehouseCode, DBOperationString._ContainIn));

            sql = sql + (sqlAndBuilder.Length > 0 ? _iSQLNodeRepository.GetAndString(sqlAndBuilder, false) : "");
            IEnumerable<WarehouseResult> result;
            IEnumerable<WarehouseResult> totalResult;
            totalResult = new DataRepository<WarehouseResult>(_dataContext).Query(sql);
            if (info.PageIndex == 0 || info.PageSize == 0)
            {
                result = totalResult.ToList();
            }
            else
            {
                result = new DataRepository<WarehouseResult>(_dataContext).QueryPage(sql,
                                                "CREATE_TIME", info.PageSize, info.PageIndex, true);
            }
            return SuccessStatus(new PageQueryResultInfo<WarehouseResult>
            {
                RowData = result,
                PageConditionInfo = info,
                TotalCount = totalResult.Count(),
                TotalPageCount = (int)Math.Ceiling((double)totalResult.Count() / info.PageSize)
            });
        }

        public OperateResultInfo Remove(WarehouseCondition info)
        {
            throw new NotImplementedException();
        }
    }
}