| | |
| | | using WIDESEAWCS_DTO.Agv; |
| | | using SqlSugar; |
| | | using static Dm.net.buffer.ByteArrayBuffer; |
| | | using WIDESEAWCS_Core.Enums; |
| | | |
| | | namespace WIDESEAWCS_Tasks |
| | | { |
| | |
| | | } |
| | | } |
| | | _taskService.UpdateData(WaitToTasks); |
| | | |
| | | //åæ¾è´§å®æåå
¥å¼å¸¸å¤ç |
| | | Dt_Task? TakeErroeTask = _taskService.Db.Queryable<Dt_Task>().Where(x => x.TaskState == TaskStatusEnum.AGV_TakeError.ObjToInt() && nameof(AGV_CSJJob).Contains(x.DeviceCode)).First(); |
| | | if (TakeErroeTask!=null) |
| | | { |
| | |
| | | otherDevice.SetValue(GroundStationDBName.W_TakeFinish, true, stationManger.StationCode); |
| | | Thread.Sleep(1000); |
| | | otherDevice.SetValue(GroundStationDBName.W_TakeFinish, false, stationManger.StationCode); |
| | | TakeErroeTask.TaskState = TaskStatusEnum.AGV_Finish.ObjToInt(); |
| | | var up = _taskRepository.DeleteAndMoveIntoHty(TakeErroeTask, OperateTypeEnum.èªå¨å®æ); |
| | | _taskService.TaskCompleted(TakeErroeTask.TaskNum); |
| | | } |
| | | Dt_Task? PutErroeTask = _taskService.Db.Queryable<Dt_Task>().Where(x => x.TaskState == TaskStatusEnum.AGV_PutError.ObjToInt() && nameof(AGV_CSJJob).Contains(x.DeviceCode)).First(); |
| | | if (PutErroeTask != null) |
| | | { |
| | | Dt_StationManger stationManger = _stationMangerRepository.QueryFirst(x => x.AGVStationCode == PutErroeTask.NextAddress); |
| | | if (stationManger == null) |
| | | { |
| | | throw new Exception($"æªæ¾å°ç«å°é
ç½®"); |
| | | } |
| | | IDevice? device = Storage.Devices.FirstOrDefault(x => x.DeviceCode == stationManger.StationDeviceCode); |
| | | if (device == null) |
| | | { |
| | | throw new Exception($"æªæ¾å°ç«å°é
ç½®"); |
| | | } |
| | | OtherDevice otherDevice = (OtherDevice)device; |
| | | otherDevice.SetValue(GroundStationDBName.W_PutFinish, true, stationManger.StationCode); |
| | | PutErroeTask.CurrentAddress = stationManger.StationCode; |
| | | PutErroeTask.NextAddress = ""; |
| | | PutErroeTask.TaskState = TaskStatusEnum.AGV_Finish.ObjToInt(); |
| | | PutErroeTask.DeviceCode = "SC01_CSJ"; |
| | | var up = _taskRepository.UpdateData(PutErroeTask); |
| | | } |
| | | } |
| | | catch (Exception ex) |
| | | { |