| | |
|---|
| | | { |
|---|
| | | R_RGVCPInfo rgvInfoRead = device.Communicator.ReadCustomer<R_RGVCPInfo>(deviceProRead.DeviceProAddress); |
|---|
| | | W_RGVCPInfo rgvInfoWrite = device.Communicator.ReadCustomer<W_RGVCPInfo>(deviceProWrite.DeviceProAddress); |
|---|
| | | if (rgvInfoRead.Mode==5 && rgvInfoRead.State == 0 && rgvInfoRead.TaskDone==1) |
|---|
| | | if ((rgvInfoRead.Mode == 5 || rgvInfoRead.Mode == 4) && rgvInfoRead.State == 0 && rgvInfoRead.TaskDone==1) |
|---|
| | | { |
|---|
| | | List<Dt_Task> tasks = _taskRepository.QueryData(x => _taskService.TaskInboundTypes.Contains(x.TaskType) && x.TaskState != TaskStatusEnum.RGV_Execute.ObjToInt() && x.DeviceCode == device.DeviceCode); |
|---|
| | | //鑾峰彇浠诲姟 |
|---|
| | | Dt_Task? task1 = tasks.FirstOrDefault(x => x.HeightType==1); |
|---|
| | | Dt_Task? task1 = tasks.FirstOrDefault(x => x.HeightType == 1); |
|---|
| | | Dt_Task? task2 = tasks.FirstOrDefault(x => x.HeightType == 2); |
|---|
| | | Dt_Task? task3 = tasks.FirstOrDefault(x => x.HeightType == 3); |
|---|
| | | Dt_Task task = _taskRepository.QueryFirst(x => _taskService.TaskInboundTypes.Contains(x.TaskType) && x.TaskState == TaskStatusEnum.RGV_Execute.ObjToInt() && x.DeviceCode == device.DeviceCode); |
|---|
| | | if (task != null && task1 == null) |
|---|
| | | List<Dt_Task> tasksDown = _taskRepository.QueryData(x => _taskService.TaskInboundTypes.Contains(x.TaskType) && x.TaskState == TaskStatusEnum.RGV_Execute.ObjToInt() && x.DeviceCode == device.DeviceCode).OrderBy(x=>x.CreateDate).Take(3).ToList(); |
|---|
| | | //鍒嗛厤RGV宸ヤ綅浠诲姟 |
|---|
| | | if (tasksDown.Count>=2) |
|---|
| | | { |
|---|
| | | device.SetValue(W_RgvCPDB.WcsTask1, task.TaskNum); |
|---|
| | | device.SetValue(W_RgvCPDB.TaskType, 4); |
|---|
| | | device.SetValue(W_RgvCPDB.WorkStation, 1); |
|---|
| | | device.SetValue(W_RgvCPDB.Qu1, task.CurrentAddress); |
|---|
| | | device.SetValue(W_RgvCPDB.Fang1, task.NextAddress); |
|---|
| | | //鍗犵敤涓や釜宸ヤ綅 |
|---|
| | | if (tasksDown.Count==2) |
|---|
| | | { |
|---|
| | | device.SetValue(W_RgvCPDB.WorkStation, 4); |
|---|
| | | if (task1 == null) |
|---|
| | | { |
|---|
| | | device.SetValue(W_RgvCPDB.WcsTask1, tasksDown[0].TaskNum); |
|---|
| | | device.SetValue(W_RgvCPDB.Qu1, tasksDown[0].CurrentAddress); |
|---|
| | | device.SetValue(W_RgvCPDB.Fang1, tasksDown[0].NextAddress); |
|---|
| | | tasksDown[0].HeightType = 1; |
|---|
| | | _taskService.UpdateTask(tasksDown[0], TaskStatusEnum.RGV_Executing); |
|---|
| | | } |
|---|
| | | if (task2 == null) |
|---|
| | | { |
|---|
| | | device.SetValue(W_RgvCPDB.WcsTask2, tasksDown[1].TaskNum); |
|---|
| | | device.SetValue(W_RgvCPDB.Qu2, tasksDown[1].CurrentAddress); |
|---|
| | | device.SetValue(W_RgvCPDB.Fang2, tasksDown[1].NextAddress); |
|---|
| | | tasksDown[1].HeightType = 2; |
|---|
| | | _taskService.UpdateTask(tasksDown[1], TaskStatusEnum.RGV_Executing); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | else //鍗犵敤涓変釜宸ヤ綅 |
|---|
| | | { |
|---|
| | | device.SetValue(W_RgvCPDB.WorkStation, 7); |
|---|
| | | if ( task1 == null) |
|---|
| | | { |
|---|
| | | device.SetValue(W_RgvCPDB.WcsTask1, tasksDown[0].TaskNum); |
|---|
| | | device.SetValue(W_RgvCPDB.Qu1, tasksDown[0].CurrentAddress); |
|---|
| | | device.SetValue(W_RgvCPDB.Fang1, tasksDown[0].NextAddress); |
|---|
| | | tasksDown[0].HeightType = 1; |
|---|
| | | _taskService.UpdateTask(tasksDown[0], TaskStatusEnum.RGV_Executing); |
|---|
| | | } |
|---|
| | | if (task2 == null) |
|---|
| | | { |
|---|
| | | device.SetValue(W_RgvCPDB.WcsTask2, tasksDown[1].TaskNum); |
|---|
| | | device.SetValue(W_RgvCPDB.Qu2, tasksDown[1].CurrentAddress); |
|---|
| | | device.SetValue(W_RgvCPDB.Fang2, tasksDown[1].NextAddress); |
|---|
| | | tasksDown[1].HeightType = 2; |
|---|
| | | _taskService.UpdateTask(tasksDown[1], TaskStatusEnum.RGV_Executing); |
|---|
| | | } |
|---|
| | | if (task3 == null) |
|---|
| | | { |
|---|
| | | device.SetValue(W_RgvCPDB.WcsTask3, tasksDown[2].TaskNum); |
|---|
| | | device.SetValue(W_RgvCPDB.Qu3, tasksDown[2].CurrentAddress); |
|---|
| | | device.SetValue(W_RgvCPDB.Fang3, tasksDown[2].NextAddress); |
|---|
| | | tasksDown[2].HeightType = 3; |
|---|
| | | _taskService.UpdateTask(tasksDown[2], TaskStatusEnum.RGV_Executing); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | device.SetValue(W_RgvCPDB.TaskReceivedDone, 1); |
|---|
| | | task.HeightType = 1; |
|---|
| | | _taskService.UpdateTask(task, TaskStatusEnum.RGV_Executing); |
|---|
| | | }else if (task != null && task2 == null) |
|---|
| | | { |
|---|
| | | device.SetValue(W_RgvCPDB.WcsTask1, task.TaskNum); |
|---|
| | | device.SetValue(W_RgvCPDB.TaskType, 4); |
|---|
| | | device.SetValue(W_RgvCPDB.WorkStation, 1); |
|---|
| | | device.SetValue(W_RgvCPDB.Qu2, task.CurrentAddress); |
|---|
| | | device.SetValue(W_RgvCPDB.Fang2, task.NextAddress); |
|---|
| | | device.SetValue(W_RgvCPDB.TaskReceivedDone, 1); |
|---|
| | | task.HeightType = 2; |
|---|
| | | _taskService.UpdateTask(task, TaskStatusEnum.RGV_Executing); |
|---|
| | | } |
|---|
| | | else if (task != null && task3 == null) |
|---|
| | | { |
|---|
| | | device.SetValue(W_RgvCPDB.WcsTask1, task.TaskNum); |
|---|
| | | device.SetValue(W_RgvCPDB.TaskType, 4); |
|---|
| | | device.SetValue(W_RgvCPDB.WorkStation, 1); |
|---|
| | | device.SetValue(W_RgvCPDB.Qu3, task.CurrentAddress); |
|---|
| | | device.SetValue(W_RgvCPDB.Fang3, task.NextAddress); |
|---|
| | | device.SetValue(W_RgvCPDB.TaskReceivedDone, 1); |
|---|
| | | task.HeightType = 3; |
|---|
| | | _taskService.UpdateTask(task, TaskStatusEnum.RGV_Executing); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | else if((rgvInfoRead.Mode == 5 || rgvInfoRead.Mode == 4) && rgvInfoRead.TaskDone == 3) |
|---|
