using Rhea.Common;
|
using SqlSugar;
|
using System;
|
using System.Collections.Generic;
|
using System.Diagnostics;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
using Tiger.Business.WMS.Extensions;
|
using Tiger.Business.WMS.Transaction;
|
using Tiger.IBusiness;
|
using Tiger.Model;
|
using Tiger.Model.Entitys.MES.Position;
|
using Tiger.Model.Extensions;
|
|
namespace Tiger.Business.WMS.Common
|
{
|
/// <summary>
|
/// 备料任务单据
|
/// </summary>
|
public class Preparation : IPreparation
|
{
|
public Preparation(DbClient mainDB, string userCode, string orgCode)
|
{
|
MainDB = mainDB;
|
UserCode = userCode;
|
OrgCode = orgCode;
|
}
|
|
#region Propertys & Variables
|
private static object AddOrderLock { get; } = new object();
|
public DbClient MainDB { get; set; }
|
public string UserCode { get; set; }
|
public string OrgCode { get; set; }
|
public BIZ_WMS_PREP PrepOrder { get; set; }
|
#endregion Propertys & Variables
|
|
#region Functions
|
/// <summary>
|
/// 备料任务添加单据
|
/// </summary>
|
/// <param name="bizType"></param>
|
/// <param name="orderNo"></param>
|
/// <returns></returns>
|
public ApiAction<ScanOutput> AddOrder(BIZ_WMS_PREP.BIZ_TYPEs bizType, string orderNo)
|
{
|
lock(AddOrderLock)
|
{
|
var action = new ApiAction<ScanOutput>(new ScanOutput());
|
|
// 查询是否已存在备料任务
|
var src = MainDB.Queryable<BIZ_WMS_PREP_SRC>().Where(q => q.SOURCE_ORDER == orderNo &&
|
SqlFunc.Subqueryable<BIZ_WMS_PREP>().Where(p => p.STATUS < BIZ_WMS_PREP.STATUSs.Sended.GetValue()).Any()).First();
|
if (PrepOrder.IsNullOrEmpty())
|
{
|
if (!src.IsNullOrEmpty())
|
{
|
PrepOrder = MainDB.Queryable<BIZ_WMS_PREP>().Where(q => q.ORDER_NO == src.ORDER_NO).IncludesAllFirstLayer().First();
|
//action.LocaleMsg = Biz.L("单据[{0}]的备料任务[{1}]加载成功，可以开始备料下架");
|
action.LocaleMsg = Biz.L("WMS.Out_BIZ_WMS_PREP.AddOrder.LoadSuccess", orderNo, PrepOrder.ORDER_NO);
|
return action;
|
}
|
else
|
{
|
PrepOrder = new BIZ_WMS_PREP()
|
{
|
AUTH_ORG = OrgCode,
|
ORDER_NO = $"MP{DateTime.Now:yyMMdd}{(DateTime.Now - DateTime.Today).TotalSeconds:00000}",
|
BIZ_TYPE = bizType.GetValue(),
|
STATUS = BIZ_WMS_PREP.STATUSs.Init.GetValue(),
|
};
|
}
|
}
|
if (!src.IsNullOrEmpty() && src.ORDER_NO != PrepOrder.ORDER_NO)
|
{
|
action.IsSuccessed = false;
|
//action.LocaleMsg = Biz.L("单据[{0}]已属于备料任务[{1}]，无法添加到当前备料任务[{2}]中，如需切换备料业务，请退出后重新选择");
|
action.LocaleMsg = Biz.L("WMS.Out_BIZ_WMS_PREP.AddOrder.NoFound", orderNo, src.ORDER_NO, PrepOrder.ORDER_NO);
|
return action;
|
}
|
|
// 查询单据明细，并合并到备料单的备料明细中
|
var dtls = bizType.GetPickList(orderNo);
|
if (dtls.Sum(q => q.QTY_ACT_REQ) <= 0)
|
{
|
action.IsSuccessed = false;
|
//action.LocaleMsg = Biz.L("单据[{0}]未找到需要备料的行明细，请扫描正确的单据");
|
action.LocaleMsg = Biz.L("WMS.Out_BIZ_WMS_PREP.AddOrder.NoNeedPrep", orderNo);
|
return action;
|
}
|
|
PrepOrder.SourceOrders = PrepOrder.SourceOrders ?? new();
|
PrepOrder.SourceDetails = PrepOrder.SourceDetails ?? new();
|
PrepOrder.Details = PrepOrder.Details ?? new();
|
PrepOrder.Batchs = PrepOrder.Batchs ?? new();
|
PrepOrder.SnList = PrepOrder.SnList ?? new();
|
var srcOrder = new BIZ_WMS_PREP_SRC()
|
{
|
AUTH_ORG = OrgCode,
|
ORDER_NO = PrepOrder.ORDER_NO,
|
SOURCE_CODE = bizType.GetSourceCode(),
|
SOURCE_ORDER = orderNo,
|
ADD_TIME = DateTime.Now,
|
};
|
PrepOrder.SourceOrders.Add(srcOrder);
|
foreach (var dtl in dtls)
|
{
|
dtl.AUTH_ORG = OrgCode;
|
var pdtl = PrepOrder.Details.Where(q => q.ITEM_CODE == dtl.ITEM_CODE).FirstOrDefault();
|
if (pdtl.IsNullOrEmpty())
|
{
|
pdtl = new ()
|
{
|
AUTH_ORG = OrgCode,
|
ORDER_NO = PrepOrder.ORDER_NO,
|
ORDER_LINE = (PrepOrder.Details.Max(q => q.LINE_CODE.ToInt32()) + 1).ToString(),
|
ITEM_CODE = dtl.ITEM_CODE,
|
SUBITEM_CODE = dtl.SUBITEM_CODE,
|
UNIT = dtl.UNIT,
|
PLAN_LOSS_QTY = dtl.PLAN_LOSS_QTY,
|
PLAN_LOSS_RATE = dtl.PLAN_LOSS_RATE,
|
IS_CALC_LOSS = dtl.IS_CALC_LOSS,
|
IS_WHOLE = dtl.IS_WHOLE,
|
SOURCE_CODE = dtl.SOURCE_CODE,
|
SOURCE_ORDER = dtl.SOURCE_ORDER,
|
SOURCE_LINE = dtl.SOURCE_LINE,
|
STATUS = BIZ_WMS_PREP_DTL.STATUSs.UnCalc.GetValue(),
|
FTY_CODE = dtl.FTY_CODE,
|
WS_CODE = dtl.WS_CODE,
|
LINE_CODE = dtl.LINE_CODE,
|
POST_CODE = dtl.POST_CODE,
|
OPER_CODE = dtl.OPER_CODE,
|
SEGMENT = dtl.SEGMENT,
|
SMT_NO = dtl.SMT_NO,
|
STATION_NO = dtl.STATION_NO,
|
FEEDER_NO = dtl.FEEDER_NO,
|
FEEDER_TYPE = dtl.FEEDER_TYPE,
|
};
|
PrepOrder.Details.Add(pdtl);
|
}
|
pdtl.QTY_REQ += dtl.QTY_ACT_REQ;
|
PrepOrder.SourceDetails.Add(dtl);
|
}
|
var srcInfo = PrepOrder.SourceOrders.Select(q => new { q.SOURCE_CODE, q.SOURCE_ORDER }).DistinctBy(q => q.SOURCE_ORDER).OrderBy(q => q.SOURCE_ORDER);
|
PrepOrder.SOURCE_CODE = string.Join(",", srcInfo.Select(q => q.SOURCE_CODE));
|
PrepOrder.SOURCE_ORDER = string.Join(",", srcInfo.Select(q => q.SOURCE_ORDER));
|
|
//使用统一的事务DB对象
|
var db = Biz.Db;
|
var dbTran = db.UseTran(() =>
|
{
|
var o = db.Storageable(PrepOrder, UserCode).WhereColumns(t => new { t.ORDER_NO, t.GHOST_ROW }).ToStorage();
|
o.AsInsertable.ExecuteCommand();
|
o.AsUpdateable.IgnoreColumns(q => q.ID).UpdateColumns(q => new { q.SOURCE_CODE, q.SOURCE_ORDER, q.UPDATE_TIME, q.UPDATE_USER }).ExecuteCommand();
|
var so = db.Storageable(PrepOrder.SourceOrders, UserCode).WhereColumns(t => new { t.ORDER_NO, t.SOURCE_ORDER, t.GHOST_ROW }).ToStorage();
|
so.AsInsertable.ExecuteCommand();
|
var sd = db.Storageable(PrepOrder.SourceDetails, UserCode).WhereColumns(t => new { t.ORDER_NO, t.ITEM_CODE, t.GHOST_ROW }).ToStorage();
|
sd.AsInsertable.ExecuteCommand();
|
var d = db.Storageable(PrepOrder.Details, UserCode).WhereColumns(t => new { t.ORDER_NO, t.ITEM_CODE, t.GHOST_ROW }).ToStorage();
|
d.AsInsertable.ExecuteCommand();
|
d.AsUpdateable.IgnoreColumns(q => q.ID).UpdateColumns(q => new { q.QTY_REQ, q.UPDATE_TIME, q.UPDATE_USER }).ExecuteCommand();
|
});
|
if (dbTran.IsSuccess)
|
{
|
//action.LocaleMsg = Biz.L("备料任务[{0}添加]单据[{1}]成功，可以开始备料下架");
|
action.LocaleMsg = Biz.L("WMS.Out_BIZ_WMS_PREP.AddOrder.LoadSuccess", PrepOrder?.ORDER_NO, orderNo);
|
}
|
else
|
{
|
Logger.Default.Fatal(dbTran.ErrorException, "Database transaction save exception");
|
//抛出异常
|
throw dbTran.ErrorException;
|
}
|
return action;
|
}
|
}
|
|
#endregion Functions
|
}
|
}
|
