using Aitex.Core.RT.Log; using DocumentFormat.OpenXml.InkML; using MECF.Framework.Common.DataCenter; using MECF.Framework.Common.Equipment; using Sicentury.Core; using System; using System.Collections.Generic; using System.Data; using System.Linq; using System.Text; namespace MECF.Framework.UI.Client.CenterViews.DataLogs.ProcessHistory { public class ProcessHistorySqlHelp { public static List QueryRecipeProcessHistoryData(string starTime, string endTime, string pm) { string cmd = $"select * from process_data where process_in='{pm}' and process_begin_time between '{starTime}' and '{endTime}' order by process_begin_time desc"; return GetPMCoatingList(cmd); } //**********************************************时间区间内Recipe运行记录查询************************************************************* private static List GetPMCoatingList(string cmd) { List recipeProcessHistoryDataList = new List(); try { var dt = QueryDataClient.Instance.Service.QueryData(cmd);//只能界面用 if (dt == null || dt.Rows.Count == 0) return null; for (int i = 0; i < dt.Rows.Count; i++) { RecipeProcessHistoryData recipeProcessHistoryData = new RecipeProcessHistoryData() { PmModel = dt.Rows[i]["process_in"].ToString(), XPath = dt.Rows[i]["recipe_name"].ToString(), Status = dt.Rows[i]["process_status"].ToString(), ProcessGuid = dt.Rows[i]["guid"].ToString(), BeginTime = dt.Rows[i]["process_begin_time"].ToString(), EndTime = dt.Rows[i]["process_end_time"].ToString() }; recipeProcessHistoryDataList.Add(recipeProcessHistoryData); } } catch (Exception) { return null; } return recipeProcessHistoryDataList; } //**********************************************选中Recipe时，查询当时记录的总的步骤流程************************************************* public static List QueryProcessHistoryData(string processGuid, string recipeName) { string cmd = $"select * from recipe_step_data where process_data_guid='{processGuid}'"; return GetProcessHistoryDataList(cmd, recipeName); } private static List GetProcessHistoryDataList(string cmd, string recipeName) { List processHistoryDataList = new List(); try { var dt = QueryDataClient.Instance.Service.QueryData(cmd); if (dt == null || dt.Rows.Count == 0) return null; for (int i = 0; i < dt.Rows.Count; i++) { ProcessHistoryData recipeProcessHistoryData = new ProcessHistoryData() { StepBeginTime = dt.Rows[i]["step_begin_time"].ToString(), StepEndTime = dt.Rows[i]["step_end_time"].ToString(), RecipeName = recipeName, StepName = dt.Rows[i]["step_name"].ToString(), StepTime = dt.Rows[i]["step_time"].ToString(), StepNumber = dt.Rows[i]["step_number"].ToString() }; processHistoryDataList.Add(recipeProcessHistoryData); } } catch (Exception) { return null; } return processHistoryDataList; } //************************************************单步时硬件数据结果查询******************************************************************* /// /// 查询气体体积数据 /// /// 拆分的天 /// PM名称 /// 显示列表对象 /// public static List GetProcessHistoryDeviceData(IEnumerable daySlices, string moduleName, List processHistoryItemList) { List dataTableList =new List(); foreach (var daySlice in daySlices)//拆分天 { dataTableList.Add(GetProcessHistoryDeviceDataListDaySlices(daySlice, moduleName, processHistoryItemList));//拆分后，每次查询结果放入集合中 } List processHistoryDeviceDataList = new List(); foreach (var item in processHistoryItemList) { var phd = new ProcessHistoryDeviceData(); phd.DeviceName = item.Display; phd.Unit = item.Unit; foreach (DataTable ds in dataTableList) { for (int i = 0; i < ds.Rows.Count; i++) { if (!item.IsPropertyExists) continue; string value = ds.Rows[i][$"{moduleName}.{item.Property}"].ToString(); if (value is not null && value.Length == 0) continue; phd.DeviceValue.Add(float.Parse(value));//历史数据点 phd.TimeStamp.Add(ds.Rows[i]["time"].ToString());//时间戳 } } phd.CalculateData(); processHistoryDeviceDataList.Add(phd); } return processHistoryDeviceDataList; } /// /// 根据拆分的天循查询数据 /// /// 拆分的天 /// PM名称 /// 显示集合列表 /// private static DataTable GetProcessHistoryDeviceDataListDaySlices(DateRangeHelper daySlices, string moduleName, List processHistoryItemList) { DataTable dataTable=new (); var ts = daySlices.Diff; for (var day = 0; day <= ts.Days; day++) { var tblName = $"{daySlices.Start.AddDays(day):yyyyMMdd}.{moduleName}"; var sql = new StringBuilder(); // 检查表名是否存在，否则SQL执行出错。 if (CheckTableExists(tblName)) { sql.Append("select time AS InternalTimeStamp"); // 添加待查询的列 foreach (var item in processHistoryItemList) { // 检查表中是否存在对应属性，否则SQL执行出错。 if (CheckPropertyExists(tblName, $"{moduleName}.{item.Property}")) { item.IsPropertyExists = true; sql.Append("," + $"\"{moduleName}.{item.Property}\""); } else//不查询状态标记 item.IsPropertyExists = false; } sql.Append($", \"time\""); sql.Append($" from \"{tblName}\""); if (day < ts.Days) sql.Append(" UNION "); sql.Append( $" where time between {daySlices.Start.Ticks} and {daySlices.End.Ticks} order by InternalTimeStamp asc"); try { var _dataTable = QueryDataClient.Instance.Service.QueryData(sql.ToString()); if (_dataTable is not null && _dataTable.Rows.Count > 0) dataTable = _dataTable; } catch (Exception ex)//查询较早日期时，可能不存在属性会报错 { } } } return dataTable; } private static bool CheckTableExists(string tableName) { var sql = $"SELECT EXISTS ( SELECT FROM pg_tables WHERE schemaname = 'public' AND tablename = '{tableName}' )"; var table = QueryDataClient.Instance.Service.QueryData(sql); if (table == null) return false; if (table.Rows.Count <= 0) return false; var value = table.Rows[0]["exists"].ToString(); if (value.ToLower() == "true") return true; return false; } private static bool CheckPropertyExists(string tableName, string property) { var sql = $"select count(1) from information_schema.columns WHERE table_name = '{tableName}' and column_name = '{property}'"; var table = QueryDataClient.Instance.Service.QueryData(sql); if (table == null) return false; if (table.Rows.Count <= 0) return false; var value =int.Parse(table.Rows[0]["count"].ToString()); if (value == 0) return false; return true; } } }