From d94384668cc8e320ca6ac77c86a35cd601cd332c Mon Sep 17 00:00:00 2001
From: hzj <826100833@qq.com>
Date: Wed, 30 Jul 2025 14:49:11 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E8=87=AA=E5=8A=A8=E8=A1=A5?=
 =?UTF-8?q?=E6=8B=9B=E6=95=B0=E6=8D=AE=E5=A4=96=E9=83=A8=E6=8E=A5=E5=8F=A3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../stat/service/impl/MessageAnalysisServiceImpl.java | 11 ++++++++++-
 1 file changed, 10 insertions(+), 1 deletion(-)

diff --git a/analysis/stat/stat-boot/src/main/java/com/njcn/stat/service/impl/MessageAnalysisServiceImpl.java b/analysis/stat/stat-boot/src/main/java/com/njcn/stat/service/impl/MessageAnalysisServiceImpl.java
index ddd8f9e..63ea6a7 100644
--- a/analysis/stat/stat-boot/src/main/java/com/njcn/stat/service/impl/MessageAnalysisServiceImpl.java
+++ b/analysis/stat/stat-boot/src/main/java/com/njcn/stat/service/impl/MessageAnalysisServiceImpl.java
@@ -92,7 +92,10 @@ public class MessageAnalysisServiceImpl implements MessageAnalysisService {
             if(Objects.equals(DataTypeEnum.HARMONIC.getCode(),dataType)){
                 MessageHarmonicDataSet messageHarmonicDataSet = JSONObject.parseObject(value, MessageHarmonicDataSet.class);
                 LocalDateTime localDateTime = messageHarmonicDataSet.getTIME();
-
+                //排除上电下电等情况前置上送上不是整分的数据
+                if(!(localDateTime.getSecond() == 0)){
+                    return;
+                }
                 Integer flag = messageHarmonicDataSet.getFLAG();
                 MessageP pq = messageHarmonicDataSet.getPQ();
                 MessageV v = messageHarmonicDataSet.getV();
@@ -384,6 +387,9 @@ public class MessageAnalysisServiceImpl implements MessageAnalysisService {
             }else if(Objects.equals(DataTypeEnum.FLUC.getCode(),dataType)){
                 MessageFlucDataSet messageFlucDataSet = JSONObject.parseObject(value, MessageFlucDataSet.class);
                 LocalDateTime localDateTime = messageFlucDataSet.getTIME(); //LocalDateTime.ofInstant(messageFlucDataSet.getTIME(), ZoneId.systemDefault()).withNano(0).withSecond(0);
+                if(!(localDateTime.getSecond() == 0)){
+                    return;
+                }
                 Integer flag = messageFlucDataSet.getFLAG();
                 MessageFs fs = messageFlucDataSet.getFs();
                 //短时闪变ABC
@@ -458,6 +464,9 @@ public class MessageAnalysisServiceImpl implements MessageAnalysisService {
                 LocalDateTime localDateTime = messagePltDataSet.getTIME();
                 Integer flag = messagePltDataSet.getFLAG();
                 MessageFl fl = messagePltDataSet.getFl();
+                if(!(localDateTime.getSecond() == 0)){
+                    return;
+                }
                 //长时闪变ABC
                 if(Objects.nonNull(fl)){
                     MessagePlt a = fl.getA();