更新 时间api用法

xufenglei

2018-02-10 f2857dd60023bb0ddb87f7f06993987f97a4b2be

 src/main/java/com/moral/service/impl/HistoryMinutelyServiceImpl.java

@@ -1,13 +1,13 @@
package com.moral.service.impl;



import static org.apache.commons.lang3.time.DateUtils.addDays;

import static org.apache.commons.lang3.time.DateUtils.truncate;

import static com.moral.common.bean.Constants.NULL_VALUE;

import static org.springframework.util.ObjectUtils.isEmpty;



import java.math.BigDecimal;

import java.math.RoundingMode;

import java.time.LocalDate;

import java.time.temporal.TemporalAdjusters;

import java.util.ArrayList;

import java.util.Calendar;

import java.util.Collections;

import java.util.Comparator;

import java.util.Date;

@@ -35,8 +35,8 @@
import com.moral.common.util.ResourceUtil;

import com.moral.common.util.ValidateUtil;

import com.moral.entity.Device;

import com.moral.mapper.HistoryMinutelyMapper;

import com.moral.mapper.DeviceMapper;

import com.moral.mapper.HistoryMinutelyMapper;

import com.moral.mapper.SensorMapper;

import com.moral.service.HistoryMinutelyService;



@@ -57,12 +57,22 @@
   @Override

   public Map<String, Object> getDayAQIByDevice(Map<String, Object> parameters) {

      ValidateUtil.notNull(parameters.get("mac"), "param.is.null");

      Date date = new Date();

      LocalDate localDate = LocalDate.now();

      // 昨日00:00:00

      parameters.put("start", truncate(addDays(date, -1), Calendar.DATE));

      parameters.put("start", localDate.minusDays(1));

		
      // 今日00:00:00

      parameters.put("end", truncate(date, Calendar.DATE));

      Map<String, Double> average = historyMinutelyMapper.getDayAQIByDevice(parameters);

      parameters.put("end", localDate);

      String[] macKeys = { "e1", "e2", "e10", "e11", "e15", "e16" };

      String sensorKeyColumn = "";

      for (int i = 0; i < macKeys.length; i++) {

         sensorKeyColumn += "AVG(json -> '$." + macKeys[i] + "[0]') " + macKeys[i];

         if (i != macKeys.length -1) {

            sensorKeyColumn += " ,";

         } 
      }

      parameters.put("sensorKeyColumn", sensorKeyColumn);

      Map<String, Double> average = historyMinutelyMapper.getSersionAvgByDevice(parameters);

      return getAQIByDataMap(average);

   }



@@ -258,6 +268,8 @@
         parameters.put("sensorKeyColumn", sensorKeyColumn);

      }



      sensorKeys.clear();

      // 监控点平均值

      if (!parameters.containsKey("mac")) {

         resul = new ArrayList<Map<String,Object>>();

         Integer monitorPointId = Integer.valueOf((String) parameters.get("monitorPoint"));

@@ -327,8 +339,9 @@
            }

            resul.add(resultMap);

         }

			
      // 设备 平均值	
      } else {

         // 所有传感器

         if (!parameters.containsKey("sensorKeyColumn")) {

            String mac = (String) parameters.get("mac");

            Device device = new Device();

@@ -347,17 +360,46 @@


   private String getSensorKeyColumnBySensors(List<Map<String, Object>> sensors) {

      String sensorKeyColumn = "";

		
      for (int i = 0; i < sensors.size(); i++) {

         String sensorKey = (String) sensors.get(i).get("sensor_key");

         String name = (String) sensors.get(i).get("name");

         if (i == sensors.size() - 1) {

            sensorKeyColumn += "AVG(json -> '$." + sensorKey + "[0]') " + sensorKey;

         } else {

            sensorKeyColumn += "AVG(json -> '$." + sensorKey + "[0]') " + sensorKey + ",";

         }

         sensorKeyColumn += "AVG(json -> '$." + sensorKey + "[0]') " + sensorKey;

         if (i != sensors.size() - 1) {

            sensorKeyColumn += " ,";

         } 
         sensorKeys.add(sensorKey + "-" + name);

      }

      return sensorKeyColumn;

   }



   @Override

   public Map<String, Object> getMonthAverageBySensor(Map<String, Object> parameters) {

      ValidateUtil.notNull(parameters.get("mac"), "param.is.null");

      ValidateUtil.notNull(parameters.get("macKey"), "param.is.null");

      Map<String, Object> result = new HashMap<String, Object>();

      LocalDate end = LocalDate.now(),start;

      // 每月一日的数据取上月的数据

      if (1 == end.getDayOfMonth()) {

         // 上个月1日00:00:00

         start = end.plusDays(-1).with(TemporalAdjusters.firstDayOfMonth());

      } else {

         // 这个月1日00:00:00

         start = end.with(TemporalAdjusters.firstDayOfMonth());

      }

      parameters.put("start", start);

      parameters.put("end", end);

      String sensorKey = (String) parameters.get("macKey");

      String sensorKeyColumn = "AVG(json -> '$." + sensorKey + "[0]') " + sensorKey;

      parameters.put("sensorKeyColumn", sensorKeyColumn);



      Map<String, Double> average = historyMinutelyMapper.getSersionAvgByDevice(parameters);

      if (isEmpty(average)) {

         result.put("average", NULL_VALUE);

      } else {

         result.put("average", String.format("%.2f", average.get(sensorKey)));

      }

      return result;

   }



}