From d4f150414533b95324b2a1c8a81c11d92efb71ec Mon Sep 17 00:00:00 2001
From: xufenglei <xufenglei>
Date: Tue, 13 Mar 2018 16:25:20 +0800
Subject: [PATCH] Merge branch 'master' of http://blit.7drlb.com:8888/r/screen_api_v2.git

---
 src/main/java/com/moral/service/impl/HistoryMinutelyServiceImpl.java |   73 ++++++++++++++++++++++++++++++++++++
 1 files changed, 73 insertions(+), 0 deletions(-)

diff --git a/src/main/java/com/moral/service/impl/HistoryMinutelyServiceImpl.java b/src/main/java/com/moral/service/impl/HistoryMinutelyServiceImpl.java
index bf84e4a..1518f85 100644
--- a/src/main/java/com/moral/service/impl/HistoryMinutelyServiceImpl.java
+++ b/src/main/java/com/moral/service/impl/HistoryMinutelyServiceImpl.java
@@ -27,9 +27,16 @@
 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;
 
+import com.moral.common.util.ReportTimeFormat;
+import com.moral.entity.charts.DataCondition;
+import com.moral.entity.charts.LineChartCriteria;
+import com.moral.entity.charts.PairData;
+import com.moral.entity.charts.TimePeriod;
 import org.apache.commons.lang3.time.DateUtils;
 import org.springframework.stereotype.Service;
 import org.springframework.util.ObjectUtils;
@@ -435,4 +442,70 @@
 		return result;
 	}
 
+	/**
+	 * ������������������������������������������������������������������
+	 * @param lineChartCriteria
+	 * @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;
+	}
+
+	/**
+	 * ������������������������������������������������������������������
+	 * @param sensorKey
+	 * @param timePeriod
+	 * @param dataCondition
+	 * @return
+	 */
+	public List<PairData> queryOneLineChartDateByCrieria(String sensorKey, TimePeriod timePeriod, DataCondition dataCondition){
+		List<String> timeList = ReportTimeFormat.makeTimeList(timePeriod);
+		List<PairData> lineChartDatas = historyMinutelyMapper.selectLineChartDateByCrieria(sensorKey,timePeriod,dataCondition);
+		List<PairData> lineChartDatasWithEmpty = new ArrayList<>();
+		int m = 0;
+		int dataLength = lineChartDatas.size()-1;
+		m = dataLength>-1?0:-1;
+		if(m>-1){
+			for(int n =0;n<timeList.size();n++){
+				String time = timeList.get(n);
+				if(m>-1){
+					PairData pairData = lineChartDatas.get(m);
+					String keyTime = pairData.getCategory();
+					if(time.equals(keyTime)){
+						lineChartDatasWithEmpty.add(pairData);
+						m = m<dataLength ? m+1 : -1;
+					}else{
+						lineChartDatasWithEmpty.add(generateEmptyData(time));
+					}
+				}else {
+					    lineChartDatasWithEmpty.add(generateEmptyData(time));
+				}
+
+			}
+		}else{
+			fillEmptyDataToList(timeList,lineChartDatasWithEmpty);
+		}
+		return  lineChartDatasWithEmpty;
+	}
+	private PairData generateEmptyData(String time) {
+		PairData pairData = new PairData();
+		pairData.setCategory(time);
+		pairData.setValue(null);
+		return pairData;
+	}
+	private void fillEmptyDataToList(List<String> timeList,List<PairData> lineChartDatasWithEmpty){
+        timeList.forEach( time ->{
+			PairData pairData = generateEmptyData(time);
+        	lineChartDatasWithEmpty.add(pairData);
+		});
+	}
 }

--
Gitblit v1.8.0