Wms_WebApi/NXWMS.WebApi/NXWMS.Service/NXWMS/WcsBase/WcsBaseService.cs

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);
            }
        }
    }
}