using OfficeOpenXml.FormulaParsing.Excel.Functions.Text;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Net;
using System.Text;
using System.Threading.Tasks;
using WIDESEAWCS_Common.TaskEnum;
using WIDESEAWCS_Core.Helper;
using WIDESEAWCS_DTO;
using WIDESEAWCS_Model.Models;
namespace WIDESEAWCS_Tasks
{
public partial class TaskJob
{
#region 下发任务
///
/// 下发任务
///
public void SendTask()
{
try
{
var newTasks = _taskService.Db.Queryable().Where(x => x.TaskState == (int)TaskStatusEnum.New).ToList();
if (newTasks.Count > 0)
{
#region 查找凯乐士任务
var Tasks = newTasks.Where(x => x.TaskType == (int)TaskTypeEnum.MLInbound || x.TaskType == (int)TaskTypeEnum.MLOutbound).ToList();
if (Tasks.Count > 0) SendGALAXISTask(Tasks);
#endregion
#region 查找RGV任务
Tasks = newTasks.Where(x => x.TaskType == (int)TaskTypeEnum.CPInbound || x.TaskType == (int)TaskTypeEnum.CPOutbound).ToList();
if (Tasks.Count > 0) SendRGVTask(Tasks);
#endregion
#region 查找海康AGV任务
Tasks = newTasks.Where(x => x.TaskType == (int)TaskTypeEnum.Carry || x.TaskType == (int)TaskTypeEnum.CJCarry || x.TaskType == (int)TaskTypeEnum.CJInbound || x.TaskType == (int)TaskTypeEnum.CJOutbound).ToList();
if (Tasks.Count > 0) SendHIKROBOTTask(Tasks);
#endregion
}
}
catch (Exception ex)
{
WriteError(nameof(TaskJob), ex.Message, ex);
}
}
#endregion
#region 下发待执行任务
///
/// 下发待执行任务
///
public void SendWaitToTask()
{
try
{
var Tasks = _taskService.Db.Queryable().Where(x => x.TaskState == (int)TaskStatusEnum.CheckShapeingOk).ToList();
SendCheckShapeingOkTask(Tasks);
}
catch (Exception ex)
{
WriteError(nameof(TaskJob), ex.Message, ex);
}
}
#endregion
}
}