From 5845828066b74cb3b1844d01832cdd030cc46672 Mon Sep 17 00:00:00 2001
From: timerzz <zhhgzhhgzhhg@163.com>
Date: Fri, 28 Mar 2025 11:01:32 +0800
Subject: [PATCH] =?UTF-8?q?update=20=E8=AE=A1=E7=AE=97=E5=88=A9=E6=B6=A6?=
 =?UTF-8?q?=E7=8E=87=E6=94=AF=E6=8C=81=E5=A4=9A=E4=B8=AAid?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 rate/rate.go | 15 +++++++++++++++
 1 file changed, 15 insertions(+)

diff --git a/rate/rate.go b/rate/rate.go
index 1b08417..0d0ef89 100644
--- a/rate/rate.go
+++ b/rate/rate.go
@@ -4,12 +4,14 @@ import (
 	"context"
 	"fmt"
 	"strconv"
+	"strings"
 
 	"gitea.timerzz.com/kedaya_haitao/common/pkg/subscribe"
 	"gitea.timerzz.com/kedaya_haitao/common/structs/storage"
 	"gitea.timerzz.com/kedaya_haitao/common/structs/utils"
 	"github.com/golang/glog"
 	"github.com/redis/go-redis/v9"
+	"golang.org/x/sync/errgroup"
 )
 
 type Controller struct {
@@ -38,6 +40,19 @@ func (c *Controller) Run() error {
 
 // 处理接受到的信息
 func (c *Controller) Rate(ctx context.Context, idString string) error {
+	var ids = strings.Split(idString, ",")
+	var wg errgroup.Group
+	for _, id := range ids {
+		var i = id
+		wg.Go(func() error {
+			return c.rate(ctx, i)
+		})
+	}
+	return wg.Wait()
+}
+
+// 处理接收到的信息
+func (c *Controller) rate(ctx context.Context, idString string) error {
 	i, _ := strconv.Atoi(idString)
 	if i <= 0 {
 		return fmt.Errorf("接收到的id不正确：%s", idString)