lihongjie/coal
1
0
Fork 0
mirror of https://codeup.aliyun.com/64f7d6b8ce01efaafef1e678/coal/coal.git synced 2026-01-25 23:57:12 +08:00
Code Issues Packages Projects Releases Wiki Activity

完善

Browse Source
This commit is contained in:
lihongjie0209
2024-08-28 23:12:57 +08:00
parent 404d8362b2
commit 1c7a752749
1 changed files with 11 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
src/main/java/cn/lihongjie/coal/dataCollector/listener/YbIotListener.java
View File

@@ -15,6 +15,7 @@ import cn.lihongjie.coal.rabbitmq.RabbitMQConfiguration;
import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.node.ObjectNode;
import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j;
@@ -98,7 +99,8 @@ public class YbIotListener {
return;
}
JsonNode jsonNode = objectMapper.readTree(body);
ObjectNode jsonNode = objectMapper.readValue(objectMapper.readTree(body).asText(), ObjectNode.class);
DataCollectorLogEntity logEntity = new DataCollectorLogEntity();
logEntity.setOrganizationId(dataCollector.getOrganizationId());
@@ -116,19 +118,19 @@ public class YbIotListener {
JsonNode data = jsonNode.get("data");
if (code.asInt() != 200) {
log.error("ybiot code is not 200: {} {}", code, msg.asText());
log.warn("ybiot code is not 200: {} {}", code, msg.asText());
return;
}
if (data == null) {
log.error("ybiot data is null");
log.warn("ybiot data is null");
return;
}
JsonNode list = data.get("list");
if (list == null) {
log.error("ybiot list is null");
log.warn("ybiot list is null");
return;
}
@@ -136,7 +138,7 @@ public class YbIotListener {
List<String> productIds =
StreamSupport.stream(list.spliterator(), false)
.map(x -> x.get("ProductId").asText())
.map(x -> x.get("ProductID").asText())
.toList();
List<MeterEntity> meters = meterService.findByProductIDs(productIds);
@@ -152,7 +154,7 @@ public class YbIotListener {
String productID = node.get("ProductID").asText();
if (StringUtils.isBlank(productID)) {
log.error("productID is blank");
log.warn("productID is blank");
continue;
}
@@ -160,7 +162,7 @@ public class YbIotListener {
if (!node.has("MeterPositiveFlow")) {
log.error("MeterPositiveFlow is null");
log.warn("MeterPositiveFlow is null");
continue;
}
@@ -168,7 +170,7 @@ public class YbIotListener {
if (!node.has("LastOnlineDate")) {
log.error("LastOnlineDate is null");
log.warn("LastOnlineDate is null");
continue;
}
@@ -185,7 +187,7 @@ public class YbIotListener {
MeterEntity meter = meterMap.get(productID);
if (meter == null) {
log.error("meter not found: {}", productID);
log.warn("meter not found: {}", productID);
continue;
}