| | |
|---|
| | | if (deviceInRedis != null && deviceInDb == null) { |
|---|
| | | // redis 存在脏数据 |
|---|
| | | redisCatchStorage.clearCatchByDeviceId(device.getDeviceId()); |
|---|
| | | |
|---|
| | | } |
|---|
| | | device.setUpdateTime(now); |
|---|
| | | device.setOnline(1); |
|---|
| | |
|---|
| | | if (device.getCreateTime() == null) { |
|---|
| | | device.setCreateTime(now); |
|---|
| | | logger.info("[设备上线,首次注册]: {}，查询设备信息以及通道信息", device.getDeviceId()); |
|---|
| | | deviceMapper.add(device); |
|---|
| | | redisCatchStorage.updateDevice(device); |
|---|
| | | commander.deviceInfoQuery(device); |
|---|
| | | sync(device); |
|---|
| | | deviceMapper.add(device); |
|---|
| | | }else { |
|---|
| | | deviceMapper.update(device); |
|---|
| | | redisCatchStorage.updateDevice(device); |
|---|
| | | } |
|---|
| | | redisCatchStorage.updateDevice(device); |
|---|
| | | |
|---|
| | | // 上线添加订阅 |
|---|
| | | if (device.getSubscribeCycleForCatalog() > 0) { |
|---|
| | | // 查询在线设备那些开启了订阅，为设备开启定时的目录订阅 |
|---|
