From 833f2a9b8b1e5344097526af8fa52b8f6694bc09 Mon Sep 17 00:00:00 2001 From: hujiebin Date: Mon, 4 Dec 2023 10:13:20 +0800 Subject: [PATCH] =?UTF-8?q?feat:=E4=BC=98=E5=8C=96=E5=91=8A=E8=AD=A6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- main.go | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/main.go b/main.go index 64a74d4..1ef787c 100644 --- a/main.go +++ b/main.go @@ -11,7 +11,6 @@ import ( "google.golang.org/grpc/resolver" "google.golang.org/grpc/resolver/manual" "hilo-socketCenter/common" - "hilo-socketCenter/common/dingding" "hilo-socketCenter/common/mylogrus" "hilo-socketCenter/common/redisCli" "hilo-socketCenter/domain/model/rpc_m" @@ -113,11 +112,12 @@ func check() { mylogrus.MyLog.Infof("cron sendGiftChan msg error,left %v-%v", l, err) } if l > MONITOR_LENGTH { - go func() { - if sErr := dingding.SendDingRobot(dingding.ROBOTWEBHOOK, fmt.Sprintf("送礼横幅变化通知延迟,队列%s长度:%d", SocketQueueSendGift, l), true); sErr != nil { - mylogrus.MyLog.Errorf("dingding msg fail:%v", sErr) - } - }() + mylogrus.MyLog.Infof("送礼横幅变化通知延迟,队列%s长度:%d", SocketQueueSendGift, l) + //go func() { + // if sErr := dingding.SendDingRobot(dingding.ROBOTWEBHOOK, fmt.Sprintf("送礼横幅变化通知延迟,队列%s长度:%d", SocketQueueSendGift, l), true); sErr != nil { + // mylogrus.MyLog.Errorf("dingding msg fail:%v", sErr) + // } + //}() n, err := redisCli.GetRedisCluster().Del(context.Background(), SocketQueueSendGift).Result() mylogrus.MyLog.Infof("del sendGiftChan msg queue:%v,n:%v,err:%v", SocketQueueSendGift, n, err) } -- 2.22.0