sx/map
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

查询历史数据修改

Browse Source
This commit is contained in:
huguanghan 2024-10-30 09:49:30 +08:00
parent 8b6c2557b2
commit b12abbe1ad
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
das/src/main/java/com/das/modules/node/service/TDEngineService.java
View File

@ -80,7 +80,7 @@ public class TDEngineService {
} }
sb.append(") TAGS (`deviceid` BIGINT);"); sb.append(") TAGS (`deviceid` BIGINT);");
try { try {
System.out.println(sb.toString()); log.info(sb.toString());
pstmt.executeUpdate(sb.toString()); pstmt.executeUpdate(sb.toString());
} catch (Exception e) { } catch (Exception e) {
log.error("创建超级表失败,失败原因{}", e); log.error("创建超级表失败,失败原因{}", e);
@ -353,6 +353,9 @@ public class TDEngineService {
} }
Map<String, Map<String, Map<String, Object>>> result = new HashMap<>(); Map<String, Map<String, Map<String, Object>>> result = new HashMap<>();
Map<String, Map<String, Object>> valueMap = new HashMap<>(); Map<String, Map<String, Object>> valueMap = new HashMap<>();
for (String item : fieldList){
valueMap.put(item,null);
}
StringBuffer sb = new StringBuffer(2048); StringBuffer sb = new StringBuffer(2048);
if (StrUtil.isNotBlank(interval)) { if (StrUtil.isNotBlank(interval)) {
String startTimeStr = SIMPLE_DATE_FORMAT.format(startTime); String startTimeStr = SIMPLE_DATE_FORMAT.format(startTime);
@ -392,7 +395,7 @@ public class TDEngineService {
List<Long> timeList = new ArrayList<>(); List<Long> timeList = new ArrayList<>();
timeList.add(rs.getTimestamp(1).getTime()); timeList.add(rs.getTimestamp(1).getTime());
List<Object> valueList = new ArrayList<>(); List<Object> valueList = new ArrayList<>();
valueList.add(rs.getObject(fieldList.get(i))); valueList.add(rs.getObject(fieldList.get(i).toLowerCase()));
map.put("times",timeList); map.put("times",timeList);
map.put("values",valueList); map.put("values",valueList);
valueMap.put(fieldList.get(i),map); valueMap.put(fieldList.get(i),map);
@ -401,7 +404,7 @@ public class TDEngineService {
List<Long> times = (List<Long>) map.get("times"); List<Long> times = (List<Long>) map.get("times");
List<Object> values = (List<Object>) map.get("values"); List<Object> values = (List<Object>) map.get("values");
times.add(rs.getTimestamp(1).getTime()); times.add(rs.getTimestamp(1).getTime());
values.add(rs.getObject(fieldList.get(i))); values.add(rs.getObject(fieldList.get(i).toLowerCase()));
} }
} }
} }