1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192 |
- 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.Base;
- using NXWMS.Model.AppModels.Result.Base;
- 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.Base
- {
- /// <summary>
- /// 包装服务
- /// </summary>
- [AutoInject(typeof(IPackageService), InjectType.Scope)]
- public class PackageService : ServiceBase, IPackageService
- {
- /// <summary>
- /// 系统操作仓储中转
- /// </summary>
- private IDataRepositoryContext _dataContext;
- /// <summary>
- /// SQL节点仓储
- /// </summary>
- private ISQLNodeRepository _iSQLNodeRepository;
- /// <summary>
- /// 配置
- /// </summary>
- private IConfiguration _configuration;
- public PackageService(IDataRepositoryContext dataRepositoryContext, IConfiguration configuration, ISQLNodeRepository iSQLNodeRepository)
- {
- this._dataContext = dataRepositoryContext;
- this._configuration = configuration;
- this._iSQLNodeRepository = iSQLNodeRepository;
- }
- public OperateResultInfo<PageQueryResultInfo<PackageResult>> GetList(PackageSearchCondition 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_PACKAGE WHERE 1=1 AND DEL_FLAG = 0 ";
- sqlAndBuilder = info.Id != null ?
- info.Id > 0 ?
- sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("PACKAGE_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.PackageCode) ?
- sqlAndBuilder :
- sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("PACKAGE_CODE", info.PackageCode, DBOperationString._ContainIn));
-
- sql = sql + (sqlAndBuilder.Length > 0 ? _iSQLNodeRepository.GetAndString(sqlAndBuilder, false) : "");
- IEnumerable<PackageResult> result;
- IEnumerable<PackageResult> totalResult;
- totalResult = new DataRepository<PackageResult>(_dataContext).Query(sql);
- if (info.PageIndex == 0 || info.PageSize == 0)
- {
- result = totalResult.ToList();
- }
- else
- {
- result = new DataRepository<PackageResult>(_dataContext).QueryPage(sql,
- "CREATE_TIME", info.PageSize, info.PageIndex, true);
- }
- return SuccessStatus(new PageQueryResultInfo<PackageResult>
- {
- RowData = result,
- PageConditionInfo = info,
- TotalCount = totalResult.Count(),
- TotalPageCount = (int)Math.Ceiling((double)totalResult.Count() / info.PageSize)
- });
- }
- }
- }
|