diff --git a/storeroom/src/main/java/com/storeroom/modules/device/controller/DeviceController.java b/storeroom/src/main/java/com/storeroom/modules/device/controller/DeviceController.java index b4ed59c..29606d3 100644 --- a/storeroom/src/main/java/com/storeroom/modules/device/controller/DeviceController.java +++ b/storeroom/src/main/java/com/storeroom/modules/device/controller/DeviceController.java @@ -180,8 +180,6 @@ public class DeviceController { String fileName = deviceCamerBindService.downloadVideo(alarmDeseCaBinetLog.getI64Ts(), item.getDeviceInfoId(), item.getId()); cameraInfo.setDownloadLink(fileName); cameraInfoList.add(cameraInfo); - - }); cameraInfoService.createAll(cameraInfoList); } diff --git a/storeroom/src/main/java/com/storeroom/modules/device/controller/VideoMonitoringController.java b/storeroom/src/main/java/com/storeroom/modules/device/controller/VideosController.java similarity index 63% rename from storeroom/src/main/java/com/storeroom/modules/device/controller/VideoMonitoringController.java rename to storeroom/src/main/java/com/storeroom/modules/device/controller/VideosController.java index e50f252..b86d3b9 100644 --- a/storeroom/src/main/java/com/storeroom/modules/device/controller/VideoMonitoringController.java +++ b/storeroom/src/main/java/com/storeroom/modules/device/controller/VideosController.java @@ -2,7 +2,9 @@ package com.storeroom.modules.device.controller; import com.storeroom.annotaion.rest.AnonymousGetMapping; +import com.storeroom.modules.device.service.CameraInfoService; import com.storeroom.modules.device.service.VideoMonitoringService; +import com.storeroom.modules.device.service.dto.CameraInfoCrieria; import com.storeroom.modules.device.service.dto.VideoMonitoringCrieria; import com.storeroom.utils.ApiResponse; import io.swagger.annotations.Api; @@ -15,14 +17,17 @@ import org.springframework.web.bind.annotation.RestController; @RestController @RequiredArgsConstructor @Api(tags = "视频监控") -@RequestMapping("/api/videomonitorng/") -public class VideoMonitoringController { +@RequestMapping("/api/videos/") +public class VideosController { - private final VideoMonitoringService videoMonitoringService; + + private final CameraInfoService cameraInfoService; @ApiOperation("视频监控列表") @AnonymousGetMapping("list") - public ApiResponse getList(VideoMonitoringCrieria crieria, Pageable pageable) { - return ApiResponse.success(videoMonitoringService.queryAll(crieria, pageable)); + public ApiResponse getList(CameraInfoCrieria crieria, Pageable pageable) { + return ApiResponse.success(cameraInfoService.queryAll(crieria, pageable)); } + + } diff --git a/storeroom/src/main/java/com/storeroom/modules/device/service/CameraInfoService.java b/storeroom/src/main/java/com/storeroom/modules/device/service/CameraInfoService.java index e6eb27c..2d0c8aa 100644 --- a/storeroom/src/main/java/com/storeroom/modules/device/service/CameraInfoService.java +++ b/storeroom/src/main/java/com/storeroom/modules/device/service/CameraInfoService.java @@ -1,6 +1,9 @@ package com.storeroom.modules.device.service; import com.storeroom.modules.device.domain.CameraInfo; +import com.storeroom.modules.device.service.dto.CameraInfoCrieria; +import com.storeroom.modules.device.service.dto.VideoMonitoringCrieria; +import org.springframework.data.domain.Pageable; import javax.servlet.http.HttpServletResponse; import java.io.IOException; @@ -22,4 +25,12 @@ public interface CameraInfoService { */ void createAll(List cameraInfoList); + /** + * 查询全部 + * @param crieria + * @param pageable + * @return + */ + Object queryAll(CameraInfoCrieria crieria, Pageable pageable); + } diff --git a/storeroom/src/main/java/com/storeroom/modules/device/service/dto/CameraInfoCrieria.java b/storeroom/src/main/java/com/storeroom/modules/device/service/dto/CameraInfoCrieria.java new file mode 100644 index 0000000..a5d4254 --- /dev/null +++ b/storeroom/src/main/java/com/storeroom/modules/device/service/dto/CameraInfoCrieria.java @@ -0,0 +1,20 @@ +package com.storeroom.modules.device.service.dto; + +import com.storeroom.annotaion.Query; +import lombok.Data; + +import java.io.Serializable; +import java.sql.Timestamp; +import java.util.List; + + +@Data +public class CameraInfoCrieria implements Serializable { + + @Query + private String alarmEvent; + + + @Query(type = Query.Type.BETWEEN) + private List createTime; +} diff --git a/storeroom/src/main/java/com/storeroom/modules/device/service/impl/CameraInfoServiceImpl.java b/storeroom/src/main/java/com/storeroom/modules/device/service/impl/CameraInfoServiceImpl.java index d9b139f..8610faf 100644 --- a/storeroom/src/main/java/com/storeroom/modules/device/service/impl/CameraInfoServiceImpl.java +++ b/storeroom/src/main/java/com/storeroom/modules/device/service/impl/CameraInfoServiceImpl.java @@ -1,9 +1,16 @@ package com.storeroom.modules.device.service.impl; import com.storeroom.modules.device.domain.CameraInfo; +import com.storeroom.modules.device.domain.VideoMonitoring; import com.storeroom.modules.device.repository.CameraInfoRepository; import com.storeroom.modules.device.service.CameraInfoService; +import com.storeroom.modules.device.service.dto.CameraInfoCrieria; +import com.storeroom.modules.device.service.dto.VideoMonitoringCrieria; +import com.storeroom.utils.PageUtil; +import com.storeroom.utils.QueryHelp; import lombok.RequiredArgsConstructor; +import org.springframework.data.domain.Page; +import org.springframework.data.domain.Pageable; import org.springframework.stereotype.Service; import javax.servlet.http.HttpServletResponse; @@ -28,5 +35,11 @@ public class CameraInfoServiceImpl implements CameraInfoService { cameraInfoRepository.saveAll(cameraInfoList); } + @Override + public Object queryAll(CameraInfoCrieria crieria, Pageable pageable) { + Page page = cameraInfoRepository.findAll((root, query, criteriaBuilder) -> QueryHelp.getPredicate(root, crieria, criteriaBuilder), pageable); + return PageUtil.toPage(page); + } + } diff --git a/storeroom/src/main/java/com/storeroom/modules/storeroom3d/config/common/VideoClient.java b/storeroom/src/main/java/com/storeroom/modules/storeroom3d/config/common/VideoClient.java index c81409b..52468a8 100644 --- a/storeroom/src/main/java/com/storeroom/modules/storeroom3d/config/common/VideoClient.java +++ b/storeroom/src/main/java/com/storeroom/modules/storeroom3d/config/common/VideoClient.java @@ -331,6 +331,12 @@ public class VideoClient { System.err.println("NetFileDownload:DOWNLOAD_CMD_TIMESPAN fail! iRet=" + iRet); } + try { + Thread.sleep(1000); + } catch (InterruptedException e) { + e.printStackTrace(); + } + return fileName; } }