4-29

xiaojiao

3 天以前 2c69e642303e9f9c3b2e37194c4c6cdf7e1b3001

 ÏîÄ¿´úÂë/WIDESEA_WCSServer/WIDESEAWCS_Tasks/AGV/CommonAGVJob.cs

@@ -47,6 +47,7 @@
        public Task Execute(IJobExecutionContext context)
        {
            var newTasks = _taskService.Db.Queryable<Dt_Task>().Where(x => (x.TaskState == (int)TaskAGVCarryStatusEnum.AGV_CarryNew)).ToList().OrderBy(x => x.Grade).ThenBy(x => x.TaskNum).ToList();
            return Task.CompletedTask;
            #region ä»»åŠ¡ä¸‹å‘
            if (newTasks.Count > 0)
            {
@@ -62,9 +63,9 @@
                        string taskGroupId = Guid.NewGuid().ToString().Replace("-", "");

                        // èŽ·å–起始站台
                        Dt_StationManager stationManagerEnd = _stationManagerRepository.QueryFirst(x => x.stationLocation == task.SourceAddress);
                        Dt_StationManager stationManagerEnd = _stationManagerRepository.QueryFirst(x => x.StationLocation == task.SourceAddress);
                        // èŽ·å–目的站台
                        Dt_StationManager finalmission = _stationManagerRepository.QueryFirst(x => x.stationLocation == task.TargetAddress);
                        Dt_StationManager finalmission = _stationManagerRepository.QueryFirst(x => x.StationLocation == task.TargetAddress);

                        if (stationManagerEnd == null) throw new Exception($"未找到任务号${task.TaskId}起始点{task.SourceAddress}位置信息");
                        if (finalmission == null) throw new Exception($"未找到任务号${task.TaskId}目标点{task.TargetAddress}位置信息");
@@ -72,17 +73,19 @@
                        agvTaskSend.RequestId = taskGroupId;
                        agvTaskSend.MissionCode = task.TaskId.ToString();
                        agvTaskSend.ViewBoardType = "W01";
                        agvTaskSend.ContainerCode = task.PalletCode;
                        //货架子搬运任务
                        MissionDataItem Startingmission = new MissionDataItem() // èµ·ç‚¹
                        {
                            Sequence = 1,
                            Position = stationManagerEnd.stationLocation,
                            Position = stationManagerEnd.StationLocation,
                        };

                        MissionDataItem Finalmission = new MissionDataItem() // ç»ˆç‚¹
                        {
                            Sequence = 2,
                            Position = finalmission.stationLocation,
                            Position = finalmission.StationLocation,
                            PutDown = true,
                        };
                        agvTaskSend.MissionData.Add(Startingmission);
                        agvTaskSend.MissionData.Add(Finalmission);
@@ -100,7 +103,7 @@
                            throw new Exception(content.Message);
                        task.Dispatchertime = DateTime.Now;
                        task.TaskState = (int)TaskAGVCarryStatusEnum.AGV_CarryExecuting;
                        _taskService.UpdateData(newTasks);
                        _taskService.UpdateData(task);
                        Thread.Sleep(500);
                    }
                    catch (Exception ex)