// Job接口實(shí)現(xiàn)示例
public class SampleJob implements Job {
    @Override
    public void execute(JobExecutionContext context) throws JobExecutionException {
        // 獲取JobDetail中的數(shù)據(jù)
        JobDataMap dataMap = context.getJobDetail().getJobDataMap();
        String jobData = dataMap.getString("jobData");
        
        // 執(zhí)行業(yè)務(wù)邏輯
        System.out.println("SampleJob執(zhí)行，數(shù)據(jù): " + jobData + ", 時(shí)間: " + new Date());
        
        // 任務(wù)上下文操作
        context.setResult("執(zhí)行成功");
    }
}

// Spring Boot中的Quartz自動(dòng)配置
@Configuration
@EnableScheduling
public class QuartzConfig {
    
    // 注冊(cè)數(shù)據(jù)源，支持持久化
    @Bean
    public DataSource quartzDataSource() {
        return DataSourceBuilder.create()
                .url("jdbc:mysql://localhost:3306/quartz_db")
                .username("root")
                .password("password")
                .driverClassName("com.mysql.cj.jdbc.Driver")
                .build();
    }
    
    // 配置Quartz屬性
    @Bean
    public Properties quartzProperties() {
        Properties properties = new Properties();
        properties.put("org.quartz.scheduler.instanceName", "SpringQuartzScheduler");
        properties.put("org.quartz.jobStore.class", "org.quartz.impl.jdbcjobstore.JobStoreTX");
        properties.put("org.quartz.jobStore.driverDelegateClass", "org.quartz.impl.jdbcjobstore.StdJDBCDelegate");
        properties.put("org.quartz.jobStore.dataSource", "quartzDS");
        properties.put("org.quartz.dataSource.quartzDS.provider", "hikaricp");
        return properties;
    }
}

// JobDetail配置示例
@Bean
public JobDetail sampleJobDetail() {
    return JobBuilder.newJob(SampleJob.class)
            .withIdentity("sampleJob", "group1")     // 設(shè)置任務(wù)唯一標(biāo)識(shí)
            .withDescription("這是一個(gè)示例任務(wù)")       // 添加描述
            .storeDurably(true)                      // 任務(wù)持久保存
            .requestRecovery(true)                   // 故障恢復(fù)
            .usingJobData("jobData", "初始值")        // 傳遞參數(shù)
            .build();
}

// JobDataMap高級(jí)用法
public class DataTransferJob implements Job {
    
    private String configValue;
    private UserService userService;
    
    // Quartz自動(dòng)注入JobDataMap中的屬性
    public void setConfigValue(String configValue) {
        this.configValue = configValue;
    }
    
    // Spring依賴注入
    @Autowired
    public void setUserService(UserService userService) {
        this.userService = userService;
    }
    
    @Override
    public void execute(JobExecutionContext context) throws JobExecutionException {
        // 獲取運(yùn)行時(shí)參數(shù)（兩種方式）
        JobDataMap mergedMap = context.getMergedJobDataMap();
        String runtimeParam = mergedMap.getString("runtimeParam");
        
        // 結(jié)合JobDetail參數(shù)和Spring注入的服務(wù)
        List<User> users = userService.findInactiveUsers();
        users.forEach(user -> {
            System.out.println("處理用戶: " + user.getUsername() + 
                              ", 配置: " + configValue + 
                              ", 運(yùn)行參數(shù): " + runtimeParam);
        });
    }
}

// 配置JobDetail
@Bean
public JobDetail dataTransferJobDetail() {
    return JobBuilder.newJob(DataTransferJob.class)
            .withIdentity("dataTransferJob")
            .usingJobData("configValue", "系統(tǒng)配置值")
            .storeDurably()
            .build();
}

// 不同類型的Trigger示例
@Bean
public Trigger simpleTrigger(JobDetail sampleJobDetail) {
    // 簡(jiǎn)單觸發(fā)器 - 每隔30秒執(zhí)行一次，無(wú)限重復(fù)
    return TriggerBuilder.newTrigger()
            .forJob(sampleJobDetail)
            .withIdentity("simpleTrigger")
            .withSchedule(SimpleScheduleBuilder.simpleSchedule()
                    .withIntervalInSeconds(30)
                    .repeatForever())
            .build();
}

@Bean
public Trigger cronTrigger(JobDetail dataTransferJobDetail) {
    // Cron觸發(fā)器 - 每天凌晨2點(diǎn)執(zhí)行
    return TriggerBuilder.newTrigger()
            .forJob(dataTransferJobDetail)
            .withIdentity("cronTrigger")
            .withSchedule(CronScheduleBuilder.cronSchedule("0 0 2 * * ?"))
            .build();
}

@Bean
public Trigger dailyIntervalTrigger(JobDetail reportJobDetail) {
    // 每日時(shí)間間隔觸發(fā)器 - 工作日9:00-17:00每小時(shí)執(zhí)行
    return TriggerBuilder.newTrigger()
            .forJob(reportJobDetail)
            .withIdentity("dailyIntervalTrigger")
            .withSchedule(DailyTimeIntervalScheduleBuilder.dailyTimeIntervalSchedule()
                    .startingDailyAt(TimeOfDay.hourAndMinuteOfDay(9, 0))
                    .endingDailyAt(TimeOfDay.hourAndMinuteOfDay(17, 0))
                    .onDaysOfTheWeek(Calendar.MONDAY, Calendar.TUESDAY, Calendar.WEDNESDAY, 
                                    Calendar.THURSDAY, Calendar.FRIDAY)
                    .withIntervalInHours(1))
            .build();
}

// Cron表達(dá)式示例及解析
@Bean
public CronTrigger advancedCronTrigger(JobDetail complexJobDetail) {
    // 創(chuàng)建Trigger時(shí)，可以添加描述和傳遞參數(shù)
    return TriggerBuilder.newTrigger()
            .forJob(complexJobDetail)
            .withIdentity("advancedCronTrigger", "cronGroup")
            .withDescription("高級(jí)Cron觸發(fā)器")
            .usingJobData("runtimeParam", "觸發(fā)器參數(shù)")
            .withSchedule(CronScheduleBuilder.cronSchedule("0 15 10 L * ?")
                    .withMisfireHandlingInstructionFireAndProceed())
            .startAt(DateBuilder.futureDate(5, DateBuilder.IntervalUnit.MINUTE))
            .endAt(DateBuilder.futureDate(6, DateBuilder.IntervalUnit.MONTH))
            .build();
}

// Cron表達(dá)式常用模式
/*
 * "0 0 12 * * ?"              每天中午12點(diǎn)觸發(fā)
 * "0 15 10 ? * MON-FRI"       周一至周五上午10:15觸發(fā)
 * "0 0/30 9-17 * * ?"         每天9點(diǎn)至17點(diǎn)每半小時(shí)觸發(fā)
 * "0 0 10,14,16 * * ?"        每天10點(diǎn)、14點(diǎn)和16點(diǎn)觸發(fā)
 * "0 0 12 ? * WED"            每周三中午12點(diǎn)觸發(fā)
 * "0 15 10 L * ?"             每月最后一天的10:15觸發(fā)
 * "0 15 10 ? * 6L"            每月最后一個(gè)周五的10:15觸發(fā)
 */

// 高級(jí)Trigger配置示例
@Bean
public Trigger advancedTrigger(JobDetail importantJobDetail) {
    Calendar calendar = new GregorianCalendar(2025, Calendar.DECEMBER, 31);
    
    return TriggerBuilder.newTrigger()
            .forJob(importantJobDetail)
            .withIdentity("advancedTrigger")
            // 設(shè)置優(yōu)先級(jí) (默認(rèn)為5，值越高優(yōu)先級(jí)越高)
            .withPriority(10)
            // 設(shè)置開(kāi)始時(shí)間
            .startAt(DateBuilder.futureDate(1, DateBuilder.IntervalUnit.HOUR))
            // 設(shè)置結(jié)束時(shí)間
            .endAt(calendar.getTime())
            // 設(shè)置調(diào)度器時(shí)區(qū)
            .inTimeZone(TimeZone.getTimeZone("Asia/Shanghai"))
            // 配置調(diào)度
            .withSchedule(SimpleScheduleBuilder.simpleSchedule()
                    .withIntervalInMinutes(30)
                    .repeatForever()
                    // 設(shè)置錯(cuò)過(guò)觸發(fā)策略
                    .withMisfireHandlingInstructionNextWithRemainingCount())
            .build();
}

// 動(dòng)態(tài)調(diào)度管理
@Service
public class DynamicScheduleService {
    
    @Autowired
    private Scheduler scheduler;
    
    // 動(dòng)態(tài)添加任務(wù)
    public void scheduleDynamicJob(String jobName, String cronExpression, Map<String, Object> jobData) 
            throws SchedulerException {
        
        // 創(chuàng)建JobDetail
        JobDetail jobDetail = JobBuilder.newJob(DynamicJob.class)
                .withIdentity(jobName)
                .storeDurably()
                .build();
        
        // 設(shè)置JobDataMap
        if (jobData != null) {
            jobDetail.getJobDataMap().putAll(jobData);
        }
        
        // 創(chuàng)建CronTrigger
        CronTrigger trigger = TriggerBuilder.newTrigger()
                .withIdentity(jobName + "Trigger")
                .withSchedule(CronScheduleBuilder.cronSchedule(cronExpression))
                .build();
        
        // 添加任務(wù)
        scheduler.scheduleJob(jobDetail, trigger);
    }
    
    // 修改任務(wù)調(diào)度時(shí)間
    public void rescheduleJob(String triggerName, String cronExpression) throws SchedulerException {
        TriggerKey triggerKey = TriggerKey.triggerKey(triggerName);
        CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey);
        
        // 創(chuàng)建新的Trigger
        CronTrigger newTrigger = TriggerBuilder.newTrigger()
                .withIdentity(triggerKey)
                .withSchedule(CronScheduleBuilder.cronSchedule(cronExpression))
                .build();
        
        // 更新調(diào)度
        scheduler.rescheduleJob(triggerKey, newTrigger);
    }
    
    // 暫停任務(wù)
    public void pauseJob(String jobName) throws SchedulerException {
        JobKey jobKey = JobKey.jobKey(jobName);
        scheduler.pauseJob(jobKey);
    }
    
    // 恢復(fù)任務(wù)
    public void resumeJob(String jobName) throws SchedulerException {
        JobKey jobKey = JobKey.jobKey(jobName);
        scheduler.resumeJob(jobKey);
    }
    
    // 刪除任務(wù)
    public void deleteJob(String jobName) throws SchedulerException {
        JobKey jobKey = JobKey.jobKey(jobName);
        scheduler.deleteJob(jobKey);
    }
}