|
@@ -187,16 +187,15 @@ public class MqttSubHandle {
|
|
|
log.info("mqttutil--当前useropenid=" + user.getOpenid() + ", fwhopenId=" + fwhOpenId);
|
|
log.info("mqttutil--当前useropenid=" + user.getOpenid() + ", fwhopenId=" + fwhOpenId);
|
|
|
log.info("发送微信公众号信息:devName=" + devName.toString() + ", phoneNo=" + user.getPhone() + "fwhOpenId=" + fwhOpenId);
|
|
log.info("发送微信公众号信息:devName=" + devName.toString() + ", phoneNo=" + user.getPhone() + "fwhOpenId=" + fwhOpenId);
|
|
|
// 发送微信公告号消息
|
|
// 发送微信公告号消息
|
|
|
- if (StringUtils.contains(devName.toString(), "卫生间")) {
|
|
|
|
|
- wxOfficeAccountClient.sendMsg(devId, devName.toString(), user.getPhone(), fwhOpenId, "设备检测到异常滞留,请前往小程序查看详细信息");
|
|
|
|
|
- log.info("发送微信公众号消息发完了");
|
|
|
|
|
|
|
+ wxOfficeAccountClient.sendMsg(devId, devName.toString(), user.getPhone(), fwhOpenId, "设备检测到跌倒,请前往小程序查看详细信息");
|
|
|
|
|
+ log.info("发送微信公众号消息发完了");
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- }
|
|
|
|
|
|
|
+
|
|
|
|
|
|
|
|
@MqttSubscribe(topic = "/das/alarm_event", qos = 2)
|
|
@MqttSubscribe(topic = "/das/alarm_event", qos = 2)
|
|
|
public void subDasAlarmEvent(String payload) {
|
|
public void subDasAlarmEvent(String payload) {
|