| | |
|---|
| | | /** |
|---|
| | | * 向Redis中存入设备状态 |
|---|
| | | */ |
|---|
| | | public void setCacheData() { |
|---|
| | | list().forEach( |
|---|
| | | device -> { |
|---|
| | | RedisDeviceStatus deviceStatus = new RedisDeviceStatus(); |
|---|
| | | deviceStatus.setDeviceId(device.getC3Id().toString()); |
|---|
| | | if (device != null) { |
|---|
| | | A5C3HeartbeatReportInnerFrame.HeartBeatDataPackage beatDataPackage = ReadTheHeartbeatPackage(device.getC3Id(), false); |
|---|
| | | if (beatDataPackage != null) { |
|---|
| | | //在线状态 1.空闲 2.充电中 3.充电中断，等待服务器确认 4.充电结束，等待服务器确认 5.有故障 6.与充电桩对接中 |
|---|
| | | if (Integer.valueOf(beatDataPackage.getStatusBit()) == 5) { |
|---|
| | | deviceStatus.setStatus(2); |
|---|
| | | } else { |
|---|
| | | deviceStatus.setStatus(0); |
|---|
| | | } |
|---|
| | | |
|---|
| | | } else { |
|---|
| | | deviceStatus.setStatus(1); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | redisUtils.set(DeviceRedisKey.C3M + device.getC3Id(), JSON.toJSONString(deviceStatus)); |
|---|
| | | // redisUtils.delete(DeviceRedisKey.C3M + device.getC3Id()); |
|---|
| | | } |
|---|
| | | ); |
|---|
| | | |
|---|
| | | } |
|---|
| | | // public void setCacheData() { |
|---|
| | | // list().forEach( |
|---|
| | | // device -> { |
|---|
| | | // RedisDeviceStatus deviceStatus = new RedisDeviceStatus(); |
|---|
| | | // deviceStatus.setDeviceId(device.getC3Id().toString()); |
|---|
| | | // if (device != null) { |
|---|
| | | // A5C3HeartbeatReportInnerFrame.HeartBeatDataPackage beatDataPackage = ReadTheHeartbeatPackage(device.getC3Id(), false); |
|---|
| | | // if (beatDataPackage != null) { |
|---|
| | | // //在线状态 1.空闲 2.充电中 3.充电中断，等待服务器确认 4.充电结束，等待服务器确认 5.有故障 6.与充电桩对接中 |
|---|
| | | // if (Integer.valueOf(beatDataPackage.getStatusBit()) == 5) { |
|---|
| | | // deviceStatus.setStatus(2); |
|---|
| | | // } else { |
|---|
| | | // deviceStatus.setStatus(0); |
|---|
| | | // } |
|---|
| | | // |
|---|
| | | // } else { |
|---|
| | | // deviceStatus.setStatus(1); |
|---|
| | | // } |
|---|
| | | // } |
|---|
| | | // redisUtils.set(DeviceRedisKey.C3M + device.getC3Id(), JSON.toJSONString(deviceStatus)); |
|---|
| | | //// redisUtils.delete(DeviceRedisKey.C3M + device.getC3Id()); |
|---|
| | | // } |
|---|
| | | // ); |
|---|
| | | // |
|---|
| | | // } |
|---|
| | | } |
|---|
