修改检测指标逻辑

models/index/index.go

@@ -4,6 +4,8 @@ import (
 	"context"
 	"hongze/mysteel_watch/global"
 	"hongze/mysteel_watch/models/base"
+	"hongze/mysteel_watch/utils"
+	"time"
 )
 
 // 钢联化工指标数据
@@ -77,8 +79,9 @@ type IndexDeleteReq struct {
 }
 
 func (d *BaseFromMysteelChemicalIndex) GetIndexCreate() (item []*BaseFromMysteelChemicalIndex, err error) {
+	endTime := time.Now().Add(-2 * time.Minute).Format(utils.FormatDateTime)
 	err = global.MYSQL["hzdata"].WithContext(context.TODO()).Model(d).
-		Where("index_name = '' ").Find(&item).Error
+		Where("index_name = '' AND create_time<=? ", endTime).Find(&item).Error
 	return
 }