using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using HH.WCS.Mobox3.DSZSH.models;
|
using HH.WCS.Mobox3.DSZSH.util;
|
using HH.WCS.Mobox3.DSZSH.wms;
|
using Newtonsoft.Json;
|
using SqlSugar;
|
using static HH.WCS.Mobox3.DSZSH.api.ApiModel;
|
using static HH.WCS.Mobox3.DSZSH.api.OtherModel;
|
|
namespace HH.WCS.Mobox3.DSZSH.api {
|
public class ApiHelper {
|
/// <summary>
|
/// 满箱下线入库
|
/// </summary>
|
/// <param name="model"></param>
|
/// <returns></returns>
|
public static SimpleResult GoodpackOffline(GoodpackOfflineInfo model) {
|
var db = new SqlHelper<object>().GetInstance();
|
var (ok, msg) = (false, string.Empty);
|
var obj = new CreateTaskObj();
|
|
var tInfo = ETask.M满箱下线入库.Info();
|
const string preLog = "API:满箱下线入库:";
|
const string cntrType = "好运箱";
|
|
try {
|
if (model.Num <= 0) {
|
return NewSimpleResult(400, preLog + $"物料数量'{model.Num}'不合法!要求:物料数量＞0");
|
}
|
|
// 检查货品容器表:是否已经存在贴标机传递的待入库物料信息
|
// QES:数量,规格是否也参与比对?
|
var cgDetail = db.Queryable<TN_CG_Detail>()
|
.Where(d => d.S_ITEM_CODE == model.ItemCode && d.S_BATCH_NO == model.BatchNo
|
&& d.N_ITEM_STATE == 1 && d.S_ITEM_STATE == "待检").First();
|
if (cgDetail == null) {
|
return NewSimpleResult(1, preLog + LogMsg.CgDetailNotFound(item: model.ItemCode) + $"物料状态='待检';" +
|
$"请检查:PDA扫码物料信息与贴标机传递的信息是否一致!!");
|
}
|
|
// 查询起点货位(绑定前)
|
var startLoc = db.Queryable<TN_Location>().Where(DbExpr.StartLocUnbind(model.StartLoc, tInfo.StartAreas)).First();
|
if (startLoc == null) {
|
return NewSimpleResult(2, preLog + LogMsg.StartLocUnbindNotFound(model.StartLoc, tInfo.StartAreas));
|
}
|
|
// 和满托下线入库的逻辑一致,由于容器移动不会更改绑定信息,所以必须删除旧数据
|
WMSHelper.FindOldCntrInfo(obj, cgDetail.S_CNTR_CODE, skipCgDetail: true);
|
|
// 绑定货位容器
|
var locCntrRel = WMSHelper.BindLocCntr(obj, startLoc, cgDetail.S_CNTR_CODE, cntrType);
|
|
// 查询终点货位
|
// Order:优先选择低层货架
|
var endLoc = db.Queryable<TN_Location>().Where(DbExpr.EndLoc(areas: tInfo.EndAreas))
|
.OrderBy(l => new { l.N_LAYER }).First();
|
if (endLoc == null) {
|
return NewSimpleResult(3, preLog + LogMsg.EndLocNotFound(areas: tInfo.EndAreas));
|
}
|
|
// 起点终点上锁,创建任务
|
WMSHelper.CreateTask(obj, startLoc, endLoc, locCntrRel.S_CNTR_CODE, tInfo.TaskName);
|
(ok, msg) = DbTran.CreateTask(obj);
|
return NewSimpleResult(ok ? 0 : 500, preLog + msg);
|
}
|
catch (Exception ex) {
|
return NewSimpleResult(ex, preLog);
|
}
|
}
|
|
/// <summary>
|
/// 空托入库
|
/// </summary>
|
/// <param name="model"></param>
|
/// <returns></returns>
|
public static SimpleResult EmptyInboundPallet(EmptyInboundInfo model) {
|
var db = new SqlHelper<object>().GetInstance();
|
var (ok, msg) = (false, string.Empty);
|
var obj = new CreateTaskObj();
|
|
var tInfo = ETask.K空托入库.Info();
|
const string preLog = "API:空托入库:";
|
const string cntrType = "托盘";
|
|
try {
|
// 查询容器表:容器类型字段
|
(ok, msg) = WMSHelper.CheckCntrType(model.CntrCode, cntrType, out var cntr);
|
if (!ok) {
|
return NewSimpleResult(1, preLog + msg);
|
}
|
|
// 查询起点货位(绑定前)
|
var startLoc = db.Queryable<TN_Location>().Where(DbExpr.StartLocUnbind(model.StartLoc, tInfo.StartAreas)).First();
|
if (startLoc == null) {
|
return NewSimpleResult(2, preLog + LogMsg.StartLocUnbindNotFound(model.StartLoc, tInfo.StartAreas));
|
}
|
|
// 空箱入库时,如果存在旧的绑定数据,删除
|
WMSHelper.FindOldCntrInfo(obj, model.CntrCode);
|
|
// 绑定货位容器
|
var locCntrRel = WMSHelper.BindLocCntr(obj, startLoc, cntr.S_CODE, cntrType);
|
|
// 查询终点货位
|
// Order:层数从低到高,行,列
|
var endLoc = db.Queryable<TN_Location>().Where(DbExpr.EndLoc(areas: tInfo.EndAreas))
|
.OrderBy(l => new { l.N_LAYER, l.N_ROW, l.N_COL }).First();
|
if (endLoc == null) {
|
return NewSimpleResult(3, preLog + LogMsg.EndLocNotFound(areas: tInfo.EndAreas));
|
}
|
|
// 起点终点上锁,创建任务
|
WMSHelper.CreateTask(obj, startLoc, endLoc, locCntrRel.S_CNTR_CODE, tInfo.TaskName);
|
(ok, msg) = DbTran.CreateTask(obj);
|
return NewSimpleResult(ok ? 0 : 500, preLog + msg);
|
}
|
catch (Exception ex) {
|
return NewSimpleResult(ex, preLog);
|
}
|
}
|
|
/// <summary>
|
/// 空箱入库
|
/// </summary>
|
/// <returns></returns>
|
public static SimpleResult EmptyInboundGoodpack(EmptyInboundInfo model) {
|
var db = new SqlHelper<object>().GetInstance();
|
var (ok, msg) = (false, string.Empty);
|
var obj = new CreateTaskObj();
|
|
var tInfo = ETask.K空箱入库.Info();
|
const string preLog = "API:空箱入库:";
|
const string cntrType = "好运箱";
|
|
try {
|
// 查询起点货位(绑定前)
|
var startLoc = db.Queryable<TN_Location>().Where(DbExpr.StartLocUnbind(model.StartLoc, tInfo.StartAreas)).First();
|
if (startLoc == null) {
|
return NewSimpleResult(1, preLog + LogMsg.StartLocUnbindNotFound(model.StartLoc, tInfo.StartAreas));
|
}
|
|
// 查询容器表:容器类型字段
|
(ok, msg) = WMSHelper.CheckCntrType(model.CntrCode, cntrType, out var cntr);
|
if (!ok) {
|
return NewSimpleResult(2, preLog + msg);
|
}
|
|
// 空箱入库时,如果存在旧的绑定数据,删除
|
WMSHelper.FindOldCntrInfo(obj, model.CntrCode);
|
|
var locCntrRel = WMSHelper.BindLocCntr(obj, startLoc, model.CntrCode, cntrType);
|
|
var endLoc = db.Queryable<TN_Location>().Where(DbExpr.EndLoc(areas: tInfo.EndAreas))
|
.OrderBy(l => new { l.N_LAYER, l.N_ROW, l.N_COL }).First();
|
if (endLoc == null) {
|
return NewSimpleResult(3, preLog + LogMsg.EndLocNotFound(areas: tInfo.EndAreas));
|
}
|
|
// 起点终点上锁,创建任务
|
WMSHelper.CreateTask(obj, startLoc, endLoc, locCntrRel.S_CNTR_CODE, tInfo.TaskName);
|
(ok, msg) = DbTran.CreateTask(obj);
|
return NewSimpleResult(ok ? 0 : 500, preLog + msg);
|
}
|
catch (Exception ex) {
|
return NewSimpleResult(ex, preLog);
|
}
|
}
|
|
/// <summary>
|
/// 空托上线出库
|
/// </summary>
|
/// <param name="model"></param>
|
/// <returns></returns>
|
public static SimpleResult EmptyOnlinePallet(EmptyOnlinePalletInfo model) {
|
var db = new SqlHelper<object>().GetInstance();
|
var (ok, msg) = (false, string.Empty);
|
var obj = new CreateTaskObj();
|
|
var tInfo = ETask.K空托上线出库.Info();
|
const string preLog = "API:空托上线出库:";
|
const string cntrType = "托盘";
|
|
try {
|
// 查询容器表:容器类型字段
|
(ok, msg) = WMSHelper.CheckCntrType(model.CntId, cntrType, out var cntr);
|
if (!ok) {
|
return NewSimpleResult(1, preLog + msg);
|
}
|
|
// 检查容器表:容器规格(物料编码)
|
var needUpdateContainer = false;
|
if (string.IsNullOrEmpty(cntr.S_SPEC)) {
|
// 目前流程:如果容器表中规格 (物料编码) 为空,根据流程的物料信息写入
|
// TEMP:后面可能会更改流程,或者用其他信息 (如物料类型/规格) 作为容器的规格
|
needUpdateContainer = true;
|
cntr.S_SPEC = model.ItemCode;
|
LogHelper.Info($"容器'{model.CntId}'在[容器表]中[规格(物料编码)]为空,将物料编码'{model.ItemCode}'写入容器的规格");
|
}
|
else if (cntr.S_SPEC != model.ItemCode) {
|
return NewSimpleResult(3, $"容器'{model.CntId}'已经与物料类型'{cntr.S_SPEC}'绑定,无法用于装载物料'{model.ItemCode}'!");
|
}
|
|
// 查询起点货位
|
var startLoc = db.Queryable<TN_Location>().LeftJoin<TN_Loc_Container>((l, c) => l.S_CODE == c.S_LOC_CODE)
|
.Where(DbExpr.StartLoc(areas: tInfo.StartAreas))
|
.Where((l, c) => c.S_CNTR_CODE == model.CntId && c.S_CNTR_TYPE == cntrType).First();
|
if (startLoc == null) {
|
return NewSimpleResult(3, preLog + LogMsg.StartLocNotFound(areas: tInfo.StartAreas) +
|
$"绑定容器编码='{model.CntId}';绑定容器类型='{cntrType}';");
|
}
|
|
// 查询终点货位
|
var endLoc = db.Queryable<TN_Location>().Where(DbExpr.EndLoc(areas: tInfo.EndAreas)).First();
|
if (endLoc == null) {
|
return NewSimpleResult(5, preLog + LogMsg.EndLocNotFound(areas: tInfo.EndAreas));
|
}
|
|
// 起点终点上锁,创建任务
|
var task = WMSHelper.CreateTask(obj, startLoc, endLoc, model.CntId, tInfo.TaskName);
|
|
cntr.S_SOURCE = task.S_CODE; // 用任务号作为容器更新的依据
|
cntr.T_MODIFY = DateTime.Now;
|
obj.ContainerToUpdate = needUpdateContainer ? cntr : null; // 如果需要更新[容器表]规格,写入obj
|
|
(ok, msg) = DbTran.CreateTask(obj);
|
return NewSimpleResult(ok ? 0 : 500, preLog + msg);
|
}
|
catch (Exception ex) {
|
return NewSimpleResult(ex, preLog);
|
}
|
}
|
|
/// <summary>
|
/// 空箱上线出库
|
/// </summary>
|
/// <param name="model"></param>
|
/// <returns></returns>
|
public static SimpleResult EmptyOnlineGoodpack(EmptyOnlineGoodpackInfo model) {
|
var db = new SqlHelper<object>().GetInstance();
|
var (ok, msg) = (false, string.Empty);
|
var obj = new CreateTaskObj();
|
|
var tInfo = ETask.K空箱上线出库.Info();
|
const string preLog = "API:空箱上线出库:";
|
const string cntrType = "好运箱";
|
|
try {
|
// 查询容器表:容器类型字段
|
(ok, msg) = WMSHelper.CheckCntrType(model.CntId, cntrType, out var cntr);
|
if (!ok) {
|
return NewSimpleResult(3, preLog + msg);
|
}
|
|
var startLoc = db.Queryable<TN_Location>().LeftJoin<TN_Loc_Container>((l, c) => l.S_CODE == c.S_LOC_CODE)
|
.Where(DbExpr.StartLoc(areas: tInfo.StartAreas))
|
.Where((l, c) => c.S_CNTR_CODE == model.CntId && c.S_CNTR_TYPE == cntrType).First();
|
if (startLoc == null) {
|
return NewSimpleResult(2, preLog + preLog + LogMsg.StartLocNotFound(areas: tInfo.StartAreas) +
|
$"绑定容器编码='{model.CntId}';绑定容器类型='{cntrType}';");
|
}
|
|
var endLoc = db.Queryable<TN_Location>().Where(DbExpr.EndLoc(areas: tInfo.EndAreas)).First();
|
if (endLoc == null) {
|
return NewSimpleResult(3, preLog + LogMsg.EndLocNotFound(areas: tInfo.EndAreas));
|
}
|
|
// 起点终点上锁,创建任务
|
WMSHelper.CreateTask(obj, startLoc, endLoc, model.CntId, tInfo.TaskName);
|
(ok, msg) = DbTran.CreateTask(obj);
|
return NewSimpleResult(ok ? 0 : 500, preLog + msg);
|
}
|
catch (Exception ex) {
|
return NewSimpleResult(ex, preLog);
|
}
|
}
|
|
/// <summary>
|
/// 抽检合格回库
|
/// </summary>
|
/// <param name="model"></param>
|
/// <returns></returns>
|
public static SimpleResult QualifiedBack(QualifiedBackInfo model) {
|
var db = new SqlHelper<object>().GetInstance();
|
var (ok, msg) = (false, string.Empty);
|
var obj = new CreateTaskObj();
|
|
var tInfo = ETask.C抽检合格回库.Info();
|
const string preLog = "API:抽检合格回库:";
|
|
try {
|
var cgDetail = db.Queryable<TN_CG_Detail>()
|
.Where(d => d.S_ITEM_CODE == model.ItemCode && d.S_CNTR_CODE == model.CntrCode).First();
|
if (cgDetail == null) {
|
return NewSimpleResult(1, preLog + LogMsg.CgDetailNotFound(item: model.ItemCode, cntr: model.CntrCode));
|
}
|
|
var locCntrRel = db.Queryable<TN_Loc_Container>().Where(c => c.S_CNTR_CODE == cgDetail.S_CNTR_CODE).First();
|
if (locCntrRel == null) {
|
return NewSimpleResult(2, preLog + LogMsg.LocCntrRelNotFound(cntr: cgDetail.S_CNTR_CODE));
|
}
|
|
var startLoc = db.Queryable<TN_Location>().Where(DbExpr.StartLoc(locCntrRel.S_LOC_CODE, tInfo.StartAreas)).First();
|
if (startLoc == null) {
|
return NewSimpleResult(3, preLog + LogMsg.StartLocNotFound(locCntrRel.S_LOC_CODE, tInfo.StartAreas));
|
}
|
|
var endAreas = locCntrRel.S_CNTR_CODE == "托盘" ? tInfo.EndAreas_Pallet : tInfo.EndAreas_Goodpack;
|
var endLoc = db.Queryable<TN_Location>().Where(DbExpr.EndLoc(areas: endAreas)).First();
|
if (endLoc == null) {
|
return NewSimpleResult(4, preLog + LogMsg.EndLocNotFound(areas: endAreas));
|
}
|
|
//修改物料状态为[合格]
|
cgDetail.N_ITEM_STATE = 0;
|
cgDetail.S_ITEM_STATE = "合格";
|
cgDetail.T_MODIFY = DateTime.Now;
|
obj.CgDetailToUpdate = cgDetail;
|
|
// 起点终点上锁,创建任务
|
WMSHelper.CreateTask(obj, startLoc, endLoc, locCntrRel.S_CNTR_CODE, tInfo.TaskName);
|
(ok, msg) = DbTran.CreateTask(obj);
|
return NewSimpleResult(ok ? 0 : 500, preLog + msg);
|
}
|
catch (Exception ex) {
|
return NewSimpleResult(ex, preLog);
|
}
|
}
|
|
/// <summary>
|
/// 抽检不合格移库
|
/// </summary>
|
/// <param name="model"></param>
|
/// <returns></returns>
|
public static SimpleResult UnqualifiedShift(UnqualifiedShiftInfo model) {
|
var db = new SqlHelper<object>().GetInstance();
|
var (ok, msg) = (false, string.Empty);
|
var obj = new CreateTaskObj();
|
|
var tInfo = ETask.C抽检不合格移库.Info();
|
const string preLog = "API:抽检不合格移库:";
|
|
try {
|
if (!tInfo.EndAreas.Contains(model.EndArea)) {
|
return NewSimpleResult(1, preLog + $"终点库区'{model.EndArea}'不满足条件!需要:货区={LogObject(tInfo.EndAreas)}");
|
}
|
|
var cgDetail = db.Queryable<TN_CG_Detail>()
|
.Where(d => d.S_ITEM_CODE == model.ItemCode && d.S_CNTR_CODE == model.CntrCode).First();
|
if (cgDetail == null) {
|
return NewSimpleResult(2, preLog + LogMsg.CgDetailNotFound(item: model.ItemCode, cntr: model.CntrCode));
|
}
|
|
var locCntrRel = db.Queryable<TN_Loc_Container>().Where(c => c.S_CNTR_CODE == cgDetail.S_CNTR_CODE).First();
|
if (locCntrRel == null) {
|
return NewSimpleResult(3, preLog + LogMsg.LocCntrRelNotFound(cntr: cgDetail.S_CNTR_CODE));
|
}
|
|
var startLoc = db.Queryable<TN_Location>().Where(DbExpr.StartLoc(locCntrRel.S_LOC_CODE, tInfo.StartAreas)).First();
|
if (startLoc == null) {
|
return NewSimpleResult(4, preLog + LogMsg.StartLocNotFound(locCntrRel.S_LOC_CODE, tInfo.StartAreas));
|
}
|
|
var endLoc = db.Queryable<TN_Location>().Where(DbExpr.EndLoc(areas: new List<string> { model.EndArea })).First();
|
if (endLoc == null) {
|
return NewSimpleResult(5, preLog + LogMsg.EndLocNotFound(areas: new List<string> { model.EndArea }));
|
}
|
|
cgDetail.N_ITEM_STATE = 2;
|
cgDetail.S_ITEM_STATE = "不合格";
|
cgDetail.T_MODIFY = DateTime.Now;
|
obj.CgDetailToUpdate = cgDetail;
|
|
// 起点终点上锁,创建任务
|
WMSHelper.CreateTask(obj, startLoc, endLoc, locCntrRel.S_CNTR_CODE, tInfo.TaskName);
|
(ok, msg) = DbTran.CreateTask(obj);
|
return NewSimpleResult(ok ? 0 : 500, preLog + msg);
|
}
|
catch (Exception ex) {
|
return NewSimpleResult(ex, preLog);
|
}
|
}
|
|
/// <summary>
|
/// 尾料回库/余料回库
|
/// </summary>
|
/// <param name="model"></param>
|
/// <returns></returns>
|
public static SimpleResult RestBack(RestBackInfo model) {
|
var db = new SqlHelper<object>().GetInstance();
|
var (ok, msg) = (false, string.Empty);
|
var obj = new CreateTaskObj();
|
|
var tInfo = ETask.W尾料回库.Info();
|
const string preLog = "API:尾料回库:";
|
|
try {
|
var startLoc = db.Queryable<TN_Location>().Where(DbExpr.StartLoc(model.StartLoc)).First();
|
if (startLoc == null) {
|
return NewSimpleResult(2, LogMsg.StartLocNotFound(model.StartLoc));
|
}
|
|
var locCntrRel = db.Queryable<TN_Loc_Container>().Where(c => c.S_LOC_CODE == model.StartLoc).First();
|
if (locCntrRel == null) {
|
return NewSimpleResult(3, preLog + LogMsg.LocCntrRelNotFound(loc: model.StartLoc));
|
}
|
|
var endAreas = locCntrRel.S_CNTR_CODE == "托盘" ? tInfo.EndAreas_Pallet : tInfo.EndAreas_Goodpack;
|
var endLoc = db.Queryable<TN_Location>().Where(DbExpr.EndLoc(areas: endAreas)).First();
|
if (endLoc == null) {
|
return NewSimpleResult(3, preLog + LogMsg.EndLocNotFound(areas: endAreas));
|
}
|
|
// 起点终点上锁,创建任务
|
WMSHelper.CreateTask(obj, startLoc, endLoc, locCntrRel.S_CNTR_CODE, tInfo.TaskName);
|
(ok, msg) = DbTran.CreateTask(obj);
|
return NewSimpleResult(ok ? 0 : 500, preLog + msg);
|
}
|
catch (Exception ex) {
|
return NewSimpleResult(ex, preLog);
|
}
|
}
|
|
/// <summary>
|
/// 生成出库单号,私有
|
/// </summary>
|
/// <param name="snType"></param>
|
/// <param name="prefix"></param>
|
/// <returns></returns>
|
private static string GenerateOrderNo(string snType, string prefix) {
|
//var id = SYSHelper.GetSerialNumberResetByDay(snType, prefix);
|
//var date = DateTime.Now.ToString("yyMMdd");
|
//return $"{prefix}{date}-{id.ToString().PadLeft(4, '0')}";
|
return SYSHelper.GenerateSN(snType, prefix, "yyMMdd");
|
}
|
|
/// <summary>
|
/// 成品胶出库(搁置)
|
/// </summary>
|
/// <param name="model"></param>
|
/// <returns></returns>
|
public static SimpleResult FinishedOutbound(FinishedOutboundInfo model) {
|
var db = new SqlHelper<object>().GetInstance();
|
var (ok, msg) = (false, string.Empty);
|
|
var tInfo = ETask.C成品胶出库.Info();
|
const string preLog = "API:成品胶出库:";
|
|
try {
|
var orderNo = GenerateOrderNo("出库单号", "CKD");
|
|
var cgDetailList = SelectCgByTotalQty(model.Qty, model.ItemCode, model.BatchNo, model.CntrType, model.ForcedOut);
|
|
if (cgDetailList.Count == 0) {
|
return NewSimpleResult(3, preLog + $"没有合适的物料可以出库");
|
}
|
|
var order = new TN_Outbound_Order {
|
S_NO = orderNo,
|
S_ITEM_CODE = model.ItemCode,
|
S_BATCH = model.BatchNo,
|
N_END_NUM = model.Qty,
|
S_END_AREA = model.EndArea
|
};
|
|
var detailList = new List<TN_Outbound_Detail>();
|
foreach (var cgDetail in cgDetailList) {
|
var detail = new TN_Outbound_Detail {
|
S_OO_NO = orderNo,
|
S_ITEM_CODE = cgDetail.S_ITEM_CODE,
|
S_BATCH_NO = cgDetail.S_BATCH_NO,
|
S_CNTR_CODE = cgDetail.S_CNTR_CODE,
|
N_COUNT = cgDetail.N_ITEM_NUM,
|
S_END_AREA = model.EndArea
|
};
|
detailList.Add(detail);
|
}
|
|
using (var tran = db.Ado.UseTran()) {
|
if (db.Insertable(order).ExecuteCommand() <= 0) {
|
tran.RollbackTran();
|
return NewSimpleResult(2, preLog + "生成出库单失败:" + LogObject(order));
|
}
|
|
if (db.Insertable(detailList).ExecuteCommand() <= 0) {
|
tran.RollbackTran();
|
return NewSimpleResult(4, preLog + "生成出库单明细失败:" + LogObject(detailList));
|
}
|
|
tran.CommitTran();
|
}
|
|
return NewSimpleResult(0, preLog + "生成出库单成功");
|
}
|
catch (Exception ex) {
|
return NewSimpleResult(ex, preLog);
|
}
|
}
|
|
/// <summary>
|
/// 成品胶强制出库(WMS)
|
/// </summary>
|
/// <returns></returns>
|
public static SimpleResult FinishedOutboundForce(FinishedOutboundInfo model) {
|
var db = new SqlHelper<object>().GetInstance();
|
var (ok, msg) = (false, string.Empty);
|
|
var taskInfo = ETask.C成品胶出库.Info();
|
const string preLog = "API:成品胶出库:";
|
|
try {
|
var orderNo = GenerateOrderNo("出库单号", "CKD");
|
|
var cgDetailList = SelectCgByTotalQty(model.Qty, model.ItemCode, model.BatchNo, model.CntrType, model.ForcedOut);
|
|
if (cgDetailList.Count == 0) {
|
return NewSimpleResult(3, preLog + $"没有合适的物料可以出库");
|
}
|
|
var order = new TN_Outbound_Order {
|
S_NO = orderNo,
|
S_ITEM_CODE = model.ItemCode,
|
S_BATCH = model.BatchNo,
|
N_END_NUM = model.Qty,
|
S_END_AREA = model.EndArea
|
};
|
|
var detailList = new List<TN_Outbound_Detail>();
|
foreach (var cgDetail in cgDetailList) {
|
var detail = new TN_Outbound_Detail {
|
S_OO_NO = orderNo,
|
S_ITEM_CODE = cgDetail.S_ITEM_CODE,
|
S_BATCH_NO = cgDetail.S_BATCH_NO,
|
S_CNTR_CODE = cgDetail.S_CNTR_CODE,
|
N_COUNT = cgDetail.N_ITEM_NUM,
|
S_END_AREA = model.EndArea
|
};
|
detailList.Add(detail);
|
}
|
|
using (var tran = db.Ado.UseTran()) {
|
if (db.Insertable(order).ExecuteCommand() <= 0) {
|
tran.RollbackTran();
|
return NewSimpleResult(500, preLog + "生成出库单失败:" + LogObject(order));
|
}
|
|
if (db.Insertable(detailList).ExecuteCommand() <= 0) {
|
tran.RollbackTran();
|
return NewSimpleResult(500, preLog + "生成出库单明细失败:" + LogObject(detailList));
|
}
|
|
tran.CommitTran();
|
}
|
|
return NewSimpleResult(0, preLog + "生成出库单成功");
|
}
|
catch (Exception ex) {
|
return NewSimpleResult(ex, preLog);
|
}
|
}
|
|
public static List<TN_CG_Detail> SelectCgByTotalQty(int qty, string itemCode, string batchNo, string cntrType = "", bool forcedOut = true) {
|
var db = new SqlHelper<object>().GetInstance();
|
var result = new List<TN_CG_Detail>();
|
var targetNum = qty;
|
try {
|
var targetCg = db.Queryable<TN_CG_Detail>()
|
.Where(a => a.S_ITEM_CODE == itemCode && a.S_BATCH_NO == batchNo)
|
.Where(a => a.N_ITEM_NUM > targetNum)
|
.OrderBy(a => a.N_ITEM_NUM, OrderByType.Asc).First();
|
if (targetCg != null) //刚好有一行满足条件
|
{
|
result.Add(targetCg);
|
return result;
|
}
|
|
// NOTE 根据总量选detail时,是否需要考虑货位的高低?
|
|
var sortedMaterials = new List<TN_CG_Detail>();
|
|
var cntrTypeList = new List<string>();
|
if (cntrType == "") {
|
cntrTypeList = new List<string> { "托盘", "好运箱" }; // 不指定托盘类型,二者均可
|
}
|
else {
|
cntrTypeList.Add(cntrType);
|
}
|
|
if (forcedOut) {
|
sortedMaterials = db.Queryable<TN_CG_Detail, TN_Loc_Container>((d, c) => d.S_CNTR_CODE == c.S_CNTR_CODE)
|
.Where(d => d.S_ITEM_CODE == itemCode && d.S_BATCH_NO == batchNo && d.N_ITEM_NUM > 0)
|
.Where((d, c) => cntrTypeList.Contains(c.S_CNTR_TYPE))
|
.Where(d => d.N_ITEM_STATE == 0 && d.S_ITEM_STATE == "合格"
|
|| d.N_ITEM_STATE == 1 && d.S_ITEM_STATE == "待检")
|
.OrderBy(d => d.N_ITEM_NUM, OrderByType.Desc)
|
.OrderBy(d => d.N_ITEM_STATE, OrderByType.Asc).ToList();
|
}
|
else {
|
sortedMaterials = db.Queryable<TN_CG_Detail, TN_Loc_Container>((d, c) => d.S_CNTR_CODE == c.S_CNTR_CODE)
|
.Where(d => d.S_ITEM_CODE == itemCode && d.S_BATCH_NO == batchNo && d.N_ITEM_NUM > 0)
|
.Where((d, c) => cntrTypeList.Contains(c.S_CNTR_TYPE))
|
.Where(d => d.N_ITEM_STATE == 0 && d.S_ITEM_STATE == "合格")
|
.OrderBy(d => d.N_ITEM_NUM, OrderByType.Desc)
|
.OrderBy(d => d.N_ITEM_STATE, OrderByType.Asc).ToList();
|
}
|
|
if (sortedMaterials.Count == 0) //没有满足条件的
|
{
|
return result;
|
}
|
|
int countNum = 0;
|
foreach (var mat in sortedMaterials) {
|
countNum += mat.N_ITEM_NUM;
|
result.Add(mat);
|
if (countNum >= targetNum) {
|
break;
|
}
|
}
|
if (result.Sum(a => a.N_ITEM_NUM) >= targetNum) {
|
return result;
|
}
|
else {
|
result.Clear();
|
return result;
|
}
|
}
|
catch (Exception ex) {
|
LogHelper.InfoEx(ex);
|
return result;
|
}
|
}
|
|
|
|
/// <summary>
|
/// 博实物料信息下发同步 (只针对好运箱)
|
/// </summary>
|
/// <param name="model"></param>
|
/// <returns></returns>
|
public static MesResult CgInfoSync(CgInfoSyncInfo model) {
|
var db = new SqlHelper<object>().GetInstance();
|
var (ok, msg) = (false, string.Empty);
|
|
const string preLog = "API:博实下发物料信息:";
|
const string cntrType = "好运箱";
|
|
try {
|
if (string.IsNullOrEmpty(model.ItemCode)) {
|
return NewMesResult(400, preLog + $"物料编码'{model.ItemCode}'不能为空!");
|
}
|
if (string.IsNullOrEmpty(model.CntrCode)) {
|
return NewMesResult(400, preLog + $"容器编码'{model.CntrCode}'不能为空!");
|
}
|
if (string.IsNullOrEmpty(model.BatchNo)) {
|
return NewMesResult(400, preLog + $"批次号'{model.BatchNo}'不能为空!");
|
}
|
if (model.ItemNum <= 0) {
|
return NewMesResult(400, preLog + $"物料数量'{model.ItemNum}'不合法!要求:物料数量＞0");
|
}
|
|
(ok, msg) = WMSHelper.CheckCntrType(model.CntrCode, cntrType, out var cntr);
|
if (!ok) {
|
return NewMesResult(1, preLog + msg);
|
}
|
|
// 将下发的信息先存储到CG表中 (此时托盘没有与产线处的货位绑定)
|
var detail = new TN_CG_Detail {
|
S_ITEM_CODE = model.ItemCode, // NOT NULL
|
S_ITEM_NAME = model.ItemName,
|
S_CNTR_CODE = model.CntrCode, // NOT NULL 料箱编号 (待定,现在暂时设定为博实下发)
|
S_BATCH_NO = model.BatchNo, // NOT NULL
|
S_STANDARD = model.Standard,
|
S_NET_WEIGHT = model.NetWeight,
|
S_QUALITY_GRADE = model.QualityGrade,
|
};
|
|
// 产线号的逻辑待定,现在设定为博实下发产线号,看后续需求变更
|
// 好运箱起点为产线货位,人工将好运箱从产线上取下,搬运到满好运箱操作区
|
//var startLocCode = "";
|
//if (model.ProdLineId.Trim() == "3") {
|
// startLocCode = "";
|
//}
|
|
//if (model.ProdLineId.Trim() != "3" || model.ProdLineId.Trim() != "4") {
|
// info = $"不合法的产线号{model.ProdLineId}:好运箱产线号必须为 3 或 4";
|
// LogHelper.Info(info);
|
// return NewMesResult(2, info);
|
//}
|
|
if (db.Insertable(detail).ExecuteCommand() <= 0) {
|
return NewMesResult(500, preLog + $"插入[物料明细表]失败!数据:{LogObject(detail)}");
|
}
|
|
return NewMesResult(500, preLog + $"插入[物料明细表]成功!数据:{LogObject(detail)}");
|
}
|
catch (Exception ex) {
|
return NewMesResult(-1, preLog + $"发生了异常:{ex.Message}\n\n{ex.StackTrace}\n");
|
}
|
}
|
|
private static string LogObject(object obj) {
|
return JsonConvert.SerializeObject(obj).Replace("\"", "'");
|
}
|
}
|
}
|
