| | |
| | | using System; |
| | | using OfficeOpenXml.FormulaParsing.Excel.Functions.RefAndLookup; |
| | | using System; |
| | | using System.Collections.Generic; |
| | | using System.Linq; |
| | | using System.Text; |
| | |
| | | using WIDESEAWCS_Common.TaskEnum; |
| | | using WIDESEAWCS_Core; |
| | | using WIDESEAWCS_Core.Helper; |
| | | using WIDESEAWCS_DTO.Agv; |
| | | using WIDESEAWCS_Model.Models; |
| | | using WIDESEAWCS_QuartzJob; |
| | | |
| | | namespace WIDESEAWCS_Tasks |
| | | { |
| | |
| | | { |
| | | try |
| | | { |
| | | var newTasks = _taskService.Db.Queryable<Dt_Task>().Where(x => x.TaskState == TaskStatusEnum.AGV_Execute.ObjToInt() && nameof(AGV_CPJob).Contains(x.DeviceCode) && !string.IsNullOrEmpty(x.DeviceCode)).ToList().OrderBy(x => x.Grade).ThenBy(x => x.CreateDate).ToList(); |
| | | var newTasks = _taskService.Db.Queryable<Dt_Task>().Where(x => (x.TaskState == TaskStatusEnum.AGV_Execute.ObjToInt()|| x.TaskState == TaskStatusEnum.New.ObjToInt()) && nameof(AGV_CPJob).Contains(x.DeviceCode) && !string.IsNullOrEmpty(x.DeviceCode)).ToList().OrderBy(x => x.Grade).ThenBy(x => x.CreateDate).ToList(); |
| | | foreach (var task in newTasks) |
| | | { |
| | | try |
| | |
| | | } |
| | | }, |
| | | }; |
| | | //åéAGVä»»å¡ |
| | | WebResponseContent content = _taskService.AgvSendTask(taskDTO, APIEnum.Agv_CPSendTask); |
| | | if (!content.Status) throw new Exception(content.Message); |
| | | |
| | | task.TaskState = TaskStatusEnum.AGV_Executing.ObjToInt(); |
| | | |
| | | if (!content.Status) |
| | | throw new Exception(content.Message); |
| | | task.TaskState = TaskStatusEnum.AGV_Takeing.ObjToInt(); |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | |
| | | if (newTasks.Count>0) |
| | | { |
| | | _taskService.UpdateData(newTasks); |
| | | } |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | WriteError(nameof(AGV_CPJob), ex.Message, ex); |
| | | } |
| | | } |
| | | /// <summary> |
| | | /// AGVåæ¾è´§åè° |
| | | /// </summary> |
| | | public void ContinueAGVTask() |
| | | { |
| | | try |
| | | { |
| | | //è·åæ¯å¦æå®å
¨ç³è¯·ä¸çä»»å¡ |
| | | var continueTask = _taskService.Db.Queryable<Dt_Task>().Where(x => (x.TaskState == TaskStatusEnum.AGV_WaitToExecute.ObjToInt()) && nameof(AGV_CPJob).Contains(x.DeviceCode) && !string.IsNullOrEmpty(x.DeviceCode)).ToList().OrderBy(x => x.Grade).ThenBy(x => x.CreateDate).FirstOrDefault(); |
| | | if (continueTask!=null) |
| | | { |
| | | //åè´§åè° |
| | | if (continueTask.TaskType.GetTaskTypeGroup() == TaskTypeGroup.InboundGroup) |
| | | { |
| | | Dt_StationManger stationManger = _stationMangerRepository.QueryFirst(x => x.AGVStationCode == continueTask.CurrentAddress || x.StationCode== continueTask.CurrentAddress); |
| | | if (stationManger == null) |
| | | { |
| | | throw new Exception($"æªæ¾å°ç«å°{continueTask.CurrentAddress}ä¿¡æ¯"); |
| | | } |
| | | IDevice? device = Storage.Devices.FirstOrDefault(x => x.DeviceCode == stationManger.StationDeviceCode); |
| | | if (device == null) |
| | | { |
| | | throw new Exception($"æªæ¾å°è®¾å¤{stationManger.StationDeviceCode}ä¿¡æ¯"); |
| | | } |
| | | OtherDevice otherDevice = (OtherDevice)device; |
| | | short canTake = otherDevice.GetValue<GroundStationDBName, short>(GroundStationDBName.R_IsCanTake, stationManger.StationCode); |
| | | if (canTake != 1) |
| | | { |
| | | return; |
| | | } |
| | | } |
| | | else//æ¾è´§åè° |
| | | { |
| | | Dt_StationManger stationManger = _stationMangerRepository.QueryFirst(x => x.AGVStationCode == continueTask.NextAddress); |
| | | if (stationManger == null) |
| | | { |
| | | throw new Exception($"æªæ¾å°ç«å°{continueTask.NextAddress}ä¿¡æ¯"); |
| | | } |
| | | IDevice? device = Storage.Devices.FirstOrDefault(x => x.DeviceCode == stationManger.StationDeviceCode); |
| | | if (device == null) |
| | | { |
| | | throw new Exception($"æªæ¾å°è®¾å¤{stationManger.StationDeviceCode}ä¿¡æ¯"); |
| | | } |
| | | OtherDevice otherDevice = (OtherDevice)device; |
| | | short canPut = otherDevice.GetValue<GroundStationDBName, short>(GroundStationDBName.R_IsCanPut, stationManger.StationCode); |
| | | if (canPut != 1) |
| | | { |
| | | return; |
| | | } |
| | | } |
| | | //è·åè°å
¥åæ° |
| | | AGVBoxApplyPassDTO boxApplyPassDTO = new AGVBoxApplyPassDTO() |
| | | { |
| | | ReqCode = Guid.NewGuid().ToString().Replace("-", ""), |
| | | ReqTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"), |
| | | TaskCode = continueTask.AgvTaskNum |
| | | }; |
| | | if (continueTask.TaskType.GetTaskTypeGroup() == TaskTypeGroup.InboundGroup) |
| | | { |
| | | boxApplyPassDTO.Type = "1"; |
| | | } |
| | | else |
| | | { |
| | | boxApplyPassDTO.Type = "2"; |
| | | } |
| | | //è¯·æ±æç®±åè°æ¥å£ |
| | | WebResponseContent content = _taskService.AgvBoxApplyPass(boxApplyPassDTO); |
| | | if (content.Status && continueTask.TaskType.GetTaskTypeGroup() == TaskTypeGroup.InboundGroup) |
| | | { |
| | | continueTask.TaskState = TaskStatusEnum.AGV_Executing.ObjToInt(); |
| | | _taskService.UpdateTask(continueTask, TaskStatusEnum.AGV_Executing); |
| | | } |
| | | else if (content.Status && continueTask.TaskType.GetTaskTypeGroup() == TaskTypeGroup.OutbondGroup) |
| | | { |
| | | continueTask.TaskState = TaskStatusEnum.AGV_Puting.ObjToInt(); |
| | | _taskService.UpdateTask(continueTask, TaskStatusEnum.AGV_Puting); |
| | | } |
| | | else |
| | | { |
| | | continueTask.TaskState = TaskStatusEnum.Exception.ObjToInt(); |
| | | continueTask.ExceptionMessage = content.Message; |
| | | _taskService.UpdateTask(continueTask, TaskStatusEnum.Exception); |
| | | } |
| | | } |
| | | } |
| | | catch (Exception ex) |
| | |
| | | var Layer = Convert.ToInt16(targetCodes[3]); |
| | | var a = Row switch |
| | | { |
| | | 1 => "A1", |
| | | 2 => "B1", |
| | | 3 => "C1", |
| | | 4 => "D1", |
| | | 5 => "E1", |
| | | 1 => "A", |
| | | 2 => "B", |
| | | 3 => "C", |
| | | 4 => "D", |
| | | 5 => "E", |
| | | _ => throw new Exception($"æªå®ä¹çæ,å°å:ã{Address}ã"), |
| | | }; |
| | | var b = Layer > 9 ? "" + Layer : "0" + Layer; |