| | |
|---|
| | | private void judgeDeviceState(String mac,Map<String, Object> dataMap){ |
|---|
| | | List<String> sensorList = Arrays.asList("a34004","a34002","a21026","a21004","a21005","a05024","a99054"); |
|---|
| | | Device device = (Device) redisTemplate.opsForHash().get(RedisConstants.DEVICE_INFO, mac); |
|---|
| | | if(Objects.isNull(device)){ |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | List<Sensor> sensors = device.getVersion().getSensors(); |
|---|
| | | Expression expression; |
|---|
| | | int state = 1; |
|---|
| | |
|---|
| | | dataMap.put("value", JSONObject.toJSONString(jsonMap)); |
|---|
| | | //存入redis |
|---|
| | | jsonMap.put("dataTime", DateUtils.dateToDateString(start)); |
|---|
| | | // redisTemplate.opsForHash().put(RedisConstants.DATA_FIVE_MINUTES, key, jsonMap); |
|---|
| | | //insertData.add(dataMap); |
|---|
| | | redisTemplate.opsForHash().put(RedisConstants.DATA_FIVE_MINUTES, key, jsonMap); |
|---|
| | | insertData.add(dataMap); |
|---|
| | | System.out.println(">>>"+key+"->>>"+jsonMap.toString()); |
|---|
| | | judgeDeviceState(key,jsonMap); |
|---|
| | | System.out.println(dataMap); |
|---|
| | | }); |
|---|
| | | |
|---|
| | | }); |
|---|
| | | //5分钟表后缀 |
|---|
| | | // String insertTimeUnits = DateUtils.dateToDateString(start, DateUtils.yyyyMM_EN); |
|---|
| | | //存入数据库 |
|---|
| | | // historyFiveMinutelyMapper.insertHistoryFiveMinutely(insertData, insertTimeUnits); |
|---|
| | | |
|---|
| | | } |
|---|
| | | } |
|---|
