From f8889f7364adae89e45a5ec3fcf4b38e430cf389 Mon Sep 17 00:00:00 2001
From: xiangpei <xiangpei@timesnew.cn>
Date: 星期二, 10 九月 2024 10:41:18 +0800
Subject: [PATCH] 工单详情

---
 ycl-server/src/main/java/com/ycl/task/UYTask.java |  345 ++++++++++++++++++++++++++++++++-------------------------
 1 files changed, 195 insertions(+), 150 deletions(-)

diff --git a/ycl-server/src/main/java/com/ycl/task/UYTask.java b/ycl-server/src/main/java/com/ycl/task/UYTask.java
index 1313214..2c3ae39 100644
--- a/ycl-server/src/main/java/com/ycl/task/UYTask.java
+++ b/ycl-server/src/main/java/com/ycl/task/UYTask.java
@@ -3,50 +3,54 @@
 import com.alibaba.fastjson2.JSONObject;
 import com.mongodb.client.result.DeleteResult;
 import com.ycl.feign.UYClient;
+import com.ycl.platform.domain.entity.YwPoint;
 import com.ycl.platform.domain.param.UY.*;
-import com.ycl.platform.domain.result.HK.FaceDeviceInspectionResult;
-import com.ycl.platform.domain.result.UY.OneMachineFileResult;
-import com.ycl.platform.domain.result.UY.OsdMonitorResult;
 import com.ycl.platform.domain.result.UY.RecordMetaDSumResult;
 import com.ycl.platform.domain.result.UY.*;
-import com.ycl.platform.service.ITMonitorService;
-import com.ycl.platform.service.IYwThresholdService;
+import com.ycl.platform.domain.vo.UpdateOnlineVO;
+import com.ycl.platform.mapper.TMonitorMapper;
 import com.ycl.platform.service.UYErrorTypeCheckService;
+import com.ycl.platform.service.YwPointService;
 import com.ycl.utils.DateUtils;
+import com.ycl.utils.http.HttpUtils;
+import com.ycl.utils.http.SelfHttpUtil;
 import constant.ApiConstants;
+import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
-import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.data.mongodb.core.MongoTemplate;
 import org.springframework.data.mongodb.core.query.Criteria;
 import org.springframework.data.mongodb.core.query.Query;
-import org.springframework.format.annotation.DateTimeFormat;
-import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.HttpStatusCode;
+import org.springframework.http.ResponseEntity;
 import org.springframework.stereotype.Component;
 import org.springframework.util.CollectionUtils;
 
+import java.io.IOException;
+import java.net.InetAddress;
 import java.text.SimpleDateFormat;
-import java.time.LocalDate;
-import java.time.LocalDateTime;
 import java.util.Calendar;
 import java.util.Date;
 import java.util.List;
+import java.util.Objects;
+import java.util.concurrent.ArrayBlockingQueue;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.ThreadPoolExecutor;
+import java.util.concurrent.TimeUnit;
 
 //浼樹簯瀵规帴鏁版嵁浠诲姟
 @Slf4j
 @Component("UYTask")
+@RequiredArgsConstructor
 public class UYTask {
 
-    @Autowired
-    private MongoTemplate mongoTemplate;
-    @Autowired
-    private UYClient uyClient;
-    @Autowired
-    private IYwThresholdService ywThresholdService;
-    @Autowired
-    private ITMonitorService monitorService;
-    @Autowired
-    private UYErrorTypeCheckService uyErrorTypeCheckService;
+    private final MongoTemplate mongoTemplate;
+    private final UYClient uyClient;
+    private final UYErrorTypeCheckService uyErrorTypeCheckService;
+    private final YwPointService pointService;
+    private final TMonitorMapper monitorMapper;
+    private final SelfHttpUtil selfHttpUtil;
 
     @Value("${youYun.tenantId}")
     private String tenantId;
@@ -59,44 +63,59 @@
     @Value("${youYun.passwd}")
     private String passwd;
 
+    private static final ExecutorService executorService = new ThreadPoolExecutor(16,
+            128,
+            5000,
+            TimeUnit.SECONDS,
+            new ArrayBlockingQueue<>(1000),
+            new ThreadPoolExecutor.CallerRunsPolicy()
+    );
+
     // 鍥惧儚妫�娴�
     public void imageDetection() {
         log.info("寮�濮嬫墽琛屽浘鍍忔娴嬫暟鎹悓姝�");
-//        ImageDetectionParam param = new ImageDetectionParam();
-//        param.setPageNum(ApiConstants.PageNo);
-//        param.setPageSize(ApiConstants.PageSize);
-//        param.setArealayerno(ApiConstants.AreaNo);
-//        JSONObject jsonObject = uyClient.imageDetection(param);
-//        if (jsonObject != null) {
-//            log.info("鏁版嵁鏍煎紡" + jsonObject);
-//            Integer statusCode = jsonObject.getInteger("statusCode");
-//            if (ApiConstants.UYSuccessCode.equals(statusCode)) {
-//                JSONObject data = jsonObject.getJSONObject("data");
-//                if (data != null) {
-//                    List<ImageDetectionResult> records = data.getList("records", ImageDetectionResult.class);
-//                    if (!CollectionUtils.isEmpty(records)) {
-//                        //濡傛灉浠婂ぉ瀛樺湪涔嬪墠鐨勬暟鎹厛鍒犻櫎
-//                        Query query = new Query(Criteria
-//                                .where("mongoCreateTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date())));
-//                        DeleteResult result = mongoTemplate.remove(query, ImageDetectionResult.class);
-//                        //瀛樻斁鍦╩ongo涓�
-//                        mongoTemplate.insertAll(records);
-//                        // 宸ュ崟鐢熸垚
-//                        uyErrorTypeCheckService.imageDetectionCheck(records);
-//                    } else {
-//                        log.error("鍥惧儚鐩戞祴鏁版嵁涓虹┖{}", data);
-//                    }
-//                } else {
-//                    log.error("鍥惧儚鐩戞祴鏁版嵁涓虹┖{}", jsonObject);
-//                }
-//            } else {
-//                log.error("鍥惧儚鐩戞祴璇锋眰澶辫触{}", jsonObject);
-//            }
-//        } else {
-//            log.error("鍥惧儚鐩戞祴鏁版嵁涓虹┖");
-//        }
-        Query query = new Query(Criteria.where("mongoCreateTime").lt(DateUtils.getDayEnd(new Date())));
-        uyErrorTypeCheckService.imageDetectionCheck(mongoTemplate.find(query, ImageDetectionResult.class));
+        ImageDetectionParam param = new ImageDetectionParam();
+        param.setPageNum(ApiConstants.PageNo);
+        param.setPageSize(ApiConstants.PageSize);
+        param.setArealayerno(ApiConstants.AreaNo);
+        JSONObject jsonObject = uyClient.imageDetection(param);
+        if (jsonObject != null) {
+            log.info("鏁版嵁鏍煎紡" + jsonObject);
+            Integer statusCode = jsonObject.getInteger("statusCode");
+            if (ApiConstants.UYSuccessCode.equals(statusCode)) {
+                JSONObject data = jsonObject.getJSONObject("data");
+                if (data != null) {
+                    List<ImageDetectionResult> records = data.getList("records", ImageDetectionResult.class);
+                    if (!CollectionUtils.isEmpty(records)) {
+                        //濡傛灉浠婂ぉ瀛樺湪涔嬪墠鐨勬暟鎹厛鍒犻櫎
+                        Query query = new Query(Criteria
+                                .where("mongoCreateTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date())));
+                        DeleteResult result = mongoTemplate.remove(query, ImageDetectionResult.class);
+                        records.stream().forEach(item -> {
+                            if (Objects.nonNull(item.getDeviceId())) {
+                                item.setNo(item.getDeviceId());
+                            }
+                        });
+                        pointService.setDeviceTagByGB(records);
+                        //瀛樻斁鍦╩ongo涓�
+                        mongoTemplate.insertAll(records);
+                        // 宸ュ崟鐢熸垚
+                        uyErrorTypeCheckService.imageDetectionCheck(records);
+                    } else {
+                        log.error("鍥惧儚鐩戞祴鏁版嵁涓虹┖{}", data);
+                    }
+                } else {
+                    log.error("鍥惧儚鐩戞祴鏁版嵁涓虹┖{}", jsonObject);
+                }
+            } else {
+                log.error("鍥惧儚鐩戞祴璇锋眰澶辫触{}", jsonObject);
+            }
+        } else {
+            log.error("鍥惧儚鐩戞祴鏁版嵁涓虹┖");
+        }
+        // 鏈湴娴嬭瘯
+//        Query query = new Query(Criteria.where("mongoCreateTime").lt(DateUtils.getDayEnd(new Date())));
+//        uyErrorTypeCheckService.imageDetectionCheck(mongoTemplate.find(query, ImageDetectionResult.class));
         log.info("缁撴潫鎵ц鍥惧儚鐩戞祴鏁版嵁鍚屾");
     }
 
@@ -106,38 +125,89 @@
         // 涓�鏈轰竴妗f敞鍐岀巼
         // 妗f鑰冩牳姣�
         log.info("寮�濮嬫墽琛屼竴鏈轰竴妗e悎鏍肩巼鏁版嵁鍚屾");
-//        MonitorQualifyParam param = new MonitorQualifyParam();
-//        param.setPageNum(ApiConstants.PageNo);
-//        param.setPageSize(ApiConstants.PageSize);
-//        JSONObject jsonObject = uyClient.monitorQualify(param);
-//        if (jsonObject != null) {
-//            String code = jsonObject.getString("code");
-//            if (ApiConstants.UYSuccessCodeStr.equals(code)) {
-//                JSONObject data = jsonObject.getJSONObject("data");
-//                if (data != null) {
-//                    List<MonitorQualifyResult> records = data.getList("records", MonitorQualifyResult.class);
-//                    if (!CollectionUtils.isEmpty(records)) {
-//                        //濡傛灉浠婂ぉ瀛樺湪涔嬪墠鐨勬暟鎹厛鍒犻櫎
-//                        Query query = new Query(Criteria
-//                                .where("mongoCreateTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date())));
-//                        DeleteResult result = mongoTemplate.remove(query, MonitorQualifyResult.class);
-//                        //瀛樻斁鍦╩ongo涓�
-//                        mongoTemplate.insertAll(records);
-//                        // 宸ュ崟鐢熸垚
-//                        uyErrorTypeCheckService.monitorQualifyCheck(records);
-//                    } else {
-//                        log.error("涓�鏈轰竴妗e悎鏍肩巼鏁版嵁涓虹┖{}", data);
-//                    }
-//                }
-//            } else {
-//                log.error("涓�鏈轰竴妗e悎鏍肩巼鏁版嵁涓虹┖{}", jsonObject);
-//            }
-//        } else {
-//            log.error("涓�鏈轰竴妗e悎鏍肩巼鏁版嵁涓虹┖");
-//        }
-        Query query = new Query(Criteria.where("mongoCreateTime").lt(DateUtils.getDayEnd(new Date())));
-        uyErrorTypeCheckService.monitorQualifyCheck(mongoTemplate.find(query, MonitorQualifyResult.class));
+        MonitorQualifyParam param = new MonitorQualifyParam();
+        param.setPageNum(ApiConstants.PageNo);
+        param.setPageSize(ApiConstants.PageSize);
+        JSONObject jsonObject = uyClient.monitorQualify(param);
+        if (jsonObject != null) {
+            String code = jsonObject.getString("code");
+            if (ApiConstants.UYSuccessCodeStr.equals(code)) {
+                JSONObject data = jsonObject.getJSONObject("data");
+                if (data != null) {
+                    List<MonitorQualifyResult> records = data.getList("records", MonitorQualifyResult.class);
+                    if (!CollectionUtils.isEmpty(records)) {
+                        //濡傛灉浠婂ぉ瀛樺湪涔嬪墠鐨勬暟鎹厛鍒犻櫎
+                        Query query = new Query(Criteria
+                                .where("mongoCreateTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date())));
+                        DeleteResult result = mongoTemplate.remove(query, MonitorQualifyResult.class);
+                        records.stream().forEach(item -> {
+                            if (Objects.nonNull(item.getSerialNumber())) {
+                                item.setNo(item.getSerialNumber().getShowValue());
+                            }
+                        });
+                        pointService.setDeviceTagByGB(records);
+                        pointService.setNew(records);
+                        //瀛樻斁鍦╩ongo涓�
+                        mongoTemplate.insertAll(records);
+                        // 宸ュ崟鐢熸垚
+                        uyErrorTypeCheckService.monitorQualifyCheck(records);
+                    } else {
+                        log.error("涓�鏈轰竴妗e悎鏍肩巼鏁版嵁涓虹┖{}", data);
+                    }
+                }
+            } else {
+                log.error("涓�鏈轰竴妗e悎鏍肩巼鏁版嵁涓虹┖{}", jsonObject);
+            }
+        } else {
+            log.error("涓�鏈轰竴妗e悎鏍肩巼鏁版嵁涓虹┖");
+        }
+        // 鏈湴娴嬭瘯
+//        Query query = new Query(Criteria.where("mongoCreateTime").lt(DateUtils.getDayEnd(new Date())));
+//        uyErrorTypeCheckService.monitorQualifyCheck(mongoTemplate.find(query, MonitorQualifyResult.class));
         log.info("缁撴潫涓�鏈轰竴妗e悎鏍肩巼鏁版嵁鍚屾");
+    }
+
+    /**
+     * 鐐逛綅鍦ㄧ嚎妫�娴�
+     */
+    public void pointOnline() {
+        log.info("寮�濮嬫娴嬬偣浣嶅湪绾�");
+        // 鍏堟煡鍑鸿澶嘔P闆嗗悎
+        List<String> ipList = monitorMapper.getDistinctIP();
+        String prefix = "http://";
+        Date now = new Date();
+        for (String ip : ipList) {
+            executorService.submit(() -> {
+                // 鍏堟娴嬭兘鍚﹁闂ip鐨勭綉椤�
+                ResponseEntity<Object> res = null;
+                UpdateOnlineVO online = new UpdateOnlineVO();
+                online.setIp(ip);
+                if ("127.0.0.1".equals(ip)) {
+                    online.setOnline(Boolean.FALSE);
+                    monitorMapper.updateOnline(online);
+                    return;
+                }
+                try {
+                    res = selfHttpUtil.get(prefix + ip, null, null);
+                    online.setOnline(Objects.nonNull(res) && HttpStatus.OK == res.getStatusCode());
+                } catch (Exception e) {
+                    online.setOnline(Boolean.FALSE);
+                }
+                online.setUpdateTime(now);
+
+                // 濡傛灉http寰楀埌鐨勪笉鍦ㄧ嚎锛岄偅涔堝啀ping涓�涓�
+                boolean reachable = false;
+                if (! online.getOnline()) {
+                    try {
+                        reachable = InetAddress.getByName(ip).isReachable(3000);
+                    } catch (IOException e) {
+                        e.printStackTrace();
+                    }
+                    online.setOnline(reachable);
+                }
+                monitorMapper.updateOnline(online);
+            });
+        }
     }
 
     //鐐逛綅鍦ㄧ嚎鐜�
@@ -178,8 +248,9 @@
         } else {
             log.error("鐐逛綅鍦ㄧ嚎缁撴灉鏁版嵁涓虹┖");
         }
-        Query query = new Query(Criteria.where("mongoCreateTime").lt(DateUtils.getDayEnd(new Date())));
-        uyErrorTypeCheckService.videoOnlineCheck(mongoTemplate.find(query, VideoOnlineResult.class));
+        // 鏈湴娴嬭瘯
+//        Query query = new Query(Criteria.where("mongoCreateTime").lt(DateUtils.getDayEnd(new Date())));
+//        uyErrorTypeCheckService.videoOnlineCheck(mongoTemplate.find(query, VideoOnlineResult.class));
         log.info("缁撴潫鎵ц鐐逛綅鍦ㄧ嚎鏁版嵁鍚屾");
     }
 
@@ -187,70 +258,44 @@
     public void recordMetaDSumTask() {
         //褰曞儚鍙敤鐜�
         log.info("寮�濮嬫墽琛屽綍鍍忓彲鐢ㄦ暟鎹悓姝�");
-//        RecordMetaDSumParam param = new RecordMetaDSumParam();
-//        param.setTenantId(tenantId);
-//        Calendar instance = Calendar.getInstance();
-//        instance.setTime(new Date());
-//        instance.add(Calendar.DAY_OF_MONTH, -1);
-//        SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd");
-//        String yesterday = format.format(instance.getTime());
-//        param.setStatTime(yesterday);
-//        JSONObject jsonObject = uyClient.recordMetaDSumList(param);
-//        if (jsonObject != null) {
-//            if (ApiConstants.UYSuccessCodeStr.equals(jsonObject.getString("code"))) {
-//                List<RecordMetaDSumResult> records = jsonObject.getList("data", RecordMetaDSumResult.class);
-//                if (!CollectionUtils.isEmpty(records)) {
-//                    //濡傛灉浠婂ぉ瀛樺湪涔嬪墠鐨勬暟鎹厛鍒犻櫎
-//                    Query query = new Query(Criteria
-//                            .where("mongoCreateTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date())));
-//                    DeleteResult result = mongoTemplate.remove(query, RecordMetaDSumResult.class);
-//                    //瀛樻斁鍦╩ongo涓�
-//                    mongoTemplate.insertAll(records);
-//                    // 宸ュ崟鐢熸垚
-//                    uyErrorTypeCheckService.recordMetaDSumCheck(records);
-//                }
-//            } else {
-//                log.error("褰曞儚鍙敤鏁版嵁涓虹┖{}", jsonObject);
-//            }
-//        }
-        Query query = new Query(Criteria.where("mongoCreateTime").lt(DateUtils.getDayEnd(new Date())));
-        uyErrorTypeCheckService.recordMetaDSumCheck(mongoTemplate.find(query, RecordMetaDSumResult.class));
+        RecordMetaDSumParam param = new RecordMetaDSumParam();
+        param.setTenantId(tenantId);
+        Calendar instance = Calendar.getInstance();
+        instance.setTime(new Date());
+        instance.add(Calendar.DAY_OF_MONTH, -1);
+        SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd");
+        String yesterday = format.format(instance.getTime());
+        param.setStatTime(yesterday);
+        JSONObject jsonObject = uyClient.recordMetaDSumList(param);
+        if (jsonObject != null) {
+            if (ApiConstants.UYSuccessCodeStr.equals(jsonObject.getString("code"))) {
+                List<RecordMetaDSumResult> records = jsonObject.getList("data", RecordMetaDSumResult.class);
+                if (!CollectionUtils.isEmpty(records)) {
+                    //濡傛灉浠婂ぉ瀛樺湪涔嬪墠鐨勬暟鎹厛鍒犻櫎
+                    Query query = new Query(Criteria
+                            .where("mongoCreateTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date())));
+                    DeleteResult result = mongoTemplate.remove(query, RecordMetaDSumResult.class);
+                    records.stream().forEach(item -> {
+                        if (Objects.nonNull(item.getDeviceId())) {
+                            item.setNo(item.getDeviceId());
+                        }
+                    });
+                    pointService.setDeviceTagByGB(records);
+                    //瀛樻斁鍦╩ongo涓�
+                    mongoTemplate.insertAll(records);
+                    // 宸ュ崟鐢熸垚
+                    uyErrorTypeCheckService.recordMetaDSumCheck(records);
+                }
+            } else {
+                log.error("褰曞儚鍙敤鏁版嵁涓虹┖{}", jsonObject);
+            }
+        }
+        // 鏈湴娴嬭瘯
+//        Query query = new Query(Criteria.where("mongoCreateTime").lt(DateUtils.getDayEnd(new Date())));
+//        uyErrorTypeCheckService.recordMetaDSumCheck(mongoTemplate.find(query, RecordMetaDSumResult.class));
         log.info("缁撴潫鎵ц褰曞儚鍙敤鏁版嵁鍚屾");
     }
 
 
-    //瑙嗛鏍囨敞
-    public void OsdMonitorTask() {
-        //瑙嗛鏍囨敞
-        log.info("寮�濮嬫墽琛岃棰戞爣娉ㄦ暟鎹悓姝�");
-        OsdMonitorParam param = new OsdMonitorParam();
-        param.setPageNum(ApiConstants.PageNo);
-        param.setPageSize(ApiConstants.PageSize);
-        JSONObject jsonObject = uyClient.osdMonitorList(param, tenantId);
-        if (jsonObject != null) {
-            if (ApiConstants.UYSuccessCodeStr.equals(jsonObject.getString("code"))) {
-                JSONObject data = jsonObject.getJSONObject("data");
-                if (data != null) {
-                    List<OsdMonitorResult> records = data.getList("records", OsdMonitorResult.class);
-                    if (!CollectionUtils.isEmpty(records)) {
-                        //濡傛灉浠婂ぉ瀛樺湪涔嬪墠鐨勬暟鎹厛鍒犻櫎
-                        Query query = new Query(Criteria
-                                .where("mongoCreateTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date())));
-                        DeleteResult result = mongoTemplate.remove(query, OsdMonitorResult.class);
-                        //瀛樻斁鍦╩ongo涓�
-                        mongoTemplate.insertAll(records);
-                    } else {
-                        log.error("瑙嗛鏍囨敞鏁版嵁涓虹┖{}", data);
-                    }
-                } else {
-                    log.error("瑙嗛鏍囨敞鏁版嵁涓虹┖{}", jsonObject);
-                }
-            } else {
-                log.error("瑙嗛鏍囨敞鏁版嵁涓虹┖{}", jsonObject);
-            }
-        } else {
-            log.error("瑙嗛鏍囨敞鏁版嵁涓虹┖");
-        }
-        log.info("缁撴潫鎵ц瑙嗛鏍囨敞鏁版嵁鍚屾");
-    }
+
 }

--
Gitblit v1.8.0