diff --git a/main.go b/main.go index d8cb4594dcefecbc0ef6cf9f4a247e9ef786ccf9..190504ded0da3895c4deb52ad9c543c3d68bda79 100644 --- a/main.go +++ b/main.go @@ -122,6 +122,8 @@ func check() { mylogrus.MyLog.Errorf("dingding msg fail:%v", sErr) } }() + n, err := redisCli.GetRedis().Del(context.Background(), SocketQueueSendGift).Result() + mylogrus.MyLog.Infof("del sendGiftChan msg queue:%v,n:%v,err:%v", SocketQueueSendGift, n, err) } if l > 0 { mylogrus.MyLog.Infof("cron sendGiftChan msg,left %v", l)