using HH.WCS.Emerson.api;
|
using HH.WCS.Emerson.LISTA.models;
|
using HH.WCS.Emerson.models.other;
|
using HH.WCS.Emerson.util;
|
using Newtonsoft.Json;
|
using Opc.Ua;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Linq.Expressions;
|
using System.Reflection;
|
using System.Runtime.Remoting.Messaging;
|
using System.Security.Cryptography;
|
using System.Text;
|
using System.Threading.Tasks;
|
using static HH.WCS.Emerson.api.ApiModel;
|
|
namespace HH.WCS.Emerson.wms
|
{
|
/// <summary>
|
/// wms管到作业
|
/// </summary>
|
internal class WMSHelper
|
{
|
internal static string GenerateTaskNo()
|
{
|
var id = SYSHelper.GetSerialNumber("作业号", "OP");
|
var date = DateTime.Now.ToString("yyMMdd");
|
return $"OP{date}{id.ToString().PadLeft(4, '0')}";
|
}
|
internal static string GenerateSortingNo()
|
{
|
var id = SYSHelper.GetSerialNumber("分拣单", "SO");
|
var date = DateTime.Now.ToString("yyMMdd");
|
return $"SO{date}{id.ToString().PadLeft(4, '0')}";
|
}
|
internal static List<WMSTask> GetOperationListByState(string state)
|
{
|
var db = new SqlHelper<object>().GetInstance();
|
return db.Queryable<WMSTask>().Where(a => a.S_B_STATE == state).ToList();
|
}
|
internal static List<WMSTask> GetOperationListByState(int state)
|
{
|
var db = new SqlHelper<object>().GetInstance();
|
return db.Queryable<WMSTask>().Where(a => a.N_B_STATE == state).ToList();
|
}
|
internal static List<WMSTask> GetWaitingOperationList()
|
{
|
var db = new SqlHelper<object>().GetInstance();
|
return db.Queryable<WMSTask>().Where(a => a.N_B_STATE == 0 || a.N_B_STATE == 3).ToList();
|
}
|
internal static PutawayOrder GetPutawayOrder(string no)
|
{
|
var db = new SqlHelper<object>().GetInstance();
|
return db.Queryable<PutawayOrder>().Where(a => a.S_NO == no).First();
|
}
|
internal static bool CreatePutawayOrder(PutawayOrder model)
|
{
|
var db = new SqlHelper<object>().GetInstance();
|
var result = db.Insertable<PutawayOrder>(model).ExecuteCommand() > 0;
|
db.Insertable<PutawayDetail>(model.Details).ExecuteCommand();
|
return result;
|
}
|
|
internal static PutawayDetail GetPutawayOrderDetail(string no, string item_code)
|
{
|
var db = new SqlHelper<object>().GetInstance();
|
return db.Queryable<PutawayDetail>().Where(a => a.S_PUTAWAY_NO == no && a.S_ITEM_CODE == item_code).First();
|
}
|
internal static PutawayDetail GetPutawayOrderDetail(string item_code)
|
{
|
var db = new SqlHelper<object>().GetInstance();
|
return db.Queryable<PutawayDetail>().Where(a => a.S_ITEM_CODE == item_code && a.F_QTY - a.F_ACC_B_QTY > 0).OrderByDescending(a => a.T_CREATE).First();
|
}
|
|
internal static void UpdatePutawayOrderDetailQty(PutawayDetail model)
|
{
|
var db = new SqlHelper<object>().GetInstance();
|
db.Updateable(model).UpdateColumns(it => new { it.F_ACC_B_QTY }).ExecuteCommand();
|
}
|
|
|
internal static ShippingOrder GetShippingOrder(string no)
|
{
|
var db = new SqlHelper<object>().GetInstance();
|
return db.Queryable<ShippingOrder>().Includes(a => a.Details).Where(a => a.S_NO == no).First();
|
}
|
internal static bool CreateShippingOrder(ShippingOrder model)
|
{
|
var db = new SqlHelper<object>().GetInstance();
|
var result = db.Insertable<ShippingOrder>(model).ExecuteCommand() > 0;
|
db.Insertable<ShippingDetail>(model.Details).ExecuteCommand();
|
return result;
|
}
|
|
internal static bool CreateSortingOrder(List<string> list)
|
{
|
var res = false;
|
//遍历获取发货单，然后判断库存，如果全都没库存，则不生成分拣单，如果有生成分拣单
|
//更新波次单，即使只有一个发货单也更新波次单
|
var db = new SqlHelper<object>().GetInstance();
|
var sortingOrderNo = "";
|
SortingOrder sortingOrder = null;
|
try
|
{
|
db.BeginTran();
|
list.ForEach(a =>
|
{
|
var so = db.Queryable<ShippingOrder>().Includes(s => s.Details).Where(s => s.S_NO == a).First();
|
//判断库存，只有已经入库的才可以计算，码盘的不算，入库后出库途中的也要计算，码盘后默认叫待入库，入库后叫正常
|
//生成出库任务，只有托盘位置在立库才需要创建出库任务（先写死立库）
|
//只有全部分拣完成才允许回库（一个托盘可能对应多个分拣明细）
|
|
//查找仓库量表和库区量表，出库单需要定位仓库和库区了，出库定位物理库区就行，入库可能物料库区还要区分逻辑库区
|
|
//暂时只查仓库量表（量表如何重置，查找所有查找C_ENABLE=N的，判断如果在仓库中，改成Y，然后统计）
|
|
//生成分拣单时候增加仓库量表分配量，生成分拣单明细时候，增加库区量表分配量
|
if (so != null && so.Details.Count > 0)
|
{
|
var fail = true;
|
for (int i = 0; i < so.Details.Count; i++)
|
{
|
var whi = db.Queryable<WHInventory>().Where(w => w.S_ITEM_CODE == so.Details[i].S_ITEM_CODE).First();
|
if (whi != null && whi.F_QTY - whi.F_ALLOC_QTY > 0)
|
{
|
//有货就出
|
float qty = whi.F_QTY - whi.F_ALLOC_QTY > so.Details[i].F_QTY ? so.Details[i].F_QTY : whi.F_QTY - whi.F_ALLOC_QTY;
|
fail = false;
|
//有可用库存，生成分拣单
|
if (sortingOrderNo == "")
|
{
|
sortingOrderNo = GenerateSortingNo();
|
sortingOrder = new SortingOrder
|
{
|
S_NO = sortingOrderNo,
|
S_SHIPPING_NO = so.S_NO,
|
Composes = new List<SortingCompose>()
|
};
|
//创建分拣单
|
db.Insertable(sortingOrder).ExecuteCommand();
|
}
|
else
|
{
|
//获取最新分拣单
|
sortingOrder = db.Queryable<SortingOrder>().Includes(s => s.Composes).Where(s => s.S_NO == sortingOrderNo).First();
|
//更新分拣单中的发货单单号
|
sortingOrder.S_SHIPPING_NO = sortingOrder.S_SHIPPING_NO + ";" + so.S_NO;
|
sortingOrder.T_MODIFY = DateTime.Now;
|
db.Updateable(sortingOrder).UpdateColumns(it => new { it.S_SHIPPING_NO, it.T_MODIFY }).ExecuteCommand();
|
}
|
//查询分拣单子表（正常情况还需要增加批次判断）
|
var soc = db.Queryable<SortingCompose>().Where(s => s.S_ITEM_CODE == so.Details[i].S_ITEM_CODE && s.S_SORTING_NO == sortingOrder.S_NO).First();
|
if (soc == null)
|
{
|
soc = new SortingCompose
|
{
|
S_ITEM_CODE = so.Details[i].S_ITEM_CODE,
|
S_SORTING_NO = sortingOrder.S_NO,
|
F_QTY = qty,
|
N_ROW_NO = sortingOrder.Composes.Count() + 1,
|
S_BATCH_NO = so.Details[i].S_BATCH_NO
|
};
|
|
//创建分拣单子表
|
db.Insertable(soc).ExecuteCommand();
|
}
|
else
|
{
|
soc.F_QTY += qty;
|
soc.T_MODIFY = DateTime.Now;
|
//更新分拣单子表
|
db.Updateable(soc).UpdateColumns(it => new { it.F_QTY, it.T_MODIFY }).ExecuteCommand();
|
}
|
//更新仓库量表分配量
|
whi.F_ALLOC_QTY += qty;
|
whi.T_MODIFY = DateTime.Now;
|
db.Updateable(whi).UpdateColumns(it => new { it.F_ALLOC_QTY, it.T_MODIFY }).ExecuteCommand();
|
//跟新发货单子表配货数量
|
so.Details[i].F_ACC_D_QTY += qty;
|
so.Details[i].T_MODIFY = DateTime.Now;
|
db.Updateable(so.Details[i]).UpdateColumns(it => new { it.F_ACC_D_QTY, it.T_MODIFY }).ExecuteCommand();
|
}
|
|
}
|
//更新发货单状态
|
so.N_B_STATE = fail ? 5 : 1;
|
if (fail)
|
{
|
so.S_NOTE = "没有库存";
|
}
|
so.S_WAVE_CODE = sortingOrderNo;
|
so.T_MODIFY = DateTime.Now;
|
db.Updateable(so).UpdateColumns(it => new { it.N_B_STATE, it.T_MODIFY, it.S_WAVE_CODE, it.S_NOTE }).ExecuteCommand();
|
|
}
|
|
|
//查找库区内托盘生成托盘明细（包括分拣中）怎么判断库内？查找货位绑定？还是托盘上加标识比较好，如果是整托出的，分拣确认后去掉分拣标识。
|
//1、只有码盘入库后的才需要加标识，分拣回的不用，分拣回的标识还在，没有变。写死码盘入的完成后加标识，整托分拣的去掉标识，防止后面重新码盘脏数据
|
//2、或者关联查询库内的，只给分拣出的加标识，每次分拣回再把标识清除了（如果不清除带标识的会很多，还不如全部加标识），整托的清除。
|
//综合选择还是方案1，这样创建分拣明细，只需要托盘物料两表查询就能定位托盘（如果信息不准，可以重置），方案2需要货位、托盘、物料三表联查
|
|
//暂时不计库区，标识用容器表 C_ENABLE 来判断，表示能不能出库
|
|
//执行分拣创建任务，遍历分拣明细中的托盘，如果在仓库就出库，如果不在就不用出库
|
|
|
});
|
//全部分拣单生成之后将分拣单状态设置为开始配货,波次号为发货单
|
sortingOrder = db.Queryable<SortingOrder>().Where(s => s.S_NO == sortingOrderNo).First();
|
sortingOrder.N_B_STATE = 1;
|
sortingOrder.T_MODIFY = DateTime.Now;
|
db.Updateable(sortingOrder).UpdateColumns(it => new { it.N_B_STATE, it.T_MODIFY }).ExecuteCommand();
|
db.CommitTran();
|
res = true;
|
}
|
catch (Exception ex)
|
{
|
Console.WriteLine(ex.Message);
|
db.RollbackTran();
|
}
|
return res;
|
|
}
|
|
internal static List<SortingDetail> GetSortingDetailByCntr(string cntr)
|
{
|
var db = new SqlHelper<object>().GetInstance();
|
var result = db.Queryable<SortingDetail>().Where(a => a.S_CNTR_CODE == cntr && a.N_B_STATE != 2).ToList();
|
return result;
|
}
|
|
internal static bool CreateWmsTask(WMSTask wmsTask)
|
{
|
try
|
{
|
var db = new SqlHelper<object>().GetInstance();
|
return db.Insertable<WMSTask>(wmsTask).ExecuteCommand() > 0;
|
}
|
catch (Exception ex)
|
{
|
Console.WriteLine(ex.Message);
|
throw;
|
}
|
}
|
|
internal static WMSTask GetWmsTaskByCntr(string cntr, bool active = true)
|
{
|
WMSTask result = null;
|
var db = new SqlHelper<object>().GetInstance();
|
if (active)
|
{
|
result = db.Queryable<WMSTask>().Where(a => a.S_CNTR_CODE.Contains(cntr) && a.N_B_STATE < 2).First();
|
}
|
else
|
{
|
result = db.Queryable<WMSTask>().Where(a => a.S_CNTR_CODE.Contains(cntr)).First();
|
}
|
return result;
|
}
|
|
internal static Location GetEnd(WMSTask a)
|
{
|
throw new NotImplementedException();
|
}
|
|
internal static Location GetStart(WMSTask a)
|
{
|
throw new NotImplementedException();
|
}
|
|
internal static void UpdateTaskState(WMSTask task)
|
{
|
var db = new SqlHelper<object>().GetInstance();
|
task.T_MODIFY = DateTime.Now;
|
task.S_B_STATE = WMSTask.GetStateStr(task.N_B_STATE);
|
db.Updateable<WMSTask>(task).UpdateColumns(a => new { a.N_B_STATE, a.S_B_STATE, a.T_MODIFY }).ExecuteCommand();
|
}
|
|
internal static bool UpdateTaskEnd(WMSTask a)
|
{
|
var db = new SqlHelper<object>().GetInstance();
|
a.T_MODIFY = DateTime.Now;
|
return db.Updateable<WMSTask>(a).UpdateColumns(it => new { it.S_END_LOC, it.T_MODIFY }).ExecuteCommand() > 0;
|
}
|
|
internal static WMSTask GetWmsTask(string code)
|
{
|
var db = new SqlHelper<object>().GetInstance();
|
return db.Queryable<WMSTask>().Where(a => a.S_CODE == code).First();
|
}
|
|
internal static void CreateSortingOrderDetail(string so_no)
|
{
|
//分拣单配货
|
var db = new SqlHelper<object>().GetInstance();
|
var so = db.Queryable<SortingOrder>().Includes(a => a.Composes).Where(a => a.S_NO == so_no && (a.N_B_STATE == 1 || a.N_B_STATE == 20)).First();//
|
if (so != null && so.Composes.Count > 0)
|
{
|
db.BeginTran();
|
try
|
{
|
int rowNo = 1;
|
so.Composes.ForEach(a =>
|
{
|
//按分拣单子表去配货，查找可用托盘(先查所有符合的，后面再优化)
|
int param1 = 10;
|
int param2 = 20;
|
|
Expression<Func<int, bool>> exp = x => x > param1;
|
|
var cirList = db.Queryable<CntrItemDetail>().Includes(c => c.Cntr).Where(c => c.Cntr.C_ENABLE == "Y" && c.S_ITEM_CODE == a.S_ITEM_CODE && (c.F_QTY - c.F_ALLOC_QTY) > 0).OrderBy(c => c.T_CREATE).ToList();
|
for (int i = 0; i < cirList.Count; i++)
|
{
|
var cir = cirList[i];
|
var sd = new SortingDetail
|
{
|
N_ROW_NO = rowNo,
|
S_BATCH_NO = a.S_BATCH_NO,
|
S_ITEM_CODE = a.S_ITEM_CODE,
|
S_CNTR_CODE = cir.S_CNTR_CODE,
|
S_SORTING_NO = a.S_SORTING_NO
|
};
|
bool needBreak = false;
|
if (cir.F_QTY - cir.F_ALLOC_QTY >= (a.F_QTY - a.F_ACC_S_QTY))
|
{
|
//容器可用数量大于分拣单子表要求的数量，生成分拣明细，然后跳出循环
|
sd.F_QTY = a.F_QTY - a.F_ACC_S_QTY;
|
needBreak = true;
|
}
|
else
|
{
|
//生成分拣明细，继续创建
|
sd.F_QTY = cir.F_QTY - cir.F_ALLOC_QTY;
|
}
|
db.Insertable(sd).ExecuteCommand();
|
rowNo++;
|
//更新容器货品表分配量
|
cir.F_ALLOC_QTY += sd.F_QTY;
|
cir.T_MODIFY = DateTime.Now;
|
db.Updateable(cir).UpdateColumns(it => new { it.F_ALLOC_QTY, it.T_MODIFY }).ExecuteCommand();
|
//更新分拣单子表的量
|
a.F_ACC_S_QTY += sd.F_QTY;
|
a.T_MODIFY = DateTime.Now;
|
db.Updateable(cir).UpdateColumns(it => new { it.F_ALLOC_QTY, it.T_MODIFY }).ExecuteCommand();
|
if (needBreak)
|
{
|
break;
|
}
|
}
|
});
|
//全部分拣单子表生成分拣明细，修改分拣单状态为配货完成(反正仓库的货能配的都配完了，除非数据有异常)
|
so.N_B_STATE = 2;
|
so.T_MODIFY = DateTime.Now;
|
db.Updateable(so).UpdateColumns(it => new { it.N_B_STATE, it.T_MODIFY }).ExecuteCommand();
|
db.CommitTran();
|
}
|
catch (Exception ex)
|
{
|
Console.WriteLine(ex.Message);
|
db.RollbackTran();
|
}
|
}
|
}
|
|
/// <summary>
|
/// 获取开始配货的分拣单，一次性生成分拣明细，避免生成一半再生成，所以创建分拣明细的时候加上事务
|
/// </summary>
|
/// <returns></returns>
|
internal static List<SortingOrder> GetWaitingSortingOrderList()
|
{
|
var db = new SqlHelper<object>().GetInstance();
|
return db.Queryable<SortingOrder>().Includes(a => a.Composes).Where(a => a.N_B_STATE == 1 || a.N_B_STATE == 20).ToList();
|
}
|
/// <summary>
|
/// 获取配货完成的分拣单，每个分拣单单独创建分拣作业
|
/// </summary>
|
/// <returns></returns>
|
internal static List<SortingOrder> GetWaitingSortingOperationList()
|
{
|
var db = new SqlHelper<object>().GetInstance();
|
return db.Queryable<SortingOrder>().Includes(a => a.Details).Where(a => a.N_B_STATE == 2 || a.N_B_STATE == 3).ToList();
|
}
|
|
/// <summary>
|
///单个分拣单的分拣明细创建作业
|
/// </summary>
|
internal static void CreateSortingOperation(SortingOrder so)
|
{
|
var list = so.Details.Where(a => a.N_B_STATE == 0).ToList();
|
var db = new SqlHelper<object>().GetInstance();
|
if (list.Count > 0)
|
{
|
try
|
{
|
db.BeginTran();
|
list.GroupBy(g => g.S_CNTR_CODE).ToList().ForEach(g =>
|
{
|
var cntr = g.Key;
|
var sdList = g.ToList();
|
//查询托盘货位，查到了创建任务，查不到说明在别的分拣作业中，不创建任务，需要回库后重新创建
|
var lcr = db.Queryable<LocCntrRel>().Where(c => c.S_CNTR_CODE == cntr).First();
|
if (lcr != null)
|
{
|
//判断托盘是否已经创建任务了，可能多个分拣明细是同一个托盘，如果创建任务了，其它分拣的要稍后，只出一次人工会搞不清楚是哪个分拣单的
|
var wmsTask = db.Queryable<WMSTask>().Where(op => op.S_CNTR_CODE.Contains(cntr) && op.N_B_STATE < 2).First();
|
if (wmsTask == null)
|
{
|
wmsTask = new WMSTask
|
{
|
S_CNTR_CODE = cntr,
|
S_CODE = WMSHelper.GenerateTaskNo(),
|
S_START_LOC = lcr.S_LOC_CODE,
|
S_END_LOC = "",
|
N_TYPE = 2,
|
S_TYPE = WMSTask.GetTypeStr(2),
|
S_OP_DEF_CODE = "",
|
S_OP_DEF_NAME = "分拣出立库"
|
};
|
if (db.Insertable(wmsTask).ExecuteCommand() > 0)
|
{
|
LocationHelper.LockLoc(lcr.S_LOC_CODE, 2);
|
}
|
|
sdList.ForEach(a =>
|
{
|
a.N_B_STATE = 1;
|
a.T_MODIFY = DateTime.Now;
|
db.Updateable(a).UpdateColumns(it => new { it.N_B_STATE, it.T_MODIFY }).ExecuteCommand();
|
});
|
}
|
}
|
//修改分拣单状态为开始作业（不代表作业全部创建了，因为有的托盘可能已经被占用了）
|
so.N_B_STATE = 3;
|
//如果所有的作业都已经创建了，就设置为作业已经创建
|
if (so.Details.Count(s => s.N_B_STATE == 0) == 0)
|
{
|
so.N_B_STATE = 4;
|
}
|
so.T_MODIFY = DateTime.Now;
|
db.Updateable(so).UpdateColumns(it => new { it.N_B_STATE, it.T_MODIFY }).ExecuteCommand();
|
|
});
|
db.CommitTran();
|
}
|
catch (Exception ex)
|
{
|
Console.WriteLine(ex.Message);
|
db.RollbackTran();
|
}
|
|
}
|
}
|
internal static void SortingConfrim(List<SortingResultCheck> models)
|
{
|
if (models.Count > 0)
|
{
|
var db = new SqlHelper<object>().GetInstance();
|
try
|
{
|
db.BeginTran();
|
//先查寻该分拣单所有执行中的分拣明细
|
var sdList = db.Queryable<SortingDetail>().Where(a => a.S_SORTING_NO == models[0].sortNo).ToList();
|
var soList = db.Queryable<ShippingOrder>().Includes(a => a.Details).Where(a => a.S_WAVE_CODE == models[0].sortNo).ToList();
|
//查出所有关联的发货单
|
models.ForEach(a =>
|
{
|
//根据条目修改累计分拣数量，添加分拣结果表，同时批分到发货单中
|
var sd = sdList.Where(b => b.S_ITEM_CODE == a.itemCode).First();
|
//简单一点，要求人工必须一次性分拣完，分拣数量和分拣明细中一致才创建分拣结果，不支持一条分拣明细多次分拣，多条分拣结果
|
//(sd.F_QTY - sd.F_ACC_SR_QTY) == a.qty
|
if (sd != null && sd.F_QTY == a.qty)
|
{
|
//查询分拣结果是否已经存在，存在就累加
|
//分拣单结果
|
var sdr = new SortingResult
|
{
|
S_SORTING_NO = models[0].sortNo,
|
F_QTY = a.qty,
|
N_ROW_NO = sd.N_ROW_NO,
|
S_ITEM_CODE = sd.S_ITEM_CODE,
|
S_ITEM_NAME = "",
|
S_BATCH_NO = sd.S_BATCH_NO,
|
S_CNTR_CODE = a.cntrCode
|
};
|
db.Insertable(sdr).ExecuteCommand();
|
//sd.F_ACC_SR_QTY += a.qty;
|
sd.N_B_STATE = 2;
|
sd.T_MODIFY = DateTime.Now;
|
db.Updateable(sd).UpdateColumns(it => new { it.N_B_STATE, it.T_MODIFY }).ExecuteCommand();
|
//批分到发货单中
|
var dList = soList.SelectMany(s => s.Details).Where(d => d.S_ITEM_CODE == a.itemCode && (d.F_QTY - d.F_ACC_S_QTY) > 0).ToList();
|
var qty = a.qty;
|
for (int i = 0; i < dList.Count; i++)
|
{
|
var d = dList[i];
|
//发货信息中间表
|
|
if (d.F_QTY - d.F_ACC_S_QTY >= a.qty)
|
{
|
//发货单数量超过托盘分拣数量，批分qty
|
d.F_ACC_S_QTY += a.qty;
|
qty = 0;
|
}
|
else
|
{
|
// 发货单数量小于托盘分拣数量
|
d.F_ACC_S_QTY = d.F_QTY;
|
qty -= (d.F_QTY - d.F_ACC_S_QTY);
|
}
|
d.T_MODIFY = DateTime.Now;
|
db.Updateable(d).UpdateColumns(it => new { it.F_ACC_S_QTY, it.T_MODIFY }).ExecuteCommand();
|
//插入到大元出库中间表
|
if (qty == 0)
|
{
|
break;
|
}
|
|
}
|
//更新托盘明细表
|
var cir = db.Queryable<CntrItemDetail>().Where(c => c.S_CNTR_CODE == a.cntrCode && c.S_ITEM_CODE == a.itemCode).First();
|
cir.F_QTY -= a.qty;
|
cir.F_ALLOC_QTY -= a.qty;
|
cir.T_MODIFY = DateTime.Now;
|
db.Updateable(cir).UpdateColumns(it => new { it.F_QTY, it.F_ALLOC_QTY, it.T_MODIFY }).ExecuteCommand();
|
//更新仓库量表和库区量表
|
//查询仓库量表
|
var wi = db.Queryable<WHInventory>().Where(i => i.S_ITEM_CODE == a.itemCode).First();
|
if (wi != null)
|
{
|
wi.F_QTY -= a.qty;
|
wi.F_ALLOC_QTY -= a.qty;
|
wi.T_MODIFY = DateTime.Now;
|
db.Updateable(wi).UpdateColumns(it => new { it.F_QTY, it.F_ALLOC_QTY, it.T_MODIFY }).ExecuteCommand();
|
}
|
//麻烦了，分拣明细只记托盘，不记住起点，如果要统计库区量表，必须对托盘加标记，记录托盘的来源库区，托盘清空后再清除标记
|
|
//逻辑库区更不需要量表了，因为从一个逻辑库区出来，可能回其它逻辑库区，那就应该直接删除逻辑库区量表，后面再加到别的逻辑库区中
|
//但是会带来新的问题，就是分拣回的托盘不属于任何逻辑库区的量，只有回库了才能计算到
|
|
//var aziList = db.Queryable<AZInventory>().Where(i => i.S_ITEM_CODE == a.itemCode).ToList();
|
}
|
|
//
|
});
|
//判断分拣单是否全部完成
|
if (sdList.Count(sd => sd.N_B_STATE != 2) == 0)
|
{
|
var spo = db.Queryable<SortingOrder>().Where(s => s.S_NO == models[0].sortNo).First();
|
if (spo != null)
|
{
|
spo.N_B_STATE = 10;
|
spo.T_MODIFY = DateTime.Now;
|
db.Updateable(spo).UpdateColumns(it => new { it.N_B_STATE, it.T_MODIFY }).ExecuteCommand();
|
}
|
}
|
//判断发货单配货是否分拣完成
|
soList.ForEach(s =>
|
{
|
if (s.Details.Count > 0 && s.Details.Count(sd => sd.F_ACC_D_QTY != sd.F_ACC_S_QTY) == 0)
|
{
|
//配货单的数量等于分拣的数量，分拣完成
|
s.N_B_STATE = 3;
|
s.T_MODIFY = DateTime.Now;
|
db.Updateable(s).UpdateColumns(it => new { it.N_B_STATE, it.T_MODIFY }).ExecuteCommand();
|
}
|
});
|
db.CommitTran();
|
}
|
catch (Exception ex)
|
{
|
Console.WriteLine(ex.Message);
|
db.RollbackTran();
|
}
|
}
|
}
|
internal static bool CheckSortingWholeCntr(string cntr, bool autoSort)
|
{
|
var result = false;
|
//判断分拣明细是不是只有一个托盘，如果是，判断容器货品明细是不是和分拣明细完全一样
|
var db = new SqlHelper<object>().GetInstance();
|
var sdList = db.Queryable<SortingDetail>().Where(a => a.S_CNTR_CODE == cntr).ToList();
|
if (sdList.Count > 0)
|
{
|
var groups = sdList.GroupBy(a => a.S_SORTING_NO).ToList();
|
if (groups.Count == 1)
|
{
|
var list = groups.ToList();
|
//只有一个分拣单的情况下,分配量和托盘量都相同，表示是整托
|
var cirList = db.Queryable<CntrItemDetail>().Where(a => a.S_CNTR_CODE == cntr).ToList();
|
if (list.Count == cirList.Count && cirList.Count(c => c.F_QTY != c.F_ALLOC_QTY) == 0)
|
{
|
result = true;
|
if (autoSort)
|
{
|
var data = sdList.Select(s => new SortingResultCheck { cntrCode = s.S_CNTR_CODE, itemCode = s.S_ITEM_CODE, qty = s.F_QTY, sortNo = s.S_SORTING_NO }).ToList();
|
SortingConfrim(data);
|
|
}
|
}
|
}
|
}
|
return result;
|
}
|
|
/// <summary>
|
/// 根据配盘单创建出库任务
|
/// </summary>
|
/// <param name="models"></param>
|
public static void CreateOutTask()
|
{
|
var db = new SqlHelper<object>().GetInstance();
|
var distribution = db.Queryable<TN_Distribution_CNTR>().Where(a => a.N_B_STATE == 1).ToList();
|
if (distribution.Count > 0)
|
{
|
try
|
{
|
foreach (var item in distribution)
|
{
|
LogHelper.Info($"托盘{item.S_CNTR_CODE}开始出库");
|
Location endloc = new Location();
|
Location startloc = new Location();
|
string endZone = "CKFJQ";
|
|
|
//根据托盘编码找托盘货位表
|
var LocCntr = ContainerHelper.GetLocCntrByCntr(item.S_CNTR_CODE);
|
if (LocCntr != null)
|
{
|
startloc = LocationHelper.GetLocListbyloc(LocCntr.S_LOC_CODE).First();
|
if (startloc == null)
|
{
|
LogHelper.Info($"根据托盘货位绑定关系-货位:{LocCntr.S_LOC_CODE}未找到货位信息");
|
}
|
else
|
{
|
if (string.IsNullOrEmpty(item.S_EXIT_LOC_CODE))
|
{
|
//根据终点库区货位和物料计算货位
|
var endlocations = LocationHelper.GetLocListAny(endZone).OrderBy(a => a.N_ROW).ToList();
|
endloc = ApiHelper.FindEndcolByLocList(endlocations);
|
}
|
else
|
{
|
endloc = LocationHelper.GetLoc(item.S_EXIT_LOC_CODE);
|
|
}
|
if (endloc == null)
|
{
|
LogHelper.Info($"终点货位:{item.S_EXIT_LOC_CODE}不可用");
|
return;
|
}
|
if (endloc.N_LOCK_STATE != 0 || endloc.N_CURRENT_NUM != 0)
|
{
|
LogHelper.Info($"终点货位:{item.S_EXIT_LOC_CODE}不可用");
|
return;
|
}
|
}
|
}
|
else
|
{
|
LogHelper.Info($"根据托盘编码:{item.S_CNTR_CODE}未找到托盘货位绑定关系");
|
}
|
if (startloc != null && endloc != null)
|
{
|
//创建wcs任务
|
var wcsTask = new WCSTask
|
{
|
S_CODE = WCSHelper.GenerateTaskNo(),
|
S_TYPE = "出库",
|
S_START_LOC = startloc.S_CODE,
|
S_END_LOC = endloc.S_CODE,
|
N_CNTR_COUNT = 1,
|
N_SCHEDULE_TYPE = 1,
|
S_CNTR_CODE = item.S_CNTR_CODE,
|
N_START_LAYER = startloc.N_LAYER,
|
N_END_LAYER = endloc.N_LAYER,
|
S_START_WH = startloc.S_WH_CODE,
|
S_END_WH = endloc.S_WH_CODE,
|
S_START_AREA = startloc.S_AREA_CODE,
|
S_END_AREA = endloc.S_AREA_CODE,
|
S_EQ_NO = item.S_BS_NO,
|
};
|
LogHelper.Info("创建任务：" + JsonConvert.SerializeObject(wcsTask), "CreateTask");
|
if (WCSHelper.CreateTask(wcsTask))
|
{
|
LogHelper.Info("创建任务成功");
|
// LocationHelper.LockLoc(startloc.S_CODE, 2);
|
// LocationHelper.LockCntr(item.S_CNTR_CODE, 2);
|
LocationHelper.LockLoc(endloc.S_CODE, 1);
|
item.N_B_STATE = 2;
|
db.Updateable(item).UpdateColumns(it => new { it.N_B_STATE }).ExecuteCommand();
|
|
//修改出库单状态
|
var distributions = db.Queryable<TN_Distribution_CNTR>().Where(a => a.N_B_STATE == 1 && a.S_BS_NO == item.S_BS_NO).ToList();
|
if (distributions.Count > 0)
|
{
|
LogHelper.Info($"托盘{item.S_CNTR_CODE}创建任务完成，出库单{item.S_BS_NO}存在未完成的出库任务，不允许修改出库单状态");
|
}
|
else
|
{
|
var outbound = db.Queryable<TN_Outbound_Order>().Where(a => a.S_NO == item.S_BS_NO).First();
|
if (outbound != null && outbound.N_B_STATE != 3)
|
{
|
outbound.N_B_STATE = 3;
|
db.Updateable(outbound).UpdateColumns(it => new { it.N_B_STATE }).ExecuteCommand();
|
LogHelper.Info($"出库单{item.S_BS_NO}创建任务完成，修改出库单状态");
|
}
|
}
|
}
|
else
|
{
|
LogHelper.Info("创建任务失败");
|
}
|
}
|
else
|
{
|
Console.WriteLine("起点终点货位为空，请检查日志");
|
}
|
}
|
}
|
catch (Exception ex)
|
{
|
LogHelper.Info($"CreateOutTask Error :{ex}");
|
throw;
|
}
|
|
|
}
|
|
}
|
|
/// <summary>
|
/// 更改出库单状态
|
/// </summary>
|
public static void UpdateOutTask(WCSTask task)
|
{
|
var db = new SqlHelper<object>().GetInstance();
|
var distribution = db.Queryable<TN_Distribution_CNTR>().Where(a => a.N_B_STATE == 1 && a.S_BS_NO == task.S_EQ_NO).ToList();
|
if (distribution.Count > 0)
|
{
|
|
LogHelper.Info($"出库任务{task.S_CODE}完成，出库单{task.S_EQ_NO}存在未完成的出库任务，不允许修改出库单状态");
|
|
}
|
else
|
{
|
var outbound = db.Queryable<TN_Outbound_Order>().Where(a => a.S_NO == task.S_EQ_NO).First();
|
if (outbound != null)
|
{
|
outbound.N_B_STATE = 3;
|
db.Updateable(outbound).UpdateColumns(it => new { it.N_B_STATE }).ExecuteCommand();
|
LogHelper.Info($"出库任务{task.S_CODE}完成，出库单{task.S_EQ_NO}完成，修改出库单状态");
|
}
|
}
|
}
|
internal static void AddChange(WCSTask task)
|
{
|
var db = new SqlHelper<object>().GetInstance();
|
var result = true;
|
try
|
{
|
|
var itemlist = db.Queryable<CntrItemDetail>().Where(a => a.S_CNTR_CODE == task.S_CNTR_CODE).ToList();
|
if (itemlist.Count > 0)
|
{
|
var url = Settings.Moboxurl + "inventory/AddChange";
|
//仓库量表升量
|
// var req = new AddChangeModel { op_type = 5 };
|
//库区量表升量
|
var req2 = new AddChangeModel { op_type = 6 };
|
itemlist.ForEach(a =>
|
{
|
LogHelper.Info($"填充数据");
|
// LogHelper.Info($"添加仓库量表数据 仓库{task.S_END_WH} 物料编码{a.S_ITEM_CODE} 物料名称{a.S_ITEM_NAME} 数量{a.F_QTY}");
|
//req.item_info.Add(new AddChangeModel.itemModel
|
//{
|
// wh_code = task.S_END_WH,
|
// item_code = a.S_ITEM_CODE,
|
// item_name = a.S_ITEM_NAME,
|
// qty = a.F_QTY
|
//});
|
LogHelper.Info($"添加库区量表数据 库区{task.S_END_AREA} 物料编码{a.S_ITEM_CODE} 物料名称{a.S_ITEM_NAME} 数量{a.F_QTY}");
|
req2.item_info.Add(new AddChangeModel.itemModel
|
{
|
wh_code = task.S_END_WH,
|
area_code = task.S_END_AREA,
|
item_code = a.S_ITEM_CODE,
|
item_name = a.S_ITEM_NAME,
|
qty = a.F_QTY
|
});
|
});
|
// var reqData = JsonConvert.SerializeObject(req);
|
|
var ReqTime = DateTimeOffset.UtcNow.ToUnixTimeSeconds().ToString();
|
|
|
//var res = new HttpHelper().WebPostMobox(url, reqData, "application/json");
|
//if (!string.IsNullOrEmpty(res))
|
//{
|
// LogHelper.Info($"mobox 仓库升量接口返回 {res}");
|
// var moboxres = JsonConvert.DeserializeObject<moboxres>(res);
|
// if (moboxres.err_code != 0)
|
// {
|
// result = false;
|
// }
|
//}
|
//else
|
//{
|
// LogHelper.Info($"mobox 仓库升量接口返回为空");
|
// result = false;
|
//}
|
var reqData2 = JsonConvert.SerializeObject(req2);
|
var ReqTime2 = DateTimeOffset.UtcNow.ToUnixTimeSeconds().ToString();
|
//var ReqTime2 = GetTimeStamp(DateTime.Now.AddHours(-8), 1, 2);
|
|
var res2 = new HttpHelper().WebPostMobox(url, reqData2, "application/json");
|
if (!string.IsNullOrEmpty(res2))
|
{
|
LogHelper.Info($"mobox 库区升量接口返回 {res2}");
|
var moboxres = JsonConvert.DeserializeObject<moboxres>(res2);
|
if (moboxres.err_code != 0)
|
{
|
result = false;
|
}
|
}
|
else
|
{
|
LogHelper.Info($"mobox 库区升量接口返回为空");
|
result = false;
|
}
|
if (result) OnShelves(task, 1);
|
|
}
|
else LogHelper.Info($"托盘{task.S_CNTR_CODE} 在容器货品明细中找不到数据");
|
}
|
catch (Exception ex)
|
{
|
LogHelper.Error($"仓库升量异常 异常信息={ex.Message}", ex);
|
}
|
}
|
|
internal static void DeleteChange(WCSTask task)
|
{
|
var db = new SqlHelper<object>().GetInstance();
|
var result = true;
|
try
|
{
|
// var wmstask = db.Queryable<WMSTask>().Where(a => a.S_CODE == task.S_OP_CODE).First();
|
//if (wmstask != null)
|
//{
|
//var IsLiKu = Settings.LKCodes.Where(a => a.LiKuCode == wmstask.S_START_AREA).FirstOrDefault() == null;
|
//if (IsLiKu)
|
//{
|
// //替换起点库区及起点仓库
|
// var LiKuCode = Settings.ConnetAreas.Where(a => a.AreaCode == wmstask.S_START_AREA).FirstOrDefault();
|
// if (LiKuCode != null)
|
// {
|
// wmstask.S_START_AREA = LiKuCode.LiKuArea;
|
// }
|
//}
|
|
var itemlist = db.Queryable<CntrItemDetail>().Where(a => a.S_CNTR_CODE == task.S_CNTR_CODE).ToList();
|
if (itemlist.Count > 0)
|
{
|
var url = Settings.Moboxurl + "inventory/AddChange";
|
//仓库量表升量
|
// var req = new AddChangeModel { op_type = 4 };
|
//库区量表升量
|
var req2 = new AddChangeModel { op_type = 7 };
|
itemlist.ForEach(a =>
|
{
|
LogHelper.Info($"填充数据");
|
//LogHelper.Info($"减仓库量表数据 仓库{task.S_START_WH} 物料编码{a.S_ITEM_CODE} 物料名称{a.S_ITEM_NAME} 数量{a.F_QTY}");
|
//req.item_info.Add(new AddChangeModel.itemModel
|
//{
|
// wh_code = task.S_START_WH,
|
// item_code = a.S_ITEM_CODE,
|
// item_name = a.S_ITEM_NAME,
|
// qty = a.F_QTY
|
//});
|
LogHelper.Info($"减库区量表数据 库区{task.S_START_WH} 物料编码{a.S_ITEM_CODE} 物料名称{a.S_ITEM_NAME} 数量{a.F_QTY}");
|
req2.item_info.Add(new AddChangeModel.itemModel
|
{
|
wh_code = task.S_START_WH,
|
area_code = task.S_START_AREA,
|
item_code = a.S_ITEM_CODE,
|
item_name = a.S_ITEM_NAME,
|
qty = a.F_QTY
|
});
|
});
|
// var reqData = JsonConvert.SerializeObject(req);
|
var AppKey = Settings.AppKey;
|
var AppSecret = Settings.AppSecret;
|
var ReqTime = DateTimeOffset.UtcNow.ToUnixTimeSeconds().ToString();
|
//var ReqTime = GetTimeStamp(DateTime.Now.AddHours(-8), 1, 2);
|
|
//var res = new HttpHelper().WebPostMobox(url, reqData, "application/json");
|
//if (!string.IsNullOrEmpty(res))
|
//{
|
// LogHelper.Info($"mobox 仓库降量接口返回 {res}");
|
// var moboxres = JsonConvert.DeserializeObject<moboxres>(res);
|
// if (moboxres.err_code != 0)
|
// {
|
// result = false;
|
// }
|
//}
|
//else
|
//{
|
// LogHelper.Info($"mobox 仓库降量接口返回为空");
|
// result = false;
|
//}
|
var reqData2 = JsonConvert.SerializeObject(req2);
|
var ReqTime2 = DateTimeOffset.UtcNow.ToUnixTimeSeconds().ToString();
|
|
var res2 = new HttpHelper().WebPostMobox(url, reqData2, "application/json");
|
if (!string.IsNullOrEmpty(res2))
|
{
|
LogHelper.Info($"mobox 库区降量接口返回 {res2}");
|
var moboxres = JsonConvert.DeserializeObject<moboxres>(res2);
|
if (moboxres.err_code != 0)
|
{
|
result = false;
|
}
|
}
|
else
|
{
|
LogHelper.Info($"mobox 库区降量接口返回为空");
|
result = false;
|
}
|
if (result) OnShelves(task, 2);
|
|
}
|
else LogHelper.Info($"托盘{task.S_CNTR_CODE} 在容器货品明细中找不到数据");
|
// }
|
// else LogHelper.Info($"未找到任务{task.S_CODE} 对应的作业");
|
|
}
|
catch (Exception ex)
|
{
|
LogHelper.Error($"仓库江量异常 异常信息={ex.Message}", ex);
|
}
|
}
|
internal static void CKAddChange(WCSTask task)
|
{
|
var db = new SqlHelper<object>().GetInstance();
|
var result = true;
|
try
|
{
|
var itemlist = db.Queryable<CntrItemDetail>().Where(a => a.S_CNTR_CODE == task.S_CNTR_CODE).ToList();
|
if (itemlist.Count > 0)
|
{
|
var url = Settings.Moboxurl + "inventory/AddChange";
|
//仓库量表升量
|
var req = new AddChangeModel { op_type = 5 };
|
|
itemlist.ForEach(a =>
|
{
|
LogHelper.Info($"填充数据");
|
LogHelper.Info($"添加仓库量表数据 仓库{task.S_END_WH} 物料编码{a.S_ITEM_CODE} 物料名称{a.S_ITEM_NAME} 数量{a.F_QTY}");
|
req.item_info.Add(new AddChangeModel.itemModel
|
{
|
wh_code = task.S_END_WH,
|
item_code = a.S_ITEM_CODE,
|
item_name = a.S_ITEM_NAME,
|
qty = a.F_QTY
|
});
|
LogHelper.Info($"添加库区量表数据 库区{task.S_END_AREA} 物料编码{a.S_ITEM_CODE} 物料名称{a.S_ITEM_NAME} 数量{a.F_QTY}");
|
|
});
|
var reqData = JsonConvert.SerializeObject(req);
|
|
var ReqTime = DateTimeOffset.UtcNow.ToUnixTimeSeconds().ToString();
|
|
|
var res = new HttpHelper().WebPostMobox(url, reqData, "application/json");
|
if (!string.IsNullOrEmpty(res))
|
{
|
LogHelper.Info($"mobox 仓库升量接口返回 {res}");
|
var moboxres = JsonConvert.DeserializeObject<moboxres>(res);
|
if (moboxres.err_code != 0)
|
{
|
result = false;
|
}
|
}
|
else
|
{
|
LogHelper.Info($"mobox 仓库升量接口返回为空");
|
result = false;
|
}
|
// var reqData2 = JsonConvert.SerializeObject(req2);
|
var ReqTime2 = DateTimeOffset.UtcNow.ToUnixTimeSeconds().ToString();
|
//var ReqTime2 = GetTimeStamp(DateTime.Now.AddHours(-8), 1, 2);
|
|
// var res2 = new HttpHelper().WebPostMobox(url, reqData2, "application/json");
|
//if (!string.IsNullOrEmpty(res2))
|
//{
|
// LogHelper.Info($"mobox 库区升量接口返回 {res2}");
|
// var moboxres = JsonConvert.DeserializeObject<moboxres>(res2);
|
// if (moboxres.err_code != 0)
|
// {
|
// result = false;
|
// }
|
//}
|
//else
|
//{
|
// LogHelper.Info($"mobox 库区升量接口返回为空");
|
// result = false;
|
//}
|
if (result) OnShelves(task, 1);
|
|
}
|
else LogHelper.Info($"托盘{task.S_CNTR_CODE} 在容器货品明细中找不到数据");
|
}
|
catch (Exception ex)
|
{
|
LogHelper.Error($"仓库升量异常 异常信息={ex.Message}", ex);
|
}
|
}
|
|
internal static void CKDeleteChange(WCSTask task)
|
{
|
var db = new SqlHelper<object>().GetInstance();
|
var result = true;
|
try
|
{
|
// var wmstask = db.Queryable<WMSTask>().Where(a => a.S_CODE == task.S_OP_CODE).First();
|
//if (wmstask != null)
|
//{
|
//var IsLiKu = Settings.LKCodes.Where(a => a.LiKuCode == wmstask.S_START_AREA).FirstOrDefault() == null;
|
//if (IsLiKu)
|
//{
|
// //替换起点库区及起点仓库
|
// var LiKuCode = Settings.ConnetAreas.Where(a => a.AreaCode == wmstask.S_START_AREA).FirstOrDefault();
|
// if (LiKuCode != null)
|
// {
|
// wmstask.S_START_AREA = LiKuCode.LiKuArea;
|
// }
|
//}
|
|
var itemlist = db.Queryable<CntrItemDetail>().Where(a => a.S_CNTR_CODE == task.S_CNTR_CODE).ToList();
|
if (itemlist.Count > 0)
|
{
|
var url = Settings.Moboxurl + "inventory/AddChange";
|
//仓库量表升量
|
var req = new AddChangeModel { op_type = 4 };
|
//库区量表升量
|
// var req2 = new AddChangeModel { op_type = 7 };
|
itemlist.ForEach(a =>
|
{
|
LogHelper.Info($"填充数据");
|
LogHelper.Info($"减仓库量表数据 仓库{task.S_START_WH} 物料编码{a.S_ITEM_CODE} 物料名称{a.S_ITEM_NAME} 数量{a.F_QTY}");
|
req.item_info.Add(new AddChangeModel.itemModel
|
{
|
wh_code = task.S_START_WH,
|
item_code = a.S_ITEM_CODE,
|
item_name = a.S_ITEM_NAME,
|
qty = a.F_QTY
|
});
|
//LogHelper.Info($"减库区量表数据 库区{task.S_START_WH} 物料编码{a.S_ITEM_CODE} 物料名称{a.S_ITEM_NAME} 数量{a.F_QTY}");
|
//req2.item_info.Add(new AddChangeModel.itemModel
|
//{
|
// wh_code = task.S_START_WH,
|
// area_code = task.S_START_AREA,
|
// item_code = a.S_ITEM_CODE,
|
// item_name = a.S_ITEM_NAME,
|
// qty = a.F_QTY
|
//});
|
});
|
var reqData = JsonConvert.SerializeObject(req);
|
var AppKey = Settings.AppKey;
|
var AppSecret = Settings.AppSecret;
|
var ReqTime = DateTimeOffset.UtcNow.ToUnixTimeSeconds().ToString();
|
//var ReqTime = GetTimeStamp(DateTime.Now.AddHours(-8), 1, 2);
|
|
var res = new HttpHelper().WebPostMobox(url, reqData, "application/json");
|
if (!string.IsNullOrEmpty(res))
|
{
|
LogHelper.Info($"mobox 仓库降量接口返回 {res}");
|
var moboxres = JsonConvert.DeserializeObject<moboxres>(res);
|
if (moboxres.err_code != 0)
|
{
|
result = false;
|
}
|
}
|
else
|
{
|
LogHelper.Info($"mobox 仓库降量接口返回为空");
|
result = false;
|
}
|
// var reqData2 = JsonConvert.SerializeObject(req2);
|
var ReqTime2 = DateTimeOffset.UtcNow.ToUnixTimeSeconds().ToString();
|
|
// var res2 = new HttpHelper().WebPostMobox(url, reqData2, "application/json");
|
//if (!string.IsNullOrEmpty(res2))
|
//{
|
// LogHelper.Info($"mobox 库区降量接口返回 {res2}");
|
// var moboxres = JsonConvert.DeserializeObject<moboxres>(res2);
|
// if (moboxres.err_code != 0)
|
// {
|
// result = false;
|
// }
|
//}
|
//else
|
//{
|
// LogHelper.Info($"mobox 库区降量接口返回为空");
|
// result = false;
|
//}
|
if (result) OnShelves(task, 2);
|
|
}
|
else LogHelper.Info($"托盘{task.S_CNTR_CODE} 在容器货品明细中找不到数据");
|
// }
|
// else LogHelper.Info($"未找到任务{task.S_CODE} 对应的作业");
|
|
}
|
catch (Exception ex)
|
{
|
LogHelper.Error($"仓库江量异常 异常信息={ex.Message}", ex);
|
}
|
}
|
internal static void OnShelves(WCSTask task, int action)
|
{
|
var db = new SqlHelper<object>().GetInstance();
|
var s_action = "";
|
if (action == 1)
|
{
|
s_action = "上架";
|
}
|
else
|
{
|
s_action = "下架";
|
}
|
try
|
{
|
var itemlist = db.Queryable<CntrItemDetail>().Where(a => a.S_CNTR_CODE == task.S_CNTR_CODE).ToList();
|
if (itemlist.Count > 0)
|
{
|
foreach (var item in itemlist)
|
{
|
var info = new TN_OnOff_Shelves
|
{
|
// S_NO = task.S_OP_CODE,
|
// N_ACTION = action,
|
S_ACTION = s_action,
|
S_ITEM_CODE = item.S_ITEM_CODE,
|
S_ITEM_NAME = item.S_ITEM_NAME,
|
S_LOC_CODE = task.S_END_LOC,
|
S_AREA_CODE = task.S_END_AREA,
|
S_CNTR_CODE = task.S_CNTR_CODE,
|
S_BATCH_NO = item.S_BATCH_NO,
|
S_SERIAL_NO = item.S_SERIAL_NO,
|
// D_PRD_DATE = item.D_PRD_DATE,
|
F_QTY = item.F_QTY
|
};
|
db.Insertable(info).ExecuteCommand();
|
}
|
}
|
}
|
catch (Exception ex)
|
{
|
LogHelper.Error($"上架记录添加异常 异常信息={ex.Message}", ex);
|
}
|
}
|
|
/// <summary>
|
/// 库区量表增加
|
/// </summary>
|
/// <param name="cntr"></param>
|
/// <param name="loc"></param>
|
internal static void AddAZLInventory(WCSTask task)
|
{
|
var db = new SqlHelper<object>().GetInstance();
|
try
|
{
|
// 查询容器货品明细数据
|
var cntrItemRels = db.Queryable<CntrItemDetail>().Where(p => p.S_CNTR_CODE == task.S_CNTR_CODE).ToList();
|
if (cntrItemRels.Count > 0)
|
{
|
foreach (var cntrItemRel in cntrItemRels)
|
{
|
var azInventory = db.Queryable<AZL_Inventory>().First(p =>
|
p.S_AREA_CODE == task.S_END_AREA && p.S_ITEM_CODE == cntrItemRel.S_ITEM_CODE);
|
|
if (azInventory != null)
|
{
|
//更新库区量表
|
azInventory.F_QTY += cntrItemRel.F_QTY;
|
azInventory.T_MODIFY = DateTime.Now;
|
db.Updateable(azInventory).UpdateColumns(it => new { it.F_QTY, it.T_MODIFY }).ExecuteCommand();
|
}
|
else
|
{
|
//新增库区量表
|
azInventory = new AZL_Inventory()
|
{
|
F_QTY = cntrItemRel.F_QTY,
|
S_ITEM_CODE = cntrItemRel.S_ITEM_CODE,
|
S_ITEM_NAME = cntrItemRel.S_ITEM_NAME,
|
S_ITEM_SPEC = cntrItemRel.S_ITEM_SPEC,
|
S_WH_CODE = task.S_END_WH,
|
S_AREA_CODE = task.S_END_AREA
|
};
|
db.Insertable(azInventory).ExecuteCommand();
|
}
|
}
|
}
|
else
|
{
|
LogHelper.Info($"根据托盘:{task.S_CNTR_CODE}未找到托盘物料明细数据");
|
}
|
}
|
catch (Exception ex)
|
{
|
LogHelper.Error($"仓库升量异常 异常信息={ex.Message}", ex);
|
}
|
}
|
/// <summary>
|
/// 库区量表减少
|
/// </summary>
|
/// <param name="cntr"></param>
|
/// <param name="loc"></param>
|
internal static void DeleteAZLInventory(WCSTask task)
|
{
|
var db = new SqlHelper<object>().GetInstance();
|
try
|
{
|
// 查询容器货品明细数据
|
var cntrItemRels = db.Queryable<CntrItemDetail>().Where(p => p.S_CNTR_CODE == task.S_CNTR_CODE).ToList();
|
if (cntrItemRels.Count > 0)
|
{
|
foreach (var cntrItemRel in cntrItemRels)
|
{
|
var azInventory = db.Queryable<AZL_Inventory>().First(p =>
|
p.S_AREA_CODE == task.S_START_AREA && p.S_ITEM_CODE == cntrItemRel.S_ITEM_CODE);
|
|
if (azInventory != null)
|
{
|
//更新库区量表
|
azInventory.F_QTY -= cntrItemRel.F_QTY;
|
azInventory.T_MODIFY = DateTime.Now;
|
db.Updateable(azInventory).UpdateColumns(it => new { it.F_QTY, it.T_MODIFY }).ExecuteCommand();
|
}
|
else
|
{
|
LogHelper.Info($"根据物料:{cntrItemRel.S_ITEM_CODE}，库区:{task.S_START_AREA}，未找到库区量表数量");
|
////新增库区量表
|
//azInventory = new AZL_Inventory()
|
//{
|
// F_QTY = cntrItemRel.F_QTY,
|
// S_ITEM_CODE = cntrItemRel.S_ITEM_CODE,
|
// S_ITEM_NAME = cntrItemRel.S_ITEM_NAME,
|
// S_ITEM_SPEC = cntrItemRel.S_ITEM_SPEC,
|
// S_WH_CODE = task.S_END_WH,
|
// S_AREA_CODE = task.S_END_AREA
|
//};
|
//db.Insertable(azInventory).ExecuteCommand();
|
}
|
}
|
}
|
else
|
{
|
LogHelper.Info($"根据托盘:{task.S_CNTR_CODE}未找到托盘物料明细数据");
|
}
|
}
|
catch (Exception ex)
|
{
|
LogHelper.Error($"仓库升量异常 异常信息={ex.Message}", ex);
|
}
|
}
|
|
/// <summary>
|
/// 库区量表增加
|
/// </summary>
|
/// <param name="task"></param>
|
internal static void AddWHInventory(WCSTask task)
|
{
|
var db = new SqlHelper<object>().GetInstance();
|
try
|
{
|
// 查询容器货品明细数据
|
var cntrItemRels = db.Queryable<CntrItemDetail>().Where(p => p.S_CNTR_CODE == task.S_CNTR_CODE).ToList();
|
if (cntrItemRels.Count > 0)
|
{
|
foreach (var cntrItemRel in cntrItemRels)
|
{
|
var azInventory = db.Queryable<WHL_Inventory>().First(p =>
|
p.S_WH_CODE == task.S_END_WH && p.S_ITEM_CODE == cntrItemRel.S_ITEM_CODE);
|
|
if (azInventory != null)
|
{
|
//更新仓库量表
|
azInventory.F_QTY += cntrItemRel.F_QTY;
|
azInventory.T_MODIFY = DateTime.Now;
|
db.Updateable(azInventory).UpdateColumns(it => new { it.F_QTY, it.T_MODIFY }).ExecuteCommand();
|
}
|
else
|
{
|
//新增仓库量表
|
azInventory = new WHL_Inventory()
|
{
|
F_QTY = cntrItemRel.F_QTY,
|
S_ITEM_CODE = cntrItemRel.S_ITEM_CODE,
|
S_ITEM_NAME = cntrItemRel.S_ITEM_NAME,
|
S_ITEM_SPEC = cntrItemRel.S_ITEM_SPEC,
|
S_WH_CODE = task.S_END_WH
|
};
|
db.Insertable(azInventory).ExecuteCommand();
|
}
|
}
|
}
|
else
|
{
|
LogHelper.Info($"根据托盘:{task.S_CNTR_CODE}未找到托盘物料明细数据");
|
}
|
}
|
catch (Exception ex)
|
{
|
LogHelper.Error($"仓库升量异常 异常信息={ex.Message}", ex);
|
}
|
}
|
|
/// <summary>
|
/// 库区量表减少
|
/// </summary>
|
/// <param name="task"></param>
|
internal static void DeletetWHInventory(WCSTask task)
|
{
|
var db = new SqlHelper<object>().GetInstance();
|
try
|
{
|
// 查询容器货品明细数据
|
var cntrItemRels = db.Queryable<CntrItemDetail>().Where(p => p.S_CNTR_CODE == task.S_CNTR_CODE).ToList();
|
if (cntrItemRels.Count > 0)
|
{
|
foreach (var cntrItemRel in cntrItemRels)
|
{
|
var azInventory = db.Queryable<WHL_Inventory>().First(p =>
|
p.S_WH_CODE == task.S_START_WH && p.S_ITEM_CODE == cntrItemRel.S_ITEM_CODE);
|
|
if (azInventory != null)
|
{
|
//更新仓库量表
|
azInventory.F_QTY += cntrItemRel.F_QTY;
|
azInventory.T_MODIFY = DateTime.Now;
|
db.Updateable(azInventory).UpdateColumns(it => new { it.F_QTY, it.T_MODIFY }).ExecuteCommand();
|
}
|
else
|
{
|
LogHelper.Info($"根据物料:{cntrItemRel.S_ITEM_CODE}，仓库:{task.S_START_WH}，未找到仓库量表数量");
|
////新增仓库量表
|
//azInventory = new WHL_Inventory()
|
//{
|
// F_QTY = cntrItemRel.F_QTY,
|
// S_ITEM_CODE = cntrItemRel.S_ITEM_CODE,
|
// S_ITEM_NAME = cntrItemRel.S_ITEM_NAME,
|
// S_ITEM_SPEC = cntrItemRel.S_ITEM_SPEC,
|
// S_WH_CODE = task.S_END_WH
|
//};
|
//db.Insertable(azInventory).ExecuteCommand();
|
}
|
}
|
}
|
else
|
{
|
LogHelper.Info($"根据托盘:{task.S_CNTR_CODE}未找到托盘物料明细数据");
|
}
|
}
|
catch (Exception ex)
|
{
|
LogHelper.Error($"仓库升量异常 异常信息={ex.Message}", ex);
|
}
|
}
|
|
/// <summary>
|
/// 仓库量表接口字段
|
/// </summary>
|
public class AddChangeModel
|
{
|
/// <summary>
|
/// 5 - 仓库加存储量，用于 入库完成
|
/// 6 - 库区加存储量，用于库区入库完成，
|
/// 7 - 库区减存储、分配量，用于 库区出库完成
|
/// 8 - 仓库减存储量，9 - 库区减存储量
|
/// 10 - 仓库减分配量，用于 配货后取消，
|
/// 11 - 库区减分配量，用于 配货后取消
|
/// </summary>
|
public int op_type { get; set; }
|
public List<itemModel> item_info { get; set; } = new List<itemModel>();
|
public class itemModel
|
{
|
public string wh_code { get; set; } = "";
|
public string area_code { get; set; } = "";
|
public string loc_code { get; set; } = "";
|
public string item_code { get; set; }
|
public string item_name { get; set; }
|
public float qty { get; set; }
|
}
|
}
|
|
public class moboxres
|
{
|
public int err_code { get; set; }
|
public string err_msg { get; set; } = "";
|
}
|
}
|
}
|
