From e6a57d1436ead205fc1e4961228c538bc15afc76 Mon Sep 17 00:00:00 2001
From: hongawen <83944980@qq.com>
Date: Mon, 4 Dec 2023 10:39:26 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BB=A3=E7=A0=81=E8=B0=83=E6=95=B4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../njcn/csharmonic/service/impl/CsEventPOServiceImpl.java    | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/service/impl/CsEventPOServiceImpl.java b/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/service/impl/CsEventPOServiceImpl.java
index b0beb35..68100fa 100644
--- a/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/service/impl/CsEventPOServiceImpl.java
+++ b/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/service/impl/CsEventPOServiceImpl.java
@@ -137,6 +137,10 @@ public class CsEventPOServiceImpl extends ServiceImpl<CsEventPOMapper, CsEventPO
             if (Objects.isNull(cfgStream) || Objects.isNull(datStream)) {
                 throw new BusinessException(WaveFileResponseEnum.ANALYSE_WAVE_NOT_FOUND);
             }
+            //持续时间超过30S时，iType调整为2，按32采样率采集数据
+            if (Objects.nonNull(eventDetail.getPersistTime()) && eventDetail.getPersistTime() > 30) {
+                iType = 2;
+            }
             waveDataDTO = waveFileComponent.getComtrade(cfgStream, datStream, iType);
         } catch (Exception e) {
             throw new BusinessException(WaveFileResponseEnum.WAVE_DATA_INVALID);