package data

import (
	dto "cid/model/dto/data"
	service "cid/service/data"
	"context"
)

type dataFetchController struct{}

// DataFetch 数据获取控制器
var DataFetch = new(dataFetchController)

// ExecuteDataFetch 执行数据获取
func (c *dataFetchController) ExecuteDataFetch(ctx context.Context, req *dto.ExecuteDataFetchReq) (res *dto.ExecuteDataFetchRes, err error) {
	return service.DataFetch.Execute(ctx, req)
}

// BatchExecuteDataFetch 批量执行数据获取
func (c *dataFetchController) BatchExecuteDataFetch(ctx context.Context, req *dto.BatchExecuteDataFetchReq) (res *dto.BatchExecuteDataFetchRes, err error) {
	return service.DataFetch.BatchExecute(ctx, req)
}

// ListDataFetchLog 获取数据获取日志列表
func (c *dataFetchController) ListDataFetchLog(ctx context.Context, req *dto.ListDataFetchLogReq) (res *dto.ListDataFetchLogRes, err error) {
	return service.DataFetch.List(ctx, req)
}

// GetDataFetchLog 获取数据获取日志详情
func (c *dataFetchController) GetDataFetchLog(ctx context.Context, req *dto.GetDataFetchLogReq) (res *dto.GetDataFetchLogRes, err error) {
	return service.DataFetch.GetOne(ctx, req)
}

// ReExecuteDataFetch 重新执行数据获取
func (c *dataFetchController) ReExecuteDataFetch(ctx context.Context, req *dto.ReExecuteDataFetchReq) (res *dto.ReExecuteDataFetchRes, err error) {
	return service.DataFetch.ReExecute(ctx, req)
}