天气预报

lizijie

2019-07-10 e97c393e23f4c015a44b5fef5fd26ae288bc6c0f

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

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



import java.time.Instant;

import java.time.LocalDate;

import java.time.LocalDateTime;

import java.time.ZoneId;

import java.time.ZoneOffset;

import java.time.temporal.ChronoUnit;

import java.time.temporal.TemporalAdjusters;

import java.util.ArrayList;

import java.util.Arrays;

import java.util.Collections;

import java.util.Comparator;

import java.util.Date;

@@ -26,10 +30,10 @@
import com.moral.entity.Sensor;

import com.moral.mapper.DeviceMapper;

import com.moral.mapper.HistoryMapper;

import com.moral.mapper.ProfessionMapper;

import com.moral.mapper.SensorMapper;

import com.moral.service.AccountService;

import com.moral.service.HistoryService;

import com.moral.service.ProfessionService;



@Service

public class HistoryServiceImpl implements HistoryService {

@@ -47,7 +51,7 @@
   private SensorMapper sensorMapper;



    @Resource

    private ProfessionMapper professionMapper;

    private ProfessionService professionService;



   @Override

   public Map<String, Object> getAllSensorAverageByDevice(Map<String, Object> parameters) throws Exception {

@@ -107,6 +111,7 @@
      ValidateUtil.notNull(parameters.get("accountId"), "param.is.null");



      String regionCode = parameters.get("regionCode").toString();

      parameters.put("provinceCode", regionCode.substring(0,2).concat("0000"));

      String regionType = "village";

      String nextLevel = "";

      if (regionCode.length() == 6) {

@@ -135,7 +140,7 @@
      String column = "value";

      if ("month".equals(timeType)) {

         if (1 != localDate.getDayOfMonth()) {

            table = "history_minutely";

            table = "history_daily";

            column = "json";

         }

         parameters.put("start", localDate.with(TemporalAdjusters.firstDayOfMonth()));

@@ -158,16 +163,20 @@
      accountService.setOrgIdsByAccount(parameters);

      

      List<Map<String, Object>> result = historyMapper.getRegionRankingData(parameters);

		
      for (Map<String, Object> map : result) {

         if (ObjectUtils.isEmpty(map.get("avg"))) {

            map.put("avg", 0);

         }

      }

      if ("profession".equals(parameters.get("dimension"))) {

         List<Profession> professions = professionMapper.selectAll();

         List<Profession> professions = professionService.getProfessiontList(parameters);

         for (Map<String, Object> map : result) {

            for (Profession profession : professions) {

               if (map.get("name").equals(profession.getName())) {

                  professions.remove(profession);

                  if (ObjectUtils.isEmpty(map.get("avg"))) {

                     map.put("avg", 0);

                  }

//                  if (ObjectUtils.isEmpty(map.get("avg"))) {

//                     map.put("avg", 0);

//                  }

                  break;

               }

            }

@@ -183,9 +192,9 @@
         for (Map<String, Object> map : result) {

            if (regions.contains(map.get("name"))) {

               regions.remove(map.get("name"));

               if (ObjectUtils.isEmpty(map.get("avg"))) {

                  map.put("avg", 0);

               }

//               if (ObjectUtils.isEmpty(map.get("avg"))) {

//                  map.put("avg", 0);

//               }

            }

            

         }

@@ -256,4 +265,34 @@
      return values;

   }



   @Override

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

      Object sensorKey = parameters.get("sensorKey");

      ValidateUtil.notNull(sensorKey, "param.is.null");

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

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

      Integer interval = Integer.valueOf(parameters.get("interval").toString());

      LocalDateTime start, end;

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

         end = LocalDateTime.now();

         int second = end.getSecond() / interval * interval;

         end = end.truncatedTo(ChronoUnit.MINUTES).plusSeconds(second);

         start = end.minusSeconds(interval);

      } else {

         //start = LocalDateTime.ofEpochSecond(Long.valueOf(parameters.get("time").toString()) / 1000, 0, ZoneOffset.ofHours(8));

         start = LocalDateTime.ofInstant(Instant.ofEpochMilli(Long.valueOf(parameters.get("time").toString())),ZoneId.of("+8"));

         end = start.plusSeconds(interval);

      }

      parameters.put("start", start);

      parameters.put("end", end);

      parameters.put("sensorKeys", Arrays.asList(((String) sensorKey).split(",")));

      accountService.setOrgIdsByAccount(parameters);

      Map<String, Object> result = historyMapper.getActualDataByRegion(parameters);

      if (ObjectUtils.isEmpty(result)) {

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

      }

      result.put("time", end.toInstant(ZoneOffset.of("+8")).toEpochMilli());

      return result;

   }



}