bugfix

2026-01-25 07:46:40 +08:00 · 2024-10-03 09:11:03 +08:00
parent e513260226
commit a383495fcb
1 changed files with 2 additions and 0 deletions
--- 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);
                }