company.go
2.3 KB
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
package models
import (
"fmt"
"time"
"github.com/astaxie/beego/orm"
)
type Company struct {
Id int64 `orm:"column(id);auto"`
Name string `orm:"column(name);size(40)"`
UserId int64 `orm:"column(user_id)"`
CreateAt time.Time `orm:"column(create_at);type(timestamp);auto_now"`
UpdateAt time.Time `orm:"column(update_at);type(timestamp)"`
DeleteAt time.Time `orm:"column(delete_at);type(timestamp)"`
Logo string `orm:"column(logo);size(255)"`
Enable int8 `orm:"column(enable)"`
}
func (t *Company) TableName() string {
return "company"
}
//公司是否有效
const (
COMPANY_ENABLE_YES int8 = 1 //有效
COMPANY_ENABLE_NO int8 = 2 //无效
)
func (t *Company) IsEnable() bool {
switch t.Enable {
case COMPANY_ENABLE_YES:
return true
case COMPANY_ENABLE_NO:
return false
}
return false
}
func (t *Company) ValidateEnable(v int8) bool {
switch v {
case COMPANY_ENABLE_YES:
return true
case COMPANY_ENABLE_NO:
return true
}
return false
}
func init() {
orm.RegisterModel(new(Company))
}
// AddCompany insert a new Company into database and returns
// last inserted Id on success.
func AddCompany(m *Company) (id int64, err error) {
o := orm.NewOrm()
id, err = o.Insert(m)
return
}
// GetCompanyById retrieves Company by Id. Returns error if
// Id doesn't exist
func GetCompanyById(id int64) (v *Company, err error) {
o := orm.NewOrm()
v = &Company{Id: id}
if err = o.Read(v); err == nil {
return v, nil
}
return nil, err
}
// UpdateCompany updates Company by Id and returns error if
// the record to be updated doesn't exist
func UpdateCompanyById(m *Company) (err error) {
o := orm.NewOrm()
v := Company{Id: m.Id}
// ascertain id exists in the database
if err = o.Read(&v); err == nil {
var num int64
if num, err = o.Update(m); err == nil {
fmt.Println("Number of records updated in database:", num)
}
}
return
}
func GetCompanyByUser(userid int64) ([]Company, error) {
datasql := `SELECT a.user_id, a.id,a.name,a.logo,a.admin_id FROM company AS a
JOIN user_company AS b ON a.id = b.company_id
WHERE a.enable = 1 AND b.user_id=?`
var (
err error
companys []Company
)
o := orm.NewOrm()
_, err = o.Raw(datasql).QueryRows(&companys)
if err == orm.ErrNoRows {
return companys, nil
}
return companys, err
}