office tag async send

pull/232/head
wangchuxiao 3 years ago
parent 9913e67928
commit b0e349212d

@ -258,7 +258,7 @@ func (s *officeServer) SendMsg2Tag(_ context.Context, req *pbOffice.SendMsg2TagR
user: user, user: user,
userID: userID, userID: userID,
content: req.Content, content: req.Content,
senderPlatformID: 0, senderPlatformID: req.SenderPlatformID,
} }
select { select {
case s.ch <- t: case s.ch <- t:
@ -281,7 +281,7 @@ func (s *officeServer) SendMsg2Tag(_ context.Context, req *pbOffice.SendMsg2TagR
defer wg.Done() defer wg.Done()
userName, err := im_mysql_model.GetUserNameByUserID(userID) userName, err := im_mysql_model.GetUserNameByUserID(userID)
if err != nil { if err != nil {
log.NewError(req.OperationID, utils.GetSelfFuncName(), "GetUserNameByUserID failed", err.Error()) log.NewError(req.OperationID, utils.GetSelfFuncName(), "GetUserNameByUserID failed", err.Error(), userID)
return return
} }
lock.Lock() lock.Lock()

Loading…
Cancel
Save