From 3c0ada304d6743d235e649d37a44289effa6b94f Mon Sep 17 00:00:00 2001
From: lihongjie0209 <lihongjie0209@gmail.com>
Date: Thu, 18 Apr 2024 09:32:06 +0800
Subject: [PATCH] bugfix

---
 .../coal/dataCollector/listener/WeightListener.java       | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/src/main/java/cn/lihongjie/coal/dataCollector/listener/WeightListener.java b/src/main/java/cn/lihongjie/coal/dataCollector/listener/WeightListener.java
index c359cf0f..655ee6df 100644
--- a/src/main/java/cn/lihongjie/coal/dataCollector/listener/WeightListener.java
+++ b/src/main/java/cn/lihongjie/coal/dataCollector/listener/WeightListener.java
@@ -160,17 +160,17 @@ public class WeightListener {
 
                 nodes.forEach(
                         x -> {
+                            WeightDeviceDataEntity deviceData = new WeightDeviceDataEntity();
                             var flowNumber = x.get("流水号").asText();
                             if (flowNumberMap.containsKey(flowNumber)) {
                                 log.info("data already exists: {} {}", flowNumber, device.getId());
-                                return;
+                                deviceData = flowNumberMap.get(flowNumber);
                             }
-//                            log.info(x.toPrettyString());
+                            //                            log.info(x.toPrettyString());
 
-                            WeightDeviceDataEntity deviceData = new WeightDeviceDataEntity();
                             deviceData.setDevice(device);
                             deviceData.setOrganizationId(device.getOrganizationId());
-                            
+
                             deviceData.setSequenceNumber(toInteger(x.get("序号")));
                             deviceData.setFlowNumber(toString(x.get("流水号")));
                             deviceData.setPlateNo(toString(x.get("车号")));