open
/
gosdk
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

table

This commit is contained in:
jiangyong 2026-05-02 09:19:43 +08:00
parent 2b8eaeedc1
commit 17110618a8
1 changed files with 30 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
unify/message.go
View File

@ -6,6 +6,7 @@ import (
"net/url" "net/url"
"git.u8t.cn/open/gosdk/util" "git.u8t.cn/open/gosdk/util"
"git.u8t.cn/open/goutil"
) )
type Message struct { type Message struct {
@ -26,6 +27,10 @@ func NewMessage(addreess string, token string, sender string) *Message {
} }
func (m *Message) Send(args ...string) error { func (m *Message) Send(args ...string) error {
return m.SendText(args...)
}
func (m *Message) SendText(args ...string) error {
var receiver, content, fingerprint, level, count string var receiver, content, fingerprint, level, count string
if len(args) == 2 { if len(args) == 2 {
receiver, content = args[0], args[1] receiver, content = args[0], args[1]
@ -36,7 +41,7 @@ func (m *Message) Send(args ...string) error {
} else if len(args) > 4 { } else if len(args) > 4 {
receiver, content, fingerprint, level, count = args[0], args[1], args[2], args[3], args[4] receiver, content, fingerprint, level, count = args[0], args[1], args[2], args[3], args[4]
} }
reqUrl := fmt.Sprintf("%s/admin/message/send?sender=%s&receiver=%s&fingerprint=%s&count=%s&level=%s&content=%s", m.address, m.sender, receiver, fingerprint, count, level, url.QueryEscape(content)) reqUrl := fmt.Sprintf("%s/admin/message/send?sender=%s&receiver=%s&type=text&fingerprint=%s&count=%s&level=%s&content=%s", m.address, m.sender, receiver, fingerprint, count, level, url.QueryEscape(content))
body, err := util.HttpGet(reqUrl, map[string]string{ body, err := util.HttpGet(reqUrl, map[string]string{
"x-token": m.token, "x-token": m.token,
}) })
@ -52,3 +57,27 @@ func (m *Message) Send(args ...string) error {
} }
return nil return nil
} }
func (m *Message) SendTable(receiver string, table *goutil.TableData) error {
content := goutil.EncodeJSON(table)
reqUrl := fmt.Sprintf("%s/admin/message/send", m.address)
reqData := make(map[string]interface{})
reqData["type"] = "table"
reqData["content"] = content
reqData["receiver"] = receiver
reqData["sender"] = m.sender
body, err := util.HttpPostJson(reqUrl, map[string]string{"x-token": m.token},
[]byte(goutil.EncodeJSON(reqData)))
if err != nil {
return err
}
var rsp util.Response
if err := json.Unmarshal(body, &rsp); err != nil {
return err
}
if rsp.Code != 0 {
return fmt.Errorf("%d:%s", rsp.Code, rsp.Message)
}
return nil
}