From 4f6290bb416e17e692eafcb5bb40ee15af5148fe Mon Sep 17 00:00:00 2001
From: fuliqi <fuliqi@qq.com>
Date: 星期一, 12 八月 2024 14:20:55 +0800
Subject: [PATCH] 海康接口重写

---
 /dev/null                                         |   60 ------------------------------
 ycl-server/src/main/java/com/ycl/task/HKTask.java |   48 +++---------------------
 2 files changed, 6 insertions(+), 102 deletions(-)

diff --git a/ycl-server/src/main/java/com/ycl/feign/HKApi.java b/ycl-server/src/main/java/com/ycl/feign/HKApi.java
deleted file mode 100644
index c8d77ef..0000000
--- a/ycl-server/src/main/java/com/ycl/feign/HKApi.java
+++ /dev/null
@@ -1,60 +0,0 @@
-package com.ycl.feign;
-
-import com.alibaba.fastjson2.JSON;
-import com.alibaba.fastjson2.JSONObject;
-import com.hikvision.artemis.sdk.ArtemisHttpUtil;
-import com.hikvision.artemis.sdk.config.ArtemisConfig;
-import com.ycl.platform.domain.param.HK.FaceDetectParam;
-import com.ycl.utils.DateUtils;
-import lombok.extern.slf4j.Slf4j;
-
-import java.util.HashMap;
-import java.util.Map;
-@Slf4j
-public class HKApi {
-
-    public static String GetCameraPreviewURL() {
-
-        /**
-         * STEP1锛氳缃钩鍙板弬鏁帮紝鏍规嵁瀹為檯鎯呭喌,璁剧疆host appkey appsecret 涓変釜鍙傛暟.
-         */
-        ArtemisConfig.host = "51.92.65.49"; // 骞冲彴鐨刬p绔彛
-        ArtemisConfig.appKey = "29555942";  // 瀵嗛挜appkey
-        ArtemisConfig.appSecret = "t9U7tCplCyYHzQPPL7cH";// 瀵嗛挜appSecret
-
-        /**
-         * STEP2锛氳缃甇penAPI鎺ュ彛鐨勪笂涓嬫枃
-         */
-        final String ARTEMIS_PATH = "/artemis";
-
-        /**
-         * STEP3锛氳缃帴鍙g殑URI鍦板潃
-         */
-        final String previewURLsApi = ARTEMIS_PATH + "/api/dqd/service/rs/v2/data/faceDetect/query";
-        Map<String, String> path = new HashMap<String, String>(2) {
-            {
-                put("https://", previewURLsApi);//鏍规嵁鐜板満鐜閮ㄧ讲纭鏄痟ttp杩樻槸https
-            }
-        };
-
-        /**
-         * STEP4锛氳缃弬鏁版彁浜ゆ柟寮�
-         */
-        String contentType = "application/json";
-
-        /**
-         * STEP5锛氱粍瑁呰姹傚弬鏁�
-         */
-        FaceDetectParam param = new FaceDetectParam();
-        param.setDate(DateUtils.getDate());
-        param.setPageNo(1);
-        param.setPageSize(20);
-        String body = JSON.toJSONString(param);
-        log.info("璇锋眰鍙傛暟:{}",body);
-        /**
-         * STEP6锛氳皟鐢ㄦ帴鍙�
-         */
-        String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, contentType , null);// post璇锋眰application/json绫诲瀷鍙傛暟
-        return result;
-    }
-}
diff --git a/ycl-server/src/main/java/com/ycl/task/HKTask.java b/ycl-server/src/main/java/com/ycl/task/HKTask.java
index 4b21232..f37f81f 100644
--- a/ycl-server/src/main/java/com/ycl/task/HKTask.java
+++ b/ycl-server/src/main/java/com/ycl/task/HKTask.java
@@ -2,10 +2,9 @@
 
 import com.alibaba.fastjson2.JSONObject;
 import com.mongodb.client.result.DeleteResult;
-import com.ycl.feign.HKApi;
+import com.ycl.feign.HkApiUtil;
 import com.ycl.feign.HkApiUtil;
 import com.ycl.platform.domain.param.HK.*;
-import com.ycl.platform.domain.result.BaseResult;
 import com.ycl.platform.domain.result.HK.*;
 import com.ycl.platform.service.ICheckIndexCarService;
 import com.ycl.platform.service.ICheckIndexFaceService;
@@ -33,8 +32,6 @@
     @Autowired
     private MongoTemplate mongoTemplate;
     @Autowired
-    private HKClient hkClient;
-    @Autowired
     private IYwThresholdService ywThresholdService;
     @Autowired
     private ICheckIndexFaceService checkIndexFaceService;
@@ -48,8 +45,7 @@
         log.info("寮�濮嬫墽琛岃溅杈嗚澶囧叏妫�鎸囨爣鐩戞祴缁撴灉鏁版嵁鍚屾");
         VehicleDeviceInspectionParam param = new VehicleDeviceInspectionParam();
         param.setPageNO(ApiConstants.PageNo).setPageSize(ApiConstants.PageSize).setDate(DateUtils.getDate());
-        JSONObject jsonObject = hkClient.vehicleDeviceInspection(param);
-        List<VehicleDeviceInspectionResult> list = getDataList(jsonObject, VehicleDeviceInspectionResult.class, "杞﹁締璁惧鍏ㄦ鎸囨爣鐩戞祴缁撴灉鏁版嵁涓虹┖");
+        List<VehicleDeviceInspectionResult> list = HkApiUtil.sendAPI("/api/dqd/service/rs/v2/data/vehFullAmount/query", param, VehicleDeviceInspectionResult.class);
         if (!CollectionUtils.isEmpty(list)) {
             //濡傛灉瀛樺湪涔嬪墠鐨勬暟鎹厛鍒犻櫎
             Query query = new Query(Criteria.where("mongoCreateTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date())));
@@ -67,8 +63,7 @@
         log.info("寮�濮嬫墽琛屼汉鑴歌澶囧叏妫�鎸囨爣鐩戞祴缁撴灉鏁版嵁鍚屾");
         FaceDeviceInspectionParam param = new FaceDeviceInspectionParam();
         param.setPageNO(ApiConstants.PageNo).setPageSize(ApiConstants.PageSize).setDate(DateUtils.getDate());
-        JSONObject jsonObject = hkClient.faceDeviceInspection(param);
-        List<FaceDeviceInspectionResult> list = getDataList(jsonObject, FaceDeviceInspectionResult.class, "浜鸿劯璁惧鍏ㄦ鎸囨爣鐩戞祴缁撴灉鏁版嵁涓虹┖");
+        List<FaceDeviceInspectionResult> list = HkApiUtil.sendAPI("/api/dqd/service/rs/v2/data/faceFullAmount/query", param, FaceDeviceInspectionResult.class);
         if (!CollectionUtils.isEmpty(list)) {
             //濡傛灉瀛樺湪涔嬪墠鐨勬暟鎹厛鍒犻櫎
             Query query = new Query(Criteria.where("mongoCreateTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date())));
@@ -89,8 +84,7 @@
         /** 杞﹁締鏁版嵁 */
         SnapshotDataMonitorParam carParam = new SnapshotDataMonitorParam();
         carParam.setPageNO(ApiConstants.PageNo).setPageSize(ApiConstants.PageSize).setDate(DateUtils.getDate()).setDataType(ApiConstants.HK_DataType_CAR);
-        JSONObject carJsonObject = hkClient.snapshotDataMonitor(carParam);
-        List<SnapshotDataMonitorResult> carList = getDataList(carJsonObject, SnapshotDataMonitorResult.class, "杞﹁締鎶撴媿鏁版嵁閲忔娴嬬粨鏋滄暟鎹�");
+        List<SnapshotDataMonitorResult> carList = HkApiUtil.sendAPI("/api/dqd/service/rs/v1/data/snapCountDetail/query", carParam, SnapshotDataMonitorResult.class);
         if (!CollectionUtils.isEmpty(carList)) {
             //濡傛灉浠婂ぉ瀛樺湪涔嬪墠鐨勬暟鎹厛鍒犻櫎
             Query query = new Query(Criteria
@@ -105,8 +99,7 @@
         /** 浜鸿劯鏁版嵁 */
         SnapshotDataMonitorParam faceParam = new SnapshotDataMonitorParam();
         faceParam.setPageNO(ApiConstants.PageNo).setPageSize(ApiConstants.PageSize).setDate(DateUtils.getDate()).setDataType(ApiConstants.HK_DataType_FACE);
-        JSONObject faceJsonObject = hkClient.snapshotDataMonitor(carParam);
-        List<SnapshotDataMonitorResult> faceList = getDataList(faceJsonObject, SnapshotDataMonitorResult.class, "浜鸿劯鎶撴媿鏁版嵁閲忔娴嬬粨鏋滄暟鎹负绌�");
+        List<SnapshotDataMonitorResult> faceList = HkApiUtil.sendAPI("/api/dqd/service/rs/v1/data/snapCountDetail/query", faceParam, SnapshotDataMonitorResult.class);
         if (!CollectionUtils.isEmpty(faceList)) {
             //濡傛灉浠婂ぉ瀛樺湪涔嬪墠鐨勬暟鎹厛鍒犻櫎
             Query query = new Query(Criteria
@@ -127,9 +120,7 @@
         //浜鸿劯鍗″彛淇℃伅閲囬泦鍑嗙‘鐜�
         MonitoringDetailParam param = new MonitoringDetailParam();
         param.setPageNO(ApiConstants.PageNo).setPageSize(ApiConstants.PageSize).setDate(DateUtils.getDate());
-
         List<MonitoringDetailResult> faceList = HkApiUtil.sendAPI("/api/dqd/service/rs/v1/device/cameraExpDetailInfo/query", param, MonitoringDetailResult.class);
-
         if (!CollectionUtils.isEmpty(faceList)) {
             //濡傛灉浠婂ぉ瀛樺湪涔嬪墠鐨勬暟鎹厛鍒犻櫎
             Query query = new Query(Criteria
@@ -148,8 +139,7 @@
         //杞﹁締鍗″彛淇℃伅閲囬泦鍑嗙‘鐜�
         CrossDetailParam param = new CrossDetailParam();
         param.setPageNO(ApiConstants.PageNo).setPageSize(ApiConstants.PageSize).setDate(DateUtils.getDate());
-        JSONObject jsonObject = hkClient.crossDetail(param);
-        List<CrossDetailResult> faceList = getDataList(jsonObject, CrossDetailResult.class, "鍗″彛灞炴�х洃娴嬬粨鏋滄暟鎹负绌�");
+        List<CrossDetailResult> faceList = HkApiUtil.sendAPI("/api/dqd/service/rs/v1/device/crossExpDetailInfo/query", param, CrossDetailResult.class);
         if (!CollectionUtils.isEmpty(faceList)) {
             //濡傛灉浠婂ぉ瀛樺湪涔嬪墠鐨勬暟鎹厛鍒犻櫎
             Query query = new Query(Criteria
@@ -301,30 +291,4 @@
         log.info("缁撴潫浜鸿劯璁惧鎶芥鎸囨爣鐩戞祴缁撴灉鏁版嵁鍚屾");
     }
 
-    //娴嬭瘯
-    public void test() {
-        log.info("娴嬭瘯娴峰悍鎺ュ彛");
-        String result = HKApi.GetCameraPreviewURL();
-        log.info("缁撴潫->{}",result);
-    }
-    //瑙f瀽鏁版嵁
-    private <T> List<T> getDataList(JSONObject jsonObject, Class<T> resultClass, String message) {
-        if (jsonObject != null && ApiConstants.HKSuccessCode.equals(jsonObject.getString("code"))) {
-            log.info("鏁版嵁鏍煎紡"+jsonObject);
-            JSONObject data = jsonObject.getJSONObject("data");
-            if (data == null) {
-                log.error(message, jsonObject);
-                return null;
-            }
-            List<T> list = data.getList("list", resultClass);
-            if (CollectionUtils.isEmpty(list)) {
-                log.error(message, data);
-                return null;
-            }
-            return list;
-        } else {
-            log.error(message);
-        }
-        return null;
-    }
 }

--
Gitblit v1.8.0