异常停车逻辑修改提交

zhangnaisong

2024-07-23 a2e85a4911dd285f7a1ac9fde312187aec597198

 ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/SyncTask.java

@@ -53,6 +53,7 @@
    private CameraSDKFactory cameraSDKFactory;

    @Resource

    private IArdChannelService ardChannelService;



    /**

     * 同步相机在线状态

     * 刘苏义

@@ -84,28 +85,26 @@


    /**

     * @Author 刘苏义

     * @Description 同步nvr通道状态实时同步流媒体

     * @Description 同步通道状态实时同步流媒体

     * @Date 2024/7/9 16:01

     */

    public void nvrChannelState() {

    public void syncChannelState() {

        log.debug("定时同步通道任务开始");

        //获取所有nvr设备

        List<ArdCameras> ardCamerasList = iArdCamerasService.selectArdCamerasListNoDataScope(new ArdCameras());

        if (ardCamerasList.size() > 0) {

            ardCamerasList.stream()

                    .filter(ardCameras -> ardCameras.getGdtype().equals("2"))

                    .forEach(ardCameras -> {

                        //通过SDK获取NVR当前通道

                        CameraSDK cameraSDK = cameraSDKFactory.createCameraSDK(ardCameras.getFactory());

                        List<ArdChannel> ardChannelList = cameraSDK.getChannels(ardCameras);

                        //同步通道表

                        ArdChannel ardChannel=new ArdChannel();

                        ardChannel.setDeviceId(ardCameras.getId());

                        List<ArdChannel> ardChannelListDb = ardChannelService.selectArdChannelList(ardChannel);

                        ardChannelService.asyncChannel(ardChannelListDb,ardChannelList);

                        //同步流媒体表



                        //同步流媒体api



                        if (ardCameras.getLoginId() > 0) {

                            //通过SDK获取NVR实际通道

                            CameraSDK cameraSDK = cameraSDKFactory.createCameraSDK(ardCameras.getFactory());

                            List<ArdChannel> ardChannelList = cameraSDK.getChannels(ardCameras);

                            //同步通道表

                            ArdChannel ardChannel = new ArdChannel();

                            ardChannel.setDeviceId(ardCameras.getId());

                            List<ArdChannel> ardChannelListDb = ardChannelService.selectArdChannelList(ardChannel);

                            ardChannelService.asyncChannel(ardCameras, ardChannelListDb, ardChannelList);

                        }

                    });

        }

    }

@@ -142,9 +141,10 @@
     * 刘苏义

     * 2023/10/13 14:13:53

     */

    public void vtdu() {

    public void syncVtdu() {

        log.debug("定时同步流媒体任务开始");

        List<String> nameList = mediaService.getNameList();

        List<Vtdu> vtduList = vtduService.selectVtduList(new Vtdu());

        vtduService.asyncVtdu(vtduList,nameList);

        vtduService.asyncVtdu(vtduList, nameList);

    }

}

}