package jnpf.dmsMapper; import jnpf.dmsEntity.fenfa.DmsBupinghengRetry; import org.apache.ibatis.annotations.Param; import java.util.List; public interface DmsBupinghengRetryMapper { List selectPending(@Param("batchSize") int batchSize, @Param("maxAttempts") int maxAttempts); int claim(@Param("task") DmsBupinghengRetry task, @Param("token") String token, @Param("maxAttempts") int maxAttempts); DmsBupinghengRetry selectClaim(@Param("task") DmsBupinghengRetry task, @Param("token") String token); int finish(@Param("task") DmsBupinghengRetry task, @Param("token") String token, @Param("stop") boolean stop, @Param("error") String error, @Param("delaySeconds") int delaySeconds); }