维护目录订阅消息与接口

648540858

2021-11-12 eca1e05aeed3c51cce36bbce80c71bc3cbcea87d

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

@@ -11,10 +11,10 @@
import com.genersoft.iot.vmp.utils.redis.RedisUtil;



/**

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

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

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

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

 *               2、设备未知原因离线，心跳超时,{@link com.genersoft.iot.vmp.gb28181.event.offline.OfflineEventListener}

 * @author: songww

 * @author: swwheihei

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

 */

@Component

@@ -38,21 +38,24 @@
      String key = VideoManagerConstants.KEEPLIVEKEY_PREFIX + event.getDeviceId();



      switch (event.getFrom()) {

      // 心跳超时触发的离线事件，说明redis中已删除，无需处理

      case VideoManagerConstants.EVENT_OUTLINE_TIMEOUT:

         break;

      // 设备主动注销触发的离线事件，需要删除redis中的超时监听

      case VideoManagerConstants.EVENT_OUTLINE_UNREGISTER:

         redis.del(key);

         break;

      default:

         boolean exist = redis.hasKey(key);

         if (exist) {

         // 心跳超时触发的离线事件，说明redis中已删除，无需处理

         case VideoManagerConstants.EVENT_OUTLINE_TIMEOUT:

            break;

         // 设备主动注销触发的离线事件，需要删除redis中的超时监听

         case VideoManagerConstants.EVENT_OUTLINE_UNREGISTER:

            redis.del(key);

         }

            break;

         default:

            boolean exist = redis.hasKey(key);

            if (exist) {

               redis.del(key);

            }

      }



      // 处理离线监听

      storager.outline(event.getDeviceId());



      // TODO 离线取消订阅



   }

}