using HH.WCS.QingXigongchang.device;
|
using HH.WCS.QingXigongchang.dispatch;
|
using HH.WCS.QingXigongchang.process;
|
using HH.WCS.QingXigongchang.util;
|
using HH.WCS.QingXigongchang.wms;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Xml.Schema;
|
using static HH.WCS.QingXigongchang.api.ApiModel;
|
|
namespace HH.WCS.QingXigongchang.core
|
{
|
internal class TaskCore
|
{
|
public static ReturnResult OperateTaskStatus(AgvTaskState model)
|
{
|
var r = new ReturnResult();
|
if (string.IsNullOrEmpty(model.No))
|
{
|
//无任务号请求(交管)
|
//DeviceProcess.Traffic(model.ForkliftNo, model.LockNo, model.State == 1023);
|
DeviceProcess.Traffic(model.ForkliftNo, model.LockNo, model.State);
|
|
}
|
else
|
{
|
var wmsTask = TaskHelper.GetTask(model.No);
|
|
if (wmsTask != null
|
&& wmsTask.S_B_STATE.Trim() != "失败"
|
&& wmsTask.S_B_STATE.Trim() != "推送异常"
|
&& wmsTask.S_B_STATE.Trim() != "完成"
|
&& wmsTask.S_B_STATE.Trim() != "强制完成"
|
&& wmsTask.S_B_STATE.Trim() != "取消")
|
{
|
if (model.State < 8 || model.State > 1000)
|
{
|
if (model.State < 7 && string.IsNullOrEmpty(model.ForkliftNo))
|
{
|
LogHelper.Info($"{model.No} 没有车号，忽略");
|
r.ResultMsg = $"{model.No} 没有车号，忽略";
|
return r;
|
}
|
|
if (model.State < 7 && model.State > 1)
|
{
|
var aLER = TaskHelper.CheckActionRecordExist(wmsTask.S_TASK_NO, model.State + "");
|
if (aLER)
|
{
|
LogHelper.Info($"{wmsTask.S_TASK_NO}-{model.State} 已经报过了，忽略");
|
return r;
|
}
|
}
|
//有任务号请求
|
switch (model.State)
|
{
|
case -1:
|
TaskProcess.OperateStatus(wmsTask, 7);
|
TaskHelper.SetTaskState(wmsTask, "推送异常");
|
break;
|
case 1:
|
TaskHelper.Begin(wmsTask);
|
break;
|
#region MyRegion
|
case 3:
|
TaskHelper.UpdateStatus(wmsTask, "开始取货");
|
break;
|
case 4:
|
TaskHelper.UpdateStatus(wmsTask, "取货完成");
|
TaskProcess.OperateStatus(wmsTask, 4);
|
var plcTSJ = Settings.GetDeviceInfoList().Find(x => x.deviceType == 13 && (x.deviceName.Contains("T1") || x.deviceName.Contains("T2")) && x.location.Contains(wmsTask.S_END_LOC));
|
if (plcTSJ != null)
|
{
|
PlcHelper.SendHex(plcTSJ.address, "3F00" + "31" + "0d0a");
|
}
|
break;
|
case 5:
|
TaskHelper.UpdateStatus(wmsTask, "开始卸货");
|
TaskProcess.OperateStatus(wmsTask, 5);
|
break;
|
case 6:
|
TaskHelper.UpdateStatus(wmsTask, "卸货完成");
|
TaskProcess.OperateStatus(wmsTask, 6);
|
break;
|
#endregion
|
case 2:
|
TaskHelper.End(wmsTask);
|
break;
|
case 7:
|
TaskProcess.OperateStatus(wmsTask, 7);
|
wmsTask.T_END_TIME = DateTime.Now;
|
TaskHelper.UpdateStatus(wmsTask, "取消");
|
break;
|
case 8://强制完成 - 未使用
|
r = TaskProcess.OperateStatus(wmsTask, 8);
|
if (r.ResultCode != -1)
|
TaskHelper.BeEnd(wmsTask);
|
break;
|
|
|
case 1101://取货申请 -
|
{
|
NDCHelper.ChangeParam(wmsTask.S_TASK_NO, 1101, 18);
|
var plc = Settings.GetDeviceInfoList().Where(a => a.location.Contains(wmsTask.S_START_LOC.Trim()) && a.enable == 1).FirstOrDefault();
|
if (plc != null && plc.deviceType == 9)
|
{
|
PlcHelper.SendHex(plc.address, "3F00" + "11" + "0d0a");
|
}
|
}
|
break;
|
case 1103://卸货申请 - 未使用
|
{
|
NDCHelper.ChangeParam(wmsTask.S_TASK_NO, 1103, 18);
|
var plc = Settings.GetDeviceInfoList().Where(a => a.location.Contains(wmsTask.S_END_LOC.Trim()) && a.enable == 1).FirstOrDefault();
|
if (plc != null && plc.deviceType == 9)
|
{
|
PlcHelper.SendHex(plc.address, "3F00" + "21" + "0d0a");
|
}
|
}
|
break;
|
case 1102://取货完成 - 未使用
|
case 1104://取货完成 - 未使用
|
{
|
string loc__ = wmsTask.S_START_LOC.Trim();
|
if (model.State == 1104)
|
loc__ = wmsTask.S_END_LOC.Trim();
|
var plc = Settings.GetDeviceInfoList().Where(a => a.location.Contains(loc__) && a.enable == 1).FirstOrDefault();
|
if (plc != null)
|
{
|
if (plc.deviceType == 9)
|
for (int i = 0; i < plc.location.Length; i++)
|
{
|
if (plc.location[i] == loc__)
|
{
|
PlcHelper.SendHex(plc.address, "3F00" + (i + 1) + "0" + "0d0a");
|
break;
|
}
|
}
|
}
|
}
|
break;
|
}
|
|
//if (r.ResultCode != -1)
|
{
|
TaskHelper.AddActionRecord(model.No, model.State, model.ForkliftNo, model.ExtData);
|
//调用第三方接口（如果有）TaskProcess.ReportStatus
|
TaskHelper.lOCReSetValue((WMSTask x) => x.S_TASK_NO.Trim() == model.No.Trim(), delegate (WMSTask x)
|
{
|
x.S_EQ_NO = model.ForkliftNo;
|
});
|
}
|
wmsTask.S_EQ_NO = model.ForkliftNo;
|
if (model.State < 8)
|
{
|
TaskProcess.GeneralInterFaceFunc(wmsTask, model.State.ToString());
|
}
|
}
|
else
|
{
|
//安全请求等
|
TaskProcess.OperateReq(model.No, model.State, model.ForkliftNo, model.ExtData);
|
}
|
}
|
else
|
{
|
if (wmsTask == null)
|
{
|
r = new ReturnResult()
|
{
|
ResultCode = -1,
|
ResultMsg = "任务号不存在。"
|
};
|
}
|
else
|
{
|
|
r = new ReturnResult()
|
{
|
ResultCode = -1,
|
ResultMsg = $"任务状态：{wmsTask.S_B_STATE},无法操作 "
|
};
|
}
|
}
|
|
}
|
|
return r;
|
}
|
|
/// <summary>
|
/// 任务分发
|
/// </summary>
|
internal static void Dispatch()
|
{
|
//查询任务
|
//获取所有未执行的任务
|
var list = TaskHelper.GetTaskListByState("未执行");
|
if (list.Count > 0)
|
{
|
list.ForEach(task =>
|
{
|
if (!TaskProcess.Intercept(task))
|
{
|
//使用自定义任务推送
|
TaskProcess.SendTask(task);
|
}
|
|
});
|
}
|
}
|
internal static void ChargeHostAgv()
|
{
|
//查询任务
|
//获取所有未执行的任务
|
var list = TaskHelper.GetTaskListByState2("已推送");
|
if (list.Count > 0)
|
{
|
if (!string.IsNullOrEmpty(Settings.AgvSqlServer))
|
list.ForEach(task =>
|
{
|
var _agvtask = TaskHelper.GetAgvTask(task);
|
if (_agvtask != null)
|
{
|
if (!String.IsNullOrEmpty(_agvtask.CN_S_ERR) && _agvtask.CN_S_ERR.Contains("指令多次发送未成功"))
|
{
|
if (DateTime.Now.Subtract(_agvtask.CN_DT_CREATE).TotalMinutes < 10)
|
TaskProcess.OperateStatus(task, 7);
|
TaskHelper.SetTaskState(task, "推送异常");
|
}
|
}
|
else
|
{
|
LogHelper.Info($"hostAGV 数据库中找不到该任务。");
|
}
|
});
|
}
|
}
|
|
|
|
}
|
}
|
