<dependency>
    <groupId>com.qihoo.finance.chronus</groupId>
    <artifactId>chronus</artifactId>
    <version>1.0.0</version>
</dependency>

@Service("selectExecuteBean")
public class SelectExecuteBean implements ChronusSdkSingleJob<Integer> {
    private static final Logger logger = LogManager.getLogger(SelectExecuteBean.class);

    @Override
    public List<Integer> selectTasks(String taskParameter, List<TaskItemDefineDomain> list, int eachFetchDataNum) throws Exception {
        List<Integer> result = new ArrayList<>();
        //查询数据集合
        return result;
    }

    @Override
    public boolean execute(Integer domain, String taskParameter) throws Exception {
        // 处理集合中的每一项
        return true;
    }
}