File was renamed from src/main/java/com/genersoft/iot/vmp/vmanager/platform/PlatformController.java |
| | |
| | | package com.genersoft.iot.vmp.vmanager.platform; |
| | | package com.genersoft.iot.vmp.vmanager.gb28181.platform; |
| | | |
| | | import com.alibaba.fastjson.JSONObject; |
| | | import com.genersoft.iot.vmp.gb28181.bean.ParentPlatform; |
| | | import com.genersoft.iot.vmp.gb28181.transmit.cmd.ISIPCommanderForPlatform; |
| | | import com.genersoft.iot.vmp.storager.IRedisCatchStorage; |
| | | import com.genersoft.iot.vmp.storager.IVideoManagerStorager; |
| | | import com.genersoft.iot.vmp.vmanager.platform.bean.ChannelReduce; |
| | | import com.genersoft.iot.vmp.vmanager.platform.bean.UpdateChannelParam; |
| | | 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 org.slf4j.Logger; |
| | | import org.slf4j.LoggerFactory; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | |
| | | /** |
| | | * 级联平台管理 |
| | | */ |
| | | @Api("级联平台管理") |
| | | @Api(tags = "级联平台管理") |
| | | @CrossOrigin |
| | | @RestController |
| | | @RequestMapping("/api/platform") |
| | |
| | | @Autowired |
| | | private SipConfig sipConfig; |
| | | |
| | | /** |
| | | * 获取国标服务的配置 |
| | | * @return |
| | | */ |
| | | @ApiOperation("获取国标服务的配置") |
| | | @GetMapping("/server_config") |
| | | public ResponseEntity<JSONObject> serverConfig() { |
| | | JSONObject result = new JSONObject(); |
| | |
| | | return new ResponseEntity<>(result, HttpStatus.OK); |
| | | } |
| | | |
| | | /** |
| | | * 分页查询级联平台 |
| | | * @param page 当前页 |
| | | * @param count 每页条数 |
| | | * @return |
| | | */ |
| | | @ApiOperation("分页查询级联平台") |
| | | @GetMapping("/query/{count}/{page}") |
| | | @ApiImplicitParams({ |
| | | @ApiImplicitParam(name = "page", value = "当前页", dataTypeClass = Integer.class), |
| | | @ApiImplicitParam(name = "count", value = "每页条数", dataTypeClass = Integer.class), |
| | | }) |
| | | public PageInfo<ParentPlatform> platforms(@PathVariable int page, @PathVariable int count){ |
| | | |
| | | if (logger.isDebugEnabled()) { |
| | |
| | | return storager.queryParentPlatformList(page, count); |
| | | } |
| | | |
| | | /** |
| | | * 保存上级平台信息 |
| | | * @param parentPlatform |
| | | * @return |
| | | */ |
| | | @ApiOperation("保存上级平台信息") |
| | | @ApiImplicitParams({ |
| | | @ApiImplicitParam(name = "parentPlatform", value = "上级平台信息", dataTypeClass = ParentPlatform.class), |
| | | }) |
| | | @PostMapping("/save") |
| | | @ResponseBody |
| | | public ResponseEntity<String> savePlatform(@RequestBody ParentPlatform parentPlatform){ |
| | |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * 删除上级平台 |
| | | * @param serverGBId 上级平台国标ID |
| | | * @return |
| | | */ |
| | | @ApiOperation("删除上级平台") |
| | | @ApiImplicitParams({ |
| | | @ApiImplicitParam(name = "serverGBId", value = "上级平台国标ID", dataTypeClass = String.class), |
| | | }) |
| | | @DeleteMapping("/delete/{serverGBId}") |
| | | @ResponseBody |
| | | public ResponseEntity<String> deletePlatform(@PathVariable String serverGBId){ |
| | |
| | | } |
| | | } |
| | | |
| | | @GetMapping("/exit/{deviceGbId}") |
| | | /** |
| | | * 查询上级平台是否存在 |
| | | * @param serverGBId 上级平台国标ID |
| | | * @return |
| | | */ |
| | | @ApiOperation("查询上级平台是否存在") |
| | | @ApiImplicitParams({ |
| | | @ApiImplicitParam(name = "serverGBId", value = "上级平台国标ID", dataTypeClass = String.class), |
| | | }) |
| | | @GetMapping("/exit/{serverGBId}") |
| | | @ResponseBody |
| | | public ResponseEntity<String> exitPlatform(@PathVariable String deviceGbId){ |
| | | public ResponseEntity<String> exitPlatform(@PathVariable String serverGBId){ |
| | | |
| | | if (logger.isDebugEnabled()) { |
| | | logger.debug("查询上级平台是否存在API调用:" + deviceGbId); |
| | | logger.debug("查询上级平台是否存在API调用:" + serverGBId); |
| | | } |
| | | ParentPlatform parentPlatform = storager.queryParentPlatById(deviceGbId); |
| | | ParentPlatform parentPlatform = storager.queryParentPlatById(serverGBId); |
| | | return new ResponseEntity<>(String.valueOf(parentPlatform != null), HttpStatus.OK); |
| | | } |
| | | |
| | | /** |
| | | * 分页查询级联平台的所有所有通道 |
| | | * @param page 当前页 |
| | | * @param count 每页条数 |
| | | * @param platformId 上级平台ID |
| | | * @param query 查询内容 |
| | | * @param online 是否在线 |
| | | * @param choosed 是否已选中 |
| | | * @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 = "query", value = "查询内容", dataTypeClass = String.class), |
| | | @ApiImplicitParam(name = "online", value = "是否在线", dataTypeClass = Boolean.class), |
| | | @ApiImplicitParam(name = "choosed", value = "是否已选中", dataTypeClass = Boolean.class), |
| | | @ApiImplicitParam(name = "channelType", value = "通道类型", dataTypeClass = Boolean.class), |
| | | }) |
| | | @GetMapping("/channel_list") |
| | | @ResponseBody |
| | | public PageInfo<ChannelReduce> channelList(int page, int count, |
| | |
| | | return channelReduces; |
| | | } |
| | | |
| | | |
| | | /** |
| | | * 向上级平台添加国标通道 |
| | | * @param param 通道关联参数 |
| | | * @return |
| | | */ |
| | | @ApiOperation("向上级平台添加国标通道") |
| | | @ApiImplicitParams({ |
| | | @ApiImplicitParam(name = "param", value = "通道关联参数", dataTypeClass = UpdateChannelParam.class), |
| | | }) |
| | | @PostMapping("/update_channel_for_gb") |
| | | @ResponseBody |
| | | public ResponseEntity<String> updateChannelForGB(@RequestBody UpdateChannelParam param){ |
| | |
| | | return new ResponseEntity<>(String.valueOf(result > 0), HttpStatus.OK); |
| | | } |
| | | |
| | | /** |
| | | * 从上级平台移除国标通道 |
| | | * @param param 通道关联参数 |
| | | * @return |
| | | */ |
| | | @ApiOperation("从上级平台移除国标通道") |
| | | @ApiImplicitParams({ |
| | | @ApiImplicitParam(name = "param", value = "通道关联参数", dataTypeClass = UpdateChannelParam.class), |
| | | }) |
| | | @DeleteMapping("/del_channel_for_gb") |
| | | @ResponseBody |
| | | public ResponseEntity<String> delChannelForGB(@RequestBody UpdateChannelParam param){ |