| | |
| | | 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; |
| | |
| | | /** |
| | | * 级联平台管理 |
| | | */ |
| | | @Api(tags = "级联平台管理") |
| | | @Tag(name = "级联平台管理") |
| | | @CrossOrigin |
| | | @RestController |
| | | @RequestMapping("/api/platform") |
| | |
| | | * |
| | | * @return |
| | | */ |
| | | @ApiOperation("获取国标服务的配置") |
| | | @Operation(summary = "获取国标服务的配置") |
| | | @GetMapping("/server_config") |
| | | public ResponseEntity<JSONObject> serverConfig() { |
| | | JSONObject result = new JSONObject(); |
| | |
| | | * |
| | | * @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); |
| | |
| | | * @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); |
| | |
| | | * @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) { |
| | |
| | | * @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) { |
| | |
| | | * @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) { |
| | |
| | | * @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); |
| | | } |
| | |
| | | * @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, |
| | |
| | | @RequestParam(required = false) Boolean online, |
| | | @RequestParam(required = false) Boolean channelType) { |
| | | |
| | | // if (logger.isDebugEnabled()) { |
| | | // logger.debug("查询所有所有通道API调用"); |
| | | // } |
| | | if (StringUtils.isEmpty(platformId)) { |
| | | platformId = null; |
| | | } |
| | |
| | | * @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) { |
| | |
| | | * @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) { |
| | |
| | | * @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) { |
| | |
| | | parentId = platform.getDeviceGBId(); |
| | | } |
| | | List<PlatformCatalog> platformCatalogList = storager.getChildrenCatalogByPlatform(platformId, parentId); |
| | | // if (platform.getTreeType().equals(TreeType.BUSINESS_GROUP)) { |
| | | // platformCatalogList = storager.getChildrenCatalogByPlatform(platformId, parentId); |
| | | // }else { |
| | | // |
| | | // } |
| | | |
| | | WVPResult<List<PlatformCatalog>> result = new WVPResult<>(); |
| | | result.setCode(0); |
| | |
| | | * @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) { |
| | |
| | | * @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) { |
| | |
| | | * 删除目录 |
| | | * |
| | | * @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) { |
| | |
| | | * @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) { |
| | |
| | | * @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) { |