using HH.WCS.Mobox3.HD.api;
using HH.WCS.Mobox3.HD.core;
using HH.WCS.Mobox3.HD.device;
using HH.WCS.Mobox3.HD.dispatch;
using HH.WCS.Mobox3.HD.models;
using HH.WCS.Mobox3.HD.util;
using HH.WCS.Mobox3.HD.wms;
using Newtonsoft.Json;
using NLog.Fluent;
using S7.Net;
using SqlSugar;
using System;
using System.Collections.Generic;
using System.IO.Ports;
using System.Linq;
using System.Reflection;
using System.Reflection.Emit;
using System.Security.Cryptography;
using static HH.WCS.Mobox3.HD.api.DigitHelper;
using static HH.WCS.Mobox3.HD.api.WmsController;
using static HH.WCS.Mobox3.HD.core.Monitor;
using static HH.WCS.Mobox3.HD.dispatch.ShopFloorControl;
using static HH.WCS.Mobox3.HD.process.TaskProcess;
using static HH.WCS.Mobox3.HD.util.Settings;
using static HH.WCS.Mobox3.HD.wms.WCSHelper;
using static System.Runtime.CompilerServices.RuntimeHelpers;
namespace HH.WCS.Mobox3.HD.process {
internal class TaskProcess {
#region 任务相关
//--------------------------------------------------任务相关--------------------------------------------------
///
/// 取货卸货完成,缓存位状态更新
///
///
///
internal static void CacheBitUpdate(WCSTask mst, bool load) {
var trayCarryCount = mst.N_CNTR_COUNT > 0 ? mst.N_CNTR_COUNT : 1;
if (load) {
Console.WriteLine($"任务{mst.S_CODE} 货位{mst.S_START_LOC}取货完成,起点解绑容器{mst.S_CNTR_CODE}");
LogHelper.Info($"任务{mst.S_CODE} 货位{mst.S_START_LOC}取货完成,起点解绑容器{mst.S_CNTR_CODE}");
LocationHelper.UnBindingLoc(mst.S_START_LOC, mst.S_CNTR_CODE.Split(',').ToList());
}
else {
Console.WriteLine($"任务{mst.S_CODE} 货位{mst.S_END_LOC}卸货完成,终点绑定容器{mst.S_CNTR_CODE}");
LogHelper.Info($"任务{mst.S_CODE} 货位{mst.S_END_LOC}卸货完成,起点解绑容器{mst.S_CNTR_CODE}");
LocationHelper.BindingLoc(mst.S_END_LOC, mst.S_CNTR_CODE.Split(',').ToList());
}
}
///
/// 任务取消,缓存位状态更新
///
///
internal static void CacheBitCancelUpdate(WCSTask mst) {
//任务取消,取货完成前的,起点的loadingCount和终点unLoadingCount都清除,取货完成的只处理终点
if (WCSHelper.CheckActionRecordExist(mst.S_CODE, 4)) {
//根据客户现场要求,如果取货完成任务失败人工拉到终点,我们就当卸货完成处理;如果是人工拉走到其它区域,我们就解锁终点,删除托盘。
//终点绑定
CacheBitUpdate(mst, false);
LocationHelper.UnLockLoc(mst.S_END_LOC);
}
else {
//起点终点解锁
LocationHelper.UnLockLoc(mst.S_START_LOC);
LocationHelper.UnLockLoc(mst.S_END_LOC);
//货位容器解绑
LocationHelper.UnBindingLoc(mst.S_START_LOC, new List { mst.S_CNTR_CODE });
}
}
///
/// 安全请求
///
///
///
///
///
internal static void OperateReq(string no, int state, string forkliftNo, string extData) {
if (state == 1101) {
//请求取货,
}
if (state == 1102) {
//请求卸货,
//根据终点判断,是cb02的入口,判断内存中状态(要状态时间),允许卸货,通知agv改参数
var dic = new Dictionary();
//< Req >< Order No = 'TN2302020002' ParamNo = '18' Param1 = '12' /> Req >
dic.Add("No", no);
dic.Add("ParamNo", "8");
dic.Add("Param1", "1");
NDC.ChangeOrder(dic);
//改完参数车子就会自己卸货
}
if (state == 1103) {
//大铁框叉走以后通知,我们要通知输送线
}
}
///
/// 任务拦截
///
///
///
internal static bool Intercept(WCSTask mst) {
var result = true;
if (! mst.S_TYPE.Equals("移库")) {
List wcsTasks = WCSHelper.GetTaskListBySrcNo(mst.S_OP_CODE);
foreach (var task in wcsTasks)
{
if (task.N_PRIORITY == 9 && task.N_B_STATE < 3)
{
result = false;
}
}
}
return result;
}
///
/// 任务状态更新处理
///
///
///
internal static void OperateStatus(WCSTask mst, int state) {
if (state == 4) {
CacheBitUpdate(mst, true);
}
if (state == 6)//卸货完成
{
CacheBitUpdate(mst, false);
}
if (state == 7) {
CacheBitCancelUpdate(mst);
}
}
private static object locLocker = new object();
///
/// 堆叠库区出入库任务申请
///
///
///
///
///
///
///
///
///
internal static bool ApplyTN_Task(Location ls, ref List cntrs, string area, string itemCode, string itemBatch, string taskType, bool insStock = true) {
var result = false;
lock (locLocker) {
try {
if (insStock) {
Console.WriteLine($"MoboxHelperCreateTask: {area}-{itemCode}-{itemBatch}-{taskType}");
var endTN_Location = GetLocation4In(area, itemCode, itemBatch, 3);
if (endTN_Location != null) {
var endLayer = endTN_Location.N_CURRENT_NUM == 0 ? 1 : 2;
var taskNo = DateTime.Now.Ticks.ToString();
result = TaskProcess.CreateTransport(ls.S_CODE, endTN_Location.S_CODE, taskType, cntrs, 1, endLayer, 3, 70);
}
else {
Console.WriteLine($"MoboxHelperCreateTask: 未找到终点货位");
}
}
else {
var startTN_Location = GetLocation4Out(area, itemCode, itemBatch, 3);
if (startTN_Location != null) {
var startLayer = startTN_Location.N_CURRENT_NUM <= 3 ? 1 : 2;
var taskNo = DateTime.Now.Ticks.ToString();
var carryCount = startTN_Location.N_CURRENT_NUM > 3 ? startTN_Location.N_CURRENT_NUM - 3 : startTN_Location.N_CURRENT_NUM;
//出库要从起点获取托盘
var cntrList = LocationHelper.GetLocCntr(startTN_Location.S_CODE);
if (cntrList.Count == startTN_Location.N_CURRENT_NUM) {
cntrs = cntrList.OrderByDescending(a => a.T_CREATE).Take(carryCount).Select(a => a.S_CNTR_CODE).ToList();
result = TaskProcess.CreateTransport(startTN_Location.S_CODE, ls.S_CODE, taskType, cntrs, startLayer, 1, carryCount, 65);
}
else {
Console.WriteLine($"起点托盘数量和货位容器表不符合,请检查【货位表】和【货位容器表】");
}
}
}
}
catch (Exception ex) {
Console.WriteLine("MoboxHelperCreateTask:" + ex.Message);
LogHelper.Error("MoboxHelperCreateTask:" + ex.Message, ex);
}
}
return result;
}
private static Location GetLocation4Out(string area, string itemCode, string itemBatch, int v) {
throw new NotImplementedException();
}
private static Location GetLocation4In(string area, string itemCode, string itemBatch, int v) {
throw new NotImplementedException();
}
///
/// 普通货架区的出入库申请
///
///
///
///
///
///
///
///
internal static bool ApplyNormalTN_Task(Location ls, ref List cntrs, string area, string taskType, string itemCode, bool insStock = true) {
var result = false;
lock (locLocker) {
try {
if (insStock) {
Console.WriteLine($"MoboxHelperCreateTask: {area}-{taskType}");
var endTN_Location = new Location();
if (endTN_Location != null) {
var taskNo = DateTime.Now.Ticks.ToString();
result = TaskProcess.CreateTransport(ls.S_CODE, endTN_Location.S_CODE, taskType, cntrs, 70);
}
else {
Console.WriteLine($"MoboxHelperCreateTask: 未找到终点货位");
}
}
else {
var startTN_Location = new Location();
if (startTN_Location != null) {
//出库要从起点获取托盘
var cntrList = LocationHelper.GetLocCntr(startTN_Location.S_CODE);
if (cntrList.Count == startTN_Location.N_CURRENT_NUM) {
result = TaskProcess.CreateTransport(startTN_Location.S_CODE, ls.S_CODE, taskType, new List { cntrList[0].S_CNTR_CODE }, 65);
}
else {
Console.WriteLine($"起点托盘数量和货位容器表不符合,请检查【货位表】和【货位容器表】");
}
}
}
}
catch (Exception ex) {
Console.WriteLine("MoboxHelperCreateTask:" + ex.Message);
LogHelper.Error("MoboxHelperCreateTask:" + ex.Message, ex);
}
}
return result;
}
///
/// 推送任务
///
///
internal static bool SendTask(WCSTask mst) {
var result = true;
var startLoc = LocationHelper.GetLocation(mst.S_START_LOC);
var endLoc = LocationHelper.GetLocation(mst.S_END_LOC);
if (mst.N_B_STATE == 0) {
if (mst.S_SCHEDULE_TYPE == "RB")
{
var itemOutLoc = getOutLocation(mst.S_START_LOC);
var itemInLoc = getOutLocation(mst.S_END_LOC);
if (itemOutLoc != null && itemOutLoc.N_CURRENT_NUM > 0)
{
if (itemOutLoc.N_LOCK_STATE == 0) {
ApiHelper.shiftStock(itemOutLoc, mst.S_OP_CODE);
}
}
else if(itemInLoc != null && itemInLoc.N_CURRENT_NUM > 0)
{
if (itemInLoc.N_LOCK_STATE == 0)
{
ApiHelper.shiftStock(itemInLoc, mst.S_OP_CODE);
}
}
else
{
// 发送堆垛机任务数据
LogHelper.Info("推送堆垛机任务,任务号:" + mst.S_CODE, "哈电");
if (sendDDJTaskData(mst))
{
mst.N_B_STATE = 1;
WCSHelper.UpdateStatus(mst);
}
}
}
else if (mst.S_SCHEDULE_TYPE == "HA")
{
//调第三方接口
var model = new HanAo.TaskInfoModel
{
requestPk = mst.S_CODE,
frmPos = mst.S_START_LOC,
toPos = mst.S_END_LOC,
trkType = mst.S_OP_NAME == "入库" ? "1" : "2",
contNo = mst.S_CNTR_CODE
};
if (HanAo.CreateOrder(model))
{
mst.N_B_STATE = 1;
WCSHelper.UpdateStatus(mst);
}
}
else if (mst.S_SCHEDULE_TYPE == "HL" && endLoc != null)
{
var model = new HL.TaskInfoModel
{
orderId = mst.S_CODE,
operateType = mst.S_OP_NAME == "入库" ? "10" : "20",
trayCode = mst.S_CNTR_CODE,
fetchPosition = startLoc.S_CODE,
fetchLevel = startLoc.N_LAYER.ToString(),
deliverPosition = endLoc.S_CODE,
deliverLevel = endLoc.N_LAYER.ToString(),
priority = mst.N_PRIORITY.ToString(),
source = "wms",
};
if (mst.S_TYPE.Contains("钢卷")) {
var cntrItemRels = ItemHelper.GetCntrItemByCntrCode(mst.S_CNTR_CODE);
model.coilNo = cntrItemRels[0].S_COIL_NO;
model.shootNo = cntrItemRels[0].S_SHOOT_NO;
model.heatNo = cntrItemRels[0].S_HEAT_NO;
model.spec = cntrItemRels[0].S_ITEM_SPEC;
}
else if (mst.S_TYPE.Contains("模具"))
{
var mouldCntr = MouldHelper.GetMouldCntr(new models.MouldCntr() { S_CNTR_CODE = mst.S_CNTR_CODE });
model.mouldTyep = mouldCntr.S_MOULD_TYPE;
model.mouldNo = mouldCntr.S_MOULD_NO;
}
if (HL.CreateOrder(model))
{
mst.N_B_STATE = 1;
WCSHelper.UpdateStatus(mst);
}
} else if (mst.S_SCHEDULE_TYPE == "LD") {
TransferTiledInfo transferTiledInfo = new TransferTiledInfo()
{
businessType = "station_to_station",
comment = mst.S_TYPE,
endStationCode = mst.S_END_LOC,
endAreaCode = mst.S_END_AREA,
startStationCode = mst.S_START_LOC,
startAreaCode = mst.S_START_AREA
};
var cntrItems = ItemHelper.GetCntrItemByCntrCode(mst.S_CNTR_CODE);
if (cntrItems != null && cntrItems.Count > 0) {
transferTiledInfo.workCode = cntrItems[0].S_WORK_NO;
transferTiledInfo.setCode = cntrItems[0].S_DEPART_NO;
transferTiledInfo.partDrawingCode = cntrItems[0].S_PARTDRAW_NO;
transferTiledInfo.processCode = cntrItems[0].S_OPER_NO;
}
// 物流调度 TODO logisticsTaskId != null
string logisticsTaskId = ShopFloorControl.transferTiled(transferTiledInfo);
if (logisticsTaskId != null)
{
WMSTask wmsTask = WMSHelper.GetWmsTask(mst.S_OP_CODE);
wmsTask.S_OP_DEF_CODE = logisticsTaskId;
WMSHelper.UpdateTask(wmsTask);
mst.N_B_STATE = 1;
WCSHelper.UpdateStatus(mst);
};
}
}
return result;
}
public static Location getOutLocation(string locCode) {
var db = new SqlHelper