From 4dbba6eb06d8896a396348fa7ea0e96a915249fb Mon Sep 17 00:00:00 2001
From: zhangyuxiang <1323804152@qq.com>
Date: Mon, 16 Jun 2025 15:38:00 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E7=9B=91=E6=B5=8B=E5=9B=A0?=
 =?UTF-8?q?=E7=B4=A0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 consumers/consumerZWYHBJCAS.go | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/consumers/consumerZWYHBJCAS.go b/consumers/consumerZWYHBJCAS.go
index 4774110..8b08328 100644
--- a/consumers/consumerZWYHBJCAS.go
+++ b/consumers/consumerZWYHBJCAS.go
@@ -154,7 +154,7 @@ func (the *consumerZWYHBJCAS) getStructIds() []int64 {
 func (the *consumerZWYHBJCAS) getEs1HourAggData() {
 	start, end := utils.GetTimeRangeByHour(-1)
 	log.Printf("查询数据时间范围 %s - %s", start, end)
-	hourFactorIds := []int{15, 18, 20}
+	hourFactorIds := []int{102, 1914, 1917}
 	structIds := the.getStructIds()
 	for _, structId := range structIds {
 		for _, factorId := range hourFactorIds {
@@ -182,7 +182,7 @@ func (the *consumerZWYHBJCAS) getEs10minAggData() {
 	//utils.GetTimeRangeBy10min() 由于振动数据实时性问题 改用一小时统一上报
 	start, end := utils.GetTimeRangeByHour(-1)
 	log.Printf("查询10min数据时间范围 %s - %s", start, end)
-	factorIds := []int{28, 592}
+	factorIds := []int{1919, 1920}
 	structIds := the.getStructIds()
 	for _, structId := range structIds {
 		for _, factorId := range factorIds {