| | |
|---|
| | | 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; |
|---|
| | | } |
|---|
| | | |
|---|
