From d1e30de4ca5e1c198df2edd0394779f93ae80f64 Mon Sep 17 00:00:00 2001
From: xiangpei <xiangpei@timesnew.cn>
Date: 星期四, 29 八月 2024 14:59:10 +0800
Subject: [PATCH] 定时任务注释解开

---
 ycl-server/src/main/java/com/ycl/task/HKTask.java |   96 +++++++++++++++++-------------------------------
 1 files changed, 34 insertions(+), 62 deletions(-)

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 6072c95..a002bcf 100644
--- a/ycl-server/src/main/java/com/ycl/task/HKTask.java
+++ b/ycl-server/src/main/java/com/ycl/task/HKTask.java
@@ -43,46 +43,46 @@
     //杞﹁締璁惧鍏ㄦ鎸囨爣鐩戞祴缁撴灉
     public void vehicleDeviceInspectionTask() {
         log.info("寮�濮嬫墽琛岃溅杈嗚澶囧叏妫�鎸囨爣鐩戞祴缁撴灉鏁版嵁鍚屾");
-//        VehicleDeviceInspectionParam param = new VehicleDeviceInspectionParam();
-//        param.setPageNo(ApiConstants.PageNo);
-//        param.setPageSize(ApiConstants.HKPageSize);
-//        param.setDate(DateUtils.getDate());
-//        param.setDataType(ApiConstants.HK_DataType_CAR);
-//        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())));
-//            DeleteResult result = mongoTemplate.remove(query, VehicleDeviceInspectionResult.class);
-//            //瀛樻斁鍦╩ongo涓�
-//            mongoTemplate.insertAll(list);
-//            //鍚屾鐨勬暟鎹繘琛屽伐鍗曢槇鍊煎鐞�
-//            ywThresholdService.carCheck(list);
-//        }
-        Query query = new Query(Criteria.where("mongoCreateTime").lt(DateUtils.getDayEnd(new Date())));
-        ywThresholdService.carCheck(mongoTemplate.find(query, VehicleDeviceInspectionResult.class));
+        VehicleDeviceInspectionParam param = new VehicleDeviceInspectionParam();
+        param.setPageNo(ApiConstants.PageNo);
+        param.setPageSize(ApiConstants.HKPageSize);
+        param.setDate(DateUtils.getDate());
+        param.setDataType(ApiConstants.HK_DataType_CAR);
+        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())));
+            DeleteResult result = mongoTemplate.remove(query, VehicleDeviceInspectionResult.class);
+            //瀛樻斁鍦╩ongo涓�
+            mongoTemplate.insertAll(list);
+            //鍚屾鐨勬暟鎹繘琛屽伐鍗曢槇鍊煎鐞�
+            ywThresholdService.carCheck(list);
+        }
+//        Query query = new Query(Criteria.where("mongoCreateTime").lt(DateUtils.getDayEnd(new Date())));
+//        ywThresholdService.carCheck(mongoTemplate.find(query, VehicleDeviceInspectionResult.class));
         log.info("缁撴潫杞﹁締璁惧鍏ㄦ鎸囨爣鐩戞祴缁撴灉鏁版嵁鍚屾");
     }
 
     //浜鸿劯璁惧鍏ㄦ鎸囨爣鐩戞祴缁撴灉
     public void faceDeviceInspectionTask() {
         log.info("寮�濮嬫墽琛屼汉鑴歌澶囧叏妫�鎸囨爣鐩戞祴缁撴灉鏁版嵁鍚屾");
-//        FaceDeviceInspectionParam param = new FaceDeviceInspectionParam();
-//        param.setPageNo(ApiConstants.PageNo);
-//        param.setPageSize(ApiConstants.HKPageSize);
-//        param.setDate(DateUtils.getDate());
-//        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())));
-//            DeleteResult result = mongoTemplate.remove(query, FaceDeviceInspectionResult.class);
-//            //瀛樻斁鍦╩ongo涓�
-//            mongoTemplate.insertAll(list);
-//            //鍚屾鐨勬暟鎹繘琛屽伐鍗曢槇鍊煎鐞�
-//            //TODO:鍙兘鏈夐噸澶嶅伐鍗�
-//            ywThresholdService.faceCheck(list);
-//        }
-        Query query = new Query(Criteria.where("mongoCreateTime").lt(DateUtils.getDayEnd(new Date())));
-        ywThresholdService.faceCheck(mongoTemplate.find(query, FaceDeviceInspectionResult.class));
+        FaceDeviceInspectionParam param = new FaceDeviceInspectionParam();
+        param.setPageNo(ApiConstants.PageNo);
+        param.setPageSize(ApiConstants.HKPageSize);
+        param.setDate(DateUtils.getDate());
+        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())));
+            DeleteResult result = mongoTemplate.remove(query, FaceDeviceInspectionResult.class);
+            //瀛樻斁鍦╩ongo涓�
+            mongoTemplate.insertAll(list);
+            //鍚屾鐨勬暟鎹繘琛屽伐鍗曢槇鍊煎鐞�
+            //TODO:鍙兘鏈夐噸澶嶅伐鍗�
+            ywThresholdService.faceCheck(list);
+        }
+//        Query query = new Query(Criteria.where("mongoCreateTime").lt(DateUtils.getDayEnd(new Date())));
+//        ywThresholdService.faceCheck(mongoTemplate.find(query, FaceDeviceInspectionResult.class));
         log.info("缁撴潫浜鸿劯璁惧鍏ㄦ鎸囨爣鐩戞祴缁撴灉鏁版嵁鍚屾");
     }
 
@@ -329,34 +329,6 @@
         }
         //TODO:宸ュ崟澶勭悊
         log.info("缁撴潫浜鸿劯璁惧鎶芥鎸囨爣鐩戞祴缁撴灉鏁版嵁鍚屾");
-    }
-
-    //娴嬭瘯
-    public void test() {
-        log.info("娴嬭瘯娴峰悍鎺ュ彛");
-        HkApiUtil.sendAPI("/api/dqd/service/rs/v2/data/faceDetect/query", new FaceDeviceSamplingParam(), Object.class);
-        log.info("缁撴潫->{}锛岃皟鐢ㄦ垚鍔�");
-    }
-
-    //娴嬭瘯
-    public void test1() {
-        log.info("娴嬭瘯娴峰悍鎺ュ彛");
-        HkApiUtil.sendAPI("/api/dqd/service/rs/v1/device/coordinateExpInfo/query", new FaceDeviceSamplingParam(), Object.class);
-        log.info("缁撴潫->{}锛岃皟鐢ㄦ垚鍔�");
-    }
-
-    //娴嬭瘯
-    public void test2() {
-        log.info("娴嬭瘯娴峰悍鎺ュ彛");
-        HkApiUtil.sendAPI("/api/dqd/service/rs/v1/device/gbCodeExpInfo/query", new FaceDeviceSamplingParam(), Object.class);
-        log.info("缁撴潫->{}锛岃皟鐢ㄦ垚鍔�");
-    }
-
-    //娴嬭瘯
-    public void test3() {
-        log.info("娴嬭瘯娴峰悍鎺ュ彛");
-        HkApiUtil.sendAPI("/api/dqd/service/rs/v2/data/passDetect/query", new FaceDeviceSamplingParam(), Object.class);
-        log.info("缁撴潫->{}锛岃皟鐢ㄦ垚鍔�");
     }
 
     //瑙f瀽鏁版嵁

--
Gitblit v1.8.0