| | |
|---|
| | | channels = deviceChannelList; |
|---|
| | | } |
|---|
| | | if (stringBuilder.length() > 0) { |
|---|
| | | logger.debug("[目录查询]收到的数据存在重复： {}" , stringBuilder); |
|---|
| | | logger.info("[目录查询]收到的数据存在重复： {}" , stringBuilder); |
|---|
| | | } |
|---|
| | | try { |
|---|
| | | int cleanChannelsResult = deviceChannelMapper.cleanChannelsNotInList(deviceId, channels); |
|---|
| | |
|---|
| | | device.setOnline(1); |
|---|
| | | logger.info("更新设备在线: " + deviceId); |
|---|
| | | redisCatchStorage.updateDevice(device); |
|---|
| | | List<DeviceChannel> deviceChannelList = deviceChannelMapper.queryOnlineChannelsByDeviceId(deviceId); |
|---|
| | | eventPublisher.catalogEventPublish(null, deviceChannelList, CatalogEvent.ON); |
|---|
| | | return deviceMapper.update(device) > 0; |
|---|
| | | } |
|---|
| | | |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public List<StreamProxyItem> getStreamProxyListForEnableInMediaServer(String id, boolean enable, boolean status) { |
|---|
| | | return streamProxyMapper.selectForEnableInMediaServer(id, enable, status); |
|---|
| | | public List<StreamProxyItem> getStreamProxyListForEnableInMediaServer(String id, boolean enable) { |
|---|
| | | return streamProxyMapper.selectForEnableInMediaServer(id, enable); |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
