g82tt/SecMPS
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Phase0_Day1_gateway_rebuilt

Browse Source
This commit is contained in:
g82tt
2026-05-16 16:09:12 +08:00
parent 5790d3e8bf
commit 943bab875a
36 changed files with 851 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

54
gateway/IntegrationGateway.sln Normal file
View File

@@ -0,0 +1,54 @@
Microsoft Visual Studio Solution File, Format Version 12.00
# Visual Studio Version 17
VisualStudioVersion = 17.0.31903.59
MinimumVisualStudioVersion = 10.0.40219.1
Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "src", "src", "{827E0CD3-B72D-47B6-A68D-7590B98EB39B}"
EndProject
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "IntegrationGateway.Host", "src\IntegrationGateway.Host\IntegrationGateway.Host.csproj", "{387BD4FC-725B-4948-B413-F50BC6BD605D}"
EndProject
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "IntegrationGateway.Core", "src\IntegrationGateway.Core\IntegrationGateway.Core.csproj", "{2055B7A5-418F-456C-8642-A99A68282561}"
EndProject
Global
GlobalSection(SolutionConfigurationPlatforms) = preSolution
Debug|Any CPU = Debug|Any CPU
Debug|x64 = Debug|x64
Debug|x86 = Debug|x86
Release|Any CPU = Release|Any CPU
Release|x64 = Release|x64
Release|x86 = Release|x86
EndGlobalSection
GlobalSection(ProjectConfigurationPlatforms) = postSolution
{387BD4FC-725B-4948-B413-F50BC6BD605D}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
{387BD4FC-725B-4948-B413-F50BC6BD605D}.Debug|Any CPU.Build.0 = Debug|Any CPU
{387BD4FC-725B-4948-B413-F50BC6BD605D}.Debug|x64.ActiveCfg = Debug|Any CPU
{387BD4FC-725B-4948-B413-F50BC6BD605D}.Debug|x64.Build.0 = Debug|Any CPU
{387BD4FC-725B-4948-B413-F50BC6BD605D}.Debug|x86.ActiveCfg = Debug|Any CPU
{387BD4FC-725B-4948-B413-F50BC6BD605D}.Debug|x86.Build.0 = Debug|Any CPU
{387BD4FC-725B-4948-B413-F50BC6BD605D}.Release|Any CPU.ActiveCfg = Release|Any CPU
{387BD4FC-725B-4948-B413-F50BC6BD605D}.Release|Any CPU.Build.0 = Release|Any CPU
{387BD4FC-725B-4948-B413-F50BC6BD605D}.Release|x64.ActiveCfg = Release|Any CPU
{387BD4FC-725B-4948-B413-F50BC6BD605D}.Release|x64.Build.0 = Release|Any CPU
{387BD4FC-725B-4948-B413-F50BC6BD605D}.Release|x86.ActiveCfg = Release|Any CPU
{387BD4FC-725B-4948-B413-F50BC6BD605D}.Release|x86.Build.0 = Release|Any CPU
{2055B7A5-418F-456C-8642-A99A68282561}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
{2055B7A5-418F-456C-8642-A99A68282561}.Debug|Any CPU.Build.0 = Debug|Any CPU
{2055B7A5-418F-456C-8642-A99A68282561}.Debug|x64.ActiveCfg = Debug|Any CPU
{2055B7A5-418F-456C-8642-A99A68282561}.Debug|x64.Build.0 = Debug|Any CPU
{2055B7A5-418F-456C-8642-A99A68282561}.Debug|x86.ActiveCfg = Debug|Any CPU
{2055B7A5-418F-456C-8642-A99A68282561}.Debug|x86.Build.0 = Debug|Any CPU
{2055B7A5-418F-456C-8642-A99A68282561}.Release|Any CPU.ActiveCfg = Release|Any CPU
{2055B7A5-418F-456C-8642-A99A68282561}.Release|Any CPU.Build.0 = Release|Any CPU
{2055B7A5-418F-456C-8642-A99A68282561}.Release|x64.ActiveCfg = Release|Any CPU
{2055B7A5-418F-456C-8642-A99A68282561}.Release|x64.Build.0 = Release|Any CPU
{2055B7A5-418F-456C-8642-A99A68282561}.Release|x86.ActiveCfg = Release|Any CPU
{2055B7A5-418F-456C-8642-A99A68282561}.Release|x86.Build.0 = Release|Any CPU
EndGlobalSection
GlobalSection(SolutionProperties) = preSolution
HideSolutionNode = FALSE
EndGlobalSection
GlobalSection(NestedProjects) = preSolution
{387BD4FC-725B-4948-B413-F50BC6BD605D} = {827E0CD3-B72D-47B6-A68D-7590B98EB39B}
{2055B7A5-418F-456C-8642-A99A68282561} = {827E0CD3-B72D-47B6-A68D-7590B98EB39B}
EndGlobalSection
EndGlobal

21
gateway/src/IntegrationGateway.Core/Abstractions/IAcceptsMetadataPush.cs Normal file
View File

@@ -0,0 +1,21 @@
namespace IntegrationGateway.Core.Abstractions;
public interface IAcceptsMetadataPush : IIntegrationAdapter
{
Task<MetadataPushResult> PushMetadataAsync(string sourceDeviceId, MetadataChangeSet changes);
}
public class MetadataChangeSet
{
public string? Name { get; set; }
public string? IpAddress { get; set; }
public int? Port { get; set; }
public int? StreamMode { get; set; }
}
public class MetadataPushResult
{
public bool Success { get; set; }
public List<string> RejectedFields { get; set; } = new();
public string? Reason { get; set; }
}

12
gateway/src/IntegrationGateway.Core/Abstractions/IHasAlarms.cs Normal file
View File

@@ -0,0 +1,12 @@
using IntegrationGateway.Core.Models;
namespace IntegrationGateway.Core.Abstractions;
public interface IHasAlarms : IIntegrationAdapter
{
Task<PagedResult<StandardAlarm>> GetAlarmsAsync(int page, int size, DateTime from, DateTime to,
int? confirmState = null, int? endState = null, List<int>? levels = null);
Task ConfirmAlarmAsync(string alarmId);
Task EndAlarmAsync(string alarmId);
Task<int> GetPendingAlarmCountAsync();
}

12
gateway/src/IntegrationGateway.Core/Abstractions/IHasFlatDevices.cs Normal file
View File

@@ -0,0 +1,12 @@
using IntegrationGateway.Core.Models;
namespace IntegrationGateway.Core.Abstractions;
public interface IHasFlatDevices : IIntegrationAdapter
{
Task<PagedResult<StandardDevice>> GetDevicesAsync(int page, int size, string? keyword = null);
Task<StandardDevice?> GetDeviceAsync(string sourceDeviceId);
Task<List<StandardDevice>> GetAllDevicesAsync();
Task<PagedResult<StandardDevice>> GetChannelsAsync(int page, int size, string? parentDeviceId = null);
Task<List<StandardDevice>> GetAllChannelsAsync();
}

8
gateway/src/IntegrationGateway.Core/Abstractions/IHasOwnDeviceTree.cs Normal file
View File

@@ -0,0 +1,8 @@
using IntegrationGateway.Core.Models;
namespace IntegrationGateway.Core.Abstractions;
public interface IHasOwnDeviceTree : IIntegrationAdapter
{
Task<List<DeviceTreeNode>> GetObjectTreeAsync();
}

10
gateway/src/IntegrationGateway.Core/Abstractions/IHasPoints.cs Normal file
View File

@@ -0,0 +1,10 @@
using IntegrationGateway.Core.Models;
namespace IntegrationGateway.Core.Abstractions;
public interface IHasPoints : IIntegrationAdapter
{
Task<List<PointValue>> GetRealtimeValuesAsync(string sourceDeviceId);
Task<List<PointValue>> GetMultiPointValuesAsync(List<(string DeviceId, int PointIndex)> points);
Task SetPointValueAsync(string sourceDeviceId, int pointIndex, double value);
}

14
gateway/src/IntegrationGateway.Core/Abstractions/IHasStreams.cs Normal file
View File

@@ -0,0 +1,14 @@
using IntegrationGateway.Core.Models;
namespace IntegrationGateway.Core.Abstractions;
public interface IHasStreams : IIntegrationAdapter
{
Task<StreamUrls> GetLiveUrlAsync(string channelId);
Task<StreamUrls> GetPlaybackUrlAsync(string channelId, DateTime start, DateTime end);
Task StopPlayAsync(string channelId);
Task<StreamUrls> GetSnapshotAsync(string channelId);
Task PtzControlAsync(string channelId, string direction, float speed);
Task PtzStopAsync(string channelId);
Task<PagedResult<StandardRecording>> GetRecordingsAsync(string channelId, DateTime start, DateTime end, int page, int size);
}

12
gateway/src/IntegrationGateway.Core/Abstractions/IIntegrationAdapter.cs Normal file
View File

@@ -0,0 +1,12 @@
using IntegrationGateway.Core.Models;
namespace IntegrationGateway.Core.Abstractions;
public interface IIntegrationAdapter
{
string AdapterCode { get; }
string DisplayName { get; }
AdapterCapabilities Capabilities { get; }
Task<bool> HealthCheckAsync();
Task InitializeAsync();
}

27
gateway/src/IntegrationGateway.Core/Infrastructure/AdapterRegistry.cs Normal file
View File

@@ -0,0 +1,27 @@
using IntegrationGateway.Core.Abstractions;
namespace IntegrationGateway.Core.Infrastructure;
public class AdapterRegistry
{
private readonly Dictionary<string, IIntegrationAdapter> _adapters = new();
public void Register(IIntegrationAdapter adapter)
{
_adapters[adapter.AdapterCode] = adapter;
}
public IIntegrationAdapter? Get(string adapterCode)
{
_adapters.TryGetValue(adapterCode, out var adapter);
return adapter;
}
public IEnumerable<IIntegrationAdapter> GetAll() => _adapters.Values;
public async Task InitializeAllAsync()
{
foreach (var adapter in _adapters.Values)
await adapter.InitializeAsync();
}
}

27
gateway/src/IntegrationGateway.Core/Infrastructure/RateLimiter.cs Normal file
View File

@@ -0,0 +1,27 @@
namespace IntegrationGateway.Core.Infrastructure;
public class RateLimiter
{
private readonly SemaphoreSlim _semaphore;
private readonly int _minIntervalMs;
private DateTime _lastRequest = DateTime.MinValue;
public RateLimiter(int maxCallsPerSecond)
{
_semaphore = new SemaphoreSlim(maxCallsPerSecond, maxCallsPerSecond);
_minIntervalMs = 1000 / maxCallsPerSecond;
}
public async Task WaitAsync()
{
await _semaphore.WaitAsync();
try
{
var elapsed = (int)(DateTime.UtcNow - _lastRequest).TotalMilliseconds;
if (elapsed < _minIntervalMs)
await Task.Delay(_minIntervalMs - elapsed);
_lastRequest = DateTime.UtcNow;
}
finally { _semaphore.Release(); }
}
}

26
gateway/src/IntegrationGateway.Core/Infrastructure/TokenManager.cs Normal file
View File

@@ -0,0 +1,26 @@
using Microsoft.Extensions.Caching.Memory;
namespace IntegrationGateway.Core.Infrastructure;
public class TokenManager
{
private readonly IMemoryCache _cache;
private static readonly SemaphoreSlim _semaphore = new(1, 1);
public TokenManager(IMemoryCache cache) => _cache = cache;
public async Task<string?> GetAsync(string key)
{
_cache.TryGetValue($"token_{key}", out string? token);
return token;
}
public async Task SetAsync(string key, string token, TimeSpan expiresIn)
{
await _semaphore.WaitAsync();
try { _cache.Set($"token_{key}", token, expiresIn * 0.9); }
finally { _semaphore.Release(); }
}
public void Remove(string key) => _cache.Remove($"token_{key}");
}

13
gateway/src/IntegrationGateway.Core/IntegrationGateway.Core.csproj Normal file
View File

@@ -0,0 +1,13 @@
<Project Sdk="Microsoft.NET.Sdk">
<PropertyGroup>
<TargetFramework>net8.0</TargetFramework>
<ImplicitUsings>enable</ImplicitUsings>
<Nullable>enable</Nullable>
</PropertyGroup>
<ItemGroup>
<PackageReference Include="Microsoft.Extensions.Caching.Memory" Version="10.0.8" />
</ItemGroup>
</Project>

14
gateway/src/IntegrationGateway.Core/Models/AdapterCapabilities.cs Normal file
View File

@@ -0,0 +1,14 @@
namespace IntegrationGateway.Core.Models;
public class AdapterCapabilities
{
public bool HasObjectTree { get; set; }
public bool HasFlatDevices { get; set; }
public bool HasPoints { get; set; }
public bool HasStreams { get; set; }
public bool HasAlarms { get; set; }
public bool HasRecordings { get; set; }
public bool HasPtz { get; set; }
public bool AcceptsControl { get; set; }
public bool AcceptsMetadataPush { get; set; }
}

13
gateway/src/IntegrationGateway.Core/Models/DeviceTreeNode.cs Normal file
View File

@@ -0,0 +1,13 @@
namespace IntegrationGateway.Core.Models;
public class DeviceTreeNode
{
public int SourceId { get; set; }
public string Name { get; set; } = "";
public int NodeType { get; set; }
public int ObjectType { get; set; }
public string? Tag { get; set; }
public Dictionary<string, object?> Option { get; set; } = new();
public List<DeviceTreeNode> Children { get; set; } = new();
public string? ParentPath { get; set; }
}

7
gateway/src/IntegrationGateway.Core/Models/PagedResult.cs Normal file
View File

@@ -0,0 +1,7 @@
namespace IntegrationGateway.Core.Models;
public class PagedResult<T>
{
public List<T> Items { get; set; } = new();
public int Total { get; set; }
}

11
gateway/src/IntegrationGateway.Core/Models/PointValue.cs Normal file
View File

@@ -0,0 +1,11 @@
namespace IntegrationGateway.Core.Models;
public class PointValue
{
public string SourceDeviceId { get; set; } = "";
public int PointIndex { get; set; }
public double Value { get; set; }
public string? UpdateTime { get; set; }
public int Interval { get; set; }
public bool IsValid { get; set; } = true;
}

15
gateway/src/IntegrationGateway.Core/Models/StandardAlarm.cs Normal file
View File

@@ -0,0 +1,15 @@
namespace IntegrationGateway.Core.Models;
public class StandardAlarm
{
public string AlarmId { get; set; } = "";
public string? DeviceId { get; set; }
public string AdapterCode { get; set; } = "";
public string Level { get; set; } = "";
public string Title { get; set; } = "";
public string? Content { get; set; }
public DateTime OccurTime { get; set; }
public string Status { get; set; } = "Active";
public double? ThresholdValue { get; set; }
public double? ActualValue { get; set; }
}

17
gateway/src/IntegrationGateway.Core/Models/StandardDevice.cs Normal file
View File

@@ -0,0 +1,17 @@
namespace IntegrationGateway.Core.Models;
public class StandardDevice
{
public string SourceId { get; set; } = "";
public string AdapterCode { get; set; } = "";
public string Name { get; set; } = "";
public string Category { get; set; } = "";
public string Group { get; set; } = "";
public string? IpAddress { get; set; }
public int? Port { get; set; }
public bool IsOnline { get; set; }
public bool IsParent { get; set; }
public string? ParentSourceId { get; set; }
public Dictionary<string, object?> Extra { get; set; } = new();
public DateTime LastSyncTime { get; set; }
}

13
gateway/src/IntegrationGateway.Core/Models/StandardPoint.cs Normal file
View File

@@ -0,0 +1,13 @@
namespace IntegrationGateway.Core.Models;
public class StandardPoint
{
public string SourceDeviceId { get; set; } = "";
public int PointIndex { get; set; }
public int PointType { get; set; }
public string? PointTag { get; set; }
public string PointName { get; set; } = "";
public string? PointDesc { get; set; }
public string? Unit { get; set; }
public bool IsControlPoint { get; set; }
}

12
gateway/src/IntegrationGateway.Core/Models/StandardRecording.cs Normal file
View File

@@ -0,0 +1,12 @@
namespace IntegrationGateway.Core.Models;
public class StandardRecording
{
public string Id { get; set; } = "";
public string ChannelId { get; set; } = "";
public DateTime StartedAt { get; set; }
public DateTime EndedAt { get; set; }
public double Duration { get; set; }
public string? FilePath { get; set; }
public long Size { get; set; }
}

11
gateway/src/IntegrationGateway.Core/Models/StreamUrls.cs Normal file
View File

@@ -0,0 +1,11 @@
namespace IntegrationGateway.Core.Models;
public class StreamUrls
{
public string? WsFlv { get; set; }
public string? HttpFlv { get; set; }
public string? Hls { get; set; }
public string? WebRtc { get; set; }
public string? Rtmp { get; set; }
public string? Rtsp { get; set; }
}

13
gateway/src/IntegrationGateway.Core/Models/SyncReport.cs Normal file
View File

@@ -0,0 +1,13 @@
namespace IntegrationGateway.Core.Models;
public class SyncReport
{
public string AdapterCode { get; set; } = "";
public int Added { get; set; }
public int Updated { get; set; }
public int Skipped { get; set; }
public int Removed { get; set; }
public List<string> Errors { get; set; } = new();
public DateTime StartTime { get; set; }
public DateTime EndTime { get; set; }
}

32
gateway/src/IntegrationGateway.Host/Controllers/AlarmsController.cs Normal file
View File

@@ -0,0 +1,32 @@
using IntegrationGateway.Core.Abstractions;
using IntegrationGateway.Core.Infrastructure;
using Microsoft.AspNetCore.Mvc;
namespace IntegrationGateway.Host.Controllers;
[ApiController]
[Route("api/gateway/alarms")]
public class AlarmsController : ControllerBase
{
private readonly AdapterRegistry _registry;
public AlarmsController(AdapterRegistry registry) => _registry = registry;
[HttpGet("{adapter}")]
public async Task<IActionResult> GetAlarms(string adapter,
[FromQuery] DateTime from, [FromQuery] DateTime to,
[FromQuery] int page = 1, [FromQuery] int size = 50)
{
var a = _registry.Get(adapter);
if (a is not IHasAlarms al) return NotFound();
return Ok(await al.GetAlarmsAsync(page, size, from, to));
}
[HttpPost("{adapter}/{alarmId}/confirm")]
public async Task<IActionResult> Confirm(string adapter, string alarmId)
{
var a = _registry.Get(adapter);
if (a is not IHasAlarms al) return NotFound();
await al.ConfirmAlarmAsync(alarmId);
return Ok(new { status = "confirmed" });
}
}

30
gateway/src/IntegrationGateway.Host/Controllers/DevicesController.cs Normal file
View File

@@ -0,0 +1,30 @@
using IntegrationGateway.Core.Abstractions;
using IntegrationGateway.Core.Infrastructure;
using Microsoft.AspNetCore.Mvc;
namespace IntegrationGateway.Host.Controllers;
[ApiController]
[Route("api/gateway/devices")]
public class DevicesController : ControllerBase
{
private readonly AdapterRegistry _registry;
public DevicesController(AdapterRegistry registry) => _registry = registry;
[HttpGet]
public async Task<IActionResult> GetDevices([FromQuery] string adapter, [FromQuery] int page = 1, [FromQuery] int size = 50)
{
var a = _registry.Get(adapter);
if (a is not IHasFlatDevices f) return NotFound();
return Ok(await f.GetDevicesAsync(page, size));
}
[HttpGet("{adapter}/{deviceId}")]
public async Task<IActionResult> GetDevice(string adapter, string deviceId)
{
var a = _registry.Get(adapter);
if (a is not IHasFlatDevices f) return NotFound();
var d = await f.GetDeviceAsync(deviceId);
return d is null ? NotFound() : Ok(d);
}
}

21
gateway/src/IntegrationGateway.Host/Controllers/HealthController.cs Normal file
View File

@@ -0,0 +1,21 @@
using IntegrationGateway.Core.Infrastructure;
using Microsoft.AspNetCore.Mvc;
namespace IntegrationGateway.Host.Controllers;
[ApiController]
[Route("api/gateway/health")]
public class HealthController : ControllerBase
{
private readonly AdapterRegistry _registry;
public HealthController(AdapterRegistry registry) => _registry = registry;
[HttpGet]
public async Task<IActionResult> Get()
{
var status = new Dictionary<string, bool>();
foreach (var a in _registry.GetAll())
status[a.AdapterCode] = await a.HealthCheckAsync();
return Ok(new { gateway = "ok", adapters = status });
}
}

37
gateway/src/IntegrationGateway.Host/Controllers/PointsController.cs Normal file
View File

@@ -0,0 +1,37 @@
using IntegrationGateway.Core.Abstractions;
using IntegrationGateway.Core.Infrastructure;
using Microsoft.AspNetCore.Mvc;
namespace IntegrationGateway.Host.Controllers;
[ApiController]
[Route("api/gateway/realtime")]
public class PointsController : ControllerBase
{
private readonly AdapterRegistry _registry;
public PointsController(AdapterRegistry registry) => _registry = registry;
[HttpGet("{adapter}/{deviceId}")]
public async Task<IActionResult> GetRealtime(string adapter, string deviceId)
{
var a = _registry.Get(adapter);
if (a is not IHasPoints p) return NotFound();
return Ok(await p.GetRealtimeValuesAsync(deviceId));
}
[HttpPost("{adapter}/control")]
public async Task<IActionResult> Control(string adapter, [FromBody] ControlRequest req)
{
var a = _registry.Get(adapter);
if (a is not IHasPoints p) return NotFound();
await p.SetPointValueAsync(req.DeviceSourceId, req.PointIndex, req.Value);
return Ok(new { status = "sent" });
}
}
public class ControlRequest
{
public string DeviceSourceId { get; set; } = "";
public int PointIndex { get; set; }
public double Value { get; set; }
}

40
gateway/src/IntegrationGateway.Host/Controllers/RegisterController.cs Normal file
View File

@@ -0,0 +1,40 @@
using IntegrationGateway.Core.Infrastructure;
using Microsoft.AspNetCore.Mvc;
namespace IntegrationGateway.Host.Controllers;
[ApiController]
[Route("api/gateway")]
public class RegisterController : ControllerBase
{
private readonly AdapterRegistry _registry;
public RegisterController(AdapterRegistry registry) => _registry = registry;
[HttpPost("register")]
public async Task<IActionResult> Register([FromBody] RegisterRequest req)
{
// 网关向 Vol.Pro 注册，由外部 GatewayClient 调用
return Ok(new { status = "ok" });
}
[HttpPost("heartbeat")]
public async Task<IActionResult> Heartbeat([FromBody] HeartbeatRequest req)
{
return Ok(new { status = "ok" });
}
}
public class RegisterRequest
{
public string NodeCode { get; set; } = "";
public string Token { get; set; } = "";
public string AdapterTypes { get; set; } = "";
public string BaseUrl { get; set; } = "";
}
public class HeartbeatRequest
{
public string NodeCode { get; set; } = "";
public string Token { get; set; } = "";
}

48
gateway/src/IntegrationGateway.Host/Controllers/StreamsController.cs Normal file
View File

@@ -0,0 +1,48 @@
using IntegrationGateway.Core.Abstractions;
using IntegrationGateway.Core.Infrastructure;
using Microsoft.AspNetCore.Mvc;
namespace IntegrationGateway.Host.Controllers;
[ApiController]
[Route("api/gateway/streams")]
public class StreamsController : ControllerBase
{
private readonly AdapterRegistry _registry;
public StreamsController(AdapterRegistry registry) => _registry = registry;
[HttpGet("{adapter}/{channelId}/live")]
public async Task<IActionResult> GetLive(string adapter, string channelId)
{
var a = _registry.Get(adapter);
if (a is not IHasStreams s) return NotFound();
return Ok(await s.GetLiveUrlAsync(channelId));
}
[HttpGet("{adapter}/{channelId}/playback")]
public async Task<IActionResult> GetPlayback(string adapter, string channelId,
[FromQuery] DateTime start, [FromQuery] DateTime end)
{
var a = _registry.Get(adapter);
if (a is not IHasStreams s) return NotFound();
return Ok(await s.GetPlaybackUrlAsync(channelId, start, end));
}
[HttpPost("{adapter}/{channelId}/ptz")]
public async Task<IActionResult> Ptz(string adapter, string channelId, [FromBody] PtzRequest req)
{
var a = _registry.Get(adapter);
if (a is not IHasStreams s) return NotFound();
if (req.Direction == "stop")
await s.PtzStopAsync(channelId);
else
await s.PtzControlAsync(channelId, req.Direction, req.Speed);
return Ok(new { status = "ok" });
}
}
public class PtzRequest
{
public string Direction { get; set; } = "stop";
public float Speed { get; set; } = 0.5f;
}

49
gateway/src/IntegrationGateway.Host/Controllers/SyncController.cs Normal file
View File

@@ -0,0 +1,49 @@
using IntegrationGateway.Core.Abstractions;
using IntegrationGateway.Core.Infrastructure;
using IntegrationGateway.Core.Models;
using Microsoft.AspNetCore.Mvc;
namespace IntegrationGateway.Host.Controllers;
[ApiController]
[Route("api/gateway")]
public class SyncController : ControllerBase
{
private readonly AdapterRegistry _registry;
public SyncController(AdapterRegistry registry) => _registry = registry;
[HttpPost("devices/sync")]
public async Task<IActionResult> SyncDevices([FromQuery] string adapter)
{
var a = _registry.Get(adapter)
?? throw new InvalidOperationException($"Adapter '{adapter}' not found");
var report = new SyncReport { AdapterCode = adapter, StartTime = DateTime.UtcNow };
if (a is IHasFlatDevices f)
{
var devices = await f.GetAllDevicesAsync();
report.Added = devices.Count;
}
else if (a is IHasOwnDeviceTree t)
{
var tree = await t.GetObjectTreeAsync();
report.Added = CountDeviceNodes(tree);
}
else return BadRequest("Adapter does not support device sync");
report.EndTime = DateTime.UtcNow;
return Ok(report);
}
private int CountDeviceNodes(List<DeviceTreeNode> nodes)
{
int count = 0;
foreach (var n in nodes)
{
if (n.NodeType == 2) count++;
count += CountDeviceNodes(n.Children);
}
return count;
}
}

118
gateway/src/IntegrationGateway.Host/GatewayClient.cs Normal file
View File

@@ -0,0 +1,118 @@
using System.Text;
using System.Text.Json;
namespace IntegrationGateway.Host;
public class GatewayClient
{
private readonly HttpClient _http;
private readonly IConfiguration _config;
public GatewayClient(IHttpClientFactory factory, IConfiguration config)
{
_http = factory.CreateClient("VolPro");
_config = config;
}
/// <summary>A1: 网关注册</summary>
public async Task<RegisterResponse?> RegisterAsync()
{
var resp = await _http.PostAsJsonAsync("/api/gateway/register", new
{
nodeCode = _config["NodeCode"],
token = _config["NodeToken"],
adapterTypes = GetAdapterTypes(),
baseUrl = _config["Urls"]?.Replace("http://*:", $"http://localhost:")
});
resp.EnsureSuccessStatusCode();
return await resp.Content.ReadFromJsonAsync<RegisterResponse>();
}
/// <summary>A2: 心跳</summary>
public async Task HeartbeatAsync()
{
await _http.PostAsJsonAsync("/api/gateway/heartbeat", new
{
nodeCode = _config["NodeCode"],
token = _config["NodeToken"]
});
}
/// <summary>A3: 设备同步</summary>
public async Task<SyncResult> SyncDevicesAsync(List<DeviceSyncItem> devices)
{
var resp = await _http.PostAsJsonAsync("/api/gateway/sync/devices", new
{
nodeCode = _config["NodeCode"],
token = _config["NodeToken"],
devices
});
resp.EnsureSuccessStatusCode();
return await resp.Content.ReadFromJsonAsync<SyncResult>() ?? new();
}
/// <summary>A4: 告警同步</summary>
public async Task<SyncResult> SyncAlarmsAsync(List<AlarmSyncItem> alarms)
{
var resp = await _http.PostAsJsonAsync("/api/gateway/sync/alarms", new
{
nodeCode = _config["NodeCode"],
token = _config["NodeToken"],
alarms
});
resp.EnsureSuccessStatusCode();
return await resp.Content.ReadFromJsonAsync<SyncResult>() ?? new();
}
private string GetAdapterTypes() => "MC4,Owl";
}
public class RegisterResponse
{
public int NodeId { get; set; }
public List<DeviceItem> Devices { get; set; } = new();
}
public class DeviceItem
{
public int DeviceId { get; set; }
public string DeviceName { get; set; } = "";
public string AdapterCode { get; set; } = "";
public string SourceId { get; set; } = "";
public string DeviceCategory { get; set; } = "";
public string DeviceGroup { get; set; } = "";
public string IsParent { get; set; } = "";
public string IsOnline { get; set; } = "";
public JsonElement? ExtraData { get; set; }
}
public class DeviceSyncItem
{
public string AdapterCode { get; set; } = "";
public string SourceId { get; set; } = "";
public string Name { get; set; } = "";
public string Category { get; set; } = "";
public string Group { get; set; } = "";
public bool IsParent { get; set; }
public string? ParentSourceId { get; set; }
public bool IsOnline { get; set; }
public string? IpAddress { get; set; }
public int? Port { get; set; }
public Dictionary<string, object?>? ExtraData { get; set; }
}
public class AlarmSyncItem
{
public string SourceAlarmId { get; set; } = "";
public string DeviceSourceId { get; set; } = "";
public string AdapterCode { get; set; } = "";
public string Level { get; set; } = "";
public string Desc { get; set; } = "";
public double? Value { get; set; }
public string StartTime { get; set; } = "";
}
public class SyncResult
{
public int Added { get; set; }
}

18
gateway/src/IntegrationGateway.Host/IntegrationGateway.Host.csproj Normal file
View File

@@ -0,0 +1,18 @@
<Project Sdk="Microsoft.NET.Sdk.Web">
<PropertyGroup>
<TargetFramework>net8.0</TargetFramework>
<Nullable>enable</Nullable>
<ImplicitUsings>enable</ImplicitUsings>
</PropertyGroup>
<ItemGroup>
<PackageReference Include="Microsoft.AspNetCore.OpenApi" Version="8.0.27" />
<PackageReference Include="Swashbuckle.AspNetCore" Version="6.6.2" />
</ItemGroup>
<ItemGroup>
<ProjectReference Include="..\IntegrationGateway.Core\IntegrationGateway.Core.csproj" />
</ItemGroup>
</Project>

6
gateway/src/IntegrationGateway.Host/IntegrationGateway.Host.http Normal file
View File

@@ -0,0 +1,6 @@
@IntegrationGateway.Host_HostAddress = http://localhost:5169
GET {{IntegrationGateway.Host_HostAddress}}/weatherforecast/
Accept: application/json
###

38
gateway/src/IntegrationGateway.Host/Program.cs Normal file
View File

@@ -0,0 +1,38 @@
using IntegrationGateway.Core.Infrastructure;
using IntegrationGateway.Host;
var builder = WebApplication.CreateBuilder(args);
builder.Services.AddControllers();
builder.Services.AddMemoryCache();
builder.Services.AddSingleton<AdapterRegistry>();
builder.Services.AddSingleton<TokenManager>();
builder.Services.AddHttpClient("VolPro", c =>
{
c.BaseAddress = new Uri(builder.Configuration["VolProBaseUrl"] ?? "http://localhost:9100");
});
builder.Services.AddSingleton<GatewayClient>();
var app = builder.Build();
app.MapControllers();
// 启动时自动向 Vol.Pro 注册
app.Lifetime.ApplicationStarted.Register(() =>
{
Task.Run(async () =>
{
var gw = app.Services.GetRequiredService<GatewayClient>();
var registry = app.Services.GetRequiredService<AdapterRegistry>();
try
{
var result = await gw.RegisterAsync();
Console.WriteLine($"[Gateway] Registered as NodeId={result?.NodeId}, Devices={result?.Devices.Count ?? 0}");
}
catch (Exception ex)
{
Console.WriteLine($"[Gateway] Registration failed: {ex.Message}");
}
});
});
app.Run();

31
gateway/src/IntegrationGateway.Host/Properties/launchSettings.json Normal file
View File

@@ -0,0 +1,31 @@
{
"$schema": "http://json.schemastore.org/launchsettings.json",
"iisSettings": {
"windowsAuthentication": false,
"anonymousAuthentication": true,
"iisExpress": {
"applicationUrl": "http://localhost:4117",
"sslPort": 0
}
},
"profiles": {
"http": {
"commandName": "Project",
"dotnetRunMessages": true,
"launchBrowser": true,
"launchUrl": "swagger",
"applicationUrl": "http://localhost:5169",
"environmentVariables": {
"ASPNETCORE_ENVIRONMENT": "Development"
}
},
"IIS Express": {
"commandName": "IISExpress",
"launchBrowser": true,
"launchUrl": "swagger",
"environmentVariables": {
"ASPNETCORE_ENVIRONMENT": "Development"
}
}
}
}

8
gateway/src/IntegrationGateway.Host/appsettings.Development.json Normal file
View File

@@ -0,0 +1,8 @@
{
"Logging": {
"LogLevel": {
"Default": "Information",
"Microsoft.AspNetCore": "Warning"
}
}
}

13
gateway/src/IntegrationGateway.Host/appsettings.json Normal file
View File

@@ -0,0 +1,13 @@
{
"Logging": {
"LogLevel": {
"Default": "Information",
"Microsoft.AspNetCore": "Warning"
}
},
"AllowedHosts": "*",
"Urls": "http://*:5100",
"VolProBaseUrl": "http://localhost:9100",
"NodeCode": "gw-31ku",
"NodeToken": "xxxxxxxxxx"
}