重构请求处理逻辑并增加重试机制

将原有的httpGet函数替换为新的httpProcessRetry函数，该函数在遇到错误时会尝试最多三次请求，并且合并了多次请求的错误信息。同时简化了状态码处理逻辑，并确保在所有URL处理完毕后发送通知。

src/watcher/watcher.go

@@ -7,6 +7,7 @@ import (
 	"github.com/SongZihuan/web-watcher/src/logger"
 	"github.com/SongZihuan/web-watcher/src/notify"
 	"net/http"
+	"strings"
 )
 
 func Run() error {
@@ -14,60 +15,15 @@ func Run() error {
 		panic("config is not ready")
 	}
 
-MainCycle:
 	for _, url := range config.GetConfig().Watcher.URLs {
 		logger.Infof("开始请求 %s", url.Name)
 
-		statusCode, err := httpGet(url.URL, url.SkipTLSVerify.IsEnable(false))
+		_, err := httpProcessRetry(url.URL, url.Name, url.Status, url.SkipTLSVerify.IsEnable(false))
 		if err != nil {
 			logger.Errorf("请求 %s 出现异常：%s", url.Name, err.Error())
 			notify.NewRecord(url.Name, url.URL, err.Error())
-			continue MainCycle
 		}
 
-		for _, s := range url.Status {
-			switch s {
-			case "xxx":
-				logger.Infof("处理 %s 完成", url.Name)
-				continue MainCycle
-			case "1xx":
-				if statusCode >= 100 && statusCode <= 199 {
-					logger.Infof("处理 %s 完成", url.Name)
-					continue MainCycle
-				}
-			case "2xx":
-				if statusCode >= 200 && statusCode <= 299 {
-					logger.Infof("处理 %s 完成", url.Name)
-					continue MainCycle
-				}
-			case "3xx":
-				if statusCode >= 300 && statusCode <= 399 {
-					logger.Infof("处理 %s 完成", url.Name)
-					continue MainCycle
-				}
-			case "4xx":
-				if statusCode >= 400 && statusCode <= 499 {
-					logger.Infof("处理 %s 完成", url.Name)
-					continue MainCycle
-				}
-			case "5xx":
-				if statusCode >= 500 && statusCode <= 599 {
-					logger.Infof("处理 %s 完成", url.Name)
-					continue MainCycle
-				}
-			default:
-				status := fmt.Sprintf("%d", statusCode)
-				if status == s {
-					logger.Infof("处理 %s 完成", url.Name)
-					continue MainCycle
-				}
-			}
-		}
-
-		errMsg := fmt.Sprintf("错误的状态码 （%d）", statusCode)
-		logger.Errorf("请求 %s 出现异常：%s", url.Name, errMsg)
-		notify.NewRecord(url.Name, url.URL, errMsg)
-
 		logger.Infof("处理 %s 完成", url.Name)
 	}
 
@@ -76,7 +32,43 @@ MainCycle:
 	return nil
 }
 
-func httpGet(url string, skipTLSVerify bool) (int, error) {
+func httpProcessRetry(url string, name string, statusList []string, skipTLSVerify bool) (int, error) {
+	var err1, err2, err3 error
+	var statusCode int
+
+	statusCode, err1 = httpProcessGet(url, name, statusList, skipTLSVerify)
+	if err1 == nil {
+		return statusCode, nil
+	}
+
+	statusCode, err2 = httpProcessGet(url, name, statusList, skipTLSVerify)
+	if err2 == nil {
+		return statusCode, nil
+	}
+
+	statusCode, err3 = httpProcessGet(url, name, statusList, skipTLSVerify)
+	if err3 == nil {
+		return statusCode, nil
+	}
+
+	// 去除重复
+	var errMap = make(map[string]bool, 3)
+	errMap[err1.Error()] = true
+	errMap[err2.Error()] = true
+	errMap[err3.Error()] = true
+
+	var errStrBuilder strings.Builder
+	var n = 0
+	for err, _ := range errMap {
+		n += 1
+		errStrBuilder.WriteString(fmt.Sprintf("检查 %s 错误[%d]: %s; ", name, n, err))
+	}
+
+	err := fmt.Errorf("%s", strings.TrimSpace(errStrBuilder.String()))
+	return -1, err
+}
+
+func httpProcessGet(url string, name string, statusList []string, skipTLSVerify bool) (int, error) {
 	// 创建一个自定义的Transport，这样我们可以访问TLS连接状态
 	tr := &http.Transport{
 		TLSClientConfig: &tls.Config{InsecureSkipVerify: skipTLSVerify}, // 忽略服务器证书验证
@@ -88,11 +80,45 @@ func httpGet(url string, skipTLSVerify bool) (int, error) {
 	// 发送请求
 	resp, err := client.Get(url)
 	if err != nil {
-		return 0, fmt.Errorf("发送 Get 请求错误：%s", err.Error())
+		return 0, fmt.Errorf("获取 GET %s 请求错误：%s", name, err.Error())
 	}
 	defer func() {
 		_ = resp.Body.Close()
 	}()
 
-	return resp.StatusCode, nil
+	statusCode := resp.StatusCode
+
+	for _, s := range statusList {
+		switch s {
+		case "xxx":
+			return statusCode, nil
+		case "1xx":
+			if statusCode >= 100 && statusCode <= 199 {
+				return statusCode, nil
+			}
+		case "2xx":
+			if statusCode >= 200 && statusCode <= 299 {
+				return statusCode, nil
+			}
+		case "3xx":
+			if statusCode >= 300 && statusCode <= 399 {
+				return statusCode, nil
+			}
+		case "4xx":
+			if statusCode >= 400 && statusCode <= 499 {
+				return statusCode, nil
+			}
+		case "5xx":
+			if statusCode >= 500 && statusCode <= 599 {
+				return statusCode, nil
+			}
+		default:
+			status := fmt.Sprintf("%d", statusCode)
+			if status == s {
+				return statusCode, nil
+			}
+		}
+	}
+
+	return statusCode, fmt.Errorf("检查 GET %s 状态码错误: %d", name, statusCode)
 }