using System;
|
using HH.WCS.Mobox3.RiDong.dto;
|
using HH.WCS.Mobox3.RiDong.generalMethod;
|
using HH.WCS.Mobox3.RiDong.models;
|
using HH.WCS.Mobox3.RiDong.util;
|
|
namespace HH.WCS.Mobox3.RiDong.wms;
|
|
/// <summary>
|
/// 容器帮助类
|
/// </summary>
|
internal static class ContainerHelper
|
{
|
/// <summary>
|
/// enable 让托盘允许被出库计算到，同时增加量表数据
|
/// </summary>
|
/// <param name="cntr"></param>
|
/// <param name="loc"></param>
|
internal static void Enable(string cntr, string loc)
|
{
|
var db = new SqlHelper<object>().GetInstance();
|
|
var cntrInfo = db.Queryable<Container>().Where(a => a.S_CODE == cntr).First();
|
|
//获取仓库量表
|
//获取物理库区
|
//获取逻辑库区
|
if (cntrInfo != null)
|
{
|
var querySqlSugarClient = AdoSqlMethod<object>.QuerySqlSugarClient();
|
|
try
|
{
|
querySqlSugarClient.BeginTran();
|
|
//防止接口重复调用，量表重复增加
|
if (cntrInfo.C_ENABLE == 'N')
|
{
|
cntrInfo.C_ENABLE = 'Y';
|
AdoSqlMethod<Container>.UpdateFirstTran(querySqlSugarClient, cntrInfo,
|
p => new { p.C_ENABLE, p.T_MODIFY });
|
|
var cirList = db.Queryable<CntrItemDetail>().Where(a => a.S_CNTR_CODE == cntr).ToList();
|
|
if (cirList.Count > 0)
|
{
|
var moBoxInputDto = new MoBoxInputDto();
|
moBoxInputDto.op_type = 5;
|
|
var moBoxInputDto2 = new MoBoxInputDto();
|
moBoxInputDto2.op_type = 6;
|
|
cirList.ForEach(a =>
|
{
|
var moBoxInputDetailDto = new MoBoxInputDetailDto();
|
var moBoxInputDetailDto2 = new MoBoxInputDetailDto();
|
|
moBoxInputDetailDto.item_code = a.S_ITEM_CODE;
|
moBoxInputDetailDto.item_name = a.S_ITEM_NAME;
|
moBoxInputDetailDto.qty = Convert.ToInt32(a.F_QTY);
|
moBoxInputDetailDto.wh_code = Settings.WHCode;
|
moBoxInputDetailDto.area_code = Settings.AreaCode;
|
|
moBoxInputDetailDto2.item_code = a.S_ITEM_CODE;
|
moBoxInputDetailDto2.item_name = a.S_ITEM_NAME;
|
moBoxInputDetailDto2.qty = Convert.ToInt32(a.F_QTY);
|
moBoxInputDetailDto2.area_code = Settings.AreaCode;
|
moBoxInputDetailDto2.wh_code = Settings.WHCode;
|
|
moBoxInputDto.item_info.Add(moBoxInputDetailDto);
|
moBoxInputDto2.item_info.Add(moBoxInputDetailDto2);
|
});
|
|
// 调用第三方接口
|
ThirdlyPortMethod.CallMoboxWMSAddChange("/api/wms/inventory/AddChange", moBoxInputDto);
|
|
ThirdlyPortMethod.CallMoboxWMSAddChange("/api/wms/inventory/AddChange", moBoxInputDto2);
|
|
}
|
}
|
querySqlSugarClient.CommitTran();
|
}
|
catch (Exception ex)
|
{
|
Console.WriteLine(ex.Message);
|
querySqlSugarClient.RollbackTran();
|
}
|
}
|
}
|
|
/// <summary>
|
/// 根据容器号获取容器信息
|
/// </summary>
|
/// <param name="cntr"></param>
|
/// <param name="type"></param>
|
/// <returns></returns>
|
internal static Container GetCntr(string cntr, string type)
|
{
|
// 查询托盘是否存在
|
var container = AdoSqlMethod<Container>.QueryFirst(p => p.S_CODE == cntr);
|
|
// 判断容器是否存在
|
if (container == null)
|
{
|
var model = new Container { S_CODE = cntr, S_TYPE = type };
|
|
// 判断是否创建成功
|
if (AdoSqlMethod<Container>.AddFirst(model))
|
{
|
container = model;
|
LogHelper.Info($"根据托盘号：{cntr},查询容器表中数据，未查询到数据，新键容器数据为：【容器编号：{cntr},容器类型：{type}】，时间点：{DateTime.Now}",
|
"入库流程日志");
|
}
|
}
|
else
|
{
|
LogHelper.Info(
|
$"根据托盘号：{cntr},查询容器表中数据，查询到的数据为：【容器编码：{container.S_CODE}，容器状态（'Y'- 可用，'N'- 不可用）：{container.C_ENABLE}," +
|
$"容器数量：{container.N_DETAIL_COUNT}】,容器的锁状态1（0 - 无锁，1 - 入库锁，2 - 出库锁，3 - 其他锁）：{container.N_LOCK_STATE}，" +
|
$"容器的锁状态2：{container.S_LOCK_STATE}】，时间点：{DateTime.Now}", "入库流程日志");
|
}
|
|
// 返回托盘（容器）信息
|
return container;
|
}
|
}
|
