| | |
| | | //存入数据库的结果集 |
| | | List<Map<String, Object>> insertData = new ArrayList<>(); |
| | | |
| | | data.forEach((key, value) -> { |
| | | data.forEach((mac, value) -> { |
| | | Map<String, Object> dataMap = new HashMap<>(); |
| | | Map<String, Object> jsonMap = new HashMap<>(); |
| | | dataMap.put("mac", key); |
| | | dataMap.put("mac", mac); |
| | | dataMap.put("time", start); |
| | | |
| | | //中间变量,用于计算除臭氧外其它因子 |
| | | List<Map<String, Object>> tempValue = new ArrayList<>(value); |
| | | |
| | | //移除第一天数据(0点的),O3滑动值第一天数据是从1点-8点 |
| | | //移除第一天数据(0点的),O3滑动值第一条数据是从1点-8点 |
| | | value.removeIf(map -> ((Date) map.get("time")).getTime() == start.getTime()); |
| | | |
| | | Map<String, Object> params = new HashMap<>(); |
| | | params.put("data", value); |
| | | params.put("type", "day"); |
| | |
| | | } |
| | | |
| | | if (ObjectUtils.isEmpty(sensorValue)) { |
| | | System.out.println(456); |
| | | return null; |
| | | } |
| | | |
| | |
| | | return null; |
| | | } |
| | | } |
| | | if ("a00e12".equals(sensorCode)) { |
| | | System.out.println(key + "==" + sensorCode + "==" + v.get("time") + "==" + aDouble); |
| | | } |
| | | |
| | | return DoubleStream.of(aDouble); |
| | | }).average(); |
| | | if (optionalDouble.isPresent()) { |