| | |
| | |
|
| | | 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;
|
| | |
| | | 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;
|
| | |
| | | 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;
|
| | | }
|
| | |
| | | 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;
|
| | | |
| | | }
|
| | | }
|