对接海康

src/main/java/com/chinaitop/depot/hk/constant/ApiHkConstant.java

@@ -15,6 +15,13 @@ public interface ApiHkConstant {
      **/
     String API_HK_REGIONS = "/artemis/api/resource/v1/regions";
     /**
+     * 分页获取监控点资源
+     *
+     * @author: ybw
+     * @date: 2024/6/18
+     **/
+    String API_HK_CAMERAS = "/artemis/api/resource/v1/cameras";
+    /**
      * 根据编号获取监控点详细信息
      *
      * @author: ybw

src/main/java/com/chinaitop/depot/hk/constant/HkProtocolEnum.java

@@ -0,0 +1,61 @@
+package com.chinaitop.depot.hk.constant;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
+/**
+ * 取流协议（应用层协议）
+ * hik”:HIK私有协议，使用视频SDK进行播放时，传入此类型；
+ * “rtsp”:RTSP协议；
+ * “rtmp”:RTMP协议（RTMP协议只支持海康SDK协议、EHOME协议、ONVIF协议接入的设备；只支持H264视频编码和AAC音频编码）；
+ * “hls”:HLS协议（HLS协议只支持海康SDK协议、EHOME协议、ONVIF协议接入的设备；只支持H264视频编码和AAC音频编码）；
+ * “ws”:Websocket协议（一般用于H5视频播放器取流播放）。
+ * 参数不填，默认为HIK协议
+ *
+ * @author ybw
+ * @version V1.0
+ * @className HkProtocolEnum
+ * @date 2024/7/24
+ **/
+@AllArgsConstructor
+@Getter
+public enum HkProtocolEnum {
+
+    /**
+     * hik”:HIK私有协议，使用视频SDK进行播放时，传入此类型；
+     *
+     * @author: ybw
+     * @date: 2024/7/24
+     **/
+    HIK("hik"),
+    /**
+     * “rtsp”:RTSP协议；
+     *
+     * @author: ybw
+     * @date: 2024/7/24
+     **/
+    RTSP("rtsp"),
+    /**
+     * “rtmp”:RTMP协议（RTMP协议只支持海康SDK协议、EHOME协议、ONVIF协议接入的设备；只支持H264视频编码和AAC音频编码）；
+     *
+     * @author: ybw
+     * @date: 2024/7/24
+     **/
+    RTMP("rtmp"),
+    /**
+     * “hls”:HLS协议（HLS协议只支持海康SDK协议、EHOME协议、ONVIF协议接入的设备；只支持H264视频编码和AAC音频编码）；
+     *
+     * @author: ybw
+     * @date: 2024/7/24
+     **/
+    HLS("hls"),
+    /**
+     * “ws”:Websocket协议（一般用于H5视频播放器取流播放）。
+     *
+     * @author: ybw
+     * @date: 2024/7/24
+     **/
+    WS("ws");
+
+    private String name;
+}

src/main/java/com/chinaitop/depot/hk/dto/req/CaptureReqDTO.java

@@ -21,22 +21,4 @@ public class CaptureReqDTO {
      * @date: 2024/6/19
      **/
     private String cameraIndexCode;
-    
-    
-    // monitor_camera的主键
-    private Integer id;
-    
-    
-    //单位id
-    private Integer orgId;
-    
-    
-    //仓房id
-    private Integer houseId;
-    
-    
-   //仓房id
-    private Integer wareHouseId;
-    
-    
 }

src/main/java/com/chinaitop/depot/hk/dto/req/Preview2ReqDTO.java

@@ -0,0 +1,38 @@
+package com.chinaitop.depot.hk.dto.req;
+
+import lombok.Data;
+
+/**
+ * 获取监控点预览取流 获取监控点预览取流  URLv2
+ *
+ * @author ybw
+ * @version V1.0
+ * @className PreviewReqVO
+ * @date 2024/6/20
+ **/
+@Data
+public class Preview2ReqDTO {
+    /**
+     * 监控点编号
+     *
+     * @author: ybw
+     * @date: 2024/6/19
+     **/
+    private String cameraIndexCode;
+
+    /**
+     * 取流协议（应用层协议），
+     * “hik”:HIK私有协议，使用视频SDK进行播放时，传入此类型；
+     * “rtsp”:RTSP协议；
+     * “rtmp”:RTMP协议（RTMP协议只支持海康SDK协议、EHOME协议、ONVIF协议接入的设备；只支持H264视频编码和AAC音频编码）；
+     * “hls”:HLS协议（HLS协议只支持海康SDK协议、EHOME协议、ONVIF协议接入的设备；只支持H264视频编码和AAC音频编码）；
+     * “ws”:Websocket协议（一般用于H5视频播放器取流播放）。
+     * 参数不填，默认为HIK协议
+     */
+    private String protocol;
+
+    public Preview2ReqDTO(PreviewReqDTO previewReqDTO) {
+        this.cameraIndexCode = previewReqDTO.getCameraIndexCode();
+        this.protocol = previewReqDTO.getProtocol().getName();
+    }
+}

src/main/java/com/chinaitop/depot/hk/dto/req/PreviewReqDTO.java

@@ -1,5 +1,6 @@
 package com.chinaitop.depot.hk.dto.req;
 
+import com.chinaitop.depot.hk.constant.HkProtocolEnum;
 import lombok.AllArgsConstructor;
 import lombok.Data;
 
@@ -21,4 +22,15 @@ public class PreviewReqDTO {
      * @date: 2024/6/19
      **/
     private String cameraIndexCode;
+
+    /**
+     * 取流协议（应用层协议），
+     * “hik”:HIK私有协议，使用视频SDK进行播放时，传入此类型；
+     * “rtsp”:RTSP协议；
+     * “rtmp”:RTMP协议（RTMP协议只支持海康SDK协议、EHOME协议、ONVIF协议接入的设备；只支持H264视频编码和AAC音频编码）；
+     * “hls”:HLS协议（HLS协议只支持海康SDK协议、EHOME协议、ONVIF协议接入的设备；只支持H264视频编码和AAC音频编码）；
+     * “ws”:Websocket协议（一般用于H5视频播放器取流播放）。
+     * 参数不填，默认为HIK协议
+     */
+    private HkProtocolEnum protocol;
 }

src/main/java/com/chinaitop/depot/hk/dto/res/CamerasResDTO.java

@@ -0,0 +1,62 @@
+package com.chinaitop.depot.hk.dto.res;
+
+import lombok.Data;
+
+/**
+ * @author ybw
+ * @version V1.0
+ * @className CamerasResDTO
+ * @date 2024/7/23
+ **/
+@Data
+public class CamerasResDTO {
+    /**
+     * 海拔
+     *
+     * @author: ybw
+     * @date: 2024/7/23
+     **/
+    private String altitude;
+    /**
+     * 监控点唯一标识
+     *
+     * @author: ybw
+     * @date: 2024/7/23
+     **/
+    private String cameraIndexCode;
+    private String cameraName;
+    private int cameraType;
+    private String cameraTypeName;
+    private String capabilitySet;
+    private String capabilitySetName;
+    private String intelligentSet;
+    private String intelligentSetName;
+    private String channelNo;
+    private String channelType;
+    private String channelTypeName;
+    private String createTime;
+    private String encodeDevIndexCode;
+    private String encodeDevResourceType;
+    private String encodeDevResourceTypeName;
+    private String gbIndexCode;
+    private String installLocation;
+    private String keyBoardCode;
+    private String latitude;
+    private String longitude;
+    private int pixel;
+    private int ptz;
+    private int ptzController;
+    private String ptzControllerName;
+    private String ptzName;
+    private String recordLocation;
+    private String recordLocationName;
+    private String regionIndexCode;
+    private int status;
+    private String statusName;
+    private int transType;
+    private String transTypeName;
+    private String treatyType;
+    private String treatyTypeName;
+    private String viewshed;
+    private String updateTime;
+}

src/main/java/com/chinaitop/depot/hk/service/HkService.java

@@ -25,6 +25,17 @@ public interface HkService {
      * @date: 2024/6/19
      **/
     PageResDTO<RegionResDTO> getRegions(PageReqDTO pageReqDTO);
+
+    /**
+     * 分页获取监控点资源
+     *
+     * @param pageReqDTO
+     * @methodName: getCameras
+     * @return: com.ybw.dto.res.PageResDTO<com.ybw.dto.res.CamerasResDTO>
+     * @author: ybw
+     * @date: 2024/7/23
+     **/
+    PageResDTO<CamerasResDTO> getCameras(PageReqDTO pageReqDTO);
     //----------------------------------------视频应用服务-----------------------------------------------
 
     /**

src/main/java/com/chinaitop/depot/hk/service/impl/HkServiceImpl.java

@@ -51,6 +51,26 @@ public class HkServiceImpl implements HkService {
         return null;
     }
 
+    @Override
+    public PageResDTO<CamerasResDTO> getCameras(PageReqDTO pageReqDTO) {
+        try {
+            Map<String, String> path = getPath(ApiHkConstant.API_HK_CAMERAS);
+            String result = ArtemisHttpUtil.doPostStringArtemis(artemisConfig, path, JSON.toJSONString(pageReqDTO), null, null, ContentType.CONTENT_TYPE_JSON);
+            ResultResDTO<PageResDTO<CamerasResDTO>> resultResDTO = JSONObject.parseObject(
+                    result,
+                    new TypeReference<ResultResDTO<PageResDTO<CamerasResDTO>>>() {
+                    }
+            );
+            log.info("{}", JSON.toJSONString(resultResDTO));
+            if (ApiHkConstant.Code.SUCCESS.equals(resultResDTO.getCode())) {
+                return resultResDTO.getData();
+            }
+        } catch (Exception e) {
+            log.error("getRegions error:", e);
+        }
+        return null;
+    }
+
     /**
      * 获取接口地址
      *
@@ -95,7 +115,9 @@ public class HkServiceImpl implements HkService {
         try {
             // 接口地址
             Map<String, String> path = getPath(ApiHkConstant.API_HK_PREVIEW_URL);
-            String result = ArtemisHttpUtil.doPostStringArtemis(artemisConfig, path, JSON.toJSONString(previewReqDTO), null, null,  ContentType.CONTENT_TYPE_JSON);
+            //对象转换
+            Preview2ReqDTO preview2ReqDTO = new Preview2ReqDTO(previewReqDTO);
+            String result = ArtemisHttpUtil.doPostStringArtemis(artemisConfig, path, JSON.toJSONString(preview2ReqDTO), null, null,  ContentType.CONTENT_TYPE_JSON);
             ResultResDTO<PreviewResDTO> resultResDTO = JSONObject.parseObject(
                     result,
                     new TypeReference<ResultResDTO<PreviewResDTO>>() {

src/test/java/com/chinaitop/depot/hk/service/HkServiceTest.java

@@ -1,8 +1,11 @@
 package com.chinaitop.depot.hk.service;
 
+import com.alibaba.fastjson.JSON;
 import com.chinaitop.depot.DepotMonitorApplication;
-import com.chinaitop.depot.hk.dto.req.CameraReqDTO;
-import com.chinaitop.depot.hk.dto.req.PageReqDTO;
+import com.chinaitop.depot.hk.constant.HkProtocolEnum;
+import com.chinaitop.depot.hk.dto.req.*;
+import com.chinaitop.depot.hk.dto.res.*;
+import lombok.extern.slf4j.Slf4j;
 import org.junit.Test;
 import org.junit.runner.RunWith;
 import org.springframework.boot.test.context.SpringBootTest;
@@ -12,6 +15,7 @@ import javax.annotation.Resource;
 
 @RunWith(SpringRunner.class)
 @SpringBootTest(classes = DepotMonitorApplication.class)
+@Slf4j
 public class HkServiceTest {
 
     @Resource
@@ -19,11 +23,54 @@ public class HkServiceTest {
 
     @Test
     public void getRegions() {
-        hkService.getRegions(new PageReqDTO(1, 30));
+        PageResDTO<RegionResDTO> pageResDTO = hkService.getRegions(new PageReqDTO(1, 30));
+        log.info("pageResDTO:{}", JSON.toJSONString(pageResDTO));
+    }
+
+    @Test
+    public void getCameras() {
+        PageResDTO<CamerasResDTO> pageResDTO = hkService.getCameras(new PageReqDTO(1, 30));
+        log.info("pageResDTO:{}", JSON.toJSONString(pageResDTO));
     }
 
     @Test
     public void getCamera() {
-        hkService.getCamera(new CameraReqDTO(""));
+        CameraResDTO cameraResDTO = hkService.getCamera(new CameraReqDTO("92768838d53b42788431697b657a507e"));
+        log.info("cameraResDTO:{}", JSON.toJSONString(cameraResDTO));
+    }
+
+    @Test
+    public void previewURLs() {
+        PreviewResDTO previewResDTO = hkService.previewURLs(new PreviewReqDTO("92768838d53b42788431697b657a507e", HkProtocolEnum.WS));
+        log.info("previewResDTO:{}", JSON.toJSONString(previewResDTO));
+    }
+
+    @Test
+    public void playbackURLs() {
+        PlaybackReqDTO playbackReqDTO = new PlaybackReqDTO();
+        playbackReqDTO.setCameraIndexCode("1234");
+        playbackReqDTO.setBeginTime("2017-06-14T00:00:00.000+08:00");
+        playbackReqDTO.setEndTime("2017-06-14T23:59:59.000+08:00");
+        log.info("playbackURLs:{}", JSON.toJSONString(hkService.playbackURLs(playbackReqDTO)));
+    }
+
+    @Test
+    public void recordStart() {
+        log.info("recordStart:{}", JSON.toJSONString(hkService.recordStart(new RecordStartReqDTO("1234", 6, 1))));
+    }
+
+    @Test
+    public void recordStop() {
+        hkService.recordStop(new RecordStopReqDTO("1234", "1", 1));
+    }
+
+    @Test
+    public void manualCapture() {
+        log.info("manualCapture:{}", JSON.toJSONString(hkService.manualCapture(new CaptureReqDTO("1234"))));
+    }
+
+    @Test
+    public void controlling() {
+        hkService.controlling(new ControllerReqDTO("1234", 1, "UP", 1, 1));
     }
 }