Teams/shgx_tz_mes_backend_sync
3
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

refactor(mqtt): 优化设备消息处理逻辑并移除调试日志

Browse Source 
移除MQTT消息接收和设备消息处理的调试日志输出
将设备消息处理逻辑限制在特定主题下执行
This commit is contained in:
赵正易
2025-09-21 13:59:01 +08:00
parent bcf5113a4a
commit 3e30d72ef2
1 changed files with 32 additions and 28 deletions
Download Patch File Download Diff File Expand all files Collapse all files

60
ZR.Service/mqtt/MqttService.cs
View File

@@ -199,9 +199,9 @@ namespace ZR.Service.mqtt
try try
{ {
var payload = Encoding.UTF8.GetString(e.ApplicationMessage.PayloadSegment); var payload = Encoding.UTF8.GetString(e.ApplicationMessage.PayloadSegment);
_logger.LogInformation( /*_logger.LogInformation(
$"收到MQTT消息 - 主题: {e.ApplicationMessage.Topic}, QoS: {e.ApplicationMessage.QualityOfServiceLevel}" $"收到MQTT消息 - 主题: {e.ApplicationMessage.Topic}, QoS: {e.ApplicationMessage.QualityOfServiceLevel}"
); );*/
// 消息处理委托给专用的处理器 // 消息处理委托给专用的处理器
await ProcessMessageAsync(e.ApplicationMessage.Topic, payload); await ProcessMessageAsync(e.ApplicationMessage.Topic, payload);
@@ -367,33 +367,37 @@ namespace ZR.Service.mqtt
private Task HandleDeviceMessage(string topic, string payload) private Task HandleDeviceMessage(string topic, string payload)
{ {
_logger.LogInformation($"处理设备消息: {topic} - {payload}"); //_logger.LogInformation($"处理设备消息: {topic} - {payload}");
// plc网关抓取数据上传
DeviceUploadDataGatWayDto deviceUploadDataGatWayDto = JsonSerializer.Deserialize<DeviceUploadDataGatWayDto>(payload); if (topic.Contains("device/data/push"))
// 这里添加设备消息处理逻辑
string deviceCode = topic.Split("/")[2];
DeviceUploadData deviceUploadData = new()
{ {
FactoryCode = "上海干巷", DeviceUploadDataGatWayDto deviceUploadDataGatWayDto = JsonSerializer.Deserialize<DeviceUploadDataGatWayDto>(payload);
WorkshopCode = "涂装车间", // 这里添加设备消息处理逻辑
LineCode = "涂装生产线", string deviceCode = topic.Split("/")[2];
DeviceCode = deviceCode, DeviceUploadData deviceUploadData = new()
DictCode = "device_dict_plc_001", {
Remark = "网关采集设备数据", FactoryCode = "上海干巷",
UploadTime = DateTime.Now, WorkshopCode = "涂装车间",
CollectionTime = DateTimeOffset.FromUnixTimeMilliseconds(deviceUploadDataGatWayDto.Time).LocalDateTime, LineCode = "涂装生产线",
Value01 = deviceUploadDataGatWayDto.DeviceParams.Value01.ToString(), DeviceCode = deviceCode,
Value02 = deviceUploadDataGatWayDto.DeviceParams.Value02.ToString(), DictCode = "device_dict_plc_001",
Value03 = deviceUploadDataGatWayDto.DeviceParams.Value03.ToString(), Remark = "网关采集设备数据",
Value04 = deviceUploadDataGatWayDto.DeviceParams.Value04.ToString(), UploadTime = DateTime.Now,
Value05 = deviceUploadDataGatWayDto.DeviceParams.Value05.ToString(), CollectionTime = DateTimeOffset.FromUnixTimeMilliseconds(deviceUploadDataGatWayDto.Time).LocalDateTime,
Value06 = deviceUploadDataGatWayDto.DeviceParams.Value06.ToString(), Value01 = deviceUploadDataGatWayDto.DeviceParams.Value01.ToString(),
Value07 = deviceUploadDataGatWayDto.DeviceParams.Value07.ToString(), Value02 = deviceUploadDataGatWayDto.DeviceParams.Value02.ToString(),
Value08 = deviceUploadDataGatWayDto.DeviceParams.Value08.ToString(), Value03 = deviceUploadDataGatWayDto.DeviceParams.Value03.ToString(),
Value09 = deviceUploadDataGatWayDto.DeviceParams.Value09.ToString(), Value04 = deviceUploadDataGatWayDto.DeviceParams.Value04.ToString(),
Value10 = deviceUploadDataGatWayDto.DeviceParams.Value10.ToString() Value05 = deviceUploadDataGatWayDto.DeviceParams.Value05.ToString(),
}; Value06 = deviceUploadDataGatWayDto.DeviceParams.Value06.ToString(),
Context.Insertable(deviceUploadData).ExecuteCommand(); Value07 = deviceUploadDataGatWayDto.DeviceParams.Value07.ToString(),
Value08 = deviceUploadDataGatWayDto.DeviceParams.Value08.ToString(),
Value09 = deviceUploadDataGatWayDto.DeviceParams.Value09.ToString(),
Value10 = deviceUploadDataGatWayDto.DeviceParams.Value10.ToString()
};
Context.Insertable(deviceUploadData).ExecuteCommand();
}
return Task.CompletedTask; return Task.CompletedTask;
} }