From 5d901b5e3f033e8b04e53420d68626cbd87431c8 Mon Sep 17 00:00:00 2001 From: 648540858 <648540858@qq.com> Date: 星期五, 06 五月 2022 10:12:34 +0800 Subject: [PATCH] 使用阿里代码规范。规范代码写法 --- src/main/java/com/genersoft/iot/vmp/storager/dao/PlatformGbStreamMapper.java | 91 +++++++++++++++++++++++++++++++++++++++++++-- 1 files changed, 86 insertions(+), 5 deletions(-) diff --git a/src/main/java/com/genersoft/iot/vmp/storager/dao/PlatformGbStreamMapper.java b/src/main/java/com/genersoft/iot/vmp/storager/dao/PlatformGbStreamMapper.java index 6243f32..98afd6b 100644 --- a/src/main/java/com/genersoft/iot/vmp/storager/dao/PlatformGbStreamMapper.java +++ b/src/main/java/com/genersoft/iot/vmp/storager/dao/PlatformGbStreamMapper.java @@ -1,7 +1,11 @@ package com.genersoft.iot.vmp.storager.dao; +import com.genersoft.iot.vmp.gb28181.bean.GbStream; +import com.genersoft.iot.vmp.gb28181.bean.ParentPlatform; +import com.genersoft.iot.vmp.gb28181.bean.PlatformCatalog; import com.genersoft.iot.vmp.gb28181.bean.PlatformGbStream; import com.genersoft.iot.vmp.media.zlm.dto.StreamProxyItem; +import com.genersoft.iot.vmp.media.zlm.dto.StreamPushItem; import org.apache.ibatis.annotations.*; import org.springframework.stereotype.Repository; @@ -12,16 +16,93 @@ @Repository public interface PlatformGbStreamMapper { - @Insert("INSERT INTO platform_gb_stream (app, stream, platformId) VALUES" + - "('${app}', '${stream}', '${platformId}')") + @Insert("REPLACE INTO platform_gb_stream (gbStreamId, platformId, catalogId) VALUES" + + "( #{gbStreamId}, #{platformId}, #{catalogId})") int add(PlatformGbStream platformGbStream); - @Delete("DELETE FROM platform_gb_stream WHERE app=#{app} AND stream=#{stream}") + + @Insert("<script> " + + "INSERT into platform_gb_stream " + + "(gbStreamId, platformId, catalogId) " + + "values " + + "<foreach collection='streamPushItems' index='index' item='item' separator=','> " + + "(${item.gbStreamId}, '${item.platformId}', '${item.catalogId}')" + + "</foreach> " + + "</script>") + int batchAdd(List<StreamPushItem> streamPushItems); + + @Delete("DELETE FROM platform_gb_stream WHERE gbStreamId = (select gbStreamId from gb_stream where app=#{app} AND stream=#{stream})") int delByAppAndStream(String app, String stream); @Delete("DELETE FROM platform_gb_stream WHERE platformId=#{platformId}") int delByPlatformId(String platformId); - @Select("SELECT * FROM platform_gb_stream WHERE app=#{app} AND stream=#{stream}") - List<StreamProxyItem> selectByAppAndStream(String app, String stream); + @Select("SELECT " + + "pp.* " + + "FROM " + + "platform_gb_stream pgs " + + "LEFT JOIN parent_platform pp ON pp.serverGBId = pgs.platformId " + + "LEFT JOIN gb_stream gs ON gs.gbStreamId = pgs.gbStreamId " + + "WHERE " + + "gs.app =#{app} " + + "AND gs.stream =#{stream} ") + List<ParentPlatform> selectByAppAndStream(String app, String stream); + + @Select("SELECT pgs.*, gs.gbId FROM platform_gb_stream pgs " + + "LEFT JOIN gb_stream gs ON pgs.gbStreamId = gs.gbStreamId " + + "WHERE gs.app=#{app} AND gs.stream=#{stream} AND pgs.platformId=#{serverGBId}") + StreamProxyItem selectOne(String app, String stream, String serverGBId); + + @Select("select gs.* \n" + + "from gb_stream gs\n" + + " left join platform_gb_stream pgs\n" + + " on gs.gbStreamId = pgs.gbStreamId\n" + + "where pgs.platformId=#{platformId} and pgs.catalogId=#{catalogId}") + List<GbStream> queryChannelInParentPlatformAndCatalog(String platformId, String catalogId); + + @Select("select gs.gbId as id, gs.name as name, pgs.platformId as platformId, pgs.catalogId as catalogId , 0 as childrenCount, 2 as type\n" + + "from gb_stream gs\n" + + " left join platform_gb_stream pgs\n" + + " on gs.gbStreamId = pgs.gbStreamId\n" + + "where pgs.platformId=#{platformId} and pgs.catalogId=#{catalogId}") + List<PlatformCatalog> queryChannelInParentPlatformAndCatalogForCatalog(String platformId, String catalogId); + + @Delete("DELETE FROM platform_gb_stream WHERE catalogId=#{id}") + int delByCatalogId(String id); + + @Select("<script> " + + "SELECT " + + "pp.* " + + "FROM " + + "parent_platform pp " + + "left join platform_gb_stream pgs on " + + "pp.serverGBId = pgs.platformId " + + "left join gb_stream gs " + + "on gs.gbStreamId = pgs.gbStreamId " + + "WHERE " + + "gs.app = #{app} " + + "AND gs.stream = #{stream}" + + "AND pp.serverGBId IN" + + "<foreach collection='platforms' item='item' open='(' separator=',' close=')' > #{item}</foreach>" + + "</script> ") + List<ParentPlatform> queryPlatFormListForGBWithGBId(String app, String stream, List<String> platforms); + + @Delete("DELETE FROM platform_gb_stream WHERE gbStreamId = (select id from gb_stream where app=#{app} AND stream=#{stream}) AND platformId=#{platformId}") + int delByAppAndStreamAndPlatform(String app, String stream, String platformId); + + @Delete("<script> "+ + "DELETE FROM platform_gb_stream where gbStreamId in " + + "<foreach collection='gbStreams' item='item' open='(' separator=',' close=')' >" + + "#{item.gbStreamId}" + + "</foreach>" + + "</script>") + void delByGbStreams(List<GbStream> gbStreams); + + @Delete("<script> "+ + "DELETE FROM platform_gb_stream where platformId=#{platformId} and gbStreamId in " + + "<foreach collection='gbStreams' item='item' open='(' separator=',' close=')'>" + + "#{item.gbStreamId} " + + "</foreach>" + + "</script>") + void delByAppAndStreamsByPlatformId(List<GbStream> gbStreams, String platformId); } -- Gitblit v1.8.0