搭配zgyw，实现gb28181
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
648540858
2022-08-22 ecd14d6757eb12e66d7668eff509c10875abf855 
 src/main/java/com/genersoft/iot/vmp/vmanager/gb28181/platform/PlatformController.java


@@ -8,6 +8,7 @@


import com.genersoft.iot.vmp.gb28181.bean.ParentPlatform;


import com.genersoft.iot.vmp.gb28181.bean.PlatformCatalog;


import com.genersoft.iot.vmp.gb28181.bean.SubscribeHolder;


import com.genersoft.iot.vmp.gb28181.bean.TreeType;


import com.genersoft.iot.vmp.gb28181.transmit.cmd.ISIPCommanderForPlatform;


import com.genersoft.iot.vmp.service.IPlatformChannelService;


import com.genersoft.iot.vmp.storager.IRedisCatchStorage;


@@ -17,10 +18,9 @@


import com.genersoft.iot.vmp.vmanager.gb28181.platform.bean.ChannelReduce;


import com.genersoft.iot.vmp.vmanager.gb28181.platform.bean.UpdateChannelParam;


import com.github.pagehelper.PageInfo;


import io.swagger.annotations.Api;


import io.swagger.annotations.ApiImplicitParam;


import io.swagger.annotations.ApiImplicitParams;


import io.swagger.annotations.ApiOperation;


import io.swagger.v3.oas.annotations.Operation;


import io.swagger.v3.oas.annotations.Parameter;


import io.swagger.v3.oas.annotations.tags.Tag;


import org.slf4j.Logger;


import org.slf4j.LoggerFactory;


import org.springframework.beans.factory.annotation.Autowired;


@@ -35,7 +35,7 @@


/**


 * 级联平台管理


 */


@Api(tags = "级联平台管理")


@Tag(name  = "级联平台管理")


@CrossOrigin


@RestController


@RequestMapping("/api/platform")


@@ -72,7 +72,7 @@


     *


     * @return


     */


    @ApiOperation("获取国标服务的配置")


    @Operation(summary = "获取国标服务的配置")


    @GetMapping("/server_config")


    public ResponseEntity<JSONObject> serverConfig() {


        JSONObject result = new JSONObject();


@@ -88,7 +88,8 @@


     *


     * @return


     */


    @ApiOperation("获取国标服务的配置")


    @Operation(summary = "获取级联服务器信息")


    @Parameter(name = "id", description = "平台国标编号", required = true)


    @GetMapping("/info/{id}")


    public ResponseEntity<WVPResult<ParentPlatform>> getPlatform(@PathVariable String id) {


        ParentPlatform parentPlatform = storager.queryParentPlatByServerGBId(id);


@@ -111,12 +112,10 @@


     * @param count 每页条数


     * @return


     */


    @ApiOperation("分页查询级联平台")


    @GetMapping("/query/{count}/{page}")


    @ApiImplicitParams({


            @ApiImplicitParam(name = "page", value = "当前页", dataTypeClass = Integer.class),


            @ApiImplicitParam(name = "count", value = "每页条数", dataTypeClass = Integer.class),


    })


    @Operation(summary = "分页查询级联平台")


    @Parameter(name = "page", description = "当前页", required = true)


    @Parameter(name = "count", description = "每页条数", required = true)


    public PageInfo<ParentPlatform> platforms(@PathVariable int page, @PathVariable int count) {




        PageInfo<ParentPlatform> parentPlatformPageInfo = storager.queryParentPlatformList(page, count);


@@ -135,10 +134,7 @@


     * @param parentPlatform


     * @return


     */


    @ApiOperation("添加上级平台信息")


    @ApiImplicitParams({


            @ApiImplicitParam(name = "parentPlatform", value = "上级平台信息", dataTypeClass = ParentPlatform.class),


    })


    @Operation(summary = "添加上级平台信息")


    @PostMapping("/add")


    @ResponseBody


    public ResponseEntity<WVPResult<String>> addPlatform(@RequestBody ParentPlatform parentPlatform) {


@@ -210,10 +206,7 @@


     * @param parentPlatform


     * @return


     */


    @ApiOperation("保存上级平台信息")


    @ApiImplicitParams({


            @ApiImplicitParam(name = "parentPlatform", value = "上级平台信息", dataTypeClass = ParentPlatform.class),


    })


    @Operation(summary = "保存上级平台信息")


    @PostMapping("/save")


    @ResponseBody


    public ResponseEntity<WVPResult<String>> savePlatform(@RequestBody ParentPlatform parentPlatform) {


@@ -285,10 +278,8 @@


     * @param serverGBId 上级平台国标ID


     * @return


     */


    @ApiOperation("删除上级平台")


    @ApiImplicitParams({


            @ApiImplicitParam(name = "serverGBId", value = "上级平台国标ID", dataTypeClass = String.class),


    })


    @Operation(summary = "删除上级平台")


    @Parameter(name = "serverGBId", description = "上级平台的国标编号")


    @DeleteMapping("/delete/{serverGBId}")


    @ResponseBody


    public ResponseEntity<String> deletePlatform(@PathVariable String serverGBId) {


@@ -338,17 +329,12 @@


     * @param serverGBId 上级平台国标ID


     * @return


     */


    @ApiOperation("查询上级平台是否存在")


    @ApiImplicitParams({


            @ApiImplicitParam(name = "serverGBId", value = "上级平台国标ID", dataTypeClass = String.class),


    })


    @Operation(summary = "查询上级平台是否存在")


    @Parameter(name = "serverGBId", description = "上级平台的国标编号")


    @GetMapping("/exit/{serverGBId}")


    @ResponseBody


    public ResponseEntity<String> exitPlatform(@PathVariable String serverGBId) {




//        if (logger.isDebugEnabled()) {


//            logger.debug("查询上级平台是否存在API调用：" + serverGBId);


//        }


        ParentPlatform parentPlatform = storager.queryParentPlatByServerGBId(serverGBId);


        return new ResponseEntity<>(String.valueOf(parentPlatform != null), HttpStatus.OK);


    }


@@ -364,16 +350,14 @@


     * @param channelType 通道类型


     * @return


     */


    @ApiOperation("分页查询级联平台的所有所有通道")


    @ApiImplicitParams({


            @ApiImplicitParam(name = "page", value = "当前页", dataTypeClass = Integer.class),


            @ApiImplicitParam(name = "count", value = "每页条数", dataTypeClass = Integer.class),


            @ApiImplicitParam(name = "platformId", value = "上级平台ID", dataTypeClass = String.class),


            @ApiImplicitParam(name = "catalogId", value = "目录ID", dataTypeClass = String.class),


            @ApiImplicitParam(name = "query", value = "查询内容", dataTypeClass = String.class),


            @ApiImplicitParam(name = "online", value = "是否在线", dataTypeClass = Boolean.class),


            @ApiImplicitParam(name = "channelType", value = "通道类型", dataTypeClass = Boolean.class),


    })


    @Operation(summary = "查询上级平台是否存在")


    @Parameter(name = "page", description = "当前页", required = true)


    @Parameter(name = "count", description = "每页条数", required = true)


    @Parameter(name = "platformId", description = "上级平台的国标编号")


    @Parameter(name = "catalogId", description = "目录ID")


    @Parameter(name = "query", description = "查询内容")


    @Parameter(name = "online", description = "是否在线")


    @Parameter(name = "channelType", description = "通道类型")


    @GetMapping("/channel_list")


    @ResponseBody


    public PageInfo<ChannelReduce> channelList(int page, int count,


@@ -383,9 +367,6 @@


                                               @RequestParam(required = false) Boolean online,


                                               @RequestParam(required = false) Boolean channelType) {




//        if (logger.isDebugEnabled()) {


//            logger.debug("查询所有所有通道API调用");


//        }


        if (StringUtils.isEmpty(platformId)) {


            platformId = null;


        }


@@ -406,10 +387,7 @@


     * @param param 通道关联参数


     * @return


     */


    @ApiOperation("向上级平台添加国标通道")


    @ApiImplicitParams({


            @ApiImplicitParam(name = "param", value = "通道关联参数", dataTypeClass = UpdateChannelParam.class),


    })


    @Operation(summary = "向上级平台添加国标通道")


    @PostMapping("/update_channel_for_gb")


    @ResponseBody


    public ResponseEntity<String> updateChannelForGB(@RequestBody UpdateChannelParam param) {


@@ -428,10 +406,7 @@


     * @param param 通道关联参数


     * @return


     */


    @ApiOperation("从上级平台移除国标通道")


    @ApiImplicitParams({


            @ApiImplicitParam(name = "param", value = "通道关联参数", dataTypeClass = UpdateChannelParam.class),


    })


    @Operation(summary = "从上级平台移除国标通道")


    @DeleteMapping("/del_channel_for_gb")


    @ResponseBody


    public ResponseEntity<String> delChannelForGB(@RequestBody UpdateChannelParam param) {


@@ -451,11 +426,9 @@


     * @param parentId   目录父ID


     * @return


     */


    @ApiOperation("获取目录")


    @ApiImplicitParams({


            @ApiImplicitParam(name = "platformId", value = "平台ID", dataTypeClass = String.class, required = true),


            @ApiImplicitParam(name = "parentId", value = "目录父ID", dataTypeClass = String.class, required = true),


    })


    @Operation(summary = "获取目录")


    @Parameter(name = "platformId", description = "上级平台的国标编号", required = true)


    @Parameter(name = "parentId", description = "父级目录的国标编号", required = true)


    @GetMapping("/catalog")


    @ResponseBody


    public ResponseEntity<WVPResult<List<PlatformCatalog>>> getCatalogByPlatform(String platformId, String parentId) {


@@ -463,13 +436,15 @@


        if (logger.isDebugEnabled()) {


            logger.debug("查询目录,platformId: {}, parentId: {}", platformId, parentId);


        }


        ParentPlatform platform = storager.queryParentPlatByServerGBId(platformId);


        if (platform == null) {


            return new ResponseEntity<>(new WVPResult<>(400, "平台未找到", null), HttpStatus.OK);


        }


        if (platformId.equals(parentId)) {


            parentId = platform.getDeviceGBId();


        }


        List<PlatformCatalog> platformCatalogList = storager.getChildrenCatalogByPlatform(platformId, parentId);


        // 查询下属的国标通道


//        List<PlatformCatalog> catalogsForChannel = storager.queryChannelInParentPlatformAndCatalog(platformId, parentId);


        // 查询下属的直播流通道


//        List<PlatformCatalog> catalogsForStream = storager.queryStreamInParentPlatformAndCatalog(platformId, parentId);


//        platformCatalogList.addAll(catalogsForChannel);


//        platformCatalogList.addAll(catalogsForStream);




        WVPResult<List<PlatformCatalog>> result = new WVPResult<>();


        result.setCode(0);


        result.setMsg("success");


@@ -483,10 +458,7 @@


     * @param platformCatalog 目录


     * @return


     */


    @ApiOperation("添加目录")


    @ApiImplicitParams({


            @ApiImplicitParam(name = "platformCatalog", value = "目录信息", dataTypeClass = PlatformCatalog.class, required = true),


    })


    @Operation(summary = "添加目录")


    @PostMapping("/catalog/add")


    @ResponseBody


    public ResponseEntity<WVPResult<List<PlatformCatalog>>> addCatalog(@RequestBody PlatformCatalog platformCatalog) {


@@ -520,10 +492,7 @@


     * @param platformCatalog 目录


     * @return


     */


    @ApiOperation("编辑目录")


    @ApiImplicitParams({


            @ApiImplicitParam(name = "platformCatalog", value = "目录信息", dataTypeClass = PlatformCatalog.class, required = true),


    })


    @Operation(summary = "编辑目录")


    @PostMapping("/catalog/edit")


    @ResponseBody


    public ResponseEntity<WVPResult<List<PlatformCatalog>>> editCatalog(@RequestBody PlatformCatalog platformCatalog) {


@@ -553,12 +522,12 @@


     * 删除目录


     *


     * @param id 目录Id


     * @param platformId 平台Id


     * @return


     */


    @ApiOperation("删除目录")


    @ApiImplicitParams({


            @ApiImplicitParam(name = "id", value = "目录Id", dataTypeClass = String.class, required = true),


    })


    @Operation(summary = "删除目录")


    @Parameter(name = "id", description = "目录Id", required = true)


    @Parameter(name = "platformId", description = "平台Id", required = true)


    @DeleteMapping("/catalog/del")


    @ResponseBody


    public ResponseEntity<WVPResult<String>> delCatalog(String id, String platformId) {


@@ -601,10 +570,7 @@


     * @param platformCatalog 关联的信息


     * @return


     */


    @ApiOperation("删除关联")


    @ApiImplicitParams({


            @ApiImplicitParam(name = "platformCatalog", value = "关联的信息", dataTypeClass = PlatformCatalog.class, required = true),


    })


    @Operation(summary = "删除关联")


    @DeleteMapping("/catalog/relation/del")


    @ResponseBody


    public ResponseEntity<WVPResult<List<PlatformCatalog>>> delRelation(@RequestBody PlatformCatalog platformCatalog) {


@@ -633,11 +599,9 @@


     * @param catalogId  目录Id


     * @return


     */


    @ApiOperation("修改默认目录")


    @ApiImplicitParams({


            @ApiImplicitParam(name = "platformId", value = "平台Id", dataTypeClass = String.class, required = true),


            @ApiImplicitParam(name = "catalogId", value = "目录Id", dataTypeClass = String.class, required = true),


    })


    @Operation(summary = "修改默认目录")


    @Parameter(name = "catalogId", description = "目录Id", required = true)


    @Parameter(name = "platformId", description = "平台Id", required = true)


    @PostMapping("/catalog/default/update")


    @ResponseBody


    public ResponseEntity<WVPResult<String>> setDefaultCatalog(String platformId, String catalogId) {