规范数据库，添加必要约束，优化通道批量导入功能

648540858

2022-02-24 a42dda2bd3cc1cf8c20cc61e7ad9211eadecbaf3

 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.UserSetup;

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.service.IDeviceService;

import com.genersoft.iot.vmp.storager.dao.dto.User;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

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

@@ -13,12 +19,12 @@
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

 */

@@ -29,12 +35,21 @@


   @Autowired

   private IVideoManagerStorager storager;



   @Autowired

   private IDeviceService deviceService;

   

   @Autowired

    private RedisUtil redis;



   @Autowired

    private SipConfig sipConfig;



   @Autowired

    private UserSetup userSetup;



   @Autowired

    private EventPublisher eventPublisher;



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



@@ -45,7 +60,8 @@
         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 + userSetup.getServerId() + "_" + event.getDevice().getDeviceId();



      switch (event.getFrom()) {

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

@@ -72,7 +88,18 @@
      }



      device.setOnline(1);

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

      if (deviceInStore != null && deviceInStore.getOnline() == 0) {

         List<DeviceChannel> deviceChannelList = storager.queryOnlineChannelsByDeviceId(device.getDeviceId());

         eventPublisher.catalogEventPublish(null, deviceChannelList, CatalogEvent.ON);

      }

      // 处理上线监听

      storager.updateDevice(device);



      // 上线添加订阅

      if (device.getSubscribeCycleForCatalog() > 0) {

         deviceService.addCatalogSubscribe(device);

      }



   }

}