package com.walker.store.task;

import com.walker.connector.Address;
import com.walker.store.support.DummyStore;

import java.util.List;

/**
 * 自定义采集任务定义，不适用<code>Store</code>对象。
 * @author 时克英
 * @date 2022-09-26
 */
public abstract class GenericGatherTask extends DatabaseGatherTask{

    public GenericGatherTask(String name, Address address){
        super(new DummyStore(), name, address);
    }

    @Override
    public Object run(String srcName, String createTableSQL, Object parameter
            , Object[] params) throws Exception{
        if(connector == null){
            connector = getConnector();
        }
        if(connector == null){
            throw new IllegalArgumentException("GatherTask参数错误：connector必须存在!");
        }

        List<Object> data = this.invokeRequest(connector, params);
        if(data == null){
            logger.debug("GatherTask调用请求返回空数据");
            return null;
        }

        return this.execute(srcName, createTableSQL, parameter, data);
    }

    /**
     * 由业务自由定义每次执行的具体反馈。
     * @param srcName
     * @param createTableSQL
     * @param parameter
     * @param data 请求远程地址返回的业务数据，如:数据库查询结果
     * @return
     */
    protected abstract Object execute(String srcName, String createTableSQL, Object parameter, List<Object> data);

    //~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
    //~ 如果请求远程服务是http或其他方式，请重写以下方法。这里默认请求的数据库数据。2022-09-26
    //~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

//    @Override
//    protected AbstractConnector getConnector() {
//        return null;
//    }
//
//    @Override
//    protected List<Object> invokeRequest(AbstractConnector connector, Object[] params) throws Exception {
//        return null;
//    }
}