优化：流媒体同步任务

liusuyi

2024-07-10 016aa105789fca71e86cdbb0d26a181812f200f9

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

@@ -17,6 +17,7 @@


import javax.annotation.Resource;

import java.util.*;



import static com.ruoyi.utils.websocket.util.WebSocketUtils.ONLINE_USER_SESSIONS;



/**

@@ -36,6 +37,7 @@
    ICameraSdkService cameraSdkService;

    @Resource

    IGlobalAlarmService globalAlarmService;



    /**

     * @描述 定时推送所有报警的点位数量

     * @参数 []

@@ -66,6 +68,7 @@
     */

    public void ptzPush() {

        try {

            if (ONLINE_USER_SESSIONS.size() > 0) {

            List<Map<String, Object>> list = new ArrayList<>();

            List<Object> Objects = redisCache.getListKey(CacheConstants.CAMERA_LIST_KEY);

            if (Objects.size() > 0) {

@@ -75,8 +78,7 @@
                    {

                        continue;

                    }

                    if(!"1".equals(camera.getGdtype()))

                    {

                        if (!"1".equals(camera.getGdtype())) {

                        continue;

                    }

                    CameraCmd cmd = new CameraCmd();

@@ -85,8 +87,7 @@
                    cmd.setOperator(camera.getOperatorId());

                    //推送在线的相机

                    boolean onLine = cameraSdkService.isOnLine(cmd);

                    if(!onLine)

                    {

                        if (!onLine) {

                        continue;

                    }

                    AjaxResult ajaxResult = cameraSdkService.getGisInfo(cmd);

@@ -121,7 +122,7 @@
                        list.add(ptz);

                    }

                }

                if (ONLINE_USER_SESSIONS.size() > 0) {



                    Map<String, Object> sendMap = new HashMap<>();

                    sendMap.put("10000", list);

                    WebSocketUtils.sendMessageAll(sendMap);