/
query.go
58 lines (44 loc) · 1.22 KB
/
query.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
package impl
import (
"github.com/infraboard/keyauth/apps/wxwork"
"github.com/infraboard/mcube/exception"
"go.mongodb.org/mongo-driver/bson"
"go.mongodb.org/mongo-driver/mongo/options"
)
func newDescribeWechatWorkRequest(req *wxwork.DescribeWechatWorkConf) (*describeWechatWorkRequest, error) {
if err := req.Validate(); err != nil {
return nil, exception.NewBadRequest(err.Error())
}
return &describeWechatWorkRequest{req}, nil
}
type describeWechatWorkRequest struct {
*wxwork.DescribeWechatWorkConf
}
func (r *describeWechatWorkRequest) FindFilter() bson.M {
filter := bson.M{}
if r.Domain != "" {
filter["_id"] = r.Domain
}
return filter
}
// newQueryConfigRequest 查询
func newQueryConfigRequest(req *wxwork.QueryConfigRequest) *queryConfigRequest {
return &queryConfigRequest{req}
}
type queryConfigRequest struct {
*wxwork.QueryConfigRequest
}
func (r *queryConfigRequest) FindOptions() *options.FindOptions {
pageSize := int64(r.PageSize)
skip := int64(r.PageSize) * int64(r.PageNumber-1)
opt := &options.FindOptions{
Sort: bson.D{{Key: "create_at", Value: -1}},
Limit: &pageSize,
Skip: &skip,
}
return opt
}
func (r *queryConfigRequest) FindFilter() bson.M {
filter := bson.M{}
return filter
}