import request from '@/utils/flink/request'
import Qs from 'qs'

/**
 * 查询任务列表
 * @param {*} pageNum
 * @param {*} pageSize
 * @param {任务名称} jobName
 * @param {Flink运行任务编号} jobId
 * @param {任务类型} jobType
 * @param {任务状态} status
 * @param {开启状态} open
 * @returns
 */
export function getTasks(pageNum, pageSize, jobName, jobId, jobType, status, open) {
  return request({
    url: '/flink/listTask',
    method: 'post',
    headers: { 'Content-Type': 'application/x-www-form-urlencoded' },
    transformRequest: [function(data) { return Qs.stringify(data) }],
    data: {
      pageNum: pageNum,
      pageSize: pageSize,
      jobName: jobName,
      jobId: jobId,
      jobType: jobType,
      status: status,
      open: open
    }
  })
}

/**
 * 开启任务
 * @param {任务编号} id
 * @returns
 */
export function openTask(id) {
  return request({
    url: '/flink/open',
    method: 'post',
    headers: { 'Content-Type': 'application/x-www-form-urlencoded' },
    transformRequest: [function(data) { return Qs.stringify(data) }],
    data: {
      id: id
    }
  })
}

/**
 * 关闭任务
 * @param {任务编号} id
 * @returns
 */
export function closeTask(id) {
  return request({
    url: '/flink/close',
    method: 'post',
    headers: { 'Content-Type': 'application/x-www-form-urlencoded' },
    transformRequest: [function(data) { return Qs.stringify(data) }],
    data: {
      id: id
    }
  })
}

/**
 * 启动任务
 * @param {任务编号} id
 * @returns
 */
export function startTask(id) {
  return request({
    url: '/flink/start',
    method: 'post',
    headers: { 'Content-Type': 'application/x-www-form-urlencoded' },
    transformRequest: [function(data) { return Qs.stringify(data) }],
    data: {
      id: id
    }
  })
}

/**
 * 停止任务
 * @param {任务编号} id
 * @param {备份编号} savepointId
 * @returns
 */
export function stopTask(id) {
  return request({
    url: '/flink/stop',
    method: 'post',
    headers: { 'Content-Type': 'application/x-www-form-urlencoded' },
    transformRequest: [function(data) { return Qs.stringify(data) }],
    data: {
      id: id
    }
  })
}

/**
 * 从savepoint备份地址中启动任务
 * @param {任务编号} id
 * @param {备份编号} savepointId
 * @returns
 */
export function startSavepoint(id, savepointId) {
  return request({
    url: '/flink/start',
    method: 'post',
    headers: { 'Content-Type': 'application/x-www-form-urlencoded' },
    transformRequest: [function(data) { return Qs.stringify(data) }],
    data: {
      id: id,
      savepointId: savepointId
    }
  })
}

/**
 * 备份
 * @param {任务编号} id
 * @returns
 */
export function savePoint(id) {
  return request({
    url: '/flink/savepoint',
    method: 'post',
    headers: { 'Content-Type': 'application/x-www-form-urlencoded' },
    transformRequest: [function(data) { return Qs.stringify(data) }],
    data: {
      id: id
    }
  })
}

/**
 * 复制任务
 * @param {任务编号} id
 * @returns
 */
export function copyConfig(id) {
  return request({
    url: '/flink/copyConfig',
    method: 'post',
    headers: { 'Content-Type': 'application/x-www-form-urlencoded' },
    transformRequest: [function(data) { return Qs.stringify(data) }],
    data: {
      id: id
    }
  })
}

/**
 * 删除任务
 * @param {任务编号} id
 * @returns
 */
export function deleteTask(id) {
  return request({
    url: '/flink/delete',
    method: 'post',
    headers: { 'Content-Type': 'application/x-www-form-urlencoded' },
    transformRequest: [function(data) { return Qs.stringify(data) }],
    data: {
      id: id
    }
  })
}

/**
 * 预校验SQL
 * @param {Flink SQL} flinkSql
 * @returns
 */
export function checkfSql(flinkSql) {
  return request({
    url: '/flink/checkfSql',
    method: 'post',
    headers: { 'Content-Type': 'application/x-www-form-urlencoded' },
    transformRequest: [function(data) { return Qs.stringify(data) }],
    data: {
      flinkSql: flinkSql
    }
  })
}

/**
 * 新增任务
 * @param {任务对象} data
 * jobName: my_online
 * jobDesc: 我的测试任务
 * deployMode: LOCAL
 * flinkRunConfig:
 * flinkCheckpointConfig:  -checkpointInterval 300000 -checkpointDir file:///home/flink/flink-streaming-platform-web/savepoint
 * flinkSql: --
 * jobType: 0
 * alarmTypes:
 * extJarPath:
 * customArgs:
 * customMainClass: com.xxxy.Demo
 * customJarUrl: http://test.coahuae.com/xxx.jar
 * @returns
 */
export function addConfig(data) {
  return request({
    url: '/flink/addConfig',
    method: 'post',
    headers: { 'Content-Type': 'application/x-www-form-urlencoded' },
    transformRequest: [function(data) { return Qs.stringify(data) }],
    data: data
  })
}

/**
 * 修改任务
 * @param {任务对象} data
 * id: 1
 * jobName: my_online
 * jobDesc: 我的测试任务
 * deployMode: LOCAL
 * flinkRunConfig:
 * flinkCheckpointConfig:  -checkpointInterval 300000 -checkpointDir file:///home/flink/flink-streaming-platform-web/savepoint
 * flinkSql: --
 * jobType: 0
 * alarmTypes:
 * extJarPath:
 * customArgs:
 * customMainClass: com.xxxy.Demo
 * customJarUrl: http://test.coahuae.com/xxx.jar
 * @returns
 */
export function editConfig(data) {
  return request({
    url: '/flink/editConfig',
    method: 'post',
    headers: { 'Content-Type': 'application/x-www-form-urlencoded' },
    transformRequest: [function(data) { return Qs.stringify(data) }],
    data: data
  })
}

/**
 * 查询历史版本列表
 * @param {*} data (jobConfigId,jobName)
 * @returns
 */
export function getTaskHistory(data) {
  return request({
    url: '/flink/jobConfigHistoryPage',
    method: 'post',
    headers: { 'Content-Type': 'application/x-www-form-urlencoded' },
    transformRequest: [function(data) { return Qs.stringify(data) }],
    data: data
  })
}

/**
 * 查询历史版本详情
 * @param {*} id
 * @returns
 */
export function getTaskHistoryDetail(id) {
  return request({
    url: '/flink/jobConfigHistoryDetail',
    method: 'post',
    headers: { 'Content-Type': 'application/x-www-form-urlencoded' },
    transformRequest: [function(data) { return Qs.stringify(data) }],
    data: { id: id }
  })
}