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("车号")));