diff --git a/tasks/water_group.go b/tasks/water_group.go index e7766be..49600c2 100644 --- a/tasks/water_group.go +++ b/tasks/water_group.go @@ -74,5 +74,5 @@ func dealYesterday(gid string) { notifyMsgs = append(notifyMsgs, " \n请未上榜的群友多多反思。") log.Printf("排行榜: \n%s", strings.Join(notifyMsgs, "\n")) - go utils.SendMessage(gid, "", strings.Join(notifyMsgs, "\n")) + go utils.SendMessage(gid, "", strings.Join(notifyMsgs, "\n"), 0) } diff --git a/utils/send.go b/utils/send.go index a284d7b..dabe5f1 100644 --- a/utils/send.go +++ b/utils/send.go @@ -4,6 +4,7 @@ import ( "encoding/json" "github.com/go-resty/resty/v2" "log" + "time" ) // SendMessage @@ -11,7 +12,11 @@ import ( // @param toId // @param atId // @param msg -func SendMessage(toId, atId, msg string) { +func SendMessage(toId, atId, msg string, retryCount int) { + if retryCount > 5 { + log.Printf("重试五次失败,停止发送") + return + } // 组装参数 param := map[string]any{ "wxid": toId, // 群或好友Id @@ -26,7 +31,9 @@ func SendMessage(toId, atId, msg string) { Post("http://10.0.0.73:19088/api/sendTextMsg") if err != nil { log.Printf("发送文本消息失败: %s", err.Error()) - return + // 休眠五秒后重新发送 + time.Sleep(5 * time.Second) + SendMessage(toId, atId, msg, retryCount+1) } log.Printf("发送文本消息结果: %s", resp.String()) }