| | |
| | | @Repository |
| | | public interface DeviceMapper { |
| | | |
| | | @Select("SELECT * FROM device WHERE deviceId = #{deviceId}") |
| | | @Select("SELECT " + |
| | | "deviceId, " + |
| | | "coalesce(custom_name, name) as name, " + |
| | | "password, " + |
| | | "manufacturer, " + |
| | | "model, " + |
| | | "firmware, " + |
| | | "transport," + |
| | | "streamMode," + |
| | | "ip," + |
| | | "port," + |
| | | "hostAddress," + |
| | | "expires," + |
| | | "registerTime," + |
| | | "keepaliveTime," + |
| | | "createTime," + |
| | | "updateTime," + |
| | | "charset," + |
| | | "subscribeCycleForCatalog," + |
| | | "subscribeCycleForMobilePosition," + |
| | | "mobilePositionSubmissionInterval," + |
| | | "subscribeCycleForAlarm," + |
| | | "ssrcCheck," + |
| | | "geoCoordSys," + |
| | | "treeType," + |
| | | "online" + |
| | | " FROM device WHERE deviceId = #{deviceId}") |
| | | Device getDeviceByDeviceId(String deviceId); |
| | | |
| | | @Insert("INSERT INTO device (" + |
| | |
| | | "ip," + |
| | | "port," + |
| | | "hostAddress," + |
| | | "expires," + |
| | | "registerTime," + |
| | | "keepaliveTime," + |
| | | "createTime," + |
| | | "updateTime," + |
| | | "charset," + |
| | | "subscribeCycleForCatalog," + |
| | | "subscribeCycleForMobilePosition," + |
| | | "mobilePositionSubmissionInterval," + |
| | | "subscribeCycleForAlarm," + |
| | | "ssrcCheck," + |
| | | "geoCoordSys," + |
| | | "treeType," + |
| | | "online" + |
| | | ") VALUES (" + |
| | | "#{deviceId}," + |
| | |
| | | "#{ip}," + |
| | | "#{port}," + |
| | | "#{hostAddress}," + |
| | | "#{expires}," + |
| | | "#{registerTime}," + |
| | | "#{keepaliveTime}," + |
| | | "#{createTime}," + |
| | | "#{updateTime}," + |
| | | "#{charset}," + |
| | | "#{subscribeCycleForCatalog}," + |
| | | "#{subscribeCycleForMobilePosition}," + |
| | | "#{mobilePositionSubmissionInterval}," + |
| | | "#{subscribeCycleForAlarm}," + |
| | | "#{ssrcCheck}," + |
| | | "#{geoCoordSys}," + |
| | | "#{treeType}," + |
| | | "#{online}" + |
| | | ")") |
| | | int add(Device device); |
| | | |
| | | @Update(value = {" <script>" + |
| | | "UPDATE device " + |
| | | "SET deviceId='${deviceId}'" + |
| | | "SET updateTime='${updateTime}'" + |
| | | "<if test=\"name != null\">, name='${name}'</if>" + |
| | | "<if test=\"manufacturer != null\">, manufacturer='${manufacturer}'</if>" + |
| | | "<if test=\"model != null\">, model='${model}'</if>" + |
| | | "<if test=\"firmware != null\">, firmware='${firmware}'</if>" + |
| | | "<if test=\"transport != null\">, transport='${transport}'</if>" + |
| | | "<if test=\"streamMode != null\">, streamMode='${streamMode}'</if>" + |
| | | "<if test=\"ip != null\">, ip='${ip}'</if>" + |
| | | "<if test=\"port != null\">, port=${port}</if>" + |
| | | "<if test=\"hostAddress != null\">, hostAddress='${hostAddress}'</if>" + |
| | | "<if test=\"online != null\">, online=${online}</if>" + |
| | | "<if test=\"registerTime != null\">, registerTime='${registerTime}'</if>" + |
| | | "<if test=\"keepaliveTime != null\">, keepaliveTime='${keepaliveTime}'</if>" + |
| | | "<if test=\"expires != null\">, expires=${expires}</if>" + |
| | | "WHERE deviceId='${deviceId}'"+ |
| | | " </script>"}) |
| | | int update(Device device); |
| | | |
| | | @Select("SELECT *, (SELECT count(0) FROM device_channel WHERE deviceId=de.deviceId) as channelCount FROM device de") |
| | | @Select("SELECT " + |
| | | "deviceId, " + |
| | | "coalesce(custom_name, name) as name, " + |
| | | "password, " + |
| | | "manufacturer, " + |
| | | "model, " + |
| | | "firmware, " + |
| | | "transport," + |
| | | "streamMode," + |
| | | "ip," + |
| | | "port," + |
| | | "hostAddress," + |
| | | "expires," + |
| | | "registerTime," + |
| | | "keepaliveTime," + |
| | | "createTime," + |
| | | "updateTime," + |
| | | "charset," + |
| | | "subscribeCycleForCatalog," + |
| | | "subscribeCycleForMobilePosition," + |
| | | "mobilePositionSubmissionInterval," + |
| | | "subscribeCycleForAlarm," + |
| | | "ssrcCheck," + |
| | | "geoCoordSys," + |
| | | "treeType," + |
| | | "online," + |
| | | "(SELECT count(0) FROM device_channel WHERE deviceId=de.deviceId) as channelCount FROM device de") |
| | | List<Device> getDevices(); |
| | | |
| | | @Delete("DELETE FROM device WHERE deviceId=#{deviceId}") |
| | | int del(String deviceId); |
| | | |
| | | @Update("UPDATE device SET online=0") |
| | | int outlineForAll(); |
| | | |
| | | @Select("SELECT " + |
| | | "deviceId, " + |
| | | "coalesce(custom_name, name) as name, " + |
| | | "password, " + |
| | | "manufacturer, " + |
| | | "model, " + |
| | | "firmware, " + |
| | | "transport," + |
| | | "streamMode," + |
| | | "ip," + |
| | | "port," + |
| | | "hostAddress," + |
| | | "expires," + |
| | | "registerTime," + |
| | | "keepaliveTime," + |
| | | "createTime," + |
| | | "updateTime," + |
| | | "charset," + |
| | | "subscribeCycleForCatalog," + |
| | | "subscribeCycleForMobilePosition," + |
| | | "mobilePositionSubmissionInterval," + |
| | | "subscribeCycleForAlarm," + |
| | | "ssrcCheck," + |
| | | "geoCoordSys," + |
| | | "treeType," + |
| | | "online " + |
| | | " FROM device WHERE online = 1") |
| | | List<Device> getOnlineDevices(); |
| | | @Select("SELECT " + |
| | | "deviceId, " + |
| | | "coalesce(custom_name, name) as name, " + |
| | | "password, " + |
| | | "manufacturer, " + |
| | | "model, " + |
| | | "firmware, " + |
| | | "transport," + |
| | | "streamMode," + |
| | | "ip," + |
| | | "port," + |
| | | "hostAddress," + |
| | | "expires," + |
| | | "registerTime," + |
| | | "keepaliveTime," + |
| | | "createTime," + |
| | | "updateTime," + |
| | | "charset," + |
| | | "subscribeCycleForCatalog," + |
| | | "subscribeCycleForMobilePosition," + |
| | | "mobilePositionSubmissionInterval," + |
| | | "subscribeCycleForAlarm," + |
| | | "ssrcCheck," + |
| | | "geoCoordSys," + |
| | | "treeType," + |
| | | "online" + |
| | | " FROM device WHERE ip = #{host} AND port=${port}") |
| | | Device getDeviceByHostAndPort(String host, int port); |
| | | |
| | | @Update(value = {" <script>" + |
| | | "UPDATE device " + |
| | | "SET updateTime='${updateTime}'" + |
| | | "<if test=\"name != null\">, custom_name='${name}'</if>" + |
| | | "<if test=\"password != null\">, password='${password}'</if>" + |
| | | "<if test=\"streamMode != null\">, streamMode='${streamMode}'</if>" + |
| | | "<if test=\"ip != null\">, ip='${ip}'</if>" + |
| | | "<if test=\"port != null\">, port=${port}</if>" + |
| | | "<if test=\"charset != null\">, charset='${charset}'</if>" + |
| | | "<if test=\"subscribeCycleForCatalog != null\">, subscribeCycleForCatalog=${subscribeCycleForCatalog}</if>" + |
| | | "<if test=\"subscribeCycleForMobilePosition != null\">, subscribeCycleForMobilePosition=${subscribeCycleForMobilePosition}</if>" + |
| | | "<if test=\"mobilePositionSubmissionInterval != null\">, mobilePositionSubmissionInterval=${mobilePositionSubmissionInterval}</if>" + |
| | | "<if test=\"subscribeCycleForAlarm != null\">, subscribeCycleForAlarm=${subscribeCycleForAlarm}</if>" + |
| | | "<if test=\"ssrcCheck != null\">, ssrcCheck=${ssrcCheck}</if>" + |
| | | "<if test=\"geoCoordSys != null\">, geoCoordSys=#{geoCoordSys}</if>" + |
| | | "<if test=\"treeType != null\">, treeType=#{treeType}</if>" + |
| | | "<if test=\"mediaServerId != null\">, mediaServerId=#{mediaServerId}</if>" + |
| | | "WHERE deviceId='${deviceId}'"+ |
| | | " </script>"}) |
| | | int updateCustom(Device device); |
| | | |
| | | @Insert("INSERT INTO device (" + |
| | | "deviceId, " + |
| | | "custom_name, " + |
| | | "password, " + |
| | | "createTime," + |
| | | "updateTime," + |
| | | "charset," + |
| | | "ssrcCheck," + |
| | | "geoCoordSys," + |
| | | "treeType," + |
| | | "online" + |
| | | ") VALUES (" + |
| | | "#{deviceId}," + |
| | | "#{name}," + |
| | | "#{password}," + |
| | | "#{createTime}," + |
| | | "#{updateTime}," + |
| | | "#{charset}," + |
| | | "#{ssrcCheck}," + |
| | | "#{geoCoordSys}," + |
| | | "#{treeType}," + |
| | | "#{online}" + |
| | | ")") |
| | | void addCustomDevice(Device device); |
| | | } |