支持锁定编辑后的设备名 #642
This commit is contained in:
parent
abc929dae7
commit
f7c14c16c9
File diff suppressed because one or more lines are too long
@ -1,8 +1,8 @@
|
|||||||
alter table wvp.media_server
|
alter table media_server
|
||||||
drop column streamNoneReaderDelayMS;
|
drop column streamNoneReaderDelayMS;
|
||||||
|
|
||||||
alter table stream_proxy
|
alter table stream_proxy
|
||||||
add enable_disable_none_reader bit(1) default null;
|
add enable_disable_none_reader bit(1) default null;
|
||||||
|
|
||||||
alter table device
|
alter table device
|
||||||
add mediaServerId varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci DEFAULT 'auto';
|
add custom_name varchar(255) default null;
|
||||||
|
@ -360,7 +360,7 @@ public class DeviceServiceImpl implements IDeviceService {
|
|||||||
device.setUpdateTime(now);
|
device.setUpdateTime(now);
|
||||||
device.setCharset(device.getCharset().toUpperCase());
|
device.setCharset(device.getCharset().toUpperCase());
|
||||||
device.setUpdateTime(DateUtil.getNow());
|
device.setUpdateTime(DateUtil.getNow());
|
||||||
if (deviceMapper.update(device) > 0) {
|
if (deviceMapper.updateCustom(device) > 0) {
|
||||||
redisCatchStorage.updateDevice(device);
|
redisCatchStorage.updateDevice(device);
|
||||||
|
|
||||||
}
|
}
|
||||||
|
@ -13,7 +13,32 @@ import java.util.List;
|
|||||||
@Repository
|
@Repository
|
||||||
public interface DeviceMapper {
|
public interface DeviceMapper {
|
||||||
|
|
||||||
@Select("SELECT * FROM device WHERE deviceId = #{deviceId}")
|
@Select("SELECT " +
|
||||||
|
"deviceId, " +
|
||||||
|
"coalesce(custom_name, name) as name, " +
|
||||||
|
"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);
|
Device getDeviceByDeviceId(String deviceId);
|
||||||
|
|
||||||
@Insert("INSERT INTO device (" +
|
@Insert("INSERT INTO device (" +
|
||||||
@ -98,7 +123,32 @@ public interface DeviceMapper {
|
|||||||
" </script>"})
|
" </script>"})
|
||||||
int update(Device device);
|
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, " +
|
||||||
|
"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();
|
List<Device> getDevices();
|
||||||
|
|
||||||
@Delete("DELETE FROM device WHERE deviceId=#{deviceId}")
|
@Delete("DELETE FROM device WHERE deviceId=#{deviceId}")
|
||||||
@ -107,8 +157,80 @@ public interface DeviceMapper {
|
|||||||
@Update("UPDATE device SET online=0")
|
@Update("UPDATE device SET online=0")
|
||||||
int outlineForAll();
|
int outlineForAll();
|
||||||
|
|
||||||
@Select("SELECT * FROM device WHERE online = 1")
|
@Select("SELECT " +
|
||||||
|
"deviceId, " +
|
||||||
|
"coalesce(custom_name, name) as name, " +
|
||||||
|
"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();
|
List<Device> getOnlineDevices();
|
||||||
@Select("SELECT * FROM device WHERE ip = #{host} AND port=${port}")
|
@Select("SELECT " +
|
||||||
|
"deviceId, " +
|
||||||
|
"coalesce(custom_name, name) as name, " +
|
||||||
|
"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);
|
Device getDeviceByHostAndPort(String host, int port);
|
||||||
|
|
||||||
|
@Update(value = {" <script>" +
|
||||||
|
"UPDATE device " +
|
||||||
|
"SET updateTime='${updateTime}'" +
|
||||||
|
"<if test=\"name != null\">, custom_name='${name}'</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=\"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);
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user