HC_YFZX
/
LASAPlatform
11
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

bugfix：可能是否去重处理导致任务结束消息未能被处理

feature-flyModify
陈伟 2025-09-10 09:59:33 +08:00
parent 4cbc021ada
commit e08a671ef7
1 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
OpenAuth.App/ServiceApp/Subscribe/ConfigSubscribe.cs
View File

@ -550,15 +550,6 @@ public class ConfigSubscribe : IJob
{
string flightId1 = (string)data.output.ext.flight_id;
var waylineMissionState = (int)data.output.ext.wayline_mission_state;
// current_step
var isHandle = IsDuplicate(Md5.Encrypt($"{result.bid}{flightId1}"));
_logger.LogDebug($"md5: {isHandle} 重复否：{IsDuplicate(Md5.Encrypt(message))}" +
$"主题：{topic} 信息：{message} ");
if (isHandle)
{
_logger.LogInformation("跳过处理");
break;
}
_logger.LogDebug("航线进度未跳过处理");
code = data.result; // result
@ -639,6 +630,15 @@ public class ConfigSubscribe : IJob
_logger.LogDebug($"航线进度：{waylineMissionState} {step} {message}");
if (step.Equals(25)) // todo 关于会接收到不同消息问题，如何处理
{
// current_step
var isHandle = IsDuplicate(Md5.Encrypt($"{result.bid}{flightId1}"));
_logger.LogDebug($"md5: {isHandle} 重复否：{IsDuplicate(Md5.Encrypt(message))}" +
$"主题：{topic} 信息：{message} ");
if (isHandle)
{
_logger.LogInformation("跳过处理");
break;
}
var task = await _sqlSugarClient.Queryable<LasaTask>()
.FirstAsync(y => y.Id == taskAssign1.TaskId);
if (task != null && !string.IsNullOrEmpty(task.AIInspection) &&