|
@@ -175,7 +175,7 @@ public class MqttSubHandle {
|
|
|
msg.put("clientId", clientId);
|
|
|
msg.put("event", event);
|
|
|
msg.put("msgType", "event");
|
|
|
- msg.put("eventListId", eventListVO.getEventListId());
|
|
|
+ msg.put("eventListId", String.valueOf(eventListVO.getEventListId()));
|
|
|
// 发送socket
|
|
|
mqttClient.sendMessage(String.format("/mps/%s/event", clientId), msg.toString());
|
|
|
|
|
@@ -213,7 +213,7 @@ public class MqttSubHandle {
|
|
|
wxMsg.put("event", "fall_confirmed");
|
|
|
wxMsg.put("msgType", "fall");
|
|
|
wxMsg.put("devName", devName.toString());
|
|
|
- wxMsg.put("eventListId", eventListVO.getEventListId());
|
|
|
+ wxMsg.put("eventListId", String.valueOf(eventListVO.getEventListId()));
|
|
|
|
|
|
log.info("发送微信跌倒主题消息:topic:{}, msg:{}", String.format(TopicConstants.TOPIC_MPS_NOTIC, RedisCacheConstant.WX_USER_PRE + userInfo.getUserId()), wxMsg.toString());
|
|
|
mqttClient.sendMessage(String.format(TopicConstants.TOPIC_MPS_NOTIC, RedisCacheConstant.WX_USER_PRE + userInfo.getUserId()), wxMsg.toString(), 2, false);
|
|
@@ -282,7 +282,7 @@ public class MqttSubHandle {
|
|
|
webMsg.put("msgType", "fall");
|
|
|
webMsg.put("devName", devName.toString());
|
|
|
webMsg.put("tenantName", tenantName);
|
|
|
- webMsg.put("eventListId", eventListVO.getEventListId());
|
|
|
+ webMsg.put("eventListId", String.valueOf(eventListVO.getEventListId()));
|
|
|
|
|
|
// 查询当前需要发送的userId
|
|
|
List<AdminUserInfo> adminUserInfos = adminUserService.queryByTenantIdAndUserType(dev.getTenantId(), null);
|