Commit 13296baa by gdj

无人机下线不删除payload表。

parent 2eafe0b9
......@@ -139,6 +139,12 @@ public class DevicePayloadServiceImpl implements IDevicePayloadService {
* @param payloads
*/
public void updatePayloadControl(DeviceDTO drone, List<DevicePayloadReceiver> payloads) {
// 检查设备是否在线,不在线则不更新payload,避免异常离线导致数据丢失
if (!deviceRedisService.checkDeviceOnline(drone.getDeviceSn())) {
log.warn("Device {} is offline, skipping payload update.", drone.getDeviceSn());
return;
}
boolean match = payloads.stream().peek(p -> p.setSn(Objects.requireNonNullElse(p.getSn(),
p.getDeviceSn() + "-" + p.getPayloadIndex().getPosition().getPosition())))
.anyMatch(p -> ControlSourceEnum.UNKNOWN == p.getControlSource());
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment