You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
139 lines
3.8 KiB
139 lines
3.8 KiB
/*
|
|
* @Description: jupyter tpi 相关内容
|
|
* @Author: tangjiang
|
|
* @Github:
|
|
* @Date: 2019-12-12 09:01:30
|
|
* @LastEditors: tangjiang
|
|
* @LastEditTime: 2019-12-12 17:58:38
|
|
*/
|
|
import types from "./actionTypes";
|
|
import { message } from 'antd';
|
|
import {
|
|
fetchJupyterTpiDataSet,
|
|
fetchJupyterTpiUrl,
|
|
fetchJupyterInfo,
|
|
fetchSyncJupyterCode,
|
|
fetchSaveJupyterTpi
|
|
} from "../../services/jupyterServer";
|
|
|
|
// 获取 jupyter 相关信息
|
|
export const getJupyterInfo = (id) => {
|
|
return (dispatch) => {
|
|
fetchJupyterInfo(id).then(res => {
|
|
if (res.data.status === 401) return;
|
|
if (res.status === 200) {
|
|
const { data } = res;
|
|
console.log(data);
|
|
if (data.status === 0) {
|
|
dispatch({
|
|
type: types.SAVE_JUPYTER_INFO,
|
|
payload: data
|
|
});
|
|
const { identifier, myshixun_identifier } = data;
|
|
// 调用获取数据集接口
|
|
dispatch(getJupyterTpiDataSet(identifier));
|
|
// 调用获取url接口
|
|
dispatch(getJupyterTpiUrl({identifier: myshixun_identifier}));
|
|
}
|
|
}
|
|
})
|
|
}
|
|
}
|
|
// 获取 jupyter tpi 数据集
|
|
export const getJupyterTpiDataSet = (identifier) => {
|
|
return (dispatch) => {
|
|
fetchJupyterTpiDataSet(identifier).then(res => {
|
|
if (res.data.status === 401) return; // 用户未登录
|
|
console.log('数据集:', res);
|
|
if (res.status === 200) {
|
|
const {data_sets} = res.data;
|
|
dispatch({
|
|
type: types.GET_JUPYTER_DATA_SETS,
|
|
payload: data_sets
|
|
});
|
|
}
|
|
});
|
|
}
|
|
}
|
|
// 获取 jupyter tpi 地址
|
|
export const getJupyterTpiUrl = (obj) => {
|
|
return (dispatch, getState) => {
|
|
const {jupyter_info} = getState().jupyterReducer;
|
|
console.log(obj.identifier, jupyter_info.myshixun_identifier);
|
|
if (!obj.identifier && !jupyter_info.myshixun_identifier) return;
|
|
const id = obj.identifier || jupyter_info.myshixun_identifier;
|
|
fetchJupyterTpiUrl({identifier: id}).then(res => {
|
|
if (res.data.status === 401) return; // 用户未登录
|
|
console.log('获取url', res);
|
|
if (res.status === 200) {
|
|
const { status, url = '', port } = res.data;
|
|
dispatch({
|
|
type: types.GET_JUPYTER_TPI_URL,
|
|
payload: {
|
|
status,
|
|
url,
|
|
port
|
|
}
|
|
})
|
|
}
|
|
})
|
|
}
|
|
}
|
|
// 保存 jupyter identifer
|
|
export const saveJupyterIdentifier = (identifier) => {
|
|
return {
|
|
type: types.SAVE_JUPYTER_IDENTIFIER,
|
|
payload: identifier
|
|
}
|
|
}
|
|
// 重置代码
|
|
export const syncJupyterCode = (identifier, msg) => {
|
|
return (dispatch) => {
|
|
fetchSyncJupyterCode(identifier).then(res => {
|
|
// console.log('同步代码成功: ', res);
|
|
if (res.data.status === 401) return;
|
|
if (res.status === 200) {
|
|
const {status} = res.data
|
|
if (status === 0) message.success(msg);
|
|
}
|
|
})
|
|
}
|
|
}
|
|
// 改变状态值
|
|
export const changeGetJupyterUrlState = (status) => {
|
|
return {
|
|
type: types.CHANGE_JUPYTER_URL_STATE,
|
|
payload: status
|
|
}
|
|
}
|
|
// 保存 jupyter tpi
|
|
export const saveJupyterTpi = () => {
|
|
return (dispatch, getState) => {
|
|
|
|
const { jupyter_tpi_code, jupyter_info }= getState().jupyterReducer;
|
|
// console.log(jupyter_info.myshixun_identifier, jupyter_tpi_code);
|
|
if (!jupyter_info.myshixun_identifier) return;
|
|
const params = {
|
|
identifier: jupyter_info.myshixun_identifier,
|
|
jupyter_port: jupyter_tpi_code
|
|
};
|
|
console.log(params);
|
|
fetchSaveJupyterTpi(params).then(res => {
|
|
dispatch({
|
|
type: types.LOADING_STATUS,
|
|
payload: false
|
|
});
|
|
if (res.status === 200) {
|
|
const { data } = res;
|
|
if (data.status === 0) {
|
|
message.success('保存成功!')
|
|
}
|
|
}
|
|
}).catch(() => {
|
|
dispatch({
|
|
type: types.LOADING_STATUS,
|
|
payload: false
|
|
});
|
|
});
|
|
}
|
|
} |