From 978aa6a04ec6b3f2d4ee7a89c94afcd352f97edb Mon Sep 17 00:00:00 2001
From: lixiangwuxian <mail@lxtend.com>
Date: Fri, 8 Nov 2024 00:43:06 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20=E4=BF=AE=E5=A4=8D=E5=90=84=E7=A7=8D?=
 =?UTF-8?q?=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 action/action.go                      | 4 ++++
 handler/steamplaying/steam_playing.go | 2 +-
 util/url.go                           | 2 +-
 3 files changed, 6 insertions(+), 2 deletions(-)

diff --git a/action/action.go b/action/action.go
index e2338b9..2b0cfe3 100644
--- a/action/action.go
+++ b/action/action.go
@@ -17,6 +17,10 @@ type actionManager struct {
 	botConn *websocket.Conn
 }
 
+func (am *actionManager) Started() bool {
+	return am.botConn != nil
+}
+
 func (am *actionManager) SetConn(conn *websocket.Conn) {
 	am.botConn = conn
 }
diff --git a/handler/steamplaying/steam_playing.go b/handler/steamplaying/steam_playing.go
index dfed1e1..821fda0 100644
--- a/handler/steamplaying/steam_playing.go
+++ b/handler/steamplaying/steam_playing.go
@@ -177,7 +177,6 @@ func RoundCheckSteamPlaying() {
 	once := true
 	playingMap := map[int64]map[string]string{}
 	for {
-		time.Sleep(5 * time.Second)
 		groups, err := getAllGroupID()
 		if err != nil {
 			fmt.Println("获取群列表失败: ", err)
@@ -185,6 +184,7 @@ func RoundCheckSteamPlaying() {
 		}
 
 		for _, group := range groups {
+			time.Sleep(3 * time.Second)
 			if _, ok := playingMap[group]; !ok {
 				playingMap[group] = map[string]string{}
 			}
diff --git a/util/url.go b/util/url.go
index 24c07bf..28c07d4 100644
--- a/util/url.go
+++ b/util/url.go
@@ -41,7 +41,7 @@ func DownloadFile(url string, filepath string) error {
 	// resp, err := http.Get(url)
 	var resp *http.Response
 	var err error
-	var maxRetry = 5
+	var maxRetry = 100
 	var retry = 0
 	for resp, err = http.Get(url); err != nil && retry < maxRetry; resp, err = http.Get(url) {
 		fmt.Println("下载失败，正在重试...")