|  |  |  | 
|---|
|  |  |  | import com.genersoft.iot.vmp.gb28181.bean.ParentPlatform; | 
|---|
|  |  |  | import com.genersoft.iot.vmp.gb28181.bean.ParentPlatformCatch; | 
|---|
|  |  |  | import com.genersoft.iot.vmp.gb28181.event.EventPublisher; | 
|---|
|  |  |  | import com.genersoft.iot.vmp.gb28181.transmit.cmd.ISIPCommanderForPlatform; | 
|---|
|  |  |  | import com.genersoft.iot.vmp.storager.IRedisCatchStorage; | 
|---|
|  |  |  | import com.genersoft.iot.vmp.storager.IVideoManagerStorager; | 
|---|
|  |  |  | import org.springframework.beans.factory.annotation.Autowired; | 
|---|
|  |  |  | 
|---|
|  |  |  | // 设置所有平台离线 | 
|---|
|  |  |  | storager.outlineForAllParentPlatform(); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | // 清理所有平台注册缓存 | 
|---|
|  |  |  | redisCatchStorage.cleanPlatformRegisterInfos(); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | List<ParentPlatform> parentPlatforms = storager.queryEnableParentPlatformList(true); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | for (ParentPlatform parentPlatform : parentPlatforms) { | 
|---|
|  |  |  |  | 
|---|
|  |  |  | redisCatchStorage.updatePlatformRegister(parentPlatform); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | redisCatchStorage.updatePlatformKeepalive(parentPlatform); | 
|---|
|  |  |  | 
|---|
|  |  |  | ParentPlatformCatch parentPlatformCatch = new ParentPlatformCatch(); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | parentPlatformCatch.setParentPlatform(parentPlatform); | 
|---|
|  |  |  | parentPlatformCatch.setId(parentPlatform.getDeviceGBId()); | 
|---|
|  |  |  | parentPlatformCatch.setId(parentPlatform.getServerGBId()); | 
|---|
|  |  |  | redisCatchStorage.updatePlatformCatchInfo(parentPlatformCatch); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | // 发送平台未注册消息 | 
|---|
|  |  |  | publisher.platformNotRegisterEventPublish(parentPlatform.getDeviceGBId()); | 
|---|
|  |  |  | publisher.platformNotRegisterEventPublish(parentPlatform.getServerGBId()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|