using HH.WCS.Mobox3.WeiLi.api;
|
using HH.WCS.Mobox3.WeiLi.models;
|
using HH.WCS.Mobox3.WeiLi.models.other;
|
using HH.WCS.Mobox3.WeiLi.util;
|
using Newtonsoft.Json;
|
using SqlSugar;
|
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.Mobox3.WeiLi.api.ApiModel;
|
using static HH.WCS.Mobox3.WeiLi.api.OtherModel;
|
using static HH.WCS.Mobox3.WeiLi.util.Settings;
|
|
namespace HH.WCS.Mobox3.WeiLi.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 string GenerateShippNo()
|
{
|
var id = SYSHelper.GetSerialNumber("出库单", "OU");
|
var date = DateTime.Now.ToString("yyMMdd");
|
return $"OU{date}{id.ToString().PadLeft(4, '0')}";
|
}
|
internal static string GenerateDistrbutionCntrNo()
|
{
|
var id = SYSHelper.GetSerialNumber("配盘号", "DC");
|
var date = DateTime.Now.ToString("yyMMdd");
|
return $"DC{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 void Fail(WCSTask tN_Task)
|
{
|
var db = new SqlHelper<object>().GetInstance();
|
var wmsTask = db.Queryable<WMSTask>().Where(a => a.S_CODE == tN_Task.S_OP_CODE).First();
|
if (wmsTask != null)
|
{
|
wmsTask.N_B_STATE = 6;
|
WMSHelper.UpdateTaskState(wmsTask);
|
}
|
}
|
|
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 TN_Outbound_Order GetOutboundOrder(string no)
|
{
|
var db = new SqlHelper<object>().GetInstance();
|
return db.Queryable<TN_Outbound_Order>().Includes(a => a.Details).Where(a => a.S_BS_NO == no).First();
|
}
|
internal static TN_Inbound_Order GetInboundOrder(string no)
|
{
|
var db = new SqlHelper<object>().GetInstance();
|
return db.Queryable<TN_Inbound_Order>().Includes(a => a.Details).Where(a => a.S_NO == no).First();
|
}
|
|
internal static TN_ASN_Order GetASNOrder(string no)
|
{
|
var db = new SqlHelper<object>().GetInstance();
|
return db.Queryable<TN_ASN_Order>().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 CreateOutboundOrder(TN_Outbound_Order model)
|
{
|
var db = new SqlHelper<object>().GetInstance();
|
var result = db.Insertable<TN_Outbound_Order>(model).ExecuteCommand() > 0;
|
db.Insertable<TN_Outbound_Detail>(model.Details).ExecuteCommand();
|
return result;
|
}
|
|
internal static bool CreateInboundOrder(TN_Inbound_Order model)
|
{
|
var db = new SqlHelper<object>().GetInstance();
|
var result = db.Insertable<TN_Inbound_Order>(model).ExecuteCommand() > 0;
|
db.Insertable<TN_Inbound_Detail>(model.Details).ExecuteCommand();
|
return result;
|
}
|
|
internal static bool CreateASNOrder(TN_ASN_Order model)
|
{
|
LogHelper.Info($"子表长度{model.Details.Count} 数据{JsonConvert.SerializeObject(model.Details)}");
|
var db = new SqlHelper<object>().GetInstance();
|
var result = db.Insertable<TN_ASN_Order>(model).ExecuteCommand() > 0;
|
db.Insertable<TN_ASN_Detail>(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_TYPE = so.S_BS_TYPE,
|
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();
|
}
|
|
Expression<Func<SortingCompose, bool>> expression = x => x.S_ITEM_CODE == so.Details[i].S_ITEM_CODE;
|
expression.AndAlso(x => x.S_SORTING_NO == sortingOrder.S_NO);
|
if (!string.IsNullOrEmpty(so.Details[i].S_BATCH_NO)) expression.AndAlso(x => x.S_BATCH_NO == so.Details[i].S_BATCH_NO);
|
if (!string.IsNullOrEmpty(so.Details[i].S_FAC_CODE)) expression.AndAlso(x => x.S_FAC_CODE == so.Details[i].S_FAC_CODE);
|
if (!string.IsNullOrEmpty(so.Details[i].S_ITEM_LOC)) expression.AndAlso(x => x.S_ITEM_LOC == so.Details[i].S_ITEM_LOC);
|
//查询分拣单子表（正常情况还需要增加批次判断）
|
var soc = db.Queryable<SortingCompose>()
|
.Where(expression)
|
.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,
|
S_FAC_CODE = so.Details[i].S_FAC_CODE,
|
S_ITEM_LOC = so.Details[i].S_ITEM_LOC
|
};
|
|
//创建分拣单子表
|
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 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<CntrItemRel>().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);
|
}
|
}
|
|
internal static void AddChange(WCSTask task)
|
{
|
var db = new SqlHelper<object>().GetInstance();
|
var result = true;
|
try
|
{
|
var itemlist = db.Queryable<CntrItemRel>().Where(a => a.S_CNTR_CODE == task.S_CNTR_CODE).ToList();
|
if (itemlist.Count > 0)
|
{
|
var url = Settings.MoboxSeverUrl + "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 AppKey = Settings.AppKey;
|
var AppSecret = Settings.AppSecret;
|
var ReqTime = DateTimeOffset.UtcNow.ToUnixTimeSeconds().ToString();
|
//var ReqTime = GetTimeStamp(DateTime.Now.AddHours(-8), 1, 2);
|
LogHelper.Info($"加密前 AppKey={AppKey} AppSecret={AppSecret} ReqTime={ReqTime}");
|
var ReqVerify = GetMd5FromString(AppKey + AppSecret + ReqTime);
|
LogHelper.Info($"加密后 AppKey={AppKey} AppSecret={AppSecret} ReqTime={ReqTime} ReqVerify={ReqVerify} url={url} req={reqData}");
|
var res = new HttpHelper().WebPost(url, reqData, "application/json", AppKey, ReqTime, ReqVerify);
|
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);
|
LogHelper.Info($"加密前 AppKey={AppKey} AppSecret={AppSecret} ReqTime={ReqTime2}");
|
var ReqVerify2 = GetMd5FromString(AppKey + AppSecret + ReqTime2);
|
LogHelper.Info($"加密后 AppKey={AppKey} AppSecret={AppSecret} ReqTime={ReqTime2} ReqVerify={ReqVerify2} url={url} req={reqData2}");
|
var res2 = new HttpHelper().WebPost(url, reqData2, "application/json", AppKey, ReqTime2, ReqVerify2);
|
if (!string.IsNullOrEmpty(res2))
|
{
|
LogHelper.Info($"mobox 库区升量接口返回 {res2}");
|
var moboxres = JsonConvert.DeserializeObject<moboxres>(res);
|
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<CntrItemRel>().Where(a => a.S_CNTR_CODE == task.S_CNTR_CODE).ToList();
|
if (itemlist.Count > 0)
|
{
|
var url = Settings.MoboxSeverUrl + "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_END_WH} 物料编码{a.S_ITEM_CODE} 物料名称{a.S_ITEM_NAME} 数量{a.F_QTY}");
|
req.item_info.Add(new AddChangeModel.itemModel
|
{
|
wh_code = wmstask.S_START_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 = wmstask.S_START_WH,
|
area_code = wmstask.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);
|
LogHelper.Info($"加密前 AppKey={AppKey} AppSecret={AppSecret} ReqTime={ReqTime}");
|
var ReqVerify = GetMd5FromString(AppKey + AppSecret + ReqTime);
|
LogHelper.Info($"加密后 AppKey={AppKey} AppSecret={AppSecret} ReqTime={ReqTime} ReqVerify={ReqVerify} url={url} req={reqData}");
|
var res = new HttpHelper().WebPost(url, reqData, "application/json", AppKey, ReqTime, ReqVerify);
|
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);
|
LogHelper.Info($"加密前 AppKey={AppKey} AppSecret={AppSecret} ReqTime={ReqTime2}");
|
var ReqVerify2 = GetMd5FromString(AppKey + AppSecret + ReqTime2);
|
LogHelper.Info($"加密后 AppKey={AppKey} AppSecret={AppSecret} ReqTime={ReqTime2} ReqVerify={ReqVerify2} url={url} req={reqData2}");
|
var res2 = new HttpHelper().WebPost(url, reqData2, "application/json", AppKey, ReqTime2, ReqVerify2);
|
if (!string.IsNullOrEmpty(res2))
|
{
|
LogHelper.Info($"mobox 库区降量接口返回 {res2}");
|
var moboxres = JsonConvert.DeserializeObject<moboxres>(res);
|
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);
|
}
|
}
|
|
public class moboxres
|
{
|
public int err_code { get; set; }
|
public string err_msg { get; set; } = "";
|
}
|
|
|
|
/// <summary>
|
/// 任务信息接口--获取时间戳
|
/// </summary>
|
/// <param name="DataBitType">数据位数：值：32|64 含义：32位|64位</param>
|
/// <param name="TimeType">获取时间类型：值：1|2 含义：1-秒级 2-毫秒级</param>
|
/// <param name="TimeUtcType">获取时间Utc类型：值：1|2 含义：1-本地时间 2-Utc时间</param>
|
/// <returns></returns>
|
public static string GetTimeStamp(DateTime dateTime, int DataBitType, int TimeType)
|
{
|
string timeStamp = "";
|
|
//时间戳打印
|
TimeSpan ts = dateTime - new DateTime(1970, 1, 1, 0, 0, 0, 0);//时间戳获取
|
double tsTime = TimeType == 1 ? ts.TotalSeconds : ts.TotalMilliseconds;//秒级|毫秒级时间获取
|
|
string TimeTypeInfo = TimeType == 1 ? "秒级" : "毫秒级";
|
timeStamp = DataBitType == 32 ? Convert.ToInt32(tsTime).ToString() : Convert.ToInt64(tsTime).ToString();
|
|
//double result = 0;
|
//result = DataBitType == 32 ? Convert.ToInt32(tsTime) : Convert.ToInt64(tsTime);
|
|
return timeStamp;
|
}
|
|
/// <summary>
|
/// MD5加密
|
/// </summary>
|
/// <param name="sInput"></param>
|
/// <returns></returns>
|
public static string GetMd5FromString(string sInput)
|
{
|
var lstData = Encoding.GetEncoding("utf-8").GetBytes(sInput);
|
var lstHash = new MD5CryptoServiceProvider().ComputeHash(lstData);
|
var result = new StringBuilder(32);
|
for (int i = 0; i < lstHash.Length; i++)
|
{
|
result.Append(lstHash[i].ToString("x2").ToUpper());
|
}
|
return result.ToString();
|
}
|
|
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; }
|
}
|
}
|
|
|
|
internal static void End(WCSTask task)
|
{
|
var db = new SqlHelper<object>().GetInstance();
|
var wmsTask = db.Queryable<WMSTask>().Where(a => a.S_CODE == task.S_OP_CODE).First();
|
if (wmsTask != null && wmsTask.S_END_LOC != task.S_END_LOC)
|
{
|
//if (wmsTask.S_OP_DEF_NAME == "码盘入库")
|
//{
|
// //修改作业状态 重新启动
|
// wmsTask.N_B_STATE = 5;
|
// WMSHelper.UpdateTaskState(wmsTask);
|
//}
|
//else
|
//{
|
//修改作业状态 重新启动
|
wmsTask.N_B_STATE = 0;
|
WMSHelper.UpdateTaskState(wmsTask);
|
//}
|
}
|
else if (wmsTask != null && wmsTask.S_END_LOC == task.S_END_LOC)
|
{
|
//修改作业状态 重新启动
|
wmsTask.N_B_STATE = 2;
|
WMSHelper.UpdateTaskState(wmsTask);
|
if (task.S_TYPE == "分拣出")
|
{
|
WCSHelper.UpdateStorStatus(task.S_CNTR_CODE, 4);
|
}
|
|
if (wmsTask.S_OP_DEF_NAME == "入库" || wmsTask.S_OP_DEF_NAME == "空框入库")
|
{
|
var LKCode = Settings.LKCodes.Where(a => a.LiKuCode == wmsTask.S_END_AREA).FirstOrDefault();
|
if (LKCode != null)
|
{
|
//入库完成上报 人工库入库在接口中回报
|
OpState(task);
|
}
|
else
|
{
|
OpState(task, false);
|
}
|
|
}
|
|
|
|
if (wmsTask.S_OP_DEF_NAME == "码盘入库")
|
{
|
var LKCode = Settings.LKCodes.Where(a => a.LiKuCode == wmsTask.S_END_AREA).FirstOrDefault();
|
var DJCode = Settings.DJCodes.Where(a => a.DJAreaCode == wmsTask.S_END_AREA).FirstOrDefault();
|
if (LKCode != null || DJCode != null)
|
{
|
//码盘入库回执
|
receiveUnloadConfirm(wmsTask.S_CNTR_CODE, wmsTask.S_END_LOC);
|
}
|
|
}
|
|
|
if (wmsTask.S_OP_DEF_NAME == "入库" || wmsTask.S_OP_DEF_NAME == "码盘入库")
|
{
|
//查询物料主数据是否有相同的数据
|
var itemlist = db.Queryable<CntrItemRel>().Where(a => a.S_CNTR_CODE == wmsTask.S_CNTR_CODE).ToList();
|
itemlist.ForEach(a =>
|
{
|
//查找物料主数据中的物料是否存在 如果存在更新物料库区
|
var itemInfo = db.Queryable<TN_Material>().Where(it => it.S_ITEM_CODE == a.S_ITEM_CODE).First();
|
if (itemInfo != null)
|
{
|
itemInfo.S_AREA_CODE = wmsTask.S_END_AREA;
|
db.Updateable(itemInfo).UpdateColumns(it => new { it.S_AREA_CODE }).ExecuteCommand();
|
}
|
});
|
}
|
//else if (wmsTask.S_OP_DEF_NAME == "出库" || wmsTask.S_OP_DEF_NAME == "空框出库")
|
//{
|
// //出库单完成上报 分拣出在分拣回接口中进行处理
|
// OutState(task);
|
//}
|
|
}
|
var cntr = db.Queryable<TN_Distribution_CNTR>().Where(a => a.S_CNTR_CODE == task.S_CNTR_CODE && a.N_B_STATE == 1).First();
|
if (cntr != null && task.S_TYPE == "分拣回")
|
{
|
var endLoc = db.Queryable<Location>().Where(a => a.S_CODE == task.S_END_LOC).First();
|
endLoc.N_LOCK_STATE = 3;
|
endLoc.S_LOCK_STATE = "其它锁";
|
db.Updateable(endLoc).UpdateColumns(it => new { it.S_LOCK_STATE, it.N_LOCK_STATE }).ExecuteCommand();
|
}
|
var InventoryCntr = db.Queryable<PlanInventory>().Where(a => a.S_CNTR_CODE == task.S_CNTR_CODE && a.N_B_STATE == 1).First();
|
if (InventoryCntr != null && task.S_TYPE == "盘点出")
|
{
|
InventoryCntr.N_B_STATE = 2;
|
db.Updateable(InventoryCntr).UpdateColumns(it => new { it.N_B_STATE }).ExecuteCommand();
|
}
|
|
//var InventoryCntr2 = db.Queryable<PlanInventory>().Where(a => a.S_CNTR_CODE == task.S_CNTR_CODE && a.N_B_STATE == 3).First();
|
//if (InventoryCntr2 != null && task.S_TYPE == "盘点回")
|
//{
|
// InventoryCntr2.N_B_STATE = 4;
|
// db.Updateable(InventoryCntr2).UpdateColumns(it => new { it.N_B_STATE }).ExecuteCommand();
|
//}
|
}
|
|
|
public static void receiveUnloadConfirm(string CNTR_CODE, string END_LOC)
|
{
|
try
|
{
|
var db = new SqlHelper<object>().GetInstance();
|
var url = Settings.ZTSeverUrl + "receiveUnloadConfirm";
|
var req = new { cntrCode = CNTR_CODE, location = END_LOC, data = new List<object>() };
|
var cn = db.Queryable<CntrItemRel>().Where(a => a.S_CNTR_CODE == CNTR_CODE).ToList();
|
if (cn.Count > 0)
|
{
|
var grouplist = cn.GroupBy(a => new { a.S_ITEM_CODE, a.S_BATCH_NO, a.S_OWNER, a.S_ERP_WH_CODE, a.S_SUPPLIER_NO, a.S_WU }).ToList();
|
for (int i = 0; i < grouplist.Count; i++)
|
{
|
var num = 0;
|
var serialNo = new List<string>();
|
var S_ITEM_CODE = grouplist[i].Key.S_ITEM_CODE;
|
var S_BATCH_NO = grouplist[i].Key.S_BATCH_NO;
|
var S_OWNER = grouplist[i].Key.S_OWNER;
|
var S_ERP_WH_CODE = grouplist[i].Key.S_ERP_WH_CODE;
|
var S_SUPPLIER_NO = grouplist[i].Key.S_SUPPLIER_NO;
|
var rowID = grouplist[i].Key.S_WU;
|
var itemgroup = cn.Where(it => it.S_ITEM_CODE == S_ITEM_CODE && it.S_BATCH_NO == S_BATCH_NO && it.S_OWNER == S_OWNER && it.S_ERP_WH_CODE == S_ERP_WH_CODE && it.S_SUPPLIER_NO == S_SUPPLIER_NO && it.S_WU == rowID).ToList();
|
if (itemgroup.Count > 0)
|
{
|
itemgroup.ForEach(a =>
|
{
|
//填充数据
|
num = num + Convert.ToInt32(a.F_QTY);
|
if (!string.IsNullOrEmpty(a.S_SERIAL_NO))
|
{
|
serialNo.Add(a.S_SERIAL_NO);
|
}
|
});
|
req.data.Add(new { itemCode = S_ITEM_CODE, factoryCode = S_OWNER, stockCode = S_ERP_WH_CODE, qty = num, vendorCode = S_SUPPLIER_NO, batchNo = S_BATCH_NO, serialNo = serialNo, rowID = rowID });
|
}
|
}
|
LogHelper.Info($"码盘入库回执 地址{url} 接口参数{JsonConvert.SerializeObject(req)}");
|
var feedback = new HttpHelper().WebPost(url, JsonConvert.SerializeObject(req));
|
LogHelper.Info($"码盘入库回执 地址{url} 接口参数{JsonConvert.SerializeObject(req)} 返回参数{feedback}");
|
if (!string.IsNullOrEmpty(feedback))
|
{
|
var weilires = JsonConvert.DeserializeObject<WeiLiResult>(feedback);
|
if (weilires.code == 200)
|
{
|
LogHelper.Info($"接口反馈成功");
|
}
|
else
|
{
|
LogHelper.Info($"码盘入库回执 反馈失败 失败原因={weilires.msg}");
|
}
|
}
|
else
|
{
|
LogHelper.Info($"码盘入库回执 反馈超时");
|
}
|
}
|
else LogHelper.Info($"托盘{CNTR_CODE} 未绑定物料");
|
|
}
|
catch (Exception ex)
|
{
|
LogHelper.Error($"码盘入库回执 异常信息={ex.Message}", ex);
|
}
|
}
|
|
|
public static string OutState(WCSTask task, string workNo)
|
{
|
var result = "";
|
var db = new SqlHelper<object>().GetInstance();
|
try
|
{
|
var url = Settings.ZTSeverUrl2 + "/business/BU_HX02";
|
|
var id = DateTime.Now.Ticks.ToString();
|
var reqinfo = db.Queryable<TN_PRICE>().Where(a => a.S_CNTR_CODE == task.S_CNTR_CODE && a.S_NO == workNo).First();
|
if (reqinfo != null)
|
{
|
id = reqinfo.S_REPEAT;
|
}
|
else
|
{
|
reqinfo = new TN_PRICE { S_NO = workNo, S_CNTR_CODE = task.S_CNTR_CODE, S_REPEAT = id };
|
db.Insertable(reqinfo).ExecuteCommand();
|
}
|
|
var req = new { shippingNoteNo = workNo, cntrNo = task.S_CNTR_CODE, destLocation = task.S_END_LOC, repeat = id, data = new List<object>() };
|
var itemlist = db.Queryable<CntrItemRel>().Where(a => a.S_CNTR_CODE == task.S_CNTR_CODE).ToList();
|
itemlist.ForEach(it =>
|
{
|
req.data.Add(new
|
{
|
itemCode = it.S_ITEM_CODE,
|
factoryCode = string.IsNullOrEmpty(it.S_OWNER) ? "" : it.S_OWNER,
|
stockCode = string.IsNullOrEmpty(it.S_ERP_WH_CODE) ? "" : it.S_ERP_WH_CODE,
|
qty = it.F_QTY,
|
vendorCode = string.IsNullOrEmpty(it.S_SUPPLIER_NO) ? "" : it.S_SUPPLIER_NO,
|
batchNo = string.IsNullOrEmpty(it.S_BATCH_NO) ? "" : it.S_BATCH_NO,
|
serialNo = string.IsNullOrEmpty(it.S_SERIAL_NO) ? "" : it.S_SERIAL_NO
|
});
|
});
|
LogHelper.Info($"出库完成任务回报 地址{url} 接口参数{JsonConvert.SerializeObject(req)}");
|
var feedback = new HttpHelper().WebPost(url, JsonConvert.SerializeObject(req));
|
LogHelper.Info($"出库完成任务回报 地址{url} 返回参数{feedback}");
|
|
if (!string.IsNullOrEmpty(feedback))
|
{
|
var weilires = JsonConvert.DeserializeObject<WeiLiResult>(feedback);
|
if (weilires.code == 200)
|
{
|
LogHelper.Info($"接口反馈成功");
|
result = weilires.data.endbit;
|
}
|
else
|
{
|
LogHelper.Info($"出库完成任务回报 反馈失败 失败原因={weilires.msg}");
|
}
|
}
|
else
|
{
|
LogHelper.Info($"出库完成任务回报 反馈超时");
|
}
|
}
|
catch (Exception ex)
|
{
|
LogHelper.Error($"出库完成任务回报异常 异常信息={ex.Message}", ex);
|
}
|
return result;
|
}
|
|
internal static void PreparationState(WCSTask task)
|
{
|
try
|
{
|
var db = new SqlHelper<object>().GetInstance();
|
var CntrItem = db.Queryable<CntrItemRel>().Where(a => a.S_CNTR_CODE == task.S_CNTR_CODE && a.S_EXT_ATTR1 == "Y").ToList();
|
if (CntrItem.Count > 0)
|
{
|
var req = new { TicketNo = CntrItem[0].S_BS_NO, ContainerNo = task.S_CNTR_CODE, LocationNo = task.S_END_LOC, Status = "02", materialList = new List<object>() };
|
CntrItem.ForEach(a =>
|
{
|
req.materialList.Add(
|
new
|
{
|
MaterialNo = a.S_ITEM_CODE,
|
LotNo = a.S_BATCH_NO,
|
FactoryCode = a.S_OWNER,
|
StockPlace = a.S_ERP_WH_CODE,
|
Qty = a.F_QTY,
|
Notes = a.S_SERIAL_NO,
|
Supplier = a.S_SUPPLIER_NO
|
});
|
});
|
var url = Settings.ZTSeverUrl2 + "/business/BU_HX04";
|
//var req = new { orderNo = task.S_OP_CODE, cntrNo = task.S_CNTR_CODE, destLocation = task.S_END_LOC };
|
LogHelper.Info($"备料状态回报 地址{url} 接口参数{JsonConvert.SerializeObject(req)}");
|
var feedback = new HttpHelper().WebPost(url, JsonConvert.SerializeObject(req));
|
if (!string.IsNullOrEmpty(feedback))
|
{
|
var weilires = JsonConvert.DeserializeObject<WeiLiResult>(feedback);
|
if (weilires.code == 200)
|
{
|
LogHelper.Info($"接口反馈成功");
|
}
|
else
|
{
|
LogHelper.Info($"备料状态回报 反馈失败 失败原因={weilires.msg}");
|
}
|
}
|
else
|
{
|
LogHelper.Info($"备料状态回报 反馈超时");
|
}
|
}
|
}
|
catch (Exception ex)
|
{
|
LogHelper.Error($"备料状态回报 异常信息{ex.Message}", ex);
|
}
|
}
|
|
public static void OpState(WCSTask task, bool bol = true)
|
{
|
try
|
{
|
var status = bol ? "success" : "failed";
|
var url = Settings.ZTSeverUrl2 + "/business/BU_HX03";
|
var req = new { orderNo = task.S_OP_CODE, cntrNo = task.S_CNTR_CODE, destLocation = task.S_END_LOC, status = status };
|
LogHelper.Info($"作业完成任务回报 地址{url} 接口参数{JsonConvert.SerializeObject(req)}");
|
var feedback = new HttpHelper().WebPost(url, JsonConvert.SerializeObject(req));
|
if (!string.IsNullOrEmpty(feedback))
|
{
|
var weilires = JsonConvert.DeserializeObject<WeiLiResult>(feedback);
|
if (weilires.code == 200)
|
{
|
LogHelper.Info($"接口反馈成功");
|
}
|
else
|
{
|
LogHelper.Info($"作业完成任务回报 反馈失败 失败原因={weilires.msg}");
|
}
|
}
|
else
|
{
|
LogHelper.Info($"作业完成任务回报 反馈超时");
|
}
|
}
|
catch (Exception ex)
|
{
|
LogHelper.Error($"作业完成任务回报异常 异常信息={ex.Message}", ex);
|
}
|
|
}
|
|
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 == 1).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;
|
}
|
}
|
|
public static bool CreateOpTask(string startLoc, string endLoc, string sType, string taskType, string trayCode)
|
{
|
bool result = false;
|
int nType = sType == "入库" ? 1 : 2;
|
var wmsTask = new WMSTask
|
{
|
S_CNTR_CODE = trayCode,
|
S_CODE = WMSHelper.GenerateTaskNo(),
|
S_START_LOC = startLoc,
|
S_END_LOC = endLoc,
|
N_TYPE = nType,
|
S_TYPE = sType,
|
S_OP_DEF_CODE = "",
|
S_OP_DEF_NAME = taskType
|
};
|
result = WMSHelper.CreateWmsTask(wmsTask);
|
if (result)
|
{
|
LocationHelper.LockLoc(startLoc, 2);
|
LocationHelper.LockLoc(endLoc, 1);
|
LogHelper.Info($"创建作业成功，作业号{wmsTask.S_CODE}");
|
}
|
|
return result;
|
}
|
|
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)
|
{
|
LogHelper.Info($"作业{a.S_CODE} 获取终点");
|
Location result = null;
|
//try
|
//{
|
string cntrarea = "";
|
var db = new SqlHelper<object>().GetInstance();
|
var cntrinfo = db.Queryable<LocCntrRel>().Where(it => it.S_CNTR_CODE == a.S_CNTR_CODE).First();
|
if (cntrinfo != null)
|
{
|
var locinfo = db.Queryable<Location>().Where(it => it.S_CODE == cntrinfo.S_LOC_CODE).First();
|
cntrarea = locinfo.S_AREA_CODE;
|
}
|
LogHelper.Info($"获取作业料框绑定点库区 {cntrarea}");
|
var start = db.Queryable<Location>().Where(it => it.S_CODE == a.S_START_LOC).First();
|
if (!string.IsNullOrEmpty(a.S_END_LOC))
|
{
|
LogHelper.Info($"作业终点有值 上锁");
|
result = db.Queryable<Location>().Where(it => it.S_CODE == a.S_END_LOC).First();
|
//这里可以作为提前上锁
|
//检查货位是否上过锁了 是否需要重新上锁
|
LocationHelper.LockLoc(a.S_END_LOC, 1);
|
}
|
else
|
{
|
//终点为空 选取终点库内位置
|
if (a.N_TYPE == 2)
|
{
|
if (Settings.ConnetAreas.Where(it => it.AreaCode == a.S_END_AREA).FirstOrDefault() == null)
|
{
|
LogHelper.Info($"作业终点不为接驳位 查找库区{a.S_END_AREA} 可用货位");
|
//其他库区
|
var endlist = db.Queryable<Location>()
|
.Where(it => it.S_AREA_CODE == a.S_END_AREA && it.N_CURRENT_NUM < it.N_CAPACITY)
|
.OrderBy(it => it.N_COL)
|
.PartitionBy(it => it.N_ROW)
|
.Take(1)
|
.ToList();
|
LogHelper.Info($"符合条件的数量{endlist.Count}");
|
foreach (var item in endlist)
|
{
|
var lockinfo = db.Queryable<Location>().Where(it => it.N_LOCK_STATE != 0 && it.S_AREA_CODE == item.S_AREA_CODE && it.N_ROW == item.N_ROW).First();
|
if (lockinfo == null)
|
{
|
result = item;
|
a.S_END_LOC = item.S_CODE;
|
break;
|
}
|
else LogHelper.Info($"货位{lockinfo.S_CODE} 有锁 当前排不可使用");
|
}
|
}
|
else
|
{
|
//终点为接驳区的任务
|
LogHelper.Info("作业终点为接驳区");
|
var ConnetInfo = Settings.ConnetAreas.Where(it => it.AreaCode == a.S_END_AREA && it.Station == a.S_STATION_LOC && (it.Roadway == start.N_ROADWAY || it.Roadway == 0)).ToList();
|
if (ConnetInfo.Count > 0)
|
{
|
LogHelper.Info($"获取接驳位配置数量 {ConnetInfo.Count}");
|
foreach (var item in ConnetInfo)
|
{
|
LogHelper.Info($"出库接驳位数量 {item.OutLocList.Length}");
|
//选取入库接驳位
|
for (int i = 0; i < item.OutLocList.Length; i++)
|
{
|
var endbit = item.OutLocList[i];
|
LogHelper.Info($"查询接驳位状态 {endbit}");
|
var connnet = db.Queryable<Location>().Where(it => it.S_CODE == endbit && it.N_LOCK_STATE == 0 && it.N_CURRENT_NUM == 0).First();
|
if (connnet != null)
|
{
|
result = connnet;
|
a.S_END_LOC = connnet.S_CODE;
|
return result;
|
}
|
}
|
}
|
}
|
else LogHelper.Info($"接驳位满足条件的配置为空");
|
}
|
}
|
else
|
{
|
LogHelper.Info($"入库任务 算取终点");
|
if (Settings.LKCodes.Where(it => it.LiKuCode == a.S_END_AREA).FirstOrDefault() != null)
|
{
|
LogHelper.Info($"入库任务 终点为立库");
|
var loctype = "";
|
var tp = a.S_CNTR_CODE.Substring(0, 2);
|
var type = Settings.LKCodes.Where(it => it.TrayPrefix == tp).FirstOrDefault();
|
if (type != null)
|
{
|
LogHelper.Info($"料框规格特殊 为{type.TrayType}");
|
loctype = type.TrayType;
|
}
|
else
|
{
|
LogHelper.Info($"该料框无特殊规格 不需区分高低货位");
|
}
|
|
if (a.S_END_AREA == "11TLKQ")
|
{
|
//托盘高度从物料表中获取
|
var itemList = db.Queryable<CntrItemRel>().Where(it => it.S_CNTR_CODE == a.S_CNTR_CODE).ToList();
|
foreach (var item in itemList)
|
{
|
var itemInfo = db.Queryable<TN_Material>().Where(it => it.S_ITEM_CODE == item.S_ITEM_CODE).First();
|
if (itemInfo != null)
|
{
|
loctype = itemInfo.S_HEIGHT;
|
if (loctype == "高货位")
|
{
|
break;
|
}
|
}
|
}
|
}
|
|
|
//终点为立库的任务
|
result = GetLiKuLocationIn(a.S_END_AREA, 0, loctype);
|
if (result != null)
|
{
|
a.S_END_LOC = result.S_CODE;
|
}
|
}
|
else
|
{
|
LogHelper.Info($"入库任务 终点不为立库");
|
//终点不为立库的任务
|
//其他库区
|
var endlist = db.Queryable<Location>()
|
.Where(it => it.S_AREA_CODE == a.S_END_AREA && it.N_CURRENT_NUM < it.N_CAPACITY)
|
.OrderBy(it => it.N_COL)
|
.PartitionBy(it => it.N_ROW)
|
.Take(1)
|
.ToList();
|
foreach (var item in endlist)
|
{
|
var lockinfo = db.Queryable<Location>().Where(it => it.N_LOCK_STATE != 0 && it.S_AREA_CODE == item.S_AREA_CODE && it.N_ROW == item.N_ROW).First();
|
if (lockinfo == null)
|
{
|
result = item;
|
a.S_END_LOC = result.S_CODE;
|
break;
|
}
|
}
|
}
|
}
|
if (string.IsNullOrEmpty(a.S_END_LOC))
|
{
|
LogHelper.Info("未找到可用终点货位");
|
return result;
|
}
|
}
|
|
if (a.N_TYPE == 2)
|
{
|
LogHelper.Info("判断是否需要二段任务");
|
//判断终点库区是否是接驳位 如果不是接驳位 需要二段任务
|
var IsSecondTask = Settings.ConnetAreas.Where(it => it.AreaCode == a.S_END_AREA).FirstOrDefault() == null;
|
if (IsSecondTask)
|
{
|
var IsConnet = Settings.ConnetAreas.Where(it => it.OutLocList.Contains(cntrinfo.S_LOC_CODE)).FirstOrDefault() == null;
|
if (IsConnet)
|
{
|
//查询起点是否在立库中 又或者起点是否在接驳区
|
var ConnetInfo = Settings.ConnetAreas.Where(it => (it.LiKuArea == a.S_START_AREA || it.AreaCode == a.S_START_AREA) && it.Station == a.S_STATION_LOC && (it.Roadway == start.N_ROADWAY || it.Roadway == 0)).ToList();
|
if (ConnetInfo.Count > 0)
|
{
|
Location connnet = null;
|
foreach (var item in ConnetInfo)
|
{
|
//选取出库接驳位
|
for (int i = 0; i < item.OutLocList.Length; i++)
|
{
|
var endbit = item.OutLocList[i];
|
connnet = db.Queryable<Location>().Where(it => it.S_CODE == endbit && it.N_LOCK_STATE == 0 && it.N_CURRENT_NUM == 0).First();
|
if (connnet != null)
|
{
|
result = connnet;
|
return result;
|
}
|
}
|
}
|
LogHelper.Info($"未找到可用接驳位");
|
result = connnet;
|
return result;
|
}
|
else
|
{
|
LogHelper.Info("未找到接驳位配置");
|
return null;
|
}
|
}
|
else LogHelper.Info("绑定位置在出库接驳位");
|
}
|
else LogHelper.Info("终点库区为接驳位 不需要二段任务");
|
|
}
|
else
|
{
|
LogHelper.Info($"判断是否需要二段任务");
|
if (Settings.LKCodes.Where(it => it.LiKuCode == result.S_AREA_CODE).FirstOrDefault() != null)
|
{
|
var IsConnet = Settings.ConnetAreas.Where(it => it.AreaCode == cntrarea).FirstOrDefault();
|
if (IsConnet == null)
|
{
|
LogHelper.Info($"起点不在入库接驳位上 寻找相应的入库接驳位");
|
var end = db.Queryable<Location>().Where(it => it.S_CODE == a.S_END_LOC).First();
|
//入库算法 查找终点是否在立库 校验托盘所在位置是否在接驳位 入库站台字段尚未确定 后续添加
|
var ConnetInfo = Settings.ConnetAreas.Where(it => it.LiKuArea == a.S_END_AREA && it.Station == a.S_STATION_LOC && (it.Roadway == end.N_ROADWAY || it.Roadway == 0)).ToList();
|
if (ConnetInfo.Count > 0)
|
{
|
LogHelper.Info($"获取接驳位配置数量 {ConnetInfo.Count}");
|
Location connnet = null;
|
foreach (var item in ConnetInfo)
|
{
|
LogHelper.Info($"入库接驳位数量 {item.InLocList.Length}");
|
//选取入库接驳位
|
for (int i = 0; i < item.InLocList.Length; i++)
|
{
|
var endbit = item.InLocList[i];
|
LogHelper.Info($"查询接驳位状态 {endbit}");
|
connnet = db.Queryable<Location>().Where(it => it.S_CODE == endbit && it.N_LOCK_STATE == 0 && it.N_CURRENT_NUM == 0).First();
|
if (connnet != null)
|
{
|
return connnet;
|
}
|
}
|
}
|
return connnet;
|
}
|
else
|
{
|
LogHelper.Info($"接驳位满足条件的配置为空");
|
return null;
|
}
|
}
|
else LogHelper.Info($"起点不为接驳位");
|
}
|
else LogHelper.Info("终点库区不为立库 不需要二段任务");
|
|
}
|
//}
|
//catch (Exception ex)
|
//{
|
// LogHelper.Error($"获取终点异常 异常信息={ex.Message}",ex);
|
//}
|
|
return result;
|
}
|
|
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);
|
var res=db.Updateable<WMSTask>(task).UpdateColumns(a => new { a.N_B_STATE, a.S_B_STATE, a.T_MODIFY }).ExecuteCommand()>0;
|
LogHelper.Info($"修改作业状态 作业号{task.S_CODE} 作业状态{task.N_B_STATE} 修改结果{res}");
|
}
|
|
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 =>
|
{
|
Expression<Func<CntrItemRel, bool>> expression = x => x.S_ITEM_CODE == a.S_ITEM_CODE;
|
expression.AndAlso(x => x.Cntr.C_ENABLE == "Y");
|
expression.AndAlso(x => (x.F_QTY - x.F_ALLOC_QTY) > (a.F_QTY - a.F_ACC_S_QTY));
|
expression.AndAlso(x => (x.F_QTY - x.F_ALLOC_QTY) / 2 < (a.F_QTY - a.F_ACC_S_QTY));
|
if (!string.IsNullOrEmpty(a.S_BATCH_NO)) expression.AndAlso(x => x.S_BATCH_NO == a.S_BATCH_NO);
|
if (!string.IsNullOrEmpty(a.S_FAC_CODE)) expression.AndAlso(x => x.S_OWNER == a.S_FAC_CODE);
|
if (!string.IsNullOrEmpty(a.S_ITEM_LOC)) expression.AndAlso(x => x.S_ERP_WH_CODE == a.S_ITEM_LOC);
|
|
|
|
|
|
var result = false;
|
var fjlist = db.Queryable<CntrItemRel>().Includes(c => c.Cntr)
|
.Where(expression)
|
.OrderBy(c => c.T_CREATE)
|
.ToList();
|
for (int i = 0; i < fjlist.Count; i++)
|
{
|
//检测这个托盘物料是否单一
|
var cir = fjlist[i];
|
var isfj = db.Queryable<SortingDetail>().Where(c => c.S_CNTR_CODE == cir.S_CNTR_CODE && c.C_REVERSE == "Y" && c.N_B_STATE < 2).First();
|
if (isfj == null)
|
{
|
var itemlist = db.Queryable<CntrItemRel>().Where(c => c.S_CNTR_CODE == cir.S_CNTR_CODE && c.F_QTY > 0).ToList();
|
if (itemlist.Count == 1)
|
{
|
result = true;
|
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,
|
S_FAC_CODE = a.S_FAC_CODE,
|
S_ITEM_LOC = a.S_ITEM_LOC,
|
F_QTY = (itemlist[0].F_QTY - itemlist[0].F_ALLOC_QTY) - (a.F_QTY - a.F_ACC_S_QTY),
|
C_REVERSE = "Y"
|
};
|
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 += a.F_QTY - a.F_ACC_S_QTY;
|
a.T_MODIFY = DateTime.Now;
|
db.Updateable(a).UpdateColumns(it => new { it.F_ACC_S_QTY, it.T_MODIFY }).ExecuteCommand();
|
var whi = db.Queryable<WHInventory>().Where(it => it.S_ITEM_CODE == a.S_ITEM_CODE).First();
|
if (whi != null)
|
{
|
whi.F_ALLOC_QTY += a.F_QTY - a.F_ACC_S_QTY;
|
whi.T_MODIFY = DateTime.Now;
|
db.Updateable(whi).UpdateColumns(it => new { it.F_ALLOC_QTY, it.T_MODIFY }).ExecuteCommand();
|
}
|
break;
|
}
|
}
|
|
}
|
|
|
Expression<Func<CntrItemRel, bool>> expression1 = x => x.S_ITEM_CODE == a.S_ITEM_CODE;
|
expression1.AndAlso(x => x.Cntr.C_ENABLE == "Y");
|
expression1.AndAlso(x => (x.F_QTY - x.F_ALLOC_QTY) > 0);
|
if (!string.IsNullOrEmpty(a.S_BATCH_NO)) expression1.AndAlso(x => x.S_BATCH_NO == a.S_BATCH_NO);
|
if (!string.IsNullOrEmpty(a.S_FAC_CODE)) expression1.AndAlso(x => x.S_OWNER == a.S_FAC_CODE);
|
if (!string.IsNullOrEmpty(a.S_ITEM_LOC)) expression1.AndAlso(x => x.S_ERP_WH_CODE == a.S_ITEM_LOC);
|
|
if (!result)
|
{
|
|
//按分拣单子表去配货，查找可用托盘(先查所有符合的，后面再优化)
|
var cirList = db.Queryable<CntrItemRel>().Includes(c => c.Cntr)
|
.Where(expression1)
|
.OrderBy(c => c.T_CREATE)
|
.ToList();
|
for (int i = 0; i < cirList.Count; i++)
|
{
|
var cir = cirList[i];
|
var isfj = db.Queryable<SortingDetail>().Where(c => c.S_CNTR_CODE == cir.S_CNTR_CODE && c.C_REVERSE == "Y" && c.N_B_STATE < 2).First();
|
if (isfj == null)
|
{
|
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_FAC_CODE = a.S_FAC_CODE,
|
S_ITEM_LOC = a.S_ITEM_LOC,
|
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(a).UpdateColumns(it => new { it.F_ACC_S_QTY, it.T_MODIFY }).ExecuteCommand();
|
var whi = db.Queryable<WHInventory>().Where(it => it.S_ITEM_CODE == a.S_ITEM_CODE).First();
|
if (whi != null)
|
{
|
whi.F_ALLOC_QTY += sd.F_QTY;
|
whi.T_MODIFY = DateTime.Now;
|
db.Updateable(whi).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<TN_Distribution_CNTR> GetWaitingSortingOperationList()
|
{
|
var db = new SqlHelper<object>().GetInstance();
|
return db.Queryable<TN_Distribution_CNTR>().Where(a => a.N_B_STATE == 1 && a.S_BS_TYPE != "人工库出库" && a.S_SORT_TYPE != "未分类").OrderBy(a => a.T_CREATE).OrderByDescending(a => a.N_PRIORITY).ToList();
|
}
|
|
internal static List<PlanInventory> GetWaitingPlanInventoryList()
|
{
|
var db = new SqlHelper<object>().GetInstance();
|
return db.Queryable<PlanInventory>().Where(a => a.N_B_STATE == 0 || a.N_B_STATE == 3).OrderBy(a => a.T_CREATE).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 area = db.Queryable<Location>().Where(c => c.S_CODE == lcr.S_LOC_CODE).First();
|
if (area != null)
|
{
|
if (Settings.LKCodes.Where(it => it.LiKuCode == area.S_AREA_CODE).FirstOrDefault() != 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_TYPE = so.S_TYPE,
|
S_OP_DEF_CODE = "",
|
S_OP_DEF_NAME = so.S_TYPE
|
};
|
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 =>
|
{
|
Expression<Func<SortingDetail, bool>> expression = x => x.S_ITEM_CODE == a.itemCode;
|
if (!string.IsNullOrEmpty(a.batchNo)) expression.AndAlso(x => x.S_BATCH_NO == a.batchNo);
|
if (!string.IsNullOrEmpty(a.factoryCode)) expression.AndAlso(x => x.S_FAC_CODE == a.factoryCode);
|
if (!string.IsNullOrEmpty(a.stockLocation)) expression.AndAlso(x => x.S_ITEM_LOC == a.stockLocation);
|
|
//根据条目修改累计分拣数量，添加分拣结果表，同时批分到发货单中
|
var sd = sdList.Where(expression.Compile()).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 = a.sortNo,
|
F_QTY = a.qty,
|
N_ROW_NO = sd.N_ROW_NO,
|
S_ITEM_CODE = sd.S_ITEM_CODE,
|
S_ITEM_NAME = sd.S_ITEM_NAME,
|
S_BATCH_NO = sd.S_BATCH_NO,
|
S_FAC_CODE = sd.S_FAC_CODE,
|
S_ITEM_LOC = sd.S_ITEM_LOC,
|
S_CNTR_CODE = a.cntrCode,
|
C_REVERSE = sd.C_REVERSE,
|
S_DEST_CNTR_CODE = a.targetcntrCode
|
};
|
db.Insertable(sdr).ExecuteCommand();
|
|
//反拣对于备货托盘进行锁定
|
if (sdr.C_REVERSE == "Y")
|
{
|
db.Updateable<Container>().SetColumns(it => new Container { C_ENABLE = "N" }).Where(it => it.S_CODE == a.cntrCode).ExecuteCommand();
|
}
|
else
|
{
|
db.Updateable<Container>().SetColumns(it => new Container { C_ENABLE = "N" }).Where(it => it.S_CODE == a.targetcntrCode).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();
|
//批分到发货单中
|
|
Expression<Func<CntrItemRel, bool>> expression1 = x => x.S_ITEM_CODE == a.itemCode;
|
expression1.AndAlso(x => x.S_CNTR_CODE == a.cntrCode);
|
if (!string.IsNullOrEmpty(a.batchNo)) expression1.AndAlso(x => x.S_BATCH_NO == a.batchNo);
|
if (!string.IsNullOrEmpty(a.factoryCode)) expression1.AndAlso(x => x.S_OWNER == a.factoryCode);
|
if (!string.IsNullOrEmpty(a.stockLocation)) expression1.AndAlso(x => x.S_ERP_WH_CODE == a.stockLocation);
|
|
//更新托盘明细表
|
var cir = db.Queryable<CntrItemRel>()
|
.Where(expression1).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();
|
|
|
Expression<Func<CntrItemRel, bool>> expression2 = x => x.S_ITEM_CODE == a.itemCode;
|
expression2.AndAlso(x => x.S_CNTR_CODE == a.targetcntrCode);
|
if (!string.IsNullOrEmpty(a.batchNo)) expression2.AndAlso(x => x.S_BATCH_NO == a.batchNo);
|
if (!string.IsNullOrEmpty(a.factoryCode)) expression2.AndAlso(x => x.S_OWNER == a.factoryCode);
|
if (!string.IsNullOrEmpty(a.stockLocation)) expression2.AndAlso(x => x.S_ERP_WH_CODE == a.stockLocation);
|
var cir1 = db.Queryable<CntrItemRel>()
|
.Where(expression2)
|
.First();
|
if (cir1 != null)
|
{
|
cir1.F_QTY += a.qty;
|
cir1.T_MODIFY = DateTime.Now;
|
db.Updateable(cir).UpdateColumns(it => new { it.F_QTY, it.T_MODIFY }).ExecuteCommand();
|
}
|
else
|
{
|
CntrItemRel item = new CntrItemRel
|
{
|
S_CNTR_CODE = a.targetcntrCode,
|
S_ITEM_CODE = a.itemCode,
|
S_BATCH_NO = a.batchNo,
|
S_OWNER = a.factoryCode,
|
S_ERP_WH_CODE = a.stockLocation,
|
F_QTY = a.qty,
|
T_MODIFY = DateTime.Now
|
};
|
db.Insertable(item).ExecuteCommand();
|
}
|
|
if (sdr.C_REVERSE == "Y")
|
{
|
a.qty = cir.F_QTY;
|
}
|
|
|
//更新仓库量表和库区量表
|
//查询仓库量表
|
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();
|
}
|
|
|
Expression<Func<ShippingDetail, bool>> expression3 = x => x.S_ITEM_CODE == a.itemCode;
|
expression3.AndAlso(x => (x.F_QTY - x.F_ACC_S_QTY) > 0);
|
if (!string.IsNullOrEmpty(a.batchNo)) expression3.AndAlso(x => x.S_BATCH_NO == a.batchNo);
|
if (!string.IsNullOrEmpty(a.factoryCode)) expression3.AndAlso(x => x.S_FAC_CODE == a.factoryCode);
|
if (!string.IsNullOrEmpty(a.stockLocation)) expression3.AndAlso(x => x.S_ITEM_LOC == a.stockLocation);
|
//分拣明细生成时 应该与发货单明细对应
|
var dList = soList.SelectMany(s => s.Details)
|
.Where(expression3.Compile())
|
.ToList();
|
var qty = a.qty;
|
for (int i = 0; i < dList.Count; i++)
|
{
|
var d = dList[i];
|
//发货信息中间表
|
//var dyo = new DayuanOut
|
//{
|
// CN_S_BATCH_NO = sd.S_BATCH_NO,
|
// CN_S_ITEM_CODE = sd.S_ITEM_CODE,
|
// CN_S_OUT_NO = d.S_SHIPPING_NO,
|
//
|
//};
|
if (d.F_QTY - d.F_ACC_S_QTY >= a.qty)
|
{
|
//发货单数量超过托盘分拣数量，批分qty
|
d.F_ACC_S_QTY += a.qty;
|
//dyo.CN_F_QUANTITY = a.qty;
|
qty = 0;
|
}
|
else
|
{
|
// 发货单数量小于托盘分拣数量
|
d.F_ACC_S_QTY = d.F_QTY;
|
qty -= (d.F_QTY - d.F_ACC_S_QTY);
|
//dyo.CN_F_QUANTITY = 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();
|
//插入到大元出库中间表
|
//db.Insertable(dyo).ExecuteCommand();
|
if (qty == 0)
|
{
|
break;
|
}
|
|
}
|
|
//麻烦了，分拣明细只记托盘，不记住起点，如果要统计库区量表，必须对托盘加标记，记录托盘的来源库区，托盘清空后再清除标记
|
|
//逻辑库区更不需要量表了，因为从一个逻辑库区出来，可能回其它逻辑库区，那就应该直接删除逻辑库区量表，后面再加到别的逻辑库区中
|
//但是会带来新的问题，就是分拣回的托盘不属于任何逻辑库区的量，只有回库了才能计算到
|
|
//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();
|
}
|
}
|
}
|
|
/// <summary>
|
/// 立库入库算法
|
/// </summary>
|
/// <param name="endArea"></param>
|
/// <param name="roadway"></param>
|
/// <returns></returns>
|
internal static Location GetLiKuLocationIn(string endArea, int roadway, string loctype = "", string IsLong = "0")
|
{
|
LogHelper.Info($"入库算法开始 终点库区={endArea} 巷道={roadway} 货位类型={loctype}");
|
Location endbit = null;
|
var res = false;
|
var loclist = new List<Location>();
|
var newendbitlist = new List<summodel>();
|
var db = new SqlHelper<object>().GetInstance();
|
//var endbitlist = new List<>();
|
//var ebitlist = new List<Location>();
|
//var endbitlist = db.Queryable<Location>()
|
// .Where(a => a.S_AREA_CODE == endArea && a.IsDouble == isDouble)
|
// .PartitionBy(a => a.N_ROADWAY)
|
// .Select(a => new { sum = SqlFunc.AggregateSum(a.N_CURRENT_NUM), ROADWAY = a.N_ROADWAY })
|
// .MergeTable()
|
// .OrderBy(a => a.sum)
|
// .ToList();
|
|
if (roadway == 0)
|
{
|
var endbitlist = db.Queryable<Location>()
|
.Where(a => a.S_AREA_CODE == endArea)
|
.Select(a => new { sum = SqlFunc.AggregateSum(a.N_CURRENT_NUM), a.N_ROADWAY })
|
//.PartitionBy(a => a.N_ROADWAY)
|
.GroupBy(a => a.N_ROADWAY)
|
.MergeTable()
|
.OrderBy(a => a.sum)
|
.ToList();
|
LogHelper.Info($"获取各个巷道数据 巷道数量={endbitlist.Count()}");
|
|
endbitlist.ForEach(a =>
|
{
|
//查找入库锁数量 加上去
|
var loc = db.Queryable<Location>()
|
.Where(it => it.S_AREA_CODE == endArea && it.N_ROADWAY == a.N_ROADWAY && it.N_LOCK_STATE == 1)
|
.ToList();
|
newendbitlist.Add(new summodel { sum = a.sum, roadway = a.N_ROADWAY, locksum = loc.Count });
|
});
|
|
newendbitlist = newendbitlist.OrderBy(a => a.sum).ToList();
|
newendbitlist = newendbitlist.OrderBy(a => a.locksum).ToList();
|
|
LogHelper.Info($"整合后数据 巷道数量={newendbitlist.Count()}");
|
foreach (var item in newendbitlist)
|
{
|
var roadwayInfo = db.Queryable<DuiDuoPeiz>().Where(a => a.S_AREA_CODE == endArea && a.N_LANE == item.roadway && a.N_STATE == 1).First();
|
if (roadwayInfo != null)
|
{
|
LogHelper.Info($"获取堆垛机状态 库区{endArea} 巷道{item.roadway} 状态{roadwayInfo.N_STATE}");
|
//if (DuiDuoBool(item.roadway))
|
//{
|
var exp = Expressionable.Create<Location>();
|
exp.And(a => a.S_AREA_CODE == endArea);
|
exp.And(a => a.N_ROADWAY == item.roadway);
|
exp.And(a => a.N_CURRENT_NUM == 0);
|
exp.And(a => a.N_LOCK_STATE == 0);
|
exp.AndIF(!string.IsNullOrEmpty(loctype), a => a.S_TYPE == loctype);
|
|
res = true;
|
if (IsLong == "0")
|
{
|
loclist = db.Queryable<Location>()
|
.Where(exp.ToExpression())
|
.OrderByDescending(it => new { N_LAYER = SqlFunc.Asc(it.N_LAYER), N_COL = SqlFunc.Asc(it.N_COL) })
|
.ToList();
|
//loclist = db.Queryable<Location>()
|
// .Where(exp.ToExpression())
|
// .OrderByDescending(it => new { N_ROW = SqlFunc.Asc(it.N_ROW), N_COL = SqlFunc.Asc(it.N_COL), N_LAYER = SqlFunc.Asc(it.N_LAYER)})
|
// .ToList();
|
}
|
else
|
{
|
loclist = db.Queryable<Location>()
|
.Where(exp.ToExpression())
|
.OrderByDescending(it => new { N_LAYER = SqlFunc.Asc(it.N_LAYER), N_COL = SqlFunc.Desc(it.N_COL) })
|
.ToList();
|
//loclist = db.Queryable<Location>()
|
// .Where(exp.ToExpression())
|
// .OrderByDescending(it => new { N_ROW = SqlFunc.Asc(it.N_ROW), N_COL = SqlFunc.Desc(it.N_COL), N_LAYER = SqlFunc.Asc(it.N_LAYER) })
|
// .ToList();
|
}
|
LogHelper.Info($"获取可用货位数量={loclist.Count}");
|
if (loclist.Count > 0)
|
{
|
endbit = loclist[0];
|
break;
|
}
|
}
|
else
|
{
|
LogHelper.Info($"巷道{item.roadway} 堆垛机无法使用");
|
}
|
}
|
}
|
else
|
{
|
var roadwayInfo = db.Queryable<DuiDuoPeiz>().Where(a => a.S_AREA_CODE == endArea && a.N_LANE == roadway && a.N_STATE == 1).First();
|
if (roadwayInfo != null)
|
{
|
LogHelper.Info($"获取堆垛机状态 库区{endArea} 巷道{roadway} 状态{roadwayInfo.N_STATE}");
|
|
var exp = Expressionable.Create<Location>();
|
exp.And(a => a.S_AREA_CODE == endArea);
|
exp.And(a => a.N_ROADWAY == roadway);
|
exp.And(a => a.N_CURRENT_NUM == 0);
|
exp.And(a => a.N_LOCK_STATE == 0);
|
exp.AndIF(!string.IsNullOrEmpty(loctype), a => a.S_TYPE == loctype);
|
//if (DuiDuoBool(int.Parse(roadway)))
|
//{
|
if (IsLong == "0")
|
{
|
//loclist = db.Queryable<Location>()
|
// .Where(exp.ToExpression())
|
// .OrderByDescending(it => new { N_ROW = SqlFunc.Asc(it.N_ROW), N_COL = SqlFunc.Asc(it.N_COL), N_LAYER = SqlFunc.Asc(it.N_LAYER) })
|
// .ToList();
|
loclist = db.Queryable<Location>()
|
.Where(exp.ToExpression())
|
.OrderByDescending(it => new { N_LAYER = SqlFunc.Asc(it.N_LAYER), N_COL = SqlFunc.Asc(it.N_COL) })
|
.ToList();
|
}
|
else
|
{
|
loclist = db.Queryable<Location>()
|
.Where(exp.ToExpression())
|
.OrderByDescending(it => new { N_LAYER = SqlFunc.Asc(it.N_LAYER), N_COL = SqlFunc.Desc(it.N_COL) })
|
.ToList();
|
//loclist = db.Queryable<Location>()
|
//.Where(exp.ToExpression())
|
//.OrderByDescending(it => new { N_ROW = SqlFunc.Asc(it.N_ROW), N_COL = SqlFunc.Desc(it.N_COL), N_LAYER = SqlFunc.Asc(it.N_LAYER) })
|
//.ToList();
|
}
|
if (loclist.Count > 0)
|
{
|
endbit = loclist[0];
|
}
|
}
|
else
|
{
|
LogHelper.Info($"巷道{roadway} 堆垛机无法使用");
|
}
|
|
//}
|
//else
|
//{
|
// msg = $"巷道{roadway} 对应堆垛机不可用";
|
// return endbit;
|
//}
|
}
|
LogHelper.Info($"入库算法结束 结果{endbit != null}");
|
|
return endbit;
|
}
|
|
public class summodel
|
{
|
public int sum { get; set; }
|
public int locksum { get; set; }
|
public int roadway { get; set; }
|
}
|
|
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<CntrItemRel>().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;
|
}
|
}
|
}
|
