using Masuit.Tools; using NewPdaSqlServer.DB; using NewPdaSqlServer.Dto.service; using NewPdaSqlServer.entity; using SqlSugar; using System.Data; using System.Data.SqlClient; using System.Text; using static Microsoft.EntityFrameworkCore.DbLoggerCategory; namespace NewPdaSqlServer.service.Warehouse; public class MesKwcxManager : Repository { public dynamic GetBarInfoList(dynamic unity) { var sqlParams = new List { new("@deptSectionCode", unity.deptSectionCode), new("@rkDate", string.IsNullOrWhiteSpace(unity.rkDate?.ToString()) ? DBNull.Value : unity.rkDate), new("@zkChecked", unity.zkChecked?.ToString() == "True" ? 1 : unity.zkChecked?.ToString() == "False" ? 0 : DBNull.Value) }; var sql2 = new StringBuilder("exec prc_pda_kwcx_barInfoList @deptSectionCode, @rkDate, @zkChecked"); var list = Db.Ado.SqlQuery(sql2.ToString(), sqlParams); if (list.Count < 1) { throw new Exception("该条件下无对应库位信息!"); } return list; } public dynamic GetBarInfo(dynamic unity) { var sqlParams = new List { }; var sql2 = new StringBuilder(@"exec prc_pda_kwcx_barInfo @BARCODE"); sqlParams.Add(new("@BARCODE", unity.barcode)); var list = Db.Ado.SqlQuery(sql2.ToString(), sqlParams); if (list.Count < 1) { throw new Exception("该条件下无对应条码信息!"); } return list[0]; } public dynamic GetKWList(dynamic unity) { var sqlParams = new List { }; var sql2 = new StringBuilder(@" select depot_code as code, depot_name as name from MES_DEPOTS"); var XcslItem = Db.Ado.SqlQuery(sql2.ToString(), sqlParams); return XcslItem; } public dynamic GetKWInfo(dynamic unity) { var sqlParams = new List { new("@depot_code", unity.code) }; var sql2 = new StringBuilder("exec prc_pda_kwcx_kwInfo @depot_code"); var KWInfo = Db.Ado.SqlQuery(sql2.ToString(), sqlParams); return KWInfo; } public dynamic GetItemInfoList(dynamic unity,dynamic RequestInfo) { var sqlParams = new List { }; var orgId = RequestInfo.OrgId; var sql2 = new StringBuilder(@"exec prc_pda_kwcx_itemInfo @barCode,@itemNo,@orgId"); sqlParams.Add(new("@barCode", unity.barCode)); sqlParams.Add(new("@itemNo", unity.itemNo)); sqlParams.Add(new("@orgId", orgId)); var list = Db.Ado.SqlQuery(sql2.ToString(), sqlParams); if (list.Count < 1) { throw new Exception("该条件下无对应条码信息!"); } return list; } }