java - 如何从 spring Batch 步骤返回自定义 RepeatStatus

Question

步骤类:GenerateReferenceNumber

package com.npst.imps.action;
import org.springframework.batch.core.StepContribution;
import org.springframework.batch.core.scope.context.ChunkContext;
import org.springframework.batch.core.step.tasklet.Tasklet;
import org.springframework.batch.repeat.RepeatStatus;
import com.npst.imps.utils.TransactionResponseData;
public class GenerateReferenceNumber implements Tasklet {
    @Override
    public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext) throws Exception {    
    double rrn= Math.random();
    chunkContext.getStepContext().getStepExecution().getJobExecution().getExecutionContext().put("rrn", rrn);   
    double tid= (double) chunkContext.getStepContext().getStepExecution().getJobExecution().getExecutionContext().get("tid");       
    chunkContext.getStepContext().getStepExecution().getJobExecution().getExecutionContext().put("trnsactionstatus", "RRN generated for Tid::"+tid+" is "+rrn);
    TransactionResponseData transactionResponseData =(TransactionResponseData) chunkContext.getStepContext().getStepExecution().getJobExecution().getExecutionContext().get("transactionResponseData");
    transactionResponseData.setRrn(rrn+"");
    chunkContext.getStepContext().getStepExecution().getJobExecution().getExecutionContext().put("transactionResponseData", transactionResponseData); 

          return RepeatStatus.FINISHED; 
    }

}

我如何返回我自己定义的状态，而不是 Repeatstatus.FINISHED ，并根据它们决定下一步。自定义状态，如成功、失败、部分等。

batchjob.xml

<beans:beans xmlns="http://www.springframework.org/schema/batch"
    xmlns:beans="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="
           http://www.springframework.org/schema/beans
           http://www.springframework.org/schema/beans/spring-beans.xsd
           http://www.springframework.org/schema/batch
           http://www.springframework.org/schema/batch/spring-batch-3.0.xsd">
       <job id="MBSFT">
         <step id="PrepareTid" allow-start-if-complete="true" next="PrepareRRN">
            <tasklet ref="PrepareTransactionId" />
        </step>

        <step id="PrepareRRN" allow-start-if-complete="true">
            <tasklet ref="GenerateReferenceNumber" />
                <next on="COMPLETED" to="IdentifyImpsService" />
        </step>

        <step id="IdentifyImpsService" allow-start-if-complete="true">
            <tasklet ref="IdentifyIMPSRequestType" />
            <next on="COMPLETED" to="FetchNBIN" />
        </step>

        <step id="FetchNBIN" allow-start-if-complete="true">
            <tasklet ref="FetchNBINFromIFSC" />
        </step>
    </job>
</beans:beans>

Answer 1

我想这是不可能的。
您可以将自定义返回状态放入 StepExecution，使用 ExecutionContextPromotionListener将属性从步骤移动到作业执行上下文，然后使用 JobExecutionDecider重定向流量。