Compare commits

..

2 Commits

Author SHA1 Message Date
longguancheng
f34844f110 Merge branch 'main' into dev_20260130_RemoveRedis 2026-02-03 15:52:50 +08:00
Bingkun Li
f09bb5b08f Bug: Fix bug that job status does not get sent back when job is over 2026-02-03 15:09:49 +08:00

View File

@ -280,23 +280,19 @@ public class JmJobStatusServiceImpl implements JmJobStatusService {
return; return;
} }
endAirline(jobId, jobVo, uavVo, airlineVo, wsVo, nextAirline == null); endAirline(jobId, jobVo, uavVo, airlineVo, wsVo, nextAirline == null);
} else if (isBoot == 1 && aStatus == ExecStatusEnum.PROCESSING) { } else if (isBoot == 1 && aStatus == ExecStatusEnum.PROCESSING && overButSending) {
if (overButSending) {
// 前一航线的图片没传完就开始了新航线 // 前一航线的图片没传完就开始了新航线
endAirline(jobId, jobVo, uavVo, airlineVo, wsVo, nextAirline == null); endAirline(jobId, jobVo, uavVo, airlineVo, wsVo, nextAirline == null);
if (nextAirline != null) { if (nextAirline != null) {
startAirline(nextAirline, wsVo); startAirline(nextAirline, wsVo);
} }
} } // else {
// return;
wsVo.setSarStatus(curr); // }
simpMessageingTemplate.convertAndSend(WebSocketKey.JM_JOB_STATUS, wsVo);
} else {
return;
}
// 4.将更新后的状态推送到前端 // 4.将更新后的状态推送到前端
// simpMessageingTemplate.convertAndSend(WebSocketKey.JM_JOB_STATUS, wsVo); wsVo.setSarStatus(curr);
simpMessageingTemplate.convertAndSend(WebSocketKey.JM_JOB_STATUS, wsVo);
} }
// 开启新航线 // 开启新航线