From 33e323fb0e6959bf838867fc5582fbcd4749abb1 Mon Sep 17 00:00:00 2001
From: xufenglei <xufenglei>
Date: Fri, 15 Jun 2018 08:53:26 +0800
Subject: [PATCH] 数据排名接口
---
src/main/java/com/moral/service/impl/HistoryServiceImpl.java | 80 ++++++++++++++++++++++++++++++++++++++++
1 files changed, 80 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/moral/service/impl/HistoryServiceImpl.java b/src/main/java/com/moral/service/impl/HistoryServiceImpl.java
index 4a9748f..9eabd4d 100644
--- a/src/main/java/com/moral/service/impl/HistoryServiceImpl.java
+++ b/src/main/java/com/moral/service/impl/HistoryServiceImpl.java
@@ -8,9 +8,11 @@
import org.springframework.stereotype.Service;
import com.moral.common.util.ValidateUtil;
+import com.moral.entity.Profession;
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;
@@ -29,6 +31,9 @@
@Resource
private SensorMapper sensorMapper;
+
+ @Resource
+ private ProfessionMapper professionMapper;
@Override
public Map<String, Object> getAllSensorAverageByDevice(Map<String, Object> parameters) throws Exception {
@@ -79,4 +84,79 @@
public String queryValueByMacAndTime(String mac, Date time){
return historyMapper.selectValueByMacAndTime(mac, time);
}
+
+ @Override
+ public List<Map<String, Object>> getRegionRankingData(Map<String, Object> parameters) {
+ ValidateUtil.notNull(parameters.get("regionCode"), "param.is.null");
+ ValidateUtil.notNull(parameters.get("dimension"), "param.is.null");
+ ValidateUtil.notNull(parameters.get("sensorKey"), "param.is.null");
+ ValidateUtil.notNull(parameters.get("accountId"), "param.is.null");
+
+ String regionCode = parameters.get("regionCode").toString();
+ String regionType = "village_code";
+ String nextLevel = "";
+ if (regionCode.length() == 6) {
+ if (regionCode.endsWith("0000")) {
+ regionType = "province_code";
+ nextLevel = "city";
+ } else if (regionCode.endsWith("00")) {
+ regionType = "city_code";
+ nextLevel = "area";
+ } else {
+ regionType = "area_code";
+ nextLevel = "town";
+ }
+ } else {
+ if (regionCode.endsWith("000")) {
+ regionType = "town_code";
+ nextLevel = "village";
+ }
+ }
+ parameters.put("regionType", regionType);
+ parameters.put("nextLevel", nextLevel);
+ parameters.put("start", LocalDateTime.now().minusMinutes(5));
+
+ accountService.setOrgIdsByAccount(parameters);
+ List<Map<String, Object>> result = historyMapper.getRegionRankingData(parameters);
+ if ("profession".equals(parameters.get("dimension"))) {
+ List<Profession> professions = professionMapper.selectAll();
+ for (Map<String, Object> map : result) {
+ for (Profession profession : professions) {
+ if (map.get("name").equals(profession.getName())) {
+ professions.remove(profession);
+ break;
+ }
+ }
+ }
+ for (Profession profession : professions) {
+ Map<String, Object> map = new HashMap<String, Object>();
+ map.put("name", profession.getName());
+ map.put("avg", 0);
+ result.add(map);
+ }
+ } else if ("region".equals(parameters.get("dimension"))) {
+ List<Map<String, Object>> regions = historyMapper.selectNextLevelRegion(parameters);
+ for (int i = result.size() - 1; i >= 0; i--) {
+ Map<String, Object> map = result.get(i);
+ for (Map<String, Object> region : regions) {
+ if ((map.get("code") == null)) {
+ result.remove(map);
+ break;
+ }
+ if (map.get("code").equals(region.get("code"))) {
+ map.put("name", region.get("name"));
+ regions.remove(region);
+ break;
+ }
+ }
+ }
+ for (Map<String, Object> region : regions) {
+ Map<String, Object> map = new HashMap<String, Object>();
+ map.put("name", region.get("name"));
+ map.put("avg", 0);
+ result.add(map);
+ }
+ }
+ return result;
+ }
}
--
Gitblit v1.8.0