import { Job } from 'bull';
import { Repository, DataSource } from 'typeorm';
import { ScheduledWorkflow } from '../entities/scheduled-workflow.entity';
import { WorkflowExecutionLog } from '../entities/workflow-execution-log.entity';
import { ScheduleJobData, BatchProcessingResult } from '../interfaces/schedule-job-data.interface';
import { ScheduleHandlerService } from 'src/module/workflow-automation/service/schedule-handler.service';
import { ReflectionHelper } from 'src/utils/service/reflection-helper.service';
export declare class ScheduleProcessor {
    private readonly scheduledWorkflowRepository;
    private readonly executionLogRepository;
    private readonly scheduleHandlerService;
    private readonly reflectionHelper;
    private readonly dataSource;
    private readonly logger;
    constructor(scheduledWorkflowRepository: Repository<ScheduledWorkflow>, executionLogRepository: Repository<WorkflowExecutionLog>, scheduleHandlerService: ScheduleHandlerService, reflectionHelper: ReflectionHelper, dataSource: DataSource);
    handleScheduledWorkflowExecution(job: Job<ScheduleJobData>): Promise<{
        success: boolean;
        executionLogId: number;
        result: BatchProcessingResult;
    }>;
    private executeWorkflowActions;
    private executeAction;
    private executeSendEmailAction;
    private executeUpdateRecordsAction;
    private getTargetRecords;
    private getTableNameForEntityType;
    private chunkArray;
    onActive(job: Job<ScheduleJobData>): void;
    onCompleted(job: Job<ScheduleJobData>, result: any): void;
    onFailed(job: Job<ScheduleJobData>, error: Error): void;
}