This is an automated email from the ASF dual-hosted git repository. linkinstar pushed a commit to branch dev in repository https://gitbox.apache.org/repos/asf/answer.git
The following commit(s) were added to refs/heads/dev by this push: new 81837c9f update new question message tag 81837c9f is described below commit 81837c9fe05f3730e70cc7260e43c86536185a92 Author: Neko <light-wh...@outlook.com> AuthorDate: Thu Aug 28 16:04:25 2025 +0800 update new question message tag fix new question message tag to get all question tags --- internal/service/content/question_service.go | 11 +++++++++-- 1 file changed, 9 insertions(+), 2 deletions(-) diff --git a/internal/service/content/question_service.go b/internal/service/content/question_service.go index ec9ce48e..69f568c4 100644 --- a/internal/service/content/question_service.go +++ b/internal/service/content/question_service.go @@ -413,8 +413,15 @@ func (qs *QuestionService) AddQuestion(ctx context.Context, req *schema.Question }) if question.Status == entity.QuestionStatusAvailable { - qs.externalNotificationQueueService.Send(ctx, - schema.CreateNewQuestionNotificationMsg(question.ID, question.Title, question.UserID, tags)) + newTags, newTagsErr := qs.tagCommon.GetTagListByNames(ctx, tagNameList) + if newTagsErr != nil { + log.Error("get question newTags error %v", newTagsErr) + qs.externalNotificationQueueService.Send(ctx, + schema.CreateNewQuestionNotificationMsg(question.ID, question.Title, question.UserID, tags)) + } else { + qs.externalNotificationQueueService.Send(ctx, + schema.CreateNewQuestionNotificationMsg(question.ID, question.Title, question.UserID, newTags)) + } } qs.eventQueueService.Send(ctx, schema.NewEvent(constant.EventQuestionCreate, req.UserID).TID(question.ID). QID(question.ID, question.UserID))