1
0
forked from x/icebergs

opt es.CMD

This commit is contained in:
shaoying 2020-08-14 02:10:21 +08:00
parent c72b3d2c28
commit bb560a9f87
3 changed files with 55 additions and 21 deletions

View File

@ -171,13 +171,18 @@ func _field_show(m *ice.Message, name, text string, arg ...string) {
} else { } else {
m.Parse("option", arg[i], arg[i+1]) m.Parse("option", arg[i], arg[i+1])
} }
data[arg[i]] = m.Optionv(arg[i]) data[arg[i]] = m.Optionv(arg[i])
if arg[i] == "args" { switch arg[i] {
case "content":
data[arg[i]] = arg[i+1]
case "args":
args := kit.Simple(m.Optionv(arg[i])) args := kit.Simple(m.Optionv(arg[i]))
count := 0 count := 0
kit.Fetch(data["inputs"], func(index int, value map[string]interface{}) { kit.Fetch(data["inputs"], func(index int, value map[string]interface{}) {
if value["_input"] == "text" || value["type"] == "text" { if value["_input"] != "button" && value["type"] != "button" {
count++ count++
} }
}) })
@ -368,6 +373,20 @@ func init() {
if len(arg) == 1 { if len(arg) == 1 {
arg = []string{"", arg[0]} arg = []string{"", arg[0]}
} }
if arg[0] == "shell" {
arg[1] = strings.TrimSpace(arg[1])
m.Echo(`<div class="story" data-type="spark" data-name="shell" data-text="%s">`, arg[1])
for _, l := range strings.Split(arg[1], "\n") {
m.Echo("<div>")
m.Echo("$ ")
m.Echo("<span>")
m.Echo(l)
m.Echo("</span>")
m.Echo("</div>")
}
m.Echo("</div>")
return
}
_spark_show(m, arg[0], kit.Select(arg[0], arg[1]), arg[2:]...) _spark_show(m, arg[0], kit.Select(arg[0], arg[1]), arg[2:]...)
}}, }},

View File

@ -54,27 +54,35 @@ var Index = &ice.Context{Name: ES, Help: "搜索",
return return
} }
if len(arg) == 1 {
m.Richs(cli.DAEMON, "", arg[0], func(key string, value map[string]interface{}) { m.Richs(cli.DAEMON, "", arg[0], func(key string, value map[string]interface{}) {
m.Cmdy("web.spide", "dev", "raw", "GET", "http://localhost:9200") m.Cmdy("web.spide", "dev", "raw", "GET", "http://localhost:9200")
}) })
}
if len(arg) == 2 {
m.Richs(cli.DAEMON, "", arg[0], func(key string, value map[string]interface{}) {
m.Cmdy("web.spide", "dev", "raw", "GET", "http://localhost:9200")
})
}
}}, }},
"command": {Name: "command 执行:button method:select=GET|PUT|POST|DELETE cmd=/ data:textarea", Help: "命令", Action: map[string]*ice.Action{}, Hand: func(m *ice.Message, c *ice.Context, cmd string, arg ...string) { "GET": {Name: "GET 查看:button cmd=/", Help: "命令", Action: map[string]*ice.Action{}, Hand: func(m *ice.Message, c *ice.Context, cmd string, arg ...string) {
if pod := m.Option("_pod"); pod != "" { if pod := m.Option("_pod"); pod != "" {
m.Option("_pod", "") m.Option("_pod", "")
m.Cmdy(web.SPACE, pod, "web.code.es.command", arg) m.Cmdy(web.SPACE, pod, "web.code.es.command", arg)
return return
} }
m.Option("header", "Content-Type", "application/json") m.Option("header", "Content-Type", "application/json")
m.Echo(kit.Formats(kit.UnMarshal(m.Cmdx("web.spide", "dev", "raw", arg[0], "http://localhost:9200/"+arg[1], "data", arg[2])))) m.Echo(kit.Formats(kit.UnMarshal(m.Cmdx("web.spide", "dev", "raw", "GET", kit.MergeURL2("http://localhost:9200", kit.Select("/", arg, 0))))))
}},
"CMD": {Name: "CMD 执行:button method:select=GET|PUT|POST|DELETE cmd=/ data:textarea", Help: "命令", Action: map[string]*ice.Action{}, Hand: func(m *ice.Message, c *ice.Context, cmd string, arg ...string) {
if pod := m.Option("_pod"); pod != "" {
m.Option("_pod", "")
m.Cmdy(web.SPACE, pod, "web.code.es.CMD", arg)
return
}
if arg[0] == "GET" {
m.Option("header", "Content-Type", "application/json")
m.Echo(kit.Formats(kit.UnMarshal(m.Cmdx("web.spide", "dev", "raw", arg[0], kit.MergeURL2("http://localhost:9200", arg[1])))))
return
}
m.Option("header", "Content-Type", "application/json")
m.Echo(kit.Formats(kit.UnMarshal(m.Cmdx("web.spide", "dev", "raw", arg[0], kit.MergeURL2("http://localhost:9200", arg[1]), "data", arg[2]))))
}}, }},
"index": {Name: "table index 创建:button", Help: "索引", Action: map[string]*ice.Action{}, Hand: func(m *ice.Message, c *ice.Context, cmd string, arg ...string) { "index": {Name: "table index 创建:button", Help: "索引", Action: map[string]*ice.Action{}, Hand: func(m *ice.Message, c *ice.Context, cmd string, arg ...string) {

View File

@ -16,20 +16,27 @@ linux https://elasticsearch.thans.cn/downloads/elasticsearch/elasticsearch-7.3.2
section 启动 section 启动
spark shell ` spark shell `
$ tar xvf elasticsearch-7.3.2-linux-x86_64.tar.gz tar xvf elasticsearch-7.3.2-linux-x86_64.tar.gz
$ cd elasticsearch-7.3.2 cd elasticsearch-7.3.2
$ ./bin/elasticsearch ./bin/elasticsearch
` `
section 体验 section 体验
spark shell ` spark shell `
$ curl http://localhost:9200 curl http://localhost:9200
` `
field command web.code.es.command option `{ _pod centos.remote }` # field command web.code.es.command option `{ _pod centos.remote }`
field GET web.code.es.GET style command args `[ /index_test/test_type/1 ]`
field CMD web.code.es.CMD style command args `[ POST /index_test/test_type/1 ] ` content `{
"name": "lisi",
"age" : "12"
}`
field es web.code.es.es field es web.code.es.es
field install web.code.install
return return
field document web.code.es.document field document web.code.es.document
field install web.code.install