From f1f702f03e617ac8b49ea5fe484b41885ea83f0c Mon Sep 17 00:00:00 2001
From: kaiyu <404897439@qq.com>
Date: Tue, 13 Jul 2021 16:52:05 +0800
Subject: [PATCH] screen-manage 删除local配置文件
---
screen-api/src/main/java/com/moral/api/kafka/consumer/SecondDataConsumer.java | 24 ++++++++++++++++--------
1 files changed, 16 insertions(+), 8 deletions(-)
diff --git a/screen-api/src/main/java/com/moral/api/kafka/consumer/SecondDataConsumer.java b/screen-api/src/main/java/com/moral/api/kafka/consumer/SecondDataConsumer.java
index c0660bb..ac723f2 100644
--- a/screen-api/src/main/java/com/moral/api/kafka/consumer/SecondDataConsumer.java
+++ b/screen-api/src/main/java/com/moral/api/kafka/consumer/SecondDataConsumer.java
@@ -29,7 +29,7 @@
@Component
public class SecondDataConsumer implements ConsumerSeekAware {
- @KafkaListener(topics = "second_data", groupId = "SecondsDataGroup3")
+ @KafkaListener(topics = "second_data", groupId = "SecondsDataGroup998")
public void listen(ConsumerRecord<String, String> record, Consumer consumer) throws Exception {
String messageStr = record.value();
Map<String, String> message = (Map<String, String>) JSON.parse(messageStr);
@@ -46,11 +46,14 @@
List<Sensor> sensors = device.getVersion().getSensors();//������������������������������
for (Sensor sensor : sensors) {
String code = sensor.getCode();
+ String showUnit = sensor.getShowUnit();
String showUnitKey = sensor.getShowUnitKey();
String unitKey = sensor.getUnitKey();
+ String unit = sensor.getUnit();
+ String sourceData = message.get(code);
//������������
//������������
- if (!unitKey.equals(showUnitKey)) {
+ if (!unitKey.equals(showUnitKey)) {//������������������������������������������������������������
String formula = sensor.getFormula();
//������sensor���������������������������������������������
if (ObjectUtils.isEmpty(formula)) {
@@ -61,13 +64,18 @@
}
}
//������������
- UnitConvertUtils.calculate(message.get(code),formula);
+ String resultData = UnitConvertUtils.calculate(message.get(code), formula);
+ if (resultData != null) {
+ resultData+=showUnit;
+ }else{//���������������������������null���������������������������������������������������������������
+ resultData = sourceData+unit;
+ }
+ resultMessgae.put(sensor.getCode(), resultData);
+ } else {
+ //������������
+ sourceData += showUnit;
+ resultMessgae.put(sensor.getCode(), sourceData);
}
- //������������
- String showUnit = sensor.getShowUnit();
- String value = message.get(code);
- value += showUnit;
- resultMessgae.put(sensor.getCode(), value);
}
resultMessgae.put("DataTime", message.get("DataTime"));
socket.sendMessage(JSON.toJSONString(resultMessgae));
--
Gitblit v1.8.0