package etl
|
|
|
|
import (
|
|
"LAPP_ETL/grmi"
|
|
"LAPP_ETL/services/etl/implments"
|
|
)
|
|
|
|
/******************************************************************************
|
|
*
|
|
* @Interface Name : RecordService
|
|
*-----------------------------------------------------------------------------
|
|
*
|
|
* @Description : Record的服务接口
|
|
*
|
|
* @Author : zhangxin
|
|
*
|
|
* @Date : 2021-07-05
|
|
*
|
|
******************************************************************************/
|
|
type RecordService interface {
|
|
/******************************************************************************
|
|
*
|
|
* @Function Name : Select
|
|
*-----------------------------------------------------------------------------
|
|
*
|
|
* @Description : 查询Record
|
|
*
|
|
* @Function Parameters : 阶段
|
|
*
|
|
* @Function Parameters : 状态
|
|
*
|
|
* @Function Parameters : 开始时间
|
|
*
|
|
* @Function Parameters : 结束时间
|
|
*
|
|
* @Function Parameters : 批次ID
|
|
*
|
|
* @Function Parameters : 任务ID
|
|
*
|
|
* @Function Parameters : 页码
|
|
*
|
|
* @Function Parameters : 每页显示得数量
|
|
*
|
|
* @Return Value : 执行时发生的错误
|
|
*
|
|
* @Author : zhangxin
|
|
*
|
|
* @Date : 2021-07-02
|
|
*
|
|
******************************************************************************/
|
|
Select(taskId int, stage string, status string, batchId string, start, end string, pageIndex, pageNum int) (grmi.PagingResult, error)
|
|
}
|
|
|
|
/******************************************************************************
|
|
*
|
|
* @Function Name : NewRecordService
|
|
*-----------------------------------------------------------------------------
|
|
*
|
|
* @Description : 创建一个RecordService
|
|
*
|
|
* @Return Value : RecordService实例
|
|
*
|
|
* @Author : zhangxin
|
|
*
|
|
* @Date : 2021-07-05
|
|
*
|
|
******************************************************************************/
|
|
func NewRecordService() RecordService {
|
|
return implments.NewRecordServiceImplement()
|
|
}
|
|
|
|
|