123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131 |
- using DapperORMCore.Context.DataContext;
- using DapperORMCore.Model.CoreModel;
- using DapperORMCore.Repository.IRepositorys;
- using Microsoft.Extensions.Configuration;
- using NXWMS.IService.NXWMS.WcsBase;
- using NXWMS.Model.AppModels.Result.WcsBase;
- using NXWMS.Model.Common;
- 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.WcsBase
- {
- /// <summary>
- /// WCS基础相关服务
- /// </summary>
- [AutoInject(typeof(IWcsBaseService), InjectType.Scope)]
- public class WcsBaseService : ServiceBase, IWcsBaseService
- {
- #region 全局变量、构造注入
- /// <summary>
- /// 系统操作仓储中转
- /// </summary>
- private IDataRepositoryContext _dataContext;
- /// <summary>
- /// SQL节点仓储
- /// </summary>
- private ISQLNodeRepository _iSQLNodeRepository;
- /// <summary>
- /// 配置
- /// </summary>
- private IConfiguration _configuration;
- /// <summary>
- /// 构造注入
- /// </summary>
- /// <param name="dataRepositoryContext"></param>
- /// <param name="configuration"></param>
- /// <param name="iSQLNodeRepository"></param>
- public WcsBaseService(IDataRepositoryContext dataRepositoryContext, IConfiguration configuration, ISQLNodeRepository iSQLNodeRepository)
- {
- this._dataContext = dataRepositoryContext;
- this._configuration = configuration;
- this._iSQLNodeRepository = iSQLNodeRepository;
- }
- #endregion
- /// <summary>
- /// 查询设备类型基础数据
- /// </summary>
- /// <returns></returns>
- public OperateResultInfo<List<WcsBasDevTypeResult>> GetDevTypeData()
- {
- try
- {
- string sql = $@"
- SELECT
- A.*,
- CASE A.USED_FLAG
- WHEN 0 THEN
- '禁用'
- ELSE
- '启用'
- END USED_FLAG_NAME,
- CASE A.DEL_FLAG
- WHEN 0 THEN
- '未删除'
- ELSE
- '已删除'
- END DEL_FLAG_NAME,
- B.USER_NAME CREATE_NAME,
- C.USER_NAME UPDATE_NAME
- FROM
- WCS_BAS_DEV_TYPE A
- LEFT JOIN SYS_USER B ON A.CREATE_BY = B.USER_ID
- LEFT JOIN SYS_USER C ON A.UPDATE_BY = C.USER_ID
- ";
- List<WcsBasDevTypeResult> resultList = new DataRepository<WcsBasDevTypeResult>(_dataContext).Query(sql).ToList();
- OperateResultInfo<List<WcsBasDevTypeResult>> retDataMsg = SuccessStatus(resultList);
- return retDataMsg;
- }
- catch (Exception ex)
- {
- return FailMessageStatus<List<WcsBasDevTypeResult>>($"查询WCS设备类型数据发生异常,【{ex.Message}】", null);
- }
- }
- /// <summary>
- /// 查询PLC配置基础数据
- /// </summary>
- /// <returns></returns>
- public OperateResultInfo<List<WcsBasPlcResult>> GetWcsPlcData()
- {
- try
- {
- string sql = $@"
- SELECT
- A.*,
- CASE A.USED_FLAG
- WHEN 0 THEN
- '禁用'
- ELSE
- '启用'
- END USED_FLAG_NAME,
- CASE A.DEL_FLAG
- WHEN 0 THEN
- '未删除'
- ELSE
- '已删除'
- END DEL_FLAG_NAME,
- B.USER_NAME CREATE_NAME,
- C.USER_NAME UPDATE_NAME
- FROM
- WCS_BAS_PLC A
- LEFT JOIN SYS_USER B ON A.CREATE_BY = B.USER_ID
- LEFT JOIN SYS_USER C ON A.UPDATE_BY = C.USER_ID
- ";
- List<WcsBasPlcResult> resultList = new DataRepository<WcsBasPlcResult>(_dataContext).Query(sql).ToList();
- OperateResultInfo<List<WcsBasPlcResult>> retDataMsg = SuccessStatus(resultList);
- return retDataMsg;
- }
- catch (Exception ex)
- {
- return FailMessageStatus<List<WcsBasPlcResult>>($"查询WCS基础PLC配置数据发生异常,【{ex.Message}】", null);
- }
- }
- }
- }
|