liusuyi
2024-07-11 b1084891961232e3c697ea9fc52f127cdccffb6b
ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/SyncTask.java
@@ -84,28 +84,24 @@
    /**
     * @Author 刘苏义
     * @Description 同步nvr通道状态实时同步流媒体
     * @Description 同步通道状态实时同步流媒体
     * @Date 2024/7/9 16:01
     */
    public void nvrChannelState() {
    public void syncChannelState() {
        log.warn("定时同步通道任务开始");
        //获取所有nvr设备
        List<ArdCameras> ardCamerasList = iArdCamerasService.selectArdCamerasListNoDataScope(new ArdCameras());
        if (ardCamerasList.size() > 0) {
            ardCamerasList.stream()
                    .filter(ardCameras -> ardCameras.getGdtype().equals("2"))
                    .forEach(ardCameras -> {
                        //通过SDK获取NVR当前通道
                        //通过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
                        ardChannelService.asyncChannel(ardCameras,ardChannelListDb,ardChannelList);
                    });
        }
    }
@@ -142,9 +138,10 @@
     * 刘苏义
     * 2023/10/13 14:13:53
     */
    public void vtdu() {
    public void syncVtdu() {
        log.warn("定时同步流媒体任务开始");
        List<String> nameList = mediaService.getNameList();
        List<Vtdu> vtduList = vtduService.selectVtduList(new Vtdu());
        vtduService.asyncVtdu(vtduList,nameList);
    }
}
}