心跳接口修改

vehicle-sdk/src/main/java/com/ozs/controller/upload/GeoHazardMonitorTokenController.java

@@ -738,6 +738,25 @@ public class GeoHazardMonitorTokenController {
                         }
                         AlarmListVo[] array = listVos.toArray(new AlarmListVo[]{});
                         respHeartbeatVo.setAlarmList(array);
+                        //获取机车前两路视频
+                        CompletableFuture.runAsync(() -> {
+                            int mile = heartbeatVo.getVisualDistance() + heartbeatVo.getCurrentMile();
+                            LambdaQueryWrapper<BaseCameraManagement> base = new LambdaQueryWrapper<>();
+                            if (heartbeatVo.getLineDir() == 1) {
+                                base.gt(BaseCameraManagement::getInstallMile, mile);
+                            }
+                            if (heartbeatVo.getLineDir() == 2) {
+                                base.lt(BaseCameraManagement::getInstallMile, mile);
+                            }
+                            base.eq(BaseCameraManagement::getRailwayCode, heartbeatVo.getRailwayCode());
+                            base.orderByAsc(BaseCameraManagement::getInstallMile);
+                            base.eq(BaseCameraManagement::getEnableOrNot, 1);
+                            base.last("limit 2");
+                            List<BaseCameraManagement> list1 = baseCameraManagementService.list(base);
+                            for (BaseCameraManagement baseCameraManagement : list1) {
+                                cameraUtil.heartbeatgetUrl(baseCameraManagement.getCameraCode(), baseCameraManagement.getChannel());
+                            }
+                        });
                     } else {
                         //没有报警信息的时候
                         distance = heartbeatVo.getVisualDistance() + heartbeatVo.getCurrentMile();