From e1ad5515a11cabbf067aa5eea5dae77044944790 Mon Sep 17 00:00:00 2001
From: silenceqi <silenceqi@hotmail.com>
Date: Wed, 20 Jan 2021 23:36:00 +0800
Subject: [PATCH] modify index management

---
 api/index_management/indices.go              |  29 +++
 api/init.go                                  |   1 +
 web/src/pages/DataManagement/Document.js     |   3 +
 web/src/pages/DataManagement/Index.js        | 253 +++++++------------
 web/src/pages/DataManagement/models/index.js |  14 +-
 web/src/services/indices.js                  |   9 +
 6 files changed, 148 insertions(+), 161 deletions(-)

diff --git a/api/index_management/indices.go b/api/index_management/indices.go
index 73e9d604..50970447 100644
--- a/api/index_management/indices.go
+++ b/api/index_management/indices.go
@@ -1,6 +1,7 @@
 package index_management
 
 import (
+	"fmt"
 	"net/http"
 	"strings"
 
@@ -107,4 +108,32 @@ func (handler APIHandler) HandleDeleteIndexAction(w http.ResponseWriter, req *ht
 	}
 	resBody["payload"] = true
 	handler.WriteJSON(w, resBody, http.StatusOK)
+}
+
+func (handler APIHandler) HandleCreateIndexAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params) {
+	defer func() {
+		if err := recover(); err != nil {
+			fmt.Println(err)
+		}
+	}()
+	client := elastic.GetClient(handler.Config.Elasticsearch)
+	indexName := ps.ByName("index")
+	resBody := newResponseBody()
+	config := map[string]interface{}{}
+	err := handler.DecodeJSON(req, &config)
+	if err != nil {
+		resBody["status"] = false
+		resBody["error"] = err
+		handler.WriteJSON(w, resBody, http.StatusOK)
+		return
+	}
+	err = client.CreateIndex(indexName, config)
+	if err != nil {
+		resBody["status"] = false
+		resBody["error"] = err
+		handler.WriteJSON(w, resBody, http.StatusOK)
+		return
+	}
+	resBody["payload"] = true
+	handler.WriteJSON(w, resBody, http.StatusOK)
 }
\ No newline at end of file
diff --git a/api/init.go b/api/init.go
index 9a15b7f0..7e489256 100644
--- a/api/init.go
+++ b/api/init.go
@@ -34,6 +34,7 @@ func Init(cfg *config.AppConfig) {
 	ui.HandleUIMethod(api.GET, pathPrefix+"index/:index/_settings", handler.HandleGetSettingsAction)
 	ui.HandleUIMethod(api.PUT, pathPrefix+"index/:index/_settings", handler.HandleUpdateSettingsAction)
 	ui.HandleUIMethod(api.DELETE, pathPrefix+"index/:index", handler.HandleDeleteIndexAction)
+	ui.HandleUIMethod(api.POST, pathPrefix+"index/:index", handler.HandleCreateIndexAction)
 
 	task.RegisterScheduleTask(task.ScheduleTask{
 		Description: "sync reindex task result to index infinireindex",
diff --git a/web/src/pages/DataManagement/Document.js b/web/src/pages/DataManagement/Document.js
index 8ed73cad..6a9f4e6a 100644
--- a/web/src/pages/DataManagement/Document.js
+++ b/web/src/pages/DataManagement/Document.js
@@ -426,6 +426,9 @@ class Doucment extends React.Component {
       return;
     }
     let {indices, mappings} = document;
+    if(!indices){
+        return
+    }
     let _index = indices[0];
     if(indices && indices.length > 1){
       //console.log(this.indexSelEl);
diff --git a/web/src/pages/DataManagement/Index.js b/web/src/pages/DataManagement/Index.js
index 761b674c..1a5ee556 100644
--- a/web/src/pages/DataManagement/Index.js
+++ b/web/src/pages/DataManagement/Index.js
@@ -55,82 +55,56 @@ class JSONWrapper extends PureComponent {
     )
   }
 }
-
-const CreateForm = Form.create()(props => {
-  const { modalVisible, form, handleAdd, handleModalVisible } = props;
-  const okHandle = () => {
+@Form.create()
+class CreateForm extends React.Component {
+  okHandle = () => {
+    const {handleAdd, form} = this.props;
     form.validateFields((err, fieldsValue) => {
       if (err) return;
       form.resetFields();
+      fieldsValue['config'] = this.editorValueGetter();
       handleAdd(fieldsValue);
     });
   };
-  return (
-    <Modal
-      destroyOnClose
-      title="新建索引"
-      visible={modalVisible}
-      width={640}
-      onOk={okHandle}
-      onCancel={() => handleModalVisible()}
-    >
-       <FormItem labelCol={{ span: 5 }} wrapperCol={{ span: 15 }} label="索引名称">
-        {form.getFieldDecorator('index', {
-          rules: [{ required: true, message: '请输入至少五个字符的名称！', min: 5 }],
-        })(<Input placeholder="请输入名称" />)}
-      </FormItem>
-      <FormItem labelCol={{ span: 5 }} wrapperCol={{ span: 15 }} label="索引设置">
-        {form.getFieldDecorator('settings', {
-          rules: [{ required: true }],
-        })(<TextArea
-          style={{ minHeight: 24 }}
-          placeholder="请输入"
-          rows={9}
-      />)}
-      </FormItem>
-    </Modal>
-  );
-});
 
-const UpdateForm = Form.create()(props => {
-  const { updateModalVisible, handleUpdateModalVisible, handleUpdate,values,form } = props;
+  render() {
+    const {modalVisible, form, handleModalVisible} = this.props;
+    return (
+        <Modal
+            destroyOnClose
+            title="新建索引"
+            visible={modalVisible}
+            width={640}
+            onOk={this.okHandle}
+            onCancel={() => handleModalVisible()}
+        >
+          <FormItem labelCol={{span: 5}} wrapperCol={{span: 15}} label="索引名称">
+            {form.getFieldDecorator('index', {
+              rules: [{required: true, message: '请输入至少五个字符的名称！', min: 5}],
+            })(<Input placeholder="请输入名称"/>)}
+          </FormItem>
+          <FormItem labelCol={{span: 5}} wrapperCol={{span: 15}} label="索引设置">
+            <div style={{border: '1px solid rgb(232, 232, 232)'}}>
+              <Editor
+                  height="300px"
+                  language="json"
+                  theme="light"
+                  options={{
+                    minimap: {
+                      enabled: false,
+                    },
+                    tabSize: 2,
+                    wordBasedSuggestions: true,
+                  }}
+                  editorDidMount={(valueGetter)=>{this.editorValueGetter=valueGetter}}
+              />
+            </div>
+          </FormItem>
+        </Modal>
+    );
+  }
+}
 
-  const okHandle = () => {
-    form.validateFields((err, fieldsValue) => {
-      if (err) return;
-      form.resetFields();
-      handleUpdate(fieldsValue);
-    });
-  };
-  
-  return (
-    <Modal
-      destroyOnClose
-      title="索引设置"
-      visible={updateModalVisible}
-      width={640}
-      onOk={okHandle}
-      onCancel={() => handleUpdateModalVisible()}
-    >
-       <FormItem labelCol={{ span: 5 }} wrapperCol={{ span: 15 }} label="索引名称">
-        {form.getFieldDecorator('index', {
-          initialValue: values.index,
-          rules: [{ required: true, message: '请输入至少五个字符的名称！', min: 5 }],
-        })(<Input placeholder="请输入名称" />)}
-      </FormItem>
-      <FormItem labelCol={{ span: 5 }} wrapperCol={{ span: 15 }} label="索引设置">
-        {form.getFieldDecorator('settings', {
-          initialValue: values.processors,
-          rules: [{ required: true }],
-        })(<TextArea
-          style={{ minHeight: 24 }}
-          placeholder="请输入"
-          rows={9}
-      />)}
-      </FormItem>
-    </Modal>
-  );
-});
 
 /* eslint react/no-multi-comp:0 */
 @connect(({ index }) => ({
@@ -143,7 +117,6 @@ class Index extends PureComponent {
     updateModalVisible: false,
     expandForm: false,
     formValues: {},
-    updateFormValues: {},
     drawerVisible: false,
     editingIndex:{},
     indexActiveKey: '1',
@@ -190,6 +163,10 @@ class Index extends PureComponent {
   ];
 
   componentDidMount() {
+    this.fetchData()
+  }
+
+  fetchData = ()=>{
     const { dispatch } = this.props;
     dispatch({
       type: 'index/fetchIndices',
@@ -205,10 +182,6 @@ class Index extends PureComponent {
     this.setState({
       formValues: {},
     });
-    dispatch({
-      type: 'pipeline/fetch',
-      payload: {},
-    });
   };
 
   handleDeleteClick = (indexName) => {
@@ -240,74 +213,18 @@ class Index extends PureComponent {
     });
   };
 
-  handleUpdateModalVisible = (flag, record) => {
-    this.setState({
-      updateModalVisible: !!flag,
-      updateFormValues: record || {},
-    });
-  };
-
   handleAdd = fields => {
     const { dispatch } = this.props;
     dispatch({
-      type: 'pipeline/add',
+      type: 'index/addIndex',
       payload: {
-        name: fields.name,
-        desc: fields.desc,
-        processors: fields.processors,
+        index: fields.index,
+        config: JSON.parse(fields.config)
       },
     });
-
-    message.success('添加成功');
     this.handleModalVisible();
   };
 
-  handleUpdate = fields => {
-    const { dispatch } = this.props;
-    dispatch({
-      type: 'pipeline/update',
-      payload: {
-        name: fields.name,
-        desc: fields.desc,
-        processors: fields.processors,
-      },
-    });
-
-    message.success('修改成功');
-    this.handleUpdateModalVisible();
-  };
-
-  renderSimpleForm() {
-    const {
-      form: { getFieldDecorator },
-    } = this.props;
-    return (
-      <Form onSubmit={this.handleSearch} layout="inline">
-        <Row gutter={{ md: 8, lg: 24, xl: 48 }}>
-          <Col md={8} sm={24}>
-            <FormItem label="索引名称">
-              {getFieldDecorator('name')(<Input placeholder="请输入" />)}
-            </FormItem>
-          </Col>
-          <Col md={8} sm={24}>
-            <span className={styles.submitButtons}>
-              <Button type="primary" htmlType="submit">
-                查询
-              </Button>
-              <Button style={{ marginLeft: 8 }} onClick={this.handleFormReset}>
-                重置
-              </Button>
-            </span>
-          </Col>
-        </Row>
-      </Form>
-    );
-  }
-
-  renderForm() {
-    return this.renderSimpleForm();
-  }
-
   handleIndexTabChanged = (activeKey, indexName) => {
     this.setState({
       indexActiveKey: activeKey,
@@ -335,8 +252,8 @@ class Index extends PureComponent {
       })
     }
   }
-  handleEditorDidMount = (_valueGetter)=>{
-    this.indexSettingsGetter = _valueGetter;
+  handleEditorDidMount = (editorName, _valueGetter)=>{
+    this[editorName] = _valueGetter;
   }
 
   handleIndexSettingsSaveClick = (indexName)=>{
@@ -347,7 +264,7 @@ class Index extends PureComponent {
       type: 'index/saveSettings',
       payload: {
         index: indexName,
-        settings: settings.settings,
+        settings: settings,
       }
     })
   }
@@ -377,35 +294,53 @@ class Index extends PureComponent {
     if(settings && settings[editingIndex.index]){
       newSettings = transformSettingsForApi(settings[editingIndex.index], editingIndex.status === 'open')
     }
+    const {form: { getFieldDecorator }} = this.props;
     
     return (
       <Fragment>
         <Card bordered={false}>
           <div className={styles.tableList}>
-            <div className={styles.tableListForm}>{this.renderForm()}</div>
+            <div className={styles.tableListForm}>
+              <Form onSubmit={this.handleSearch} layout="inline">
+                <Row gutter={{ md: 8, lg: 24, xl: 48 }}>
+                  <Col md={8} sm={24}>
+                    <FormItem label="索引名称">
+                      {getFieldDecorator('name')(<Input placeholder="请输入" />)}
+                    </FormItem>
+                  </Col>
+                  <Col md={8} sm={24}>
+                    <span className={styles.submitButtons}>
+                      <Button type="primary" htmlType="submit">
+                        查询
+                      </Button>
+                      <Button style={{ marginLeft: 8 }} onClick={this.handleFormReset}>
+                        重置
+                      </Button>
+                    </span>
+                  </Col>
+                  <Col md={8} sm={24} style={{textAlign:"right"}}>
+                    <Button icon="redo" style={{marginRight:10}} onClick={()=>{this.fetchData()}}>刷新</Button>
+                    <Button icon="plus" type="primary" onClick={() => this.handleModalVisible(true)}>
+                      新建
+                    </Button>
+                  </Col>
+                </Row>
+              </Form>
+            </div>
             <div className={styles.tableListOperator}>
-              <Button icon="plus" type="primary" onClick={() => this.handleModalVisible(true)}>
-                新建
-              </Button>
+
             </div>
             <Table bordered
               dataSource={indices}
-              rowKey='index'
+              rowKey='id'
               pagination={
-                {pageSize: 5,}
+                {pageSize: 10,}
               }
               columns={this.columns}
             />
           </div>
         </Card>
         <CreateForm {...parentMethods} modalVisible={modalVisible} />
-        {updateFormValues && Object.keys(updateFormValues).length ? (
-          <UpdateForm
-            {...updateMethods}
-            updateModalVisible={updateModalVisible}
-            values={updateFormValues}
-          />
-        ) : null}
         <Drawer title={editingIndex.index}
           visible={drawerVisible}
           onClose={()=>{
@@ -417,17 +352,17 @@ class Index extends PureComponent {
           width={720}
         >
            <Tabs activeKey={this.state.indexActiveKey} onChange={(activeKey)=>{this.handleIndexTabChanged(activeKey, editingIndex.index)}}>
-            <TabPane tab="Summary" key="1">
+            <TabPane tab="概览" key="1">
             <Descriptions title="General" column={2}>
-              <Descriptions.Item label="Health">{editingIndex.health}</Descriptions.Item>
-              <Descriptions.Item label="Status">{editingIndex.status}</Descriptions.Item>
-              <Descriptions.Item label="Primaries">{editingIndex.shards}</Descriptions.Item>
-              <Descriptions.Item label="Replicas">{editingIndex.replicas}</Descriptions.Item>
-              <Descriptions.Item label="Docs Count">{editingIndex.docs_count}</Descriptions.Item>
-              <Descriptions.Item label="Docs Deleted">{editingIndex.docs_deleted}</Descriptions.Item>
-              <Descriptions.Item label="Storage Size"></Descriptions.Item>
-              <Descriptions.Item label="Primary Storage Size"></Descriptions.Item>
-              <Descriptions.Item label="Alias">
+              <Descriptions.Item label="健康">{editingIndex.health}</Descriptions.Item>
+              <Descriptions.Item label="状态">{editingIndex.status}</Descriptions.Item>
+              <Descriptions.Item label="主分片数">{editingIndex.shards}</Descriptions.Item>
+              <Descriptions.Item label="副分片数">{editingIndex.replicas}</Descriptions.Item>
+              <Descriptions.Item label="文档数">{editingIndex.docs_count}</Descriptions.Item>
+              <Descriptions.Item label="删除文档数">{editingIndex.docs_deleted}</Descriptions.Item>
+              <Descriptions.Item label="存贮大小"></Descriptions.Item>
+              <Descriptions.Item label="主存贮大小"></Descriptions.Item>
+              <Descriptions.Item label="别名">
               </Descriptions.Item>
             </Descriptions>
             </TabPane>
@@ -462,7 +397,7 @@ class Index extends PureComponent {
                       tabSize: 2,
                       wordBasedSuggestions: true,
                     }}
-                    editorDidMount={this.handleEditorDidMount}
+                    editorDidMount={(valueGetter)=>this.handleEditorDidMount('indexSettingsGetter', valueGetter)}
                 />
               </div>
             </TabPane>
diff --git a/web/src/pages/DataManagement/models/index.js b/web/src/pages/DataManagement/models/index.js
index 7ef329bf..50be2d13 100644
--- a/web/src/pages/DataManagement/models/index.js
+++ b/web/src/pages/DataManagement/models/index.js
@@ -1,5 +1,5 @@
 import { getIndices,getMappings, getSettings, deleteIndex,
-updateSettings} from '@/services/indices';
+updateSettings,createIndex} from '@/services/indices';
 import { message } from 'antd';
 
 export default {
@@ -79,7 +79,17 @@ export default {
                     clusterIndices: clusterIndices,
                 }
             })
-        }
+        },
+        *addIndex({payload}, {call, put, select}){
+            let resp = yield call(createIndex, payload);
+            if(resp.status === false){
+                message.warn("create index failed")
+                return
+            }
+            yield put({
+                type: 'fetchIndices'
+            })
+        },
     },
     reducers:{
         saveData(state, {payload}){
diff --git a/web/src/services/indices.js b/web/src/services/indices.js
index 25b0457a..aa798832 100644
--- a/web/src/services/indices.js
+++ b/web/src/services/indices.js
@@ -40,4 +40,13 @@ export async function deleteIndex(params) {
     return request(`${pathPrefix}/index/${index}`, {
         method: 'DELETE'
     });
+}
+
+
+export async function createIndex(params) {
+    let index = params.index;
+    return request(`${pathPrefix}/index/${index}`, {
+        method: 'POST',
+        body: params.config
+    });
 }
\ No newline at end of file