package/aqi
1
0
Fork 0
mirror of https://github.com/wonli/aqi.git synced 2025-09-26 20:51:23 +08:00
Code Issues Packages Projects Releases Wiki Activity

*

Browse Source
This commit is contained in:
ideaa
2025-06-17 16:37:46 +08:00
parent 57cb28f47e
commit a56d4ad5b7
2 changed files with 7 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
ws/context_params.go
View File

@@ -46,15 +46,14 @@ func (c *Context) GetPagination() *Pagination {
return InitPagination(p, 100)
}
func (c *Context) GetSizePagination(pageSize int) *Pagination {
func (c *Context) GetMaxPagination(max int) *Pagination {
p := &Page{}
page := gjson.Get(c.Params, "page").String()
if page != "" {
_ = json.Unmarshal([]byte(page), &p)
}
p.PageSize = pageSize
return InitPagination(p, 0)
return InitPagination(p, max)
}
func (c *Context) GetMinInt(key string, min int) int {

12
ws/context_send.go
View File

@@ -45,16 +45,14 @@ func (c *Context) SendMsg(msg string) {
}
// SendAction 发送Action
func (c *Context) SendAction(action *Action) {
m := action.WithId(c.Id)
func (c *Context) SendAction(m *Action) {
c.Response = m
c.Client.SendMsg(m.Encode())
}
// SendActionData 发送数据给当前用户
func (c *Context) SendActionData(action string, data any) {
m := New(action).WithId(c.Id).WithData(data)
m := New(action).WithData(data)
c.Response = m
c.Client.SendMsg(m.Encode())
@@ -62,7 +60,7 @@ func (c *Context) SendActionData(action string, data any) {
// SendActionMsg 发送消息给当前用户
func (c *Context) SendActionMsg(action, msg string) {
m := New(action).WithId(c.Id).WithMsg(msg)
m := New(action).WithMsg(msg)
c.Response = m
c.Client.SendMsg(m.Encode())
@@ -70,9 +68,9 @@ func (c *Context) SendActionMsg(action, msg string) {
// SendTo 发送给指定用户
func (c *Context) SendTo(uid, action string, data any) {
m := New(action).WithId(c.Id).WithData(data)
c.Response = m
m := New(action).WithData(data)
c.Response = m
user := c.Client.Hub.User(uid)
if user != nil {
user.SendMsg(m.Encode())