Method CreateComment

internal/service/comment.go:37–71

CreateComment 创建评论的实现

(ctx context.Context, comment domain.Comment)

// CreateComment 创建评论的实现
func (c *commentService) CreateComment(ctx context.Context, comment domain.Comment) error {
	// 参数校验
	if comment.Content == "" {
		return fmt.Errorf("评论内容不能为空")
	}

	// 创建评论
	commentId, err := c.repo.CreateComment(ctx, comment)
	if err != nil || commentId == 0 {
		return fmt.Errorf("发布评论失败: %w", err)
	}

	ctx, cancel := context.WithTimeout(ctx, time.Second*5)
	defer cancel()

	general.WithAsyncCancel(ctx, cancel, func() error {
		// 异步发送审核事件
		go func() {
			event := check.CheckEvent{
				BizId:   2, // 表示审核业务类型为评论
				PostId:  uint(commentId),
				Content: comment.Content,
				Uid:     comment.UserId,
			}

			if err := c.checkProducer.ProduceCheckEvent(event); err != nil {
				log.Printf("发送评论审核事件失败: %v", err)
				return
			}
		}()
		return nil
	})()

	return nil
}

// DeleteComment 删除评论的实现
func (c *commentService) DeleteComment(ctx context.Context, commentId int64) error {