sqlite的api,便于内部使用
liuxiaolong
2020-02-24 9f410d497dbc50f83b08b4657d3b122679301cd8
logPrint
12个文件已修改
123 ■■■■■ 已修改文件
areaApi.go 3 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
cameraApi.go 21 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
client.go 14 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
dicApi.go 5 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
eventPush.go 5 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
fileAnalysis.go 11 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
fileStack.go 27 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
sdkApi.go 11 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
soApi.go 5 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
syssetApi.go 5 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
taskApi.go 7 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
taskSdkRuleApi.go 9 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
areaApi.go
@@ -2,7 +2,6 @@
import (
    "encoding/json"
    "fmt"
    "strconv"
)
@@ -150,7 +149,7 @@
    }
    var res Result
    if err = json.Unmarshal(respBody, &res); err != nil {
        fmt.Println(err)
        logPrint(err)
        return flag
    }
    flag = res.Success
cameraApi.go
@@ -3,7 +3,6 @@
import (
    "basic.com/pubsub/protomsg.git"
    "encoding/json"
    "fmt"
    "strconv"
)
@@ -68,7 +67,7 @@
    var res Result
    if err = json.Unmarshal(body, &res); err != nil {
        fmt.Println(err)
        logPrint(err)
        return false
    }
@@ -144,7 +143,7 @@
    var res Result
    if err = json.Unmarshal(body, &res); err != nil {
        fmt.Println(err)
        logPrint(err)
        return nil
    }
@@ -185,7 +184,7 @@
    var res Result
    if err = json.Unmarshal(body, &res); err != nil {
        fmt.Println(err)
        logPrint(err)
        return nil
    }
@@ -205,7 +204,7 @@
    var res Result
    if err = json.Unmarshal(body, &res); err != nil {
        fmt.Println(err)
        logPrint(err)
        return false,nil
    }
@@ -279,7 +278,7 @@
    var res Result
    if err = json.Unmarshal(body, &res); err != nil {
        fmt.Println(err)
        logPrint(err)
        return false,nil
    }
@@ -378,7 +377,7 @@
    }
    b, err := json.Marshal(res.Data)
    if err !=nil {
        fmt.Println("unmarshal GetCamerasByRunType.result err")
        logPrint("unmarshal GetCamerasByRunType.result err")
        return false,nil
    }
    if err = json.Unmarshal(b, &cameras);err !=nil {
@@ -401,7 +400,7 @@
    var res Result
    if err = json.Unmarshal(body, &res); err != nil {
        fmt.Println(err)
        logPrint(err)
        return false,nil
    }
@@ -421,7 +420,7 @@
    var res Result
    if err = json.Unmarshal(body, &res); err != nil {
        fmt.Println(err)
        logPrint(err)
        return false,nil
    }
@@ -440,7 +439,7 @@
    var res Result
    if err = json.Unmarshal(body, &res); err != nil {
        fmt.Println(err)
        logPrint(err)
        return false,nil
    }
@@ -458,7 +457,7 @@
    var res Result
    if err = json.Unmarshal(body, &res); err != nil {
        fmt.Println(err)
        logPrint(err)
        return false,nil
    }
client.go
@@ -1,6 +1,9 @@
package dbapi
import "strconv"
import (
    "fmt"
    "strconv"
)
type Client interface {
    //GET
@@ -25,7 +28,16 @@
    CONTENT_TYPE_JSON    = "application/json"
)
var logPrint = func(i ...interface{}) {
    fmt.Println(i)
}
//初始化dbserver的地址和端口
func Init(ip string,port int){
    BASIC_URL = "http://"+ ip + ":" + strconv.Itoa(port)
}
func InitLog(fn func(i ...interface{})) {
    if fn != nil {
        logPrint = fn
    }
}
dicApi.go
@@ -2,7 +2,6 @@
import (
    "encoding/json"
    "fmt"
    "strconv"
)
@@ -35,7 +34,7 @@
    }
    var res Result
    if err = json.Unmarshal(respBody, &res); err != nil {
        fmt.Println(err)
        logPrint(err)
        return false,nil
    }
    return res.Success,res.Data
@@ -52,7 +51,7 @@
    }
    var res Result
    if err = json.Unmarshal(respBody, &res); err != nil {
        fmt.Println(err)
        logPrint(err)
        return false,nil
    }
    return res.Success,res.Data
eventPush.go
@@ -3,7 +3,6 @@
import (
    "basic.com/pubsub/protomsg.git"
    "encoding/json"
    "fmt"
    "strconv"
)
@@ -35,7 +34,7 @@
    var res Result
    if err = json.Unmarshal(body, &res); err != nil {
        fmt.Println(err)
        logPrint(err)
        return false,nil
    }
@@ -92,7 +91,7 @@
    bytes, _ := json.Marshal(res.Data)
    err = json.Unmarshal(bytes, &allRules)
    if err !=nil{
        fmt.Println("all eventPushRules unmarshal err:",err)
        logPrint("all eventPushRules unmarshal err:",err)
        return false,nil
    }
    return true,allRules
fileAnalysis.go
@@ -3,7 +3,6 @@
import (
    "basic.com/pubsub/protomsg.git"
    "encoding/json"
    "fmt"
    "strconv"
)
@@ -133,7 +132,7 @@
    var res Result
    if err = json.Unmarshal(body, &res); err != nil {
        fmt.Println(err)
        logPrint(err)
        return false
    }
@@ -153,7 +152,7 @@
    var res Result
    if err = json.Unmarshal(body, &res); err != nil {
        fmt.Println(err)
        logPrint(err)
        return false
    }
@@ -174,7 +173,7 @@
    var res Result
    if err = json.Unmarshal(body, &res); err != nil {
        fmt.Println(err)
        logPrint(err)
        return false
    }
@@ -194,7 +193,7 @@
    var res Result
    if err = json.Unmarshal(body, &res); err != nil {
        fmt.Println(err)
        logPrint(err)
        return false
    }
@@ -215,7 +214,7 @@
    var res Result
    if err = json.Unmarshal(body, &res); err != nil {
        fmt.Println(err)
        logPrint(err)
        return false
    }
fileStack.go
@@ -1,6 +1,7 @@
package dbapi
import (
    "basic.com/pubsub/protomsg.git"
    "encoding/json"
    "strconv"
)
@@ -77,6 +78,32 @@
    return res.Success, res.Data
}
func (api FileStackApi) FindAll() (flag bool,stacks []protomsg.FileStack){
    url := api.getBasicUrl() + DATA_URL_PREFIX + "/fileStack/findAll"
    client := NewClient()
    body, err := client.DoGetRequest(url, nil, nil)
    if err != nil {
        return false, nil
    }
    var res Result
    if err = json.Unmarshal(body, &res); err != nil {
        return false, nil
    }
    b, err := json.Marshal(res.Data)
    if err !=nil {
        logPrint("unmarshal GetCamerasByRunType.result err")
        return false,nil
    }
    if err = json.Unmarshal(b, &stacks);err !=nil {
        return false,nil
    } else {
        return true,stacks
    }
}
func (api FileStackApi) ChangeEnable(id string,enable bool) bool {
    url := api.getBasicUrl() + DATA_URL_PREFIX + "/fileStack/changeEnable"
    client := NewClient()
sdkApi.go
@@ -3,7 +3,6 @@
import (
    "basic.com/pubsub/protomsg.git"
    "encoding/json"
    "fmt"
    "strconv"
)
@@ -36,7 +35,7 @@
    }
    var res Result
    if err = json.Unmarshal(respBody, &res); err != nil {
        fmt.Println(err)
        logPrint(err)
        return flag,nil
    }
    return res.Success,res.Data
@@ -55,7 +54,7 @@
    }
    var res Result
    if err = json.Unmarshal(respBody, &res); err != nil {
        fmt.Println(err)
        logPrint(err)
        return sdkArr
    }
    bytes, _ := json.Marshal(res.Data)
@@ -113,7 +112,7 @@
    }
    var res Result
    if err = json.Unmarshal(respBody, &res); err != nil {
        fmt.Println(err)
        logPrint(err)
        return false,nil
    }
    return res.Success,res.Data
@@ -130,7 +129,7 @@
    }
    var res Result
    if err = json.Unmarshal(respBody, &res); err != nil {
        fmt.Println(err)
        logPrint(err)
        return false,nil
    }
    bytes, _ := json.Marshal(res.Data)
@@ -150,7 +149,7 @@
    }
    var res Result
    if err = json.Unmarshal(respBody, &res); err != nil {
        fmt.Println(err)
        logPrint(err)
        return false,nil
    }
    bytes, _ := json.Marshal(res.Data)
soApi.go
@@ -3,7 +3,6 @@
import (
    "basic.com/pubsub/protomsg.git"
    "encoding/json"
    "fmt"
    "strconv"
)
@@ -36,7 +35,7 @@
    }
    var res Result
    if err = json.Unmarshal(respBody, &res); err != nil {
        fmt.Println(err)
        logPrint(err)
        return soInfos
    }
    bytes, _ := json.Marshal(res.Data)
@@ -53,7 +52,7 @@
    }
    var res Result
    if err = json.Unmarshal(respBody, &res); err != nil {
        fmt.Println(err)
        logPrint(err)
        return false,nil
    }
    return res.Success,res.Data
syssetApi.go
@@ -3,7 +3,6 @@
import (
    "basic.com/pubsub/protomsg.git"
    "encoding/json"
    "fmt"
    "strconv"
)
@@ -64,7 +63,7 @@
    var res Result
    if err = json.Unmarshal(body, &res); err != nil {
        fmt.Println(err)
        logPrint(err)
        return false,nil
    }
@@ -83,7 +82,7 @@
    var res Result
    if err = json.Unmarshal(body, &res); err != nil {
        fmt.Println(err)
        logPrint(err)
        return false,nil
    }
taskApi.go
@@ -3,7 +3,6 @@
import (
    "basic.com/pubsub/protomsg.git"
    "encoding/json"
    "fmt"
    "strconv"
)
@@ -36,7 +35,7 @@
    }
    var res Result
    if err = json.Unmarshal(respBody, &res); err != nil {
        fmt.Println(err)
        logPrint(err)
        return taskInfos
    }
    bytes, _ := json.Marshal(res.Data)
@@ -56,7 +55,7 @@
    }
    var res Result
    if err = json.Unmarshal(respBody, &res); err != nil {
        fmt.Println(err)
        logPrint(err)
        return taskInfos
    }
    bytes, _ := json.Marshal(res.Data)
@@ -100,7 +99,7 @@
    }
    var res Result
    if err = json.Unmarshal(respBody, &res); err != nil {
        fmt.Println(err)
        logPrint(err)
        return false,nil
    }
    return res.Success,res.Data
taskSdkRuleApi.go
@@ -3,7 +3,6 @@
import (
    "basic.com/pubsub/protomsg.git"
    "encoding/json"
    "fmt"
    "strconv"
)
@@ -35,7 +34,7 @@
    var res Result
    if err = json.Unmarshal(body, &res); err != nil {
        fmt.Println(err)
        logPrint(err)
        return false,nil
    }
    bytes, _ := json.Marshal(res.Data)
@@ -59,7 +58,7 @@
    var res Result
    if err = json.Unmarshal(body, &res); err != nil {
        fmt.Println(err)
        logPrint(err)
        return false,err
    }
    return res.Success,res.Data
@@ -79,7 +78,7 @@
    var res Result
    if err = json.Unmarshal(body, &res); err != nil {
        fmt.Println(err)
        logPrint(err)
        return false
    }
@@ -96,7 +95,7 @@
    var res Result
    if err = json.Unmarshal(body, &res); err != nil {
        fmt.Println(err)
        logPrint(err)
        return false,nil
    }