新增访问日志监控接口

hzims-service/operational/src/main/java/com/hnac/hzims/operational/station/controller/StationVideoTypeController.java

@@ -59,13 +59,13 @@ public class StationVideoTypeController extends BladeController {
 
     private final IStationService stationService;
 
-	/**秘钥appKey**/
+    /** 秘钥appKey **/
     @Value("${hzims.videoProperties.appKey}")
     private String appKey;
-	/**代理API网关nginx服务器ip端口**/
+    /** 代理API网关nginx服务器ip端口 **/
     @Value("${hzims.videoProperties.videoHost}")
     private String videoHost;
-	/**秘钥appSecret**/
+    /** 秘钥appSecret **/
     @Value("${hzims.videoProperties.appSecret}")
     private String appSecret;
 
@@ -78,17 +78,17 @@ public class StationVideoTypeController extends BladeController {
     @ApiOperation(value = "分页", notes = "传入stationVideoType")
     @OperationAnnotation(
             moduleName = "站点管理",
-			title = "视频配置",operatorType = OperatorType.MOBILE,businessType = BusinessType.GENCODE,
+            title = "视频配置", operatorType = OperatorType.MOBILE, businessType = BusinessType.GENCODE,
             action = "分页查询")
     public R<IPage<StationVideoTypeVO>> list(StationVideoTypeEntity entity, Query query) {
-		LambdaQueryWrapper<StationVideoTypeEntity> queryWrapper = Condition.getQueryWrapper(new StationVideoTypeEntity(),entity);
+        LambdaQueryWrapper<StationVideoTypeEntity> queryWrapper = Condition.getQueryWrapper(new StationVideoTypeEntity(), entity);
         queryWrapper.orderByAsc(StationVideoTypeEntity::getStationId).orderByAsc(StationVideoTypeEntity::getSort);
         IPage<StationVideoTypeEntity> pages = stationVideoTypeService.page(Condition.getPage(query), queryWrapper);
         IPage<StationVideoTypeVO> vos = StationVideoTypeWrapper.builder().pageVO(pages);
         List<StationVideoTypeVO> records = vos.getRecords();
         records.forEach(stationVideoTypeVO -> {
             R<Dept> deptR = sysClient.getDept(stationVideoTypeVO.getDeptId());
-			if(deptR.isSuccess()){
+            if (deptR.isSuccess()) {
                 stationVideoTypeVO.setDeptName(Optional.ofNullable(deptR.getData()).map(Dept::getDeptName).orElse(null));
             }
         });
@@ -103,17 +103,17 @@ public class StationVideoTypeController extends BladeController {
     @ApiOperation(value = "新增")
     public R save(@Valid @RequestBody StationVideoTypeEntity req) {
         List<StationVideoTypeEntity> list = stationVideoTypeService.list(Wrappers.<StationVideoTypeEntity>lambdaQuery()
-			.eq(StationVideoTypeEntity::getStationId,req.getStationId())
+                .eq(StationVideoTypeEntity::getStationId, req.getStationId())
-			.eq(StationVideoTypeEntity::getName,req.getName())
+                .eq(StationVideoTypeEntity::getName, req.getName())
         );
         StationVO stationVO = stationService.getStationByCode(req.getStationId());
-		if(ObjectUtil.isNotEmpty(stationVO)){
+        if (ObjectUtil.isNotEmpty(stationVO)) {
             req.setCreateDept(stationVO.getRefDept());
         }
         req.setAppKey(appKey);
         req.setVideoHost(videoHost);
         req.setAppSecret(appSecret);
-		return list.size()>0 ? R.fail(400,"该名称已录入数据，请找到相应记录做修改处理") : R.status(stationVideoTypeService.save(req));
+        return list.size() > 0 ? R.fail(400, "该名称已录入数据，请找到相应记录做修改处理") : R.status(stationVideoTypeService.save(req));
     }
 
     /**
@@ -124,11 +124,11 @@ public class StationVideoTypeController extends BladeController {
     @ApiOperation(value = "修改", notes = "传入stationVideoType")
     public R update(@Valid @RequestBody StationVideoTypeEntity req) {
         List<StationVideoTypeEntity> list = stationVideoTypeService.list(Wrappers.<StationVideoTypeEntity>lambdaQuery()
-			.eq(StationVideoTypeEntity::getStationId,req.getStationId())
+                .eq(StationVideoTypeEntity::getStationId, req.getStationId())
-			.eq(StationVideoTypeEntity::getName,req.getName())
+                .eq(StationVideoTypeEntity::getName, req.getName())
-			.ne(StationVideoTypeEntity::getId,req.getId())
+                .ne(StationVideoTypeEntity::getId, req.getId())
         );
-		return list.size()>0 ? R.fail(400,"该名称/视频源已录入数据，请找到相应记录做修改处理") : R.status(stationVideoTypeService.updateById(req));
+        return list.size() > 0 ? R.fail(400, "该名称/视频源已录入数据，请找到相应记录做修改处理") : R.status(stationVideoTypeService.updateById(req));
     }
 
     /**
@@ -145,10 +145,7 @@ public class StationVideoTypeController extends BladeController {
     @RequestMapping(value = "/getVideoMonitor", method = {RequestMethod.GET, RequestMethod.POST})
     @ApiOperationSupport(order = 50)
     @ApiOperation(value = "获取视频监测列表", notes = "获取视频监测列表")
-	@OperationAnnotation(moduleName = "视频监控",title = "视频监控",operatorType = OperatorType.APPSYSTEMS,businessType =
+    public R<List<VideoMonitorVO>> getVideoMonitor() {
-			BusinessType.GENCODE,
-			action = "获取视频监测列表")
-	public R<List<VideoMonitorVO>> getVideoMonitor(){
         List<VideoMonitorVO> result = stationVideoTypeService.getVideoMonitor();
         return R.data(result);
     }
@@ -156,17 +153,17 @@ public class StationVideoTypeController extends BladeController {
     @ApiLog
     @RequestMapping(value = "/getById", method = {RequestMethod.GET, RequestMethod.POST})
     @ApiOperationSupport(order = 60)
-	@OperationAnnotation(moduleName = "视频监控",title = "视频监控",operatorType = OperatorType.APPSYSTEMS,businessType = BusinessType.GENCODE,
-			action = "获取视频监测对象")
     @ApiOperation(value = "获取视频监测对象", notes = "获取视频监测对象")
-	public R<StationVideoTypeEntity> getById(@RequestParam Long id,@RequestParam int streamType){
+    public R<StationVideoTypeEntity> getById(@RequestParam Long id, @RequestParam int streamType) {
-		return R.data(stationVideoTypeService.getById(id,streamType));
+        return R.data(stationVideoTypeService.getById(id, streamType));
     }
+
     @ApiLog
     @RequestMapping(value = "/getHikVideo", method = {RequestMethod.GET, RequestMethod.POST})
-	public R<String> getHikVideo(){
+    public R<String> getHikVideo() {
         return R.data(stationVideoTypeService.getHikVideo());
     }
+
     @ApiLog
     @RequestMapping(value = "/getStationsByVideo", method = {RequestMethod.GET, RequestMethod.POST})
     @ApiOperationSupport(order = 70)
@@ -174,32 +171,37 @@ public class StationVideoTypeController extends BladeController {
     public R<List<StationEntity>> getStationsByVideo() {
         return R.data(stationVideoTypeService.getStationsByVideo());
     }
+
     @ApiLog
     @GetMapping("/getStationVideoOrderBySort")
     @ApiOperationSupport(order = 80)
     @ApiOperation(value = "根据站点、视频排序获取视频列表", notes = "根据站点、视频排序获取视频列表")
-	public R<IPage> getStationVideoOrderBySort(StationVideoTypeDTO stationVideoTypeDTO,Query query) {
+    public R<IPage> getStationVideoOrderBySort(StationVideoTypeDTO stationVideoTypeDTO, Query query) {
-		return R.data(stationVideoTypeService.getStationVideoOrderBySort(stationVideoTypeDTO,query));
+        return R.data(stationVideoTypeService.getStationVideoOrderBySort(stationVideoTypeDTO, query));
     }
+
     @ApiLog
     @RequestMapping(value = "/getVideoByIdsAndType", method = {RequestMethod.GET, RequestMethod.POST})
     @ApiOperationSupport(order = 90)
     @ApiOperation(value = "根据视频ID、视频流类型获取视频地址", notes = "根据视频ID、视频流类型获取视频地址")
     public R<List<StationVideoTypeEntity>> getVideoByIdsAndType(@RequestParam String ids, @RequestParam String type) {
-		return R.data(stationVideoTypeService.getVideoByIdsAndType(ids,type));
+        return R.data(stationVideoTypeService.getVideoByIdsAndType(ids, type));
     }
+
     @ApiLog
     @GetMapping("/getVideoByIds")
     @ApiOperationSupport(order = 100)
     @ApiOperation(value = "根据视频ID获取视频地址", notes = "根据视频ID获取视频地址")
-	public R<List<StationVideoTypeEntity>> getVideoByIds(@RequestParam String ids,@RequestParam String randomCode) {
+    public R<List<StationVideoTypeEntity>> getVideoByIds(@RequestParam String ids, @RequestParam String randomCode) {
-		return R.data(stationVideoTypeService.getVideoByIds(ids,randomCode));
+        return R.data(stationVideoTypeService.getVideoByIds(ids, randomCode));
     }
+
     @ApiLog
-	@RequestMapping(value = "/getVideoReviewerToken",method = {RequestMethod.GET, RequestMethod.POST})
+    @RequestMapping(value = "/getVideoReviewerToken", method = {RequestMethod.GET, RequestMethod.POST})
     public R<String> getVideoReviewerToken() {
         return R.data(stationVideoTypeService.getVideoReviewerToken());
     }
+
     @ApiLog
     @GetMapping("/getVideoMonitorByAgency")
     @ApiOperationSupport(order = 110)
@@ -207,6 +209,7 @@ public class StationVideoTypeController extends BladeController {
     public R<List<VideoMonitorVO>> getVideoMonitorByAgency(@RequestParam @ApiParam("视频分类") String type) {
         return R.data(stationVideoTypeService.getVideoMonitor(type));
     }
+
     @ApiLog
     @GetMapping("/getHikVisionStations")
     @ApiOperationSupport(order = 120)
@@ -214,6 +217,7 @@ public class StationVideoTypeController extends BladeController {
     public R<List<JSONObject>> getHikVisionStations() {
         return R.data(stationVideoTypeService.getHikVisionStations());
     }
+
     @ApiLog
     @GetMapping("/getMonitorsByStation")
     @ApiOperationSupport(order = 130)
@@ -221,4 +225,14 @@ public class StationVideoTypeController extends BladeController {
     public R<Map<HikDeviceResp, List<HikMonitorResp>>> getMonitorsByStation(@RequestParam String stationId) {
         return R.data(stationVideoTypeService.getMonitorsByStation(stationId));
     }
+
+
+    @OperationAnnotation(moduleName = "视频监控", title = "视频监控", operatorType = OperatorType.APPSYSTEMS, businessType =
+            BusinessType.GENCODE,
+            action = "获取视频监测列表")
+    @GetMapping("/videoimages")
+    public R videoimages() {
+        return R.success("视频监控处理成功");
+    }
+
 }