From f0e2d9d2c7c41b311217bdb2c4d114ff53f6a146 Mon Sep 17 00:00:00 2001
From: dengjunjie <dengjunjie@hnkhzn.com>
Date: 星期二, 16 四月 2024 07:47:17 +0800
Subject: [PATCH] 优化空托逻辑

---
 代码管理/PCS/WCS_Server/WIDESEA_WCS/JobsPart/Common/RestockHCJ.cs |  108 +++++++++++++++++++++++++++++------------------------
 1 files changed, 59 insertions(+), 49 deletions(-)

diff --git "a/\344\273\243\347\240\201\347\256\241\347\220\206/PCS/WCS_Server/WIDESEA_WCS/JobsPart/Common/RestockHCJ.cs" "b/\344\273\243\347\240\201\347\256\241\347\220\206/PCS/WCS_Server/WIDESEA_WCS/JobsPart/Common/RestockHCJ.cs"
index 410a9c6..8680c72 100644
--- "a/\344\273\243\347\240\201\347\256\241\347\220\206/PCS/WCS_Server/WIDESEA_WCS/JobsPart/Common/RestockHCJ.cs"
+++ "b/\344\273\243\347\240\201\347\256\241\347\220\206/PCS/WCS_Server/WIDESEA_WCS/JobsPart/Common/RestockHCJ.cs"
@@ -36,58 +36,68 @@
                 {
                     if (task.agv_tasktype == "TaskType_EmptyPallet")//绌烘墭浠诲姟
                     {
-                        if (task.agv_fromaddress == "" && DateTime.Now - task.agv_createtime >= TimeSpan.FromMinutes(5))
+                        if (task.agv_fromaddress == "" && DateTime.Now - task.agv_createtime >= TimeSpan.FromMinutes(1))
                         {
-                            var Pipeline_client = PLCClient.Clients.FirstOrDefault(t => t.PLCName == "閾炬潯鏈�");
-                            if (Pipeline_client == null) throw new Exception("閾炬潯鏈鸿皟搴︽湇鍔℃湭寮�鍚紒");
-                            if (!Pipeline_client.IsConnected) throw new Exception("涓庨摼鏉℃満杩炴帴瓒呮椂锛�");
-                            var area = task.agv_Traytype == "SmallTray" ? "11" : "10";
-                            //鎵�1搴撳尯鐨勭┖鎵樹綅
-                            var EmptyStation = stationinfoRepository.Find(x => x.area == area && x.quantity > 0 && x.stationCode.Contains("A") /*&& x.location_state == "Stroge"*//*LocationStateEnum.Stroge.ToString()*/ && x.enable).OrderBy(x => x.column).ThenBy(x => x.line).FirstOrDefault();
-                            if (EmptyStation != null)
-                                if (EmptyStation.location_state == LocationStateEnum.Busy.ToString()) EmptyStation = null;
-                            #region 涓�涓尯鍩熷彧鑳芥湁涓�涓┖鎵樹换鍔�
-                            //bool ok = false;
-                            //if (EmptyStation != null)
-                            //    ok = agvtaskService.Find(x => x.agv_fromaddress == EmptyStation.stationCode || x.agv_toaddress == EmptyStation.stationCode).Any();
-                            //if (EmptyStation == null || ok)
-                            //    EmptyStation = stationinfoRepository.Find(x => x.area == area && x.quantity > 0 && x.stationCode.Contains(area == "10" ? "D" : "C") && x.location_state == "Stroge" /*LocationStateEnum.Stroge.ToString()*/ && x.enable)
-                            //    .OrderBy(x => x.line).OrderByDescending(x => x.column).FirstOrDefault();
-                            #endregion
-                            if (EmptyStation == null)
-                                EmptyStation = stationinfoRepository.Find(x => x.area == area && x.quantity > 0 && x.stationCode.Contains(area == "10" ? "D" : "C") && x.enable).OrderByDescending(x => x.column).FirstOrDefault();
-                            if (EmptyStation == null) continue;
-                            #region 搴撳唴瀛樺湪浠诲姟鍗犵敤
-                            if (EmptyStation.location_state == LocationStateEnum.Busy.ToString())
-                                continue;
-                            #endregion
-
-                            if (EmptyStation == null)
-                                EmptyStation = stationinfoRepository.Find(x => x.area == area && x.quantity > 0 && x.stationCode.Contains(area == "10" ? "D" : "C") && x.location_state == "Stroge" && x.enable).OrderByDescending(x => x.column).FirstOrDefault();
-                            if (EmptyStation != null)
+                            if (task.agv_tasknum.Contains("_"))
                             {
-                                #region 搴撳唴瀛樺湪浠诲姟鍗犵敤
-                                //if (EmptyStation.location_state == LocationStateEnum.Busy.ToString())
-                                //    continue;
-                                #endregion
-
-                                //if (agvtaskService.Find(x => x.agv_fromaddress == EmptyStation.stationCode || x.agv_toaddress == EmptyStation.stationCode).Any())
-                                //    return;
-                                #region 琛ュ簱鍐呯┖鎵樼洏锛屼笉闇�瑕佸厜鐢靛垽鏂�
-                                var PalletSignal = Pipeline_client.ReadByOrder<Int16>("R_PalletSignal", task.agv_toaddress);//璇诲彇鎵樼洏淇″彿:1:鏈�,2鏃�
-                                var MaterialSignal = Pipeline_client.ReadByOrder<Int16>("R_MaterialSignal", task.agv_toaddress);//璇诲彇璐х墿淇″彿:1:鏈�,2鏃�
-                                if (PalletSignal == 2 && MaterialSignal == 2)
-                                {
-                                    task.agv_fromaddress = EmptyStation.stationCode;
-                                    task.StarQuantity = EmptyStation.quantity - 1;
-                                    task.agv_taskstate = "Create";
-                                    agvtaskService.Update(task, true);
-                                    EmptyStation.location_state = LocationStateEnum.Busy.ToString();
-                                    stationinfoRepository.Update(EmptyStation, true);
-                                    WriteDBLog.Success("鏇存柊绌虹洏闃熷垪浠诲姟", $"浠诲姟缂栧彿锛歿task.agv_tasknum}", "PCS");
-                                }
-                                #endregion
+                                string mainTaskNum = task.agv_tasknum.Split('_')[0];
+                                if (agvtaskService.Find(x => x.agv_tasknum == mainTaskNum && (task.agv_taskstate == "Executing1" || task.agv_taskstate == "Complete1")).Any())
+                                    GetStation.EmptyPalletStation(task);
                             }
+                            else
+                                GetStation.EmptyPalletStation(task);
+                            #region
+                            //var Pipeline_client = PLCClient.Clients.FirstOrDefault(t => t.PLCName == "閾炬潯鏈�");
+                            //if (Pipeline_client == null) throw new Exception("閾炬潯鏈鸿皟搴︽湇鍔℃湭寮�鍚紒");
+                            //if (!Pipeline_client.IsConnected) throw new Exception("涓庨摼鏉℃満杩炴帴瓒呮椂锛�");
+                            //var area = task.agv_Traytype == "SmallTray" ? "11" : "10";
+                            ////鎵�1搴撳尯鐨勭┖鎵樹綅
+                            //var EmptyStation = stationinfoRepository.Find(x => x.area == area && x.quantity > 0 && x.stationCode.Contains("A") /*&& x.location_state == "Stroge"*//*LocationStateEnum.Stroge.ToString()*/ && x.enable).OrderBy(x => x.column).ThenBy(x => x.line).FirstOrDefault();
+                            //if (EmptyStation != null)
+                            //    if (EmptyStation.location_state == LocationStateEnum.Busy.ToString()) EmptyStation = null;
+                            //#region 涓�涓尯鍩熷彧鑳芥湁涓�涓┖鎵樹换鍔�
+                            ////bool ok = false;
+                            ////if (EmptyStation != null)
+                            ////    ok = agvtaskService.Find(x => x.agv_fromaddress == EmptyStation.stationCode || x.agv_toaddress == EmptyStation.stationCode).Any();
+                            ////if (EmptyStation == null || ok)
+                            ////    EmptyStation = stationinfoRepository.Find(x => x.area == area && x.quantity > 0 && x.stationCode.Contains(area == "10" ? "D" : "C") && x.location_state == "Stroge" /*LocationStateEnum.Stroge.ToString()*/ && x.enable)
+                            ////    .OrderBy(x => x.line).OrderByDescending(x => x.column).FirstOrDefault();
+                            //#endregion
+                            //if (EmptyStation == null)
+                            //    EmptyStation = stationinfoRepository.Find(x => x.area == area && x.quantity > 0 && x.stationCode.Contains(area == "10" ? "D" : "C") && x.enable).OrderByDescending(x => x.column).FirstOrDefault();
+                            //if (EmptyStation == null) continue;
+                            //#region 搴撳唴瀛樺湪浠诲姟鍗犵敤
+                            //if (EmptyStation.location_state == LocationStateEnum.Busy.ToString())
+                            //    continue;
+                            //#endregion
+
+                            //if (EmptyStation == null)
+                            //    EmptyStation = stationinfoRepository.Find(x => x.area == area && x.quantity > 0 && x.stationCode.Contains(area == "10" ? "D" : "C") && x.location_state == "Stroge" && x.enable).OrderByDescending(x => x.column).FirstOrDefault();
+                            //if (EmptyStation != null)
+                            //{
+                            //    #region 搴撳唴瀛樺湪浠诲姟鍗犵敤
+                            //    //if (EmptyStation.location_state == LocationStateEnum.Busy.ToString())
+                            //    //    continue;
+                            //    #endregion
+
+                            //    //if (agvtaskService.Find(x => x.agv_fromaddress == EmptyStation.stationCode || x.agv_toaddress == EmptyStation.stationCode).Any())
+                            //    //    return;
+                            //    #region 琛ュ簱鍐呯┖鎵樼洏锛屼笉闇�瑕佸厜鐢靛垽鏂�
+                            //    var PalletSignal = Pipeline_client.ReadByOrder<Int16>("R_PalletSignal", task.agv_toaddress);//璇诲彇鎵樼洏淇″彿:1:鏈�,2鏃�
+                            //    var MaterialSignal = Pipeline_client.ReadByOrder<Int16>("R_MaterialSignal", task.agv_toaddress);//璇诲彇璐х墿淇″彿:1:鏈�,2鏃�
+                            //    if (PalletSignal == 2 && MaterialSignal == 2)
+                            //    {
+                            //        task.agv_fromaddress = EmptyStation.stationCode;
+                            //        task.StarQuantity = EmptyStation.quantity - 1;
+                            //        task.agv_taskstate = "Create";
+                            //        agvtaskService.Update(task, true);
+                            //        EmptyStation.location_state = LocationStateEnum.Busy.ToString();
+                            //        stationinfoRepository.Update(EmptyStation, true);
+                            //        WriteDBLog.Success("鏇存柊绌虹洏闃熷垪浠诲姟", $"浠诲姟缂栧彿锛歿task.agv_tasknum}", "PCS");
+                            //    }
+                            //    #endregion
+                            //}
+                            #endregion
                         }
                     }
                     else if (task.agv_tasktype == "TaskType_OutsourceOutbound" || task.agv_tasktype == "TaskType_Outbound")//澶栧崗搴撳嚭搴�/AB搴撳嚭搴�

--
Gitblit v1.9.3