From 6e8fea7023b59fba9c5e4a7ef288766e3b47d068 Mon Sep 17 00:00:00 2001
From: yfh <yuan.fenghua@free-sun.com.cn>
Date: Thu, 3 Oct 2024 20:40:41 +0800
Subject: [PATCH] =?UTF-8?q?expireSeconds=E5=B0=8F=E4=BA=8E3=E5=88=86?=
 =?UTF-8?q?=E9=92=9F=EF=BC=8C=E8=BF=94=E5=9B=9E180=E7=A7=92?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 et_calc/group/calcTask.go | 15 ++++++++++-----
 1 file changed, 10 insertions(+), 5 deletions(-)

diff --git a/et_calc/group/calcTask.go b/et_calc/group/calcTask.go
index 4d6c2f1..d53f0d3 100644
--- a/et_calc/group/calcTask.go
+++ b/et_calc/group/calcTask.go
@@ -11,11 +11,11 @@ import (
 	"time"
 )
 
-// 沉降分组业务处理说明：
-// dimensionId 对应WEB端配置：组网配置/采集策略
-// taskId是维度下的schema每次调用的时候，生成一个唯一的
-// 分组配置要求：分组计算中的测点的【采集策略】同一个周期采集
-// 特殊场景：上报类测点，要进行分组计算，需要在协议里处理，输出_acq_number确保一致
+//沉降分组业务处理说明：
+//dimensionId 对应WEB端配置：组网配置/采集策略
+//taskId是维度下的schema每次调用的时候，生成的一个编码
+//分组配置要求：分组计算中的测点的【采集策略】同一个周期采集
+//特殊场景：上报类测点，要进行分组计算，需要在协议里处理，输出_acq_number确保一致
 
 type CalcTask struct {
 	*BaseDueTask
@@ -44,6 +44,7 @@ func (t *CalcTask) AddStationData(data common_models.Station) {
 		return
 	}
 	t.stationMap[data.Info.Id] = data
+	log.Println(t.R())
 }
 
 // CheckIntegrity 检查计算项是否完整
@@ -70,6 +71,10 @@ func (t *CalcTask) SetTimeout() int {
 		expireSeconds = FromDimension(t.dimensionId)
 	}
 
+	// 小于3分钟，返回180秒
+	if expireSeconds < 60*3 {
+		expireSeconds = 60 * 3
+	}
 	t.SetDeadLineTime(expireSeconds)
 	return expireSeconds
 }