From 47383a6030bcb03d00ed4a90cd5582035fb3c932 Mon Sep 17 00:00:00 2001
From: lihongjie0209 <lihongjie0209@gmail.com>
Date: Wed, 1 May 2024 20:43:57 +0800
Subject: [PATCH] =?UTF-8?q?=E7=A3=85=E6=88=BF=E6=95=B0=E6=8D=AE=E5=BD=92?=
 =?UTF-8?q?=E6=A1=A3=E4=B9=8B=E5=90=8E=E4=B8=8D=E5=86=8D=E5=90=8C=E6=AD=A5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../listener/WeightListener.java              | 20 +++++++++++++++++++
 1 file changed, 20 insertions(+)

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());