From f5e1051a7e6d3ffccc815a631d8be372d772c58f Mon Sep 17 00:00:00 2001
From: xiangpei <xiangpei@timesnew.cn>
Date: 星期二, 23 七月 2024 11:56:22 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'

---
 ycl-server/src/main/resources/mapper/zgyw/YwThresholdMapper.xml                    |   17 +-
 ycl-common/src/main/java/constant/CompareConstant.java                             |   13 ++
 ycl-server/src/main/java/com/ycl/task/HKTask.java                                  |   12 +
 ycl-server/src/main/java/com/ycl/platform/mapper/YwThresholdMapper.java            |    4 
 ycl-pojo/src/main/java/com/ycl/platform/domain/param/UY/CameraParam.java           |    2 
 ycl-pojo/src/main/java/com/ycl/platform/domain/param/UY/RecordMetaDSumParam.java   |    2 
 ycl-pojo/src/main/java/com/ycl/platform/domain/param/UY/OnlineParam.java           |    2 
 ycl-pojo/src/main/java/com/ycl/platform/domain/result/UY/OsdMonitorResult.java     |    2 
 ycl-pojo/src/main/java/com/ycl/platform/domain/result/UY/CameraResult.java         |    2 
 ycl-pojo/src/main/java/com/ycl/platform/domain/result/UY/RecordMetaDSumResult.java |    2 
 ycl-server/src/main/java/com/ycl/platform/service/impl/YwThresholdServiceImpl.java |  144 +++++++++++++++++++++--
 ycl-pojo/src/main/java/com/ycl/platform/domain/result/UY/OnlineResult.java         |    2 
 ycl-server/src/main/java/com/ycl/web/UYClient.java                                 |    7 
 ycl-pojo/src/main/java/com/ycl/platform/domain/entity/YwThreshold.java             |    5 
 ycl-server/src/main/java/com/ycl/platform/service/IYwThresholdService.java         |   16 ++
 ycl-server/src/main/java/com/ycl/task/UYTask.java                                  |   59 +++++++++
 ycl-common/src/main/java/constant/YwThreadConstants.java                           |   52 ++++++++
 17 files changed, 302 insertions(+), 41 deletions(-)

diff --git a/ycl-common/src/main/java/constant/CompareConstant.java b/ycl-common/src/main/java/constant/CompareConstant.java
new file mode 100644
index 0000000..9a82af8
--- /dev/null
+++ b/ycl-common/src/main/java/constant/CompareConstant.java
@@ -0,0 +1,13 @@
+package constant;
+//姣旇緝绫诲瀷
+public class CompareConstant {
+    /**
+     * 澶т簬绛変簬
+     */
+    public static final String MoreThanEq = "moreThanEq";
+
+    /**
+     * 灏忎簬绛変簬
+     */
+    public static final String LessThanEq = "lessThanEq";
+}
diff --git a/ycl-common/src/main/java/constant/YwThreadConstants.java b/ycl-common/src/main/java/constant/YwThreadConstants.java
new file mode 100644
index 0000000..c32dba7
--- /dev/null
+++ b/ycl-common/src/main/java/constant/YwThreadConstants.java
@@ -0,0 +1,52 @@
+package constant;
+
+/**
+ * 闃堝�煎父閲�
+ */
+public class YwThreadConstants {
+    //鏃堕挓鍑嗙‘鐜�
+    public static final String Car_ClockPercent = "Car_ClockPercent";
+    //鏁版嵁鍙婃椂鐜�
+    public static final String Car_TimelyPercent = "Car_TimelyPercent";
+    //鐧藉ぉ杞﹁締鏈瘑鍒噺
+    public static final String Car_DayNoNumberCount = "Car_DayNoNumberCount";
+    //涓嶅敮涓�鏁版嵁閲�
+    public static final String Car_NouniqueCount = "Car_NouniqueCount";
+    //鍏」鏁版嵁涓嶅畬鏁撮噺
+    public static final String Car_NoIntegrityCount = "Car_NoIntegrityCount";
+    //鎸佺画鏃犳暟鎹ぉ鏁�
+    public static final String Car_ContinueNoDataCount = "Car_ContinueNoDataCount";
+
+    //鏃堕挓鍑嗙‘鐜�
+    public static final String Face_ClockPercent = "Face_ClockPercent";
+    //鏁版嵁鍙婃椂鐜�
+    public static final String Face_TimelyPercent = "Face_TimelyPercent";
+    //涓嶅敮涓�鏁版嵁閲�
+    public static final String Face_NouniqueCount = "Face_NouniqueCount";
+    //寤烘ā澶辫触鐜�
+    public static final String Face_FailPercent = "Face_FailPercent";
+    //骞冲潎浜鸿劯浣庡钩鍒嗙巼
+    public static final String Face_LowScorePercent = "Face_LowScorePercent";
+    //鎸佺画鏃犳暟鎹ぉ鏁�
+    public static final String Face_ContinueNoDataCount = "Face_ContinueNoDataCount";
+
+    //妯$硦鍒嗗��
+    public static final String Video_Blur = "Video_Blur";
+    //棰滆壊鍒嗗��
+    public static final String Video_Color = "Video_Color";
+    //浜害鍒嗗��
+    public static final String Video_Light = "Video_Light";
+    //閬尅鍒嗗��
+    public static final String Video_Shade = "Video_Shade";
+    //鎶栧姩鍒嗗��
+    public static final String Video_Shake = "Video_Shake";
+    //闆姳鍒嗗��
+    public static final String Video_Snow = "Video_Snow";
+    //鏉$汗鍒嗗��
+    public static final String Video_Stripe = "Video_Stripe";
+    //淇″彿鍒嗗��
+    public static final String Video_Signal = "Video_Signal";
+    //鏍囨敞鏃堕棿宸�
+    public static final String Video_DiffTime = "Video_DiffTime";
+
+}
diff --git a/ycl-pojo/src/main/java/com/ycl/platform/domain/entity/YwThreshold.java b/ycl-pojo/src/main/java/com/ycl/platform/domain/entity/YwThreshold.java
index ae804d7..e91c0d9 100644
--- a/ycl-pojo/src/main/java/com/ycl/platform/domain/entity/YwThreshold.java
+++ b/ycl-pojo/src/main/java/com/ycl/platform/domain/entity/YwThreshold.java
@@ -39,6 +39,11 @@
     @TableField("count_type")
     private String countType;
 
+    /** 閿�煎搴擸wThreadConstants */
+    @Excel(name = "閿��")
+    @TableField("`key`")
+    private String key;
+
     /** 闃堝�煎悕 */
     @Excel(name = "闃堝�煎悕")
     @TableField("name")
diff --git a/ycl-pojo/src/main/java/com/ycl/platform/domain/param/YY/CameraParam.java b/ycl-pojo/src/main/java/com/ycl/platform/domain/param/UY/CameraParam.java
similarity index 89%
rename from ycl-pojo/src/main/java/com/ycl/platform/domain/param/YY/CameraParam.java
rename to ycl-pojo/src/main/java/com/ycl/platform/domain/param/UY/CameraParam.java
index 176eec5..0a74a9d 100644
--- a/ycl-pojo/src/main/java/com/ycl/platform/domain/param/YY/CameraParam.java
+++ b/ycl-pojo/src/main/java/com/ycl/platform/domain/param/UY/CameraParam.java
@@ -1,4 +1,4 @@
-package com.ycl.platform.domain.param.YY;
+package com.ycl.platform.domain.param.UY;
 
 import lombok.Data;
 import lombok.experimental.Accessors;
diff --git a/ycl-pojo/src/main/java/com/ycl/platform/domain/param/YY/OnlineParam.java b/ycl-pojo/src/main/java/com/ycl/platform/domain/param/UY/OnlineParam.java
similarity index 91%
rename from ycl-pojo/src/main/java/com/ycl/platform/domain/param/YY/OnlineParam.java
rename to ycl-pojo/src/main/java/com/ycl/platform/domain/param/UY/OnlineParam.java
index 5ab8659..110dc3c 100644
--- a/ycl-pojo/src/main/java/com/ycl/platform/domain/param/YY/OnlineParam.java
+++ b/ycl-pojo/src/main/java/com/ycl/platform/domain/param/UY/OnlineParam.java
@@ -1,4 +1,4 @@
-package com.ycl.platform.domain.param.YY;
+package com.ycl.platform.domain.param.UY;
 
 import lombok.Data;
 import lombok.experimental.Accessors;
diff --git a/ycl-pojo/src/main/java/com/ycl/platform/domain/param/YY/RecordMetaDSumParam.java b/ycl-pojo/src/main/java/com/ycl/platform/domain/param/UY/RecordMetaDSumParam.java
similarity index 96%
rename from ycl-pojo/src/main/java/com/ycl/platform/domain/param/YY/RecordMetaDSumParam.java
rename to ycl-pojo/src/main/java/com/ycl/platform/domain/param/UY/RecordMetaDSumParam.java
index b842cba..83ea4e5 100644
--- a/ycl-pojo/src/main/java/com/ycl/platform/domain/param/YY/RecordMetaDSumParam.java
+++ b/ycl-pojo/src/main/java/com/ycl/platform/domain/param/UY/RecordMetaDSumParam.java
@@ -1,4 +1,4 @@
-package com.ycl.platform.domain.param.YY;
+package com.ycl.platform.domain.param.UY;
 
 import lombok.Data;
 import lombok.experimental.Accessors;
diff --git a/ycl-pojo/src/main/java/com/ycl/platform/domain/result/YY/CameraResult.java b/ycl-pojo/src/main/java/com/ycl/platform/domain/result/UY/CameraResult.java
similarity index 98%
rename from ycl-pojo/src/main/java/com/ycl/platform/domain/result/YY/CameraResult.java
rename to ycl-pojo/src/main/java/com/ycl/platform/domain/result/UY/CameraResult.java
index 059dd62..93e5fda 100644
--- a/ycl-pojo/src/main/java/com/ycl/platform/domain/result/YY/CameraResult.java
+++ b/ycl-pojo/src/main/java/com/ycl/platform/domain/result/UY/CameraResult.java
@@ -1,4 +1,4 @@
-package com.ycl.platform.domain.result.YY;
+package com.ycl.platform.domain.result.UY;
 
 import lombok.Data;
 
diff --git a/ycl-pojo/src/main/java/com/ycl/platform/domain/result/YY/OnlineResult.java b/ycl-pojo/src/main/java/com/ycl/platform/domain/result/UY/OnlineResult.java
similarity index 96%
rename from ycl-pojo/src/main/java/com/ycl/platform/domain/result/YY/OnlineResult.java
rename to ycl-pojo/src/main/java/com/ycl/platform/domain/result/UY/OnlineResult.java
index 1868a9b..8e6f1b1 100644
--- a/ycl-pojo/src/main/java/com/ycl/platform/domain/result/YY/OnlineResult.java
+++ b/ycl-pojo/src/main/java/com/ycl/platform/domain/result/UY/OnlineResult.java
@@ -1,4 +1,4 @@
-package com.ycl.platform.domain.result.YY;
+package com.ycl.platform.domain.result.UY;
 
 import lombok.Data;
 
diff --git a/ycl-pojo/src/main/java/com/ycl/platform/domain/result/YY/OsdMonitorResult.java b/ycl-pojo/src/main/java/com/ycl/platform/domain/result/UY/OsdMonitorResult.java
similarity index 97%
rename from ycl-pojo/src/main/java/com/ycl/platform/domain/result/YY/OsdMonitorResult.java
rename to ycl-pojo/src/main/java/com/ycl/platform/domain/result/UY/OsdMonitorResult.java
index 078b9d4..8ac3736 100644
--- a/ycl-pojo/src/main/java/com/ycl/platform/domain/result/YY/OsdMonitorResult.java
+++ b/ycl-pojo/src/main/java/com/ycl/platform/domain/result/UY/OsdMonitorResult.java
@@ -1,4 +1,4 @@
-package com.ycl.platform.domain.result.YY;
+package com.ycl.platform.domain.result.UY;
 
 import lombok.Data;
 
diff --git a/ycl-pojo/src/main/java/com/ycl/platform/domain/result/YY/RecordMetaDSumResult.java b/ycl-pojo/src/main/java/com/ycl/platform/domain/result/UY/RecordMetaDSumResult.java
similarity index 96%
rename from ycl-pojo/src/main/java/com/ycl/platform/domain/result/YY/RecordMetaDSumResult.java
rename to ycl-pojo/src/main/java/com/ycl/platform/domain/result/UY/RecordMetaDSumResult.java
index 6422958..94819a5 100644
--- a/ycl-pojo/src/main/java/com/ycl/platform/domain/result/YY/RecordMetaDSumResult.java
+++ b/ycl-pojo/src/main/java/com/ycl/platform/domain/result/UY/RecordMetaDSumResult.java
@@ -1,4 +1,4 @@
-package com.ycl.platform.domain.result.YY;
+package com.ycl.platform.domain.result.UY;
 
 import lombok.Data;
 
diff --git a/ycl-server/src/main/java/com/ycl/platform/mapper/YwThresholdMapper.java b/ycl-server/src/main/java/com/ycl/platform/mapper/YwThresholdMapper.java
index 38c8cf1..ecfcfda 100644
--- a/ycl-server/src/main/java/com/ycl/platform/mapper/YwThresholdMapper.java
+++ b/ycl-server/src/main/java/com/ycl/platform/mapper/YwThresholdMapper.java
@@ -61,8 +61,4 @@
      */
     public int deleteYwThresholdByIds(Long[] ids);
 
-    /**
-     * 鏍规嵁璁惧绫诲瀷鑾峰彇杩愮淮闃堝��
-     */
-    public List<YwThreshold> selectByType(String type);
 }
diff --git a/ycl-server/src/main/java/com/ycl/platform/service/IYwThresholdService.java b/ycl-server/src/main/java/com/ycl/platform/service/IYwThresholdService.java
index 58b5ad0..d2eaaa2 100644
--- a/ycl-server/src/main/java/com/ycl/platform/service/IYwThresholdService.java
+++ b/ycl-server/src/main/java/com/ycl/platform/service/IYwThresholdService.java
@@ -2,6 +2,7 @@
 
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.ycl.platform.domain.entity.YwThreshold;
+import com.ycl.platform.domain.result.HK.VehicleDeviceInspectionResult;
 
 import java.util.List;
 import java.util.Map;
@@ -61,4 +62,19 @@
      * @return 缁撴灉
      */
     public int deleteYwThresholdById(Long id);
+
+    /**
+     * 鍒ゆ柇杞﹁締闃堝�兼潯浠�
+     */
+    public void carCheck(List<VehicleDeviceInspectionResult> list);
+
+    /**
+     * 鍒ゆ柇浜鸿劯闃堝�兼潯浠�
+     */
+    public void faceCheck(List list);
+
+    /**
+     * 鍒ゆ柇瑙嗛闃堝�兼潯浠�
+     */
+    public void videoCheck(List list);
 }
diff --git a/ycl-server/src/main/java/com/ycl/platform/service/impl/YwThresholdServiceImpl.java b/ycl-server/src/main/java/com/ycl/platform/service/impl/YwThresholdServiceImpl.java
index 273be68..549e453 100644
--- a/ycl-server/src/main/java/com/ycl/platform/service/impl/YwThresholdServiceImpl.java
+++ b/ycl-server/src/main/java/com/ycl/platform/service/impl/YwThresholdServiceImpl.java
@@ -1,16 +1,22 @@
 package com.ycl.platform.service.impl;
 
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.ycl.platform.domain.entity.WorkOrder;
 import com.ycl.platform.domain.entity.YwThreshold;
+import com.ycl.platform.domain.result.HK.VehicleDeviceInspectionResult;
 import com.ycl.platform.mapper.WorkOrderMapper;
 import com.ycl.platform.mapper.YwThresholdMapper;
 import com.ycl.platform.service.IYwThresholdService;
+import constant.CompareConstant;
+import constant.YwThreadConstants;
+import enumeration.general.BusinessTypeEnum;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import utils.DateUtils;
 
 import java.util.Date;
+import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 import java.util.stream.Collectors;
@@ -22,8 +28,7 @@
  * @date 2024-07-19
  */
 @Service
-public class YwThresholdServiceImpl extends ServiceImpl<YwThresholdMapper, YwThreshold> implements IYwThresholdService
-{
+public class YwThresholdServiceImpl extends ServiceImpl<YwThresholdMapper, YwThreshold> implements IYwThresholdService {
     @Autowired
     private YwThresholdMapper ywThresholdMapper;
 
@@ -34,8 +39,7 @@
      * @return 杩愮淮闃堝��
      */
     @Override
-    public YwThreshold selectYwThresholdById(Long id)
-    {
+    public YwThreshold selectYwThresholdById(Long id) {
         return ywThresholdMapper.selectYwThresholdById(id);
     }
 
@@ -46,8 +50,7 @@
      * @return 杩愮淮闃堝��
      */
     @Override
-    public Map<String, List<YwThreshold>> selectYwThresholdList(YwThreshold ywThreshold)
-    {
+    public Map<String, List<YwThreshold>> selectYwThresholdList(YwThreshold ywThreshold) {
         List<YwThreshold> ywThresholds = ywThresholdMapper.selectYwThresholdList(ywThreshold);
         Map<String, List<YwThreshold>> map = ywThresholds.stream().collect(Collectors.groupingBy(YwThreshold::getMonitorType));
         return map;
@@ -60,8 +63,7 @@
      * @return 缁撴灉
      */
     @Override
-    public int insertYwThreshold(YwThreshold ywThreshold)
-    {
+    public int insertYwThreshold(YwThreshold ywThreshold) {
         ywThreshold.setCreateTime(DateUtils.getNowDate());
         return ywThresholdMapper.insertYwThreshold(ywThreshold);
     }
@@ -73,8 +75,7 @@
      * @return 缁撴灉
      */
     @Override
-    public Boolean updateYwThreshold(List<YwThreshold> list)
-    {
+    public Boolean updateYwThreshold(List<YwThreshold> list) {
         list.forEach(item -> item.setCreateTime(new Date()));
         return updateBatchById(list);
     }
@@ -86,8 +87,7 @@
      * @return 缁撴灉
      */
     @Override
-    public int deleteYwThresholdByIds(Long[] ids)
-    {
+    public int deleteYwThresholdByIds(Long[] ids) {
         return ywThresholdMapper.deleteYwThresholdByIds(ids);
     }
 
@@ -98,8 +98,124 @@
      * @return 缁撴灉
      */
     @Override
-    public int deleteYwThresholdById(Long id)
-    {
+    public int deleteYwThresholdById(Long id) {
         return ywThresholdMapper.deleteYwThresholdById(id);
     }
+
+
+    @Override
+    public void faceCheck(List list) {
+
+    }
+
+    @Override
+    public void videoCheck(List list) {
+
+    }
+
+    /**
+     * 鍒ゆ柇杞﹁締闃堝�兼槸鍚︽弧瓒充笅鍙戞潯浠�
+     *
+     * @param list
+     */
+    @Override
+    public void carCheck(List<VehicleDeviceInspectionResult> list) {
+        QueryWrapper<YwThreshold> wrapper = new QueryWrapper<>();
+        wrapper.eq("monitor_type", BusinessTypeEnum.CAR.name());
+        List<YwThreshold> ywThresholds = ywThresholdMapper.selectList(wrapper);
+        Map<String, YwThreshold> map = new HashMap<>();
+        for (YwThreshold ywThreshold : ywThresholds) {
+            String key = ywThreshold.getKey();
+            map.put(key, ywThreshold);
+        }
+        //鏃堕挓鍑嗙‘鐜囬槇鍊�
+        Float clockPercent = Float.valueOf(map.get(YwThreadConstants.Car_ClockPercent).getValue());
+        Float clockPercentAuto = Float.valueOf(map.get(YwThreadConstants.Car_ClockPercent).getValueAuto());
+        //鏁版嵁鍙婃椂鐜囬槇鍊�
+        Float timelyPercent = Float.valueOf(map.get(YwThreadConstants.Car_TimelyPercent).getValue());
+        Float timelyPercentAuto = Float.valueOf(map.get(YwThreadConstants.Car_TimelyPercent).getValueAuto());
+        //鎸佺画鏃犳暟鎹ぉ鏁伴槇鍊�
+        Integer continueNoDataCount = Integer.valueOf(map.get(YwThreadConstants.Car_ContinueNoDataCount).getValue());
+        Integer continueNoDataCountAuto = Integer.valueOf(map.get(YwThreadConstants.Car_ContinueNoDataCount).getValueAuto());
+        //涓嶅敮涓�鏁版嵁閲忛槇鍊�
+        Integer nouniqueCount = Integer.valueOf(map.get(YwThreadConstants.Car_NouniqueCount).getValue());
+        Integer nouniqueCountAuto = Integer.valueOf(map.get(YwThreadConstants.Car_NouniqueCount).getValueAuto());
+        //鐧藉ぉ鏈瘑鍒噺闃堝��
+        Integer dayNoNumberCount = Integer.valueOf(map.get(YwThreadConstants.Car_DayNoNumberCount).getValue());
+        Integer dayNoNumberCountAuto = Integer.valueOf(map.get(YwThreadConstants.Car_DayNoNumberCount).getValueAuto());
+        //杞﹁締鍏」灞炴�т笉瀹屾暣閲忛槇鍊�
+        Integer noIntegrityCount = Integer.valueOf(map.get(YwThreadConstants.Car_NoIntegrityCount).getValue());
+        Integer noIntegrityCountAuto = Integer.valueOf(map.get(YwThreadConstants.Car_NoIntegrityCount).getValueAuto());
+
+        //澶勭悊鎺ュ彛鏁版嵁
+        for (VehicleDeviceInspectionResult result : list) {
+            if (result == null) {
+                log.error("杞﹁締瀵硅薄鏁版嵁涓虹┖");
+                continue;
+            }
+            //妫�鏌ユ寔缁棤鏁版嵁澶╂暟
+            Integer continueNoDataCountResult = result.getContinueNoDataCount();
+            check(continueNoDataCount, continueNoDataCountAuto, result, continueNoDataCountResult, "杞﹁締鎸佺画鏃犳暟鎹ぉ鏁颁负绌�", CompareConstant.MoreThanEq);
+            //妫�鏌ユ椂閽熷噯纭巼
+            Float clockPercentResult = result.getSnapClock().getClockPercent();
+            check(clockPercent, clockPercentAuto, result, clockPercentResult, "杞﹁締鏃堕挓鍑嗙‘鐜囦负绌�", CompareConstant.LessThanEq);
+            //妫�鏌ユ暟鎹強鏃剁巼
+            Float timelyPercentResult = result.getSnapTimely().getTimelyPercent();
+            check(timelyPercent, timelyPercentAuto, result, timelyPercentResult, "杞﹁締鏁版嵁鍙婃椂鐜囦负绌�", CompareConstant.LessThanEq);
+            //妫�鏌ヤ笉鍞竴鏁版嵁閲�
+            Integer nouniqueCountResult = result.getSnapUnique().getNouniqueCount();
+            check(nouniqueCount, nouniqueCountAuto, result, nouniqueCountResult, "杞﹁締涓嶅敮涓�鏁版嵁閲忎负绌�", CompareConstant.MoreThanEq);
+            //妫�鏌ョ櫧澶╂湭璇嗗埆閲�
+            Integer dayNoNumberCountResult = result.getSnapPlate().getDayNoNumberCount();
+            check(dayNoNumberCount, dayNoNumberCountAuto, result, dayNoNumberCountResult, "杞﹁締鐧藉ぉ鏈瘑鍒噺涓虹┖", CompareConstant.MoreThanEq);
+            //杞﹁締鍏」灞炴�т笉瀹屾暣閲�
+            Integer noIntegrityCountResult = result.getIntegrity().getNoIntegrityCount();
+            check(noIntegrityCount, noIntegrityCountAuto, result, noIntegrityCountResult, "杞﹁締鍏」灞炴�т笉瀹屾暣閲忎负绌�", CompareConstant.MoreThanEq);
+        }
+
+    }
+
+    private void check(Integer threshold, Integer thresholdAuto, VehicleDeviceInspectionResult result, Integer thresholdResult, String message, String command) {
+        if (thresholdResult != null) {
+            //澶т簬绫诲瀷
+            if (CompareConstant.MoreThanEq.equals(command)) {
+                if (thresholdResult >= thresholdAuto) {
+                    //TODO锛氳嚜鍔ㄤ笅鍙戝伐鍗�
+                } else if (thresholdResult >= threshold) {
+                    //TODO锛氳繘鍏ヤ笅鍙戝伐鍗曢〉闈�
+                }
+            } else if (CompareConstant.LessThanEq.equals(command)) {
+                //灏忎簬绫诲瀷
+                if (thresholdResult <= thresholdAuto) {
+                    //TODO锛氳嚜鍔ㄤ笅鍙戝伐鍗�
+                } else if (thresholdResult <= threshold) {
+                    //TODO锛氳繘鍏ヤ笅鍙戝伐鍗曢〉闈�
+                }
+            }
+        } else {
+            log.error(message + result);
+        }
+    }
+
+    private void check(Float threshold, Float thresholdAuto, VehicleDeviceInspectionResult result, Float thresholdResult, String message, String command) {
+        if (thresholdResult != null) {
+            //澶т簬绫诲瀷
+            if (CompareConstant.MoreThanEq.equals(command)) {
+                if (thresholdResult >= thresholdAuto) {
+                    //TODO锛氳嚜鍔ㄤ笅鍙戝伐鍗�
+                } else if (thresholdResult >= threshold) {
+                    //TODO锛氳繘鍏ヤ笅鍙戝伐鍗曢〉闈�
+                }
+            } else if (CompareConstant.LessThanEq.equals(command)) {
+                //灏忎簬绫诲瀷
+                if (thresholdResult <= thresholdAuto) {
+                    //TODO锛氳嚜鍔ㄤ笅鍙戝伐鍗�
+                } else if (thresholdResult <= threshold) {
+                    //TODO锛氳繘鍏ヤ笅鍙戝伐鍗曢〉闈�
+                }
+            }
+        } else {
+            log.error(message + 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 e508811..5220041 100644
--- a/ycl-server/src/main/java/com/ycl/task/HKTask.java
+++ b/ycl-server/src/main/java/com/ycl/task/HKTask.java
@@ -7,6 +7,7 @@
 import com.ycl.platform.domain.result.HK.FaceDeviceInspectionResult;
 import com.ycl.platform.domain.result.HK.VehicleDeviceInspectionResult;
 import com.ycl.platform.mapper.YwThresholdMapper;
+import com.ycl.platform.service.IYwThresholdService;
 import com.ycl.web.HKClient;
 import enumeration.BusinessType;
 import enumeration.general.BusinessTypeEnum;
@@ -30,7 +31,7 @@
     @Autowired
     private HKClient hkClient;
     @Autowired
-    private YwThresholdMapper thresholdMapper;
+    private IYwThresholdService ywThresholdService;
 
     private final static Integer pageNo = 1;
     private final static Integer pageSize = 5000;
@@ -53,10 +54,11 @@
             if (CollectionUtils.isEmpty(list)) {
                 throw new RuntimeException("杞﹁締璁惧鍏ㄦ鎸囨爣鐩戞祴缁撴灉鏁版嵁涓虹┖");
             }
-            //TODO:鍚屾鐨勬暟鎹彲鑳介渶瑕佸伐鍗曢槇鍊肩瓑澶勭悊
-            List<YwThreshold> ywThresholds = thresholdMapper.selectByType(BusinessTypeEnum.CAR.name());
             //瀛樻斁鍦╩ongo涓�
             mongoTemplate.insert(list);
+            //鍚屾鐨勬暟鎹繘琛屽伐鍗曢槇鍊煎鐞�
+            ywThresholdService.carCheck(list);
+
         } else {
             log.error("鍚屾杞﹁締璁惧鍏ㄦ鎸囨爣鐩戞祴缁撴灉澶辫触", jsonObject);
         }
@@ -79,10 +81,10 @@
             if (CollectionUtils.isEmpty(list)) {
                 throw new RuntimeException("浜鸿劯璁惧鍏ㄦ鎸囨爣鐩戞祴缁撴灉鏁版嵁涓虹┖");
             }
-            //TODO:鍚屾鐨勬暟鎹彲鑳介渶瑕佸伐鍗曢槇鍊肩瓑澶勭悊
-
             //瀛樻斁鍦╩ongo涓�
             mongoTemplate.insert(list);
+            //TODO:鍚屾鐨勬暟鎹彲鑳介渶瑕佸伐鍗曢槇鍊肩瓑澶勭悊
+
         } else {
             log.error("鍚屾浜鸿劯璁惧鍏ㄦ鎸囨爣鐩戞祴缁撴灉澶辫触", jsonObject);
         }
diff --git a/ycl-server/src/main/java/com/ycl/task/UYTask.java b/ycl-server/src/main/java/com/ycl/task/UYTask.java
new file mode 100644
index 0000000..e0c9c37
--- /dev/null
+++ b/ycl-server/src/main/java/com/ycl/task/UYTask.java
@@ -0,0 +1,59 @@
+package com.ycl.task;
+
+import com.alibaba.fastjson2.JSONObject;
+import com.ycl.platform.domain.param.HK.FaceDeviceInspectionParam;
+import com.ycl.platform.domain.param.HK.VehicleDeviceInspectionParam;
+import com.ycl.platform.domain.result.HK.FaceDeviceInspectionResult;
+import com.ycl.platform.domain.result.HK.VehicleDeviceInspectionResult;
+import com.ycl.platform.service.IYwThresholdService;
+import com.ycl.web.HKClient;
+import com.ycl.web.UYClient;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.mongodb.core.MongoTemplate;
+import org.springframework.stereotype.Component;
+import org.springframework.util.CollectionUtils;
+
+import java.text.SimpleDateFormat;
+import java.util.Date;
+import java.util.List;
+
+
+@Slf4j
+@Component("UYTask")
+public class UYTask {
+
+    @Autowired
+    private MongoTemplate mongoTemplate;
+    @Autowired
+    private UYClient uyClient;
+    @Autowired
+    private IYwThresholdService ywThresholdService;
+
+    private final static Integer pageNo = 1;
+    private final static Integer pageSize = 5000;
+    //鎴愬姛鐘舵�佺爜
+    private final static String successCode = "0";
+
+    //杞﹁締璁惧鍏ㄦ鎸囨爣鐩戞祴缁撴灉
+    public void VehicleDeviceInspectionTask() {
+        log.info("寮�濮嬫墽琛岃溅杈嗚澶囧叏妫�鎸囨爣鐩戞祴缁撴灉鏁版嵁鍚屾");
+
+        log.info("缁撴潫杞﹁締璁惧鍏ㄦ鎸囨爣鐩戞祴缁撴灉鏁版嵁鍚屾");
+    }
+
+
+    public void FaceDeviceInspectionTask() {
+        log.info("寮�濮嬫墽琛屼汉鑴歌澶囧叏妫�鎸囨爣鐩戞祴缁撴灉鏁版嵁鍚屾");
+
+        log.info("缁撴潫浜鸿劯璁惧鍏ㄦ鎸囨爣鐩戞祴缁撴灉鏁版嵁鍚屾");
+    }
+
+
+    private String getToday() {
+        Date date = new Date();
+        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
+        String today = sdf.format(date);
+        return today;
+    }
+}
diff --git a/ycl-server/src/main/java/com/ycl/web/UYClient.java b/ycl-server/src/main/java/com/ycl/web/UYClient.java
index e66f4ef..8757669 100644
--- a/ycl-server/src/main/java/com/ycl/web/UYClient.java
+++ b/ycl-server/src/main/java/com/ycl/web/UYClient.java
@@ -1,11 +1,10 @@
 package com.ycl.web;
 
 import com.alibaba.fastjson2.JSONObject;
-import com.ycl.config.HKFeignConfig;
 import com.ycl.config.YYFeignConfig;
-import com.ycl.platform.domain.param.YY.CameraParam;
-import com.ycl.platform.domain.param.YY.OnlineParam;
-import com.ycl.platform.domain.param.YY.RecordMetaDSumParam;
+import com.ycl.platform.domain.param.UY.CameraParam;
+import com.ycl.platform.domain.param.UY.OnlineParam;
+import com.ycl.platform.domain.param.UY.RecordMetaDSumParam;
 import org.springframework.cloud.openfeign.FeignClient;
 import org.springframework.stereotype.Component;
 import org.springframework.web.bind.annotation.GetMapping;
diff --git a/ycl-server/src/main/resources/mapper/zgyw/YwThresholdMapper.xml b/ycl-server/src/main/resources/mapper/zgyw/YwThresholdMapper.xml
index e969c66..0e50e52 100644
--- a/ycl-server/src/main/resources/mapper/zgyw/YwThresholdMapper.xml
+++ b/ycl-server/src/main/resources/mapper/zgyw/YwThresholdMapper.xml
@@ -3,7 +3,7 @@
 PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
 "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.ycl.platform.mapper.YwThresholdMapper">
-    
+
     <resultMap type="YwThreshold" id="YwThresholdResult">
         <result property="id"    column="id"    />
         <result property="monitorType"    column="monitor_type"    />
@@ -18,12 +18,12 @@
     </resultMap>
 
     <sql id="selectYwThresholdVo">
-        select id, monitor_type, count_type, name, value, value_auto, create_time, update_time, description, deleted from t_yw_threshold
+        select id, monitor_type, count_type,  `key` , name, value, value_auto, create_time, update_time, description, deleted from t_yw_threshold
     </sql>
 
     <select id="selectYwThresholdList" parameterType="YwThreshold" resultMap="YwThresholdResult">
         <include refid="selectYwThresholdVo"/>
-        <where>  
+        <where>
             <if test="monitorType != null  and monitorType != ''"> and monitor_type = #{monitorType}</if>
             <if test="countType != null  and countType != ''"> and count_type = #{countType}</if>
             <if test="name != null  and name != ''"> and name like concat('%', #{name}, '%')</if>
@@ -33,17 +33,18 @@
             <if test="deleted != null  and deleted != ''"> and deleted = #{deleted}</if>
         </where>
     </select>
-    
+
     <select id="selectYwThresholdById" parameterType="Long" resultMap="YwThresholdResult">
         <include refid="selectYwThresholdVo"/>
         where id = #{id}
     </select>
-        
+
     <insert id="insertYwThreshold" parameterType="YwThreshold" useGeneratedKeys="true" keyProperty="id">
         insert into t_yw_threshold
         <trim prefix="(" suffix=")" suffixOverrides=",">
             <if test="monitorType != null and monitorType != ''">monitor_type,</if>
             <if test="countType != null">count_type,</if>
+            <if test="key != null">`key`,</if>
             <if test="name != null">name,</if>
             <if test="value != null">value,</if>
             <if test="valueAuto != null">value_auto,</if>
@@ -55,6 +56,7 @@
         <trim prefix="values (" suffix=")" suffixOverrides=",">
             <if test="monitorType != null and monitorType != ''">#{monitorType},</if>
             <if test="countType != null">#{countType},</if>
+            <if test="key != null">#{key},</if>
             <if test="name != null">#{name},</if>
             <if test="value != null">#{value},</if>
             <if test="valueAuto != null">#{valueAuto},</if>
@@ -70,6 +72,7 @@
         <trim prefix="SET" suffixOverrides=",">
             <if test="monitorType != null and monitorType != ''">monitor_type = #{monitorType},</if>
             <if test="countType != null">count_type = #{countType},</if>
+            <if test="key != null">`key` = #{key},</if>
             <if test="name != null">name = #{name},</if>
             <if test="value != null">value = #{value},</if>
             <if test="valueAuto != null">value_auto = #{valueAuto},</if>
@@ -86,9 +89,9 @@
     </delete>
 
     <delete id="deleteYwThresholdByIds" parameterType="String">
-        delete from t_yw_threshold where id in 
+        delete from t_yw_threshold where id in
         <foreach item="id" collection="array" open="(" separator="," close=")">
             #{id}
         </foreach>
     </delete>
-</mapper>
\ No newline at end of file
+</mapper>

--
Gitblit v1.8.0