Method RejectCheck

internal/service/check.go:122–179

RejectCheck 审核拒绝

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

// RejectCheck 审核拒绝
func (s *checkService) RejectCheck(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.UnApproved,
	}); 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()

		done := make(chan error, 2)
		go func() {
			done <- s.postProducer.ProducePublishEvent(publish.PublishEvent{
				PostId: check.PostID,
				Uid:    check.Uid,
				Status: domain.Draft,
			})
		}()

		go func() {
			done <- s.recordActivity(uid, "审核拒绝")
		}()

		for i := 0; i < 2; i++ {
			select {
			case err := <-done:
				if err != nil {
					s.l.Error("异步任务执行失败", zap.Error(err))
				}
			case <-ctx.Done():
				s.l.Error("异步任务执行超时")
				return
			}
		}
	}()

	return nil
}