From ce71e469c74ba4a8ae1fcdbf287ee86a033b7185 Mon Sep 17 00:00:00 2001
From: ZhuDongming <773644075@qq.com>
Date: Mon, 30 Mar 2020 11:39:32 +0800
Subject: [PATCH] 循环发送修改
---
src/main/java/com/moral/task/RabbitMQInsertTask.java | 33 +++++++++++++++++++++------------
1 files changed, 21 insertions(+), 12 deletions(-)
diff --git a/src/main/java/com/moral/task/RabbitMQInsertTask.java b/src/main/java/com/moral/task/RabbitMQInsertTask.java
index 4c1ca30..c87ce5b 100644
--- a/src/main/java/com/moral/task/RabbitMQInsertTask.java
+++ b/src/main/java/com/moral/task/RabbitMQInsertTask.java
@@ -378,6 +378,7 @@
for (Map<String, Object> map : macAndOrganizationIdMap) {
kv.put(map.get("mac").toString(), map.get("organizationId"));
}
+ int count = 0;
for (int i = 0; i <= 358; i++) {
LocalDateTime startTime = value.plusMinutes(i);
LocalDateTime endTime = value.plusMinutes(i + 1);
@@ -388,7 +389,7 @@
devices.put("macs", macList);
devices.put("yearAndMonth", yearAndMonth);
List<Map<String, Object>> realtimeData = historyMinutelyService.getMinutelySensorData(devices);
- XxlJobLogger.log("RabbitMQRealtimeMinutelyData:" + realtimeData.size());
+ count += realtimeData.size();
if (!CollectionUtils.isEmpty(realtimeData)) {
for (Map<String, Object> deviceData : realtimeData) {
if (!ObjectUtils.isEmpty(deviceData)) {
@@ -410,10 +411,12 @@
intersection.stream().forEach(parentId -> rabbitTemplate.convertAndSend(organization_data.getName(), parentId + "." + mac, JSON.toJSONString(deviceData)));
}
}
- ReturnT returnT = new ReturnT(200, "RabbitMQ������������������������������");
- return returnT;
+
}
}
+ XxlJobLogger.log("RabbitMQRealtimeMinutelyData:" + count);
+ ReturnT returnT = new ReturnT(200, "RabbitMQ������������������������������");
+ return returnT;
} catch (Exception e) {
XxlJobLogger.log("RabbitMQRealtimeMinutelyException:" + e.getMessage());
logger.error(e.getMessage());
@@ -512,6 +515,7 @@
for (Map<String, Object> map : macAndOrganizationIdMap) {
kv.put(map.get("mac").toString(), map.get("organizationId"));
}
+ int count = 0;
for (int i = 0; i <= 350; i = i + 5) {
LocalDateTime startTime = value.plusMinutes(i);
LocalDateTime endTime = value.plusMinutes(i + 5);
@@ -522,7 +526,7 @@
devices.put("macs", macList);
devices.put("yearAndMonth", yearAndMonth);
List<Map<String, Object>> realtimeData = historyMinutelyService.getMinutelySensorData(devices);
- XxlJobLogger.log("RabbitMQRealtimeEveryFiveMinutesData:" + realtimeData.size());
+ count += realtimeData.size();
if (!CollectionUtils.isEmpty(realtimeData)) {
for (Map<String, Object> deviceData : realtimeData) {
if (!ObjectUtils.isEmpty(deviceData)) {
@@ -544,10 +548,11 @@
intersection.stream().forEach(parentId -> rabbitTemplate.convertAndSend(organization_data.getName(), parentId + "." + mac, JSON.toJSONString(deviceData)));
}
}
- ReturnT returnT = new ReturnT(200, "RabbitMQ���5������������������������������");
- return returnT;
}
}
+ XxlJobLogger.log("RabbitMQRealtimeEveryFiveMinutesData:" + count);
+ ReturnT returnT = new ReturnT(200, "RabbitMQ���5������������������������������");
+ return returnT;
} catch (Exception e) {
XxlJobLogger.log("RabbitMQRealtimeEveryFiveMinutesException:" + e.getMessage());
logger.error(e.getMessage());
@@ -647,6 +652,7 @@
for (Map<String, Object> map : macAndOrganizationIdMap) {
kv.put(map.get("mac").toString(), map.get("organizationId"));
}
+ int count = 0;
for (int i = 0; i <= 340; i = i + 10) {
LocalDateTime startTime = value.plusMinutes(i);
LocalDateTime endTime = value.plusMinutes(i + 1);
@@ -657,7 +663,7 @@
devices.put("macs", macList);
devices.put("yearAndMonth", yearAndMonth);
List<Map<String, Object>> minutelyDataList = historyMinutelyService.getMinutelySensorData(devices);
- XxlJobLogger.log("RabbitMQMinutelyData:" + minutelyDataList.size());
+ count += minutelyDataList.size();
if (!CollectionUtils.isEmpty(minutelyDataList)) {
for (Map<String, Object> deviceData : minutelyDataList) {
if (!ObjectUtils.isEmpty(deviceData)) {
@@ -680,10 +686,11 @@
intersection.stream().forEach(parentId -> rabbitTemplate.convertAndSend(organization_data.getName(), parentId + "." + mac, JSON.toJSONString(minutelyData)));
}
}
- ReturnT returnT = new ReturnT(200, "RabbitMQ������������������������");
- return returnT;
}
}
+ XxlJobLogger.log("RabbitMQMinutelyData:" + count);
+ ReturnT returnT = new ReturnT(200, "RabbitMQ������������������������");
+ return returnT;
} catch (Exception e) {
XxlJobLogger.log("RabbitMQMinutelyException:" + e.getMessage());
logger.error(e.getMessage());
@@ -780,6 +787,7 @@
for (Map<String, Object> map : macAndOrganizationIdMap) {
kv.put(map.get("mac").toString(), map.get("organizationId"));
}
+ int count = 0;
for (int i = 0; i <= 6; i++) {
LocalDateTime startTime = value.plusHours(i);
LocalDateTime endTime = value.plusHours(i + 1);
@@ -789,7 +797,7 @@
devices.put("end", endTime);
devices.put("macs", macList);
List<Map<String, Object>> hourlyDataList = historyHourlyService.getHourlySensorData(devices);
- XxlJobLogger.log("RabbitMQHourlyData:" + hourlyDataList.size());
+ count += hourlyDataList.size();
if (!CollectionUtils.isEmpty(hourlyDataList)) {
for (Map<String, Object> deviceData : hourlyDataList) {
if (!ObjectUtils.isEmpty(deviceData)) {
@@ -812,10 +820,11 @@
intersection.stream().forEach(parentId -> rabbitTemplate.convertAndSend(organization_data.getName(), parentId + "." + mac, JSON.toJSONString(hourlyData)));
}
}
- ReturnT returnT = new ReturnT(200, "RabbitMQ������������������������");
- return returnT;
}
}
+ XxlJobLogger.log("RabbitMQHourlyData:" + count);
+ ReturnT returnT = new ReturnT(200, "RabbitMQ������������������������");
+ return returnT;
} catch (Exception e) {
XxlJobLogger.log("RabbitMQHourlyException:" + e.getMessage());
logger.error(e.getMessage());
--
Gitblit v1.8.0