From a05b17c400067475a256071c2e92a9f1b3abe343 Mon Sep 17 00:00:00 2001
From: dengjunjie <dengjunjie@hnkhzn.com>
Date: 星期三, 03 七月 2024 18:16:02 +0800
Subject: [PATCH] 桁架模式2

---
 代码管理/PCS/WCS_Server/WIDESEA_WCS/Jobs/equipment/GantryJob.cs               |   11 
 代码管理/PCS/WCS_Server/WIDESEA_WCS/Common/Gantry2.cs                         |  717 +++++++++++++++++++++++++++++++++++++++++++++++++++
 代码管理/PCS/WCS_Server/WIDESEA_WCS/WCSClient/Siemens/SiemensPLCClient.cs     |   13 
 代码管理/PCS/WCS_Server/WIDESEA_WCS/Services/WCS/Partial/dt_patternService.cs |   60 +++-
 代码管理/PCS/WCS_Server/WIDESEA_WCS/Common/Gantry.cs                          |    5 
 5 files changed, 787 insertions(+), 19 deletions(-)

diff --git "a/\344\273\243\347\240\201\347\256\241\347\220\206/PCS/WCS_Server/WIDESEA_WCS/Common/Gantry.cs" "b/\344\273\243\347\240\201\347\256\241\347\220\206/PCS/WCS_Server/WIDESEA_WCS/Common/Gantry.cs"
index 4ab7b03..d56fee2 100644
--- "a/\344\273\243\347\240\201\347\256\241\347\220\206/PCS/WCS_Server/WIDESEA_WCS/Common/Gantry.cs"
+++ "b/\344\273\243\347\240\201\347\256\241\347\220\206/PCS/WCS_Server/WIDESEA_WCS/Common/Gantry.cs"
@@ -27,7 +27,7 @@
 
 namespace WIDESEA_WCS
 {
-    public class Gantry
+    public class Gantry : Gantry2
     {
         #region 鏌ヨ杞﹁疆鏁版嵁
         /// <summary>
@@ -627,7 +627,8 @@
                                 if (!Stations.Where(x => x.enable && x.stationCode != NGStation && x.location_state != LocationStateEnum.Stroge.ToString()).Any())
                                 {
                                     var station = Stations.Where(x => x.enable && x.stationCode != NGStation && x.location_state == LocationStateEnum.Stroge.ToString()).OrderBy(x => x.lastUpdateTime).FirstOrDefault();
-                                    agvtask(stationinfoRepository, station, Work, name == "3鍗曞厓涓嬫枡鍖�" ? "TaskType_OutsourceInbound" : "TaskType_Inbound");
+                                    if (station != null)
+                                        agvtask(stationinfoRepository, station, Work, name == "3鍗曞厓涓嬫枡鍖�" ? "TaskType_OutsourceInbound" : "TaskType_Inbound");
                                 }
                                 #endregion
                             }
diff --git "a/\344\273\243\347\240\201\347\256\241\347\220\206/PCS/WCS_Server/WIDESEA_WCS/Common/Gantry2.cs" "b/\344\273\243\347\240\201\347\256\241\347\220\206/PCS/WCS_Server/WIDESEA_WCS/Common/Gantry2.cs"
new file mode 100644
index 0000000..28b89ca
--- /dev/null
+++ "b/\344\273\243\347\240\201\347\256\241\347\220\206/PCS/WCS_Server/WIDESEA_WCS/Common/Gantry2.cs"
@@ -0,0 +1,717 @@
+锘縰sing HslCommunication;
+using System;
+using System.Collections.Generic;
+using System.Globalization;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using System.Xml.Linq;
+using WIDESEA_Comm;
+using WIDESEA_Comm.LogInfo;
+using WIDESEA_Core.BaseProvider;
+using WIDESEA_Core.EFDbContext;
+using WIDESEA_Entity.DomainModels;
+using WIDESEA_WCS.IRepositories;
+using WIDESEA_WCS.JobsPart.Common;
+using WIDESEA_WCS.Repositories;
+using WIDESEA_WCS.WCSClient;
+using WIDESEA_WMS.IRepositories;
+using WIDESEA_WMS.Repositories;
+using static System.Collections.Specialized.BitVector32;
+
+namespace WIDESEA_WCS
+{
+    public class Gantry2
+    {
+        #region 瑙嗚妫�娴嬭拷婧溅杞俊鎭�
+        /// <summary>
+        /// 瑙嗚妫�娴嬭拷婧溅杞俊鎭�
+        /// </summary>
+        /// <param name="client"></param>
+        public void QuerySJSN(PLCClient client)
+        {
+            VOLContext Context = new VOLContext();
+            Idt_info_traceRepository traceRepository = new dt_info_traceRepository(Context);
+            List<string> names = new List<string>() { "瑙嗚妫�娴�1", "瑙嗚妫�娴�2", "瑙嗚妫�娴�3", "瑙嗚妫�娴�4" };
+            foreach (string name in names)
+            {
+                try
+                {
+                    var Read_Load = client.ReadByOrder<bool>("Read_Load", name);//瑙嗚妫�娴嬪紑濮嬩俊鍙�
+                    if (Read_Load)
+                    {
+                        var PartID_Load = client.ReadByOrder<string>("PartID_Load", name);//杞﹁疆SN鍙�
+                        var State_Load = client.ReadByOrder<Int16>("State_Load ", name);//杞﹁疆鐘舵��
+                        var LoadTime = client.ReadByOrder<string>("LoadTime ", name);//瑙嗚妫�娴嬪紑濮嬫椂闂�
+                        var time = DateTime.ParseExact(LoadTime, "yyyyMMddHHmmss", CultureInfo.CurrentCulture);
+                        var info_trace = traceRepository.Find(x => x.trace_SN == PartID_Load).FirstOrDefault();
+                        if (info_trace != null)
+                        {
+                            info_trace.trace_tcvm_number = name;
+                            info_trace.trace_tcvm_start_time = time;
+                            traceRepository.Update(info_trace, x => new { x.trace_tcvm_number, x.trace_tcvm_start_time }, true);
+                        }
+                        client.WriteByOrder("ReadFinished_Load", true, name);
+                    }
+                    else
+                        client.WriteByOrder("ReadFinished_Load", false, name);
+                    var Read_Unload = client.ReadByOrder<bool>("Read_Unload", name);//瑙嗚妫�娴嬪畬鎴愪俊鍙�
+                    if (Read_Unload)
+                    {
+                        var PartID_Unload = client.ReadByOrder<string>("PartID_Unload", name);//杞﹁疆SN鍙�
+                        var State_Unload = client.ReadByOrder<Int16>("State_Unload  ", name);//杞﹁疆鐘舵��
+                        var UnloadTime = client.ReadByOrder<string>("UnloadTime ", name);//瑙嗚妫�娴嬪紑濮嬫椂闂�
+                        var info_trace = traceRepository.Find(x => x.trace_SN == PartID_Unload).FirstOrDefault();
+                        var time = DateTime.ParseExact(UnloadTime, "yyyyMMddHHmmss", CultureInfo.CurrentCulture);
+                        if (info_trace != null)
+                        {
+                            info_trace.trace_tcvm_finish_time = time;
+                            info_trace.trace_tcvm_statu = State_Unload;
+                            traceRepository.Update(info_trace, x => new { x.trace_tcvm_finish_time, x.trace_tcvm_statu }, true);
+                        }
+                        client.WriteByOrder("ReadFinished_Unload", true, name);
+                    }
+                    else
+                        client.WriteByOrder("ReadFinished_Unload", false, name);
+                }
+                catch (Exception ex)
+                {
+                    WriteLog.Write_Log("鎶ラ敊鏃ュ織", name, "閿欒淇℃伅锛�", $"閿欒淇℃伅锛歿ex.Message}");
+                }
+            }
+        }
+        #endregion
+
+        #region 妯″紡2鏌ヨ杞﹁疆璁㈠崟鍜岃溅杞弬鏁�
+        /// <summary>
+        /// 妯″紡2鏌ヨ杞﹁疆璁㈠崟鍜岃溅杞弬鏁�
+        /// </summary>
+        /// <param name="client"></param>
+        public void QueryWheelOrderData(PLCClient client)
+        {
+            VOLContext Context = new VOLContext();
+            Idt_geometry_dataRepository dataRepository = new dt_geometry_dataRepository(Context);
+            IVV_Mes_WorkinfoRepository workinfoRepository = new VV_Mes_WorkinfoRepository(Context);
+            List<string> names = new List<string>() { "1鍗曞厓鐢宠鏌ヨ璁㈠崟鍜岃溅杞弬鏁�", "2鍗曞厓鐢宠鏌ヨ璁㈠崟鍜岃溅杞弬鏁�", "妫�娴嬩笂鏂欑敵璇锋煡璇㈣鍗曞拰杞﹁疆鍙傛暟" };
+            foreach (var name in names)
+            {
+                try
+                {
+                    var oi_on = client.ReadByOrder<Byte>("oi_on", name); //鐢宠
+
+                    if (oi_on == 1)
+                    {
+                        var wp_id = client.ReadByOrder<string>("o_wp_id", name);
+
+                        #region SN鍙蜂笉鑳戒负绌�
+                        if (string.IsNullOrEmpty(wp_id))
+                        {
+                            client.WriteByOrder("i_status", (byte)0, name);
+                            WriteLog.Write_Log(name, wp_id, "閿欒淇℃伅锛�", $"璇诲彇妗佹灦淇℃伅锛歕n杞﹁疆SN锛歿wp_id}\n\n鍐欏叆妗佹灦淇℃伅锛歕ni_status锛�2\noi_on锛�0\n\n杞﹁疆SN鍙蜂负绌�");
+                            continue;
+                        }
+                        #endregion
+
+                        #region 宸ュ崟涓嶈兘涓虹┖
+                        var Work = workinfoRepository.Find(x => x.SN == wp_id && (name.Contains("妫�娴嬩笂鏂�") ? x.processCode == "28" : x.processCode == "17")).OrderByDescending(x => x.CreateTime).FirstOrDefault();
+                        if (Work == null)
+                        {
+                            client.WriteByOrder("i_status", (byte)2, name);
+                            WriteLog.Write_Log(name, wp_id, "閿欒淇℃伅锛�", $"璇诲彇妗佹灦淇℃伅锛歕n杞﹁疆SN锛歿wp_id}\n\n鍐欏叆妗佹灦淇℃伅锛歕ni_status锛�2\noi_on锛�0\n\n鏈煡璇㈠埌宸ュ崟璇︽儏");
+                            continue;
+                        }
+                        #endregion
+
+                        #region 杞﹁疆鍙傛暟涓嶈兘涓虹┖
+                        var geometry = Pipeline.QueryMateriel(Work.drawingNo);
+                        if (geometry == null)
+                        {
+                            client.WriteByOrder("i_status", (byte)3, name);
+                            WriteLog.Write_Log(name, wp_id, "閿欒淇℃伅锛�", $"璇诲彇妗佹灦淇℃伅锛歕n杞﹁疆SN锛歿wp_id}\n\n鍐欏叆妗佹灦淇℃伅锛歕ni_status锛�3\noi_on锛�0\n\n鍥惧彿锛歿Work.drawingNo}鏈煡璇㈠埌杞﹁疆淇℃伅鍙傛暟");
+                            continue;
+                        }
+                        #endregion
+
+                        #region 鍐欏叆鍙傛暟
+                        client.WriteByOrder("i_stackNoRange", geometry.stackNoRange, name);//鎵撳寘鏁伴噺
+                        client.WriteByOrder("i_drawing_id", Work.drawingNo, name);//鍥惧彿
+                        client.WriteByOrder("i_job_id", Work.jobID, name);//宸ュ崟缂栧彿
+                        client.WriteByOrder("i_heat_id", Work.heatID, name);//鐐変唬鍙�
+                        client.WriteByOrder("i_batch_id", Work.heatBatchID, name);//鐑鐞嗘壒娆�
+
+                        client.WriteByOrder("i_parameter_a", (float)geometry.a, name);
+                        client.WriteByOrder("i_parameter_b", (float)geometry.b, name);
+                        client.WriteByOrder("i_parameter_c", (float)geometry.c, name);
+                        client.WriteByOrder("i_parameter_d", (float)geometry.d, name);
+                        client.WriteByOrder("i_parameter_e", (float)geometry.e, name);
+                        client.WriteByOrder("i_parameter_f", (float)geometry.f, name);
+                        client.WriteByOrder("i_parameter_g", (float)geometry.g, name);
+                        client.WriteByOrder("i_parameter_h", (float)geometry.h, name);
+
+                        client.WriteByOrder("i_status", (byte)1, name);
+                        client.WriteByOrder("i_wp_id", wp_id, name);
+                        #endregion
+                    }
+                }
+                catch (Exception ex)
+                {
+                    WriteLog.Write_Log("鎶ラ敊鏃ュ織", name, "閿欒淇℃伅锛�", $"閿欒淇℃伅锛歿ex.Message}");
+                }
+            }
+        }
+        #endregion
+
+        #region 妯″紡2鍙栨斁鏂欏畬鎴�
+        /// <summary>
+        /// 妯″紡2鍙栨斁鏂欏畬鎴�
+        /// </summary>
+        /// <param name="client"></param>
+        public void Finished(PLCClient client)
+        {
+            VOLContext Context = new VOLContext();
+            Idt_stationinfoRepository stationinfoRepository = new dt_stationinfoRepository(Context);
+            IVV_Mes_WorkinfoRepository workinfoRepository = new VV_Mes_WorkinfoRepository(Context);
+            Idt_mes_detailRepository mes_DetailRepository = new dt_mes_detailRepository(Context);
+            List<string> names = new List<string>() { "1鍗曞厓鍙栨枡鏀炬枡", "2鍗曞厓鍙栨枡鏀炬枡" };
+            foreach (string name in names)
+            {
+                try
+                {
+                    var areaCode = Pipeline.area_code(name.Contains("1鍗曞厓") ? "1鍗曞厓涓嬫枡鍖�" : "2鍗曞厓涓嬫枡鍖�");
+
+
+                    var R_Finished = client.ReadByOrder<Int16>("R_Finished", name); //1锛氬彇鏂欏畬鎴愶紱2锛氭斁鏂欏畬鎴�
+                    var W_Update_Finished = client.ReadByOrder<Int16>("W_Update_Finished", name);//1锛氬彇鏂欏畬鎴愶紱2锛氭斁鏂欏畬鎴�
+
+                    #region 澶嶄綅瀹屾垚淇″彿
+                    if (R_Finished != 1 && W_Update_Finished == 1 || R_Finished != 2 && W_Update_Finished == 2)
+                    {
+                        client.WriteByOrder("W_Update_Finished", (Int16)0, name);
+                    }
+                    #endregion
+
+                    #region 鍙栨枡瀹屾垚
+                    if (R_Finished == 1 && W_Update_Finished != 1)
+                    {
+                        var R_Wheel_id = client.ReadByOrder<string>("R_Wheel_id", name);//杞﹁疆SN鍙�
+                        var R_In_Clamp_Area = client.ReadByOrder<Int16>("R_In_Clamp_Area", name);//涓嬫枡浣嶅彿
+                        var R_IndexNr = client.ReadByOrder<Int16>("R_IndexNr", name); //鎵樼洏涓婄殑绗嚑涓溅杞�
+                        var station = stationinfoRepository.Find(x => x.area == areaCode && x.stationCode.Substring(x.stationCode.Length - 1, 1) == R_In_Clamp_Area.ToString()).FirstOrDefault();
+                        if (station != null)
+                        {
+                            if (!station.bindSN.Contains(R_Wheel_id))
+                            {
+                                client.WriteByOrder("W_IsError", (Int16)5, name);//鎶ヨ
+                                client.WriteByOrder("W_Wheel_id", R_Wheel_id, name);//杞﹁疆SN鍙�
+                                throw new Exception($"鍙栨枡瀹屾垚澶辫触锛佷笅鏂欎綅鍙凤細{station.stationCode}\nW_IsError锛歿5}\n杞﹁疆SN鍙凤細{R_Wheel_id}\n鍙栫鍑犱釜杞﹁疆锛歿R_IndexNr}\n涓嬫枡浣嶈溅杞暟锛歿station.quantity}\n閿欒淇℃伅锛氬綋鍓嶄笅鏂欎綅鏃犳杞﹁疆锛�");
+                            }
+                            var bindSNS = station.bindSN.Split(",");
+                            Updatemes(R_Wheel_id, name);
+                            station.bindSN = OperStr(bindSNS, R_Wheel_id);
+                            var billets = station.billetID.Split(",");
+                            station.billetID = OperStr(billets);
+                            station.quantity = station.quantity - 1;
+                            if (station.quantity <= 0)
+                            {
+                                station.stationType = string.Empty;
+                                station.Number = string.Empty;
+                                station.heatNumber = string.Empty;
+                                station.tray_status = TrayStateEnum.EmptyTray.ToString();
+                            }
+                            var count = stationinfoRepository.Update(station, true);
+                            if (count < 1) throw new Exception($"鍙栨枡瀹屾垚淇℃伅鏇存柊澶辫触锛佷笅鏂欎綅缂栧彿锛歿station.stationCode}");
+
+                            client.WriteByOrder("W_Update_Finished", (Int16)1, name);//1锛氬彇鏂欐洿鏂板畬鎴愶紱2锛氭斁鏂欐洿鏂板畬鎴�
+                            client.WriteByOrder("W_In_Clamp_Area", R_In_Clamp_Area, name);//涓嬫枡浣嶅彿
+                            client.WriteByOrder("W_IndexNr", R_IndexNr, name);//鎵樼洏涓婄殑绗嚑涓溅杞�
+                            client.WriteByOrder("W_Wheel_id", R_Wheel_id, name);//杞﹁疆SN鍙�
+                        }
+                        WriteLog.Write_Log("妯″紡2" + name + "鍙栨枡瀹屾垚", station.stationCode, $"杞﹁疆SN鍙凤細{R_Wheel_id}", $"涓嬫枡浣嶅彿锛歿R_In_Clamp_Area}");
+                    }
+                    #endregion
+
+                    #region 鏀炬枡瀹屾垚
+                    else if (R_Finished == 2 && W_Update_Finished != 2)
+                    {
+                        var R_Wheel_id = client.ReadByOrder<string>("R_Wheel_id", name);//杞﹁疆SN鍙�
+                        var R_In_Clamp_Area = client.ReadByOrder<Int16>("R_In_Clamp_Area", name);//涓嬫枡浣嶅彿
+                        var R_IndexNr = client.ReadByOrder<Int16>("R_IndexNr", name); //鎵樼洏涓婄殑绗嚑涓溅杞�
+                        var station = stationinfoRepository.Find(x => x.area == areaCode && x.stationCode.Substring(x.stationCode.Length - 1, 1) == R_In_Clamp_Area.ToString()).FirstOrDefault();
+                        if (station != null)
+                        {
+                            if (!string.IsNullOrEmpty(station.bindSN))
+                            {
+                                if (station.bindSN.Contains(R_Wheel_id))
+                                {
+                                    client.WriteByOrder("W_IsError", (Int16)5, name);//鎶ヨ
+                                    client.WriteByOrder("W_Wheel_id", R_Wheel_id, name);//杞﹁疆SN鍙�
+                                    throw new Exception($"鏀炬枡瀹屾垚澶辫触锛佷笅鏂欎綅鍙凤細{station.stationCode}\nW_IsError锛歿5}\n杞﹁疆SN鍙凤細{R_Wheel_id}\n鏀剧鍑犱釜杞﹁疆锛歿R_IndexNr}\n涓嬫枡浣嶈溅杞暟锛歿station.quantity}\n閿欒淇℃伅锛氬凡瀛樺湪杞﹁疆SN鍙凤紒");
+                                }
+                            }
+                            var Mes_Work = workinfoRepository.Find(x => x.SN == R_Wheel_id && x.processCode == "17").OrderByDescending(x => x.CreateTime).FirstOrDefault();
+                            #region 璐т綅鐘舵�佹洿鏂�
+                            station.bindSN = string.IsNullOrEmpty(station.bindSN) ? R_Wheel_id : station.bindSN + "," + R_Wheel_id;
+                            station.billetID = string.IsNullOrEmpty(station.billetID) ? Mes_Work.billetID.ToString() : station.billetID + "," + Mes_Work.billetID;
+                            station.quantity++;
+                            if (station.quantity == 1)
+                            {
+                                station.stationType = Mes_Work.drawingNo;
+                                station.Number = Mes_Work.workOrder;
+                                station.heatNumber = Mes_Work.heatID;
+                                station.tray_status = TrayStateEnum.StrogeTray.ToString();
+                            }
+                            var count = stationinfoRepository.Update(station, true);
+                            if (count < 1)
+                                throw new Exception($"鏀炬枡瀹屾垚淇℃伅鏇存柊澶辫触锛佷笅鏂欎綅缂栧彿锛歿station.stationCode}");
+                            #endregion
+
+                            #region 淇敼宸ュ崟鐘舵��
+                            var Detail = mes_DetailRepository.FindFirst(x => x.jobID == Mes_Work.jobID && x.SN == Mes_Work.SN);
+                            Detail.Status = "涓嬬嚎";
+                            Detail.FinishTime = DateTime.Now;
+                            count = mes_DetailRepository.Update(Detail, x => new { x.Status, x.FinishTime }, true);
+                            if (count < 1)
+                                throw new Exception($"宸ュ崟瀛愯〃淇℃伅鏇存柊澶辫触锛佽溅杞甋N鍙凤細{Detail.SN}");
+                            #endregion
+
+                            client.WriteByOrder("W_Update_Finished", (Int16)2, name);//1锛氬彇鏂欐洿鏂板畬鎴愶紱2锛氭斁鏂欐洿鏂板畬鎴�
+                            client.WriteByOrder("W_In_Clamp_Area", R_In_Clamp_Area, name);//涓嬫枡浣嶅彿
+                            client.WriteByOrder("W_IndexNr", R_IndexNr, name);//鎵樼洏涓婄殑绗嚑涓溅杞�
+                            client.WriteByOrder("W_Wheel_id", R_Wheel_id, name);//杞﹁疆SN鍙�
+                        }
+                        WriteLog.Write_Log("妯″紡2" + name + "鏀炬枡瀹屾垚", station.stationCode, $"杞﹁疆SN鍙凤細{R_Wheel_id}", $"涓嬫枡浣嶅彿锛歿R_In_Clamp_Area}");
+                    }
+                    #endregion
+
+                    var R_Request = client.ReadByOrder<Int16>("R_Request", name);//1锛氬彇鏂欙紱2锛氭斁鏂�
+                    #region 鍙栨枡
+                    if (R_Request == 1)
+                    {
+                        var R_Wheel_id = client.ReadByOrder<string>("R_Wheel_id", name);//杞﹁疆SN鍙�
+                        var R_In_Clamp_Area = client.ReadByOrder<Int16>("R_In_Clamp_Area", name);//涓嬫枡浣嶅彿
+                        var R_IndexNr = client.ReadByOrder<Int16>("R_IndexNr", name); //鎵樼洏涓婄殑绗嚑涓溅杞�
+                        var station = stationinfoRepository.Find(x => x.area == areaCode && x.stationCode.Substring(x.stationCode.Length - 1, 1) == R_In_Clamp_Area.ToString()).FirstOrDefault();
+                        if (station != null)
+                        {
+                            var Work = workinfoRepository.Find(x => x.SN == R_Wheel_id && x.processCode == "28").OrderByDescending(x => x.CreateTime).FirstOrDefault();
+                            if (Work == null)
+                            {
+                                client.WriteByOrder("W_IsError", (Int16)5, name);//鎶ヨ
+                                client.WriteByOrder("W_Wheel_id", R_Wheel_id, name);//杞﹁疆SN鍙�
+                                throw new Exception($"鐢宠鍙栨枡澶辫触锛佷笅鏂欎綅鍙凤細{station.stationCode}\nW_IsError锛歿5}\n杞﹁疆SN鍙凤細{R_Wheel_id}\n鍙栫鍑犱釜杞﹁疆锛歿R_IndexNr}\n涓嬫枡浣嶈溅杞暟锛歿station.quantity}\n閿欒淇℃伅锛氭湭鏌ヨ鍒版娴嬪伐鍗曚俊鎭紒");
+                            }
+                            if (!station.bindSN.Contains(R_Wheel_id))
+                            {
+                                client.WriteByOrder("W_IsError", (Int16)5, name);//鎶ヨ
+                                client.WriteByOrder("W_Wheel_id", R_Wheel_id, name);//杞﹁疆SN鍙�
+                                throw new Exception($"鐢宠鍙栨枡澶辫触锛佷笅鏂欎綅鍙凤細{station.stationCode}\nW_IsError锛歿5}\n杞﹁疆SN鍙凤細{R_Wheel_id}\n鍙栫鍑犱釜杞﹁疆锛歿R_IndexNr}\n涓嬫枡浣嶈溅杞暟锛歿station.quantity}\n閿欒淇℃伅锛氬綋鍓嶄笅鏂欎綅鏃犳杞﹁疆锛�");
+                            }
+                            if (station.location_state != LocationStateEnum.Stroge.ToString())
+                            {
+                                client.WriteByOrder("W_IsError", (Int16)4, name);//鍙栨枡涓嶅厑璁�
+                                client.WriteByOrder("W_Wheel_id", R_Wheel_id, name);//杞﹁疆SN鍙�
+                                throw new Exception($"鐢宠鍙栨枡澶辫触锛佷笅鏂欎綅鍙凤細{station.stationCode}\nW_IsError锛歿4}\n杞﹁疆SN鍙凤細{R_Wheel_id}\n鍙栫鍑犱釜杞﹁疆锛歿R_IndexNr}\n涓嬫枡浣嶈溅杞暟锛歿station.quantity}\n閿欒淇℃伅锛氫笅鏂欎綅璐т綅鐘舵�佷笉涓烘湁璐э紒");
+                            }
+                            if (station.quantity != R_IndexNr)
+                            {
+                                client.WriteByOrder("W_IsError", (Int16)5, name);//鎶ヨ
+                                client.WriteByOrder("W_Wheel_id", R_Wheel_id, name);//杞﹁疆SN鍙�
+                                throw new Exception($"鐢宠鍙栨枡澶辫触锛佷笅鏂欎綅鍙凤細{station.stationCode}\nW_IsError锛歿5}\n杞﹁疆SN鍙凤細{R_Wheel_id}\n鍙栫鍑犱釜杞﹁疆锛歿R_IndexNr}\n涓嬫枡浣嶈溅杞暟锛歿station.quantity}\n閿欒淇℃伅锛氭満姊版墜鎶撳彇杞﹁疆涓庝笅鏂欎綅鏁伴噺涓嶅尮閰嶏紒");
+                            }
+                            client.WriteByOrder("W_In_Clamp_Area", (Int16)R_In_Clamp_Area, name);
+                            client.WriteByOrder("W_IndexNr", (Int16)R_IndexNr, name);
+                            client.WriteByOrder("W_IsError", (Int16)3, name);//鍙栨枡鍏佽
+                            client.WriteByOrder("W_Wheel_id", R_Wheel_id, name);//杞﹁疆SN鍙�
+                        }
+                        else
+                        {
+                            client.WriteByOrder("W_IsError", (Int16)5, name);//鎶ヨ
+                            client.WriteByOrder("W_Wheel_id", R_Wheel_id, name);//杞﹁疆SN鍙�
+                            throw new Exception($"鐢宠鍙栨枡澶辫触锛佷笅鏂欎綅鍙凤細{R_In_Clamp_Area}锛沇_IsError锛歿5},鏈尮閰嶅埌涓嬫枡浣嶅彿锛�");
+                        }
+                        WriteLog.Write_Log("妯″紡2" + name + "鐢宠鍙栨枡", station.stationCode, $"W_IsError锛歿3},杞﹁疆SN鍙凤細{R_Wheel_id}", $"涓嬫枡浣嶅彿锛歿R_In_Clamp_Area}\n鍙栫鍑犱釜杞﹁疆锛歿R_IndexNr}锛沑n涓嬫枡浣嶈溅杞暟锛歿station.quantity}");
+                    }
+                    #endregion
+
+                    #region 鏀炬枡
+                    else if (R_Request == 2)
+                    {
+                        var R_Wheel_id = client.ReadByOrder<string>("R_Wheel_id", name);//杞﹁疆SN鍙�
+                        var R_In_Clamp_Area = client.ReadByOrder<Int16>("R_In_Clamp_Area", name);//涓嬫枡浣嶅彿
+                        var R_IndexNr = client.ReadByOrder<Int16>("R_IndexNr", name); //鎵樼洏涓婄殑绗嚑涓溅杞�
+                        var R_PartStatus = client.ReadByOrder<Int16>("R_PartStatus", name);//杞﹁疆鐘舵��
+                        var station = stationinfoRepository.Find(x => x.area == areaCode && x.stationCode.Substring(x.stationCode.Length - 1, 1) == R_In_Clamp_Area.ToString()).FirstOrDefault();
+                        if (station != null)
+                        {
+                            if (!string.IsNullOrEmpty(station.bindSN))
+                            {
+                                if (station.bindSN.Contains(R_Wheel_id))
+                                {
+                                    client.WriteByOrder("W_IsError", (Int16)5, name);//鎶ヨ
+                                    client.WriteByOrder("W_Wheel_id", R_Wheel_id, name);//杞﹁疆SN鍙�
+                                    throw new Exception($"鐢宠鏀炬枡澶辫触锛佷笅鏂欎綅鍙凤細{station.stationCode}\nW_IsError锛歿5}\n杞﹁疆SN鍙凤細{R_Wheel_id}\n鏀剧鍑犱釜杞﹁疆锛歿R_IndexNr}\n涓嬫枡浣嶈溅杞暟锛歿station.quantity}\n閿欒淇℃伅锛氬凡瀛樺湪杞﹁疆SN鍙凤紒");
+                                }
+                            }
+                            if (station.location_state != LocationStateEnum.Stroge.ToString())
+                            {
+                                client.WriteByOrder("W_IsError", (Int16)2, name);//鏀炬枡涓嶅厑璁�
+                                client.WriteByOrder("W_Wheel_id", R_Wheel_id, name);//杞﹁疆SN鍙�
+                                throw new Exception($"鐢宠鏀炬枡澶辫触锛佷笅鏂欎綅鍙凤細{station.stationCode}\nW_IsError锛歿2}\n杞﹁疆SN鍙凤細{R_Wheel_id}\n鏀剧鍑犱釜杞﹁疆锛歿R_IndexNr}\n涓嬫枡浣嶈溅杞暟锛歿station.quantity}\n閿欒淇℃伅锛氫笅鏂欎綅璐т綅鐘舵�佷笉涓烘湁璐э紒");
+                            }
+                            if (station.quantity + 1 != R_IndexNr)
+                            {
+                                client.WriteByOrder("W_IsError", (Int16)5, name);//鎶ヨ
+                                client.WriteByOrder("W_Wheel_id", R_Wheel_id, name);//杞﹁疆SN鍙�
+                                throw new Exception($"鐢宠鏀炬枡澶辫触锛佷笅鏂欎綅鍙凤細{station.stationCode}\nW_IsError锛歿5}\n杞﹁疆SN鍙凤細{R_Wheel_id}\n鏀剧鍑犱釜杞﹁疆锛歿R_IndexNr}\n涓嬫枡浣嶈溅杞暟锛歿station.quantity}\n閿欒淇℃伅锛氭満姊版墜鏀炬枡杞﹁疆涓庝笅鏂欎綅鏁伴噺涓嶅尮閰嶏紒");
+                            }
+                            client.WriteByOrder("W_In_Clamp_Area", (Int16)R_In_Clamp_Area, name);
+                            client.WriteByOrder("W_IndexNr", (Int16)R_IndexNr, name);
+                            client.WriteByOrder("W_IsError", (Int16)1, name);//鏀炬枡鍏佽
+                            client.WriteByOrder("W_Wheel_id", R_Wheel_id, name);//杞﹁疆SN鍙�
+                        }
+                        else
+                        {
+                            client.WriteByOrder("W_IsError", (Int16)5, name);//鎶ヨ
+                            client.WriteByOrder("W_Wheel_id", R_Wheel_id, name);//杞﹁疆SN鍙�
+                            throw new Exception($"鐢宠鏀炬枡澶辫触锛佷笅鏂欎綅鍙凤細{R_In_Clamp_Area}锛涙湭鍖归厤鍒颁笅鏂欎綅鍙凤紒");
+                        }
+                        WriteLog.Write_Log("妯″紡2" + name + "鐢宠鏀炬枡", station.stationCode, $"W_IsError锛歿1},杞﹁疆SN鍙凤細{R_Wheel_id}", $"涓嬫枡浣嶅彿锛歿R_In_Clamp_Area}\n鏀剧鍑犱釜杞﹁疆锛歿R_IndexNr}\n涓嬫枡浣嶈溅杞暟锛歿station.quantity}\n杞﹁疆鐘舵�侊細{R_PartStatus}");
+                    }
+                    #endregion
+
+
+                }
+                catch (Exception ex)
+                {
+                    WriteLog.Write_Log("鎶ラ敊鏃ュ織", name, "閿欒淇℃伅锛�", $"閿欒淇℃伅锛歿ex.Message}");
+                }
+            }
+        }
+        #endregion
+
+        #region 妯″紡2NG杞﹁疆涓嬫枡
+        /// <summary>
+        /// 妯″紡2NG杞﹁疆涓嬫枡(鍚堝苟鍒版ā寮�2鍙栨斁鏂欏畬鎴�)
+        /// </summary>
+        /// <param name="client"></param>
+        public void NGLayofflevel(PLCClient client)
+        {
+            VOLContext Context = new VOLContext();
+            Idt_stationinfoRepository stationinfoRepository = new dt_stationinfoRepository(Context);
+            Idt_mes_detailRepository mes_DetailRepository = new dt_mes_detailRepository(Context);
+            Idt_plcinfodetailRepository plcRepository = new dt_plcinfodetailRepository(Context);
+            Idt_plcinfoheadRepository repository = new dt_plcinfoheadRepository(Context);
+            IVV_Mes_WorkinfoRepository workinfoRepository = new VV_Mes_WorkinfoRepository(Context);
+            var Pipeline_client = PLCClient.Clients.FirstOrDefault(t => t.PLCName == "閾炬潯鏈�");
+            if (Pipeline_client == null) throw new Exception("閾炬潯鏈鸿皟搴︽湇鍔℃湭寮�鍚紒");
+            if (!Pipeline_client.IsConnected) throw new Exception("涓庨摼鏉℃満杩炴帴瓒呮椂锛�");
+            var Pipelineplc = repository.FindFirst(x => x.plcinfo_name == Pipeline_client.PLCName);
+            List<string> names = new List<string>() { "X01001003", "X02001003" };
+            foreach (var name in names)
+            {
+                try
+                {
+                    var Area = name == "X01001003" ? "5" : "6";
+                    #region 涓嬫枡瀹屾垚
+                    var finished = client.ReadByOrder<Boolean>("o_load_finished ", name);//鏀炬枡瀹屾垚
+                    var updatefinished = client.ReadByOrder<Boolean>("i_storage_update ", name);//璐т綅鐘舵�佹洿鏂�
+
+                    #region 璐т綅鐘舵�佹洿鏂板浣�
+                    if (!finished && updatefinished)
+                    {
+                        client.WriteByOrder("i_storage_update", false, name);//璐т綅鐘舵�佹洿鏂�
+                        #region 鏃ュ織璁板綍
+                        WriteLog.Write_Log("妯″紡2" + name + "鏀炬枡瀹屾垚", name + "璐т綅鐘舵�佹洿鏂颁俊鍙峰浣�", "鎴愬姛锛�",
+                            $"璇诲彇妗佹灦淇℃伅锛歕n鏀炬枡瀹屾垚淇″彿锛歿finished}\n\n鍐欏叆妗佹灦淇℃伅锛歕n璐т綅鐘舵�佹洿鏂颁俊鍙凤細{false}");
+                        #endregion
+                    }
+                    #endregion
+
+                    if (finished && !updatefinished)
+                    {
+                        client.WriteByOrder("i_enabl_load", false, name);//鏄惁鍏佽
+
+                        #region 璇诲彇妗佹灦淇℃伅
+                        var WheelType = client.ReadByOrder<Int16>("o_wheel_type ", name); //杞﹁疆绫诲瀷
+                        var Wheel_SN = client.ReadByOrder<string>("o_wheel_id", name);//杞﹁疆SN鍙�
+                        if (string.IsNullOrEmpty(Wheel_SN))
+                        {
+                            WriteLog.Write_Log("妯″紡2" + name + "鏀炬枡瀹屾垚鍑洪敊", "杞﹁疆SN鍙蜂负绌�", "璇诲彇妗佹灦淇℃伅锛�", $"杞﹁疆SN鍙凤細{Wheel_SN}涓虹┖");
+                            continue;
+                        }
+
+                        var Mes_Work = workinfoRepository.Find(x => x.SN == Wheel_SN && x.processCode == "17").OrderByDescending(x => x.CreateTime).FirstOrDefault();
+                        if (Mes_Work == null)
+                        {
+                            WriteLog.Write_Log("妯″紡2" + name + "鏀炬枡瀹屾垚鍑洪敊", Wheel_SN, "璇诲彇妗佹灦淇℃伅锛�", $"杞﹁疆SN鍙凤細{Wheel_SN}鏈煡璇㈠埌宸ュ崟淇℃伅");
+                            continue;
+                        }
+                        #endregion
+
+                        var AreaNr = client.ReadByOrder<Int16>("i_areaNr", name);
+                        if (AreaNr == 0)
+                        {
+                            client.WriteByOrder("i_storage_update", true, name);//璐т綅鐘舵�佹洿鏂�
+                            continue;
+                        }
+
+                        #region 鍒ゆ柇鍖哄煙鍙锋槸鍚︿竴鑷�
+                        var area = client.ReadByOrder<Int16>("o_place_prog", name);//鏀炬枡瀹屾垚鐨勫尯鍩熷彿
+
+                        if (AreaNr != area)
+                        {
+                            Pipeline_client.WriteByOrder("W_AlarmSignal", (Int16)2, name);//鎶ヨ
+                            WriteLog.Write_Log("妯″紡2" + name + "鏀炬枡瀹屾垚鍑洪敊", Wheel_SN, "鍒ゆ柇鍖哄煙鍙锋槸鍚︿竴鑷�", $"PCS鍖哄煙鍙凤細{AreaNr}锛沑n妗佹灦鍖哄煙鍙凤細{area}\n閿欒淇℃伅锛歅CS鍖哄煙鍙蜂笌妗佹灦鍖哄煙鍙蜂笉涓�鑷达紒");
+                            continue;
+                        }
+                        #endregion
+
+                        var station = stationinfoRepository.Find(x => x.stationCode == name && x.stationCode.Substring(x.stationCode.Length - 1, 1) == AreaNr.ToString() && x.enable).FirstOrDefault();
+                        if (station != null)
+                        {
+                            #region 鍒ゆ柇杞﹁疆鏁伴噺鏄惁涓�鑷�
+                            var quantity = client.ReadByOrder<Int16>("o_pos_prog", name);//妗佹灦璁板綍鐨勮溅杞暟閲�
+
+                            if (quantity != station.quantity + 1)
+                            {
+                                Pipeline_client.WriteByOrder("W_AlarmSignal", (Int16)2, name);//鎶ヨ
+                                WriteLog.Write_Log("妯″紡2" + name + "鏀炬枡瀹屾垚鍑洪敊", Wheel_SN, "鍒ゆ柇杞﹁疆鏁伴噺鏄惁涓�鑷�", $"鍖哄煙鍙凤細{AreaNr}锛沑n妗佹灦杞﹁疆鏁帮細{quantity}\nPCS杞﹁疆鏁帮細{station.quantity + 1}\n閿欒淇℃伅锛歅CS鍖哄煙鍙蜂笌妗佹灦鍖哄煙鍙蜂笉涓�鑷达紒");
+                                continue;
+                            }
+                            #endregion
+
+                            if (!string.IsNullOrEmpty(station.bindSN))
+                            {
+                                if (station.bindSN.Contains(Wheel_SN))
+                                    throw new Exception($"{station.stationCode}宸插瓨鍦ㄨ溅杞甋N鍙凤細{Wheel_SN}");
+                            }
+
+                            #region 娓呯┖缁欐鏋剁殑涓嬫枡淇℃伅
+                            client.WriteByOrder("i_indexNr", (Int16)0, name);//鎵樼洏涓婄殑绗嚑涓溅杞�
+                            client.WriteByOrder("i_storage_type", (Int16)0, name);//鎵樼洏绫诲瀷1-妯斁;2-绔栨斁(鏆傛椂鍙湁妯斁鎵樼洏)
+                            client.WriteByOrder("i_areaNr", (Int16)0, name);//鍖哄煙璐т綅鍙�
+                            client.WriteByOrder("i_storage_update", true, name);//璐т綅鐘舵�佹洿鏂�
+                            WriteLog.Write_Log("妯″紡2" + name + "鏀炬枡瀹屾垚", Wheel_SN, "鎴愬姛锛�",
+                                $"璇诲彇妗佹灦淇℃伅锛歕n鏀炬枡瀹屾垚淇″彿锛歿finished}\n杞﹁疆SN锛歿Wheel_SN}\n杞瀷ID锛歿WheelType}\n涓嬫枡浣嶅彿锛歿AreaNr}\n\n" +
+                                $"澶勭悊鍐欏叆妗佹灦淇℃伅锛歕n鍖哄煙璐т綅鍙凤細{0}\n鎵樼洏涓婄殑绗嚑涓溅杞細{0}\n鎵樼洏绫诲瀷锛歿0}\n\n" +
+                                $"鍐欏叆妗佹灦淇℃伅锛歕n璐т綅鐘舵�佹洿鏂颁俊鍙凤細{true}\n鏄惁鍏佽涓嬫枡锛歿false}");
+                            #endregion
+
+                            #region 璐т綅鐘舵�佹洿鏂�
+                            station.bindSN = string.IsNullOrEmpty(station.bindSN) ? Wheel_SN : station.bindSN + "," + Wheel_SN;
+                            station.billetID = string.IsNullOrEmpty(station.billetID) ? Mes_Work.billetID.ToString() : station.billetID + "," + Mes_Work.billetID;
+                            station.quantity++;
+                            if (station.quantity == 1)
+                            {
+                                station.stationType = Mes_Work.drawingNo;
+                                station.Number = Mes_Work.workOrder;
+                                station.heatNumber = Mes_Work.heatID;
+                                station.tray_status = "StrogeTray";
+                            }
+                            station.remark = "";
+                            var count = stationinfoRepository.Update(station, true);
+                            if (count < 1)
+                                throw new Exception($"涓嬫枡浣嶄俊鎭洿鏂板け璐ワ紒涓嬫枡浣嶇紪鍙凤細{station.stationCode}");
+                            #endregion
+
+                            #region 淇敼宸ュ崟鐘舵��
+                            var Detail = mes_DetailRepository.FindFirst(x => x.jobID == Mes_Work.jobID && x.SN == Mes_Work.SN);
+                            Detail.Status = "涓嬬嚎";
+                            Detail.FinishTime = DateTime.Now;
+                            count = mes_DetailRepository.Update(Detail, x => new { x.Status, x.FinishTime }, true);
+                            if (count < 1)
+                                throw new Exception($"宸ュ崟瀛愯〃淇℃伅鏇存柊澶辫触锛佽溅杞甋N鍙凤細{Detail.SN}");
+                            #endregion
+                        }
+                    }
+                    #endregion
+
+                    #region 涓嬫枡浣嶆暟閲忎紶缁欐鏋�
+                    var Stations = stationinfoRepository.Find(x => x.area == Area).ToList();
+                    foreach (var station in Stations)
+                    {
+                        client.WriteByOrder(station.stationCode, (Int16)station.quantity, name);
+                    }
+                    #endregion
+                    var Station = Stations.Where(x => x.stationCode == name).FirstOrDefault();
+                    //if (Station.enable)
+                    //    client.WriteByOrder(Station.stationCode, Station.location_state != LocationStateEnum.Stroge.ToString(), name);
+
+                    #region 鐢宠涓嬫枡
+                    var Request_Load = client.ReadByOrder<Boolean>("o_request_load ", name);//涓嬫枡鐢宠
+                    if (Request_Load)
+                    {
+                        #region 璇诲彇妗佹灦淇℃伅
+                        var Wheel_Type = client.ReadByOrder<Int16>("o_wheel_type", name);//杞﹁疆绫诲瀷
+                        var Wheel_id = client.ReadByOrder<string>("o_wheel_id", name);//杞﹁疆SN鍙�
+                        if (string.IsNullOrEmpty(Wheel_id))
+                        {
+                            WriteLog.Write_Log("妯″紡2" + name + "鐢宠鏀炬枡寮傚父", "杞﹁疆SN鍙蜂负绌�", "", $"璇诲彇妗佹灦淇℃伅锛歕n杞﹁疆SN鍙凤細{Wheel_id}涓虹┖");
+                            continue;
+                        }
+                        var Work = workinfoRepository.Find(x => x.SN == Wheel_id && x.processCode == "17").OrderByDescending(x => x.CreateTime).FirstOrDefault();
+                        if (Work == null)
+                        {
+                            client.WriteByOrder("i_enabl_load", false, name);//淇″彿涓篺alse妗佹灦鍋滄杩涘叆
+                            WriteLog.Write_Log("妯″紡2" + name + "鐢宠鏀炬枡寮傚父", Wheel_id, "鏌ヨ鏈哄姞宸ュ伐鍗�", $"璇诲彇妗佹灦淇℃伅锛歕n杞﹁疆SN鍙凤細{Wheel_id}鏈煡璇㈠埌宸ュ崟淇℃伅\n鍐欏叆妗佹灦淇℃伅锛歕n鏄惁鍏佽涓嬫枡锛歿false}");
+                            continue;
+                        }
+                        #endregion
+
+                        var wheel = Pipeline.QueryMateriel(Work.drawingNo);
+                        if (wheel == null)
+                        {
+                            client.WriteByOrder("i_enabl_load", false, name);//淇″彿涓篺alse妗佹灦鍋滄杩涘叆
+                            WriteLog.Write_Log("妯″紡2" + name + "鐢宠鏀炬枡寮傚父", Wheel_id, $"鏌ヨ{Work.drawingNo}杞﹁疆鍙傛暟", $"璇诲彇妗佹灦淇℃伅锛歕n杞﹁疆SN鍙凤細{Wheel_id}鏈煡璇㈠埌宸ュ崟淇℃伅\n鍐欏叆妗佹灦淇℃伅锛歕n鏄惁鍏佽涓嬫枡锛歿false}");
+                            continue;
+                        }
+
+                        #region 鎹㈠浘鍙�,涓嬫枡鍙e叾浠栧浘鍙锋墭鐩樺叏閮ㄥ叆搴�
+                        if (Station.enable && Station.location_state == LocationStateEnum.Stroge.ToString() && Station.quantity > 0 && Station.stationType != Work.drawingNo)
+                        {
+                            agvtask(stationinfoRepository, Station, Work, "TaskType_OutsourceInbound");
+                            continue;
+                        }
+
+                        #endregion
+
+                        #region 鎵樼洏绫诲瀷涓嶄竴鑷撮渶鏇存崲鎵樼洏
+                        if (Station.enable && Station.tray_type != "LargeTray" && wheel.e > 1100)
+                        {
+                            client.WriteByOrder("i_enabl_load", false, name);//淇″彿涓篺alse妗佹灦鍋滄杩涘叆
+                            Station.location_state = LocationStateEnum.Trayswitching.ToString();
+                            stationinfoRepository.Update(Station, x => new { x.location_state }, true);
+                            continue;
+                        }
+                        #endregion
+
+                        var PartStatus = client.ReadByOrder<Int16>("o_partstatus ", name);//1:ok;2:nok
+
+                        var load_zone = client.ReadByOrder<Boolean>("o_load_zone ", name);// 杩涘叆涓嬫枡鍖�
+                        if (load_zone) continue;
+                        WriteLog.Write_Log("妯″紡2" + name + "鐢宠鏀炬枡", Wheel_id, "鐢宠鏀炬枡", $"璇诲彇妗佹灦淇℃伅锛歕n杞﹁疆SN锛歿Wheel_id}\n杞瀷ID锛歿Wheel_Type}\n杞﹁疆鐘舵�侊細{PartStatus}\n鏄惁杩涘叆涓嬫枡鍖猴細{load_zone}");
+
+                        if ((Int16)PartStatus == 2)
+                        {
+                            if (!(Station.enable && Station.location_state == LocationStateEnum.Stroge.ToString() && Station.quantity < wheel.stackNoRange && Station.stationType == Work.drawingNo))
+                            {
+                                if (Station.enable && Station.location_state == LocationStateEnum.Stroge.ToString() && Station.quantity > 0)
+                                {
+                                    agvtask(stationinfoRepository, Station, Work, "TaskType_OutsourceInbound");
+                                    continue;
+                                }
+                                if (!(Station.enable && Station.location_state == LocationStateEnum.Stroge.ToString() && Station.quantity == 0)) continue;
+                            }
+                            var Pipelinedetails = plcRepository.Find(x => x.plcdetail_iotype == Pipelineplc.plcinfo_iotyep && x.plcdetail_number == Station.stationCode).ToList();
+                            var PalletSignal = (Int16)DBExtension.Read(Pipelinedetails.Where(x => x.plcdetail_name == "R_PalletSignal").First(), Pipeline_client);//璇诲彇鎵樼洏淇″彿:1:鏈�,2鏃�
+                            var MaterialSignal = (Int16)DBExtension.Read(Pipelinedetails.Where(x => x.plcdetail_name == "R_MaterialSignal").First(), Pipeline_client);//璇诲彇璐х墿淇″彿:1:鏈�,2鏃�
+                            if (PalletSignal == 1)
+                            {
+                                List<string> list = new List<string>();
+                                if (Station.bindSN != null)
+                                {
+                                    var SNS = Station.bindSN.Split(",");
+                                    foreach (var SN in SNS)
+                                    {
+                                        if (!string.IsNullOrEmpty(SN))
+                                            list.Add(SN);
+                                    }
+                                }
+
+
+                                //缂撳瓨鏋朵笂杞﹁疆鏁伴噺涓嶴N鍙锋暟閲忎笉涓�鑷�
+                                if (list.Count != Station.quantity)
+                                {
+                                    Station.location_state = LocationStateEnum.Abnormal.ToString();
+                                    Station.remark = "杞﹁疆鏁伴噺涓嶴N鍙锋暟閲忎笉涓�鑷�";
+                                    stationinfoRepository.Update(Station, x => new { x.location_state, x.remark }, true);
+                                    continue;
+                                }
+                                var area = Convert.ToInt16(Station.stationCode.Substring(Station.stationCode.Length - 1, 1));
+                                client.WriteByOrder("i_areaNr", (Int16)area, name);//鍖哄煙璐т綅鍙�
+                                client.WriteByOrder("i_indexNr", (Int16)(Station.quantity + 1), name);//鎵樼洏涓婄殑绗嚑涓溅杞�
+                                client.WriteByOrder("i_storage_type", (Int16)1, name);//鎵樼洏绫诲瀷1-妯斁;2-绔栨斁(鏆傛椂鍙湁妯斁鎵樼洏)
+                                client.WriteByOrder("i_enabl_load", true, name);//鏄惁鍏佽
+                                Station.remark = "妗佹灦涓嬫枡";
+                                stationinfoRepository.Update(Station, x => new { x.remark }, true);
+                                #region 鏃ュ織璁板綍
+                                WriteLog.Write_Log("妯″紡2" + name + "鐢宠鏀炬枡", Wheel_id, "鍏佽鏀炬枡",
+                                    $"璇诲彇妗佹灦淇℃伅锛歕n杞﹁疆SN锛歿Wheel_id}\n杞瀷ID锛歿Wheel_Type}\n杞﹁疆鐘舵�侊細鍚堟牸" +
+                                    $"\n璇诲彇鎵樼洏鍏夌數淇″彿锛歿PalletSignal}" +
+                                    $"\n\n鍐欏叆妗佹灦淇℃伅锛歕n涓嬫枡浣嶅彿锛歿area}\n绗嚑涓溅杞細{(Station.quantity + 1)}\n鎵樼洏绫诲瀷锛�1\n鏄惁鍏佽涓嬫枡锛歵rue");
+                                #endregion
+                                continue;
+                            }
+                        }
+                    }
+                    #endregion
+                }
+                catch (Exception ex)
+                {
+                    WriteLog.Write_Log("鎶ラ敊鏃ュ織", "妯″紡2NG杞﹁疆涓嬫枡", name, $"閿欒淇℃伅锛歿ex.Message}");
+                }
+            }
+        }
+        #endregion
+        public static string OperStr(string[] strArrty, string SN)
+        {
+            string[] newstr = strArrty.Where(x => x != SN).ToArray();
+            string Newsn = string.Join(",", newstr);
+
+            return Newsn;
+        }
+
+        public string OperStr(string[] strArrty)
+        {
+            string[] newstr = strArrty.RemoveLast(1);
+            string Newsn = string.Join(",", newstr);
+
+            return Newsn;
+        }
+
+        /// <summary>
+        /// 鏇存敼宸ュ崟鐘舵��
+        /// </summary>
+        /// <param name="SN"></param>
+        public static void Updatemes(string SN, string name)
+        {
+            VOLContext Context = new VOLContext();
+            Idt_mes_detailRepository mes_DetailRepository = new dt_mes_detailRepository(Context);
+            Idt_mes_headRepository mes_HeadRepository = new dt_mes_headRepository(Context);
+            IVV_Mes_WorkinfoRepository workinfoRepository = new VV_Mes_WorkinfoRepository(Context);
+            var Mes_Work = workinfoRepository.Find(x => x.SN == SN && (name.Contains("2鍗曞厓鍙栨枡鏀炬枡") ? x.processCode == "28" : x.processCode == "17")).FirstOrDefault();
+            if (Mes_Work != null)
+            {
+                var mes_Detail = mes_DetailRepository.Find(x => x.SN == SN && x.jobID == Mes_Work.jobID).FirstOrDefault();
+                if (mes_Detail != null)
+                {
+                    mes_Detail.Status = "涓婄嚎";
+                    mes_Detail.FinishTime = DateTime.Now;
+                    mes_DetailRepository.Update(mes_Detail, x => new { x.Status, x.FinishTime }, true);
+                    var mes_Head = mes_HeadRepository.Find(x => x.jobID == mes_Detail.jobID).FirstOrDefault();
+                    if (mes_Head != null)
+                    {
+                        mes_Head.finishNum++;
+                        if (mes_Head.finishNum == mes_Head.quantity) mes_Head.FinishTime = DateTime.Now;
+                        mes_HeadRepository.Update(mes_Head, x => new { x.finishNum, x.FinishTime }, true);
+                    }
+                }
+            }
+        }
+
+        #region 涓嬫枡浣嶆坊鍔犻槦鍒椾换鍔�
+        public void agvtask(Idt_stationinfoRepository stationinfoRepository, dt_stationinfo stationinfo, VV_Mes_Workinfo Work, string tasktype)
+        {
+            VOLContext Context = new VOLContext();
+            Idt_agvtaskRepository agvtaskRepository = new dt_agvtaskRepository(Context);
+            IVV_Mes_WorkinfoRepository workinfoRepository = new VV_Mes_WorkinfoRepository(Context);
+            Work = workinfoRepository.Find(x => x.workOrder == stationinfo.Number && x.processCode == "17").FirstOrDefault();
+            var task = agvtaskRepository.Find(x => x.agv_fromaddress == stationinfo.stationCode).FirstOrDefault();
+            if (task != null) return;
+            if (!string.IsNullOrEmpty(Work.area))
+                tasktype = "TaskType_OutsourceInbound";
+            AGVTask.AddQueueTask(stationinfoRepository, agvtaskRepository, stationinfo, tasktype, Work);
+        }
+        #endregion
+    }
+}
diff --git "a/\344\273\243\347\240\201\347\256\241\347\220\206/PCS/WCS_Server/WIDESEA_WCS/Jobs/equipment/GantryJob.cs" "b/\344\273\243\347\240\201\347\256\241\347\220\206/PCS/WCS_Server/WIDESEA_WCS/Jobs/equipment/GantryJob.cs"
index 21d47a4..d86db37 100644
--- "a/\344\273\243\347\240\201\347\256\241\347\220\206/PCS/WCS_Server/WIDESEA_WCS/Jobs/equipment/GantryJob.cs"
+++ "b/\344\273\243\347\240\201\347\256\241\347\220\206/PCS/WCS_Server/WIDESEA_WCS/Jobs/equipment/GantryJob.cs"
@@ -44,9 +44,18 @@
             }
             client.WriteByOrder("W_Palpitate", client.ReadByOrder<bool>("R_Palpitate", "蹇冭烦"));
             Gantry gantry = new Gantry();
+
+            #region 妯″紡1
             gantry.QueryOrder(client);
             gantry.QueryWheeldata(client);
-            gantry.Layofflevel(client);
+            gantry.Layofflevel(client);//妯″紡1/2涓夊崟鍏冮兘浣跨敤杩欎釜鏂规硶涓嬫枡
+            #endregion
+
+            #region 妯″紡2
+            gantry.QueryWheelOrderData(client);
+            gantry.Finished(client); 
+            #endregion
+            //gantry.QuerySJSN(client);//瑙嗚閲囬泦
         }
     }
 }
diff --git "a/\344\273\243\347\240\201\347\256\241\347\220\206/PCS/WCS_Server/WIDESEA_WCS/Services/WCS/Partial/dt_patternService.cs" "b/\344\273\243\347\240\201\347\256\241\347\220\206/PCS/WCS_Server/WIDESEA_WCS/Services/WCS/Partial/dt_patternService.cs"
index 7cf9eb8..1d9eb35 100644
--- "a/\344\273\243\347\240\201\347\256\241\347\220\206/PCS/WCS_Server/WIDESEA_WCS/Services/WCS/Partial/dt_patternService.cs"
+++ "b/\344\273\243\347\240\201\347\256\241\347\220\206/PCS/WCS_Server/WIDESEA_WCS/Services/WCS/Partial/dt_patternService.cs"
@@ -23,6 +23,8 @@
 using WIDESEA_WCS.Repositories;
 using WIDESEA_Comm;
 using WIDESEA_WCS.WCSClient;
+using System.Xml.Linq;
+using OfficeOpenXml.FormulaParsing.Excel.Functions.Math;
 
 namespace WIDESEA_WCS.Services
 {
@@ -53,6 +55,8 @@
             WebResponseContent content = new WebResponseContent();
             try
             {
+                var model = JsonConvert.DeserializeObject<dt_pattern>(v);
+                if (model.pattern_state == 1) throw new Exception("褰撳墠灏辨槸妯″紡1");
                 var Gantry_client = PLCClient.Clients.FirstOrDefault(t => t.PLCName == "妗佹灦");
                 if (Gantry_client == null) throw new Exception("妗佹灦璋冨害鏈嶅姟鏈紑鍚紒");
                 if (!Gantry_client.IsConnected) throw new Exception("涓庢鏋惰繛鎺ヨ秴鏃讹紒");
@@ -61,17 +65,29 @@
                 var stations = stationinfoRepository.Find(x => x.stationCode == "X01001001" || x.stationCode == "X01001002" || x.stationCode == "X02001001" || x.stationCode == "X02001002").ToList();
                 if (stations.Where(x => x.tray_status == TrayStateEnum.StrogeTray.ToString()).Any())
                     throw new Exception("璁剧疆涓烘ā寮�1澶辫触锛佷笅鏂欎綅瀛樺湪杞﹁疆锛�");
+
+
                 #region 鍐欏叆淇″彿鍛婅瘔妗佹灦鍒囨崲妯″紡
-
+                var ok = Gantry_client.ReadByOrder<bool>("o_enable_change_mode", model.pattern_name);
                 #endregion
-
-                var model = JsonConvert.DeserializeObject<dt_pattern>(v);
-                model.pattern_state = 1;
-                var cont = _repository.Update(model, true);
-                if (cont > 0)
-                    content.OK(model.pattern_name + "璁剧疆涓烘ā寮�1鎴愬姛锛�");
+                if (ok)
+                {
+                    Gantry_client.WriteByOrder("i_mode", (Int16)1, model.pattern_name);
+                    model.pattern_state = 1;
+                    var cont = _repository.Update(model, true);
+                    if (cont > 0)
+                        content.OK(model.pattern_name + "璁剧疆涓烘ā寮�1鎴愬姛锛�");
+                    else
+                        throw new Exception(model.pattern_name + "璁剧疆涓烘ā寮�2澶辫触锛�");
+                    foreach (var stat in stations)
+                    {
+                        stat.enable = true;
+                    }
+                    stationinfoRepository.UpdateRange(stations, x => new { x.enable }, true);
+                }
                 else
-                    content.Error(model.pattern_name + "璁剧疆涓烘ā寮�1澶辫触锛�");
+                    content.Error(model.pattern_name + "璁剧疆涓烘ā寮�1澶辫触锛佹鏋舵湭鍏佽璁剧疆涓烘ā寮�1");
+
             }
             catch (Exception ex)
             {
@@ -89,6 +105,8 @@
             WebResponseContent content = new WebResponseContent();
             try
             {
+                var model = JsonConvert.DeserializeObject<dt_pattern>(v);
+                if (model.pattern_state == 0) throw new Exception("褰撳墠灏辨槸妯″紡2");
                 var Gantry_client = PLCClient.Clients.FirstOrDefault(t => t.PLCName == "妗佹灦");
                 if (Gantry_client == null) throw new Exception("妗佹灦璋冨害鏈嶅姟鏈紑鍚紒");
                 if (!Gantry_client.IsConnected) throw new Exception("涓庢鏋惰繛鎺ヨ秴鏃讹紒");
@@ -97,13 +115,27 @@
                 var stations = stationinfoRepository.Find(x => x.stationCode == "X01001001" || x.stationCode == "X01001002" || x.stationCode == "X02001001" || x.stationCode == "X02001002").ToList();
                 if (stations.Where(x => x.tray_status == TrayStateEnum.StrogeTray.ToString()).Any())
                     throw new Exception("璁剧疆涓烘ā寮�2澶辫触锛佷笅鏂欎綅瀛樺湪杞﹁疆锛�");
-                var model = JsonConvert.DeserializeObject<dt_pattern>(v);
-                model.pattern_state = 0;
-                var cont = _repository.Update(model, true);
-                if (cont > 0)
-                    content.OK(model.pattern_name + "璁剧疆涓烘ā寮�2鎴愬姛锛�");
+                #region 鍐欏叆淇″彿鍛婅瘔妗佹灦鍒囨崲妯″紡
+                var ok = Gantry_client.ReadByOrder<bool>("o_enable_change_mode", model.pattern_name);
+                #endregion
+                if (ok)
+                {
+                    Gantry_client.WriteByOrder("i_mode", (Int16)2, model.pattern_name);
+                    model.pattern_state = 0;
+                    var cont = _repository.Update(model, true);
+                    if (cont > 0)
+                        content.OK(model.pattern_name + "璁剧疆涓烘ā寮�2鎴愬姛锛�");
+                    else
+                        throw new Exception(model.pattern_name + "璁剧疆涓烘ā寮�2澶辫触锛�");
+                    foreach (var stat in stations)
+                    {
+                        stat.enable = false;
+                    }
+                    stationinfoRepository.UpdateRange(stations, x => new { x.enable }, true);
+                }
                 else
-                    content.Error(model.pattern_name + "璁剧疆涓烘ā寮�2澶辫触锛�");
+                    content.Error(model.pattern_name + "璁剧疆涓烘ā寮�2澶辫触锛佹鏋舵湭鍏佽璁剧疆涓烘ā寮�2");
+
             }
             catch (Exception ex)
             {
diff --git "a/\344\273\243\347\240\201\347\256\241\347\220\206/PCS/WCS_Server/WIDESEA_WCS/WCSClient/Siemens/SiemensPLCClient.cs" "b/\344\273\243\347\240\201\347\256\241\347\220\206/PCS/WCS_Server/WIDESEA_WCS/WCSClient/Siemens/SiemensPLCClient.cs"
index 7e42f5b..0dfc40e 100644
--- "a/\344\273\243\347\240\201\347\256\241\347\220\206/PCS/WCS_Server/WIDESEA_WCS/WCSClient/Siemens/SiemensPLCClient.cs"
+++ "b/\344\273\243\347\240\201\347\256\241\347\220\206/PCS/WCS_Server/WIDESEA_WCS/WCSClient/Siemens/SiemensPLCClient.cs"
@@ -155,8 +155,17 @@
         /// <returns></returns>
         public override DataType ReadByOrder<DataType>(string orderName, string Method = null)
         {
-            var item = itemGroups.Where(t => t.name.Equals(orderName)).FirstOrDefault();
-            if (Method != null) { item = itemGroups.Where(t => t.name.Equals(orderName) && t.Methods.Equals(Method)).FirstOrDefault(); }
+            DBItemGroup item = null;
+            //var item = itemGroups.Where(t => t.name.Equals(orderName)).FirstOrDefault();
+            //if (Method != null) { item = itemGroups.Where(t => t.name.Equals(orderName) && t.Methods.Equals(Method)).FirstOrDefault(); }
+            var items = itemGroups.Where(t => t.name.Contains(orderName)).ToList();
+            if (items.Count > 0)
+            {
+                if (Method != null)
+                    item = items.Where(t => t.Methods.Contains(Method)).FirstOrDefault();
+                else
+                    item = items.Where(t => t.name.Contains(orderName)).FirstOrDefault();
+            }
             if (item == null)
             {
                 throw new Exception($"PLC{PLCName},鏈畾涔夋寚浠orderName}");

--
Gitblit v1.9.3