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