| | |
| | | public partial class ToAGVService |
| | | { |
| | | /// <summary> |
| | | /// AGVåè°æ¥å£ |
| | | /// AGVç»§ç»ä»»å¡æ¥å£ |
| | | /// </summary> |
| | | /// <param name="taskRespon"></param> |
| | | /// <returns></returns> |
| | |
| | | var task = _taskRepository.QueryFirst(x => x.AGVtaskId == taskResult.task_id); |
| | | if (task == null) throw new Exception($"æªç¥ä»»å¡:{taskResult.task_id}"); |
| | | |
| | | if (taskResult.result.ToLower() == "task_execute") //AGVå¼å§æ§è¡ |
| | | { |
| | | task.TaskState = (int)TaskStatusEnum.Executing; |
| | | _taskRepository.Update(task); |
| | | } |
| | | var finishTask = _taskRepository.QueryFirst(x => x.Roadway == task.Roadway && x.TaskState == (int)TaskStatusEnum.Completed /*&& x.TargetAddress == task.TargetAddress*/); |
| | | if (finishTask != null) throw new Exception("å½åä½ç½®å卿ªäººå·¥ç¡®è®¤å®æä»»å¡,ä¸å
许æ¾è´§"); |
| | | |
| | | if (taskResult.result.ToLower() == "task_complete") //AGVä»»å¡ç»æ |
| | | { |
| | | task.TaskState = (int)TaskStatusEnum.Completed; |
| | | |
| | | WebResponseContent responseContent = _taskService.CompleteAsync((int)task.TaskNum).Result; |
| | | if (!responseContent.Status) |
| | | { |
| | | throw new Exception(responseContent.Message); |
| | | } |
| | | //_taskRepository.Update(task); |
| | | } |
| | | return content.OK(); |
| | | } |
| | | catch (Exception ex) |