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 c2589a66..615bd98d 100644
--- a/src/main/java/cn/lihongjie/coal/dataCollector/listener/WeightListener.java
+++ b/src/main/java/cn/lihongjie/coal/dataCollector/listener/WeightListener.java
@@ -204,6 +204,16 @@ public class WeightListener {
                                 flowNumber,
                                 device.getId());
                         deviceData = flowNumberMap.get(flowNumber);
+
+                        if (StringUtils.equals(deviceData.getArchiveStatus(), "1")) {
+                            log.info(
+                                    "data already archived: {} {} {}",
+                                    seqNumber,
+                                    flowNumber,
+                                    device.getId());
+                            return;
+                        }
+
                         deviceData.setInvalid(true);
                     } else {
 
@@ -422,6 +432,16 @@ public class WeightListener {
                                 flowNumber,
                                 device.getId());
                         deviceData = seqNumberMap.get(seqNumber);
+
+                        if (StringUtils.equals(deviceData.getArchiveStatus(), "1")) {
+                            log.info(
+                                    "data already archived: {} {} {}",
+                                    seqNumber,
+                                    flowNumber,
+                                    device.getId());
+                            return;
+                        }
+
                     }
                     //                            log.info(x.toPrettyString());