From e8ef361dc975aeaedeee6f28dfe679489a22f9d5 Mon Sep 17 00:00:00 2001 From: ZhuDongming <773644075@qq.com> Date: Mon, 02 Sep 2019 17:42:06 +0800 Subject: [PATCH] Merge branch 'master' of http://blit.7drlb.com:8888/r/screen_api_v2 --- src/main/java/com/moral/service/impl/HistoryMinutelyServiceImpl.java | 71 +++++++++++++++++++---------------- 1 files changed, 38 insertions(+), 33 deletions(-) diff --git a/src/main/java/com/moral/service/impl/HistoryMinutelyServiceImpl.java b/src/main/java/com/moral/service/impl/HistoryMinutelyServiceImpl.java index 6b5800d..ba6fc1a 100644 --- a/src/main/java/com/moral/service/impl/HistoryMinutelyServiceImpl.java +++ b/src/main/java/com/moral/service/impl/HistoryMinutelyServiceImpl.java @@ -3,8 +3,6 @@ import static com.moral.common.bean.Constants.NULL_VALUE; import static org.springframework.util.ObjectUtils.isEmpty; -import java.io.FileNotFoundException; -import java.io.IOException; import java.math.BigDecimal; import java.text.ParseException; import java.text.SimpleDateFormat; @@ -46,7 +44,6 @@ import com.moral.common.util.ParameterUtils; import com.moral.common.util.ReportTimeFormat; import com.moral.common.util.ResourceUtil; -import com.moral.common.util.StringUtils; import com.moral.common.util.ValidateUtil; import com.moral.entity.Sensor; import com.moral.entity.charts.DataCondition; @@ -58,9 +55,6 @@ import com.moral.mapper.HistoryMinutelyMapper; import com.moral.mapper.SensorMapper; import com.moral.service.HistoryMinutelyService; -import com.moral.service.SensorService; - -import lombok.val; @Service @SuppressWarnings({"unchecked", "unused", "rawtypes"}) @@ -544,46 +538,57 @@ * @return */ @Override - public List<Map<String, Object>> getSensorData(Map<String, Object> parameters) { - String startTime=parameters.get("startTime").toString(); - Boolean flag=null; - try { - flag = DateUtils.isSameDay(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").parse(startTime), new Date()); - }catch (ParseException e) { - e.printStackTrace(); - } - List<Sensor> sensors=sensorMapper.getSensorsByMac(parameters); - List<String> sensorKeys=new ArrayList<>(); - for(Sensor sensor:sensors){ + public List<List<Map<String, Object>>> getSensorData(Map<String, Object> parameters) { + String startTime = parameters.get("startTime").toString(); + DateTimeFormatter dateTimeFormatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"); + LocalDateTime startTimeLocalDateTime = LocalDateTime.parse(startTime, dateTimeFormatter); + LocalDate today = LocalDate.now(); + LocalDate startTimeLocalDate=startTimeLocalDateTime.toLocalDate(); + Boolean flag=today.isEqual(startTimeLocalDate); + List<Sensor> sensors = sensorMapper.getSensorsByMac(parameters); + List<String> sensorKeys = new ArrayList<>(); + for (Sensor sensor : sensors) { sensorKeys.add(sensor.getSensorKey()); } parameters.put("sensorKeys", sensorKeys); - List<Map<String, Object>> listMap=null; - if(flag){ + List<Map<String, Object>> listMap = null; + if (flag) { listMap = historyMapper.getSensorDataToday(parameters); - }else{ + } else { listMap = historyMinutelyMapper.getSensorData(parameters); } - List<Map<String, Object>> listMapNew = new ArrayList<>(); - Map<String, Object> new_map = new LinkedHashMap<>(); + List<List<Map<String, Object>>> listMaps = new ArrayList<>(); + List<Map<String, Object>> listMapAvg = new ArrayList<>(); + List<Map<String, Object>> listMapMin = new ArrayList<>(); + List<Map<String, Object>> listMapMax = new ArrayList<>(); if (CollectionUtils.isNotEmpty(listMap)) { for (Map<String, Object> map : listMap) { - new_map.put("������", map.get("time")); - for (String key : map.keySet()) { + Map<String, Object> mapAvg = new LinkedHashMap<>(); + Map<String, Object> mapMin = new LinkedHashMap<>(); + Map<String, Object> mapMax = new LinkedHashMap<>(); + mapAvg.put("time", map.get("time")); + mapMin.put("time", map.get("time")); + mapMax.put("time", map.get("time")); + for (Entry<String,Object> entry : map.entrySet()) { for (Sensor sensor : sensors) { - if (sensor.getSensorKey().equals(key)) { - if("e79".equals(key)||"e80".equals(key)||"e81".equals(key)){ - new_map.put(sensor.getDescription(), StringUtils.scientificCountingConversion(map.get(key).toString())+sensor.getUnit()); - }else{ - new_map.put(sensor.getDescription(), map.get(key)+sensor.getUnit()); - } + if (sensor.getSensorKey().equals(entry.getKey())) { + mapAvg.put(entry.getKey(), new BigDecimal(entry.getValue().toString()).stripTrailingZeros().toPlainString() + sensor.getUnit()); + } else if (("min" + sensor.getSensorKey()).equals(entry.getKey())) { + mapMin.put(entry.getKey().substring(3), new BigDecimal(entry.getValue().toString().replace("\"", "")).stripTrailingZeros().toPlainString()); + } else if (("max" + sensor.getSensorKey()).equals(entry.getKey())) { + mapMax.put(entry.getKey().substring(3), new BigDecimal(entry.getValue().toString().replace("\"", "")).stripTrailingZeros().toPlainString()); } } } - listMapNew.add(new_map); - new_map = new LinkedHashMap<>(); + listMapAvg.add(mapAvg); + listMapMin.add(mapMin); + listMapMax.add(mapMax); } + listMaps.add(listMapAvg); + listMaps.add(listMapMin); + listMaps.add(listMapMax); } - return listMapNew; + return listMaps; } + } -- Gitblit v1.8.0