From d70f7cf3cf5afbfa3d9ca396068d9ff4bfe4046f Mon Sep 17 00:00:00 2001
From: xufenglei <xufenglei>
Date: Mon, 22 Jul 2019 15:21:06 +0800
Subject: [PATCH] app更新

---
 src/main/java/com/moral/service/impl/HistoryServiceImpl.java |   52 ++++++++++++++++++++++++++++++++++++++++++++++++----
 1 files changed, 48 insertions(+), 4 deletions(-)

diff --git a/src/main/java/com/moral/service/impl/HistoryServiceImpl.java b/src/main/java/com/moral/service/impl/HistoryServiceImpl.java
index 72410be..f8c8a05 100644
--- a/src/main/java/com/moral/service/impl/HistoryServiceImpl.java
+++ b/src/main/java/com/moral/service/impl/HistoryServiceImpl.java
@@ -24,6 +24,8 @@
 
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
+import com.googlecode.aviator.AviatorEvaluator;
+import com.googlecode.aviator.Expression;
 import com.moral.common.util.ValidateUtil;
 import com.moral.entity.Device;
 import com.moral.entity.Profession;
@@ -31,6 +33,7 @@
 import com.moral.mapper.DeviceMapper;
 import com.moral.mapper.HistoryMapper;
 import com.moral.mapper.SensorMapper;
+import com.moral.mapper.SensorUnitMapper;
 import com.moral.service.AccountService;
 import com.moral.service.HistoryService;
 import com.moral.service.ProfessionService;
@@ -241,26 +244,55 @@
     		map = JSON.parseObject(values.get(0).get("value").toString());
 		}
     	Device device = deviceMapper.selectByPrimaryKey(Integer.valueOf((String) parameters.get("deviceId")));
+    	Map<String, Object> sensorUnits = getSensorUnitByDeviceMac(parameters);
     	for (Map<String, Object> sensor : sensors) {
+    		Object sensorKey = sensor.get("sensor_key");
+    		sensor.put("name", sensor.get("description"));
+    		sensor.put("state", device.getState());
     		if (!ObjectUtils.isEmpty(map)) {
     			sensor.put("value", map.remove(sensor.get("sensor_key")));
 			}
-    		sensor.put("state", device.getState());
-    		sensor.put("name", sensor.get("description"));
+    		if (sensorUnits.containsKey(sensorKey)) {
+    			Map<String, Object> sensorUnit  = (Map<String, Object>) sensorUnits.get(sensorKey);
+    			sensor.put("unit", sensorUnit.get("name"));
+    			if (sensor.containsKey("value")) {
+    				Object value = sensor.get("value");
+    				String rules = sensorUnit.get("rules").toString();
+    				rules = rules.replace("d", "").replace("{0}", "value");
+    				Expression expression = AviatorEvaluator.compile(rules);
+    				Map<String, Object> env = new HashMap<String, Object>();
+    				env.put("value", Double.valueOf(value.toString()));
+    				value = expression.execute(env);
+    				sensor.put("value",String.format("%.2f", value));
+				}
+			}
     	}
 		return sensors;
 	}
 
 	@Override
 	public List<Map<String, Object>> getSensorDataBySensorKey(Map<String, Object> parameters) {
-		ValidateUtil.notNull(parameters.get("sensorKey"), "param.is.null");
+		Object sensorKey = parameters.get("sensorKey");
+		ValidateUtil.notNull(sensorKey, "param.is.null");
 		ValidateUtil.notNull(parameters.get("mac"), "param.is.null");
 		ValidateUtil.notNull(parameters.get("size"), "param.is.null");
 		parameters.put("size", Integer.valueOf(parameters.remove("size").toString()));
 		List<Map<String, Object>> values = historyMapper.getValueByMacAndSize(parameters);
+		Map<String, Object> sensorUnits = getSensorUnitByDeviceMac(parameters);
 		for (Map<String, Object> value : values) {
 			JSONObject json = JSON.parseObject(value.remove("value").toString());
-			value.put("value", json.get(parameters.get("sensorKey")));
+			Object sensorKeyValue = json.get(sensorKey);
+			if (sensorUnits.containsKey(sensorKey)) {
+				Map<String, Object> sensorUnit  = (Map<String, Object>) sensorUnits.get(sensorKey);
+				String rules = sensorUnit.get("rules").toString();
+				rules = rules.replace("d", "").replace("{0}", "sensorKeyValue");
+				Expression expression = AviatorEvaluator.compile(rules);
+				Map<String, Object> env = new HashMap<String, Object>();
+				env.put("value", Double.valueOf(sensorKeyValue.toString()));
+				sensorKeyValue = expression.execute(env);
+				sensorKeyValue = String.format("%.2f", sensorKeyValue);
+			}
+			value.put("value", sensorKeyValue);
 		}
 		return values;
 	}
@@ -295,4 +327,16 @@
 		return result;
 	}
 
+	@Resource
+	private SensorUnitMapper sensorUnitMapper;
+	@Override
+	public Map<String, Object> getSensorUnitByDeviceMac(Map<String, Object> parameters){
+		Map<String, Object> resultMap = new HashMap<String, Object>();
+		List<Map<String, Object>> list = sensorUnitMapper.getSensorUnitByDeviceMac(parameters);
+		for (Map<String, Object> map : list) {
+			resultMap.put(map.remove("sensor_key").toString(), map);
+		}
+		return resultMap;
+		
+	}
 }

--
Gitblit v1.8.0