using Dapper; using Estsh.Core.Base; using Estsh.Core.Dapper; using Estsh.Core.Wms.IRepositories; using Estsh.Core.Model.Result; using Estsh.Core.Repositories; using System.Collections; using System.Data; using System.Text; using System.Security.Cryptography; using System.Text.Json; using Estsh.Core.Models; using Newtonsoft.Json.Linq; using Estsh.Core.Model.EnumUtil; namespace Estsh.Core.Wms.Repositories { public class StockRepository : BaseRepository, IStockRepository { public StockRepository(DapperDbContext _dapperDbContext) : base(_dapperDbContext) { } /// /// 获取箱条码信息 /// /// /// public SysStock GetCartonInfo(string cartonNo) { using (IDbConnection dbConn = dapperDbContext.GetDbConnection()) { dbConn.Open(); string result = string.Empty; StringBuilder sql = new StringBuilder(1024); sql.Append("select * from sys_stock (nolock) where carton_no=@carton_no "); DynamicParameters parameters = new DynamicParameters(); parameters.Add("@carton_no", cartonNo); //List dt = dbConn.Query(sql.ToString(), parameters).ToList(); return dbConn.QueryFirstOrDefault(sql.ToString(), parameters); } } /// /// 获取库位对应的库存信息 /// /// /// public List GetLocateStockInfo(string locateName) { using (IDbConnection dbConn = dapperDbContext.GetDbConnection()) { dbConn.Open(); string result = string.Empty; StringBuilder sql = new StringBuilder(1024); sql.Append("SELECT * FROM dbo.sys_stock (nolock) WHERE enabled = 'Y' AND locate_name = @locateName "); DynamicParameters parameters = new DynamicParameters(); parameters.Add("@locateName", locateName); List stocks = dbConn.Query(sql.ToString(), parameters).ToList(); return stocks; } } } }