<route lang="yaml">
  name: collectorTask
</route>

<script lang="ts" setup name="collectorTask">
import { ref } from 'vue'
import TableTools from "@/components/Tools/table_tools.vue";
import {
  addMetaDataTask,
  deleteMetaDataTask,
  getMetaDataTask,
  updateMetaDataTask,
  updateMetaDataState,
  checkMetaDataTask,
  executeMetaDataTask,
  getDatabase,
  checkDatabaseIsExist
} from '@/api/modules/dataMetaService';
import  {
  getCronExecTime
} from '@/api/modules/queryService';
import { TableColumnWidth } from '@/utils/enum';
import { commonPageConfig } from '@/components/PageNav/index';
import { useValidator } from '@/hooks/useValidator';

const { required, checkExistName } = useValidator();
const { proxy } = getCurrentInstance() as any;

const router = useRouter();

/** 数据源选择列表数据。 */
const dataSourceList = ref([])

/** 头部搜索框配置 */
const searchItemList = ref([
  {
    type: "input",
    label: "",
    field: "collectTaskName",
    default: "",
    placeholder: "采集任务名称",
    clearable: true,
  },
  {
    type: "select",
    label: "",
    placeholder: '数据源名称',
    field: 'dataSourceGuid',
    default: '',
    options: dataSourceList.value,
    props: {
      label: 'databaseNameZh',
      value: 'guid'
    },
    clearable: true,
  },
  {
    type: "select",
    label: "",
    field: "taskState",
    default: "",
    placeholder: "任务状态",
    options: [
      { label: "上线", value: "1" },
      { label: "下线", value: "0" },
    ],
    clearable: true,
  }
]);

const currTableData: any = ref<Object>({});
/** 分页及搜索传参信息配置。 */
const page = ref({
  ...commonPageConfig,
  collectTaskName: '',
  dataSourceGuid: '',
  taskState: null
});

const tableInfo = ref({
  id: 'data-source-table',
 // multiple:true,
  fields: [
    { label: "序号", type: "index", width: TableColumnWidth.INDEX, align: "center" },
    { label: "采集任务名称", field: "collectTaskName", width: 140 },
    { label: "元模型", field: "metadataModelChName", width: 140 },
    { label: "数据源名称", field: "datasourceName", width: 160,type: 'text_btn', value: 'datasourceName',columClass:"text_btn" },
    { label: '任务状态', field: 'taskState', type: 'switch', activeText: '上线', inactiveText: '下线', activeValue: 1, inactiveValue: 0, switchWidth: 56, width: 100, align: 'center' },
    { label: "执行计划", field: "collectType", type: 'filter', width: 90 },
    { label: "同步策略", field: "collectMode", type: 'filter', width: 90 },
    { label: "执行周期", field: "execCycle", width: TableColumnWidth.EXECCYCLE },
    { label: "执行状态", field: "runingState", width: TableColumnWidth.STATE, align: 'center', type: "tag" },
    { label: "下次执行时间", field: "nextExecuteTime", width: TableColumnWidth.DATETIME },
    { label: "最后执行时间", field: "lastRuningTime", width: TableColumnWidth.DATETIME, },
    { label: "修改人", field: "updateUserName", width: TableColumnWidth.USERNAME },
    { label: "修改时间", field: "updateTime", width: TableColumnWidth.DATETIME },
  ],
  data: [],
  page: {
    type: "normal",
    rows: 0,
    ...page.value,
  },
  actionInfo: {
    label: "操作",
    type: "btn",
    width: 210,
    fixed: 'right',
    btns: (scope) => {
      const row = scope.row
      let btnsArr: any = [];
      if (row.isCarry) {
        btnsArr.splice(0, 0, { label: "执行中...", value: "carry", disabled: true })
      } else {
        btnsArr.splice(0, 0, { label: "立即执行", value: "carry", disabled: row.taskState === 0 || row.execState == 1 })
      }
      // btnsArr.push({ label: "编辑", value: "edit", disabled: row.taskState === 1 || row.isCarry || row.execState == 1 });
      btnsArr.push({ label: "删除", value: "delete", disabled: row.isCarry || row.taskState === 1 || row.execState == 1 });
      btnsArr.push({ label: "执行日志", value: "log" });
      return btnsArr
    },
  },
  loading: false
})

const collectType = ref(1)

const formItems: any = ref([
{
    label: '元模型',
    type: 'select',
    placeholder: '请选择',
    field: 'metadataModel',
    default: '1',
    options:[
      { label:"数据库表", value:'1' },
      // {label:"BI报表",value:2,},
      // {label:"数据服务",value:3,},
      { label:"ETL工具",value:'4' },
      // {label:"数据处理",value:5,}
    ],
    clearable: true,
    required: true
  }, {
    label: '采集任务名称',
    type: 'input',
    placeholder: '请输入',
    field: 'collectTaskName',
    default: '',
    maxlength: 50,
    clearable: true,
    required: true
  }, {
    label: '数据源名称',
    type: 'select',
    placeholder: '请选择',
    field: 'dataSourceGuid',
    default: '',
    options: dataSourceList.value,
    props: {
      label: 'databaseNameZh',
      value: 'guid'
    },
    clearable: true,
    required: true
  }, {
    label: "执行计划",
    type: "radio-group",
    placeholder: "",
    field: "collectType",
    default: 1,
    options: [
      {
        label: "离线",
        value: 1,
      },
      // {
      //   label: "实时",
      //   value: 2,
      // },
    ],
    required: true,
  }, {
    label: '同步策略',
    type: 'select',
    placeholder: '请选择',
    field: 'collectMode',
    default: 2,
    options: [
      // { label: '增量', value: 1 },
      { label: '全量', value: 2 },
    ],
    clearable: true,
    required: true,
    visible: true
  }, {
    label: '执行周期',
    type: 'input-popover-panel',
    placeholder: '',
    field: 'execCycle',
    default: '',
    append: {
      btn: { label: '执行时间', value: 'cron' }
    },
    teleported: true,
    clearable: true,
    required: true,
    block: true,
    visible: true,
  }, {
    label: '接下来五次执行时间',
    type: 'textarea',
    placeholder: '执行时间',
    field: 'zxzq',
    clearable: true,
    required: false,
    rows: 5,
    block: true,
    visible: true,
    readonly: true
  }, {
    label: "",
    type: "checkbox",
    placeholder: "抽取存量数据",
    field: "isInit",
    default: 'Y',
    trueValue: 'Y',
    falseValue: 'N',
    required: false,
    visible: false,
    col: 'margin-top-21'
  },
])

/** 记录已校验过的信息。 */
const checkedInfo: any = ref({});

const formRules: any = ref({
  metadataModel: [required('请选择元模型')],
  collectTaskName: [required('请填写采集任务名称'), checkExistName(checkedInfo.value, checkMetaDataTask, currTableData.value, 'collectTaskName')],
  dataSourceGuid: [required('请选择数据源')],
  execCycle: [required('请设置执行周期')],
  collectMode: [required('请选择同步策略')],
})
const formInfo = ref({
  type: 'form',
  title: '',
  formInfo: {
    id: 'add-dict-form',
    items: formItems.value,
    rules: formRules.value
  }
})
/** 新建编辑采集任务对话框配置 */
const dialogInfo = ref({
  visible: false,
  size: 700,
  direction: "column",
  header: {
    title: "新建",
  },
  type: '',
  contents: [
    formInfo.value,
  ],
  footer: {
    btns: [
      { type: "default", label: "取消", value: "cancel" },
      { type: "primary", label: "确定", value: "submit" },
    ],
  },
});

const toSearch = (val: any, clear: boolean = false) => {
  if (clear) {
    searchItemList.value.map((item) => (item.default = ""));
    page.value.collectTaskName = '';
    page.value.dataSourceGuid = "";
    page.value.taskState = null;
  } else {
    page.value.collectTaskName = val.collectTaskName;
    page.value.dataSourceGuid = val.dataSourceGuid;
    page.value.taskState = val.taskState;
  }
  getTableData();
};

const getTableData = () => {
  tableInfo.value.loading = true
  getMetaDataTask({
    pageIndex: page.value.curr,
    pageSize: page.value.limit,
    collectTaskName: page.value.collectTaskName,
    dataSourceGuid: page.value.dataSourceGuid,
    taskState: page.value.taskState
  }).then((res: any) => {
    if (res.code == proxy.$passCode) {
      const data = res.data || {}
      tableInfo.value.data = data.records || []
      tableInfo.value.page.limit = data.pageSize
      tableInfo.value.page.curr = data.pageIndex
      tableInfo.value.page.rows = data.totalRows
    } else {
      proxy.$ElMessage({
        type: 'error',
        message: res.msg,
      })
    }
    tableInfo.value.loading = false
  })
};

const tableSwitchBeforeChange = (scope, field, callback) => {
  const msg = `确定【${scope.row[field] == 1 ? '下线' : '上线'}】${scope.row.collectTaskName}?`
  proxy.$openMessageBox(msg, () => {
    const state = scope.row[field] == 1 ? 0 : 1
    const result = tableSwitchChange(state, scope, field)
    callback(result)
  }, () => {
    callback(false)
  });
}

const tableSwitchChange = (val, scope, field) => {
  return new Promise((resolve, reject) => {
    let params = {
      guid: scope.row.guid,
      taskState: val
    }
    updateMetaDataState(params).then((res: any) => {
      if (res.code == proxy.$passCode && res.data) {
        getTableData();
        proxy.$ElMessage({
          type: "success",
          message: `${scope.row.collectTaskName}【${val == 0 ? '下线' : '上线'}】成功`,
        });
        resolve(true)
      } else {
        proxy.$ElMessage({
          type: "error",
          message: res.msg,
        });
        reject(false)
      }
    }).catch(() => {
      reject(false)
    })
  })
}

const tablePageChange = (info) => {
  page.value.curr = Number(info.curr);
  page.value.limit = Number(info.limit);
  getTableData();
};

const oldOriginValue = ref({});

const setFormItems = (row: any = null) => {
  let val = oldOriginValue.value = Object.assign({ collectType: collectType.value, collectMode: 2, isInit: 'Y', metadataModel: '1' }, oldOriginValue.value, row || {});
  formItems.value.map(item => {
    if (item.field == 'dataSourceGuid') {
      item.options = dataSourceList.value
    }
    item.default = val[item.field] || "";
  })
}

const tableBtnClick = (scope, btn) => {
  const type = btn.value;
  let row = scope.row;
  currTableData.value = row;
  if (type == 'carry') {
    row.isCarry = true
    const guid = row.guid
    executeMetaDataTask(guid).then((res: any) => {
      if (res.code == proxy.$passCode) {
        getTableData();
        proxy.$ElMessage({
          type: "success",
          message: "立即执行成功",
        });
      } else {
        proxy.$ElMessage({
          type: "error",
          message: res.msg,
        });
        getTableData();
      }
      row.isCarry = false
    }).catch(() => {
      row.isCarry = false
    })
  } else if (type == 'log') {
    router.push({
      path: '/data-meta/collect-task/excution-log',
      query: {
        guid: row.guid,
        name: row.collectTaskName,
        type: row.collectType
      }
    })
  } else if (type == "edit") {
    dialogInfo.value.header.title = '编辑采集任务';
    dialogInfo.value.type = type
    setDetailInfo(scope.row);
    formInfo.value.formInfo.items[6].default = '';
    formRules.value.collectTaskName = [required('请填写采集任务名称'), checkExistName(checkedInfo.value, checkMetaDataTask, currTableData.value, 'collectTaskName')];
    dialogInfo.value.contents[0].formInfo.rules = formRules.value;
  } else if (type == "delete") {
    proxy.$openMessageBox("此操作将永久删除, 是否继续?", () => {
      let guids = [currTableData.value.guid]
      deleteMetaDataTask(guids).then((res: any) => {
        if (res.code == proxy.$passCode) {
          getTableData();
          proxy.$ElMessage({
            type: "success",
            message: "删除成功",
          });
        } else {
          proxy.$ElMessage({
            type: "error",
            message: res.msg,
          });
        }
      });
    })
  } else if(type=="datasourceName"){
    if (row.metadataModel == '4') {
      proxy.$ElMessage.warning("元模型为ETL工具的采集任务无元数据详情！")
      return;
    }
    checkDatabaseIsExist(row.dataSourceGuid).then((res:any)=>{
        if(res.code===proxy.$passCode){
          if(res.data){
            router.push({
              name:"metadataQuery",
              query:{
              dataSourceGuid:row.dataSourceGuid,
              datasourceName:row.datasourceName,
              }
            })
          } else {
            proxy.$ElMessage.warning("该任务暂未执行成功过！")
          }
        }
    })
  }
};

const loadDrawer = () => {
  collectType.value = 1
  setFormItems()
  setGroup()
  formInfo.value.formInfo.items[5].default = '0 00 00 01 * ? '
  dialogInfo.value.header.title = '新建采集任务'
  dialogInfo.value.type = 'add'
  formInfo.value.formInfo.items = formItems.value
  dialogInfo.value.visible = true;
  checkedInfo.value = {};
  formItems.value[0].default = '1';
  formItems.value[0].disabled = false;
};

const setDetailInfo = (row) => {
  collectType.value = row.collectType
  setFormItems(row)
  setGroup()
  formItems.value[0].disabled = true;
  dialogInfo.value.visible = true;
  checkedInfo.value = {};
}

const getDataSourceList = () => {
  // TODO
  // getDatabase({ connectStatus: 1 }).then((res: any) => {
  //   if (res.code == proxy.$passCode) {
  //     dataSourceList.value = res.data || [];
  //     formItems.value[1].options = dataSourceList.value;
  //     searchItemList.value[1].options = dataSourceList.value;
  //   } else {
  //     proxy.$ElMessage({
  //       type: "error",
  //       message: res.msg,
  //     });
  //   }
  // })
}

const radioGroupChange = (val, info) => {
  collectType.value = val
  setFormItems(info)
  setGroup()
}

const scheduleChange = (val, rowValue) => {
  setFormItems(rowValue)
  formItems.value.at(-3).default = val
  formInfo.value.formInfo.items = formItems.value
}

// 切换结构类型 设置选项显隐
const setGroup = () => {
  if (collectType.value == 2) {
    formItems.value.at(-1).visible = true
    formItems.value.at(-2).visible = false
    formItems.value.at(-3).visible = false
    formItems.value.at(-4).visible = false
  } else {
    formItems.value.at(-1).visible = false
    formItems.value.at(-2).visible = true
    formItems.value.at(-3).visible = true
    formItems.value.at(-4).visible = true
  }
  formInfo.value.formInfo.items = formItems.value
}

const taskCreateDialogRef = ref();

const dialogBtnClick = (btn, info) => {
  if (btn.value == 'submit') {
    let params = { ...info ,}
   // params.taskState = 1;
    if (dialogInfo.value.type == 'add') {
      params.taskState = 1;
      addMetaDataTask(params).then((res: any) => {
        if (res.code == proxy.$passCode) {
          page.value.curr = 1;
          getTableData();
          proxy.$ElMessage({
            type: 'success',
            message: '添加采集任务成功'
          })
          dialogInfo.value.visible = false;
        } else {
          proxy.$ElMessage.error(res.msg);
        }
      })
    } else {
      params.guid = currTableData.value.guid
      updateMetaDataTask(params).then((res: any) => {
        if (res.code == proxy.$passCode) {
          getTableData();
          proxy.$ElMessage({
            type: 'success',
            message: '修改采集任务成功'
          })
          dialogInfo.value.visible = false;
        } else {
          proxy.$ElMessage.error(res.msg);
        }
      })
    }
  } else if (btn.value == 'cancel') {
    dialogInfo.value.visible = false;
  }  else if (btn.value = 'cron') {
    let vInfo = taskCreateDialogRef.value.dialogFormRef[0].formInline;
    if (!vInfo.execCycle) {
      return;
    }
    getCronExecTime(vInfo.execCycle).then((res: any) => {
      if (res?.length) {
        vInfo.zxzq = res.join('\n');
        setFormItems(vInfo);
      } else {
        proxy.$ElMessage({
          type: 'error',
          message: res.msg,
        })
      }
    })
  }
};

const importMeta = () => {
  let query: any = {
      isfileImport: '4'
    }
    // 打开导入文件.
    router.push({
      name: 'importFileMeta',
      query: query
    });
}

onActivated(() => {
  getDataSourceList()
})

onBeforeMount(() => {
  toSearch({})
})
</script>

<template>
  <div class="container_wrap">
    <div class="table_tool_wrap">
     <!-- 头部搜索 -->
      <TableTools :searchItems="searchItemList" :searchId="'data-source-search'" @search="toSearch" :init="false" />
      <div class="tools_btns">
        <!-- <el-button type="primary" @click="loadDrawer">新建</el-button> -->
        <el-button @click="importMeta">导入</el-button>
      </div>
    </div>
    <div class="table_panel_wrap">
      <!-- 右侧采集任务表格 -->
      <Table :tableInfo="tableInfo" @tableBtnClick="tableBtnClick"
        @tablePageChange="tablePageChange" @tableSwitchBeforeChange="tableSwitchBeforeChange" />
    </div>
    <!-- 新建编辑采集任务对话框 -->
    <Dialog ref="taskCreateDialogRef" :dialogInfo="dialogInfo" @btnClick="dialogBtnClick" @radioGroupChange="radioGroupChange"
      @scheduleChange="scheduleChange" />
  </div>
</template>

<style scoped lang="scss">

.table_tool_wrap {
  width: 100%;
  height: 84px !important;
  padding: 0 8px;

  .tools_btns {
    padding: 0px 0 0;
  }
}

.table_panel_wrap {
  width: 100%;
  height: calc(100% - 84px);
  padding: 0px 8px 0;
}
</style>