From ed8f0aeffb619c0540b16420320973207c55f015 Mon Sep 17 00:00:00 2001 From: fengxiang <110431245@qq.com> Date: Fri, 23 Mar 2018 08:52:49 +0800 Subject: [PATCH] 地图点击关闭弹窗 --- src/main/java/com/moral/service/impl/HistoryMinutelyServiceImpl.java | 41 +++++++++++++++++++++++------------------ 1 files changed, 23 insertions(+), 18 deletions(-) diff --git a/src/main/java/com/moral/service/impl/HistoryMinutelyServiceImpl.java b/src/main/java/com/moral/service/impl/HistoryMinutelyServiceImpl.java index fab186f..43104c6 100644 --- a/src/main/java/com/moral/service/impl/HistoryMinutelyServiceImpl.java +++ b/src/main/java/com/moral/service/impl/HistoryMinutelyServiceImpl.java @@ -9,7 +9,6 @@ import java.time.temporal.TemporalAdjusters; import java.util.ArrayList; import java.util.Arrays; -import java.util.Collection; import java.util.Collections; import java.util.Comparator; import java.util.Date; @@ -27,8 +26,6 @@ import java.util.concurrent.ExecutorCompletionService; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; -import java.util.stream.Collector; -import java.util.stream.Collectors; import javax.annotation.Resource; @@ -147,6 +144,10 @@ Map<String, List<Object>> resultMap = new HashMap<String, List<Object>>(); List<Map<String, Object>> list = JSON.parseObject((String)parameters.get("items"), new TypeReference<List<Map<String, Object>>>() {}); parameters.remove("items"); + Map<String, Object> timeType = JSON.parseObject((String)parameters.get("timeType"), new TypeReference<Map<String, Object>>() {}); + parameters.remove("timeType"); + parameters.putAll(timeType); + ExecutorService threadPool = Executors.newCachedThreadPool(); CompletionService<Map<String, List<Object>>> cs = new ExecutorCompletionService<Map<String, List<Object>>>(threadPool); @@ -271,7 +272,7 @@ @Override public List<Map<String, Object>> getMonitorPointOrDeviceAvgData(Map<String, Object> parameters) throws Exception { - List<Map<String, Object>> resul ; + List<Map<String, Object>> resultList ; String type = (String) parameters.get("type"); String time = (String) parameters.get("time"); @@ -308,7 +309,7 @@ //sensorKeys.clear(); // ������������������ if (!parameters.containsKey("mac")) { - resul = new ArrayList<Map<String,Object>>(); + resultList = new ArrayList<Map<String,Object>>(); Integer monitorPointId = Integer.valueOf(parameters.get("monitorPoint").toString()); List<Map<String, Object>> deviceVersions = deviceMapper.getDeviceVersionIdByMonitorPoint(monitorPointId); ExecutorService threadPool = Executors.newCachedThreadPool(); @@ -373,7 +374,7 @@ for (String sensorKey : value.keySet()) { resultMap.put(sensorKey, value.get(sensorKey)[2]); } - resul.add(resultMap); + resultList.add(resultMap); } // ������ ��������� } else { @@ -388,9 +389,9 @@ parameters.put("sensorKeyColumn", sensorKeyColumn); } - resul = historyMinutelyMapper.getMonitorPointOrDeviceAvgData(parameters); + resultList = historyMinutelyMapper.getMonitorPointOrDeviceAvgData(parameters); } - return resul; + return resultList; } private String getSensorKeyColumnBySensors(List<Map<String, Object>> sensors,Map<String, Object> parameters) { @@ -448,16 +449,20 @@ * @return */ @Override - public List<List<PairData>> queryLineChartDateByCrieria(LineChartCriteria lineChartCriteria){ - String sensorKey = lineChartCriteria.getSensorKey(); - TimePeriod timePeriod = lineChartCriteria.getTimePeriod(); - List<DataCondition> dataConditionList = lineChartCriteria.getDataConditions(); - List<List<PairData>> list = new ArrayList<>(); - dataConditionList.forEach(item -> { - List<PairData> pairDataList = queryOneLineChartDateByCrieria(sensorKey,timePeriod,item); - list.add(pairDataList); - }); - return list; + public Map<String, List<List<PairData>>> queryLineChartDateByCrieria(LineChartCriteria lineChartCriteria){ + Map<String,List<List<PairData>>> listMap = new HashMap<>(); + for(String sensorKey:lineChartCriteria.getSensorKeys()){ + TimePeriod timePeriod = lineChartCriteria.getTimePeriod(); + List<DataCondition> dataConditionList = lineChartCriteria.getDataConditions(); + List<List<PairData>> list = new ArrayList<>(); + dataConditionList.forEach(item -> { + List<PairData> pairDataList = queryOneLineChartDateByCrieria(sensorKey,timePeriod,item); + list.add(pairDataList); + }); + listMap.put(sensorKey,list); + } + + return listMap; } /** -- Gitblit v1.8.0