Merge branch 'main' into dev_20260130_RemoveRedis
This commit is contained in:
commit
f34844f110
@ -280,23 +280,19 @@ public class JmJobStatusServiceImpl implements JmJobStatusService {
|
||||
return;
|
||||
}
|
||||
endAirline(jobId, jobVo, uavVo, airlineVo, wsVo, nextAirline == null);
|
||||
} else if (isBoot == 1 && aStatus == ExecStatusEnum.PROCESSING) {
|
||||
if (overButSending) {
|
||||
} else if (isBoot == 1 && aStatus == ExecStatusEnum.PROCESSING && overButSending) {
|
||||
// 前一航线的图片没传完,就开始了新航线
|
||||
endAirline(jobId, jobVo, uavVo, airlineVo, wsVo, nextAirline == null);
|
||||
if (nextAirline != null) {
|
||||
startAirline(nextAirline, wsVo);
|
||||
}
|
||||
}
|
||||
|
||||
wsVo.setSarStatus(curr);
|
||||
simpMessageingTemplate.convertAndSend(WebSocketKey.JM_JOB_STATUS, wsVo);
|
||||
} else {
|
||||
return;
|
||||
}
|
||||
} // else {
|
||||
// return;
|
||||
// }
|
||||
|
||||
// 4.将更新后的状态推送到前端
|
||||
// simpMessageingTemplate.convertAndSend(WebSocketKey.JM_JOB_STATUS, wsVo);
|
||||
wsVo.setSarStatus(curr);
|
||||
simpMessageingTemplate.convertAndSend(WebSocketKey.JM_JOB_STATUS, wsVo);
|
||||
}
|
||||
|
||||
// 开启新航线
|
||||
|
||||
Loading…
Reference in New Issue
Block a user