using System.Data;
|
using System.Data.SqlClient;
|
using Masuit.Tools;
|
using NewPdaSqlServer.DB;
|
using NewPdaSqlServer.Dto.service;
|
using NewPdaSqlServer.entity;
|
using NewPdaSqlServer.entity.Base;
|
using NewPdaSqlServer.util;
|
using SqlSugar;
|
|
namespace NewPdaSqlServer.service.Warehouse;
|
|
public class MesStrkManager : Repository<MesItemBl>
|
{
|
/// <summary>
|
/// 获取受托入库申请列表
|
/// </summary>
|
/// <returns>受托入库申请列表</returns>
|
public List<string> GetStrkBillNo(WarehouseQuery query)
|
{
|
var list = Db.Queryable<MesShouTuo>()
|
.Where(s => s.IsCheck == true && s.IsFinish == false)
|
.Select(s => s.BillNo).ToList();
|
|
return list;
|
}
|
|
/// <summary>
|
/// 根据单号获取MES物料表明细
|
/// </summary>
|
/// <param name="query">仓库查询参数</param>
|
/// <returns>物料明细列表</returns>
|
public List<ItemDetailModel> GetMesItemDetailByBillNo(
|
WarehouseQuery query)
|
{
|
// 关联查询物料表、物料明细表和物料基础信息表
|
var mesItemTblDetails = Db
|
.Queryable<MesShouTuo, MesShouTuoDetail, MesItems>((a, b, c) =>
|
new JoinQueryInfos(
|
JoinType.Left,
|
a.Guid == b.PGuid,
|
JoinType.Left,
|
b.FMaterialId == c.Id.ToString())
|
).Where((a, b, c) => a.BillNo == query.billNo && a.IsCheck == true)
|
.Select<ItemDetailModel>((a, b, c) => new ItemDetailModel
|
{
|
ItemNo = c.ItemNo,
|
ItemName = c.ItemName,
|
ItemModel = c.ItemModel,
|
FQty = b.FQty, // 申请数量
|
SQty = b.SQty, // 已扫数量
|
Pid = b.PGuid.ToString(),
|
FMaterialId = b.FMaterialId,
|
Id = b.Guid.ToString()
|
}).ToList();
|
|
// 筛选出待退数量大于已退数量的记录
|
//var itemTblDetails = mesItemTblDetails
|
// .Where(s => (s.Tld005 ?? 0) - (s.Tld006 ?? 0) > 0).ToList();
|
|
return mesItemTblDetails;
|
}
|
|
/// <summary>
|
/// 受托入库入库
|
/// </summary>
|
/// <param name="unity"></param>
|
/// <returns></returns>
|
/// <exception cref="Exception"></exception>
|
public string XsthScanBarcode(WarehouseQuery unity)
|
{
|
var _strMsg = "";
|
var _intSum = "";
|
using (var conn = new SqlConnection(DbHelperSQL.strConn))
|
{
|
if (unity.userName.IsNullOrEmpty()) throw new Exception("用户名不允许为空");
|
if (unity.sectionCode.IsNullOrEmpty())
|
throw new Exception("库位编号不允许为空");
|
if (unity.barcode.IsNullOrEmpty()) throw new Exception("条码不允许为空");
|
if (unity.billNo.IsNullOrEmpty()) throw new Exception("申请单号不允许为空");
|
|
using (var cmd = new SqlCommand("[prc_pda_inv_strk]", conn))
|
{
|
try
|
{
|
conn.Open();
|
cmd.CommandType = CommandType.StoredProcedure;
|
SqlParameter[] parameters =
|
{
|
new("@po_outMsg", SqlDbType.NVarChar, 300),
|
new("@po_outSum", SqlDbType.NVarChar, 300),
|
//new("@po_womInBarSum", SqlDbType.NVarChar, 300),
|
new("@pi_user", unity.userName),
|
new("@pi_barcode", unity.barcode),
|
new("@pi_sectionCode", unity.sectionCode),
|
new("@pi_billno", unity.billNo)
|
};
|
parameters[0].Direction = ParameterDirection.Output;
|
parameters[1].Direction = ParameterDirection.Output;
|
// parameters[2].Direction = ParameterDirection.Output;
|
|
foreach (var parameter in parameters)
|
cmd.Parameters.Add(parameter);
|
cmd.ExecuteNonQuery();
|
_strMsg = parameters[0].Value.ToString();
|
_intSum = parameters[1].Value.ToString();
|
|
var result = Convert.ToInt32(_intSum);
|
if (result <= 0) throw new Exception(_strMsg);
|
|
return _strMsg;
|
|
//return 0;
|
}
|
catch (Exception ex)
|
{
|
throw new Exception(ex.Message);
|
}
|
finally
|
{
|
conn.Close();
|
}
|
}
|
}
|
}
|
}
|
