using Rhea.Common;
|
using Microsoft.AspNetCore.Http;
|
using SqlSugar;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Linq.Expressions;
|
using System.Text;
|
using System.Threading;
|
using System.Threading.Tasks;
|
using Tiger.Model;
|
|
using Newtonsoft.Json;
|
using Tiger.IBusiness;
|
|
namespace Tiger.Business.WMS.Transaction
|
{
|
/// <summary>
|
/// 生产领料事务
|
/// </summary>
|
public class OutSplit : WMSTransactionBase, IOutSplit
|
{
|
public IOutSplit Init(string id, string userCode, string apiHost, string orgCode, string fty)
|
{
|
TransID = id;
|
UserCode = userCode;
|
ApiHost = apiHost;
|
OrgCode = orgCode;
|
FTY_CODE = fty;
|
Logger.Console.Info($"Start {this.GetType().Name} Transaction[ID: {TransID}]");
|
return this;
|
}
|
|
#region Propertys & Variables
|
public string UserCode { get; set; }
|
public long UserId { get; set; }
|
public string OrgCode { get; set; }
|
public string FTY_CODE { get; set; }
|
public string ReqNo { get; set; }
|
public string ExceedTranId { get; set; }
|
public Inventory CurInv { get; set; }
|
public ProductionPickToMes toMes { get; set; }
|
public AuthOption option { get; set; }
|
#endregion
|
|
#region Functions
|
|
/// <summary>
|
/// 拆批扫描物料条码
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
public async Task<ApiAction<OutSplitOutput>> ScanItem(OutSplitInput input)
|
{
|
var action = new ApiAction<OutSplitOutput>();
|
try
|
{
|
if (input.SN.IsNullOrEmpty())
|
{
|
action.IsSuccessed = false;
|
action.LocaleMsg = Biz.L("条码不能为空");
|
return action;
|
}
|
//解析条码
|
Result<IInventory> result = WMS_ITEM_Biz.WmsItem.Get(input.SN, input.AuthOption, true);
|
if (!result.IsSuccessed)
|
{
|
action.IsSuccessed = false;
|
action.LocaleMsg = result.LocaleMsg;
|
return action;
|
}
|
CurInv = result.Data as Inventory;
|
if (string.IsNullOrEmpty(CurInv.ItemInfo?.ITEM_CODE))
|
{
|
action.IsSuccessed = false;
|
action.LocaleMsg = Biz.L("WMS.InReceipt.ScanItem.NotFound", CurInv.ItemInfo?.ITEM_CODE);
|
return action;
|
}
|
//物料验证
|
if (CurInv.ItemInfo.IsNullOrEmpty() || CurInv.ItemInfo.IS_ACTIVE == "N")
|
{
|
action.IsSuccessed = false;
|
action.LocaleMsg = Biz.L("WMS.ProdMReq.ScanItem.ItemCodeNotExistsOrNotActive", CurInv.ItemInfo.ITEM_CODE.IsNullOrEmpty(CurInv.Barcode.ItemCode));
|
return action;
|
}
|
if (!CurInv.isExists || CurInv.Status == WMS_ITEM.STATUSs.WaitIn)
|
{
|
action.IsSuccessed = false;
|
action.LocaleMsg = Biz.L("WMS.InReceipt.ScanItem.NotExist", CurInv.SN); //条码[{0}]不存在于系统中
|
return action;
|
}
|
|
ReqNo = input.ReqNo;
|
ExceedTranId = input.ExceedTranId;
|
option = input.AuthOption;
|
|
action.LocaleMsg = Biz.L($"条码[{CurInv.CurPkg.SN}]扫描成功！");
|
action.Data = new OutSplitOutput() {
|
MaterialCode = CurInv.ItemInfo.ITEM_CODE,
|
MaterialName = CurInv.ItemInfo.ITEM_NAME,
|
SupplierCode = CurInv.Items[0].SUPP_CODE,
|
Barcode = CurInv.SN, //批次号即为条码
|
DateCode = CurInv.Items[0].PROD_DATE,
|
LotNo = CurInv.Barcode.LotNo,
|
ScanQty = CurInv.CurPkg.QTY, //批次数量
|
Unit = CurInv.ItemInfo.UNIT
|
};
|
|
}
|
catch (Exception ex)
|
{
|
action.CatchExceptionWithLog(ex, $"扫描物料[{input.SN}]复核异常");
|
}
|
|
return action;
|
|
}
|
|
/// <summary>
|
/// 拆分
|
/// </summary>
|
/// <param name="splitNum"></param>
|
/// <returns></returns>
|
public async Task<ApiAction<OutSplitSubmit>> SplitBarcodeRecord(string qty)
|
{
|
var action = new ApiAction<OutSplitSubmit>();
|
try
|
{
|
Logger.Interface.Info($"拆包 => [{CurInv.SN}]正在准备开始执行拆包操作......");
|
int splitNum = Convert.ToInt32(qty);
|
if (splitNum >= CurInv.CurPkg.QTY || splitNum <= 0)
|
{
|
action.IsSuccessed = false;
|
action.LocaleMsg = Biz.L($"拆批数量有误！");
|
return action;
|
}
|
Logger.Interface.Info($"拆包 => [{CurInv.SN}]当前数量[{CurInv.CurPkg.QTY}],实际数量[{splitNum}]");
|
|
//获取供应商信息
|
var vender = await Biz.Db.Queryable<BAS_SUPPLIER>().Where(t => t.SUPP_CODE == CurInv.Items[0].SUPP_CODE).FirstAsync();
|
|
//生成条码
|
var cutSerial = Convert.ToString(CurInv.Barcode.ReprintNo ?? 0, 2);
|
cutSerial = cutSerial == "0" ? "1" : cutSerial;
|
var orglSn = CurInv.SN.Split("_")[0];
|
|
var nSplitSn = $"{orglSn}_CA{Convert.ToString(Convert.ToInt32(cutSerial + "0", 2), 16).ToUpper()}";
|
var nRemainSn = $"{orglSn}_CB{Convert.ToString(Convert.ToInt32(cutSerial + "1", 2), 16).ToUpper()}";
|
|
if (Biz.Db.Queryable<WMS_ITEM>().Any(t => t.SN == nRemainSn))
|
{
|
//throw new UserFriendlyException(1011, "生成的拆批条码已存在！", vender != null ? vender.VenderSName : "");
|
action.IsSuccessed = false;
|
action.LocaleMsg = Biz.L($"生成的拆批条码已存在！供应商：{vender?.SUPP_NAME_CN}");
|
return action;
|
}
|
|
//#region 操作条码信息
|
|
//条码一
|
var nSplitBarcode1 = CurInv.Items[0];
|
var nSplitBarcode2 = CurInv.Items[0].Clone();
|
nSplitBarcode1.SN = nSplitSn;
|
//nSplitBarcode1.BarcodeStatus = (int)Domain.InvStorageInfoSides.BarcodeStatus.Outstock; //出库状态
|
nSplitBarcode1.QTY = splitNum;
|
nSplitBarcode1.TRANS_CODE = nameof(OutSplit);
|
if (!ReqNo.IsNullOrEmpty())
|
{
|
nSplitBarcode1.STATUS = WMS_ITEM.STATUSs.Sended.GetValue();
|
nSplitBarcode1.LOCATION_ID = "";
|
nSplitBarcode1.REGION_ID = "";
|
nSplitBarcode1.WH_ID = "";
|
nSplitBarcode1.SHELF_ID = "";
|
}
|
|
var nSplitPgk1 = CurInv.CurPkg;
|
var nSplitPgk2 = CurInv.CurPkg.Clone();
|
nSplitPgk1.SN = nSplitSn;
|
nSplitPgk1.QTY = splitNum;
|
if (!ReqNo.IsNullOrEmpty())
|
{
|
nSplitPgk1.LOCATION_ID = "";
|
nSplitPgk1.REGION_ID = "";
|
nSplitPgk1.WH_ID = "";
|
nSplitPgk1.SHELF_ID = "";
|
}
|
|
//条码二
|
nSplitBarcode2.SN = nRemainSn;
|
var currentQty = nSplitBarcode2.QTY;//原条码实际数量
|
nSplitBarcode2.QTY = nSplitBarcode2.QTY - splitNum; //拆分后剩下的数量
|
nSplitBarcode2.ID = Guid.NewGuid().ToString("N");
|
nSplitBarcode2.TRANS_CODE = nameof(OutSplit);
|
if (!ReqNo.IsNullOrEmpty())
|
{
|
nSplitBarcode2.STATUS = WMS_ITEM.STATUSs.InStore.GetValue();
|
}
|
nSplitPgk2.SN = nRemainSn;
|
nSplitPgk2.QTY = nSplitBarcode2.QTY;
|
nSplitPgk2.ID = Guid.NewGuid().ToString("N");
|
|
string msg = ReqNo.IsNullOrEmpty() ? $"手工拆分物料：原条码[{CurInv.SN}，条码一[{nSplitBarcode1.SN}]，条码二[{nSplitBarcode2.SN}]]" : $"自动拆分物料：单据[{ReqNo}]，原条码[{CurInv.SN}，发料条码[{nSplitBarcode1.SN}]，需要上架条码[{nSplitBarcode2.SN}]]";
|
|
if (!ExceedTranId.IsNullOrEmpty())
|
{
|
var MaterialReqTrans = Biz.Db.Queryable<BIZ_ERP_PROD_OUT>().Where(t => t.BILLCODE == ReqNo).Any();
|
var OthReqTrans = Biz.Db.Queryable<BIZ_ERP_OTH_OUT>().Where(t => t.BILLCODE == ReqNo).Any();
|
var SaleReqTrans = Biz.Db.Queryable<BIZ_ERP_SALE_OUT>().Where(t => t.BILLCODE == ReqNo).Any();
|
var TfTrans = Biz.Db.Queryable<BIZ_WMS_TRANSFER>().Where(t => t.BILLCODE == ReqNo).Any();
|
ProductionMaterialReq trans = null;
|
OutWorkOrder owoTrans = null;
|
OutOther othTrans = null;
|
OutSale saleTrans = null;
|
OutTransfer tfTrans = null;
|
if (WMSContext.TransactionDic.ContainsKey(ExceedTranId))
|
{
|
trans = WMSContext.TransactionDic[ExceedTranId] as ProductionMaterialReq;
|
othTrans = WMSContext.TransactionDic[ExceedTranId] as OutOther;
|
saleTrans = WMSContext.TransactionDic[ExceedTranId] as OutSale;
|
tfTrans = WMSContext.TransactionDic[ExceedTranId] as OutTransfer;
|
//领料单发料或者工单发料
|
if (MaterialReqTrans)
|
{
|
if (trans == null)
|
{
|
owoTrans = WMSContext.TransactionDic[ExceedTranId] as OutWorkOrder;
|
if (!owoTrans.IsFinished)
|
{
|
lock (owoTrans.TransLock)
|
{
|
Logger.Interface.Info($"自动拆包 => 返回工单发料事务[{ExceedTranId}]，开始确认发料并保存数据。");
|
var response = owoTrans.ConfirmExceed(new()
|
{
|
isExceed = true,
|
AuthOption = option
|
}).Result;
|
action.IsSuccessed = response.IsSuccessed;
|
action.LocaleMsg = response.IsSuccessed ? Biz.L(msg) : Biz.L(response.Message);
|
}
|
}
|
else
|
{
|
action.IsSuccessed = false;
|
action.LocaleMsg = Biz.L($"Transaction Error: 工单领料事务[ID:{ExceedTranId}]已经关闭，请重新打开工单领料功能");
|
}
|
}
|
else
|
{
|
if (!trans.IsFinished)
|
{
|
lock (trans.TransLock)
|
{
|
Logger.Interface.Info($"自动拆包 => 返回领料单发料事务[{ExceedTranId}]，开始确认发料并保存数据。");
|
var response = trans.ConfirmExceed(new()
|
{
|
isExceed = true,
|
AuthOption = option
|
}).Result;
|
action.IsSuccessed = response.IsSuccessed;
|
action.LocaleMsg = response.IsSuccessed ? Biz.L(msg) : Biz.L(response.Message);
|
}
|
}
|
else
|
{
|
action.IsSuccessed = false;
|
action.LocaleMsg = Biz.L($"Transaction Error: 生产领料事务[ID:{ExceedTranId}]已经关闭，请重新打开生产领料功能");
|
}
|
}
|
}
|
//其他出库发料
|
if (OthReqTrans)
|
{
|
if (!othTrans.IsFinished)
|
{
|
lock (othTrans.TransLock)
|
{
|
Logger.Interface.Info($"自动拆包 => 返回其他出库发料事务[{ExceedTranId}]，开始确认发料并保存数据。");
|
var response = othTrans.ConfirmExceed(new()
|
{
|
isExceed = "true",
|
AuthOption = option
|
}).Result;
|
action.IsSuccessed = response.IsSuccessed;
|
action.LocaleMsg = response.IsSuccessed ? Biz.L(msg) : Biz.L(response.Message);
|
}
|
}
|
else
|
{
|
action.IsSuccessed = false;
|
action.LocaleMsg = Biz.L($"Transaction Error: 其他出库事务[ID:{ExceedTranId}]已经关闭，请重新打开其他出库功能");
|
}
|
}
|
//销售出库发料
|
//if (SaleReqTrans)
|
//{
|
// if (!saleTrans.IsFinished)
|
// {
|
// lock (saleTrans.TransLock)
|
// {
|
// Logger.Interface.Info($"自动拆包 => 返回销售出库发料事务[{ExceedTranId}]，开始确认发料并保存数据。");
|
// var response = saleTrans.ConfirmExceed(new()
|
// {
|
// isExceed = true,
|
// AuthOption = option
|
// }).Result;
|
// action.IsSuccessed = response.IsSuccessed;
|
// action.LocaleMsg = response.IsSuccessed ? Biz.L(msg) : Biz.L(response.Message);
|
// }
|
// }
|
// else
|
// {
|
// action.IsSuccessed = false;
|
// action.LocaleMsg = Biz.L($"Transaction Error: 销售出库事务[ID:{ExceedTranId}]已经关闭，请重新打开销售出库功能");
|
// }
|
//}
|
//调拨出库发料
|
if (TfTrans)
|
{
|
if (!tfTrans.IsFinished)
|
{
|
lock (tfTrans.TransLock)
|
{
|
Logger.Interface.Info($"自动拆包 => 返回调拨出库发料事务[{ExceedTranId}]，开始确认发料并保存数据。");
|
var response = tfTrans.ConfirmExceed(new()
|
{
|
isExceed = "true",
|
AuthOption = option
|
}).Result;
|
action.IsSuccessed = response.IsSuccessed;
|
action.LocaleMsg = response.IsSuccessed ? Biz.L(msg) : Biz.L(response.Message);
|
}
|
}
|
else
|
{
|
action.IsSuccessed = false;
|
action.LocaleMsg = Biz.L($"Transaction Error: 调拨出库事务[ID:{ExceedTranId}]已经关闭，请重新打开调拨出库功能");
|
}
|
}
|
}
|
else
|
{
|
action.IsSuccessed = false;
|
action.LocaleMsg = Biz.L($"Transaction Error: 事务[ID:{ExceedTranId}]已经关闭，请重新打开功能");
|
}
|
action.LocaleMsg = action.IsSuccessed ? Biz.L(msg) : action.LocaleMsg;
|
}
|
|
if (action.IsSuccessed)
|
{
|
//保存数据库
|
var db = Business.Biz.Db;
|
var dbTran = db.UseTran(() =>
|
{//入库
|
db.Updateable(nSplitBarcode1, UserCode).ExecuteCommand();
|
db.Insertable(new WMS_ITEM_HIS(nSplitBarcode1, msg), UserCode).ExecuteCommand();
|
db.Insertable(nSplitBarcode2, UserCode).ExecuteCommand();
|
db.Insertable(new WMS_ITEM_HIS(nSplitBarcode2, msg), UserCode).ExecuteCommand();
|
db.Updateable(nSplitPgk1, UserCode).ExecuteCommand();
|
db.Insertable(nSplitPgk2, UserCode).ExecuteCommand();
|
});
|
if (!dbTran.IsSuccess)
|
{
|
Logger.Default.Fatal(dbTran.ErrorException, "Database transaction save exception");
|
this.Close(!dbTran.IsSuccess);
|
throw dbTran.ErrorException;
|
}
|
|
//通过工厂带出 MES api 和 agv api
|
MES_FACTORY _factory = db.Queryable<MES_FACTORY>()
|
.Where(x => x.FTY_CODE == FTY_CODE)
|
.First();
|
//发送到MES
|
if (Cache.SysParam["IsSend", "SendToMES"].PARAM_VALUE.ToString() == "Y" && !ReqNo.IsNullOrEmpty() && Biz.Db.Queryable<BIZ_ERP_PROD_OUT>().Where(x => x.BILLCODE == ReqNo).Any())
|
{
|
var dtl = Biz.Db.Queryable<BIZ_ERP_PROD_OUT_DTL>().Where(x => x.BILLCODE == ReqNo).First();
|
var sourcecode = dtl != null ? dtl.SOURCECODE : "";
|
var query = Biz.Db.Queryable<WMS_SCTRWO_TRANSFER>().Where(x => x.ORIGINAL_WORKORDER == sourcecode).First();
|
var sctrwo = query != null ? (query.TARGET_WORKORDER.IsNullOrEmpty() ? sourcecode : query.TARGET_WORKORDER) : sourcecode;
|
toMes = new ProductionPickToMes()
|
{
|
qrcode = WMS_ITEM_Biz.WmsItem.GetQRCode(nSplitBarcode1.SN),
|
wo = sctrwo, // nCurrentLines.First().SourceCode,
|
pkgid = nSplitBarcode1.SN,
|
mfrkp = CurInv.Barcode.OEMItemCode,
|
kpno = CurInv.ItemInfo.ITEM_CODE,
|
dc = CurInv.Barcode.ProdDateStr,
|
lc = CurInv.Barcode.LotNo,
|
qty = nSplitBarcode1.QTY.ToString(),
|
erpBillCode = ReqNo, //MES接口增加字段，返回备料完成的当前领料单号 2023/05/17 Ben Lin
|
taskid = ""
|
};
|
var mesApi = _factory != null ? _factory.MES_API : Cache.SysParam["apiUrl", "SendToMES"].PARAM_VALUE.ToString();
|
var res = HttpHelper.PostAsync(mesApi, JsonConvert.SerializeObject(toMes)).Result;
|
var _action = JsonConvert.DeserializeObject<ApiAction>(res.Message);
|
Logger.Interface.Info($"生产领料-自动拆分物料 =>拆分物料发料发送MES完成，单号：[{ReqNo}]，MES传入Json:{JsonConvert.SerializeObject(toMes)}，MES返回：{res.Message}");
|
}
|
}
|
|
action.Data = new OutSplitSubmit() {
|
nRemainSn = nRemainSn,
|
nSplitSn = nSplitSn,
|
SupplierCode = vender?.SUPP_CODE,
|
};
|
}
|
catch (Exception ex)
|
{
|
action.CatchExceptionWithLog(ex, $"系统异常");
|
}
|
return action;
|
}
|
|
private ApiAction Confirm<T>(T trans) {
|
ApiAction action = new ApiAction();
|
|
return action;
|
}
|
|
/// <summary>
|
/// 添加一个ApiAction的历史记录
|
/// </summary>
|
/// <param name="action"></param>
|
public override void AddHistory<T>(Microsoft.AspNetCore.Http.HttpRequest request, ApiAction<T> action)
|
{
|
var his = action.History();
|
//his.TraceDic.Add("CurReqType", CurReqType);
|
//his.TraceDic.Add("CurInv", CurInv);
|
//his.TraceDic.Add("req", req);
|
//his.TraceDic.Add("toMes", toMes);
|
//his.TraceDic.Add("CurPoolList", CurPoolList);
|
ActionHistoryList.Add($"{request.HttpContext.TraceIdentifier} at {action.Timestamp:yyyy/MM/dd HH:mm:ss.fff}: {request.Path}", his);
|
LastActionTime = DateTime.Now;
|
}
|
|
#endregion
|
|
public override bool Close(bool needSaveHistoryLog = false)
|
{
|
//needSaveHistoryLog = true;
|
//保存操作日志
|
|
this.IsFinished = true;
|
return IsFinished ? base.Close(needSaveHistoryLog) : IsFinished;
|
}
|
|
}//endClass
|
}
|
