-
Notifications
You must be signed in to change notification settings - Fork 0
/
dashmember.go
78 lines (61 loc) · 1.61 KB
/
dashmember.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
package dashmember
import (
"fmt"
"github.com/504dev/logr/mysql"
"github.com/504dev/logr/types"
)
func findAllByField(fieldname string, val interface{}, limit int) (types.DashMembers, error) {
conn := mysql.Conn()
members := types.DashMembers{}
sqltext := fmt.Sprintf("SELECT id, dash_id, user_id, status FROM dashboard_members WHERE %v = ?", fieldname)
if limit > 0 {
sqltext = fmt.Sprintf("%v LIMIT %v", sqltext, limit)
}
err := conn.Select(&members, sqltext, val)
if err != nil {
return nil, err
}
return members, nil
}
func findOneByField(fieldname string, val interface{}) (*types.DashMember, error) {
members, err := findAllByField(fieldname, val, 1)
if err != nil {
return nil, err
}
if len(members) == 0 {
return nil, nil
}
return members[0], nil
}
func GetById(id int) (*types.DashMember, error) {
return findOneByField("id", id)
}
func GetAllByDashId(id int) (types.DashMembers, error) {
return findAllByField("dash_id", id, 0)
}
func GetAllByUserId(id int) (types.DashMembers, error) {
return findAllByField("user_id", id, 0)
}
func Create(m *types.DashMember) error {
conn := mysql.Conn()
values := []interface{}{m.DashId, m.UserId, types.MemberStatusApproved}
sqltext := "INSERT INTO dashboard_members (dash_id, user_id, status) VALUES (?, ?, ?)"
res, err := conn.Exec(sqltext, values...)
if err != nil {
return err
}
id, err := res.LastInsertId()
if err != nil {
return err
}
m.Id = int(id)
return nil
}
func Remove(id int) error {
conn := mysql.Conn()
_, err := conn.Exec("DELETE FROM dashboard_members WHERE id = ?", id)
if err != nil {
return err
}
return nil
}