From 5ad78065f965a65db1e4c9e7d799ab42c5a01cae Mon Sep 17 00:00:00 2001 From: 龚焕茏 <2842157468@qq.com> Date: 星期三, 28 八月 2024 14:25:50 +0800 Subject: [PATCH] feat:数据中心统计数 --- ycl-server/src/main/java/com/ycl/task/UYTask.java | 68 +++++++++++++++++----------------- 1 files changed, 34 insertions(+), 34 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..3241096 100644 --- a/ycl-server/src/main/java/com/ycl/task/UYTask.java +++ b/ycl-server/src/main/java/com/ycl/task/UYTask.java @@ -144,40 +144,40 @@ public void videoOnlineTask() { //瑙嗛鍥惧儚璐ㄩ噺 log.info("寮�濮嬫墽琛岀偣浣嶅湪绾挎暟鎹悓姝�"); - VideoOnlineParam param = new VideoOnlineParam(); - param.setPageNum(ApiConstants.PageNo); - param.setPageSize(ApiConstants.PageSize); - param.setArealayerno(ApiConstants.AreaNo); - param.setStatus(ApiConstants.UY_OnlineStatus_All); - param.setIcmpStatus(ApiConstants.UY_OnlineStatus_All); - JSONObject jsonObject = uyClient.videoOnline(param); - if (jsonObject != null) { - Integer statusCode = jsonObject.getInteger("statusCode"); - if (ApiConstants.UYSuccessCode.equals(statusCode)) { - JSONObject data = jsonObject.getJSONObject("data"); - if (data != null) { - List<VideoOnlineResult> records = data.getList("records", VideoOnlineResult.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, VideoOnlineResult.class); - //瀛樻斁鍦╩ongo涓� - mongoTemplate.insertAll(records); - // 宸ュ崟鐢熸垚 - uyErrorTypeCheckService.videoOnlineCheck(records); - } else { - log.error("鐐逛綅鍦ㄧ嚎缁撴灉鏁版嵁涓虹┖{}", data); - } - } else { - log.error("鐐逛綅鍦ㄧ嚎缁撴灉鏁版嵁涓虹┖{}", jsonObject); - } - } else { - log.error("鐐逛綅鍦ㄧ嚎缁撴灉璇锋眰澶辫触{}", jsonObject); - } - } else { - log.error("鐐逛綅鍦ㄧ嚎缁撴灉鏁版嵁涓虹┖"); - } +// VideoOnlineParam param = new VideoOnlineParam(); +// param.setPageNum(ApiConstants.PageNo); +// param.setPageSize(ApiConstants.PageSize); +// param.setArealayerno(ApiConstants.AreaNo); +// param.setStatus(ApiConstants.UY_OnlineStatus_All); +// param.setIcmpStatus(ApiConstants.UY_OnlineStatus_All); +// JSONObject jsonObject = uyClient.videoOnline(param); +// if (jsonObject != null) { +// Integer statusCode = jsonObject.getInteger("statusCode"); +// if (ApiConstants.UYSuccessCode.equals(statusCode)) { +// JSONObject data = jsonObject.getJSONObject("data"); +// if (data != null) { +// List<VideoOnlineResult> records = data.getList("records", VideoOnlineResult.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, VideoOnlineResult.class); +// //瀛樻斁鍦╩ongo涓� +// mongoTemplate.insertAll(records); +// // 宸ュ崟鐢熸垚 +// uyErrorTypeCheckService.videoOnlineCheck(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.videoOnlineCheck(mongoTemplate.find(query, VideoOnlineResult.class)); log.info("缁撴潫鎵ц鐐逛綅鍦ㄧ嚎鏁版嵁鍚屾"); -- Gitblit v1.8.0