配置修改

zhongrj

2025-01-16 f1d079f9c0b3d384090477ca54e0548373d62b57

 src/main/java/com/genersoft/iot/vmp/gb28181/event/EventPublisher.java

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

import com.genersoft.iot.vmp.gb28181.bean.*;
import com.genersoft.iot.vmp.gb28181.event.offline.OfflineEvent;
import com.genersoft.iot.vmp.gb28181.event.platformKeepaliveExpire.PlatformKeepaliveExpireEvent;
import com.genersoft.iot.vmp.gb28181.event.platformNotRegister.PlatformCycleRegisterEvent;
import com.genersoft.iot.vmp.gb28181.event.platformNotRegister.PlatformNotRegisterEvent;
import com.genersoft.iot.vmp.gb28181.event.device.RequestTimeoutEvent;
import com.genersoft.iot.vmp.gb28181.event.record.RecordEndEvent;
import com.genersoft.iot.vmp.gb28181.event.subscribe.catalog.CatalogEvent;
import com.genersoft.iot.vmp.media.zlm.event.ZLMOfflineEvent;
import com.genersoft.iot.vmp.media.zlm.event.ZLMOnlineEvent;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationEventPublisher;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;

import com.genersoft.iot.vmp.gb28181.event.alarm.AlarmEvent;
import com.genersoft.iot.vmp.gb28181.event.online.OnlineEvent;

import javax.sip.TimeoutEvent;
import java.util.ArrayList;
import java.util.HashSet;
import java.util.List;
@@ -32,58 +28,6 @@

   @Autowired
    private ApplicationEventPublisher applicationEventPublisher;
	
   public void onlineEventPublish(Device device, String from, int expires) {
      OnlineEvent onEvent = new OnlineEvent(this);
      onEvent.setDevice(device);
      onEvent.setFrom(from);
      onEvent.setExpires(expires);
        applicationEventPublisher.publishEvent(onEvent);
    }

   public void onlineEventPublish(Device device, String from) {
      OnlineEvent onEvent = new OnlineEvent(this);
      onEvent.setDevice(device);
      onEvent.setFrom(from);
      applicationEventPublisher.publishEvent(onEvent);
   }
	
   public void outlineEventPublish(String deviceId, String from){
      OfflineEvent outEvent = new OfflineEvent(this);
      outEvent.setDeviceId(deviceId);
      outEvent.setFrom(from);
        applicationEventPublisher.publishEvent(outEvent);
    }

   /**
    * 平台心跳到期事件
    * @param platformGbId
    */
   public void platformKeepaliveExpireEventPublish(String platformGbId){
      PlatformKeepaliveExpireEvent platformNotRegisterEvent = new PlatformKeepaliveExpireEvent(this);
      platformNotRegisterEvent.setPlatformGbID(platformGbId);
        applicationEventPublisher.publishEvent(platformNotRegisterEvent);
    }

   /**
    * 平台未注册事件
    * @param platformGbId
    */
   public void platformNotRegisterEventPublish(String platformGbId){
      PlatformNotRegisterEvent platformNotRegisterEvent = new PlatformNotRegisterEvent(this);
      platformNotRegisterEvent.setPlatformGbID(platformGbId);
        applicationEventPublisher.publishEvent(platformNotRegisterEvent);
   }

   /**
    * 平台周期注册事件
    * @param paltformGbId
    */
   public void platformRegisterCycleEventPublish(String paltformGbId) {
      PlatformCycleRegisterEvent platformCycleRegisterEvent = new PlatformCycleRegisterEvent(this);
      platformCycleRegisterEvent.setPlatformGbID(paltformGbId);
      applicationEventPublisher.publishEvent(platformCycleRegisterEvent);
   }
   
   /**
    * 设备报警事件
@@ -115,6 +59,13 @@
   }


   public void requestTimeOut(TimeoutEvent timeoutEvent) {
      RequestTimeoutEvent requestTimeoutEvent = new RequestTimeoutEvent(this);
      requestTimeoutEvent.setTimeoutEvent(timeoutEvent);
      applicationEventPublisher.publishEvent(requestTimeoutEvent);
   }


   /**
    *
    * @param platformId