소스 검색

feat: 修复添加同步任务接口

nobody 2 년 전
부모
커밋
34c98d3815
2개의 변경된 파일6개의 추가작업 그리고 8개의 파일을 삭제
  1. 2 4
      src/module/datasource/component/StepFour.jsx
  2. 4 4
      src/module/datasource/component/SyncTaskAdd.jsx

+ 2 - 4
src/module/datasource/component/StepFour.jsx

@@ -1,6 +1,5 @@
 import React, { useState } from 'react'
 import { Form, Select, Input, DatePicker, Row, Col, InputNumber } from 'antd'
-
 export default function StepFour({ syncDataForm }) {
   const [showPartitionTime, setShowPartitionTime] = useState(false)
   return (
@@ -26,8 +25,7 @@ export default function StepFour({ syncDataForm }) {
           partition_info: '',
           replace_param: '',
           executor_timeout: 0,
-          executor_fail_retry_count: 0,
-          inc_start_time: 0
+          executor_fail_retry_count: 0
         }}
       >
         <Form.Item
@@ -86,7 +84,7 @@ export default function StepFour({ syncDataForm }) {
               message: '请选择增量开始时间',
             },
           ]}>
-          <DatePicker showTime placeholder="" />
+          <DatePicker showTime/>
         </Form.Item>
         <Form.Item
           label="增量时间字段"

+ 4 - 4
src/module/datasource/component/SyncTaskAdd.jsx

@@ -9,6 +9,7 @@ import styled from 'styled-components'
 import { MenuFoldOutlined, MenuUnfoldOutlined } from '@ant-design/icons'
 import { getDataSourceList, getTableSchema, buildJsonData, createJob } from '../services'
 import { useNavigate } from 'react-router'
+import moment from 'moment'
 
 const { Step } = Steps
 
@@ -310,14 +311,13 @@ export default function SyncTaskAdd() {
 
   // 完成提交
   const finishSubmit = async (job_json) => {
-    setSubmiting(true)
+    // setSubmiting(true)
     const fields = currentForm.getFieldValue()
-    const params = {...fields, job_json}
+    const params = {...fields, job_json, 'inc_start_time': moment(fields.inc_start_time).unix()}
     const { data } = await createJob(params)
-    console.log(data);
     if (data.code === 200) {
       message.success('提交成功')
-      navigate('/')
+      navigate(-1);
     } else {
       message.error('提交失败')
     }