| | |
|---|
| | | import java.util.HashMap; |
|---|
| | | import java.util.List; |
|---|
| | | import java.util.Map; |
|---|
| | | import java.util.Optional; |
|---|
| | | |
|---|
| | | import com.alibaba.fastjson.JSON; |
|---|
| | | import com.googlecode.aviator.AviatorEvaluator; |
|---|
| | |
|---|
| | | /** |
|---|
| | | * @param deviceData 设备数据 |
|---|
| | | * @param adjustFormula 校准公式 |
|---|
| | | * @param aqiMap 设备所在地区对应的墨迹aqi数据 |
|---|
| | | * @param aqiMap 与设备绑定的国控站点aqi数据 |
|---|
| | | * @return Map<String, Object> 校准后数据 |
|---|
| | | */ |
|---|
| | | public Map<String, Object> adjust(Map<String, Object> deviceData, Map<String, Object> adjustFormula, Map<String, Object> aqiMap) { |
|---|
| | |
|---|
| | | deviceData.put(key, measuredValue); |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | |
|---|
| | | //根据时间段筛选校准公式 |
|---|
| | | DeviceAdjustValue deviceAdjustValue = sensorFormulas.stream() |
|---|
| | | DeviceAdjustValue deviceAdjustValue = new DeviceAdjustValue(); |
|---|
| | | Optional<DeviceAdjustValue> optional = sensorFormulas.stream() |
|---|
| | | .filter(o -> o.getStartTime().getTime() <= finalTime && o.getEndTime().getTime() > finalTime) |
|---|
| | | .findFirst().get(); |
|---|
| | | .findFirst(); |
|---|
| | | if (optional.isPresent()) { |
|---|
| | | deviceAdjustValue = optional.get(); |
|---|
| | | } |
|---|
| | | String formula = deviceAdjustValue.getValue(); |
|---|
| | | if (StringUtils.isEmpty(formula)) { |
|---|
| | | deviceData.put(key, measuredValue); |
|---|
