全局布局调整补充：之前路由把两个播放器界面也加入全局样式，现在移出到一级路由

xiaoxie

2022-04-21 fc97febe1da97a9cadb12fc32f247b34eb0d5e7c

 src/main/java/com/genersoft/iot/vmp/gb28181/event/online/OnlineEventListener.java

@@ -1,7 +1,13 @@
package com.genersoft.iot.vmp.gb28181.event.online;



import com.genersoft.iot.vmp.conf.SipConfig;

import com.genersoft.iot.vmp.conf.UserSetting;

import com.genersoft.iot.vmp.gb28181.bean.Device;

import com.genersoft.iot.vmp.gb28181.bean.DeviceChannel;

import com.genersoft.iot.vmp.gb28181.event.EventPublisher;

import com.genersoft.iot.vmp.gb28181.event.subscribe.catalog.CatalogEvent;

import com.genersoft.iot.vmp.gb28181.transmit.cmd.impl.SIPCommander;

import com.genersoft.iot.vmp.service.IDeviceService;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import org.springframework.beans.factory.annotation.Autowired;

@@ -9,16 +15,16 @@
import org.springframework.stereotype.Component;



import com.genersoft.iot.vmp.common.VideoManagerConstants;

import com.genersoft.iot.vmp.storager.IVideoManagerStorager;

import com.genersoft.iot.vmp.storager.IVideoManagerStorage;

import com.genersoft.iot.vmp.utils.redis.RedisUtil;



import java.text.SimpleDateFormat;

import java.util.Date;

import java.util.List;



/**

 * @Description: 在线事件监听器，监听到离线后，修改设备离在线状态。 设备在线有两个来源：

 *               1、设备主动注销，发送注销指令，{@link com.genersoft.iot.vmp.gb28181.transmit.request.impl.RegisterRequestProcessor}

 *               2、设备未知原因离线，心跳超时,{@link com.genersoft.iot.vmp.gb28181.transmit.request.impl.MessageRequestProcessor}

 * @description: 在线事件监听器，监听到离线后，修改设备离在线状态。 设备在线有两个来源：

 *               1、设备主动注销，发送注销指令

 *               2、设备未知原因离线，心跳超时

 * @author: swwheihei

 * @date: 2020年5月6日 下午1:51:23

 */

@@ -28,13 +34,26 @@
   private final static Logger logger = LoggerFactory.getLogger(OnlineEventListener.class);



   @Autowired

   private IVideoManagerStorager storager;

   private IVideoManagerStorage storager;



   @Autowired

   private IDeviceService deviceService;

   

   @Autowired

    private RedisUtil redis;



   @Autowired

    private SipConfig sipConfig;



   @Autowired

    private UserSetting userSetting;



   @Autowired

    private EventPublisher eventPublisher;



   @Autowired

   private SIPCommander cmder;





   private SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");



@@ -45,14 +64,21 @@
         logger.debug("设备上线事件触发，deviceId：" + event.getDevice().getDeviceId() + ",from:" + event.getFrom());

      }

      Device device = event.getDevice();

      String key = VideoManagerConstants.KEEPLIVEKEY_PREFIX + event.getDevice().getDeviceId();



      if (device == null) return;

      String key = VideoManagerConstants.KEEPLIVEKEY_PREFIX + userSetting.getServerId() + "_" + event.getDevice().getDeviceId();

      Device deviceInStore = storager.queryVideoDevice(device.getDeviceId());

      device.setOnline(1);

      switch (event.getFrom()) {

      // 注册时触发的在线事件，先在redis中增加超时超时监听

      case VideoManagerConstants.EVENT_ONLINE_REGISTER:

         // 超时时间

         redis.set(key, event.getDevice().getDeviceId(), sipConfig.getKeepaliveTimeOut());

         device.setRegisterTime(format.format(new Date(System.currentTimeMillis())));

         device.setRegisterTime(format.format(System.currentTimeMillis()));

         if (deviceInStore == null) { //第一次上线

            logger.info("[{}] 首次注册，查询设备信息以及通道信息", device.getDeviceId());

            cmder.deviceInfoQuery(device);

            deviceService.sync(device);

         }

         break;

      // 设备主动发送心跳触发的在线事件

      case VideoManagerConstants.EVENT_ONLINE_KEEPLIVE:

@@ -63,16 +89,22 @@
         } else {

            redis.expire(key, sipConfig.getKeepaliveTimeOut());

         }

         device.setKeepaliveTime(format.format(new Date(System.currentTimeMillis())));

         device.setKeepaliveTime(format.format(System.currentTimeMillis()));

         break;

      // 设备主动发送消息触发的在线事件

      case VideoManagerConstants.EVENT_ONLINE_MESSAGE:



         break;

      }



      device.setOnline(1);

      // 处理上线监听

      storager.updateDevice(device);

      // 上线添加订阅

      if (device.getSubscribeCycleForCatalog() > 0) {

         // 查询在线设备那些开启了订阅，为设备开启定时的目录订阅

         deviceService.addCatalogSubscribe(device);

      }

      if (device.getSubscribeCycleForMobilePosition() > 0) {

         deviceService.addMobilePositionSubscribe(device);

      }

   }

}