office tag async send

internal/rpc/office/office.go

@@ -102,12 +102,14 @@ type tagSendStruct struct {
 
 func (s *officeServer) sendTagMsgRoutine() {
 	log.NewInfo("", utils.GetSelfFuncName(), "start")
+	for {
 		select {
 		case v := <-s.ch:
 			msg.TagSendMessage(v.operationID, v.user, v.userID, v.content, v.senderPlatformID)
 			time.Sleep(time.Millisecond * 500)
 		}
 	}
+}
 
 func (s *officeServer) GetUserTags(_ context.Context, req *pbOffice.GetUserTagsReq) (resp *pbOffice.GetUserTagsResp, err error) {
 	log.NewInfo(req.OperationID, utils.GetSelfFuncName(), "req ", req.String())