From 3351ade035a3a027d38e0372e496a5669cd7bde2 Mon Sep 17 00:00:00 2001 From: fuliqi <fuliqi@qq.com> Date: 星期一, 30 九月 2024 00:34:42 +0800 Subject: [PATCH] 下发工单bug --- ycl-server/src/main/java/com/ycl/task/UYTask.java | 70 +++++++++++++++++----------------- 1 files changed, 35 insertions(+), 35 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 c070048..39d0d29 100644 --- a/ycl-server/src/main/java/com/ycl/task/UYTask.java +++ b/ycl-server/src/main/java/com/ycl/task/UYTask.java @@ -273,41 +273,41 @@ 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); - 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)); +// 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("缁撴潫鎵ц褰曞儚鍙敤鏁版嵁鍚屾"); } -- Gitblit v1.8.0