wvp-pro.git - Gitblit

			@@ -20,11 +20,11 @@
			@Insert("INSERT INTO wvp_device_channel (channel_id, device_id, name, manufacture, model, owner, civil_code, block, " +
			"address, parental, parent_id, safety_way, register_way, cert_num, certifiable, err_code, secrecy, " +
			"ip_address, port, password, ptz_type, status, stream_id, longitude, latitude, longitude_gcj02, latitude_gcj02, " +
			"longitude_wgs84, latitude_wgs84, has_audio, create_time, update_time, business_group_id, gps_time) " +
			"longitude_wgs84, latitude_wgs84, has_audio, create_time, update_time, business_group_id, gps_time, stream_identification) " +
			"VALUES (#{channelId}, #{deviceId}, #{name}, #{manufacture}, #{model}, #{owner}, #{civilCode}, #{block}," +
			"#{address}, #{parental}, #{parentId}, #{safetyWay}, #{registerWay}, #{certNum}, #{certifiable}, #{errCode}, #{secrecy}, " +
			"#{ipAddress}, #{port}, #{password}, #{PTZType}, #{status}, #{streamId}, #{longitude}, #{latitude}, #{longitudeGcj02}, " +
			"#{latitudeGcj02}, #{longitudeWgs84}, #{latitudeWgs84}, #{hasAudio}, #{createTime}, #{updateTime}, #{businessGroupId}, #{gpsTime})")
			"#{ipAddress}, #{port}, #{password}, #{ptzType}, #{status}, #{streamId}, #{longitude}, #{latitude}, #{longitudeGcj02}, " +
			"#{latitudeGcj02}, #{longitudeWgs84}, #{latitudeWgs84}, #{hasAudio}, #{createTime}, #{updateTime}, #{businessGroupId}, #{gpsTime}, #{streamIdentification})")
			int add(DeviceChannel channel);

			@Update(value = {" <script>" +
			@@ -48,7 +48,7 @@
			"<if test='ipAddress != null'>, ip_address=#{ipAddress}</if>" +
			"<if test='port != null'>, port=#{port}</if>" +
			"<if test='password != null'>, password=#{password}</if>" +
			"<if test='PTZType != null'>, custom_ptz_type=#{PTZType}</if>" +
			"<if test='ptzType != null'>, custom_ptz_type=#{ptzType}</if>" +
			"<if test='status != null'>, status=#{status}</if>" +
			"<if test='streamId != null'>, stream_id=#{streamId}</if>" +
			"<if test='hasAudio != null'>, has_audio=#{hasAudio}</if>" +
			@@ -60,6 +60,7 @@
			"<if test='latitudeWgs84 != null'>, latitude_wgs84=#{latitudeWgs84}</if>" +
			"<if test='businessGroupId != null'>, business_group_id=#{businessGroupId}</if>" +
			"<if test='gpsTime != null'>, gps_time=#{gpsTime}</if>" +
			"<if test='streamIdentification != null'>, stream_identification=#{streamIdentification}</if>" +
			"WHERE device_id=#{deviceId} AND channel_id=#{channelId}"+
			" </script>"})
			int update(DeviceChannel channel);
			@@ -102,12 +103,17 @@
			"dc.longitude_wgs84, " +
			"dc.latitude_wgs84, " +
			"dc.business_group_id, " +
			"dc.stream_identification, " +
			"dc.gps_time " +
			"from " +
			"wvp_device_channel dc " +
			"WHERE " +
			"dc.device_id = #{deviceId} " +
			" <if test='query != null'> AND (dc.channel_id LIKE concat('%',#{query},'%') OR dc.name LIKE concat('%',#{query},'%') OR dc.name LIKE concat('%',#{query},'%'))</if> " +
			" <if test='query != null'> AND (" +
			"dc.channel_id LIKE concat('%',#{query},'%') " +
			"OR dc.name LIKE concat('%',#{query},'%') " +
			"OR dc.custom_name LIKE concat('%',#{query},'%')" +
			")</if> " +
			" <if test='parentChannelId != null'> AND (dc.parent_id=#{parentChannelId} OR dc.civil_code = #{parentChannelId}) </if> " +
			" <if test='online == true' > AND dc.status= true</if>" +
			" <if test='online == false' > AND dc.status= false</if>" +
			@@ -237,17 +243,17 @@
			"(channel_id, device_id, name, manufacture, model, owner, civil_code, block, sub_count, " +
			" address, parental, parent_id, safety_way, register_way, cert_num, certifiable, err_code, secrecy, " +
			" ip_address,port,password,ptz_type,status,stream_id,longitude,latitude,longitude_gcj02,latitude_gcj02,"+
			" longitude_wgs84,latitude_wgs84,has_audio,create_time,update_time,business_group_id,gps_time)"+
			" longitude_wgs84,latitude_wgs84,has_audio,create_time,update_time,business_group_id,gps_time,stream_identification)"+
			"values " +
			"<foreach collection='addChannels' index='index' item='item' separator=','> " +
			"(#{item.channelId}, #{item.deviceId}, #{item.name}, #{item.manufacture}, #{item.model}, " +
			"#{item.owner}, #{item.civilCode}, #{item.block},#{item.subCount}," +
			"#{item.address}, #{item.parental}, #{item.parentId}, #{item.safetyWay}, #{item.registerWay}, " +
			"#{item.certNum}, #{item.certifiable}, #{item.errCode}, #{item.secrecy}, " +
			"#{item.ipAddress}, #{item.port}, #{item.password}, #{item.PTZType}, #{item.status}, " +
			"#{item.ipAddress}, #{item.port}, #{item.password}, #{item.ptzType}, #{item.status}, " +
			"#{item.streamId}, #{item.longitude}, #{item.latitude},#{item.longitudeGcj02}, " +
			"#{item.latitudeGcj02},#{item.longitudeWgs84}, #{item.latitudeWgs84}, #{item.hasAudio}, now(), now(), " +
			"#{item.businessGroupId}, #{item.gpsTime}) " +
			"#{item.businessGroupId}, #{item.gpsTime}, #{item.streamIdentification}) " +
			"</foreach> " +
			"</script>")
			int batchAdd(@Param("addChannels") List<DeviceChannel> addChannels);
			@@ -265,7 +271,7 @@
			"#{item.owner}, #{item.civilCode}, #{item.block},#{item.subCount}," +
			"#{item.address}, #{item.parental}, #{item.parentId}, #{item.safetyWay}, #{item.registerWay}, " +
			"#{item.certNum}, #{item.certifiable}, #{item.errCode}, #{item.secrecy}, " +
			"#{item.ipAddress}, #{item.port}, #{item.password}, #{item.PTZType}, #{item.status}, " +
			"#{item.ipAddress}, #{item.port}, #{item.password}, #{item.ptzType}, #{item.status}, " +
			"#{item.streamId}, #{item.longitude}, #{item.latitude},#{item.longitudeGcj02}, " +
			"#{item.latitudeGcj02},#{item.longitudeWgs84}, #{item.latitudeWgs84}, #{item.hasAudio}, now(), now(), " +
			"#{item.businessGroupId}, #{item.gpsTime}) " +
			@@ -333,7 +339,7 @@
			"<if test='item.ipAddress != null'>, ip_address=#{item.ipAddress}</if>" +
			"<if test='item.port != null'>, port=#{item.port}</if>" +
			"<if test='item.password != null'>, password=#{item.password}</if>" +
			"<if test='item.PTZType != null'>, ptz_type=#{item.PTZType}</if>" +
			"<if test='item.ptzType != null'>, ptz_type=#{item.ptzType}</if>" +
			"<if test='item.status != null'>, status=#{item.status}</if>" +
			"<if test='item.streamId != null'>, stream_id=#{item.streamId}</if>" +
			"<if test='item.hasAudio != null'>, has_audio=#{item.hasAudio}</if>" +
			@@ -345,6 +351,7 @@
			"<if test='item.latitudeWgs84 != null'>, latitude_wgs84=#{item.latitudeWgs84}</if>" +
			"<if test='item.businessGroupId != null'>, business_group_id=#{item.businessGroupId}</if>" +
			"<if test='item.gpsTime != null'>, gps_time=#{item.gpsTime}</if>" +
			"<if test='item.streamIdentification != null'>, stream_identification=#{item.streamIdentification}</if>" +
			"<if test='item.id > 0'>WHERE id=#{item.id}</if>" +
			"<if test='item.id == 0'>WHERE device_id=#{item.deviceId} AND channel_id=#{item.channelId}</if>" +
			"</foreach>" +
			@@ -388,7 +395,7 @@
			"WHERE device_id=#{deviceId} " +
			" <if test='channelId != null' > AND channel_id=#{channelId}</if>" +
			" </script>"})
			void updatePosition(DeviceChannel deviceChannel);
			int updatePosition(DeviceChannel deviceChannel);

			@Select("SELECT * FROM wvp_device_channel WHERE length(trim(stream_id)) > 0")
			List<DeviceChannel> getAllChannelInPlay();
			@@ -492,7 +499,44 @@
			void clearPlay(String deviceId);
			// 设备主子码流逻辑END
			@Select(value = {" <script>" +
			"select * " +
			"SELECT id,\n" +
			" channel_id,\n" +
			" COALESCE(custom_name, name) AS name,\n" +
			" custom_name,\n" +
			" manufacture,\n" +
			" model,\n" +
			" owner,\n" +
			" civil_code,\n" +
			" block,\n" +
			" address,\n" +
			" parent_id,\n" +
			" safety_way,\n" +
			" register_way,\n" +
			" cert_num,\n" +
			" certifiable,\n" +
			" err_code,\n" +
			" end_time,\n" +
			" secrecy,\n" +
			" ip_address,\n" +
			" port,\n" +
			" password,\n" +
			" COALESCE(custom_ptz_type, ptz_type) AS ptz_type,\n" +
			" status,\n" +
			" COALESCE(custom_longitude, longitude) AS longitude,\n" +
			" COALESCE(custom_latitude, latitude) AS latitude,\n" +
			" stream_id,\n" +
			" device_id,\n" +
			" parental,\n" +
			" has_audio,\n" +
			" create_time,\n" +
			" update_time,\n" +
			" sub_count,\n" +
			" longitude_gcj02,\n" +
			" latitude_gcj02,\n" +
			" longitude_wgs84,\n" +
			" latitude_wgs84,\n" +
			" business_group_id,\n" +
			" gps_time\n" +
			"from wvp_device_channel " +
			"where device_id=#{deviceId}" +
			" <if test='parentId != null and parentId != deviceId'> and parent_id = #{parentId} </if>" +
			@@ -501,4 +545,9 @@
			" </script>"})
			List<DeviceChannel> getSubChannelsByDeviceId(@Param("deviceId") String deviceId, @Param("parentId") String parentId, @Param("onlyCatalog") boolean onlyCatalog);

			@Update("<script>" +
			"UPDATE wvp_device_channel SET stream_identification=#{streamIdentification} WHERE device_id=#{deviceId}" +
			" <if test='channelId != null'> and channel_id = #{channelId} </if>" +
			"</script>")
			void updateChannelStreamIdentification(DeviceChannel channel);
			}