From b4048fbe80dba8e7756ae557a15ab60b4f80a44b Mon Sep 17 00:00:00 2001 From: 648540858 <648540858@qq.com> Date: 星期二, 04 四月 2023 09:09:07 +0800 Subject: [PATCH] 合并开源主线 --- src/main/java/com/genersoft/iot/vmp/storager/dao/DeviceMapper.java | 28 +++++++++++++++++++++------- 1 files changed, 21 insertions(+), 7 deletions(-) diff --git a/src/main/java/com/genersoft/iot/vmp/storager/dao/DeviceMapper.java b/src/main/java/com/genersoft/iot/vmp/storager/dao/DeviceMapper.java index 0aed820..fe739ea 100644 --- a/src/main/java/com/genersoft/iot/vmp/storager/dao/DeviceMapper.java +++ b/src/main/java/com/genersoft/iot/vmp/storager/dao/DeviceMapper.java @@ -39,9 +39,12 @@ "mobilePositionSubmissionInterval," + "subscribeCycleForAlarm," + "ssrcCheck," + + "asMessageChannel," + "geoCoordSys," + "treeType," + - "online" + + "online," + + "mediaServerId," + + "(SELECT count(0) FROM device_channel WHERE deviceId=device.deviceId) as channelCount "+ " FROM device WHERE deviceId = #{deviceId}") Device getDeviceByDeviceId(String deviceId); @@ -70,6 +73,7 @@ "mobilePositionSubmissionInterval," + "subscribeCycleForAlarm," + "ssrcCheck," + + "asMessageChannel," + "geoCoordSys," + "treeType," + "online" + @@ -98,6 +102,7 @@ "#{mobilePositionSubmissionInterval}," + "#{subscribeCycleForAlarm}," + "#{ssrcCheck}," + + "#{asMessageChannel}," + "#{geoCoordSys}," + "#{treeType}," + "#{online}" + @@ -152,9 +157,11 @@ "mobilePositionSubmissionInterval," + "subscribeCycleForAlarm," + "ssrcCheck," + + "asMessageChannel," + "geoCoordSys," + "treeType," + "online," + + "mediaServerId," + "(SELECT count(0) FROM device_channel WHERE deviceId=de.deviceId) as channelCount FROM device de" + "<if test=\"online != null\"> where online=${online}</if>"+ " </script>" @@ -163,9 +170,6 @@ @Delete("DELETE FROM device WHERE deviceId=#{deviceId}") int del(String deviceId); - - @Update("UPDATE device SET online=0") - int outlineForAll(); @Select("SELECT " + "deviceId, " + @@ -192,6 +196,7 @@ "mobilePositionSubmissionInterval," + "subscribeCycleForAlarm," + "ssrcCheck," + + "asMessageChannel," + "geoCoordSys," + "treeType," + "online " + @@ -222,6 +227,7 @@ "mobilePositionSubmissionInterval," + "subscribeCycleForAlarm," + "ssrcCheck," + + "asMessageChannel," + "geoCoordSys," + "treeType," + "online" + @@ -243,12 +249,13 @@ "<if test=\"mobilePositionSubmissionInterval != null\">, mobilePositionSubmissionInterval=#{mobilePositionSubmissionInterval}</if>" + "<if test=\"subscribeCycleForAlarm != null\">, subscribeCycleForAlarm=#{subscribeCycleForAlarm}</if>" + "<if test=\"ssrcCheck != null\">, ssrcCheck=#{ssrcCheck}</if>" + + "<if test=\"asMessageChannel != null\">, asMessageChannel=#{asMessageChannel}</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); + void updateCustom(Device device); @Insert("INSERT INTO device (" + "deviceId, " + @@ -259,9 +266,11 @@ "updateTime," + "charset," + "ssrcCheck," + + "asMessageChannel," + "geoCoordSys," + "treeType," + - "online" + + "online," + + "mediaServerId" + ") VALUES (" + "#{deviceId}," + "#{name}," + @@ -271,9 +280,11 @@ "#{updateTime}," + "#{charset}," + "#{ssrcCheck}," + + "#{asMessageChannel}," + "#{geoCoordSys}," + "#{treeType}," + - "#{online}" + + "#{online}," + + "#{mediaServerId}" + ")") void addCustomDevice(Device device); @@ -282,4 +293,7 @@ @Select("select * from device") List<Device> getAll(); + + @Select("select * from device where asMessageChannel = 1") + List<Device> queryDeviceWithAsMessageChannel(); } -- Gitblit v1.8.0