using System.Data;
|
using System.Data.SqlClient;
|
using Masuit.Tools;
|
using Masuit.Tools.Hardware;
|
using NewPdaSqlServer.DB;
|
using NewPdaSqlServer.Dto.service;
|
using NewPdaSqlServer.entity;
|
using SqlSugar;
|
using static Microsoft.EntityFrameworkCore.DbLoggerCategory;
|
|
namespace NewPdaSqlServer.service.Warehouse;
|
|
/// <summary>
|
/// 库位变更管理类，继承自通用仓储类Repository，操作采购退货申请表（MesCgthSq）
|
/// </summary>
|
public class KwbgManager : Repository<MesCgthSq>
|
{
|
/// <summary>
|
/// 根据传入的WarehouseQuery对象（包含条码信息），查询物料库存表MES_INV_ITEM_STOCKS，获取对应的库存信息
|
/// </summary>
|
/// <param name="unity">WarehouseQuery对象，包含条码编号等查询条件</param>
|
/// <returns>
|
/// 返回MES_INV_ITEM_STOCKS表中与条码匹配的第一条库存信息（MesInvItemStocks类型）。
|
/// 如果未找到，则抛出异常提示“该条码库存不存在！”
|
/// resultInfos.tbBillList = m.GetBarInfo(unity);
|
/// </returns>
|
///public MesInvItemStocks GetBarInfo(WarehouseQuery unity)
|
public dynamic GetBarInfo(dynamic query)
|
{
|
if (query == null)
|
throw new ArgumentNullException(nameof(query), "参数对象不能为null");
|
|
if (string.IsNullOrEmpty(query.barcode?.ToString()))
|
throw new ArgumentException("物料条码不能为空", nameof(query.barcode));
|
|
var parameters = new[]
|
{
|
new SugarParameter("@pi_barcode", query.barcode),
|
new SugarParameter("@inP1", null),
|
new SugarParameter("@inP2", null),
|
new SugarParameter("@inP3", null),
|
new SugarParameter("@inP4", null)
|
};
|
|
try
|
{
|
List<dynamic>? ZsBarInfo = Db.Ado.SqlQuery<dynamic>(
|
"EXEC prc_pda_kwbg_selKwInfoByBarcode @pi_barcode,@inP1,@inP2,@inP3,@inP4", parameters);
|
|
return ZsBarInfo;
|
}
|
catch (Exception ex)
|
{
|
// 保留原有异常处理逻辑
|
throw new Exception($"{ex.Message}");
|
}
|
}
|
|
/// <summary>
|
/// 根据物料ID查询物料表MES_ITEMS，获取物料详细信息
|
/// </summary>
|
/// <param name="strItemId">物料ID（decimal类型）</param>
|
/// <returns>
|
/// 返回MES_ITEMS表中与ID匹配且未禁用（Fforbidstatus为"A"）的第一条物料信息（MesItems类型）。
|
/// 如果未找到，则抛出异常提示“该条码对应物料信息不存在或已禁用！”
|
/// resultInfos.tbMesItems = m.GetItemNo(resultInfos.tbBillList.ItemId);
|
/// </returns>
|
public MesItems GetItemNo(decimal strItemId)
|
{
|
// 使用SqlSugar的Queryable方法，查询MES_ITEMS表
|
// 条件：Id字段等于strItemId，且Fforbidstatus字段为"A"（表示未禁用）
|
var itemInfo = Db.Queryable<MesItems>()
|
.Where(s => s.Id == strItemId && s.Fforbidstatus == "A")
|
.First(); // 获取第一条匹配记录
|
|
// 如果未查询到结果（itemInfo为null），则抛出异常，提示物料信息不存在或已禁用
|
if (itemInfo is null) throw new Exception("该条码对应物料信息不存在或已禁用！");
|
|
// 返回查询到的物料信息对象
|
return itemInfo;
|
}
|
/// <summary>
|
/// 仓库信息表
|
/// </summary>
|
/// <param name="depot_id"></param>
|
/// <returns></returns>
|
public MesDepots GetDepot(decimal depot_id)
|
{
|
var depotInfo = Db.Queryable< MesDepots >()
|
.Where(s => s.DepotId == depot_id)
|
.First(); // 获取第一条匹配记录
|
// 如果未查询到结果（itemInfo为null），则抛出异常，提示物料信息不存在或已禁用
|
if (depotInfo is null) throw new Exception("该条码库存不存在仓库！");
|
return depotInfo;
|
}
|
|
|
|
/// <summary>
|
/// 变更库位
|
/// </summary>
|
/// <param name="unity"></param>
|
/// <returns></returns>
|
/// <exception cref="Exception"></exception>
|
public dynamic ChangeDepotSection(dynamic unity)
|
{
|
// 存储过程输出信息
|
var _strMsg = "";
|
// 存储过程输出的数量（用于判断变更是否成功）
|
var _intSum = "";
|
// 存储过程输出的新库位代码
|
var _NewDepotSectionCode = ""; // 新库位代码
|
|
// 创建SQL连接，使用配置的连接字符串
|
using (var conn = new SqlConnection(DbHelperSQL.strConn))
|
{
|
//if (string.IsNullOrEmpty(query.barcode?.ToString()))
|
//throw new ArgumentException("物料条码不能为空", nameof(query.barcode));
|
|
if (string.IsNullOrEmpty(unity.userName?.ToString()))
|
throw new ArgumentException("用户名不允许为空", nameof(unity.userName));
|
if (string.IsNullOrEmpty(unity.OldDepotSectionCode?.ToString()))
|
throw new ArgumentException("原库位不允许为空", nameof(unity.OldDepotSectionCode));
|
if (string.IsNullOrEmpty(unity.NewDepotSectionCode?.ToString()))
|
throw new ArgumentException("新库位不允许为空", nameof(unity.NewDepotSectionCode));
|
if (string.IsNullOrEmpty(unity.barcode?.ToString()))
|
throw new ArgumentException("物料条码不允许为空", nameof(unity.barcode));
|
|
//if (unity.userName.IsNullOrEmpty()) throw new Exception("用户名不允许为空");
|
//if (unity.OldDepotSectionCode.IsNullOrEmpty()) throw new Exception("原库位不允许为空");
|
//if (unity.NewDepotSectionCode.IsNullOrEmpty()) throw new Exception("新库位不允许为空");
|
//if (unity.barcode.IsNullOrEmpty()) throw new Exception("物料条码不允许为空");
|
|
// 创建SQL命令，指定要执行的存储过程
|
using (var cmd = new SqlCommand("[prc_pda_change_depot]", conn))
|
{
|
try
|
{
|
// 打开数据库连接
|
conn.Open();
|
// 设置命令类型为存储过程
|
cmd.CommandType = CommandType.StoredProcedure;
|
|
// 构造存储过程参数数组
|
SqlParameter[] parameters =
|
{
|
// 输出参数：返回信息
|
new("@outMsg", SqlDbType.NVarChar, 2000),
|
// 输出参数：返回数量
|
new("@outSum", SqlDbType.Int),
|
// 输出参数：返回新库位代码
|
new("@new_depotSectionsCode", SqlDbType.NVarChar, 300),
|
// 输入参数：操作用户
|
new SqlParameter("@c_user", unity.userName?.ToString() ?? ""),
|
// 输入参数：原条码
|
new SqlParameter("@p_barcode", unity.barcode?.ToString() ?? ""),
|
// 输入参数：原库位代码
|
new("@old_depotSectionsCode", unity.OldDepotSectionCode?.ToString() ??""),
|
// 输入参数：新库位代码
|
new("@new_depotSectionsCode_input", unity.NewDepotSectionCode?.ToString() ??""),
|
// 输入参数：仓库代码
|
new("@DepotCode", unity.DepotCode) { Value = unity.DepotCode ?? "" },
|
// 输入参数：仓库id
|
new SqlParameter("@DepotId", (int?)unity.DepotId ?? (object)DBNull.Value)
|
};
|
// 设置输出参数方向
|
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(); // 返回数量
|
_NewDepotSectionCode = parameters[2].Value.ToString(); // 新库位代码
|
|
// 判断变更结果，如果数量小于等于0，则表示变更失败，抛出异常并返回错误信息
|
var result = Convert.ToInt32(_intSum);
|
if (result <= 0) throw new Exception(_strMsg);
|
|
// 使用匿名对象而不是 dynamic? 更合适
|
var dto = new
|
{
|
barcode = unity.barcode,
|
OldDepotSectionCode = unity.OldDepotSectionCode,
|
NewDepotSectionCode = _NewDepotSectionCode
|
};
|
|
return dto;
|
}
|
catch (Exception ex)
|
{
|
// 捕获异常并抛出，保留原始异常信息
|
throw new Exception(ex.Message);
|
}
|
finally
|
{
|
// 关闭数据库连接
|
conn.Close();
|
}
|
}
|
}
|
}
|
/*ProductionPickDto、WarehouseQuery有过添加
|
public string? OldDepotSectionCode { get; set; } //旧库位编码
|
public string? NewDepotSectionCode { get; set; } //新库位编码
|
|
ProductionPickDto有过添加
|
public int? DepotId { get; set; } //仓库id
|
*/
|
|
|
}
|
