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

648540858

2022-02-24 a42dda2bd3cc1cf8c20cc61e7ad9211eadecbaf3

 src/main/java/com/genersoft/iot/vmp/gb28181/event/offline/OfflineEventListener.java

@@ -1,15 +1,22 @@
package com.genersoft.iot.vmp.gb28181.event.offline;



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

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 org.slf4j.Logger;

import org.slf4j.LoggerFactory;

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

import org.springframework.context.ApplicationListener;

import org.springframework.context.annotation.DependsOn;

import org.springframework.context.annotation.Lazy;

import org.springframework.stereotype.Component;



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

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

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



import java.util.List;



/**

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

@@ -31,6 +38,9 @@


   @Autowired

    private UserSetup userSetup;



   @Autowired

    private EventPublisher eventPublisher;



   @Override

   public void onApplicationEvent(OfflineEvent event) {

@@ -56,6 +66,8 @@
            }

      }



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

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

      // 处理离线监听

      storager.outline(event.getDeviceId());