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 全局变量、构造注入 /// /// 系统操作仓储中转 /// private IDataRepositoryContext _dataContext; /// /// SQL节点仓储 /// private ISQLNodeRepository _iSQLNodeRepository; /// /// 配置 /// private IConfiguration _configuration; /// /// 构造注入 /// /// /// /// public MaterielMsgForAddArrivalService(IDataRepositoryContext dataRepositoryContext, IConfiguration configuration, ISQLNodeRepository iSQLNodeRepository) { this._dataContext = dataRepositoryContext; this._configuration = configuration; this._iSQLNodeRepository = iSQLNodeRepository; } #endregion public OperateResultInfo> 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 resultList = new DataRepository(_dataContext).Query(sql).ToList(); OperateResultInfo> retDataMsg = SuccessStatus(resultList); return retDataMsg; } catch (Exception ex) { return FailMessageStatus>($"查询物料基础信息发生异常!,【{ex.Message}】", null); } } } }