using HH.WCS.HangYang.dispatch;
|
using HH.WCS.HangYang.process;
|
using HH.WCS.HangYang.util;
|
using HH.WCS.HangYang.wms;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using static HH.WCS.HangYang.api.ApiModel;
|
|
namespace HH.WCS.HangYang.core
|
{
|
internal class WCSCore
|
{
|
public static void OperateAgvTaskStatus(AgvTaskState model)
|
{
|
var TN_Task = WCSHelper.GetTask(model.No);
|
if (TN_Task != null)
|
{
|
if (model.State <= 7)
|
{
|
|
//有任务号请求
|
switch (model.State)
|
{
|
case 1:
|
WCSHelper.Begin(TN_Task);
|
break;
|
#region MyRegion
|
case 3:
|
WCSHelper.UpdateStatus(TN_Task, "开始取货");
|
break;
|
case 4:
|
WCSHelper.UpdateStatus(TN_Task, "取货完成");
|
TaskProcess.OperateStatus(TN_Task, 4);
|
break;
|
case 5:
|
WCSHelper.UpdateStatus(TN_Task, "开始卸货");
|
break;
|
case 6:
|
WCSHelper.UpdateStatus(TN_Task, "卸货完成");
|
TaskProcess.OperateStatus(TN_Task, 6);
|
break;
|
#endregion
|
case 2:
|
WCSHelper.End(TN_Task);
|
//根据任务类型更新作业状态和终点
|
var taskList = Settings.CompleteTasks;
|
if (taskList.taskType.Contains(TN_Task.S_TYPE))
|
{
|
//完成作业
|
WMSHelper.UpdateWmsTask(TN_Task, 3);
|
}
|
WMSHelper.AddChange(TN_Task);
|
WMSHelper.DeleteChange(TN_Task);
|
break;
|
case 7:
|
TaskProcess.OperateStatus(TN_Task, 7);
|
WCSHelper.Fail(TN_Task);
|
break;
|
}
|
WCSHelper.AddActionRecord(model.No, model.State, model.ForkliftNo, model.ExtData);
|
|
}
|
|
}
|
}
|
|
/// <summary>
|
/// 任务分发，根据调度类型发给不同的调度系统
|
/// </summary>
|
internal static void Dispatch()
|
{
|
//查询任务
|
//获取所有等待的任务
|
var list = WCSHelper.GetTaskListByState("等待"); ;
|
if (list.Count > 0)
|
{
|
list.ForEach(task =>
|
{
|
//使用自定义任务推送
|
TaskProcess.SendGZTask(task);
|
});
|
}
|
}
|
|
|
#region 杭氧任务服务
|
/// <summary>
|
/// 循环作业生成任务
|
/// </summary>
|
internal static void ExecuteJob()
|
{
|
try
|
{
|
//查询任务
|
//获取所有等待的作业
|
var list = WMSHelper.GetWmsTaskListByState("等待"); ;
|
if (list.Count > 0)
|
{
|
|
list.ForEach(task =>
|
{
|
//生成入库任务
|
TaskProcess.CreateInTask(task);
|
});
|
}
|
}
|
catch (Exception ex)
|
{
|
var st = new System.Diagnostics.StackTrace(ex, true);
|
var frame = st.GetFrame(0); // 获取第一个堆栈帧
|
if (frame != null)
|
{
|
LogHelper.Error($"CreateInTask获取作业创建入库任务出现错误！！", ex);
|
LogHelper.Error($"文件名: {frame.GetFileName()}", ex);
|
LogHelper.Error($"行号: {frame.GetFileLineNumber()}", ex);
|
LogHelper.Error($"列号: {frame.GetFileColumnNumber()}", ex);
|
}
|
}
|
|
}
|
|
|
/// <summary>
|
/// 循环接驳位生成入库任务
|
/// </summary>
|
private static readonly object _inventoryLock = new object();
|
internal static void ProcessZoneInventoryCycle()
|
{
|
try
|
{
|
lock (_inventoryLock) // 加锁确保同一时间只有一个线程执行
|
{
|
//循环入库暂存区生成合托或入库任务
|
TaskProcess.BatchInWork();
|
}
|
}
|
catch (Exception ex)
|
{
|
var st = new System.Diagnostics.StackTrace(ex, true);
|
var frame = st.GetFrame(0); // 获取第一个堆栈帧
|
if (frame != null)
|
{
|
LogHelper.Error($"循环接驳位生成入库任务！！", ex);
|
LogHelper.Error($"文件名: {frame.GetFileName()}", ex);
|
LogHelper.Error($"行号: {frame.GetFileLineNumber()}", ex);
|
LogHelper.Error($"列号: {frame.GetFileColumnNumber()}", ex);
|
}
|
}
|
|
}
|
|
/// <summary>
|
/// 根据配盘单生成出库任务
|
/// </summary>
|
internal static void GenerateFromPicking()
|
{
|
try
|
{
|
//查询已配盘的配盘单
|
var list = WMSHelper.GetPickingListByState("配货完成");
|
if (list.Count > 0)
|
{
|
TaskProcess.GenerateFromPicking(list);
|
}
|
}
|
catch (Exception ex)
|
{
|
var st = new System.Diagnostics.StackTrace(ex, true);
|
var frame = st.GetFrame(0); // 获取第一个堆栈帧
|
if (frame != null)
|
{
|
LogHelper.Error($"根据配盘单生成出库任务！！", ex);
|
LogHelper.Error($"文件名: {frame.GetFileName()}", ex);
|
LogHelper.Error($"行号: {frame.GetFileLineNumber()}", ex);
|
LogHelper.Error($"列号: {frame.GetFileColumnNumber()}", ex);
|
}
|
}
|
}
|
#endregion
|
}
|
}
|
