同步任务

src/view/Manage/DatasourceManage/Component/DatasourceItem.jsx

@@ -7,7 +7,7 @@ import { dispatch } from '../../../../model';
 import './DatasourceItem.less';
 
 const DatasourceItem = (props) => {
-  const { data, onStartTask, onEditTask, onDeleteTask, expanded } = props;
+  const { data, onStartTask, onEditTask, onDeleteTask, expanded, refresh, refreshSuccess } = props;
   const [ tasks, setTasks ] = useState(null);
 
   useEffect(() => {
@@ -18,6 +18,14 @@ const DatasourceItem = (props) => {
     //eslint-disable-next-line react-hooks/exhaustive-deps
   }, [expanded])
 
+  useEffect(() => {
+    if (refresh && expanded) {
+      getTasks();
+    }
+    
+    //eslint-disable-next-line react-hooks/exhaustive-deps
+  }, [refresh])
+
   const getTasks = () => {
     dispatch({
       type: 'datasource.getTasksByDatasourceId',
@@ -26,6 +34,7 @@ const DatasourceItem = (props) => {
       },
       callback: data => {
         setTasks(data);
+        refresh && refreshSuccess && refreshSuccess();
       }
     })
   }

src/view/Manage/DatasourceManage/Component/DatasourceList.jsx

@@ -6,7 +6,7 @@ import DatasourceItem from './DatasourceItem';
 
 const DatasourceList = (props) => {
 
-  const { loading, data, onEdit, onAddTask, onDelete, onStartTask, onEditTask, onDeleteTask } = props;
+  const { loading, data, onEdit, onAddTask, onDelete, onStartTask, onEditTask, onDeleteTask, idBindTasksNeedRefresh, refreshTasksSuccess } = props;
 
   const [ expandedBindId, setExpandedBindId ] = useState({});
 
@@ -63,7 +63,7 @@ const DatasourceList = (props) => {
                   </Space>
                 </div>
               }
-              description={ <DatasourceItem data={item} expanded={expanded} onStartTask={onStartTask} onEditTask={onEditTask} onDeleteTask={onDeleteTask} /> }
+              description={ <DatasourceItem data={item} expanded={expanded} refresh={idBindTasksNeedRefresh===item.id} onStartTask={onStartTask} onEditTask={onEditTask} onDeleteTask={onDeleteTask} refreshSuccess={refreshTasksSuccess} /> }
             />
           </List.Item>
         );

src/view/Manage/DatasourceManage/Component/UpdateTaskModal.jsx

@@ -107,7 +107,7 @@ const UpdateTaskModal = (props) => {
         },
         callback: data => {
           setConfirmLoading(false);
-          onCancel && onCancel();
+          onCancel && onCancel(true);
         },
         error: () => {
           setConfirmLoading(false);

src/view/Manage/DatasourceManage/index.jsx

@@ -25,6 +25,7 @@ const DatasourceManage = () => {
   const [ updateTaskModalVisible, setUpdateTaskModalVisible ] = useState(false);
   const [ updateTaskModalAction, setUpdateTaskModalAction ] = useState('');
   const [ currentDatasourceId, setCurrentDatasourceId ] = useState('');
+  const [ currentDatasourceIdBindTasksNeedRefresh, setCurrentDatasourceIdBindTasksNeedRefresh ] = useState('');
   const [ currentTaskId, setCurrentTaskId ] = useState('');
 
   const [modal, contextHolder] = Modal.useModal();
@@ -138,6 +139,7 @@ const DatasourceManage = () => {
 
   const editTask = (task) => {
     setCurrentTaskId(task.id);
+    setCurrentDatasourceId(task.target.id||'');
     setUpdateTaskModalAction('edit');
     setUpdateTaskModalVisible(true);
   }
@@ -153,6 +155,8 @@ const DatasourceManage = () => {
             harvestingTaskId: task.id
           },
           callback: () => {
+            setCurrentDatasourceIdBindTasksNeedRefresh(task.target.id||'');
+            setCurrentDatasourceId(task.target.id||'');
             showMessage('success', '删除任务成功');
           }
         });
@@ -160,8 +164,13 @@ const DatasourceManage = () => {
     });
   }
 
-  const onUpdateTaskModalVisibleCancel = () => {
+  const onUpdateTaskModalVisibleCancel = (refresh = false) => {
     setUpdateTaskModalVisible(false);
+    refresh && setCurrentDatasourceIdBindTasksNeedRefresh(currentDatasourceId);
+  }
+
+  const refreshTasksSuccess = () => {
+    setCurrentDatasourceIdBindTasksNeedRefresh('');
   }
 
   return (
@@ -199,12 +208,14 @@ const DatasourceManage = () => {
         <DatasourceList 
           loading={loadingDatasources}
           data={filterDatasources||[]}
+          idBindTasksNeedRefresh={currentDatasourceIdBindTasksNeedRefresh}
           onEdit={editDatasource}
           onAddTask={addTask}
           onDelete={deleteDatasource}
           onStartTask={startTask}
           onEditTask={editTask}
           onDeleteTask={deleteTask}
+          refreshTasksSuccess={refreshTasksSuccess}
         />
       </div>