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
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
| package com.genersoft.iot.vmp.storager.dao;
|
| import com.genersoft.iot.vmp.media.zlm.dto.MediaServerItem;
| import org.apache.ibatis.annotations.Insert;
| import org.apache.ibatis.annotations.Mapper;
| import org.apache.ibatis.annotations.Select;
| import org.apache.ibatis.annotations.Update;
| import org.springframework.stereotype.Repository;
|
| import java.util.List;
|
|
| @Mapper
| @Repository
| public interface MediaServerMapper {
|
| @Insert("INSERT INTO media_server (" +
| "id, " +
| "ip, " +
| "hookIp, " +
| "sdpIp, " +
| "streamIp, " +
| "httpPort, " +
| "httpSSlPort, " +
| "rtmpPort, " +
| "rtmpSSlPort, " +
| "rtpProxyPort, " +
| "rtspPort, " +
| "rtspSSLPort, " +
| "autoConfig, " +
| "secret, " +
| "streamNoneReaderDelayMS, " +
| "rtpEnable, " +
| "rtpPortRange, " +
| "recordAssistPort, " +
| "defaultServer, " +
| "createTime, " +
| "updateTime" +
| ") VALUES " +
| "(" +
| "'${id}', " +
| "'${ip}', " +
| "'${hookIp}', " +
| "'${sdpIp}', " +
| "'${streamIp}', " +
| "${httpPort}, " +
| "${httpSSlPort}, " +
| "${rtmpPort}, " +
| "${rtmpSSlPort}, " +
| "${rtpProxyPort}, " +
| "${rtspPort}, " +
| "${rtspSSLPort}, " +
| "${autoConfig}, " +
| "'${secret}', " +
| "${streamNoneReaderDelayMS}, " +
| "${rtpEnable}, " +
| "'${rtpPortRange}', " +
| "${recordAssistPort}, " +
| "${defaultServer}, " +
| "'${createTime}', " +
| "'${updateTime}')")
| int add(MediaServerItem mediaServerItem);
|
| @Update(value = {" <script>" +
| "UPDATE media_server " +
| "SET updateTime='${updateTime}'" +
| "<if test=\"ip != null\">, ip='${ip}'</if>" +
| "<if test=\"hookIp != null\">, hookIp='${hookIp}'</if>" +
| "<if test=\"sdpIp != null\">, sdpIp='${sdpIp}'</if>" +
| "<if test=\"streamIp != null\">, streamIp='${streamIp}'</if>" +
| "<if test=\"httpPort != null\">, httpPort=${httpPort}</if>" +
| "<if test=\"httpSSlPort != null\">, httpSSlPort=${httpSSlPort}</if>" +
| "<if test=\"rtmpPort != null\">, rtmpPort=${rtmpPort}</if>" +
| "<if test=\"rtmpSSlPort != null\">, rtmpSSlPort=${rtmpSSlPort}</if>" +
| "<if test=\"rtpProxyPort != null\">, rtpProxyPort=${rtpProxyPort}</if>" +
| "<if test=\"rtspPort != null\">, rtspPort=${rtspPort}</if>" +
| "<if test=\"rtspSSLPort != null\">, rtspSSLPort=${rtspSSLPort}</if>" +
| "<if test=\"autoConfig != null\">, autoConfig=${autoConfig}</if>" +
| "<if test=\"streamNoneReaderDelayMS != null\">, streamNoneReaderDelayMS=${streamNoneReaderDelayMS}</if>" +
| "<if test=\"rtpEnable != null\">, rtpEnable=${rtpEnable}</if>" +
| "<if test=\"rtpPortRange != null\">, rtpPortRange='${rtpPortRange}'</if>" +
| "<if test=\"secret != null\">, secret='${secret}'</if>" +
| "<if test=\"recordAssistPort != null\">, recordAssistPort=${recordAssistPort}</if>" +
| "WHERE id='${id}'"+
| " </script>"})
| int update(MediaServerItem mediaServerItem);
|
| @Select("SELECT * FROM media_server WHERE id='${id}'")
| MediaServerItem queryOne(String id);
|
| @Select("SELECT * FROM media_server")
| List<MediaServerItem> queryAll();
|
| @Select("DELETE FROM media_server WHERE id='${id}'")
| void delOne(String id);
|
| @Select("DELETE FROM media_server WHERE ip='${host}' and httpPort=${port}")
| void delOneByIPAndPort(String host, int port);
|
| @Select("DELETE FROM media_server WHERE defaultServer=1;")
| void delDefault();
|
| @Select("SELECT * FROM media_server WHERE ip='${host}' and httpPort=${port}")
| MediaServerItem queryOneByHostAndPort(String host, int port);
| }
|
|
