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