| | |
|---|
| | | identity.getIntValue("devtype"), identity.getIntValue("devid"), |
|---|
| | | identity.getIntValue("subdevid"), identity.getIntValue("chlid")); |
|---|
| | | RealtimeSnapshot latestSnapshot = object.getObject("latestSnapshot", RealtimeSnapshot.class); |
|---|
| | | // sourceDisplayNo 用宽容读法：升级前写进 Redis 的候选没有这个键，读成空即可，不该报错。 |
|---|
| | | return new ChannelCandidate(channelIdentity, object.getBooleanValue("online"), |
|---|
| | | DeviceWorkStatus.valueOf(object.getString("workStatus")), requiredInstant(object, "observedAt"), |
|---|
| | | latestSnapshot, optionalInstant(object, "lastDataAt")); |
|---|
| | | latestSnapshot, optionalInstant(object, "lastDataAt"), object.getString("sourceDisplayNo")); |
|---|
| | | } |
|---|
| | | |
|---|
| | | private CollectorCandidate collectorCandidate(Object value) |
|---|
