From 9913e679282c0c89341517be21de14ef0ff9a822 Mon Sep 17 00:00:00 2001
From: wangchuxiao <wangchuxiao97@outlook.com>
Date: Wed, 18 May 2022 15:16:44 +0800
Subject: [PATCH] office tag async send

---
 internal/rpc/office/office.go | 10 ++++++----
 1 file changed, 6 insertions(+), 4 deletions(-)

diff --git a/internal/rpc/office/office.go b/internal/rpc/office/office.go
index 016e6278f..93b2d1d2f 100644
--- a/internal/rpc/office/office.go
+++ b/internal/rpc/office/office.go
@@ -102,10 +102,12 @@ type tagSendStruct struct {
 
 func (s *officeServer) sendTagMsgRoutine() {
 	log.NewInfo("", utils.GetSelfFuncName(), "start")
-	select {
-	case v := <-s.ch:
-		msg.TagSendMessage(v.operationID, v.user, v.userID, v.content, v.senderPlatformID)
-		time.Sleep(time.Millisecond * 500)
+	for {
+		select {
+		case v := <-s.ch:
+			msg.TagSendMessage(v.operationID, v.user, v.userID, v.content, v.senderPlatformID)
+			time.Sleep(time.Millisecond * 500)
+		}
 	}
 }