PackageService.cs 3.8 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192
  1. using DapperORMCore.Context.DataContext;
  2. using DapperORMCore.Model.CoreModel;
  3. using DapperORMCore.Repository.IRepositorys;
  4. using DapperORMCore.String.Consts;
  5. using Microsoft.Extensions.Configuration;
  6. using NXWMS.IService.NXWMS.Base;
  7. using NXWMS.Model.AppModels.Condition.Base;
  8. using NXWMS.Model.AppModels.Result.Base;
  9. using NXWMS.Model.Common;
  10. using NXWMS.String.Enums;
  11. using System;
  12. using System.Collections.Generic;
  13. using System.Linq;
  14. using System.Text;
  15. using System.Threading.Tasks;
  16. using WestDistance.DapperORM.Repository.Repositorys;
  17. namespace NXWMS.Service.NXWMS.Base
  18. {
  19. /// <summary>
  20. /// 包装服务
  21. /// </summary>
  22. [AutoInject(typeof(IPackageService), InjectType.Scope)]
  23. public class PackageService : ServiceBase, IPackageService
  24. {
  25. /// <summary>
  26. /// 系统操作仓储中转
  27. /// </summary>
  28. private IDataRepositoryContext _dataContext;
  29. /// <summary>
  30. /// SQL节点仓储
  31. /// </summary>
  32. private ISQLNodeRepository _iSQLNodeRepository;
  33. /// <summary>
  34. /// 配置
  35. /// </summary>
  36. private IConfiguration _configuration;
  37. public PackageService(IDataRepositoryContext dataRepositoryContext, IConfiguration configuration, ISQLNodeRepository iSQLNodeRepository)
  38. {
  39. this._dataContext = dataRepositoryContext;
  40. this._configuration = configuration;
  41. this._iSQLNodeRepository = iSQLNodeRepository;
  42. }
  43. public OperateResultInfo<PageQueryResultInfo<PackageResult>> GetList(PackageSearchCondition info)
  44. {
  45. var sqlAndBuilder = new StringBuilder();
  46. var sqlOrBuilder = new StringBuilder();
  47. var sql = $@"SELECT
  48. CreateName = (SELECT USER_NAME FROM SYS_USER A WHERE A.USER_ID=CREATE_BY),
  49. UpdateName = (SELECT USER_NAME FROM SYS_USER B WHERE B.USER_ID=UPDATE_BY),
  50. UsedFlagName = {_iSQLNodeRepository.GetEnumIntCaseString<UsedFlag>("USED_FLAG")},
  51. {info.ItemSQL} FROM BAS_PACKAGE WHERE 1=1 AND DEL_FLAG = 0 ";
  52. sqlAndBuilder = info.Id != null ?
  53. info.Id > 0 ?
  54. sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("PACKAGE_ID", info.Id, DBOperationString._Equal)) :
  55. sqlAndBuilder : sqlAndBuilder;
  56. sqlAndBuilder = info.IsUsed == null ?
  57. sqlAndBuilder :
  58. sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("USED_FLAG", info.IsUsed, DBOperationString._Equal));
  59. sqlAndBuilder = string.IsNullOrWhiteSpace(info.PackageCode) ?
  60. sqlAndBuilder :
  61. sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("PACKAGE_CODE", info.PackageCode, DBOperationString._ContainIn));
  62. sql = sql + (sqlAndBuilder.Length > 0 ? _iSQLNodeRepository.GetAndString(sqlAndBuilder, false) : "");
  63. IEnumerable<PackageResult> result;
  64. IEnumerable<PackageResult> totalResult;
  65. totalResult = new DataRepository<PackageResult>(_dataContext).Query(sql);
  66. if (info.PageIndex == 0 || info.PageSize == 0)
  67. {
  68. result = totalResult.ToList();
  69. }
  70. else
  71. {
  72. result = new DataRepository<PackageResult>(_dataContext).QueryPage(sql,
  73. "CREATE_TIME", info.PageSize, info.PageIndex, true);
  74. }
  75. return SuccessStatus(new PageQueryResultInfo<PackageResult>
  76. {
  77. RowData = result,
  78. PageConditionInfo = info,
  79. TotalCount = totalResult.Count(),
  80. TotalPageCount = (int)Math.Ceiling((double)totalResult.Count() / info.PageSize)
  81. });
  82. }
  83. }
  84. }