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 }