| | |
| | | private void loadDeviceState(List<Device> list){
|
| | | //从redis里取状态
|
| | | list.stream().map( device -> {
|
| | | String mac = Optional.of(device.getMac()).get();
|
| | | String mac = device.getMac();
|
| | | if(!StringUtils.isBlank(mac)){
|
| | | String state = getSateFromRedis(device.getMonitorPointId(),mac.toLowerCase());
|
| | | device.setState(state);
|
| | | }else{
|
| | | device.setState(Constants.DEVICE_STATE_OFFLINE);
|
| | | }
|
| | | return device;
|
| | | }).count();
|
| | | }
|
| | |
| | | @Override
|
| | | public List<Map<String,String>> queryDevicesState(List<String> macList,Boolean withData) {
|
| | | List<Map<String,String>> list = macList.stream().map(mac->{
|
| | | Map<String,String> resultMap = new HashMap<>();
|
| | | if(!StringUtils.isBlank(mac)){
|
| | | mac = mac.toLowerCase();
|
| | | Device device = getDeviceWithOrgIdsByMac(mac);
|
| | | Map<String,String> resultMap = new HashMap<>();
|
| | | Map<String,String> stateMap = getStateMapFromRedis(device.getMonitorPointId(),mac);
|
| | | if(!MapUtils.isEmpty(stateMap)){
|
| | | resultMap.putAll(stateMap);
|
| | |
| | | resultMap.put("state",Constants.DEVICE_STATE_OFFLINE);
|
| | | resultMap.put("mac",mac);
|
| | | }
|
| | | //添加data
|
| | | if(BooleanUtils.isTrue(withData)){
|
| | | String dataKey = "data_"+mac;
|
| | | Map<String,String> dataMap = redisUtils.get(dataKey,new TypeReference<Map<String,String>>(){});
|
| | |
| | | resultMap.putAll(dataMap);
|
| | | }
|
| | | }
|
| | | }
|
| | | return resultMap;
|
| | | }).collect(Collectors.toList());
|
| | | return list;
|