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

更改属性说明

Browse Source
This commit is contained in:
2248356998 qq.com
2023-07-14 12:23:46 +08:00
parent 506e0f144f
commit 201788e286
4 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/Plugins/ThingsGateway.Kafka/KafkaProducer.cs
View File

@@ -173,9 +173,9 @@ public class KafkaProducer : UpLoadBase
var cacheData = await CacheDb.GetCacheData();
foreach (var item in cacheData)
{
var result1 = await producer.ProduceAsync(item.Topic, new Message<Null, string> { Value = item.CacheStr }, cancellationToken);
var cacheResult = await producer.ProduceAsync(item.Topic, new Message<Null, string> { Value = item.CacheStr }, cancellationToken);
if (result.Status == PersistenceStatus.Persisted)
if (cacheResult.Status == PersistenceStatus.Persisted)
{
logMessage.Trace(LogMessageHeader + $"主题：{item.Topic}{Environment.NewLine}负载：{item.CacheStr}");

4
src/Plugins/ThingsGateway.Mqtt/MqttClientProperty.cs
View File

@@ -40,9 +40,9 @@ public class MqttClientProperty : UpDriverPropertyBase
[DeviceProperty("Rpc返回Topic", "")] public string RpcSubTopic { get; set; } = "ThingsGateway/RpcSub";
[DeviceProperty("Rpc写入Topic", "")] public string RpcWriteTopic { get; set; } = "ThingsGateway/RpcWrite";
[DeviceProperty("设备实体脚本", "查看文档说明，为空时不起作用")] public string BigTextScriptDeviceModel { get; set; }
[DeviceProperty("设备实体脚本", "查看文档说明，为空时默认Json传输")] public string BigTextScriptDeviceModel { get; set; }
[DeviceProperty("变量实体脚本", "查看文档说明，为空时不起作用")] public string BigTextScriptVariableModel { get; set; }
[DeviceProperty("变量实体脚本", "查看文档说明，为空时默认Json传输")] public string BigTextScriptVariableModel { get; set; }
[DeviceProperty("是否间隔上传", "False时为变化检测上传")] public bool IsInterval { get; set; } = false;

4
src/Plugins/ThingsGateway.Mqtt/MqttServerProperty.cs
View File

@@ -26,7 +26,7 @@ public class MqttServerProperty : UpDriverPropertyBase
[DeviceProperty("变量Topic", "")] public string VariableTopic { get; set; } = "ThingsGateway/Variable";
[DeviceProperty("Rpc返回Topic", "")] public string RpcSubTopic { get; set; } = "ThingsGateway/RpcSub";
[DeviceProperty("Rpc写入Topic", "不允许订阅")] public string RpcWriteTopic { get; set; } = "ThingsGateway/RpcWrite";
[DeviceProperty("设备实体脚本", "查看文档说明，为空时不起作用")] public string BigTextScriptDeviceModel { get; set; }
[DeviceProperty("变量实体脚本", "查看文档说明，为空时不起作用")] public string BigTextScriptVariableModel { get; set; }
[DeviceProperty("设备实体脚本", "查看文档说明，为空时默认Json传输")] public string BigTextScriptDeviceModel { get; set; }
[DeviceProperty("变量实体脚本", "查看文档说明，为空时默认Json传输")] public string BigTextScriptVariableModel { get; set; }
}

4
src/Plugins/ThingsGateway.RabbitMQ/RabbitMQClientProperty.cs
View File

@@ -35,6 +35,6 @@ public class RabbitMQClientProperty : UpDriverPropertyBase
[DeviceProperty("缓存最大条数", "默认2千条")] public int CacheMaxCount { get; set; } = 2000;
[DeviceProperty("设备实体脚本", "查看文档说明，为空时不起作用")] public string BigTextScriptDeviceModel { get; set; }
[DeviceProperty("变量实体脚本", "查看文档说明，为空时不起作用")] public string BigTextScriptVariableModel { get; set; }
[DeviceProperty("设备实体脚本", "查看文档说明，为空时默认Json传输")] public string BigTextScriptDeviceModel { get; set; }
[DeviceProperty("变量实体脚本", "查看文档说明，为空时默认Json传输")] public string BigTextScriptVariableModel { get; set; }
}