From 6786a50444373e069e3cdb30409443f64c48834b Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=87=8C=E6=B5=B7=E4=BB=B2=E5=AD=90?= <ysg@myschools.me>
Date: Mon, 17 Oct 2022 23:30:48 +0800
Subject: [PATCH] init

---
 service/probe-service.go | 25 ++++++++++++++++---------
 1 file changed, 16 insertions(+), 9 deletions(-)

diff --git a/service/probe-service.go b/service/probe-service.go
index 4c32131..9fcdde1 100644
--- a/service/probe-service.go
+++ b/service/probe-service.go
@@ -14,7 +14,7 @@ import (
 // 探针
 func Probe() {
 	for {
-		time.Sleep(time.Second)
+		time.Sleep(10 * time.Second)
 		db, err := mysql.New()
 		if err != nil {
 			exceptionless.SubmitAppError("Probe", "mysql.New", nil, err)
@@ -22,7 +22,7 @@ func Probe() {
 		}
 
 		var domains []*model.Domain
-		if err := db.Where("updated_at<?", time.Now().Add(-10*time.Minute)).Find(&domains).Error; err != nil {
+		if err := db.Where("updated_at<?", time.Now().Add(-3*time.Minute)).Find(&domains).Error; err != nil {
 			if err != gorm.ErrRecordNotFound {
 				exceptionless.SubmitAppError("Probe", "mysql.Find", nil, err)
 				continue
@@ -30,13 +30,20 @@ func Probe() {
 		}
 
 		for _, d := range domains {
-			for i := 0; i < 500; i++ {
-				url := fmt.Sprintf(`https://www.%s.%s`, randSeq(), d.Root)
-				if url == "" {
-					continue
-				}
-				siteAccess(&url)
-			}
+			go probeRequest(d)
+		}
+	}
+}
+
+func probeRequest(domain *model.Domain) {
+	db, _ := mysql.New()
+	for i := 0; i < 100; i++ {
+		url := fmt.Sprintf(`https://www.%s.%s`, randSeq(), domain.Root)
+		siteAccess(&url)
+		domain.UpdatedAt = time.Now()
+		if err := db.Updates(domain).Error; err != nil {
+			exceptionless.SubmitAppError("probeRequest", "mysql.Updates", nil, err)
+			continue
 		}
 	}
 }