"第7天：MC4.0适配器（对象树+实时数据+告警）"

2026-05-17 00:23:18 +08:00
parent 6ebe327879
commit 206eaad42d
7 changed files with 336 additions and 0 deletions
--- a/gateway/IntegrationGateway.sln
+++ b/gateway/IntegrationGateway.sln
@@ -11,6 +11,8 @@ Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "IntegrationGateway.Core", "
 EndProject
 Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "IntegrationGateway.Adapters.Owl", "src\IntegrationGateway.Adapters.Owl\IntegrationGateway.Adapters.Owl.csproj", "{8B0BD376-E1C5-4B62-AEC9-E2F4397C991E}"
 EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "IntegrationGateway.Adapters.MC4", "src\IntegrationGateway.Adapters.MC4\IntegrationGateway.Adapters.MC4.csproj", "{6C64C3EB-58ED-45A3-B86D-0B464081BFA0}"
+EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
 		Debug|Any CPU = Debug|Any CPU
@@ -57,6 +59,18 @@ Global
 		{8B0BD376-E1C5-4B62-AEC9-E2F4397C991E}.Release|x64.Build.0 = Release|Any CPU
 		{8B0BD376-E1C5-4B62-AEC9-E2F4397C991E}.Release|x86.ActiveCfg = Release|Any CPU
 		{8B0BD376-E1C5-4B62-AEC9-E2F4397C991E}.Release|x86.Build.0 = Release|Any CPU
+		{6C64C3EB-58ED-45A3-B86D-0B464081BFA0}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{6C64C3EB-58ED-45A3-B86D-0B464081BFA0}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{6C64C3EB-58ED-45A3-B86D-0B464081BFA0}.Debug|x64.ActiveCfg = Debug|Any CPU
+		{6C64C3EB-58ED-45A3-B86D-0B464081BFA0}.Debug|x64.Build.0 = Debug|Any CPU
+		{6C64C3EB-58ED-45A3-B86D-0B464081BFA0}.Debug|x86.ActiveCfg = Debug|Any CPU
+		{6C64C3EB-58ED-45A3-B86D-0B464081BFA0}.Debug|x86.Build.0 = Debug|Any CPU
+		{6C64C3EB-58ED-45A3-B86D-0B464081BFA0}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{6C64C3EB-58ED-45A3-B86D-0B464081BFA0}.Release|Any CPU.Build.0 = Release|Any CPU
+		{6C64C3EB-58ED-45A3-B86D-0B464081BFA0}.Release|x64.ActiveCfg = Release|Any CPU
+		{6C64C3EB-58ED-45A3-B86D-0B464081BFA0}.Release|x64.Build.0 = Release|Any CPU
+		{6C64C3EB-58ED-45A3-B86D-0B464081BFA0}.Release|x86.ActiveCfg = Release|Any CPU
+		{6C64C3EB-58ED-45A3-B86D-0B464081BFA0}.Release|x86.Build.0 = Release|Any CPU
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE
@@ -65,5 +79,6 @@ Global
 		{387BD4FC-725B-4948-B413-F50BC6BD605D} = {827E0CD3-B72D-47B6-A68D-7590B98EB39B}
 		{2055B7A5-418F-456C-8642-A99A68282561} = {827E0CD3-B72D-47B6-A68D-7590B98EB39B}
 		{8B0BD376-E1C5-4B62-AEC9-E2F4397C991E} = {827E0CD3-B72D-47B6-A68D-7590B98EB39B}
+		{6C64C3EB-58ED-45A3-B86D-0B464081BFA0} = {827E0CD3-B72D-47B6-A68D-7590B98EB39B}
 	EndGlobalSection
 EndGlobal
--- a/gateway/src/IntegrationGateway.Adapters.MC4/IntegrationGateway.Adapters.MC4.csproj
+++ b/gateway/src/IntegrationGateway.Adapters.MC4/IntegrationGateway.Adapters.MC4.csproj
@@ -0,0 +1,13 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <ItemGroup>
+    <ProjectReference Include="..\IntegrationGateway.Core\IntegrationGateway.Core.csproj" />
+  </ItemGroup>
+
+  <PropertyGroup>
+    <TargetFramework>net8.0</TargetFramework>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <Nullable>enable</Nullable>
+  </PropertyGroup>
+
+</Project>
--- a/gateway/src/IntegrationGateway.Adapters.MC4/Mc4Adapter.cs
+++ b/gateway/src/IntegrationGateway.Adapters.MC4/Mc4Adapter.cs
@@ -0,0 +1,249 @@
+using IntegrationGateway.Core.Abstractions;
+using IntegrationGateway.Core.Infrastructure;
+using IntegrationGateway.Core.Models;
+using System.Text;
+using System.Text.Json;
+
+namespace IntegrationGateway.Adapters.MC4;
+
+public class Mc4Adapter : IHasOwnDeviceTree, IHasPoints, IHasAlarms
+{
+    private readonly HttpClient _http;
+    private readonly Mc4AuthHelper _auth;
+    private readonly RateLimiter _limiter = new(2);
+
+    public string AdapterCode { get; }
+    public string DisplayName => $"MC4 ({AdapterCode})";
+    public AdapterCapabilities Capabilities => new()
+    {
+        HasObjectTree = true, HasPoints = true, HasAlarms = true, AcceptsControl = true
+    };
+
+    public Mc4Adapter(string adapterCode, HttpClient http, string baseUrl)
+    {
+        AdapterCode = adapterCode;
+        _http = http;
+        _auth = new Mc4AuthHelper(http, baseUrl);
+    }
+
+    public async Task InitializeAsync() => await _auth.GetTokenAsync();
+
+    public async Task<bool> HealthCheckAsync()
+    {
+        try
+        {
+            var client = await _auth.GetAuthenticatedClientAsync();
+            var resp = await client.PostAsync("/api/central/auth/conf/get", null);
+            return resp.IsSuccessStatusCode;
+        }
+        catch { return false; }
+    }
+
+    // ─── IHasOwnDeviceTree ───
+    public async Task<List<DeviceTreeNode>> GetObjectTreeAsync()
+    {
+        await _limiter.WaitAsync();
+        var client = await _auth.GetAuthenticatedClientAsync();
+        var resp = await client.PostAsync("/api/central/object/tree", null);
+        resp.EnsureSuccessStatusCode();
+        var json = await resp.Content.ReadAsStringAsync();
+        var tree = JsonSerializer.Deserialize<List<Mc4TreeNode>>(json)!;
+        return tree.Select(MapNode).ToList();
+    }
+
+    private static DeviceTreeNode MapNode(Mc4TreeNode n) => new()
+    {
+        SourceId = n.Id,
+        Name = n.Name ?? n.Id.ToString(),
+        NodeType = n.Type,
+        ObjectType = n.ObjectType,
+        Tag = n.Tag,
+        Option = n.Option ?? new Dictionary<string, object?>(),
+        Children = n.Children?.Select(MapNode).ToList() ?? new()
+    };
+
+    // ─── IHasPoints ───
+    public async Task<List<PointValue>> GetRealtimeValuesAsync(string sourceDeviceId)
+    {
+        await _limiter.WaitAsync();
+        var client = await _auth.GetAuthenticatedClientAsync();
+        var body = JsonSerializer.Serialize(new { id = int.Parse(sourceDeviceId) });
+        var resp = await client.PostAsync("/api/central/device/point/value/get",
+            new StringContent(body, Encoding.UTF8, "application/json"));
+        resp.EnsureSuccessStatusCode();
+        var json = await resp.Content.ReadAsStringAsync();
+        var values = JsonSerializer.Deserialize<List<Mc4PointValue>>(json)!;
+        return values.Select(v => new PointValue
+        {
+            SourceDeviceId = sourceDeviceId,
+            PointIndex = v.Index,
+            Value = v.Value,
+            UpdateTime = v.Time,
+            Interval = v.Interval
+        }).ToList();
+    }
+
+    public async Task<List<PointValue>> GetMultiPointValuesAsync(List<(string DeviceId, int PointIndex)> points)
+    {
+        await _limiter.WaitAsync();
+        var client = await _auth.GetAuthenticatedClientAsync();
+        var body = JsonSerializer.Serialize(new
+        {
+            points = points.Select(p => new { id = int.Parse(p.DeviceId), index = p.PointIndex })
+        });
+        var resp = await client.PostAsync("/api/central/point/multi/value/get",
+            new StringContent(body, Encoding.UTF8, "application/json"));
+        resp.EnsureSuccessStatusCode();
+        var json = await resp.Content.ReadAsStringAsync();
+        var values = JsonSerializer.Deserialize<List<Mc4PointValue>>(json)!;
+        return values.Select(v => new PointValue
+        {
+            SourceDeviceId = v.Id.ToString(),
+            PointIndex = v.Index,
+            Value = v.Value,
+            UpdateTime = v.Time,
+            Interval = v.Interval
+        }).ToList();
+    }
+
+    public async Task SetPointValueAsync(string sourceDeviceId, int pointIndex, double value)
+    {
+        await _limiter.WaitAsync();
+        var client = await _auth.GetAuthenticatedClientAsync();
+        var body = JsonSerializer.Serialize(new { id = int.Parse(sourceDeviceId), index = pointIndex, value });
+        await client.PostAsync("/api/central/point/value/set",
+            new StringContent(body, Encoding.UTF8, "application/json"));
+    }
+
+    // ─── IHasAlarms ───
+    public async Task<PagedResult<StandardAlarm>> GetAlarmsAsync(int page, int size, DateTime from, DateTime to,
+        int? confirmState = null, int? endState = null, List<int>? levels = null)
+    {
+        await _limiter.WaitAsync();
+        var client = await _auth.GetAuthenticatedClientAsync();
+        var body = JsonSerializer.Serialize(new Mc4AlarmQuery
+        {
+            From = from.ToString("yyyy-MM-dd HH:mm:ss"),
+            To = to.ToString("yyyy-MM-dd HH:mm:ss"),
+            Skip = (page - 1) * size,
+            Limit = size,
+            Sort = 1
+        });
+        var resp = await client.PostAsync("/api/central/alarm/query",
+            new StringContent(body, Encoding.UTF8, "application/json"));
+        resp.EnsureSuccessStatusCode();
+        var json = await resp.Content.ReadAsStringAsync();
+        var result = JsonSerializer.Deserialize<Mc4AlarmQueryResult>(json)!;
+
+        return new PagedResult<StandardAlarm>
+        {
+            Items = result.List?.Select(a => new StandardAlarm
+            {
+                AlarmId = a.Id ?? "",
+                DeviceId = a.Sid?.ToString(),
+                AdapterCode = AdapterCode,
+                Level = MapAlarmLevel(a.Level),
+                Title = a.Desc ?? "",
+                Content = a.EngDesc,
+                OccurTime = DateTime.TryParse(a.Stime, out var st) ? st : DateTime.MinValue,
+                Status = MapAlarmState(a.State),
+                ActualValue = a.Soption?.Value,
+                ThresholdValue = a.Eoption?.Value
+            }).ToList() ?? new(),
+            Total = result.Total
+        };
+    }
+
+    public async Task ConfirmAlarmAsync(string alarmId)
+    {
+        await _limiter.WaitAsync();
+        var client = await _auth.GetAuthenticatedClientAsync();
+        var body = JsonSerializer.Serialize(new { id = alarmId, option = new { } });
+        await client.PostAsync("/api/central/alarm/confirm",
+            new StringContent(body, Encoding.UTF8, "application/json"));
+    }
+
+    public async Task EndAlarmAsync(string alarmId)
+    {
+        await _limiter.WaitAsync();
+        var client = await _auth.GetAuthenticatedClientAsync();
+        var body = JsonSerializer.Serialize(new { id = alarmId, option = new { } });
+        await client.PostAsync("/api/central/alarm/end",
+            new StringContent(body, Encoding.UTF8, "application/json"));
+    }
+
+    public async Task<int> GetPendingAlarmCountAsync()
+    {
+        await _limiter.WaitAsync();
+        var client = await _auth.GetAuthenticatedClientAsync();
+        var body = JsonSerializer.Serialize(new { state = 1 });
+        var resp = await client.PostAsync("/api/central/alarm/custom_query_count",
+            new StringContent(body, Encoding.UTF8, "application/json"));
+        resp.EnsureSuccessStatusCode();
+        var json = await resp.Content.ReadAsStringAsync();
+        return int.TryParse(json, out var count) ? count : 0;
+    }
+
+    private static string MapAlarmLevel(int level) => level switch { 1 => "提示", 2 => "普通", 3 => "重要", 4 => "紧急", _ => "提示" };
+    private static string MapAlarmState(int state) => state switch { 1 => "未确认", 2 => "已确认", 3 => "已结束", _ => "未确认" };
+}
+
+// ─── MC4 JSON Models ───
+public class Mc4TreeNode
+{
+    public int Id { get; set; }
+    public string? Name { get; set; }
+    public int Type { get; set; }
+    public int ObjectType { get; set; }
+    public string? Tag { get; set; }
+    public Dictionary<string, object?>? Option { get; set; }
+    public List<Mc4TreeNode>? Children { get; set; }
+}
+
+public class Mc4PointValue
+{
+    public int Id { get; set; }
+    public int Index { get; set; }
+    public double Value { get; set; }
+    public string? Time { get; set; }
+    public int Interval { get; set; }
+}
+
+public class Mc4AlarmQuery
+{
+    public string From { get; set; } = "";
+    public string To { get; set; } = "";
+    public int Skip { get; set; }
+    public int Limit { get; set; }
+    public int Sort { get; set; }
+}
+
+public class Mc4AlarmQueryResult
+{
+    public int Total { get; set; }
+    public List<Mc4AlarmItem>? List { get; set; }
+}
+
+public class Mc4AlarmItem
+{
+    public string? Id { get; set; }
+    public int? Sid { get; set; }
+    public int Sno { get; set; }
+    public string? Desc { get; set; }
+    public string? EngDesc { get; set; }
+    public int Level { get; set; }
+    public int State { get; set; }
+    public string? Stime { get; set; }
+    public string? Etime { get; set; }
+    public string? Ctime { get; set; }
+    public string? Cuser { get; set; }
+    public int Type { get; set; }
+    public Mc4Option? Soption { get; set; }
+    public Mc4Option? Eoption { get; set; }
+}
+
+public class Mc4Option
+{
+    public double? Value { get; set; }
+    public string? TypeName { get; set; }
+}
--- a/gateway/src/IntegrationGateway.Adapters.MC4/Mc4AuthHelper.cs
+++ b/gateway/src/IntegrationGateway.Adapters.MC4/Mc4AuthHelper.cs
@@ -0,0 +1,43 @@
+using System.Text.Json;
+
+namespace IntegrationGateway.Adapters.MC4;
+
+public class Mc4AuthHelper
+{
+    private readonly HttpClient _http;
+    private readonly string _baseUrl;
+    private string? _token;
+    private DateTime _tokenExpiry = DateTime.MinValue;
+
+    public Mc4AuthHelper(HttpClient http, string baseUrl)
+    {
+        _http = http;
+        _baseUrl = baseUrl.TrimEnd('/');
+    }
+
+    public async Task<string> GetTokenAsync()
+    {
+        if (!string.IsNullOrEmpty(_token) && DateTime.UtcNow < _tokenExpiry)
+            return _token;
+
+        var resp = await _http.PostAsync($"{_baseUrl}/api/central/auth/conf/get", null);
+        resp.EnsureSuccessStatusCode();
+        var json = await resp.Content.ReadAsStringAsync();
+        var result = JsonSerializer.Deserialize<Mc4AuthResponse>(json);
+        _token = result?.Token ?? "";
+        _tokenExpiry = DateTime.UtcNow.AddHours(8);
+        return _token!;
+    }
+
+    public async Task<HttpClient> GetAuthenticatedClientAsync()
+    {
+        var token = await GetTokenAsync();
+        var client = new HttpClient { BaseAddress = new Uri(_baseUrl) };
+        client.DefaultRequestHeaders.Add("token", token);
+        return client;
+    }
+
+    public void Invalidate() => _token = null;
+
+    public class Mc4AuthResponse { public string? Token { get; set; } }
+}
--- a/gateway/src/IntegrationGateway.Host/IntegrationGateway.Host.csproj
+++ b/gateway/src/IntegrationGateway.Host/IntegrationGateway.Host.csproj
@@ -14,6 +14,7 @@
  <ItemGroup>
    <ProjectReference Include="..\IntegrationGateway.Core\IntegrationGateway.Core.csproj" />
    <ProjectReference Include="..\IntegrationGateway.Adapters.Owl\IntegrationGateway.Adapters.Owl.csproj" />
+    <ProjectReference Include="..\IntegrationGateway.Adapters.MC4\IntegrationGateway.Adapters.MC4.csproj" />
  </ItemGroup>

 </Project>
--- a/gateway/src/IntegrationGateway.Host/Program.cs
+++ b/gateway/src/IntegrationGateway.Host/Program.cs
@@ -1,5 +1,6 @@
 using IntegrationGateway.Core.Infrastructure;
 using IntegrationGateway.Adapters.Owl;
+using IntegrationGateway.Adapters.MC4;
 using IntegrationGateway.Host;

 var builder = WebApplication.CreateBuilder(args);
@@ -37,6 +38,17 @@ var owlAdapter = new OwlAdapter(
 );
 registry.Register(owlAdapter);

+// 注册 MC4 适配器
+var mc4Cfg = builder.Configuration.GetSection("MC4");
+var mc4Http = app.Services.GetRequiredService<IHttpClientFactory>().CreateClient("VolPro");
+var mc4Adapter = new Mc4Adapter(
+    "MC4:31ku",
+    mc4Http,
+    mc4Cfg["BaseUrl"] ?? "http://localhost:3000"
+);
+registry.Register(mc4Adapter);
+
+
        try
        {
            var result = await gw.RegisterAsync();
--- a/gateway/src/IntegrationGateway.Host/appsettings.json
+++ b/gateway/src/IntegrationGateway.Host/appsettings.json
@@ -14,5 +14,8 @@
    "BaseUrl": "http://owl_host:15123",
    "Username": "admin",
    "Password": "your_owl_password"
+  },
+  "MC4": {
+    "BaseUrl": "http://mc4_host:3000"
  }
 }