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 615bd98d..1c71bc96 100644
--- a/src/main/java/cn/lihongjie/coal/dataCollector/listener/WeightListener.java
+++ b/src/main/java/cn/lihongjie/coal/dataCollector/listener/WeightListener.java
@@ -170,7 +170,7 @@ public class WeightListener {
 
         var flowNumbers =
                 StreamSupport.stream(nodes.spliterator(), false)
-                        .map(x -> x.get("原流水号").asInt())
+                        .map(x -> x.get("原流水号").asText())
                         .collect(Collectors.toList());
 
         Map<String, WeightDeviceDataEntity> flowNumberMap =