spring batch conditional if步骤

public class MyDecider implements JobExecutionDecider {
    
    @Override
    public FlowExecutionStatus decide(JobExecution jobExecution, StepExecution stepExecution) {
        // 根据特定条件判断是否执行某个步骤
        if (条件判断) {
            return new FlowExecutionStatus("STEP1");
        } else {
            return new FlowExecutionStatus("STEP2");
        }
    }
}

@Configuration
@EnableBatchProcessing
public class BatchConfig {

    @Autowired
    private JobBuilderFactory jobBuilderFactory;

    @Autowired
    private StepBuilderFactory stepBuilderFactory;

    @Bean
    public Step step1() {
        return stepBuilderFactory.get("step1")
                .tasklet((contribution, chunkContext) -> {
                    // 步骤1的逻辑
                    return RepeatStatus.FINISHED;
                })
                .build();
    }

    @Bean
    public Step step2() {
        return stepBuilderFactory.get("step2")
                .tasklet((contribution, chunkContext) -> {
                    // 步骤2的逻辑
                    return RepeatStatus.FINISHED;
                })
                .build();
    }

    @Bean
    public Job myJob() {
        return jobBuilderFactory.get("myJob")
                .start(step1())
                .next(myDecider())
                .from(myDecider()).on("STEP1").to(step2())
                .from(myDecider()).on("STEP2").end()
                .build();
    }

    @Bean
    public JobExecutionDecider myDecider() {
        return new MyDecider();
    }
}