From 33d898d8146223184fcaab82a9e16649434a1ab6 Mon Sep 17 00:00:00 2001
From: lizijie <lzjiiie@163.com>
Date: Fri, 09 Sep 2022 17:47:54 +0800
Subject: [PATCH] 千灯数据转发bug修改
---
src/main/java/com/moral/task/RabbitMQInsertQiandengPark.java | 16 ++++++++++------
1 files changed, 10 insertions(+), 6 deletions(-)
diff --git a/src/main/java/com/moral/task/RabbitMQInsertQiandengPark.java b/src/main/java/com/moral/task/RabbitMQInsertQiandengPark.java
index 91b1e10..de8a97b 100644
--- a/src/main/java/com/moral/task/RabbitMQInsertQiandengPark.java
+++ b/src/main/java/com/moral/task/RabbitMQInsertQiandengPark.java
@@ -176,12 +176,16 @@
String yearMonthDay = sdf.format(new Date());
History guodu = historyMapper.selectLastDataByMac(yearMonthDay, "jsxlqxpc000001");
History baihua = historyMapper.selectLastDataByMac(yearMonthDay, "jsxlqxpc000002");
- Map<String,Object> guoduValue = JSONObject.parseObject(guodu.getValue().toString());
- JSONObject baihuaValue = JSONObject.parseObject(baihua.getValue().toString());
- guoduValue.put("mac","jsxlqxpc000001");
- baihuaValue.put("mac","jsxlqxpc000002");
- minutelyData.add(guoduValue);
- minutelyData.add(baihuaValue);
+ if (!ObjectUtils.isEmpty(guodu)){
+ Map<String,Object> guoduValue = JSONObject.parseObject(guodu.getValue().toString());
+ guoduValue.put("mac","jsxlqxpc000001");
+ minutelyData.add(guoduValue);
+ }
+ if (!ObjectUtils.isEmpty(baihua)){
+ JSONObject baihuaValue = JSONObject.parseObject(baihua.getValue().toString());
+ baihuaValue.put("mac","jsxlqxpc000002");
+ minutelyData.add(baihuaValue);
+ }
XxlJobLogger.log("RabbitMQHourlyData:" + minutelyData.size());
if (!CollectionUtils.isEmpty(minutelyData)) {
for (Map<String, Object> deviceData : minutelyData) {
--
Gitblit v1.8.0