From 5d7223be751e88dd5cfc95f728462bbd3d1af42c Mon Sep 17 00:00:00 2001 From: like <1025687351@qq.com> Date: Tue, 20 May 2025 16:51:51 +0800 Subject: [PATCH] =?UTF-8?q?=E6=8E=A8=E6=B5=81=E6=8E=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../manage/controller/MegaphoneController.java | 14 ++++++++++++++ 1 file changed, 14 insertions(+) diff --git a/dk-modules/sample/src/main/java/org/dromara/sample/manage/controller/MegaphoneController.java b/dk-modules/sample/src/main/java/org/dromara/sample/manage/controller/MegaphoneController.java index 5ae2901..2a8c9a6 100644 --- a/dk-modules/sample/src/main/java/org/dromara/sample/manage/controller/MegaphoneController.java +++ b/dk-modules/sample/src/main/java/org/dromara/sample/manage/controller/MegaphoneController.java @@ -268,6 +268,7 @@ public class MegaphoneController { @RequestBody MapobjectMap ) { String top = "task/image/disobey/smoke"; + String topTow = "task/image/disobey/streamType"; //发送mqtt String s = remoteConfigService.selectStreamIp(); DisobeyDTO param = Convert.convert(DisobeyDTO.class, objectMap); @@ -298,6 +299,13 @@ public class MegaphoneController { disobeyDTO.setRtmpUrl(param.getRtmpUrl()); gatewayPublish.publish(top,new CommonTopicRequest<>() .setData(Objects.requireNonNull(disobeyDTO)),1); + + Map map = new HashMap<>(); + map.put("labelEn",type); + map.put("deviceSn",objectMap.get("deviceSn")); + StreamTypeDTO param1 = Convert.convert(StreamTypeDTO.class, map); + gatewayPublish.publish(top,new CommonTopicRequest<>() + .setData(Objects.requireNonNull(param1)),1); } } }else if (CollectionUtils.isNotEmpty(types) && split.length < types.size()){ @@ -336,6 +344,12 @@ public class MegaphoneController { gatewayPublish.publish(top,new CommonTopicRequest<>() .setData(Objects.requireNonNull(disobeyDTO)),1); + Map map = new HashMap<>(); + map.put("labelEn",type); + map.put("deviceSn",objectMap.get("deviceSn")); + StreamTypeDTO param1 = Convert.convert(StreamTypeDTO.class, map); + gatewayPublish.publish(top,new CommonTopicRequest<>() + .setData(Objects.requireNonNull(param1)),1); } } }else {