From 73a926018601d9a5a5a3d3f4c051537f45a8eff4 Mon Sep 17 00:00:00 2001 From: dengjunjie <dengjunjie@hnkhzn.com> Date: 星期四, 14 三月 2024 09:33:38 +0800 Subject: [PATCH] 优化代码逻辑 --- 代码管理/PCS/WCS_Server/WIDESEA_WCS/Common/Gantry.cs | 556 +++++++++++++++++++++++++++++++++++++++++++++++-------- 1 files changed, 476 insertions(+), 80 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 84d6f6f..7f19a23 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" @@ -1,11 +1,14 @@ -锘縰sing StackExchange.Redis; +锘縰sing FreeSql.Internal.Model; +using StackExchange.Redis; using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; using WIDESEA_Comm; +using WIDESEA_Comm.LogInfo; using WIDESEA_Core.EFDbContext; +using WIDESEA_Core.FreeDB; using WIDESEA_WCS.IRepositories; using WIDESEA_WCS.Repositories; using WIDESEA_WCS.WCSClient; @@ -15,17 +18,26 @@ { public class Gantry { - static VOLContext Context = new VOLContext(); - Idt_plcinfoheadRepository repository = new dt_plcinfoheadRepository(Context); - Idt_plcinfodetailRepository plcRepository = new dt_plcinfodetailRepository(Context); - Idt_geometry_dataRepository dataRepository = new dt_geometry_dataRepository(Context); - Idt_stationinfoRepository stationinfoRepository = new dt_stationinfoRepository(Context); - + //FreeDB freeDB = new FreeDB(); + //static VOLContext Context = new VOLContext(); + //Idt_plcinfoheadRepository repository = new dt_plcinfoheadRepository(Context); + //Idt_plcinfodetailRepository plcRepository = new dt_plcinfodetailRepository(Context); + //Idt_geometry_dataRepository dataRepository = new dt_geometry_dataRepository(Context); + //Idt_geometry_data_detectionlineRepository detectionlineRepository = new dt_geometry_data_detectionlineRepository(Context); + ////Idt_stationinfoRepository stationinfoRepository = new dt_stationinfoRepository(Context); + //Idt_mes_detailRepository mes_DetailRepository = new dt_mes_detailRepository(Context); + //Idt_mes_headRepository mes_HeadRepository = new dt_mes_headRepository(Context); + //Idt_patternRepository patternRepository = new dt_patternRepository(Context); #region 鏌ヨ杞﹁疆鏁版嵁 public void QueryWheeldata(PLCClient client) { try { + VOLContext Context = new VOLContext(); + Idt_plcinfoheadRepository repository = new dt_plcinfoheadRepository(Context); + Idt_plcinfodetailRepository plcRepository = new dt_plcinfodetailRepository(Context); + Idt_geometry_dataRepository dataRepository = new dt_geometry_dataRepository(Context); + Idt_geometry_data_detectionlineRepository detectionlineRepository = new dt_geometry_data_detectionlineRepository(Context); var plc = repository.FindFirst(x => x.plcinfo_name == client.PLCName); List<string> names = new List<string>() { "1鍗曞厓杈婇亾涓嬫枡鏌ヨ杞﹁疆", "2鍗曞厓杈婇亾涓嬫枡鏌ヨ杞﹁疆", "3鍗曞厓杈婇亾涓嬫枡鏌ヨ杞﹁疆", "杈婇亾涓婃枡鏌ヨ杞﹁疆" }; foreach (string name in names) @@ -35,37 +47,68 @@ if ((byte)on == 1) { var wp_type = DBExtension.Read(details.Where(x => x.plcdetail_name == "R_o_wp_type").First(), client); - var geometry = dataRepository.FindFirst(x => x.TypeId == (Int32)wp_type); - if (geometry == null) + if (name != "杈婇亾涓婃枡鏌ヨ杞﹁疆") { - //DBExtension.Write(details.Where(x => x.plcdetail_name == "W_i_status").First(), client, (Int16)2); - //1-鎵惧埌鏁版嵁锛�2-鏈壘鍒板伐浠剁被鍨嬫暟鎹� - client.WriteByOrder("W_i_status", (byte)2, name); - //灞忚斀宸ヨ壓(灞忚斀瑙嗚妫�娴�/灞忚斀娑傛补); - //client.WriteByOrder("W_i_skip_op", "1", name); - client.WriteByOrder("R_oi_on", (byte)0, name); + var geometry = dataRepository.FindFirst(x => x.TypeId == (Int32)wp_type); + if (geometry == null) + { + //DBExtension.Write(details.Where(x => x.plcdetail_name == "W_i_status").First(), client, (Int16)2); + //1-鎵惧埌鏁版嵁锛�2-鏈壘鍒板伐浠剁被鍨嬫暟鎹� + client.WriteByOrder("W_i_status", (byte)2, name); + client.WriteByOrder("R_oi_on", (byte)0, name); + #region 鏃ュ織璁板綍 + WriteDBLog.Error(name, $"璇诲彇妗佹灦淇℃伅锛歕n杞瀷ID锛歿wp_type}\n\n鍐欏叆妗佹灦淇℃伅锛歕nW_i_status锛�2\nR_oi_on锛�0\n\n鏈煡璇㈠埌鏈哄姞宸ヨ溅杞俊鎭�", "PCS"); + #endregion + } + else + { + //1-鎵惧埌鏁版嵁锛�2-鏈壘鍒板伐浠剁被鍨嬫暟鎹� + client.WriteByOrder("W_i_status", (byte)1, name); + client.WriteByOrder("W_i_parameter_a", (float)geometry.a, name); + client.WriteByOrder("W_i_parameter_b", (float)geometry.b, name); + client.WriteByOrder("W_i_parameter_c", (float)geometry.c, name); + client.WriteByOrder("W_i_parameter_d", (float)geometry.d, name); + client.WriteByOrder("W_i_parameter_e", (float)geometry.e, name); + client.WriteByOrder("W_i_parameter_f", (float)geometry.f, name); + client.WriteByOrder("W_i_parameter_g", (float)geometry.g, name); + client.WriteByOrder("W_i_parameter_h", (float)geometry.h, name); + client.WriteByOrder("R_oi_on", (byte)0, name); + #region 鏃ュ織璁板綍 + WriteDBLog.Success(name, $"璇诲彇妗佹灦淇℃伅锛歕n杞瀷ID锛歿wp_type}\n\n鍐欏叆妗佹灦淇℃伅锛歕nW_i_status锛�1" + $"\na锛歿(float)geometry.a}\nb锛歿(float)geometry.b}\nc锛歿(float)geometry.c}\n" + + $"d锛歿(float)geometry.d}\ne锛歿(float)geometry.e}\nf锛歿(float)geometry.f}\ng锛歿(float)geometry.g}\nh锛歿(float)geometry.h}\nR_oi_on锛�0", "PCS"); + #endregion + } } else { - //1-鎵惧埌鏁版嵁锛�2-鏈壘鍒板伐浠剁被鍨嬫暟鎹� - client.WriteByOrder("W_i_status", (byte)1, name); - client.WriteByOrder("W_i_parameter_a", (float)geometry.a, name); - client.WriteByOrder("W_i_parameter_b", (float)geometry.b, name); - client.WriteByOrder("W_i_parameter_c", (float)geometry.c, name); - client.WriteByOrder("W_i_parameter_d", (float)geometry.d, name); - client.WriteByOrder("W_i_parameter_e", (float)geometry.e, name); - client.WriteByOrder("W_i_parameter_f", (float)geometry.f, name); - client.WriteByOrder("W_i_parameter_g", (float)geometry.g, name); - client.WriteByOrder("W_i_parameter_h", (float)geometry.h, name); - //灞忚斀宸ヨ壓(灞忚斀瑙嗚妫�娴�/灞忚斀娑傛补) - if (name != "杈婇亾涓婃枡鏌ヨ杞﹁疆") + var geometry = detectionlineRepository.FindFirst(x => x.TypeId == (Int32)wp_type); + if (geometry == null) { - client.WriteByOrder("W_i_skip_op_SJ1", (byte)1, name);//灞忚斀瑙嗚妫�娴嬭澶�1 - client.WriteByOrder("W_i_skip_op_SJ2", (byte)1, name);//灞忚斀瑙嗚妫�娴嬭澶�2 - client.WriteByOrder("W_i_skip_op_LT", (byte)1, name);//灞忚斀閾炬潯鏈� + client.WriteByOrder("W_i_status", (byte)2, name); + client.WriteByOrder("R_oi_on", (byte)0, name); + #region 鏃ュ織璁板綍 + WriteDBLog.Error(name, $"璇诲彇妗佹灦淇℃伅锛歕n杞瀷ID锛歿wp_type}\n\n鍐欏叆妗佹灦淇℃伅锛歕nW_i_status锛�2\nR_oi_on锛�0\n\n鏈煡璇㈠埌妫�娴嬬嚎杞﹁疆淇℃伅", "PCS"); + #endregion } - client.WriteByOrder("R_oi_on", (byte)0, name); + else + { + client.WriteByOrder("W_i_status", (byte)1, name); + client.WriteByOrder("W_i_parameter_a", (float)geometry.a, name); + client.WriteByOrder("W_i_parameter_b", (float)geometry.b, name); + client.WriteByOrder("W_i_parameter_c", (float)geometry.c, name); + client.WriteByOrder("W_i_parameter_d", (float)geometry.d, name); + client.WriteByOrder("W_i_parameter_e", (float)geometry.e, name); + client.WriteByOrder("W_i_parameter_f", (float)geometry.f, name); + client.WriteByOrder("W_i_parameter_g", (float)geometry.g, name); + client.WriteByOrder("W_i_parameter_h", (float)geometry.h, name); + client.WriteByOrder("R_oi_on", (byte)0, name); + #region 鏃ュ織璁板綍 + WriteDBLog.Success(name, $"璇诲彇妗佹灦淇℃伅锛歕n杞瀷ID锛歿wp_type}\n\n鍐欏叆妗佹灦淇℃伅锛歕nW_i_status锛�1" + $"\na锛歿(float)geometry.a}\nb锛歿(float)geometry.b}\nc锛歿(float)geometry.c}\n" + + $"d锛歿(float)geometry.d}\ne锛歿(float)geometry.e}\nf锛歿(float)geometry.f}\ng锛歿(float)geometry.g}\nh锛歿(float)geometry.h}\nR_oi_on锛�0", "PCS"); + #endregion + } } + } } } @@ -81,37 +124,147 @@ { try { + VOLContext Context = new VOLContext(); + Idt_plcinfoheadRepository repository = new dt_plcinfoheadRepository(Context); + Idt_plcinfodetailRepository plcRepository = new dt_plcinfodetailRepository(Context); + Idt_geometry_dataRepository dataRepository = new dt_geometry_dataRepository(Context); + Idt_geometry_data_detectionlineRepository detectionlineRepository = new dt_geometry_data_detectionlineRepository(Context); + Idt_mes_detailRepository mes_DetailRepository = new dt_mes_detailRepository(Context); + Idt_mes_headRepository mes_HeadRepository = new dt_mes_headRepository(Context); + Idt_patternRepository patternRepository = new dt_patternRepository(Context); var plc = repository.FindFirst(x => x.plcinfo_name == client.PLCName); List<string> names = new List<string>() { "1鍗曞厓杈婇亾涓嬫枡鏌ヨ璁㈠崟", "2鍗曞厓杈婇亾涓嬫枡鏌ヨ璁㈠崟", "3鍗曞厓杈婇亾涓嬫枡鏌ヨ璁㈠崟", "杈婇亾涓婃枡鏌ヨ璁㈠崟" }; foreach (string name in names) { var details = plcRepository.Find(x => x.plcdetail_iotype == plc.plcinfo_iotyep && x.plcdetail_number == name).ToList(); var on = DBExtension.Read(details.Where(x => x.plcdetail_name == "R_oi_on").First(), client); + //var on = DBExtension.Read(details.Where(x => x.plcdetail_name == "R_oi_on" && x.plcdetail_number == name).First(), client); if ((byte)on == 1) { - var wp_id = DBExtension.Read(details.Where(x => x.plcdetail_name == "R_o_wp_id").First(), client); - //闇�娣诲姞鏌ヨ杞﹁疆SN鍙疯鍗曢�昏緫 闇�娣诲姞鍏ュ簱妯″紡鍒ゆ柇锛屾墜鍔ㄥ叆搴撴ā寮忛渶浜哄伐娣诲姞鍏ュ簱搴撳尯锛屽惁鍒欐姤璀� - - - var wp_type = DBExtension.Read(details.Where(x => x.plcdetail_name == "R_o_wp_type").First(), client); - var geometry = dataRepository.FindFirst(x => x.TypeId == (Int32)wp_type); - if (geometry == null) + //var wp_id = DBExtension.Read(details.Where(x => x.plcdetail_name == "R_o_wp_id").First(), client).ToString(); + var wp_id = client.ReadByOrder<string>("R_o_wp_id", name); + if (string.IsNullOrEmpty(wp_id)) { - //1-濂�,鍏佽鍔犲伐锛�2-涓嶅湪鍒楄〃涓紝3-涓嶅姞宸ヨ溅杞被鍨嬶紝4-鎵嬪姩鍏ュ簱妯″紡浜哄伐鏈�夋嫨搴撳尯 - client.WriteByOrder("W_i_status", (Int16)2, name); - client.WriteByOrder("R_oi_on", (Int16)0, name); + #region 鏃ュ織璁板綍 + client.WriteByOrder("W_i_status", (byte)2, name); + client.WriteByOrder("R_oi_on", (byte)0, name); + WriteDBLog.Error(name, $"璇诲彇妗佹灦淇℃伅锛歕n杞﹁疆SN锛歿wp_id}\n\n鍐欏叆妗佹灦淇℃伅锛歕nW_i_status锛�2\nR_oi_on锛�0\n\n杞﹁疆SN鍙蜂负绌�", "PCS"); + #endregion + continue; + } + var wp_type = DBExtension.Read(details.Where(x => x.plcdetail_name == "R_o_wp_type").First(), client); + var mes_Detail = mes_DetailRepository.FindFirst(x => x.SN == wp_id); + #region 娴嬭瘯浣跨敤 + if (mes_Detail == null) + { + mes_Detail = mes_DetailRepository.FindFirst(x => x.jobID == (name == "3鍗曞厓杈婇亾涓嬫枡鏌ヨ璁㈠崟" ? "01180127004-2" : "01180127004-1")); + mes_Detail.SN = wp_id; + mes_DetailRepository.Update(mes_Detail, true); + } + #endregion + if (mes_Detail == null) + { + client.WriteByOrder("W_i_status", (byte)2, name); + client.WriteByOrder("R_oi_on", (byte)0, name); + #region 鏃ュ織璁板綍 + WriteDBLog.Error(name, $"璇诲彇妗佹灦淇℃伅锛歕n杞﹁疆SN锛歿wp_id}\n\n鍐欏叆妗佹灦淇℃伅锛歕nW_i_status锛�2\nR_oi_on锛�0\n\n鏈煡璇㈠埌宸ュ崟璇︽儏", "PCS"); + #endregion + continue; + } + var mes_Head = mes_HeadRepository.FindFirst(x => x.jobID == mes_Detail.jobID); + if (mes_Head == null) + { + client.WriteByOrder("W_i_status", (byte)2, name); + client.WriteByOrder("R_oi_on", (byte)0, name); + #region 鏃ュ織璁板綍 + WriteDBLog.Error(name, $"璇诲彇妗佹灦淇℃伅锛歕n杞﹁疆SN锛歿wp_id}\n\n鍐欏叆妗佹灦淇℃伅锛歕nW_i_status锛�2\nR_oi_on锛�0\n\n鏈煡璇㈠埌宸ュ崟澶磋〃", "PCS"); + #endregion + continue; + } + + if (name != "杈婇亾涓婃枡鏌ヨ璁㈠崟") + { + //闇�娣诲姞鏌ヨ杞﹁疆SN鍙疯鍗曢�昏緫 闇�娣诲姞鍏ュ簱妯″紡鍒ゆ柇锛屾墜鍔ㄥ叆搴撴ā寮忛渶浜哄伐娣诲姞鍏ュ簱搴撳尯锛屽惁鍒欐姤璀� + var pattern = patternRepository.FindFirst(x => x.pattern_name == "鍏ュ簱妯″紡").pattern_state; + if (pattern != 1 && string.IsNullOrEmpty(mes_Head.area)) + { + client.WriteByOrder("W_i_status", (byte)4, name); + client.WriteByOrder("R_oi_on", (byte)0, name); + #region 鏃ュ織璁板綍 + WriteDBLog.Error(name, $"璇诲彇妗佹灦淇℃伅锛歕n杞﹁疆SN锛歿wp_id}\n\n鍐欏叆妗佹灦淇℃伅锛歕nW_i_status锛�4\nR_oi_on锛�0\n\n鎵嬪姩鍏ュ簱妯″紡鏈�夋嫨搴撳尯", "PCS"); + #endregion + continue; + } + //var geometry = dataRepository.FindFirst(x => x.TypeId == (Int32)wp_type); + var geometry = dataRepository.Find(x => x.Description == mes_Head.drawingNo && x.TypeId == (Int32)wp_type).FirstOrDefault(); + if (geometry == null) + { + //1-濂�,鍏佽鍔犲伐锛�2-涓嶅湪鍒楄〃涓紝3-涓嶅姞宸ヨ溅杞被鍨嬶紝4-鎵嬪姩鍏ュ簱妯″紡浜哄伐鏈�夋嫨搴撳尯 + client.WriteByOrder("W_i_status", (byte)2, name); + client.WriteByOrder("R_oi_on", (byte)0, name); + #region 鏃ュ織璁板綍 + WriteDBLog.Error(name, $"璇诲彇妗佹灦淇℃伅锛歕n杞﹁疆SN锛歿wp_id}\n杞瀷ID锛歿wp_type}\n\n鍐欏叆妗佹灦淇℃伅锛歕nW_i_status锛�2\nR_oi_on锛�0\n\n鏈煡璇㈠埌鏈哄姞宸ヨ溅杞俊鎭�", "PCS"); + #endregion + continue; + } + else + { + //1-濂�,鍏佽鍔犲伐锛�2-涓嶅湪鍒楄〃涓紝3-涓嶅姞宸ヨ溅杞被鍨嬶紝4-鎵嬪姩鍏ュ簱妯″紡浜哄伐鏈�夋嫨搴撳尯 + client.WriteByOrder("W_i_status", (byte)1, name); + client.WriteByOrder("W_i_job_id", mes_Detail.jobID, name); + client.WriteByOrder("W_i_drawing_id", mes_Head.drawingNo, name); + client.WriteByOrder("W_i_heat_id", mes_Detail.heatID, name); + //client.WriteByOrder("W_i_sourceheat", "", name); + client.WriteByOrder("W_i_batch_id", mes_Detail.heatBatchID, name); + + //灞忚斀宸ヨ壓(灞忚斀瑙嗚妫�娴�/灞忚斀娑傛补) + //if (name != "杈婇亾涓婃枡鏌ヨ杞﹁疆") + //{ + client.WriteByOrder("W_i_skip_op_SJ1", name == "3鍗曞厓杈婇亾涓嬫枡鏌ヨ璁㈠崟" ? true : mes_Head.skip_op_1, name);//灞忚斀瑙嗚妫�娴嬭澶�1 + client.WriteByOrder("W_i_skip_op_SJ2", name == "3鍗曞厓杈婇亾涓嬫枡鏌ヨ璁㈠崟" ? true : mes_Head.skip_op_2, name);//灞忚斀瑙嗚妫�娴嬭澶�2 + client.WriteByOrder("W_i_skip_op_LT", mes_Head.skip_op_3, name);//灞忚斀閾炬潯鏈� + //} + client.WriteByOrder("R_oi_on", (byte)0, name); + #region 鏃ュ織璁板綍 + WriteDBLog.Success(name, $"璇诲彇妗佹灦淇℃伅锛歕n杞﹁疆SN锛歿wp_id}\n杞瀷ID锛歿wp_type}\n\n鍐欏叆妗佹灦淇℃伅锛歕nW_i_status锛�1" + + $"\nW_i_job_id锛歿mes_Detail.jobID}\nW_i_drawing_id锛歿mes_Head.drawingNo}\nW_i_heat_id锛歿mes_Detail.heatID}\nW_i_batch_id锛歿mes_Detail.heatBatchID}" + + $"\nW_i_skip_op_SJ1锛歿(name == "3鍗曞厓杈婇亾涓嬫枡鏌ヨ璁㈠崟" ? true : mes_Head.skip_op_1)}\nW_i_skip_op_SJ2锛歿(name == "3鍗曞厓杈婇亾涓嬫枡鏌ヨ璁㈠崟" ? true : mes_Head.skip_op_2)}" + + $"\nW_i_skip_op_LT锛歿mes_Head.skip_op_3}\nR_oi_on锛�0", "PCS"); + #endregion + } } else { - //1-濂�,鍏佽鍔犲伐锛�2-涓嶅湪鍒楄〃涓紝3-涓嶅姞宸ヨ溅杞被鍨嬶紝4-鎵嬪姩鍏ュ簱妯″紡浜哄伐鏈�夋嫨搴撳尯 - client.WriteByOrder("W_i_status", (Int16)1, name); - //client.WriteByOrder("W_i_job_id", "", name); - //client.WriteByOrder("W_i_drawing_id", "", name); - //client.WriteByOrder("W_i_heat_id", "", name); - //client.WriteByOrder("W_i_sourceheat", "", name); - //client.WriteByOrder("W_i_batch_id", "", name); - client.WriteByOrder("R_oi_on", (Int16)0, name); + var geometry = detectionlineRepository.Find(x => x.Description == mes_Head.drawingNo && x.TypeId == (Int32)wp_type).FirstOrDefault(); + if (geometry == null) + { + //1-濂�,鍏佽鍔犲伐锛�2-涓嶅湪鍒楄〃涓紝3-涓嶅姞宸ヨ溅杞被鍨嬶紝4-鎵嬪姩鍏ュ簱妯″紡浜哄伐鏈�夋嫨搴撳尯 + client.WriteByOrder("W_i_status", (byte)2, name); + client.WriteByOrder("R_oi_on", (byte)0, name); + #region 鏃ュ織璁板綍 + WriteDBLog.Error(name, $"璇诲彇妗佹灦淇℃伅锛歕n杞﹁疆SN锛歿wp_id}\n杞瀷ID锛歿wp_type}\n\n鍐欏叆妗佹灦淇℃伅锛歕nW_i_status锛�2\nR_oi_on锛�0\n\n鏈煡璇㈠埌妫�娴嬬嚎杞﹁疆淇℃伅", "PCS"); + #endregion + continue; + } + else + { + //1-濂�,鍏佽鍔犲伐锛�2-涓嶅湪鍒楄〃涓紝3-涓嶅姞宸ヨ溅杞被鍨嬶紝4-鎵嬪姩鍏ュ簱妯″紡浜哄伐鏈�夋嫨搴撳尯 + client.WriteByOrder("W_i_status", (byte)1, name); + client.WriteByOrder("W_i_job_id", mes_Detail.jobID, name); + client.WriteByOrder("W_i_drawing_id", mes_Head.drawingNo, name); + client.WriteByOrder("W_i_heat_id", mes_Detail.heatID, name); + //client.WriteByOrder("W_i_sourceheat", "", name); + client.WriteByOrder("W_i_batch_id", mes_Detail.heatBatchID, name); + client.WriteByOrder("R_oi_on", (byte)0, name); + #region 鏃ュ織璁板綍 + WriteDBLog.Success(name, $"璇诲彇妗佹灦淇℃伅锛歕n杞﹁疆SN锛歿wp_id}\n杞瀷ID锛歿wp_type}\n\n鍐欏叆妗佹灦淇℃伅锛歕nW_i_status锛�1" + $"\nW_i_job_id锛歿mes_Detail.jobID}" + + $"\nW_i_drawing_id锛歿mes_Head.drawingNo}\nW_i_heat_id锛歿mes_Detail.heatID}\nW_i_batch_id锛歿mes_Detail.heatBatchID}\nR_oi_on锛�0", "PCS"); + #endregion + } } + + + } } } @@ -122,64 +275,307 @@ } #endregion - #region 涓嬫枡浣嶄氦浜� + #region 涓嬫枡浣嶄氦浜� 锛侊紒锛佷笅鏂欓�昏緫闇�淇敼 public void Layofflevel(PLCClient client) { try { + VOLContext Context = new VOLContext(); + Idt_plcinfoheadRepository repository = new dt_plcinfoheadRepository(Context); + Idt_plcinfodetailRepository plcRepository = new dt_plcinfodetailRepository(Context); + Idt_stationinfoRepository stationinfoRepository = new dt_stationinfoRepository(Context); + Idt_geometry_dataRepository dataRepository = new dt_geometry_dataRepository(Context); + Idt_geometry_data_detectionlineRepository detectionlineRepository = new dt_geometry_data_detectionlineRepository(Context); + Idt_mes_detailRepository mes_DetailRepository = new dt_mes_detailRepository(Context); + Idt_mes_headRepository mes_HeadRepository = new dt_mes_headRepository(Context); + Idt_patternRepository patternRepository = new dt_patternRepository(Context); var plc = repository.FindFirst(x => x.plcinfo_name == client.PLCName); 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>() { "1鍗曞厓涓嬫枡鍖�", "2鍗曞厓涓嬫枡鍖�", "3鍗曞厓涓嬫枡鍖�" }; + foreach (string name in names) { var details = plcRepository.Find(x => x.plcdetail_iotype == plc.plcinfo_iotyep && x.plcdetail_number == name).ToList(); + var Wheel_Type = DBExtension.Read(details.Where(x => x.plcdetail_name == "R_Wheel_Type").First(), client);//杞﹁疆绫诲瀷 + var Wheel_id = client.ReadByOrder<string>("R_Wheel_id", name);//杞﹁疆SN鍙� + if (string.IsNullOrEmpty(Wheel_id)) continue; + //var Wheel_id = DBExtension.Read(details.Where(x => x.plcdetail_name == "R_Wheel_id").First(), client).ToString(); + + var mes_Detail = mes_DetailRepository.FindFirst(x => x.SN == Wheel_id); + if (mes_Detail == null) + { + #region 鏃ュ織璁板綍 + WriteDBLog.Error(name, $"璇诲彇妗佹灦淇℃伅锛歕n杞﹁疆SN锛歿Wheel_id}\n\n鏈煡璇㈠埌宸ュ崟璇︽儏", "PCS"); + #endregion + continue; + } + var mes_Head = mes_HeadRepository.FindFirst(x => x.jobID == mes_Detail.jobID); + if (mes_Head == null) + { + #region 鏃ュ織璁板綍 + WriteDBLog.Error(name, $"璇诲彇妗佹灦淇℃伅锛歕n杞﹁疆SN锛歿Wheel_id}\n\n鏈煡璇㈠埌宸ュ崟澶磋〃", "PCS"); + #endregion + continue; + } + + + var finished = (bool)DBExtension.Read(details.Where(x => x.plcdetail_name == "R_load_finished").First(), client);//鏀炬枡瀹屾垚 + var updatefinished = (bool)DBExtension.Read(details.Where(x => x.plcdetail_name == "W_Storage_update").First(), client);//璐т綅鐘舵�佹洿鏂� + if (!finished && updatefinished) + { + client.WriteByOrder("W_Storage_update", false, name);//璐т綅鐘舵�佹洿鏂� + #region 鏃ュ織璁板綍 + WriteDBLog.Success(name + "璐т綅鐘舵�佹洿鏂板浣�", $"璇诲彇妗佹灦淇℃伅锛歕n杞﹁疆SN锛歿Wheel_id}\n杞瀷ID锛歿Wheel_Type}\n\n鍐欏叆妗佹灦淇℃伅锛歕nW_Storage_update锛歠alse", "PCS"); + #endregion + } + if (finished && !updatefinished) + { + var AreaNr = (Int16)DBExtension.Read(details.Where(x => x.plcdetail_name == "W_AreaNr").First(), client); + var areaCode = PipelineJob.area_code(name); //鏍规嵁涓嬫枡鍙e崟鍏冨悕鑾峰彇鍖哄煙浠g爜 + var station = stationinfoRepository.FindFirst(x => x.area == areaCode && x.stationCode.Substring(x.stationCode.Length - 1, 1) == AreaNr.ToString()); //姝ゅ鏈夐棶棰� 涓嶇煡閬撴槸缁撳熬涓�1鐨勫摢涓笅鏂欏彛 + station.quantity++; //todo 姝ゅ鏁伴噺涓嶄細澧炲姞 浣嗘槸鏇存柊瀹炰綋褰卞搷鎶ラ敊 鏄庢棩娴嬭瘯 + if (station.quantity > 5) + throw new Exception($"涓嬫枡浣嶄俊鎭洿鏂板け璐ワ紒涓嬫枡浣嶈溅杞暟閲忓ぇ浜�5锛歿station.stationCode}"); + //station.bindSN = station.bindSN == string.Empty ? Wheel_id : station.bindSN + "," + Wheel_id; + station.bindSN = string.IsNullOrEmpty(station.bindSN) ? Wheel_id : station.bindSN + "," + Wheel_id; + if (station.quantity == 1) + { + station.stationType = mes_Head.drawingNo; + station.Number = mes_Head.jobID; + station.heatNumber = mes_Detail.heatID; + station.tray_status = "StrogeTray"; + } + var count = stationinfoRepository.Update(station, true); + if (count < 1) + throw new Exception($"涓嬫枡浣嶄俊鎭洿鏂板け璐ワ紒涓嬫枡浣嶇紪鍙凤細{station.stationCode}"); + client.WriteByOrder("W_Storage_update", true, name);//璐т綅鐘舵�佹洿鏂� + client.WriteByOrder("W_Enabl_Load", false, name);//鏄惁鍏佽 + #region 鏃ュ織璁板綍 + WriteDBLog.Success(name + "鏀炬枡瀹屾垚", $"璇诲彇妗佹灦淇℃伅锛歕n杞﹁疆SN锛歿Wheel_id}\n杞瀷ID锛歿Wheel_Type}\n涓嬫枡浣嶅彿锛歿AreaNr}" + + $"\n\n鍐欏叆妗佹灦淇℃伅锛歕nW_Storage_update锛歵rue" + $"\nW_Enabl_Load锛歠alse", "PCS"); + #endregion + } + var Request = (bool)DBExtension.Read(details.Where(x => x.plcdetail_name == "R_Request_Load").First(), client); if (!Request) continue; - List<string> StationCodes = new List<string>() { "X01001001", "X01001002", "X01001003" }; - if (name == "2鍗曞厓涓嬫枡鍖�") - StationCodes = new List<string>() { "X02001001", "X02001002", "X02001003" }; - if (name == "3鍗曞厓涓嬫枡鍖�") - StationCodes = new List<string>() { "X03001001", "X03001002" }; - var Wheel_Type = (Int32)DBExtension.Read(details.Where(x => x.plcdetail_name == "R_Wheel_Type").First(), client);//杞﹁疆绫诲瀷 - var Wheel_id = DBExtension.Read(details.Where(x => x.plcdetail_name == "R_Wheel_id").First(), client).ToString();//杞﹁疆SN鍙� - for (int i = 0; i < StationCodes.Count - 1; i++) + var Stations = stationinfoRepository.Find(x => x.area == PipelineJob.area_code(name)); + + var NGStation = "X01001003"; + if (name == "2鍗曞厓涓嬫枡鍖�") NGStation = "X02001003"; + if (name == "3鍗曞厓涓嬫枡鍖�") NGStation = "X03001002"; + + foreach (var station in Stations) //浠讳綍涓�涓笅鏂欎綅涓虹┖鎴栫鐢ㄦ椂,閮戒細鍋滄妗佹灦 { - var PartStatus = (Int32)DBExtension.Read(details.Where(x => x.plcdetail_name == "R_PartStatus").First(), client);//1:ok;2:nok - string NG = StationCodes[StationCodes.Count - 1];//NG璐т綅 - var station = stationinfoRepository.FindFirst(x => x.stationCode == StationCodes[i] && x.enable && x.location_state == LocationStateEnum.Stroge.ToString() && x.quantity < 5); - if (station == null) continue; - var Pipelinedetails = plcRepository.Find(x => x.plcdetail_iotype == Pipelineplc.plcinfo_iotyep && x.plcdetail_number == StationCodes[i]).ToList(); - var PalletSignal = (Int16)DBExtension.Read(Pipelinedetails.Where(x => x.plcdetail_name == "R_PalletSignal").First(), client);//璇诲彇鎵樼洏淇″彿:1:鏈�,2鏃� - if (PalletSignal == 1) + if (!station.enable || station.location_state == LocationStateEnum.Empty.ToString()) + client.WriteByOrder("W_Enabl_Load", false, name);//淇″彿涓篺alse妗佹灦鍋滄杩涘叆 + } + + //var currentAreaNr = (Int16)DBExtension.Read(details.Where(x => x.plcdetail_name == "W_Are00aNr").First(), client); + //var currentAreaCode = PipelineJob.area_code(name); //鏍规嵁涓嬫枡鍙e崟鍏冨悕鑾峰彇鍖哄煙浠g爜 + //var currentStation = stationinfoRepository.FindFirst(x => x.area == currentAreaCode && x.stationCode.Substring(x.stationCode.Length - 1, 1) == currentAreaNr.ToString()); + //if (!currentStation.enable || currentStation.location_state == LocationStateEnum.Empty.ToString()) + // client.WriteByOrder("W_Enabl_Load", false, name);//淇″彿涓篺alse妗佹灦鍋滄杩涘叆 + + var wheel = PipelineJob.QueryMateriel(mes_Head.drawingNo); + if (wheel == null) + { + #region 鏃ュ織璁板綍 + WriteDBLog.Error(name, $"鏈煡璇㈠埌杞﹁疆淇℃伅锛�", "PCS"); + #endregion + continue; + } + + var PartStatus = DBExtension.Read(details.Where(x => x.plcdetail_name == "R_PartStatus").First(), client);//1:ok;2:nok + if ((Int16)PartStatus == 1) + { + var Stationinfo = Stations + .Where(x => x.enable + && x.stationCode != NGStation + && x.location_state == LocationStateEnum.Stroge.ToString() + && x.quantity < 5 + && x.stationType == mes_Head.drawingNo + && x.tray_type == (wheel.e < 1100 ? "SmallTray" : "LargeTray") + && x.Number == mes_Detail.jobID + && x.heatNumber == mes_Detail.heatID) + .OrderByDescending(x => x.quantity) + .FirstOrDefault(); + if (Stationinfo == null) + Stationinfo = Stations.Where(x => x.enable && x.stationCode != NGStation && x.location_state == LocationStateEnum.Stroge.ToString() && x.quantity == 0).FirstOrDefault(); + if (Stationinfo != null) { - if (PartStatus == 1 && NG != station.stationCode) + #region 鎵樼洏绫诲瀷涓嶄竴鑷撮渶鏇存崲鎵樼洏 + if (Stationinfo.tray_type != (wheel.e < 1100 ? "SmallTray" : "LargeTray")) { - client.WriteByOrder("W_AreaNr", (Int16)i + 1, name);//鍖哄煙璐т綅鍙� - client.WriteByOrder("W_IndexNr", (Int16)station.quantity + 1, name);//鎵樼洏涓婄殑绗嚑涓溅杞� + Stationinfo.location_state = LocationStateEnum.Abnormal.ToString(); + Stationinfo.tray_type = Stationinfo.tray_type == "SmallTray" ? "SmallTray/LargeTray" : "LargeTray/SmallTray"; + Stationinfo.remark = "鎵樼洏绫诲瀷涓嶄竴鑷撮渶鏇存崲鎵樼洏"; + stationinfoRepository.Update(Stationinfo, true); + continue; } - else if (PartStatus == 2 && NG == station.stationCode) + #endregion + + var Pipelinedetails = plcRepository.Find(x => x.plcdetail_iotype == Pipelineplc.plcinfo_iotyep && x.plcdetail_number == Stationinfo.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(details.Where(x => x.plcdetail_name == "R_MaterialSignal").First(), Pipeline_client);//璇诲彇璐х墿淇″彿:1:鏈�,2鏃� + //var Wheel_id = client.ReadByOrder<string>("R_Wheel_id", name); + if (PalletSignal == 1) { - client.WriteByOrder("W_AreaNr", (Int16)i + 1, name);//鍖哄煙璐т綅鍙� - client.WriteByOrder("W_IndexNr", (Int16)station.quantity + 1, name);//鎵樼洏涓婄殑绗嚑涓溅杞� + List<string> list = new List<string>(); + if (Stationinfo.bindSN != null) + { + var SNS = Stationinfo.bindSN.Split(","); + foreach (var SN in SNS) + { + if (!string.IsNullOrEmpty(SN)) + list.Add(SN); + } + } + + //缂撳瓨鏋朵笂杞﹁疆鏁伴噺涓嶴N鍙锋暟閲忎笉涓�鑷� + if (list.Count != Stationinfo.quantity) + { + Stationinfo.location_state = LocationStateEnum.Abnormal.ToString(); + Stationinfo.remark = "杞﹁疆鏁伴噺涓嶴N鍙锋暟閲忎笉涓�鑷�"; + stationinfoRepository.Update(Stationinfo, true); + continue; + //鍐欏叆妗佹灦鎶ヨ淇″彿 + //throw new Exception("涓嬫枡浣嶈溅杞暟閲忎笌SN鍙锋暟閲忎笉涓�鑷达紝涓嬫枡浣嶇紪鍙凤細" + Stationinfo.stationCode); + } + var area = Convert.ToInt16(Stationinfo.stationCode.Substring(Stationinfo.stationCode.Length - 1, 1)); + client.WriteByOrder("W_AreaNr", (Int16)area, name);//鍖哄煙璐т綅鍙� + client.WriteByOrder("W_IndexNr", (Int16)(Stationinfo.quantity + 1), name);//鎵樼洏涓婄殑绗嚑涓溅杞� + client.WriteByOrder("W_Storage_Type", (Int16)1, name);//鎵樼洏绫诲瀷1-妯斁;2-绔栨斁(鏆傛椂鍙湁妯斁鎵樼洏) + client.WriteByOrder("W_Enabl_Load", true, name);//鏄惁鍏佽 + #region 鏃ュ織璁板綍 + WriteDBLog.Success(name + "鏀炬枡鐢宠", $"璇诲彇妗佹灦淇℃伅锛歕n杞﹁疆SN锛歿Wheel_id}\n杞瀷ID锛歿Wheel_Type}\n杞﹁疆鐘舵�侊細OK" + + $"\n璇诲彇鎵樼洏鍏夌數淇″彿锛歿PalletSignal}" + + $"\n\n鍐欏叆妗佹灦淇℃伅锛歕n涓嬫枡浣嶅彿锛歿area}\n绗嚑涓溅杞細{(Stationinfo.quantity + 1)}\n鎵樼洏绫诲瀷锛�1\nW_Enabl_Load锛歵rue", "PCS"); + #endregion + return; } - client.WriteByOrder("W_Storage_Type", (Int16)1, name);//鎵樼洏绫诲瀷1-妯斁;2-绔栨斁(鏆傛椂鍙湁妯斁鎵樼洏) - client.WriteByOrder("W_Enabl_Load", true, name);//鏄惁鍏佽 } } - var finished = (bool)DBExtension.Read(details.Where(x => x.plcdetail_name == "R_load_finished").First(), client);//鏀炬枡瀹屾垚 - if (finished) + else if ((Int16)PartStatus == 2) { - var AreaNr = (Int16)DBExtension.Read(details.Where(x => x.plcdetail_name == "W_AreaNr").First(), client); - var station = stationinfoRepository.FindFirst(x => x.stationCode == StationCodes[AreaNr - 1]); - station.quantity = station.quantity++; - stationinfoRepository.Update(station); - client.WriteByOrder("W_Storage_update", true, name);//璐т綅鐘舵�佹洿鏂� + var Stationinfo = Stations + .Where(x => x.enable + && x.stationCode == NGStation + && x.location_state == LocationStateEnum.Stroge.ToString() + && x.quantity < 5 + && x.stationType == mes_Head.drawingNo + && x.tray_type == (wheel.e < 1100 ? "SmallTray" : "LargeTray") + && x.Number == mes_Detail.jobID + && x.heatNumber == mes_Detail.heatID).FirstOrDefault(); + if (Stationinfo == null) + Stationinfo = Stations.Where(x => x.enable && x.stationCode == NGStation && x.location_state == LocationStateEnum.Stroge.ToString() && x.quantity == 0).FirstOrDefault(); + if (Stationinfo != null) + { + #region 鎵樼洏绫诲瀷涓嶄竴鑷撮渶鏇存崲鎵樼洏 + if (Stationinfo.tray_type != (wheel.e < 1100 ? "SmallTray" : "LargeTray")) + { + Stationinfo.location_state = LocationStateEnum.Abnormal.ToString(); + Stationinfo.tray_type = Stationinfo.tray_type == "SmallTray" ? "SmallTray/LargeTray" : "LargeTray/SmallTray"; + Stationinfo.remark = "鎵樼洏绫诲瀷涓嶄竴鑷撮渶鏇存崲鎵樼洏"; + stationinfoRepository.Update(Stationinfo, true); + } + #endregion + var Pipelinedetails = plcRepository.Find(x => x.plcdetail_iotype == Pipelineplc.plcinfo_iotyep && x.plcdetail_number == Stationinfo.stationCode).ToList(); + var PalletSignal = (Int16)DBExtension.Read(Pipelinedetails.Where(x => x.plcdetail_name == "R_PalletSignal").First(), Pipeline_client);//璇诲彇鎵樼洏淇″彿:1:鏈�,2鏃� + if (PalletSignal == 1) + { + var SNS = Stationinfo.bindSN.Split(","); + List<string> list = new List<string>(); + if (Stationinfo.bindSN != null) + { + foreach (var SN in SNS) + { + if (!string.IsNullOrEmpty(SN)) + list.Add(SN); + } + } + + //缂撳瓨鏋朵笂杞﹁疆鏁伴噺涓嶴N鍙锋暟閲忎笉涓�鑷� + if (list.Count != Stationinfo.quantity) + { + Stationinfo.location_state = LocationStateEnum.Abnormal.ToString(); + Stationinfo.remark = "杞﹁疆鏁伴噺涓嶴N鍙锋暟閲忎笉涓�鑷�"; + stationinfoRepository.Update(Stationinfo, true); + continue; + //鍐欏叆妗佹灦鎶ヨ淇″彿 + //throw new Exception("涓嬫枡浣嶈溅杞暟閲忎笌SN鍙锋暟閲忎笉涓�鑷达紝涓嬫枡浣嶇紪鍙凤細" + Stationinfo.stationCode); + } + var area = Convert.ToInt16(Stationinfo.stationCode.Substring(Stationinfo.stationCode.Length - 1, 1)); + client.WriteByOrder("W_AreaNr", (Int16)area, name);//鍖哄煙璐т綅鍙� + client.WriteByOrder("W_IndexNr", (Int16)(Stationinfo.quantity + 1), name);//鎵樼洏涓婄殑绗嚑涓溅杞� + client.WriteByOrder("W_Storage_Type", (Int16)1, name);//鎵樼洏绫诲瀷1-妯斁;2-绔栨斁(鏆傛椂鍙湁妯斁鎵樼洏) + client.WriteByOrder("W_Enabl_Load", true, name);//鏄惁鍏佽 + #region 鏃ュ織璁板綍 + WriteDBLog.Success(name + "鏀炬枡鐢宠", $"璇诲彇妗佹灦淇℃伅锛歕n杞﹁疆SN锛歿Wheel_id}\n杞瀷ID锛歿Wheel_Type}\n杞﹁疆鐘舵�侊細NG" + + $"\n璇诲彇鎵樼洏鍏夌數淇″彿锛歿PalletSignal}" + + $"\n\n鍐欏叆妗佹灦淇℃伅锛歕n涓嬫枡浣嶅彿锛歿area}\n绗嚑涓溅杞細{(Stationinfo.quantity + 1)}\n鎵樼洏绫诲瀷锛�1\nW_Enabl_Load锛歵rue", "PCS"); + #endregion + return; + } + } } + #region + //var Stationinfo = Stations + // .Where(x => x.enable + // && x.location_state == LocationStateEnum.Stroge.ToString() + // && x.quantity < 5 + // && x.stationType == PipelineJob.QueryMateriel(Wheel_Type) + // && x.Number == mes_Detail.jobID + // && x.heatNumber == mes_Detail.heatID).FirstOrDefault(); + //if (Stationinfo == null) + // Stationinfo = Stations.Where(x => x.enable && x.location_state == LocationStateEnum.Stroge.ToString() && x.quantity == 0).FirstOrDefault(); + //if (Stationinfo != null) + //{ + + //} + + //List<string> StationCodes = new List<string>() { "X01001001", "X01001002", "X01001003" }; + //if (name == "2鍗曞厓涓嬫枡鍖�") + // StationCodes = new List<string>() { "X02001001", "X02001002", "X02001003" }; + //if (name == "3鍗曞厓涓嬫枡鍖�") + // StationCodes = new List<string>() { "X03001001", "X03001002" }; + + #endregion + + #region + //for (int i = 0; i < StationCodes.Count - 1; i++) + //{ + // var PartStatus = (Int32)DBExtension.Read(details.Where(x => x.plcdetail_name == "R_PartStatus").First(), client);//1:ok;2:nok + // string NG = StationCodes[StationCodes.Count - 1];//NG璐т綅 + // var station = stationinfoRepository.FindFirst(x => x.stationCode == StationCodes[i] && x.enable && x.location_state == LocationStateEnum.Stroge.ToString() && x.quantity < 5); + // if (station == null) continue; + // var Pipelinedetails = plcRepository.Find(x => x.plcdetail_iotype == Pipelineplc.plcinfo_iotyep && x.plcdetail_number == StationCodes[i]).ToList(); + // var PalletSignal = (Int16)DBExtension.Read(Pipelinedetails.Where(x => x.plcdetail_name == "R_PalletSignal").First(), client);//璇诲彇鎵樼洏淇″彿:1:鏈�,2鏃� + // if (PalletSignal == 1) + // { + // if (PartStatus == 1 && NG != station.stationCode) + // { + // client.WriteByOrder("W_AreaNr", (Int16)i + 1, name);//鍖哄煙璐т綅鍙� + // client.WriteByOrder("W_IndexNr", (Int16)station.quantity + 1, name);//鎵樼洏涓婄殑绗嚑涓溅杞� + // client.WriteByOrder("W_Storage_Type", (Int16)1, name);//鎵樼洏绫诲瀷1-妯斁;2-绔栨斁(鏆傛椂鍙湁妯斁鎵樼洏) + // client.WriteByOrder("W_Enabl_Load", true, name);//鏄惁鍏佽 + // return; + // } + // else if (PartStatus == 2 && NG == station.stationCode) + // { + // client.WriteByOrder("W_AreaNr", (Int16)i + 1, name);//鍖哄煙璐т綅鍙� + // client.WriteByOrder("W_IndexNr", (Int16)station.quantity + 1, name);//鎵樼洏涓婄殑绗嚑涓溅杞� + // client.WriteByOrder("W_Storage_Type", (Int16)1, name);//鎵樼洏绫诲瀷1-妯斁;2-绔栨斁(鏆傛椂鍙湁妯斁鎵樼洏) + // client.WriteByOrder("W_Enabl_Load", true, name);//鏄惁鍏佽 + // return; + // } + // } + //} + #endregion } } catch (Exception ex) -- Gitblit v1.9.3