From 3d685203e77cd8deb2982856ee70f4d51d7ce8db Mon Sep 17 00:00:00 2001
From: lizijie <lzjiiie@163.com>
Date: Fri, 20 May 2022 11:33:42 +0800
Subject: [PATCH] 千灯转发数据添加恶臭两台微站数据
---
src/main/java/com/moral/task/RabbitMQInsertQiandengPark.java | 29 +++++++++++++++++++++++++++++
1 files changed, 29 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/moral/task/RabbitMQInsertQiandengPark.java b/src/main/java/com/moral/task/RabbitMQInsertQiandengPark.java
index 9bd3ba0..86e7c94 100644
--- a/src/main/java/com/moral/task/RabbitMQInsertQiandengPark.java
+++ b/src/main/java/com/moral/task/RabbitMQInsertQiandengPark.java
@@ -1,6 +1,9 @@
package com.moral.task;
import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
+import com.moral.entity.History;
+import com.moral.mapper.HistoryMapper;
import com.moral.service.*;
import com.xxl.job.core.biz.model.ReturnT;
import com.xxl.job.core.handler.annotation.XxlJob;
@@ -10,10 +13,12 @@
import org.springframework.amqp.core.TopicExchange;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.stereotype.Component;
import org.springframework.util.CollectionUtils;
import org.springframework.util.ObjectUtils;
import javax.annotation.Resource;
+import java.text.SimpleDateFormat;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.time.temporal.ChronoUnit;
@@ -26,6 +31,7 @@
* @author: lizijie
* @create: 2022-05-13 08:58
**/
+@Component
public class RabbitMQInsertQiandengPark {
private static transient Logger logger = LoggerFactory.getLogger(RabbitMQInsertQiandengPark.class);
@@ -40,6 +46,9 @@
@Resource
private HistoryHourlyService historyHourlyService;
+
+ @Resource
+ private HistoryMapper historyMapper;
@Resource
private OrganizationRelationService organizationRelationService;
@@ -92,6 +101,16 @@
devices.put("macs", macList);
devices.put("yearAndMonth", yearAndMonth);
List<Map<String, Object>> minutelyData = historyMinutelyService.getMinutelySensorData(devices);
+ SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMdd");
+ 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);
XxlJobLogger.log("RabbitMQMinutelyData:" + minutelyData.size());
if (!CollectionUtils.isEmpty(minutelyData)) {
for (Map<String, Object> deviceData : minutelyData) {
@@ -149,6 +168,16 @@
devices.put("end", endTime);
devices.put("macs", macList);
List<Map<String, Object>> minutelyData = historyHourlyService.getHourlySensorData(devices);
+ SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMdd");
+ 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);
XxlJobLogger.log("RabbitMQHourlyData:" + minutelyData.size());
if (!CollectionUtils.isEmpty(minutelyData)) {
for (Map<String, Object> deviceData : minutelyData) {
--
Gitblit v1.8.0