添加注释,去除无用注释

feature-flyModify
陈伟 2025-09-11 17:21:33 +08:00
parent 7a5f0c5f77
commit ce750bb8d1
1 changed files with 7 additions and 20 deletions

View File

@ -83,19 +83,7 @@ public class ConfigSubscribe : IJob
private async Task HandleTopic(MqttApplicationMessageReceivedEventArgs args, string topic, private async Task HandleTopic(MqttApplicationMessageReceivedEventArgs args, string topic,
string message) string message)
{ {
/* // 序列号提取
thing/product/{device_sn}/osd properties
thing/product/{device_sn}/state properties
thing/product/{gateway_sn}/services_reply service 线
thing/product/{gateway_sn}/events
SD
thing/product/{gateway_sn}/requests
sys/product/{gateway_sn}/status 线
thing/product/{gateway_sn}/property/set_reply
thing/product/{gateway_sn}/drc/up DRC */
var sn = topic.Split("/")[2]; var sn = topic.Split("/")[2];
var tempStr = topic.Replace(sn, "*"); var tempStr = topic.Replace(sn, "*");
//Console.WriteLine($"成功调用主题 [{topic}] 的消息: {message}"); //Console.WriteLine($"成功调用主题 [{topic}] 的消息: {message}");
@ -110,6 +98,7 @@ public class ConfigSubscribe : IJob
var rtmp = "rtmp://175.27.168.120:6019/live/7"; var rtmp = "rtmp://175.27.168.120:6019/live/7";
switch (tempStr) switch (tempStr)
{ {
// 目前主要处理了获取航线文件及临时凭证上传
case "thing/product/*/requests": case "thing/product/*/requests":
switch (method) switch (method)
{ {
@ -149,7 +138,6 @@ public class ConfigSubscribe : IJob
} }
} }
}; };
// thing/product/{gateway_sn}/requests_reply
var tempTopic = $"thing/product/{sn}/requests_reply"; var tempTopic = $"thing/product/{sn}/requests_reply";
await _mqttClientManager.PublishAsync(tempTopic, await _mqttClientManager.PublishAsync(tempTopic,
JsonConvert.SerializeObject(storageConfigRequest)); JsonConvert.SerializeObject(storageConfigRequest));
@ -205,6 +193,7 @@ public class ConfigSubscribe : IJob
} }
break; break;
// 主要处理了文件回传及航线进度
case "thing/product/*/events": case "thing/product/*/events":
switch (method) switch (method)
{ {
@ -592,7 +581,6 @@ public class ConfigSubscribe : IJob
} }
else else
{ {
// 航线成功 // 航线成功
if (waylineMissionState.Equals(9)) // 航结结束,更新任务状态 if (waylineMissionState.Equals(9)) // 航结结束,更新任务状态
{ {
@ -626,6 +614,7 @@ public class ConfigSubscribe : IJob
}; };
await _sqlSugarClient.Updateable(record).IgnoreNullColumns().ExecuteCommandAsync(); await _sqlSugarClient.Updateable(record).IgnoreNullColumns().ExecuteCommandAsync();
} }
var step = (int)data.output.progress.current_step; var step = (int)data.output.progress.current_step;
_logger.LogDebug($"航线进度:{waylineMissionState} {step} {message}"); _logger.LogDebug($"航线进度:{waylineMissionState} {step} {message}");
if (step.Equals(25)) // todo 关于会接收到不同消息问题,如何处理 if (step.Equals(25)) // todo 关于会接收到不同消息问题,如何处理
@ -639,6 +628,7 @@ public class ConfigSubscribe : IJob
_logger.LogInformation("跳过处理"); _logger.LogInformation("跳过处理");
break; break;
} }
var task = await _sqlSugarClient.Queryable<LasaTask>() var task = await _sqlSugarClient.Queryable<LasaTask>()
.FirstAsync(y => y.Id == taskAssign1.TaskId); .FirstAsync(y => y.Id == taskAssign1.TaskId);
if (task != null && !string.IsNullOrEmpty(task.AIInspection) && if (task != null && !string.IsNullOrEmpty(task.AIInspection) &&
@ -667,7 +657,6 @@ public class ConfigSubscribe : IJob
_liveInfo[$"{tid}{bid}"] = taskAssign1.TaskId; _liveInfo[$"{tid}{bid}"] = taskAssign1.TaskId;
} }
} }
} }
/*if (result.need_reply.Equals(1)) /*if (result.need_reply.Equals(1))
@ -703,9 +692,6 @@ public class ConfigSubscribe : IJob
} }
break; break;
// 任务资源处理
// 航线进度处理
// 任务取消 thing/product/*/services_reply
case "thing/product/*/services_reply": case "thing/product/*/services_reply":
switch (method) switch (method)
{ {
@ -714,6 +700,7 @@ public class ConfigSubscribe : IJob
{ {
break; break;
} }
// 已验证tid bid 是相同的 // 已验证tid bid 是相同的
// 开启直播成功调用ai model // 开启直播成功调用ai model
_logger.LogDebug($"开启直播成功 {message}"); _logger.LogDebug($"开启直播成功 {message}");