using HH.WCS.JingyuNongfu.api;
|
using HH.WCS.JingyuNongfu.device;
|
using HH.WCS.JingyuNongfu.dispatch;
|
using HH.WCS.JingyuNongfu.process;
|
using HH.WCS.JingyuNongfu.util;
|
using HH.WCS.JingyuNongfu.wms;
|
using Newtonsoft.Json;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using static HH.WCS.JingyuNongfu.api.ApiModel;
|
|
namespace HH.WCS.JingyuNongfu.core
|
{
|
internal class TaskCore
|
{
|
public const string AlterControlSwitch01 = "1";//任务上报MES变更开发 1-开启 0-关闭
|
public static void OperateTaskStatus(AgvTaskState model)
|
{
|
|
if (string.IsNullOrEmpty(model.No))
|
{
|
//无任务号请求(交管)
|
DeviceProcess.Traffic(model.ForkliftNo, model.LockNo, model.State == 1023);
|
}
|
else
|
{
|
var wmsTask = TaskHelper.GetTask(model.No);
|
if (wmsTask != null)
|
{
|
if (model.State <= 7)
|
{
|
var db = new SqlHelper<object>().GetInstance();
|
//有任务号请求
|
switch (model.State)
|
{
|
case 1:
|
if (model.ForkliftNo.Trim() != "0")
|
{
|
TaskHelper.Begin(wmsTask, model.ForkliftNo);
|
}
|
break;
|
|
case 3:
|
TaskHelper.UpdateStatus(wmsTask, "开始取货");
|
|
break;
|
case 4:
|
|
var info = Settings.deviceInfos.Where(a => a.location.Contains(wmsTask.S_START_LOC)).FirstOrDefault();
|
if (info != null && info.deviceType == 6)
|
{
|
PlcHelper.SendHex(info.address, "3F00100D0A");
|
LogHelper.Info($"顶升机安全交互1102成功", "安全请求");
|
}
|
|
|
TaskHelper.UpdateStatus(wmsTask, "取货完成");
|
TaskProcess.OperateStatus(wmsTask, 4, model.No);
|
//取货完成删除富勒托盘表
|
if (wmsTask.S_TYPE.Contains("成品下线"))
|
{
|
// var order = db.Queryable<WorkOrder1>().Where(a => a.S_WorkNo == wmsTask.S_SRC_NO).First();
|
if (wmsTask.S_NOTE.Trim() == "是")
|
{
|
if (ContainerHelper.delFlCntr(wmsTask.S_CNTRS.Split(',').ToList()))
|
{
|
LogHelper.Info($"任务{wmsTask.S_TASK_NO}富勒托盘数据已删除", "ThirdSystemLog");
|
}
|
}
|
}
|
|
break;
|
case 5:
|
TaskHelper.UpdateStatus(wmsTask, "开始卸货");
|
|
#region 成品开始卸货算卸货完成，提前下达任务
|
//成品下线开始卸货提前把货放终点
|
if (wmsTask.S_TYPE.Contains("成品下线"))
|
{
|
//成品下线如果处理过5 后续发5不做卸货处理
|
if (!TaskHelper.CheckActionRecordExist(wmsTask.S_TASK_NO, "5"))
|
{
|
TaskProcess.OperateStatus(wmsTask, 6, model.No);
|
}
|
}
|
#endregion
|
|
break;
|
case 6:
|
TaskHelper.UpdateStatus(wmsTask, "卸货完成");
|
//非成品下线6把货位放到终点
|
if (!wmsTask.S_TYPE.Contains("成品下线"))
|
{
|
TaskProcess.OperateStatus(wmsTask, 6, model.No);
|
}
|
|
if (wmsTask.S_TYPE.Contains("注塑"))
|
{
|
DeviceProcess.XieliaoPpzsj(wmsTask);
|
}
|
//else if (wmsTask.S_TYPE.Contains("翻斗机即产满筐上线（瓶胚）") || wmsTask.S_TYPE.Contains("翻斗机即产空筐下线（瓶胚）") || wmsTask.S_TYPE.Contains("翻斗机库存满筐上线（瓶胚）") || wmsTask.S_TYPE.Contains("翻斗机库存空筐下线（瓶胚）"))
|
//{
|
// DeviceProcess.XieliaoFdj(wmsTask);
|
//}
|
//翻斗机上满卸货完成发送复位信号
|
else if (wmsTask.S_TYPE.Contains("翻斗机"))
|
{
|
DeviceProcess.XieliaoFdj(wmsTask);
|
}
|
break;
|
|
case 2:
|
TaskHelper.End(wmsTask);
|
//if (wmsTask.S_TYPE.Contains("瓶盖"))
|
//{
|
// DeviceProcess.XieliaoFdj(wmsTask);
|
//}
|
#region 订单完成判断有没有收到4和6 没有程序处理4和6
|
if (!TaskHelper.CheckActionRecordExist(wmsTask.S_TASK_NO, "4"))
|
{
|
TaskProcess.OperateStatus(wmsTask, 4, model.No);
|
}
|
//成品下线判断5有没有发，其他的判单4有没有发
|
if (wmsTask.S_TYPE.Contains("成品下线"))
|
{
|
if (!TaskHelper.CheckActionRecordExist(wmsTask.S_TASK_NO, "5"))
|
{
|
TaskProcess.OperateStatus(wmsTask, 6, model.No);
|
}
|
}
|
else
|
{
|
if (!TaskHelper.CheckActionRecordExist(wmsTask.S_TASK_NO, "6"))
|
{
|
TaskProcess.OperateStatus(wmsTask, 6, model.No);
|
}
|
}
|
#endregion
|
|
#region 富勒上报判定
|
if (wmsTask.S_TYPE.Contains("成品下线"))
|
{
|
//var order = db.Queryable<WorkOrder1>().Where(a => a.S_WorkNo == wmsTask.S_SRC_NO).First();
|
// LogHelper.Info("成品工单信息" + JsonConvert.SerializeObject(order), "ThirdSystemLog");
|
if (wmsTask.S_NOTE.Trim() == "是")
|
{
|
LogHelper.Info($"有码模式进入任务完成状态回报,任务{wmsTask.S_TASK_NO}", "ThirdSystemLog");
|
TaskProcess.ThirdReportStatus(wmsTask);
|
}
|
|
}
|
if (wmsTask.S_TYPE.Contains("移库") && !wmsTask.S_CNTRS.Contains("TP"))
|
{
|
LogHelper.Info($"有码模式进入任务完成状态回报,任务{wmsTask.S_TASK_NO}", "ThirdSystemLog");
|
TaskProcess.ThirdReportStatus(wmsTask);
|
}
|
#endregion
|
|
break;
|
case 7:
|
case -1:
|
TaskProcess.OperateStatus(wmsTask, 7, model.No);
|
break;
|
|
|
}
|
TaskHelper.AddActionRecord(model.No, model.State, model.ForkliftNo, model.ExtData);
|
//调用第三方接口（如果有）TaskProcess.ReportStatus
|
if (AlterControlSwitch01 == "1")
|
{
|
//任务状态-1，上报7
|
if (model.State == -1)
|
{
|
model.State = 7;
|
}
|
|
TaskProcess.GeneralInterFaceFunc(wmsTask, model.State.ToString());
|
}
|
}
|
|
|
else
|
{
|
//安全请求等
|
TaskProcess.OperateReq(model.No, model.State, model.ForkliftNo, model.ExtData);
|
}
|
}
|
}
|
}
|
|
/// <summary>
|
/// 任务分发
|
/// </summary>
|
internal static void Dispatch()
|
{
|
//查询任务
|
//获取所有未执行的任务
|
var list = TaskHelper.GetTaskListByState("未执行");
|
if (list.Count > 0)
|
{
|
list.ForEach(task =>
|
{
|
|
//if (!TaskProcess.Intercept(task))
|
//{
|
//使用自定义任务推送
|
TaskProcess.SendTask(task);
|
//}
|
|
});
|
|
|
}
|
}
|
}
|
}
|
