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 } }