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