OTS/OTSIncAReportApp/1-UI/OTSReportExport/DataIntegration/BasicData.cs

using DevExpress.Office.Drawing;
using NPOI.Util;
using OTSCommon.DBOperate;
using OTSIncAReportApp.DataOperation.DataAccess;
using OTSIncAReportApp.OTSRstMgrFunction;
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using static OTSDataType.otsdataconst;
using static OTSIncAReportApp.OTSReport_Export;

namespace OTSIncAReportApp._1_UI.OTSReportExport.DataIntegration
{
	public class BasicData
    {
        ParticleData fielddata;
        private string SizeChart = "";

        List<string> colid = new List<string>();
        List<string> colid_Below7 = new List<string>();

        List<string> GroupInformation = new List<string>();

		private List<DataTable> BData = new List<DataTable>();
        private List<DataTable> Measurements = new List<DataTable>();//测量结果数据列队

		private DataTable AllClass = new DataTable();
        private DataTable AllElement = new DataTable();
        private bool IsShereAClassificationGroup = false;
        private ResultFile resfile;
        private string FilePath = "";

        private string VDA19String = "5,15,25,50,100,150,200,400,600,1000";

        /// <summary>
        /// 获取粒级表
        /// </summary>
        public void SetParticlesizeTable(OTSReport_Export m_otsreport_export)
        {
            colid.Clear();
            colid_Below7.Clear();

            string path1 = m_otsreport_export.m_ReportApp.m_rstDataMgr.m_RptConfigFile.PartSizeFileFolder +
                 m_otsreport_export.m_ReportApp.m_rstDataMgr.m_RptConfigFile.PartSizeFile;
            DataSet ds = OTSIncAReportApp.DataOperation.DataAccess.XMLoperate.GetXml(path1);
            SizeChart = ds.Tables[0].Rows[0]["Sizes"].ToString();

            var sizes = ParseSizeString(SizeChart);
            BuildSizeColumnLists(sizes, colid, colid_Below7);
        }

        /// <summary>
        /// 获取粒级表
        /// </summary>
        /// <returns></returns>
        public List<string> GetParticlesizeTable()
        {
            if (colid.Count > 7)
            {
                return colid;
            }
            else
            {
                return colid_Below7;
            }

        }

       
        public void SetDBData(c_TemplateClass m_mbszclass, OTSReport_Export m_otsreport_export, string ComputeMode)
        {
            // 输出集合初始化
            BData = new List<DataTable>();
            Measurements = new List<DataTable>();

            // 本次使用的 ParticleData（局部）
            ParticleData particleData = new ParticleData(m_otsreport_export.m_ReportApp.m_rstDataMgr.ResultFilesList[m_otsreport_export.m_ReportApp.m_rstDataMgr.GetWorkingResultId()].FilePath);

            // 基础列
            var baseCols = new List<string> { "TypeName", "ar", "TypeId", "Largest", "Class", "GroupId", "con" };

            // 获取粒级表 sizestr（支持 VDA19）
            string path1 = m_otsreport_export.m_ReportApp.m_rstDataMgr.m_RptConfigFile.PartSizeFileFolder +
                 m_otsreport_export.m_ReportApp.m_rstDataMgr.m_RptConfigFile.PartSizeFile;
            DataSet ds = OTSIncAReportApp.DataOperation.DataAccess.XMLoperate.GetXml(path1);

            string sizestr = m_mbszclass.M_VDA19.IsVDA19 ? VDA19String : ds.Tables[0].Rows[0]["Sizes"].ToString();
            var sizes = ParseSizeString(sizestr);

            // 构建 size 列名（保留原有逻辑）
            bool blBelow7;
            List<string> sizeBucketNames;
            BuildSizeColumns(sizes, out sizeBucketNames, out blBelow7);

            // 构建 m_bt_DBData 列
            DataTable m_bt_DBData = new DataTable();
            foreach (var c in baseCols.Concat(sizeBucketNames))
            {
                m_bt_DBData.Columns.Add(c);
            }

            // 读取并过滤原始数据（TypeId > 10）
            DataTable dt = InvalidRemoval(particleData.GetParticleListForParticlSize("area", ""));
            DataTable AreaInformationOfAllElements = InvalidRemoval(particleData.GetAreaByAllIncA(""));
            DataTable dtp = InvalidRemoval(particleData.GetParticleAll(""));

            // 计算匹配列名 po
            string po = ComputeMode;
            switch (po)
            {
                case "DMAX":
                    po = "DMAX";
                    break;
                case "DMIN":
                    po = "DMIN";
                    break;
                case "ECD":
                    po = "Area";
                    break;
                case "FERET":
                    po = "DFERET";
                    break;
            }

            // 将 dtp 按 TypeId 建索引，避免多次 Select
            var dtpByType = GroupRowsByType(dtp);

            // 构建 m_bt_DBData 行
            foreach (DataRow srcRow in dt.Rows)
            {
                string typeId = srcRow["TypeId"].ToString();
                DataRow dr = m_bt_DBData.NewRow();
                dr["TypeName"] = srcRow["TypeName"].ToString();
                dr["TypeId"] = typeId;
                dr["con"] = srcRow["con"].ToString();
                dr["GroupId"] = srcRow["GroupId"].ToString();
                dr["Class"] = string.IsNullOrEmpty(srcRow["GroupName"].ToString()) ? "Default" : srcRow["GroupName"].ToString();
                dr["Largest"] = Math.Round(Convert.ToDouble(srcRow["max"]), 2);

                List<DataRow> rowsOfType;
                dtpByType.TryGetValue(typeId, out rowsOfType);
                if (rowsOfType == null) rowsOfType = new List<DataRow>();

                // 为每个 size bucket 计数
                for (int a = 0; a < sizeBucketNames.Count; a++)
                {
                    double min = 0, max = double.MaxValue;
                    if (blBelow7)
                    {
                        min = sizes[a];
                        max = (a < sizes.Count - 1) ? sizes[a + 1] : double.MaxValue;
                    }
                    else
                    {
                        var parts = sizeBucketNames[a].Split('~');
                        double.TryParse(parts[0], out min);
                        if (parts.Length > 1 && parts[1] != "MAX")
                        {
                            double.TryParse(parts[1], out max);
                        }
                        else if (parts.Length > 1 && parts[1] == "MAX")
                        {
                            max = double.MaxValue;
                        }
                    }

                    int count = CountRowsInRange(rowsOfType, po, min, max);
                    dr[sizeBucketNames[a]] = count;
                }

                // ar 字段填充
                dr["ar"] = 0;
                foreach (DataRow arRow in AreaInformationOfAllElements.Rows)
                {
                    if (arRow["TypeId"].ToString() == typeId)
                    {
                        dr["ar"] = arRow["ar"];
                        break;
                    }
                }

                m_bt_DBData.Rows.Add(dr);
            }

            // 按名称过滤不需要的物质分类（保持原行为）
            FilterByDeleteClass(m_bt_DBData, m_mbszclass);

			// 构建 GroupInformation（去重）
			GroupInformation = ExtractUniqueClasses(m_bt_DBData, "Class");
			//GroupInformation = m_bt_DBData.AsEnumerable()
   //                                      .Select(r => r["Class"].ToString())
   //                                      .Distinct()
   //                                      .ToList();

            // 系统类型为 IncA 时，按 Class 拆分
            if (m_otsreport_export.m_ReportApp.m_RptConfigFile.Systype == OTS_SysType_ID.IncA)
            {
                BData = GroupInformation.Select(g =>
                {
                    var t = m_bt_DBData.Clone();
                    foreach (DataRow r in m_bt_DBData.Rows)
                    {
                        if (r["Class"].ToString() == g) t.Rows.Add(r.ItemArray);
                    }
                    return t;
                }).ToList();

                Measurements = GroupInformation.Select(g =>
                {
                    var t = dtp.Clone();
                    foreach (DataRow r in dtp.Rows)
                    {
                        string groupName = string.IsNullOrEmpty(r["GroupName"].ToString()) ? "Default" : r["GroupName"].ToString();
                        if (groupName == g) t.Rows.Add(r.ItemArray);
                    }
                    return t;
                }).ToList();

                return;
            }

			// 判断是否使用指定组（RuleGroup 中存在 GroupId == "0"）
			bool useSpecifyGroups = TableContainsGroupIdZero(m_otsreport_export.m_mbszclass.RuleGroup);

			//bool useSpecifyGroups = m_otsreport_export.m_mbszclass.RuleGroup.AsEnumerable()
   //                                     .Any(r => r["GroupId"].ToString() == "0");

            if (!useSpecifyGroups)
            {
				// 按现有 GroupId 拆分 BData
				var groups = ExtractUniqueClasses(m_bt_DBData, "GroupId");
				//var groups = m_bt_DBData.AsEnumerable()
    //                                    .Select(r => r["GroupId"].ToString())
    //                                    .Distinct()
    //                                    .ToList();

                BData = groups.Select(g =>
                {
                    var t = m_bt_DBData.Clone();
                    foreach (DataRow r in m_bt_DBData.Rows)
                    {
                        if (r["GroupId"].ToString() == g) t.Rows.Add(r.ItemArray);
                    }
                    return t;
                }).ToList();

                // Measurements 按 GroupInformation 拆分
                Measurements = GroupInformation.Select(g =>
                {
                    var t = dtp.Clone();
                    foreach (DataRow r in dtp.Rows)
                    {
                        string strGroupId = string.IsNullOrEmpty(r["GroupName"].ToString()) ? "Default" : r["GroupName"].ToString();
                        if (strGroupId == g) t.Rows.Add(r.ItemArray);
                    }
                    return t;
                }).ToList();

                return;
            }

            // 使用指定规则组：按模板 m_mbszclass.List_data 构造
            BData = BuildSpecifyGroup(m_bt_DBData, m_mbszclass);

            // 测量结果颗粒组队列（修复原代码索引误用）
            List<DataTable> datas1 = new List<DataTable>();
			List<string> stringsa = particleData.ObtainParticleCategory(m_otsreport_export, this);
			for (int i = 0; i < stringsa.Count; i++)
			{
				DataTable data = dtp.Clone();
				for (int a = 0; a < dtp.Rows.Count; a++)
				{
                    if (Convert.ToInt64(dtp.Rows[i]["TypeId"]) > 10)
                    {
                        string strGroupName = string.IsNullOrEmpty(dtp.Rows[a]["GroupName"].ToString()) ? "Default" : dtp.Rows[a]["GroupName"].ToString();
						if (stringsa[i].ToString() == strGroupName)
						{
							data.Rows.Add(dtp.Rows[a].ItemArray);
						}
					}
				}
				datas1.Add(data);
			}

			Measurements = new List<DataTable>();
			for (int i = 0; i < m_otsreport_export.m_mbszclass.List_data.Count; i++)
            {
				bool b3 = false;
				string str_class = "";
				for (int a = 0; a < m_otsreport_export.m_mbszclass.RuleGroup.Rows.Count; a++)
				{
					if (m_otsreport_export.m_mbszclass.RuleGroup.Rows[a]["GroupId"].ToString() == m_otsreport_export.m_mbszclass.List_data[i].TableName)
					{
						if (m_otsreport_export.m_mbszclass.RuleGroup.Rows[a]["display"].ToString() == "1")
						{
							str_class = m_otsreport_export.m_mbszclass.RuleGroup.Rows[a]["GroupName"].ToString();
							b3 = true;
						}
					}
				}

                
				if (b3)
                {
					DataTable table = datas1[i].Clone();
					for (int a = 0; a < datas1[i].Rows.Count; a++)
                    {
						for (int b = 0; b < m_otsreport_export.m_mbszclass.List_data[i].Rows.Count; b++)
                        {
                            if (m_otsreport_export.m_mbszclass.List_data[i].Rows[b]["display"].ToString() == "1")
                            {
								if (datas1[i].Rows[a]["TypeId"].ToString() == m_otsreport_export.m_mbszclass.List_data[i].Rows[b]["STDId"].ToString())
								{
									table.Rows.Add(datas1[i].Rows[a].ItemArray);
								}
							}
                        }
					}
					Measurements.Add(table);
				}
			}
        }

		// ---------- 私有辅助函数 ----------

		private bool TableContainsGroupIdZero(DataTable table)
		{
			if (table == null || table.Rows.Count == 0) return false;
			foreach (DataRow row in table.Rows)
			{
				if (row == null) continue;
				var obj = row["GroupId"];
				if (obj == null) continue;
				if (obj.ToString().Trim() == "0") return true;
			}
			return false;
		}
		private List<string> ExtractUniqueClasses(DataTable table ,string textNmae)
		{
			var set = new HashSet<string>();
			if (table == null) return new List<string>();

			foreach (DataRow row in table.Rows)
			{
				if (row == null) continue;
				var obj = row[textNmae];
				if (obj == null) continue;
				var s = obj.ToString().Trim();
				if (string.IsNullOrEmpty(s)) continue;
				set.Add(s);
			}

			return new List<string>(set);
		}
		private List<double> ParseSizeString(string sizestr)
		{
			if (string.IsNullOrEmpty(sizestr)) return new List<double>();
			return sizestr.Split(new[] { ',' }, StringSplitOptions.RemoveEmptyEntries)
						  .Select(s => { double.TryParse(s.Trim(), out double v); return v; })
						  .ToList();
		}

		private void BuildSizeColumnLists(List<double> sizes, List<string> out_geCols, List<string> out_rangeCols)
		{
			out_geCols.Clear();
			out_rangeCols.Clear();
			if (sizes == null || sizes.Count == 0) return;

			foreach (var d in sizes) out_geCols.Add("≥" + d.ToString());

			for (int i = 0; i < sizes.Count - 1; i++)
			{
				out_rangeCols.Add(sizes[i].ToString() + "~" + sizes[i + 1].ToString());
			}
			out_rangeCols.Add(sizes.Last().ToString() + "~MAX");
		}

		private void BuildSizeColumns(List<double> sizes, out List<string> sizeBucketNames, out bool blBelow7)
		{
			sizeBucketNames = new List<string>();
			blBelow7 = (sizes != null && sizes.Count > 7);
			if (sizes == null || sizes.Count == 0) return;

			if (blBelow7)
			{
				foreach (var d in sizes) sizeBucketNames.Add("≥" + d.ToString());
			}
			else
			{
				for (int i = 0; i < sizes.Count - 1; i++)
				{
					sizeBucketNames.Add(sizes[i].ToString() + "~" + sizes[i + 1].ToString());
				}
				sizeBucketNames.Add(sizes.Last().ToString() + "~MAX");
			}
		}

		private Dictionary<string, List<DataRow>> GroupRowsByType(DataTable dtp)
		{
			var dict = new Dictionary<string, List<DataRow>>();
			if (dtp == null) return dict;
			foreach (DataRow r in dtp.Rows)
			{
				string key = r["TypeId"].ToString();
				if (!dict.ContainsKey(key)) dict[key] = new List<DataRow>();
				dict[key].Add(r);
			}
			return dict;
		}

		private int CountRowsInRange(List<DataRow> rows, string columnName, double min, double max)
		{
			if (rows == null || rows.Count == 0) return 0;
			int cnt = 0;
			if (columnName == "Area")
			{
				double areaMin = (min / 2.0) * (min / 2.0) * Math.PI;
				double areaMax = (max == double.MaxValue) ? double.MaxValue : (max / 2.0) * (max / 2.0) * Math.PI;
				foreach (var r in rows)
				{
					if (double.TryParse(r["Area"].ToString(), out double v))
					{
						if (v >= areaMin && v < areaMax) cnt++;
					}
				}
			}
			else
			{
				foreach (var r in rows)
				{
					if (double.TryParse(r[columnName].ToString(), out double v))
					{
						if (v >= min && v < max) cnt++;
					}
				}
			}
			return cnt;
		}

		private void FilterByDeleteClass(DataTable table, c_TemplateClass m_mbszclass)
		{
			if (m_mbszclass?.M_KLLBXX?.list_str_kllb_DeleteClass == null || m_mbszclass.M_KLLBXX.list_str_kllb_DeleteClass.Count == 0) return;
			var toRemove = new HashSet<string>(m_mbszclass.M_KLLBXX.list_str_kllb_DeleteClass);
			for (int i = table.Rows.Count - 1; i >= 0; i--)
			{
				if (toRemove.Contains(table.Rows[i]["TypeName"].ToString()))
				{
					table.Rows.RemoveAt(i);
				}
			}
		}

		private List<DataTable> BuildSpecifyGroup(DataTable m_bt_DBData, c_TemplateClass m_mbszclass)
		{
			var SpecifyGroup = new List<DataTable>();
			for (int i = 0; i < m_mbszclass.List_data.Count; i++)
			{
				DataTable tpl = m_mbszclass.List_data[i];
				DataTable data = m_bt_DBData.Clone();
				bool visible = false;
				string str_class = "";

				foreach (DataRow rg in m_mbszclass.RuleGroup.Rows)
				{
					if (rg["GroupId"].ToString() == tpl.TableName)
					{
						if (rg["display"].ToString() == "1")
						{
							visible = true;
							str_class = rg["GroupName"].ToString();
						}
						break;
					}
				}

				data.TableName = tpl.TableName;
				if (!visible)
				{
					SpecifyGroup.Add(data);
					continue;
				}

				for (int a = 0; a < tpl.Rows.Count; a++)
				{
					if (tpl.Rows[a]["display"].ToString() != "1") continue;

					string stdId = tpl.Rows[a]["STDId"].ToString();
					var found = FindRowByTypeId(m_bt_DBData, stdId);
					if (found != null)
					{
						data.Rows.Add(found.ItemArray);
					}
					else
					{
						DataRow newRow = data.NewRow();
						newRow["TypeName"] = tpl.Rows[a]["StrName"];
						newRow["ar"] = 0;
						newRow["TypeId"] = stdId;
						newRow["GroupId"] = tpl.Rows[a]["GroupId"];
						newRow["con"] = 0;
						newRow["Largest"] = 0;
						newRow["Class"] = str_class;
						for (int j = 7; j < data.Columns.Count; j++) newRow[j] = 0;
						data.Rows.Add(newRow);
					}
				}

				SpecifyGroup.Add(data);
			}
			return SpecifyGroup;
		}

		private DataRow FindRowByTypeId(DataTable table, string typeId)
		{
			foreach (DataRow r in table.Rows)
			{
				if (r["TypeId"].ToString() == typeId) return r;
			}
			return null;
		}

		// ---------- 其余方法保持原样 ----------

		/// <summary>
		/// 获取夹杂物组信息
		/// </summary>
		/// <returns></returns>
		public List<string> GetGroupInformation()
		{
			return GroupInformation;
		}
		/// <summary>
		/// 获取读取数据库并过滤颗粒
		/// </summary>
		/// <returns></returns>
		public List<DataTable> GetDBData()
		{
			return BData;
		}
		/// <summary>
		/// 获取读取数据库并过滤颗粒
		/// </summary>
		/// <returns></returns>
		public List<DataTable> etDBData()
		{
			return BData;
		}
		public void SetAllClass()
		{
			AllClass = fielddata.GetAllClass();
		}
		/// <summary>
		/// 获取全部大类
		/// </summary>
		/// <returns></returns>
		public DataTable GetAllClass()
		{
			return AllClass;
		}
		/// <summary>
		///测量结果数据列队
		/// </summary>
		/// <returns></returns>
		public List<DataTable> GetMeasurements()
		{
			return Measurements;

		}

		/// <summary>
		/// 定义ParticleData类
		/// </summary>
		public void newParticleData(OTSReport_Export m_otsreport_export)
		{
			fielddata = new ParticleData(m_otsreport_export.m_ReportApp.m_rstDataMgr.ResultFilesList[m_otsreport_export.m_ReportApp.m_rstDataMgr.GetWorkingResultId()].FilePath);
		}
		public ParticleData getParticleData()
		{
			return fielddata;
		}
		public void SetAllElement()
		{
			AllElement = fielddata.GetAllElement();
		}
		/// <summary>
		/// 获取全部元素
		/// </summary>
		/// <returns></returns>
		public DataTable GetAllElement()
		{
			return AllElement;
		}
		/// <summary>
		/// 判断是否有大分类，有为true
		/// </summary>
		/// <param name="m_otsreport_export"></param>
		/// <returns></returns>
		public void IsThereAMajorClassification(BasicData basicData, OTSReport_Export m_otsreport_export)
		{
			List<string> ClassName = new List<string>();

			for (int i = 0; i < BData.Count; i++)
			{
				if (BData[i].Rows.Count != 0)
				{
					ClassName.Add(i.ToString());
				}
			}

			if (ClassName.Count < 2)
			{
				IsShereAClassificationGroup = false;
			}
			else
			{
				IsShereAClassificationGroup = true;
			}
		}
		public bool GetIsThereAMajorClassification()
		{
			return IsShereAClassificationGroup;
		}



		public void IsResultFilesList(OTSReport_Export m_otsreport_export)
		{
			resfile = m_otsreport_export.m_ReportApp.m_rstDataMgr.ResultFilesList[m_otsreport_export.m_ReportApp.m_rstDataMgr.GetWorkingResultId()];
		}
		/// <summary>
		/// 获取标准库名称
		/// </summary>
		/// <returns></returns>
		public string GetResfile()
		{
			string str_libraryName = "";
			bool endsWithDb = resfile.GetSTDName().EndsWith(".db", StringComparison.OrdinalIgnoreCase);
			if (endsWithDb)
			{
				str_libraryName = resfile.GetSTDName();
			}
			else
			{
				str_libraryName = resfile.GetSTDName() + ".db";
			}
			return str_libraryName;
		}
		public void IsFilePath(OTSReport_Export m_otsreport_export)
		{
			FilePath = m_otsreport_export.m_ReportApp.m_rstDataMgr.CurResultFile.FilePath;
		}
		/// <summary>
		/// 得到文件路径
		/// </summary>
		/// <returns></returns>
		public string GetFilePath()
		{
			return FilePath;
		}

		#region 内部函数（保留原有两个）
		private string getWhere(string max, string min, string col, string partic)
		{
			if (col == "Area")
			{
				return col + ">=" + ((Convert.ToDouble(min) / 2) * (Convert.ToDouble(min) / 2) * Math.PI).ToString() + " and " + col + "<" + ((Convert.ToDouble(max) / 2) * (Convert.ToDouble(max) / 2) * Math.PI).ToString() + " and TypeId=" + partic;

			}
			else
			{
				return col + ">=" + min + " and " + col + "<" + max + " and TypeId=" + partic;
			}

		}
		private DataTable InvalidRemoval(DataTable dt)
		{
			DataTable dataTable = dt.Copy();
			dataTable.Clear();

			for (int i = 0; i < dt.Rows.Count; i++)
			{
				if (Convert.ToInt32(dt.Rows[i]["TypeId"]) > 10)
				{
					dataTable.Rows.Add(dt.Rows[i].ItemArray);
				}
			}
			return dataTable;
		}
		#endregion
	}
}