package client

import (
	"fmt"
	"git.sxidc.com/go-tools/api_binding/http_binding/response"
	"net/url"
	"strconv"
)

const (
	getExecuteSqlLogsUrl = "/ds/api/v1/exec/sql/log/query"
)

func (c *Client) GetExecuteSqlLogs(token string, baseUrl string, namespace string, dataSource string,
	executor string, startExecuteTime string, endExecuteTime string, pageNo int, pageSize int) ([]ExecuteSqlLogInfo, error) {
	fullUrl, err := url.JoinPath(baseUrl, getExecuteSqlLogsUrl)
	if err != nil {
		return nil, err
	}

	resp := new(response.InfosResponse[ExecuteSqlLogInfo])

	err = c.get(token, fullUrl, map[string]string{
		"namespace":        namespace,
		"dataSource":       dataSource,
		"executor":         executor,
		"startExecuteTime": startExecuteTime,
		"endExecuteTime":   endExecuteTime,
		"pageNo":           strconv.Itoa(pageNo),
		"pageSize":         strconv.Itoa(pageSize),
	}, resp)
	if err != nil {
		return nil, err
	}

	if !resp.Success {
		return nil, fmt.Errorf(resp.Msg)
	}

	return resp.Infos, nil
}