Shikong/gb28181-docking-platform-mocking
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

zlm on_stream_changed 仅处理 rtsp

Browse Source
This commit is contained in:
shikong 2024-02-23 08:39:59 +08:00
parent ec79694bb6
commit 717ee609bf
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
gb28181-mocking-api/src/main/java/cn/skcks/docking/gb28181/mocking/api/zlm/ZlmHookApi.java
View File

@ -8,6 +8,7 @@ import cn.skcks.docking.gb28181.mocking.service.zlm.hook.ZlmStreamNoneReaderHook
import io.swagger.v3.oas.annotations.tags.Tag; import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController; import org.springframework.web.bind.annotation.RestController;
@ -24,8 +25,11 @@ public class ZlmHookApi {
@PostJson("/on_stream_changed") @PostJson("/on_stream_changed")
public void onStreamChanged(@RequestBody ZlmStreamChangeDTO dto){ public void onStreamChanged(@RequestBody ZlmStreamChangeDTO dto){
log.debug("on_stream_changed {}", dto);
if(StringUtils.equalsIgnoreCase(dto.getSchema(), "rtsp")){
zlmStreamChangeHookService.processEvent(dto.getApp(),dto.getStream(), dto.getRegist()); zlmStreamChangeHookService.processEvent(dto.getApp(),dto.getStream(), dto.getRegist());
} }
}
@PostJson("/on_stream_none_reader") @PostJson("/on_stream_none_reader")
public void onStreamNoneReader(@RequestBody ZlmStreamNoneReaderDTO dto){ public void onStreamNoneReader(@RequestBody ZlmStreamNoneReaderDTO dto){