|
@@ -19,8 +19,8 @@ export default {
|
|
|
},
|
|
},
|
|
|
reducers: {
|
|
reducers: {
|
|
|
list(state, action) {
|
|
list(state, action) {
|
|
|
- let data = action.data;
|
|
|
|
|
- return Object.assign({}, state, {list: data});
|
|
|
|
|
|
|
+ const { list } = action;
|
|
|
|
|
+ return { ...state, list };
|
|
|
},
|
|
},
|
|
|
add(state, action) {
|
|
add(state, action) {
|
|
|
let newOne = Object.assign({}, state.newOne);
|
|
let newOne = Object.assign({}, state.newOne);
|
|
@@ -166,6 +166,7 @@ export default {
|
|
|
},
|
|
},
|
|
|
effects: {
|
|
effects: {
|
|
|
*fetchList(action, { select, call, put, takeEvery, takeLatest }) {
|
|
*fetchList(action, { select, call, put, takeEvery, takeLatest }) {
|
|
|
|
|
+ const body = {};
|
|
|
try {
|
|
try {
|
|
|
const dataSource = yield select(state => state.present.dataSource);
|
|
const dataSource = yield select(state => state.present.dataSource);
|
|
|
if(!action.mandatory && dataSource.list.length > 0) {
|
|
if(!action.mandatory && dataSource.list.length > 0) {
|
|
@@ -173,11 +174,12 @@ export default {
|
|
|
}
|
|
}
|
|
|
const res = yield call(service.fetch, {
|
|
const res = yield call(service.fetch, {
|
|
|
url: URLS.DATASOURCE_LIST,
|
|
url: URLS.DATASOURCE_LIST,
|
|
|
- body: {}
|
|
|
|
|
|
|
+ body
|
|
|
});
|
|
});
|
|
|
|
|
|
|
|
|
|
+ console.log('请求数据源列表', body, res);
|
|
|
if(!res.err && res.data.code > 0) {
|
|
if(!res.err && res.data.code > 0) {
|
|
|
- let data = res.data.data.map((r, i) => {
|
|
|
|
|
|
|
+ let list = res.data.data.map((r, i) => {
|
|
|
let dbConfig = JSON.parse(r.dbConfig);
|
|
let dbConfig = JSON.parse(r.dbConfig);
|
|
|
let tags = JSON.parse(r.dataTag);
|
|
let tags = JSON.parse(r.dataTag);
|
|
|
return {
|
|
return {
|
|
@@ -193,8 +195,7 @@ export default {
|
|
|
groupCode: r.connectorGroup+''
|
|
groupCode: r.connectorGroup+''
|
|
|
}
|
|
}
|
|
|
});
|
|
});
|
|
|
- console.log('请求数据源列表', res, data);
|
|
|
|
|
- yield put({ type: 'list', data });
|
|
|
|
|
|
|
+ yield put({ type: 'list', list });
|
|
|
}else {
|
|
}else {
|
|
|
message.error('读取数据源列表错误: ' + (res.err || res.data.msg));
|
|
message.error('读取数据源列表错误: ' + (res.err || res.data.msg));
|
|
|
}
|
|
}
|
|
@@ -313,7 +314,7 @@ export default {
|
|
|
}catch(e) {
|
|
}catch(e) {
|
|
|
console.log(e);
|
|
console.log(e);
|
|
|
message.error('数据源解析错误');
|
|
message.error('数据源解析错误');
|
|
|
- yield put({ type: 'list', data: [] });
|
|
|
|
|
|
|
+ yield put({ type: 'list', list: [] });
|
|
|
}
|
|
}
|
|
|
},
|
|
},
|
|
|
*importNewModelColumns(action, { select, call, put }) {
|
|
*importNewModelColumns(action, { select, call, put }) {
|
|
@@ -379,7 +380,7 @@ export default {
|
|
|
break;
|
|
break;
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
- yield put({ type: 'list', data: list });
|
|
|
|
|
|
|
+ yield put({ type: 'list', list });
|
|
|
message.success('删除成功');
|
|
message.success('删除成功');
|
|
|
}else {
|
|
}else {
|
|
|
message.error('删除失败: ' + (res.err || res.data.msg));
|
|
message.error('删除失败: ' + (res.err || res.data.msg));
|
|
@@ -791,6 +792,38 @@ export default {
|
|
|
console.log(e);
|
|
console.log(e);
|
|
|
message.error('设置分组失败');
|
|
message.error('设置分组失败');
|
|
|
}
|
|
}
|
|
|
|
|
+ },
|
|
|
|
|
+ *transfer(action, { put, call, select }) {
|
|
|
|
|
+ const { userCode, dataSourceCode } = action;
|
|
|
|
|
+ const body = {
|
|
|
|
|
+ userId: userCode,
|
|
|
|
|
+ id: dataSourceCode
|
|
|
|
|
+ };
|
|
|
|
|
+ try {
|
|
|
|
|
+ const res = yield call(service.fetch, {
|
|
|
|
|
+ url: URLS.DATASOURCE_TRANSFER,
|
|
|
|
|
+ body
|
|
|
|
|
+ });
|
|
|
|
|
+ console.log('数据源移交', body, res);
|
|
|
|
|
+ if(!res.err && res.data.code > 0) {
|
|
|
|
|
+ const dataSource = yield select(state => state.present.dataSource);
|
|
|
|
|
+ const list = dataSource.list;
|
|
|
|
|
+ for(let i = 0; i < list.length; i++) {
|
|
|
|
|
+ if(list[i].code === dataSourceCode) {
|
|
|
|
|
+ list.splice(i, 1);
|
|
|
|
|
+ break;
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
|
|
+ yield put({ type: 'list', list });
|
|
|
|
|
+ message.success('移交成功');
|
|
|
|
|
+ }else {
|
|
|
|
|
+ console.log(body, res.err || res.data.msg);
|
|
|
|
|
+ message.error('移交失败');
|
|
|
|
|
+ }
|
|
|
|
|
+ }catch(e) {
|
|
|
|
|
+ console.log(body, e);
|
|
|
|
|
+ message.error('移交失败');
|
|
|
|
|
+ }
|
|
|
}
|
|
}
|
|
|
},
|
|
},
|
|
|
subscriptions: {
|
|
subscriptions: {
|