推流接口

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

@@ -267,55 +267,47 @@ public class MegaphoneController {
         //发送mqtt
         String s = remoteConfigService.selectStreamIp();
         DisobeyDTO param = Convert.convert(DisobeyDTO.class, objectMap);
-
         if (param.getOpen() == 1){
+            deviceStreamMapper.delete(new QueryWrapper<DeviceStreamEntity>().eq("rtmp_url", param.getRtmpUrl()));
             if (StringUtils.isNotEmpty(param.getModel())){
                 String[] split = param.getModel().split(",");
                 for (String type : split){
-                    List<DeviceStreamEntity> deviceStreamEntities = deviceStreamMapper.selectList(new QueryWrapper<DeviceStreamEntity>().eq("rtmp_url", param.getRtmpUrl())
+                    DeviceStreamEntity deviceStreamEntity = new DeviceStreamEntity();
-                        .eq("stream_type", type));
+                    deviceStreamEntity.setStreamType(type);
-                    if (CollectionUtils.isEmpty(deviceStreamEntities)){
+                    deviceStreamEntity.setCreateTime(new Date());
-                        DeviceStreamEntity deviceStreamEntity = new DeviceStreamEntity();
+                    deviceStreamEntity.setUpdateTime(new Date());
-                        deviceStreamEntity.setStreamType(type);
+                    deviceStreamEntity.setRtmpUrl(param.getRtmpUrl());
-                        deviceStreamEntity.setCreateTime(new Date());
+                    deviceStreamMapper.insert(deviceStreamEntity);
-                        deviceStreamEntity.setUpdateTime(new Date());
+                    List<String> list = new ArrayList<>();
-                        deviceStreamEntity.setRtmpUrl(param.getRtmpUrl());
+                    list.add(type);
-                        deviceStreamMapper.insert(deviceStreamEntity);
+                    DisobeyDTO disobeyDTO = new DisobeyDTO();
-                        List<String> list = new ArrayList<>();
+                    disobeyDTO.setUrl(s);
-                        list.add(type);
+                    disobeyDTO.setOpen(param.getOpen());
-                        DisobeyDTO disobeyDTO = new DisobeyDTO();
+                    disobeyDTO.setType(list);
-                        disobeyDTO.setUrl(s);
+                    disobeyDTO.setRtmpUrl(param.getRtmpUrl());
-                        disobeyDTO.setOpen(param.getOpen());
+                    gatewayPublish.publish(top,new CommonTopicRequest<>()
-                        disobeyDTO.setType(list);
+                        .setData(Objects.requireNonNull(disobeyDTO)),1);
-                        disobeyDTO.setRtmpUrl(param.getRtmpUrl());
+
-                        gatewayPublish.publish(top,new CommonTopicRequest<>()
-                            .setData(Objects.requireNonNull(disobeyDTO)),1);
-                    }
                 }
             }
         }
         if (param.getOpen() == 2){
-            if (StringUtils.isNotEmpty(param.getModel())){
+            List<DeviceStreamEntity> deviceStreamEntities = deviceStreamMapper.selectList(new QueryWrapper<DeviceStreamEntity>().eq("rtmp_url", param.getRtmpUrl()));
-                String[] split = param.getModel().split(",");
+            if (CollectionUtils.isNotEmpty(deviceStreamEntities)){
-                for (String type : split){
+                for (DeviceStreamEntity deviceStreamEntity: deviceStreamEntities){
-                    List<DeviceStreamEntity> deviceStreamEntities = deviceStreamMapper.selectList(new QueryWrapper<DeviceStreamEntity>().eq("rtmp_url", param.getRtmpUrl())
+                    deviceStreamMapper.delete(new QueryWrapper<DeviceStreamEntity>().eq("rtmp_url", deviceStreamEntity.getRtmpUrl())
-                        .eq("stream_type", type));
+                        .eq("stream_type", deviceStreamEntity.getStreamType()));
-                    if (CollectionUtils.isNotEmpty(deviceStreamEntities)){
+                    List<String> list = new ArrayList<>();
-                        deviceStreamMapper.delete(new QueryWrapper<DeviceStreamEntity>().eq("rtmp_url", param.getRtmpUrl())
+                    list.add(deviceStreamEntity.getStreamType());
-                            .eq("stream_type", type));
+                    DisobeyDTO disobeyDTO = new DisobeyDTO();
-                        List<String> list = new ArrayList<>();
+                    disobeyDTO.setUrl(s);
-                        list.add(type);
+                    disobeyDTO.setOpen(param.getOpen());
-                        DisobeyDTO disobeyDTO = new DisobeyDTO();
+                    disobeyDTO.setType(list);
-                        disobeyDTO.setUrl(s);
+                    disobeyDTO.setRtmpUrl(param.getRtmpUrl());
-                        disobeyDTO.setOpen(param.getOpen());
+                    gatewayPublish.publish(top,new CommonTopicRequest<>()
-                        disobeyDTO.setType(list);
+                        .setData(Objects.requireNonNull(disobeyDTO)),1);
-                        disobeyDTO.setRtmpUrl(param.getRtmpUrl());
-                        gatewayPublish.publish(top,new CommonTopicRequest<>()
-                            .setData(Objects.requireNonNull(disobeyDTO)),1);
-                    }
                 }
-            }else {
+
-                deviceStreamMapper.delete(new QueryWrapper<DeviceStreamEntity>().eq("rtmp_url", param.getRtmpUrl()));
             }
         }
         return HttpResultResponse.success();