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