platform-bi-web/app/models/dataConnect.js

import { message } from 'antd'
import * as service from '../services/index'
import URLS from '../constants/url'

export default {
    namespace: 'dataConnect',
    state: {
        list: [],
        newOne: {}
    },
    reducers: {
        testData(state, action) {
            let list = state.list;
            for(let i = 0; i < 4; i++) {
                let newOne = {
                    name: 'tttttt'+i,
                    type: 'oracle',
                    address: '2',
                    port: '3',
                    userName: '2222',
                    password: 'aaaww',
                    description: ' dddddddddddddddddddddd'
                };
                newOne.key = new Date().getMilliseconds()+(Math.random()*100).toFixed(0)+i;
                newOne.code = new Date().getMilliseconds()+(Math.random()*100).toFixed(0)+i;
                list.push(newOne);
            }
            return Object.assign({}, state, {list});
        },
        list(state, action) {
            const data = action.data;
            return Object.assign({}, state, {list: data});
        },
        add(state, action) {
            let newOne = Object.assign({}, state.newOne);
            let list = state.list;
            newOne.key = new Date().getMilliseconds()+(Math.random()*100).toFixed(0);
            newOne.code = new Date().getMilliseconds()+(Math.random()*100).toFixed(0);
            list.push(newOne);
            return Object.assign({}, state, {list});
        },
        modify(state, action) {
            const { newOne } = state;
            let list = state.list;
            for(let i = 0; i < list.length; i++) {
                if(list[i].code == newOne.code) {
                    list[i] = Object.assign({}, newOne);
                    break;
                }
            }
            return Object.assign({}, state, {list});
        },
        delete(state, action) {
            const { model } = action;
            let { list } = state;
            for(let i = 0; i < list.length; i++) {
                if(list[i].code == model.code) {
                    list.splice(i, 1);
                }
            }
            return Object.assign({}, state, {list});

        },
        setNewModelField(state, action) {
            const { name, value } = action;
            let newOne = state.newOne;
            newOne[name] = value;
            return Object.assign({}, state, {newOne});
        },
        setNewModel(state, action) {
            const { model } = action;
            let newOne = Object.assign({}, model);
            return Object.assign({}, state, {newOne});
        },
        resetNewModel(state, action) {
            return Object.assign({}, state, {newOne: {}});
        }
    },
    effects: {
        *fetchList(action, { select, call, put, takeEvery, takeLatest }) {
            try {
                const res = yield call(service.fetch, {
                    url: URLS.DATACONNECT_LIST,
                    body: {}
                });
                if(!res.err && res.data.code > 0) {
                    let data = res.data.data.map((r, i) => {
                        return {
                            key: i,
                            code: r.id,
                            name: r.name,
                            dbName: r.dataName,
                            dbType: r.databaseType,
                            address: r.addrass,
                            port: r.port,
                            userName: r.userName,
                            password: r.passWord,
                            description: r.note
                        }
                    });
                    console.log(data);
                    yield put({ type: 'list', data });
                }else {
                    message.error('读取数据连接配置列表错误');
                }
            }catch(e) {
                message.error('读取数据连接配置列表错误');
                console.log(e);
            }
        },
        *remoteAdd(action, { select, call, put, takeEvery, takeLatest }) {
            const dataConnect = yield select(state => state.present.dataConnect);
            const model = dataConnect.newOne;
            try {
                const res = yield call(service.fetch, {
                    url: URLS.DATACONNECT_ADD,
                    body: {
                        "name": model.name,
                        "addrass": model.address,
                        "port": model.port,
                        "databaseType": model.dbType,
                        "dataName": model.dbName,
                        "userName": model.userName,
                        "passWord": model.password,
                        "note": model.description
                    }
                });
                yield put({ type: 'add' });
                message.success('新增成功');
            }catch(e) {
                message.error('新增失败');
                //yield takeLatest({ type: 'loadList', data: [] });
            }
        },
        *remoteModify(action, { select, call, put }) {
            try{
                const dataConnect = yield select(state => state.present.dataConnect);
                let model = dataConnect.newOne;
                const code = action.code;
                let list = dataConnect.list;
    
    
                let data = {
                    id: code,
                    name: model.name,
                    addrass: model.address,
                    port: model.port,
                    databaseType: model.dbType,
                    dataName: model.dbName,
                    userName: model.userName,
                    passWord: model.password,
                    note: model.description
                };
                console.log(data);
                const res = yield call(service.fetch, {
                    url: URLS.DATACONNECT_UPDATE,
                    body: data
                });
                if(!res.err && res.data.code > 0) {
                    list = list.map(l => {
                        if(l.code == action.code) {
                            l = model;
                        }
                        return l;
                    });
                    yield put({ type: 'list', data: list });
                    message.success('修改成功');
                }else {
                    message.error('修改失败');
    
                }
            }catch(e) {
                message.error('修改失败');
            }
        },
        *remoteDelete(action, { select, call, put, takeEvery, takeLatest }) {
            const dataConnect = yield select(state => state.present.dataConnect);
            const code = action.code;
            let list = dataConnect.list;
            try {
                const res = yield call(service.fetch, {
                    url: URLS.DATACONNECT_DELETE,
                    body: [code]
                });
                if(!res.err && res.data.code > 0) {
                    for(let i = 0; i < list.length; i++) {
                        if(list[i].code == code) {
                            list.splice(i, 1);
                            break;
                        }
                    }
                    yield put({ type: 'list', data: list });
                    message.success('删除成功');
                }else {
                    message.error('删除失败');
                }
            }catch(e) {
                message.error('删除失败');
                console.log(e);
            }
        }
    },
    subscriptions: {
        setup({ dispatch, history }) {
            dispatch({ type: 'fetchList' })
            return history.listen(({ pathname, query }) => {
            })
        }
    }
};