package com.iplatform.rectext.scheduler;

import com.iplatform.gather.GatherScheduler;
import com.walker.store.AbstractStore;
import com.walker.store.support.EmptyDatabaseStore;
import com.walker.store.task.GatherTask;

/**
 * 持续写入课程文本描述到相似数据库中，在数据库中定义任务时间周期。
 * <pre>
 *     1）该任务不会停止，每间隔2小时执行一次;
 *     2）增量拉取数据，数据先组织好写入中间表，然后调用sdk写入milvus
 * </pre>
 */
public class WriteCourseToMilvus extends GatherScheduler {

    private GatherTask gatherTask;

    public WriteCourseToMilvus(int id, String name){
        super(id, name, new EmptyDatabaseStore());
    }

    @Override
    protected GatherTask providerTask(AbstractStore store) {
        return null;
    }

    @Override
    protected void terminateGatherScheduler(int schedulerId) {

    }

    @Override
    protected Object onProcess(Object[] inputParams) throws Exception {
        if(this.gatherTask == null){
            this.gatherTask = this.providerTask(this.getStore());
            if(this.gatherTask == null){
                throw new IllegalArgumentException("未提供任务对象，调度无法执行：" + this.getName());
            }
        }
        // srcName, createTableSQL, parameter, params[]
        return this.gatherTask.run((String)inputParams[0], (String)inputParams[1], inputParams[2], (Object[])inputParams[3]);
    }
}