From 559890c482f5973f06aafdfec9550fee5ba3c7f2 Mon Sep 17 00:00:00 2001
From: wenxiangchao <wenxiangchao@ihengxin.com.cn>
Date: 星期一, 09 十一月 2026 17:02:15 +0800
Subject: [PATCH] feat: CAN 模拟器 TCP 化 + 多设备并发调试 + 后台生命周期管理
---
Aging.Infrastructure/Broker/DeviceConfigHash.cs | 78 +++++++++++++++++++++++++++++++++++++++
1 files changed, 78 insertions(+), 0 deletions(-)
diff --git a/Aging.Infrastructure/Broker/DeviceConfigHash.cs b/Aging.Infrastructure/Broker/DeviceConfigHash.cs
new file mode 100644
index 0000000..a6b4d13
--- /dev/null
+++ b/Aging.Infrastructure/Broker/DeviceConfigHash.cs
@@ -0,0 +1,78 @@
+using System;
+using System.Data;
+using System.IO;
+using System.Security.Cryptography;
+using System.Text;
+
+namespace Aging.Infrastructure.Broker
+{
+ /// <summary>
+ /// 浠� DeviceConfig 鐨� data.db 璁＄畻涓嶅彲鍙橀厤缃揩鐓у搱甯岋紙INV-04 瀵硅处鍩哄噯锛夈��
+ /// 鎷兼帴瑙勫垯涓� Plugin.DeviceConfig.Model.DeviceConfigModel.ComputeConfigHash 淇濇寔涓�鑷达細
+ /// DEVICE / CHANNEL / SLOT 涓夋鎸夊悇鑷帓搴忔嫾鎺ュ悗 SHA256锛堝皬鍐欏崄鍏繘鍒讹級銆�
+ /// OwnerProcessId 灞炶繍琛屾湡淇℃伅锛屼笉鍙備笌鍝堝笇銆�
+ /// </summary>
+ public static class DeviceConfigHash
+ {
+ public static string Compute(string dataDbPath)
+ {
+ if (!File.Exists(dataDbPath))
+ throw new FileNotFoundException("閰嶇疆搴撲笉瀛樺湪", dataDbPath);
+
+ var sb = new StringBuilder();
+ using (var conn = new System.Data.SQLite.SQLiteConnection(
+ $"Data Source={dataDbPath};Version=3;Read Only=True;"))
+ {
+ conn.Open();
+ AppendRows(conn, "DeviceDefinition", "SELECT * FROM DeviceDefinition ORDER BY DeviceId;", sb, row =>
+ {
+ string em = Col(row, "ExecutionMode") ?? "Local";
+ string auth = Col(row, "AuthorityId") ?? "";
+ string bk = Col(row, "BrokerId") ?? "";
+ string sk = Col(row, "PhysicalSessionKey") ?? "";
+ return $"DEVICE:{row["DeviceId"]}|{row["Kind"]}|{row["DriverType"]}|{row["Transport"]}|{row["Endpoint"]}|{em}|{auth}|{bk}|{sk};";
+ });
+ AppendRows(conn, "DeviceChannel", "SELECT * FROM DeviceChannel ORDER BY DeviceId, ChannelId;", sb, row =>
+ $"CHANNEL:{row["DeviceId"]}|{row["ChannelId"]}|{row["Capability"]}|{row["MaxVoltage"]}|{row["MaxCurrent"]};");
+ AppendRows(conn, "SlotDeviceMapping", "SELECT * FROM SlotDeviceMapping ORDER BY SlotId, Capability, Version;", sb, row =>
+ $"SLOT:{row["SlotId"]}|{row["Capability"]}|{row["Version"]}|{row["DeviceId"]}|{row["ChannelId"]};");
+ }
+
+ using (var sha = SHA256.Create())
+ {
+ var hash = sha.ComputeHash(Encoding.UTF8.GetBytes(sb.ToString()));
+ return BitConverter.ToString(hash).Replace("-", "").ToLowerInvariant();
+ }
+ }
+
+ private static void AppendRows(System.Data.SQLite.SQLiteConnection conn, string table, string sql, StringBuilder sb, Func<DataRow, string> fmt)
+ {
+ // 琛ㄧ己澶辨椂璺宠繃绌烘锛氬搱甯屽鈥滀笉瀛樺湪鐨勬暟鎹�濅笌鈥滈浂琛屸�濈粨鏋滀竴鑷达紝涓や晶鍚屽嚱鏁颁繚璇佸彲瀵硅处
+ using (var probe = conn.CreateCommand())
+ {
+ probe.CommandText = "SELECT COUNT(*) FROM sqlite_master WHERE type='table' AND name=@t;";
+ probe.Parameters.AddWithValue("@t", table);
+ var has = Convert.ToInt64(probe.ExecuteScalar()) > 0;
+ if (!has) return;
+ }
+ using (var cmd = conn.CreateCommand())
+ {
+ cmd.CommandText = sql;
+ using (var rd = cmd.ExecuteReader())
+ {
+ var dt = new DataTable();
+ dt.Load(rd);
+ foreach (DataRow row in dt.Rows)
+ sb.Append(fmt(row));
+ }
+ }
+ }
+
+ private static string? Col(DataRow row, string name)
+ {
+ if (row.Table.Columns.Contains(name) && row[name] != DBNull.Value)
+ return row[name].ToString();
+ return null;
+ }
+ }
+}
--
Gitblit v1.9.1