Wms_WebApi/NXWMS.WebApi/NXWMS.Service/NXWMS/Common/MaterielMsgForAddArrivalService.cs

using DapperORMCore.Context.DataContext;
using DapperORMCore.Model.CoreModel;
using DapperORMCore.Repository.IRepositorys;
using Microsoft.Extensions.Configuration;
using NXWMS.IService.NXWMS.Common;
using NXWMS.Model.AppModels.Result.Common;
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.Common
{
    [AutoInject(typeof(IMaterielMsgForAddArrivalService), InjectType.Scope)]
    public class MaterielMsgForAddArrivalService : ServiceBase, IMaterielMsgForAddArrivalService
    {
        #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 MaterielMsgForAddArrivalService(IDataRepositoryContext dataRepositoryContext, IConfiguration configuration, ISQLNodeRepository iSQLNodeRepository)
        {
            this._dataContext = dataRepositoryContext;
            this._configuration = configuration;
            this._iSQLNodeRepository = iSQLNodeRepository;
        }
        #endregion

        public OperateResultInfo<List<MaterielMsgForAddArrivalResult>> GetMaterielMsgForAddArrival()
        {
            try
            {
                string sql = $@"
                                SELECT
	                                A.MATERIEL_CODE,
	                                A.MATERIEL_NAME,
	                                '' MATERIEL_BARCODE,
	                                B.MATERIEL_TYPE_CODE,
	                                B.MATERIEL_TYPE_NAME
                                FROM
	                                BAS_MATERIEL A
                                LEFT JOIN BAS_MATERIEL_TYPE B ON A.MATERIEL_TYPE = B.MATERIEL_TYPE_CODE
                                WHERE
	                                A.USED_FLAG = 1
                                AND A.DEL_FLAG = 0
                                AND B.USED_FLAG = 1
                                AND B.DEL_FLAG = 0
                            ";
                List<MaterielMsgForAddArrivalResult> resultList = new DataRepository<MaterielMsgForAddArrivalResult>(_dataContext).Query(sql).ToList();
                OperateResultInfo<List<MaterielMsgForAddArrivalResult>> retDataMsg = SuccessStatus(resultList);
                return retDataMsg;
            }
            catch (Exception ex)
            {
                return FailMessageStatus<List<MaterielMsgForAddArrivalResult>>($"查询物料基础信息发生异常！，【{ex.Message}】", null);
            }
        }
    }
}