| | |
|---|
| | | if (updateChannelOnlineList.size() > 300) { |
|---|
| | | executeSaveForOnline(); |
|---|
| | | } |
|---|
| | | if (userSetting.getDeviceStatusNotify()) { |
|---|
| | | // 发送redis消息 |
|---|
| | | redisCatchStorage.sendDeviceOrChannelStatus(device.getDeviceId(), channel.getChannelId(), true); |
|---|
| | | } |
|---|
| | | |
|---|
| | | break; |
|---|
| | | case CatalogEvent.OFF : |
|---|
| | | // 离线 |
|---|
| | | logger.info("[收到通道离线通知] 来自设备: {}, 通道 {}", device.getDeviceId(), channel.getChannelId()); |
|---|
| | | if (userSetting.getRefuseChannelStatusChannelFormNotify()) { |
|---|
| | | logger.info("[收到通道离线通知] 但是平台已配置拒绝此消息，来自设备: {}, 通道 {}", device.getDeviceId(), channel.getChannelId()); |
|---|
| | | }else { |
|---|
| | | updateChannelOfflineList.add(channel); |
|---|
| | | if (updateChannelOfflineList.size() > 300) { |
|---|
| | | executeSaveForOffline(); |
|---|
| | | } |
|---|
| | | }else { |
|---|
| | | logger.info("[收到通道离线通知] 但是平台已配置拒绝此消息，来自设备: {}, 通道 {}", device.getDeviceId(), channel.getChannelId()); |
|---|
| | | if (userSetting.getDeviceStatusNotify()) { |
|---|
| | | // 发送redis消息 |
|---|
| | | redisCatchStorage.sendDeviceOrChannelStatus(device.getDeviceId(), channel.getChannelId(), false); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | break; |
|---|
| | | case CatalogEvent.VLOST: |
|---|
| | | // 视频丢失 |
|---|
| | | logger.info("[收到通道视频丢失通知] 来自设备: {}, 通道 {}", device.getDeviceId(), channel.getChannelId()); |
|---|
| | | if (userSetting.getRefuseChannelStatusChannelFormNotify()) { |
|---|
| | | logger.info("[收到通道视频丢失通知] 但是平台已配置拒绝此消息，来自设备: {}, 通道 {}", device.getDeviceId(), channel.getChannelId()); |
|---|
| | | }else { |
|---|
| | | updateChannelOfflineList.add(channel); |
|---|
| | | if (updateChannelOfflineList.size() > 300) { |
|---|
| | | executeSaveForOffline(); |
|---|
| | | } |
|---|
| | | }else { |
|---|
| | | logger.info("[收到通道视频丢失通知] 但是平台已配置拒绝此消息，来自设备: {}, 通道 {}", device.getDeviceId(), channel.getChannelId()); |
|---|
| | | if (userSetting.getDeviceStatusNotify()) { |
|---|
| | | // 发送redis消息 |
|---|
| | | redisCatchStorage.sendDeviceOrChannelStatus(device.getDeviceId(), channel.getChannelId(), false); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | break; |
|---|
| | | case CatalogEvent.DEFECT: |
|---|
| | | // 故障 |
|---|
| | | logger.info("[收到通道视频故障通知] 来自设备: {}, 通道 {}", device.getDeviceId(), channel.getChannelId()); |
|---|
| | | if (userSetting.getRefuseChannelStatusChannelFormNotify()) { |
|---|
| | | logger.info("[收到通道视频故障通知] 但是平台已配置拒绝此消息，来自设备: {}, 通道 {}", device.getDeviceId(), channel.getChannelId()); |
|---|
| | | }else { |
|---|
| | | updateChannelOfflineList.add(channel); |
|---|
| | | if (updateChannelOfflineList.size() > 300) { |
|---|
| | | executeSaveForOffline(); |
|---|
| | | } |
|---|
| | | }else { |
|---|
| | | logger.info("[收到通道视频故障通知] 但是平台已配置拒绝此消息，来自设备: {}, 通道 {}", device.getDeviceId(), channel.getChannelId()); |
|---|
| | | if (userSetting.getDeviceStatusNotify()) { |
|---|
| | | // 发送redis消息 |
|---|
| | | redisCatchStorage.sendDeviceOrChannelStatus(device.getDeviceId(), channel.getChannelId(), false); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | break; |
|---|
| | | case CatalogEvent.ADD: |
|---|
