Method ApproveCheck

internal/service/check.go:45–119

ApproveCheck 审核通过

(ctx context.Context, checkID int64, remark string, uid int64)

// ApproveCheck 审核通过
func (s *checkService) ApproveCheck(ctx context.Context, checkID int64, remark string, uid int64) error {
	// 获取审核详情
	check, err := s.repo.FindByID(ctx, checkID)
	if err != nil {
		s.l.Error("获取审核详情失败", zap.Error(err))
		return fmt.Errorf("获取审核详情失败: %w", err)
	}

	// 检查是否已审核
	if check.Status != domain.UnderReview {
		s.l.Error("当前审核状态不允许操作", zap.Uint8("status", check.Status))
		return fmt.Errorf("当前审核状态不允许操作,状态:%v", check.Status)
	}

	// 更新审核状态为通过
	if err := s.repo.UpdateStatus(ctx, domain.Check{
		ID:     checkID,
		Remark: remark,
		Status: domain.Approved,
	}); err != nil {
		s.l.Error("更新审核状态失败",
			zap.Int64("check_id", checkID),
			zap.String("remark", remark),
			zap.Error(err))
		return fmt.Errorf("更新审核状态失败: %w", err)
	}

	go func() {
		ctx, cancel := context.WithTimeout(context.Background(), 2*time.Minute)
		defer cancel()

		expectedTasks := 1
		if check.BizId == 1 || check.BizId == 2 {
			expectedTasks++
		}
		done := make(chan error, expectedTasks)
		go func() {
			if check.BizId == 1 {
				done <- s.postProducer.ProducePublishEvent(publish.PublishEvent{
					PostId: check.PostID,
					Uid:    check.Uid,
					Status: domain.Published,
					BizId:  check.BizId,
				})
			} else if check.BizId == 2 {
				done <- s.commentProducer.ProduceCommentEvent(comment.CommentEvent{
					PostId: check.PostID,
					Uid:    check.Uid,
					Status: domain.Published,
					BizId:  check.BizId,
				})
			} else {
				done <- nil
			}
		}()

		go func() {
			done <- s.recordActivity(uid, "审核通过")