|
|
@@ -9,7 +9,7 @@ import org.springblade.core.tool.utils.StringUtil;
|
|
|
import org.springblade.device.entity.VideoCloudDevice;
|
|
|
import org.springblade.device.feign.IVideoCloudDeviceClient;
|
|
|
import org.springblade.third.service.IThirdVideoCloudDeviceService;
|
|
|
-import org.springblade.websocket.model.ChatMessage;
|
|
|
+//import org.springblade.websocket.model.ChatMessage;
|
|
|
import org.springframework.messaging.simp.SimpMessageSendingOperations;
|
|
|
import org.springframework.web.bind.annotation.PostMapping;
|
|
|
import org.springframework.web.bind.annotation.RequestBody;
|
|
|
@@ -40,21 +40,22 @@ public class MediaServerWebHookController {
|
|
|
*/
|
|
|
@PostMapping(value = "/on_stream_changed")
|
|
|
public Map<String, Object> onStreamChanged(@RequestBody Map<String, Object> params){
|
|
|
- logger.info("【MediaServer】on_stream_changed", JSONUtil.toJsonStr(params));
|
|
|
- Boolean regist = (Boolean)params.get("regist");
|
|
|
- String stream = (String)params.get("stream");
|
|
|
- VideoCloudDevice videoCloudDevice = videoCloudDeviceClient.getByDeviceNum(stream);
|
|
|
- if(videoCloudDevice != null){
|
|
|
- ChatMessage chatMessage = new ChatMessage();
|
|
|
- chatMessage.setType(ChatMessage.MessageType.CHAT);
|
|
|
- chatMessage.setSender(stream);
|
|
|
- String routerKey = "/topic/" + chatMessage.getSender();
|
|
|
- messagingTemplate.convertAndSend(routerKey, chatMessage);
|
|
|
- }
|
|
|
- Map<String, Object> returnMap = new HashMap<>();
|
|
|
- returnMap.put("code", 0);
|
|
|
- returnMap.put("msg", "success");
|
|
|
- return returnMap;
|
|
|
+// logger.info("【MediaServer】on_stream_changed", JSONUtil.toJsonStr(params));
|
|
|
+// Boolean regist = (Boolean)params.get("regist");
|
|
|
+// String stream = (String)params.get("stream");
|
|
|
+// VideoCloudDevice videoCloudDevice = videoCloudDeviceClient.getByDeviceNum(stream);
|
|
|
+// if(videoCloudDevice != null){
|
|
|
+// ChatMessage chatMessage = new ChatMessage();
|
|
|
+// chatMessage.setType(ChatMessage.MessageType.CHAT);
|
|
|
+// chatMessage.setSender(stream);
|
|
|
+// String routerKey = "/topic/" + chatMessage.getSender();
|
|
|
+// messagingTemplate.convertAndSend(routerKey, chatMessage);
|
|
|
+// }
|
|
|
+// Map<String, Object> returnMap = new HashMap<>();
|
|
|
+// returnMap.put("code", 0);
|
|
|
+// returnMap.put("msg", "success");
|
|
|
+// return returnMap;
|
|
|
+ return null;
|
|
|
}
|
|
|
|
|
|
// /**
|