fengxiang
2018-03-23 ed8f0aeffb619c0540b16420320973207c55f015
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);
@@ -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;
   }
   /**