|
@@ -1,5 +1,6 @@
|
|
|
package com.ruoyi.mqtt.service;
|
|
|
|
|
|
+import com.alibaba.fastjson2.JSONObject;
|
|
|
import com.ruoyi.common.model.MqttMessage;
|
|
|
import com.ruoyi.common.utils.StringUtils;
|
|
|
import com.ruoyi.manage.domain.ChannelNumberVo;
|
|
@@ -70,7 +71,8 @@ public class MqttMessageListener {
|
|
|
//返回值为photoAddress_channelId
|
|
|
String payload = message.getPayload();
|
|
|
if (StringUtils.isNotEmpty(payload)) {
|
|
|
- String[] messageResult = payload.split("_");
|
|
|
+ JSONObject jsonObject = JSONObject.parseObject(payload);
|
|
|
+ String[] messageResult = jsonObject.get("rtsp").toString().split("#");
|
|
|
//插入通道画框图片
|
|
|
ChannelNumberVo channelNumber = new ChannelNumberVo();
|
|
|
channelNumber.setChannelId(Long.valueOf(messageResult[0]));
|