推流接口

dk-modules/sample/src/main/java/org/dromara/sample/manage/controller/MegaphoneController.java

@@ -268,6 +268,7 @@ public class MegaphoneController {
                                           @RequestBody Map<String,Object>objectMap
     ) {
         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<String,Object> 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<String,Object> 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 {