From 68343df577836d29f8bd106823b1805d365f4a54 Mon Sep 17 00:00:00 2001
From: wangxinhui <wangxinhui@hnkhzn.com>
Date: 星期四, 17 七月 2025 16:23:40 +0800
Subject: [PATCH] Merge branch 'master' of http://115.159.85.185:8098/r/ZhiHuiQiCe/LongDeLiLiKu

---
 项目代码/WCS/WCSServices/WIDESEAWCS_Tasks/成品仓/RGVJob_CP.cs |   85 +++++++++++++++++++++++++++---------------
 1 files changed, 54 insertions(+), 31 deletions(-)

diff --git "a/\351\241\271\347\233\256\344\273\243\347\240\201/WCS/WCSServices/WIDESEAWCS_Tasks/\346\210\220\345\223\201\344\273\223/RGVJob_CP.cs" "b/\351\241\271\347\233\256\344\273\243\347\240\201/WCS/WCSServices/WIDESEAWCS_Tasks/\346\210\220\345\223\201\344\273\223/RGVJob_CP.cs"
index d5ed193..d2a8ad1 100644
--- "a/\351\241\271\347\233\256\344\273\243\347\240\201/WCS/WCSServices/WIDESEAWCS_Tasks/\346\210\220\345\223\201\344\273\223/RGVJob_CP.cs"
+++ "b/\351\241\271\347\233\256\344\273\243\347\240\201/WCS/WCSServices/WIDESEAWCS_Tasks/\346\210\220\345\223\201\344\273\223/RGVJob_CP.cs"
@@ -76,45 +76,68 @@
                 {
                     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)

--
Gitblit v1.9.3