mirror of
https://gitee.com/ThingsGateway/ThingsGateway.git
synced 2025-10-27 05:37:10 +08:00
91 lines
3.5 KiB
C#
91 lines
3.5 KiB
C#
//------------------------------------------------------------------------------
|
||
// 此代码版权声明为全文件覆盖，如有原作者特别声明，会在下方手动补充
|
||
// 此代码版权（除特别声明外的代码）归作者本人Diego所有
|
||
// 源代码使用协议遵循本仓库的开源协议及附加协议
|
||
// Gitee源代码仓库：https://gitee.com/diego2098/ThingsGateway
|
||
// Github源代码仓库：https://github.com/kimdiego2098/ThingsGateway
|
||
// 使用文档：https://thingsgateway.cn/
|
||
// QQ群：605534569
|
||
//------------------------------------------------------------------------------
|
||
|
||
using ThingsGateway.Gateway.Application;
|
||
|
||
using TouchSocket.Core;
|
||
using TouchSocket.Dmtp.Rpc;
|
||
using TouchSocket.Rpc;
|
||
using TouchSocket.Sockets;
|
||
|
||
namespace ThingsGateway.Management;
|
||
|
||
internal sealed partial class ReverseCallbackServer : SingletonRpcServer
|
||
{
|
||
RedundancyHostedService RedundancyHostedService;
|
||
public ReverseCallbackServer(RedundancyHostedService redundancyHostedService)
|
||
{
|
||
RedundancyHostedService = redundancyHostedService;
|
||
}
|
||
|
||
[DmtpRpc(MethodInvoke = true)]
|
||
public void UpData(ICallContext callContext, List<DeviceDataWithValue> deviceDatas)
|
||
{
|
||
|
||
foreach (var deviceData in deviceDatas)
|
||
{
|
||
if (GlobalData.ReadOnlyDevices.TryGetValue(deviceData.Name, out var device))
|
||
{
|
||
device.RpcDriver = RedundancyHostedService;
|
||
device.Tag = callContext.Caller is IIdClient idClient ? idClient.Id : string.Empty;
|
||
|
||
|
||
device.SetDeviceStatus(deviceData.ActiveTime, deviceData.DeviceStatus == DeviceStatusEnum.OnLine ? false : true, lastErrorMessage: deviceData.LastErrorMessage);
|
||
|
||
foreach (var variableData in deviceData.ReadOnlyVariableRuntimes)
|
||
{
|
||
if (device.ReadOnlyVariableRuntimes.TryGetValue(variableData.Key, out var value))
|
||
{
|
||
value.SetValue(variableData.Value.RawValue, variableData.Value.CollectTime, variableData.Value.IsOnline);
|
||
value.SetErrorMessage(variableData.Value.LastErrorMessage);
|
||
}
|
||
}
|
||
|
||
}
|
||
}
|
||
RedundancyHostedService.LogMessage?.Trace("Update data success");
|
||
}
|
||
|
||
|
||
|
||
[DmtpRpc(MethodInvoke = true)]
|
||
public List<DataWithDatabase> GetData()
|
||
{
|
||
List<DataWithDatabase> dataWithDatabases = new();
|
||
foreach (var channels in GlobalData.ReadOnlyChannels)
|
||
{
|
||
DataWithDatabase dataWithDatabase = new();
|
||
dataWithDatabase.Channel = channels.Value;
|
||
dataWithDatabase.DeviceVariables = new();
|
||
foreach (var devices in channels.Value.ReadDeviceRuntimes)
|
||
{
|
||
DeviceDataWithDatabase deviceDataWithDatabase = new();
|
||
|
||
deviceDataWithDatabase.Device = devices.Value;
|
||
deviceDataWithDatabase.Variables = devices.Value.ReadOnlyVariableRuntimes.Select(a => a.Value).Cast<Variable>().ToList();
|
||
|
||
|
||
dataWithDatabase.DeviceVariables.Add(deviceDataWithDatabase);
|
||
}
|
||
|
||
dataWithDatabases.Add(dataWithDatabase);
|
||
}
|
||
return dataWithDatabases;
|
||
|
||
|
||
}
|
||
|
||
[DmtpRpc(MethodInvoke = true)]
|
||
public Task<Dictionary<string, Dictionary<string, IOperResult>>> Rpc(Dictionary<string, Dictionary<string, string>> deviceDatas, CancellationToken cancellationToken)
|
||
{
|
||
return GlobalData.RpcService.InvokeDeviceMethodAsync("Management", deviceDatas, cancellationToken);
|
||
}
|
||
}
|