1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
| package com.genersoft.iot.vmp.storager.dao;
|
| import com.genersoft.iot.vmp.media.zlm.dto.StreamProxyItem;
| import org.apache.ibatis.annotations.*;
| import org.springframework.stereotype.Repository;
|
| import java.util.List;
|
| @Mapper
| @Repository
| public interface StreamProxyMapper {
|
| @Insert("INSERT INTO stream_proxy (type, app, stream, url, src_url, dst_url, " +
| "timeout_ms, ffmpeg_cmd_key, rtp_type, enable_hls, enable_mp4, enable) VALUES" +
| "('${type}','${app}', '${stream}', '${url}', '${src_url}', '${dst_url}', " +
| "'${timeout_ms}', '${ffmpeg_cmd_key}', '${rtp_type}', ${enable_hls}, ${enable_mp4}, ${enable} )")
| int add(StreamProxyItem streamProxyDto);
|
| @Update("UPDATE stream_proxy " +
| "SET type=#{type}, " +
| "app=#{app}," +
| "stream=#{stream}," +
| "url=#{url}, " +
| "src_url=#{src_url}," +
| "dst_url=#{dst_url}, " +
| "timeout_ms=#{timeout_ms}, " +
| "ffmpeg_cmd_key=#{ffmpeg_cmd_key}, " +
| "rtp_type=#{rtp_type}, " +
| "enable_hls=#{enable_hls}, " +
| "enable=#{enable}, " +
| "enable_mp4=#{enable_mp4} " +
| "WHERE app=#{app} AND stream=#{stream}")
| int update(StreamProxyItem streamProxyDto);
|
| @Delete("DELETE FROM stream_proxy WHERE app=#{app} AND stream=#{stream}")
| int del(String app, String stream);
|
| @Select("SELECT st.*, pgs.gbId, pgs.name, pgs.longitude, pgs.latitude FROM stream_proxy st LEFT JOIN gb_stream pgs on st.app = pgs.app AND st.stream = pgs.stream")
| List<StreamProxyItem> selectAll();
|
| @Select("SELECT st.*, pgs.gbId, pgs.name, pgs.longitude, pgs.latitude FROM stream_proxy st LEFT JOIN gb_stream pgs on st.app = pgs.app AND st.stream = pgs.stream WHERE st.enable=${enable}")
| List<StreamProxyItem> selectForEnable(boolean enable);
|
| @Select("SELECT st.*, pgs.gbId, pgs.name, pgs.longitude, pgs.latitude FROM stream_proxy st LEFT JOIN gb_stream pgs on st.app = pgs.app AND st.stream = pgs.stream WHERE st.app=#{app} AND st.stream=#{stream}")
| StreamProxyItem selectOne(String app, String stream);
| }
|
|
