-
Notifications
You must be signed in to change notification settings - Fork 99
/
Copy pathprobing.go
106 lines (85 loc) · 2.24 KB
/
probing.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
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
package api
import (
"github.com/gin-gonic/gin"
middleware "watchAlert/internal/middleware"
"watchAlert/internal/models"
"watchAlert/internal/services"
)
type ProbingController struct{}
func (e ProbingController) API(gin *gin.RouterGroup) {
eventA := gin.Group("probing")
eventA.Use(
middleware.Auth(),
middleware.Permission(),
middleware.ParseTenant(),
middleware.AuditingLog(),
)
{
eventA.POST("createProbing", e.Create)
eventA.POST("updateProbing", e.Update)
eventA.POST("deleteProbing", e.Delete)
eventA.POST("onceProbing", e.Once)
}
eventB := gin.Group("probing")
eventB.Use(
middleware.Auth(),
middleware.Permission(),
middleware.ParseTenant(),
)
{
eventB.GET("listProbing", e.List)
eventB.GET("searchProbing", e.Search)
}
}
func (e ProbingController) List(ctx *gin.Context) {
r := new(models.ProbingRuleQuery)
BindQuery(ctx, r)
tid, _ := ctx.Get("TenantID")
r.TenantId = tid.(string)
Service(ctx, func() (interface{}, interface{}) {
return services.ProbingService.List(r)
})
}
func (e ProbingController) Search(ctx *gin.Context) {
r := new(models.ProbingRuleQuery)
BindQuery(ctx, r)
tid, _ := ctx.Get("TenantID")
r.TenantId = tid.(string)
Service(ctx, func() (interface{}, interface{}) {
return services.ProbingService.Search(r)
})
}
func (e ProbingController) Create(ctx *gin.Context) {
r := new(models.ProbingRule)
BindJson(ctx, r)
tid, _ := ctx.Get("TenantID")
r.TenantId = tid.(string)
Service(ctx, func() (interface{}, interface{}) {
return services.ProbingService.Create(r)
})
}
func (e ProbingController) Update(ctx *gin.Context) {
r := new(models.ProbingRule)
BindJson(ctx, r)
tid, _ := ctx.Get("TenantID")
r.TenantId = tid.(string)
Service(ctx, func() (interface{}, interface{}) {
return services.ProbingService.Update(r)
})
}
func (e ProbingController) Delete(ctx *gin.Context) {
r := new(models.ProbingRuleQuery)
BindJson(ctx, r)
tid, _ := ctx.Get("TenantID")
r.TenantId = tid.(string)
Service(ctx, func() (interface{}, interface{}) {
return services.ProbingService.Delete(r)
})
}
func (e ProbingController) Once(ctx *gin.Context) {
r := new(models.OnceProbing)
BindJson(ctx, r)
Service(ctx, func() (interface{}, interface{}) {
return services.ProbingService.Once(r)
})
}