From a383495fcb1b22d9821d49be2348539617a007d9 Mon Sep 17 00:00:00 2001 From: lihongjie0209 Date: Thu, 3 Oct 2024 09:11:03 +0800 Subject: [PATCH] bugfix --- .../cn/lihongjie/coal/dataCollector/listener/YbIotListener.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/main/java/cn/lihongjie/coal/dataCollector/listener/YbIotListener.java b/src/main/java/cn/lihongjie/coal/dataCollector/listener/YbIotListener.java index bacc06f7..3b1f7280 100644 --- a/src/main/java/cn/lihongjie/coal/dataCollector/listener/YbIotListener.java +++ b/src/main/java/cn/lihongjie/coal/dataCollector/listener/YbIotListener.java @@ -184,6 +184,7 @@ public class YbIotListener { entity.setValue(meterPositiveFlow); + MeterEntity meter = meterMap.get(productID); if (meter == null) { @@ -192,6 +193,7 @@ public class YbIotListener { } entity.setMeter(meter); + entity.setOrganizationId(meter.getOrganizationId()); entities.add(entity); }