|
|
@@ -152,6 +152,7 @@ public class MqttCallbackHandler extends AbstractHandler {
|
|
|
if ("2".equals(map.get("flag"))) {
|
|
|
Long level = Long.valueOf(map.get("level"));
|
|
|
Long thresholdId = Long.valueOf(map.get("thresholdId"));
|
|
|
+ String offset = map.get("offset");
|
|
|
//阈值表以及明细表存储
|
|
|
String url = dictByDictCode.get(itemName) == null ? null : dictByDictCode.get(itemName).getUrl();
|
|
|
String itemValueAndUnit = StringUtils.isBlank(url) ? itemValue : (itemValue + url);
|
|
|
@@ -184,7 +185,8 @@ public class MqttCallbackHandler extends AbstractHandler {
|
|
|
templateParam.put("time", time);
|
|
|
templateParam.put("level", level.toString());
|
|
|
templateParam.put("name", device.getName());
|
|
|
- templateParam.put("value", itemValue);
|
|
|
+// templateParam.put("value", itemValue);
|
|
|
+ templateParam.put("value", offset);
|
|
|
commonService.pushSmsMessage(pushToPhone
|
|
|
, smsTemplateConfig.getDataAlarm().getSmsCode()
|
|
|
, smsTemplateConfig.getDataAlarm().getSignName()
|
|
|
@@ -213,7 +215,8 @@ public class MqttCallbackHandler extends AbstractHandler {
|
|
|
templateParam.put("name", device.getName());
|
|
|
templateParam.put("time", time);
|
|
|
templateParam.put("project", vo == null ? null : vo.getProjectName());
|
|
|
- templateParam.put("value", itemValue);
|
|
|
+// templateParam.put("value", itemValue);
|
|
|
+ templateParam.put("value", offset);
|
|
|
commonService.pushEmailMessage(emailAddress
|
|
|
, templateParam);
|
|
|
}
|
|
|
@@ -313,7 +316,8 @@ public class MqttCallbackHandler extends AbstractHandler {
|
|
|
templateParam.put("time", time);
|
|
|
templateParam.put("level", level.toString());
|
|
|
templateParam.put("name", device.getName());
|
|
|
- templateParam.put("value", itemValueAndUnit);
|
|
|
+// templateParam.put("value", itemValueAndUnit);
|
|
|
+ templateParam.put("value", String.valueOf(offset));
|
|
|
commonService.pushSmsMessage(pushToPhone
|
|
|
, smsTemplateConfig.getDataAlarm().getSmsCode()
|
|
|
, smsTemplateConfig.getDataAlarm().getSignName()
|
|
|
@@ -342,7 +346,8 @@ public class MqttCallbackHandler extends AbstractHandler {
|
|
|
templateParam.put("name", device.getName());
|
|
|
templateParam.put("time", time);
|
|
|
templateParam.put("project", vo == null ? null : vo.getProjectName());
|
|
|
- templateParam.put("value", itemValueAndUnit);
|
|
|
+// templateParam.put("value", itemValueAndUnit);
|
|
|
+ templateParam.put("value", String.valueOf(offset));
|
|
|
commonService.pushEmailMessage(emailAddress
|
|
|
, templateParam);
|
|
|
}
|
|
|
@@ -443,8 +448,10 @@ public class MqttCallbackHandler extends AbstractHandler {
|
|
|
if (checkItemName.contains(itemName)) {
|
|
|
BigDecimal offset = commonService.computeOffset(itemValue, itemName, deviceRelation);
|
|
|
map = newAlarmCompute(offset, kwsThresholds);
|
|
|
+ map.put("offset",String.valueOf(offset));
|
|
|
} else {
|
|
|
map = newAlarmCompute(new BigDecimal(itemValue), kwsThresholds);
|
|
|
+ map.put("offset",itemValue);
|
|
|
}
|
|
|
// map = oldAlarmCompute(checkItemName, itemName, itemValue, deviceRelation, kwsThresholds);
|
|
|
return map;
|