sqlite的api,便于内部使用
liuxiaolong
2021-06-09 0eeae77a0af3a9ca114408cac9667dc7bf8193fd
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
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
package dbapi
 
import (
    "basic.com/pubsub/protomsg.git"
    "encoding/json"
    "strconv"
)
 
type CameraPolygonRelationApi struct{
    Ip string
    Port int
}
 
func (api CameraPolygonRelationApi) getBasicUrl() string {
    if api.Ip == "" {
        return BASIC_URL
    }
    if api.Ip == "" {
        api.Ip = DEFAULT_IP
    }
    if api.Port == 0 {
        api.Port = DEFAULT_PORT
    }
    return "http://"+api.Ip+":"+strconv.Itoa(api.Port)
}
 
func (api CameraPolygonRelationApi) FindPolygonByGroup(groupId string) (bool,interface{}) {
    url := api.getBasicUrl() + DATA_URL_PREFIX + "/polygon/findByCamGroup"
    client := NewClient()
 
    paramQuery := map[string]string {
        "groupId": groupId,
    }
    body, err := client.DoGetRequest(url, paramQuery, nil)
    if err != nil {
        return false, nil
    }
 
    var res Result
    if err = json.Unmarshal(body, &res); err != nil {
        return false,nil
    }
    return res.Success, res.Data
}
 
func (api CameraPolygonRelationApi) FindAll() (flag bool,list []protomsg.CameraPolygonRelation) {
    url := api.getBasicUrl() + DATA_URL_PREFIX + "/polygon/relation/findAll"
    client := NewClient()
 
    body, err := client.DoGetRequest(url, nil, nil)
    if err != nil {
        logPrint("polygon relation findAll err:", err)
        return false, nil
    }
 
    var res Result
    if err = json.Unmarshal(body, &res); err != nil {
        logPrint("relations unmarshal err:", err)
        return false,nil
    }
 
    bts, _ := json.Marshal(res.Data)
    err = json.Unmarshal(bts, &list)
    if err != nil {
        return false, nil
    }
 
    return true, list
}
 
func (api CameraPolygonRelationApi) Relations(paramBody map[string]interface{}) (bool,interface{}) {
    url := api.getBasicUrl() + DATA_URL_PREFIX + "/polygon/relations"
    client := NewClient()
    body, err := client.DoPostRequest(url,CONTENT_TYPE_JSON,paramBody,nil,nil)
    if err != nil {
        return false,nil
    }
 
    var res Result
    if err = json.Unmarshal(body, &res); err != nil {
        return false,nil
    }
    return res.Success, res.Data
}
 
func (api CameraPolygonRelationApi) FindRelationByGroup(groupId string) (bool,interface{}) {
    url := api.getBasicUrl() + DATA_URL_PREFIX + "/polygon/relation/findByGroup"
    client := NewClient()
    paramQuery := map[string]string {
        "groupId": groupId,
    }
    body, err := client.DoGetRequest(url,paramQuery,nil)
    if err != nil {
        return false,nil
    }
 
    var res Result
    if err = json.Unmarshal(body, &res); err != nil {
        return false,nil
    }
    return res.Success, res.Data
}
 
func (api CameraPolygonRelationApi) SaveRelation(paramBody map[string]interface{}) (bool,interface{}) {
    url := api.getBasicUrl() + DATA_URL_PREFIX + "/polygon/relation/save"
    client := NewClient()
    body, err := client.DoPostRequest(url,CONTENT_TYPE_JSON,paramBody,nil,nil)
    if err != nil {
        return false,nil
    }
 
    var res Result
    if err = json.Unmarshal(body, &res); err != nil {
        return false,nil
    }
    return res.Success,res.Data
}
 
func (api CameraPolygonRelationApi) DelRelation(id string) bool {
    url := api.getBasicUrl() + DATA_URL_PREFIX + "/polygon/relation/del"
    client := NewClient()
    paramMap := make(map[string]string,0)
    paramMap["id"] = id
    body, err := client.DoPostRequest(url,CONTENT_TYPE_FORM,nil,paramMap, nil)
    if err != nil {
        return false
    }
 
    var res Result
    if err = json.Unmarshal(body, &res); err != nil {
        return false
    }
    return res.Success
}