Method RecoverQuestion

internal/service/content/question_service.go:732–796

(ctx context.Context, req *schema.QuestionRecoverReq)

}

func (qs *QuestionService) RecoverQuestion(ctx context.Context, req *schema.QuestionRecoverReq) (err error) {
	questionInfo, exist, err := qs.questionRepo.GetQuestion(ctx, req.QuestionID)
	if err != nil {
		return err
	}
	if !exist {
		return errors.BadRequest(reason.QuestionNotFound)
	}
	if questionInfo.Status != entity.QuestionStatusDeleted {
		return nil
	}

	err = qs.questionRepo.RecoverQuestion(ctx, req.QuestionID)
	if err != nil {
		return err
	}

	// update user's question count
	userQuestionCount, err := qs.questioncommon.GetUserQuestionCount(ctx, questionInfo.UserID)
	if err != nil {
		log.Error("user GetUserQuestionCount error", err.Error())
	} else {
		err = qs.userCommon.UpdateQuestionCount(ctx, questionInfo.UserID, userQuestionCount)
		if err != nil {
			log.Error("user IncreaseQuestionCount error", err.Error())
		}
	}

	// update tag's question count
	if err = qs.tagCommon.RecoverTagRelListByObjectID(ctx, questionInfo.ID); err != nil {
		log.Errorf("remove tag rel list by object id error %v", err)
	}

	tagIDs := make([]string, 0)
	tags, err := qs.tagCommon.GetObjectEntityTag(ctx, questionInfo.ID)
	if err != nil {
		return err
	}
	for _, v := range tags {
		tagIDs = append(tagIDs, v.ID)
	}
	if len(tagIDs) > 0 {
		if err = qs.tagCommon.RefreshTagQuestionCount(ctx, tagIDs); err != nil {
			log.Errorf("update tag's question count failed, %v", err)
		}
	}
	err = qs.questionRepo.RecoverQuestionLink(ctx, &entity.QuestionLink{
		FromQuestionID: questionInfo.ID,
	}, &entity.QuestionLink{
		ToQuestionID: questionInfo.ID,
	})
	if err != nil {
		return
	}

	qs.activityQueueService.Send(ctx, &schema.ActivityMsg{
		UserID:           req.UserID,
		TriggerUserID:    converter.StringToInt64(req.UserID),