WcsBaseService.cs 5.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131
  1. using DapperORMCore.Context.DataContext;
  2. using DapperORMCore.Model.CoreModel;
  3. using DapperORMCore.Repository.IRepositorys;
  4. using Microsoft.Extensions.Configuration;
  5. using NXWMS.IService.NXWMS.WcsBase;
  6. using NXWMS.Model.AppModels.Result.WcsBase;
  7. using NXWMS.Model.Common;
  8. using System;
  9. using System.Collections.Generic;
  10. using System.Linq;
  11. using System.Text;
  12. using System.Threading.Tasks;
  13. using WestDistance.DapperORM.Repository.Repositorys;
  14. namespace NXWMS.Service.NXWMS.WcsBase
  15. {
  16. /// <summary>
  17. /// WCS基础相关服务
  18. /// </summary>
  19. [AutoInject(typeof(IWcsBaseService), InjectType.Scope)]
  20. public class WcsBaseService : ServiceBase, IWcsBaseService
  21. {
  22. #region 全局变量、构造注入
  23. /// <summary>
  24. /// 系统操作仓储中转
  25. /// </summary>
  26. private IDataRepositoryContext _dataContext;
  27. /// <summary>
  28. /// SQL节点仓储
  29. /// </summary>
  30. private ISQLNodeRepository _iSQLNodeRepository;
  31. /// <summary>
  32. /// 配置
  33. /// </summary>
  34. private IConfiguration _configuration;
  35. /// <summary>
  36. /// 构造注入
  37. /// </summary>
  38. /// <param name="dataRepositoryContext"></param>
  39. /// <param name="configuration"></param>
  40. /// <param name="iSQLNodeRepository"></param>
  41. public WcsBaseService(IDataRepositoryContext dataRepositoryContext, IConfiguration configuration, ISQLNodeRepository iSQLNodeRepository)
  42. {
  43. this._dataContext = dataRepositoryContext;
  44. this._configuration = configuration;
  45. this._iSQLNodeRepository = iSQLNodeRepository;
  46. }
  47. #endregion
  48. /// <summary>
  49. /// 查询设备类型基础数据
  50. /// </summary>
  51. /// <returns></returns>
  52. public OperateResultInfo<List<WcsBasDevTypeResult>> GetDevTypeData()
  53. {
  54. try
  55. {
  56. string sql = $@"
  57. SELECT
  58. A.*,
  59. CASE A.USED_FLAG
  60. WHEN 0 THEN
  61. '禁用'
  62. ELSE
  63. '启用'
  64. END USED_FLAG_NAME,
  65. CASE A.DEL_FLAG
  66. WHEN 0 THEN
  67. '未删除'
  68. ELSE
  69. '已删除'
  70. END DEL_FLAG_NAME,
  71. B.USER_NAME CREATE_NAME,
  72. C.USER_NAME UPDATE_NAME
  73. FROM
  74. WCS_BAS_DEV_TYPE A
  75. LEFT JOIN SYS_USER B ON A.CREATE_BY = B.USER_ID
  76. LEFT JOIN SYS_USER C ON A.UPDATE_BY = C.USER_ID
  77. ";
  78. List<WcsBasDevTypeResult> resultList = new DataRepository<WcsBasDevTypeResult>(_dataContext).Query(sql).ToList();
  79. OperateResultInfo<List<WcsBasDevTypeResult>> retDataMsg = SuccessStatus(resultList);
  80. return retDataMsg;
  81. }
  82. catch (Exception ex)
  83. {
  84. return FailMessageStatus<List<WcsBasDevTypeResult>>($"查询WCS设备类型数据发生异常,【{ex.Message}】", null);
  85. }
  86. }
  87. /// <summary>
  88. /// 查询PLC配置基础数据
  89. /// </summary>
  90. /// <returns></returns>
  91. public OperateResultInfo<List<WcsBasPlcResult>> GetWcsPlcData()
  92. {
  93. try
  94. {
  95. string sql = $@"
  96. SELECT
  97. A.*,
  98. CASE A.USED_FLAG
  99. WHEN 0 THEN
  100. '禁用'
  101. ELSE
  102. '启用'
  103. END USED_FLAG_NAME,
  104. CASE A.DEL_FLAG
  105. WHEN 0 THEN
  106. '未删除'
  107. ELSE
  108. '已删除'
  109. END DEL_FLAG_NAME,
  110. B.USER_NAME CREATE_NAME,
  111. C.USER_NAME UPDATE_NAME
  112. FROM
  113. WCS_BAS_PLC A
  114. LEFT JOIN SYS_USER B ON A.CREATE_BY = B.USER_ID
  115. LEFT JOIN SYS_USER C ON A.UPDATE_BY = C.USER_ID
  116. ";
  117. List<WcsBasPlcResult> resultList = new DataRepository<WcsBasPlcResult>(_dataContext).Query(sql).ToList();
  118. OperateResultInfo<List<WcsBasPlcResult>> retDataMsg = SuccessStatus(resultList);
  119. return retDataMsg;
  120. }
  121. catch (Exception ex)
  122. {
  123. return FailMessageStatus<List<WcsBasPlcResult>>($"查询WCS基础PLC配置数据发生异常,【{ex.Message}】", null);
  124. }
  125. }
  126. }
  127. }