using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
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.apiMethod;
|
|
/// <summary>
|
/// 出库流程方法类
|
/// </summary>
|
public abstract class OutWareHouseService
|
{
|
/// <summary>
|
/// 创建出库单
|
/// </summary>
|
public static void CreateOutboundOrderFromMaterialOut(List<MaterialOut> materialOuts)
|
{
|
List<OutboundOrder> outboundOrders = new List<OutboundOrder>();
|
|
// 创建出库单
|
foreach (var materialOut in materialOuts)
|
{
|
// 查询物料表
|
var tnMaterial = AdoSqlMethod<TN_Material>.QueryFirst(p => p.S_ITEM_CODE == materialOut.S_INT_PRODUCT_CODE);
|
|
// 物料表为空
|
if (tnMaterial is null)
|
{
|
if (materialOut.S_ITEM_EMPTY != "物料不存在")
|
{
|
materialOut.S_ITEM_EMPTY = "物料不存在";
|
AdoSqlMethod<MaterialOut>.UpdateFirst(materialOut, p => new { p.S_ITEM_EMPTY });
|
}
|
}
|
else
|
{
|
if (outboundOrders.Count > 0 && outboundOrders.Count(p => p.S_NO == materialOut.S_TRAN_SUB_SEQ) > 0)
|
{
|
if (tnMaterial.ISAUTO == "Y")
|
{
|
materialOut.S_TRANSACTION += "-001";
|
}
|
else
|
{
|
materialOut.S_TRANSACTION += "-002";
|
}
|
|
var outboundOrder = outboundOrders.First(p => p.S_NO == materialOut.S_TRANSACTION);
|
|
outboundOrder.Details.Add(new OutboundDetail()
|
{
|
S_OO_NO = outboundOrder.S_NO,
|
S_SERIAL_NO = outboundOrder.S_NO,
|
N_ROW_NO = materialOut.S_ORDER_LINE,
|
S_BATCH_NO = materialOut.S_LOT,
|
F_QTY = materialOut.S_LOR_QUANTITYOT,
|
S_ITEM_CODE = materialOut.S_INT_PRODUCT_CODE,
|
S_IDENTIFICATION = "MO",
|
S_ITEM_NAME = tnMaterial.S_ITEM_NAME,
|
S_BS_NO = materialOut.S_SO
|
});
|
|
materialOut.S_CREATE_OK = 1;
|
}
|
else
|
{
|
// 创建出库单主表数据
|
OutboundOrder outboundOrder = new OutboundOrder();
|
|
if (tnMaterial.ISAUTO == "Y")
|
{
|
outboundOrder.ISAUTO = "Y";
|
materialOut.S_TRANSACTION += "-001";
|
}
|
else
|
{
|
outboundOrder.ISAUTO = "N";
|
materialOut.S_TRANSACTION += "-002";
|
}
|
|
outboundOrder.S_NO = materialOut.S_TRANSACTION;
|
|
outboundOrder.Details = new List<OutboundDetail>();
|
|
outboundOrder.Details.Add(new OutboundDetail()
|
{
|
S_OO_NO = outboundOrder.S_NO,
|
S_SERIAL_NO = outboundOrder.S_NO,
|
N_ROW_NO = materialOut.S_ORDER_LINE,
|
S_BATCH_NO = materialOut.S_LOT,
|
F_QTY = materialOut.S_LOR_QUANTITYOT,
|
S_ITEM_CODE = materialOut.S_INT_PRODUCT_CODE,
|
S_IDENTIFICATION = "MO",
|
S_ITEM_NAME = tnMaterial.S_ITEM_NAME,
|
S_BS_NO = materialOut.S_SO
|
});
|
|
materialOut.S_CREATE_OK = 1;
|
|
outboundOrders.Add(outboundOrder);
|
}
|
}
|
}
|
|
var querySqlSugarClient = AdoSqlMethod<object>.QuerySqlSugarClient();
|
|
try
|
{
|
querySqlSugarClient.BeginTran();
|
AdoSqlMethod<OutboundOrder>.AddOutboundOrderAndDetailsListTran(querySqlSugarClient, outboundOrders);
|
AdoSqlMethod<MaterialOut>.UpdateListTran(querySqlSugarClient, materialOuts, p => new { p.S_CREATE_OK });
|
querySqlSugarClient.CommitTran();
|
}
|
catch (Exception e)
|
{
|
Console.WriteLine(e);
|
querySqlSugarClient.RollbackTran();
|
}
|
}
|
|
/// <summary>
|
/// 创建出库单
|
/// </summary>
|
public static void CreateOutboundOrderFromDoOut(List<DoOut> doOuts)
|
{
|
List<OutboundOrder> outboundOrders = new List<OutboundOrder>();
|
|
// 创建出库单
|
foreach (var doOut in doOuts)
|
{
|
// 查询物料表
|
var tnMaterial = AdoSqlMethod<TN_Material>.QueryFirst(p => p.S_ITEM_CODE == doOut.S_INT_PRODUCT_CODE);
|
|
if (tnMaterial == null)
|
{
|
if (doOut.S_ITEM_EMPTY != "物料不存在")
|
{
|
doOut.S_ITEM_EMPTY = "物料不存在";
|
AdoSqlMethod<DoOut>.UpdateFirst(doOut, p => new { p.S_ITEM_EMPTY });
|
}
|
}
|
else
|
{
|
if (tnMaterial.ISAUTO == "Y")
|
{
|
doOut.S_TRANSACTION += "-001";
|
}
|
else
|
{
|
doOut.S_TRANSACTION += "-002";
|
}
|
|
if (outboundOrders.Count > 0 && outboundOrders.Count(p => p.S_NO == doOut.S_TRANSACTION) > 0)
|
{
|
var outboundOrder = outboundOrders.First(p => p.S_NO == doOut.S_TRANSACTION);
|
|
outboundOrder.Details.Add(new OutboundDetail
|
{
|
S_OO_NO = outboundOrder.S_NO,
|
S_SERIAL_NO = outboundOrder.S_NO,
|
N_ROW_NO = doOut.S_ORDER_LINE,
|
S_BATCH_NO = doOut.S_LOT,
|
F_QTY = doOut.S_LOR_QUANTITYOT,
|
S_ITEM_CODE = doOut.S_INT_PRODUCT_CODE,
|
S_IDENTIFICATION = "DO",
|
S_ITEM_NAME = tnMaterial.S_ITEM_NAME,
|
S_BS_NO = doOut.S_SO
|
});
|
|
doOut.S_CREATE_OK = 1;
|
}
|
else
|
{
|
// 创建出库单主表数据
|
OutboundOrder outboundOrder = new OutboundOrder();
|
|
if (tnMaterial.ISAUTO == "Y")
|
{
|
outboundOrder.ISAUTO = "Y";
|
doOut.S_TRANSACTION += "-001";
|
}
|
else
|
{
|
outboundOrder.ISAUTO = "N";
|
doOut.S_TRANSACTION += "-002";
|
}
|
|
outboundOrder.S_NO = doOut.S_TRANSACTION;
|
|
outboundOrder.Details = new List<OutboundDetail>();
|
|
outboundOrder.Details.Add(new OutboundDetail()
|
{
|
S_OO_NO = outboundOrder.S_NO,
|
S_SERIAL_NO = outboundOrder.S_NO,
|
N_ROW_NO = doOut.S_ORDER_LINE,
|
S_BATCH_NO = doOut.S_LOT,
|
F_QTY = doOut.S_LOR_QUANTITYOT,
|
S_ITEM_CODE = doOut.S_INT_PRODUCT_CODE,
|
S_IDENTIFICATION = "DO",
|
S_ITEM_NAME = tnMaterial.S_ITEM_NAME,
|
S_BS_NO = doOut.S_SO,
|
});
|
|
doOut.S_CREATE_OK = 1;
|
|
outboundOrders.Add(outboundOrder);
|
}
|
}
|
}
|
|
var querySqlSugarClient = AdoSqlMethod<object>.QuerySqlSugarClient();
|
|
try
|
{
|
querySqlSugarClient.BeginTran();
|
AdoSqlMethod<OutboundOrder>.AddOutboundOrderAndDetailsListTran(querySqlSugarClient, outboundOrders);
|
AdoSqlMethod<DoOut>.UpdateListTran(querySqlSugarClient, doOuts, p => new { p.S_CREATE_OK });
|
querySqlSugarClient.CommitTran();
|
}
|
catch (Exception e)
|
{
|
Console.WriteLine(e);
|
querySqlSugarClient.RollbackTran();
|
}
|
}
|
|
/// <summary>
|
/// 结果确定
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
public static ApiModel.SimpleResult ResultDetermination(ResultDeterminationDto input)
|
{
|
var result = new ApiModel.SimpleResult();
|
|
var container = AdoSqlMethod<Container>.QueryFirst(p => p.S_CODE == input.cntrCode);
|
|
// 判断托盘在容器表中是存在
|
if (container != null)
|
{
|
// 托盘存在，将托盘变更为可用状态
|
container.C_ENABLE = 'Y';
|
|
// 找到所有的容器货品明细数据
|
var cntrItemDetails = AdoSqlMethod<CntrItemDetail>.QueryList(p => p.S_CNTR_CODE == input.cntrCode);
|
|
if (cntrItemDetails.Count > 0)
|
{
|
// 容器货品明细数据存在
|
foreach (var cntrItemDetail in cntrItemDetails)
|
{
|
cntrItemDetail.F_QTY -= cntrItemDetail.F_ALLOC_QTY;
|
cntrItemDetail.F_ALLOC_QTY = 0;
|
|
// 如果当前容器货品明细数据为0
|
if (cntrItemDetail.F_QTY == 0)
|
{
|
// 删除容器货品明细
|
AdoSqlMethod<CntrItemDetail>.DeleteFirst(cntrItemDetail);
|
container.N_DETAIL_COUNT -= 1;
|
}
|
else
|
{
|
AdoSqlMethod<CntrItemDetail>.UpdateFirst(cntrItemDetail, p => new { p.F_QTY, p.F_ALLOC_QTY });
|
}
|
}
|
|
// 找到对应的配盘明细数据
|
var distributionCntrDetails = AdoSqlMethod<TN_Distribution_CNTR_Detail>
|
.QueryList(p => input.ids.Contains(p.S_ID));
|
|
if (distributionCntrDetails.Count > 0)
|
{
|
var moBoxInputDto = new MoBoxInputDto();
|
moBoxInputDto.op_type = 4;
|
|
var moBoxInputDto2 = new MoBoxInputDto();
|
moBoxInputDto2.op_type = 7;
|
|
foreach (var distribution in distributionCntrDetails)
|
{
|
distribution.IS_SORTING = "Y";
|
distribution.F_ACC_P_QTY = distribution.F_QTY;
|
|
var moBoxInputDetailDto = new MoBoxInputDetailDto();
|
moBoxInputDetailDto.item_code = distribution.S_ITEM_CODE;
|
moBoxInputDetailDto.item_name = distribution.S_ITEM_NAME;
|
moBoxInputDetailDto.qty = Convert.ToInt32(distribution.F_QTY);
|
moBoxInputDetailDto.wh_code = Settings.WHCode;
|
moBoxInputDetailDto.area_code = Settings.AreaCode;
|
|
var moBoxInputDetailDto2 = new MoBoxInputDetailDto();
|
moBoxInputDetailDto2.item_code = distribution.S_ITEM_CODE;
|
moBoxInputDetailDto2.item_name = distribution.S_ITEM_NAME;
|
moBoxInputDetailDto2.qty = Convert.ToInt32(distribution.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);
|
|
AdoSqlMethod<TN_Distribution_CNTR_Detail>.UpdateList(distributionCntrDetails,
|
p => new { p.IS_SORTING, p.F_ACC_P_QTY });
|
|
var tnDistributionCntr = AdoSqlMethod<TN_Distribution_CNTR>.QueryFirst(p => distributionCntrDetails[0].S_DC_NO == p.S_DC_NO);
|
|
if (tnDistributionCntr != null)
|
{
|
// 根据主表找到所有的配盘子表数据
|
var tnDistributionCntrDetails =
|
AdoSqlMethod<TN_Distribution_CNTR_Detail>.QueryList(p =>
|
p.S_DC_NO == tnDistributionCntr.S_DC_NO);
|
|
// 配盘明细完成的数量和总数量一致，出库单完成
|
if (tnDistributionCntrDetails.Count(p => p.IS_SORTING == "Y") ==
|
tnDistributionCntrDetails.Count)
|
{
|
tnDistributionCntr.N_B_STATE = 6;
|
tnDistributionCntr.S_B_STATE = "完成";
|
AdoSqlMethod<TN_Distribution_CNTR>.UpdateFirst(tnDistributionCntr, p => new { p.N_B_STATE, p.S_B_STATE });
|
|
var tnDistributionCntrs = AdoSqlMethod<TN_Distribution_CNTR>.QueryList(p => p.S_BS_NO == tnDistributionCntr.S_BS_NO);
|
|
if (tnDistributionCntrs.Count(p => p.N_B_STATE == 6) == tnDistributionCntrs.Count)
|
{
|
var outboundOrder = AdoSqlMethod<OutboundOrder>.QueryFirst(p => p.S_NO == tnDistributionCntr.S_BS_NO);
|
outboundOrder.N_B_STATE = 4;
|
AdoSqlMethod<OutboundOrder>.UpdateFirst(outboundOrder, p => new { p.N_B_STATE });
|
}
|
}
|
}
|
|
AdoSqlMethod<Container>.UpdateFirst(container, p => new { p.C_ENABLE, p.N_DETAIL_COUNT });
|
}
|
else
|
{
|
result.resultCode = -1;
|
result.resultMsg = $"当前容器{input.cntrCode}的配盘单明细数据不存在";
|
}
|
}
|
else
|
{
|
result.resultCode = -1;
|
result.resultMsg = $"当前容器{input.cntrCode}的容器货品明细数据不存在";
|
}
|
}
|
else
|
{
|
result.resultCode = -1;
|
result.resultMsg = $"当前容器{input.cntrCode}不存在";
|
}
|
|
return result;
|
}
|
|
/// <summary>
|
/// 指引出库结果确定
|
/// </summary>
|
/// <returns></returns>
|
public static ApiModel.SimpleResult ResultDeterminationGuideOut(Task task)
|
{
|
var result = new ApiModel.SimpleResult();
|
|
// 找到所有的容器货品明细数据
|
var cntrItemDetails = AdoSqlMethod<CntrItemDetail>.QueryList(p => p.S_CNTR_CODE == task.S_CNTR_CODE);
|
|
if (cntrItemDetails.Count > 0)
|
{
|
var moBoxInputDto = new MoBoxInputDto();
|
moBoxInputDto.op_type = 4;
|
|
var moBoxInputDto2 = new MoBoxInputDto();
|
moBoxInputDto2.op_type = 7;
|
|
foreach (var distribution in cntrItemDetails)
|
{
|
var moBoxInputDetailDto = new MoBoxInputDetailDto();
|
moBoxInputDetailDto.item_code = distribution.S_ITEM_CODE;
|
moBoxInputDetailDto.item_name = distribution.S_ITEM_NAME;
|
moBoxInputDetailDto.qty = Convert.ToInt32(distribution.F_QTY);
|
moBoxInputDetailDto.wh_code = Settings.WHCode;
|
moBoxInputDetailDto.area_code = Settings.AreaCode;
|
|
var moBoxInputDetailDto2 = new MoBoxInputDetailDto();
|
moBoxInputDetailDto2.item_code = distribution.S_ITEM_CODE;
|
moBoxInputDetailDto2.item_name = distribution.S_ITEM_NAME;
|
moBoxInputDetailDto2.qty = Convert.ToInt32(distribution.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);
|
}
|
|
return result;
|
}
|
|
/// <summary>
|
/// 指引出库
|
/// </summary>
|
/// <param name="input"></param>
|
public static ApiModel.SimpleResult GuideOut(OperationDto input)
|
{
|
var result = new ApiModel.SimpleResult();
|
|
// 1.查询容器货位表
|
var locCntrRel = AdoSqlMethod<LocCntrRel>.QueryFirst(p => p.S_CNTR_CODE == input.cntrCode);
|
|
if (locCntrRel == null)
|
{
|
result.resultCode = -1;
|
result.resultMsg = "该容器的容器货位不存在";
|
return result;
|
}
|
|
// 2. 确定起点
|
input.startLocation = locCntrRel.S_LOC_CODE;
|
input.taskType = 5;
|
|
// 3.调用创建任务的接口
|
return SynthesizeService.AddOperation(input);
|
}
|
}
|
