From 6fe4792f1f71389400d075b57fb613d7815b6783 Mon Sep 17 00:00:00 2001
From: cjs <2216046164@qq.com>
Date: 星期四, 10 七月 2025 17:21:51 +0800
Subject: [PATCH] 111

---
 ams/Hanhe.iWCS.JingmenGEMTwoProtocol/ProcessHelper.cs |   98 ++++++++++++++++++++++++++++++++++++++++++++++--
 1 files changed, 93 insertions(+), 5 deletions(-)

diff --git a/ams/Hanhe.iWCS.JingmenGEMTwoProtocol/ProcessHelper.cs b/ams/Hanhe.iWCS.JingmenGEMTwoProtocol/ProcessHelper.cs
index ce7e3bc..3a74ae0 100644
--- a/ams/Hanhe.iWCS.JingmenGEMTwoProtocol/ProcessHelper.cs
+++ b/ams/Hanhe.iWCS.JingmenGEMTwoProtocol/ProcessHelper.cs
@@ -16,10 +16,12 @@
 using System.Net.Configuration;
 using System.Text;
 using System.Web.UI.WebControls.WebParts;
+using static Hanhe.iWCS.JingmenGEMTwoProtocol.ApiHelper;
 using static Hanhe.iWCS.JingmenGEMTwoProtocol.EnentListen;
 using static Hanhe.iWCS.JingmenGEMTwoProtocol.MESHelper;
 using static Hanhe.iWCS.JingmenGEMTwoProtocol.PLCControl;
 using static Hanhe.iWCS.JingmenGEMTwoProtocol.ProtocolAnalysis;
+using static System.Runtime.CompilerServices.RuntimeHelpers;
 
 namespace Hanhe.iWCS.JingmenGEMTwoProtocol
 {
@@ -182,11 +184,27 @@
                     //涓や釜鎺ラ┏骞冲彴
                     if (mst.CN_S_START_BIT == conn1[0].locCode || mst.CN_S_START_BIT == conn1[1].locCode)
                     {
-                        start.CN_N_AGV_LOCATION = Settings.GetDGConnectingbitsList().Where(a => a.locCode == mst.CN_S_START_BIT).First().agvSite[1];
+                        if (mst.CN_S_BUSS_TYPE == "鐢甸挻鐢熶骇閫�簱(浜屾)")
+                        {
+                            start.CN_N_AGV_LOCATION = Settings.GetDGConnectingbitsList().Where(a => a.locCode == mst.CN_S_START_BIT).First().agvSite[0];
+                        }
+                        else
+                        {
+                            start.CN_N_AGV_LOCATION = Settings.GetDGConnectingbitsList().Where(a => a.locCode == mst.CN_S_START_BIT).First().agvSite[1];
+                        }
+                        
                     }
                     if (mst.CN_S_END_BIT == conn1[0].locCode || mst.CN_S_END_BIT == conn1[1].locCode)
                     {
-                        end.CN_N_AGV_LOCATION = Settings.GetDGConnectingbitsList().Where(a => a.locCode == mst.CN_S_END_BIT).First().agvSite[0];
+                        if (mst.CN_S_BUSS_TYPE == "鐢甸挻鐢熶骇閫�簱")
+                        {
+                            end.CN_N_AGV_LOCATION = Settings.GetDGConnectingbitsList().Where(a => a.locCode == mst.CN_S_END_BIT).First().agvSite[1];
+                        }
+                        else
+                        {
+                            end.CN_N_AGV_LOCATION = Settings.GetDGConnectingbitsList().Where(a => a.locCode == mst.CN_S_END_BIT).First().agvSite[0];
+                        }
+                        
                     }
                 }
                 if (conn1.Count == 1)
@@ -194,11 +212,26 @@
                     //涓�釜鎺ラ┏骞冲彴
                     if (mst.CN_S_START_BIT == conn1[0].locCode)
                     {
-                        start.CN_N_AGV_LOCATION = Settings.GetDGConnectingbitsList().Where(a => a.locCode == mst.CN_S_START_BIT).First().agvSite[1];
+                        if(mst.CN_S_BUSS_TYPE == "鐢甸挻鐢熶骇閫�簱(浜屾)")
+                        {
+                            start.CN_N_AGV_LOCATION = Settings.GetDGConnectingbitsList().Where(a => a.locCode == mst.CN_S_START_BIT).First().agvSite[0];
+                        }
+                        else
+                        {
+                            start.CN_N_AGV_LOCATION = Settings.GetDGConnectingbitsList().Where(a => a.locCode == mst.CN_S_START_BIT).First().agvSite[1];
+                        }
+                        
                     }
                     if (mst.CN_S_END_BIT == conn1[0].locCode)
                     {
-                        end.CN_N_AGV_LOCATION = Settings.GetDGConnectingbitsList().Where(a => a.locCode == mst.CN_S_END_BIT).First().agvSite[0];
+                        if(mst.CN_S_BUSS_TYPE == "鐢甸挻鐢熶骇閫�簱")
+                        {
+                            end.CN_N_AGV_LOCATION = Settings.GetDGConnectingbitsList().Where(a => a.locCode == mst.CN_S_END_BIT).First().agvSite[1];
+                        }
+                        else
+                        {
+                            end.CN_N_AGV_LOCATION = Settings.GetDGConnectingbitsList().Where(a => a.locCode == mst.CN_S_END_BIT).First().agvSite[0];
+                        }
                     }
                 }
                 #endregion
@@ -234,7 +267,7 @@
                         }
                     }
                 }
-                if (mst.CN_S_BUSS_TYPE == "缂撳瓨鏋跺叆绔嬪簱" || mst.CN_S_BUSS_TYPE == "鐢甸挻缂撳瓨鏋跺叆绔嬪簱")
+                if (mst.CN_S_BUSS_TYPE == "缂撳瓨鏋跺叆绔嬪簱" || mst.CN_S_BUSS_TYPE == "鐢甸挻缂撳瓨鏋跺叆绔嬪簱" || mst.CN_S_BUSS_TYPE == "鐢甸挻鐢熶骇閫�簱")
                 {
                     TRow = "1";
                 }
@@ -529,6 +562,10 @@
                         result = true;
                     }
                 }
+                if (mst.CN_S_BUSS_TYPE == "鐢甸挻鐢熶骇閫�簱")
+                {
+                    SGTK(mst);
+                }
                 var bussTypeInfo = Settings.GetHouWeiCodeo().Where(a => a.location == mst.Ext1).FirstOrDefault();
                 if (bussTypeInfo != null)
                 {
@@ -592,6 +629,57 @@
         }
 
         /// <summary>
+        /// 鍥涢挻鐢熶骇閫�簱
+        /// 灏嗕换鍔℃媶鍒嗘垚涓ゆ浠诲姟锛岀涓�浠诲姟缁堢偣鏀逛负鎺ラ┏骞冲彴
+        /// 浜屾浠诲姟浠庢帴椹冲钩鍙板叆搴�+        /// </summary>
+        /// <param name="mst"></param>
+        private static void SGTK(TN_I_TASK_MST mst)
+        {
+            var CBInfo = Settings.GetDGConnectingbitsList().Where(a => a.enable == 1).ToList();
+            if (CBInfo != null)
+            {
+                foreach (var a in CBInfo)
+                {
+                    if (!string.IsNullOrEmpty(a.locCode))
+                    {
+                        //鍦ㄤ腑闂磋〃涓煡鎵剧偣浣�+                        var CBTable = MongoDBSingleton.Instance.FindOne<DGConnectingBits>(Query.EQ("Bit", a.locCode), "DGConnectingBits");
+                        if (CBTable != null)
+                        {
+                            if (string.IsNullOrEmpty(CBTable.trayCode))
+                            {
+                                //鏀逛换鍔$殑缁堢偣
+                                MongoDBSingleton.Instance.Update<TN_I_TASK_MST>(Query.EQ("CN_S_TASK_NO", mst.CN_S_TASK_NO), Update.Set("CN_S_END_BIT", a.locCode), UpdateFlags.None);
+
+                                new SqlHelper<object>().ExecuteSql($"update dbo.tn_am_task_mst set CN_S_END_BIT='{a.locCode}',CN_S_END_AGVBIT = '{StockInstance.Instance.GetAGVCodeForBitCode(a.locCode)}' where CN_S_TASK_NO = '{mst.CN_S_TASK_NO}'");
+
+                                CMMLog.Debug($"鐢熶骇閫�簱锛氭洿鏀圭粓鐐规垚鍔燂紒");
+                                MongoDBSingleton.Instance.Update<DGConnectingBits>(Query.EQ("Bit", a.locCode), Update.Set("trayCode", mst.CN_S_BATCH_NO).Set("END_LOC",mst.CN_S_END_BIT), UpdateFlags.None);
+                                break;
+                            }
+                        }
+                        else
+                        {
+                            //鏀逛换鍔$殑缁堢偣
+                            MongoDBSingleton.Instance.Update<TN_I_TASK_MST>(Query.EQ("CN_S_TASK_NO", mst.CN_S_TASK_NO), Update.Set("CN_S_END_BIT", a.locCode), UpdateFlags.None);
+
+                            new SqlHelper<object>().ExecuteSql($"update dbo.tn_am_task_mst set CN_S_END_BIT='{a.locCode}',CN_S_END_AGVBIT = '{StockInstance.Instance.GetAGVCodeForBitCode(a.locCode)}' where CN_S_TASK_NO = '{mst.CN_S_TASK_NO}'");
+
+                            CMMLog.Debug($"鐢熶骇閫�簱锛氭洿鏀圭粓鐐规垚鍔燂紒");
+                            //鎵撳寘涓嬬嚎浠诲姟鐢熸垚鎴愬姛锛屽悜涓棿琛ㄦ彃鍏ユ暟鎹�+
+                            MongoDBSingleton.Instance.Insert<DGConnectingBits>(new DGConnectingBits { Bit = a.locCode, trayCode = mst.CN_S_BATCH_NO,END_LOC = mst.CN_S_END_BIT, state = "0" });
+                            break;
+                        }
+                    }
+                    else CMMLog.Debug("鐢熶骇閫�簱鎺ラ┏浣嶇偣浣嶆湭閰嶇疆");
+                }
+            }
+            else CMMLog.Debug("鐢熶骇閫�簱鎺ラ┏浣嶆湭閰嶇疆");
+        }
+
+        /// <summary>
         /// 杈呮潗鍏ュ簱娴佺▼
         /// </summary>
         /// <param name="mst"></param>

--
Gitblit v1.9.1