From 01dfd9dc8de7b19f9dfa4284722e01bbd5837801 Mon Sep 17 00:00:00 2001 From: zhangmeng <775834166@qq.com> Date: 星期五, 19 一月 2024 09:10:30 +0800 Subject: [PATCH] replace json to json-iterator --- gb28181Api.go | 220 ++++++++++++++++++++++++++++++------------------------ 1 files changed, 121 insertions(+), 99 deletions(-) diff --git a/gb28181Api.go b/gb28181Api.go index 5d4ea58..c43052f 100644 --- a/gb28181Api.go +++ b/gb28181Api.go @@ -2,30 +2,31 @@ import ( "basic.com/pubsub/protomsg.git" - json "github.com/json-iterator/go" + jsoniter "github.com/json-iterator/go" "strconv" ) -type Gb28181Api struct{ - +type Gb28181Api struct { } //鍥芥爣閰嶇疆鏄剧ず -func (api Gb28181Api) Show() (flag bool,gbConfig protomsg.Gb28181Config) { +func (api Gb28181Api) Show() (flag bool, gbConfig protomsg.Gb28181Config) { netNode := getNetNode(Topic_Gb28181_Service) url := DATA_URL_PREFIX + "/gb28181/configShow" client := NewClient(WithNodes(netNode)) respBody, err := client.DoGetRequest(url, nil, nil) - if err !=nil { - return false,gbConfig + if err != nil { + return false, gbConfig } var res Result + var json = jsoniter.ConfigCompatibleWithStandardLibrary if err = json.Unmarshal(respBody, &res); err != nil { - return false,gbConfig + return false, gbConfig } if res.Success { - if bts,err := json.Marshal(res.Data);err ==nil { - if err = json.Unmarshal(bts, &gbConfig);err ==nil { + if bts, err := json.Marshal(res.Data); err == nil { + var json = jsoniter.ConfigCompatibleWithStandardLibrary + if err = json.Unmarshal(bts, &gbConfig); err == nil { return true, gbConfig } } @@ -43,42 +44,45 @@ return flag } var res Result + var json = jsoniter.ConfigCompatibleWithStandardLibrary if err = json.Unmarshal(respBody, &res); err != nil { return flag } return res.Success } -func (api Gb28181Api) FindAreaByParentId(parentId string) (bool,interface{}) { +func (api Gb28181Api) FindAreaByParentId(parentId string) (bool, interface{}) { url := DATA_URL_PREFIX + "/gb28181/findAreaByParentId" - netNode := getNetNode(url2Topic(Topic_Gb28181_Service,url)) + netNode := getNetNode(url2Topic(Topic_Gb28181_Service, url)) client := NewClient(WithNodes(netNode)) paramMap := make(map[string]string, 0) paramMap["parentId"] = parentId respBody, err := client.DoGetRequest(url, paramMap, nil) - if err !=nil { - return false,nil + if err != nil { + return false, nil } var res Result + var json = jsoniter.ConfigCompatibleWithStandardLibrary if err = json.Unmarshal(respBody, &res); err != nil { - return false,nil + return false, nil } return res.Success, res.Data } -func (api Gb28181Api) NewGbId(code string) (bool,interface{}) { +func (api Gb28181Api) NewGbId(code string) (bool, interface{}) { url := DATA_URL_PREFIX + "/gb28181/newGbId" - netNode := getNetNode(url2Topic(Topic_Gb28181_Service,url)) + netNode := getNetNode(url2Topic(Topic_Gb28181_Service, url)) client := NewClient(WithNodes(netNode)) paramMap := make(map[string]string, 0) paramMap["code"] = code respBody, err := client.DoGetRequest(url, paramMap, nil) - if err !=nil { - return false,nil + if err != nil { + return false, nil } var res Result + var json = jsoniter.ConfigCompatibleWithStandardLibrary if err = json.Unmarshal(respBody, &res); err != nil { - return false,nil + return false, nil } return res.Success, res.Data } @@ -88,7 +92,7 @@ //cameraName锛堟憚鍍忔満鍚嶇О锛� func (api Gb28181Api) GetGb28181CameraTree(parentId string, searchType string, cameraName string) []TreeMenu { url := DATA_URL_PREFIX + "/gb28181/tree" - netNode := getNetNode(url2Topic(Topic_Gb28181_Service,url)) + netNode := getNetNode(url2Topic(Topic_Gb28181_Service, url)) var result []TreeMenu client := NewClient(WithNodes(netNode)) @@ -104,12 +108,13 @@ } var res Result + var json = jsoniter.ConfigCompatibleWithStandardLibrary if err = json.Unmarshal(respBody, &res); err != nil { return nil } bytes, _ := json.Marshal(res.Data) - if err = json.Unmarshal(bytes, &result);err !=nil{ + if err = json.Unmarshal(bytes, &result); err != nil { return nil } return result @@ -122,13 +127,14 @@ flag := false client := NewClient(WithNodes(netNode)) paramBody := map[string]interface{}{ - "id":id, + "id": id, } respBody, err := client.DoPostRequest(url, CONTENT_TYPE_FORM, paramBody, nil, nil) if err != nil { return flag } var res Result + var json = jsoniter.ConfigCompatibleWithStandardLibrary if err = json.Unmarshal(respBody, &res); err != nil { return flag } @@ -147,6 +153,7 @@ return flag } var res Result + var json = jsoniter.ConfigCompatibleWithStandardLibrary if err = json.Unmarshal(respBody, &res); err != nil { return flag } @@ -155,27 +162,28 @@ } //鑾峰彇鏈妭鐐圭殑鎵�鏈夊浗鏍囨憚鍍忔満 -func (api Gb28181Api) GetAllCamerasByServer(serverId string,cameraName string) (b bool,cams []protomsg.Camera) { +func (api Gb28181Api) GetAllCamerasByServer(serverId string, cameraName string) (b bool, cams []protomsg.Camera) { url := DATA_URL_PREFIX + "/gb28181/getAllCamerasByServer" - netNode := getNetNode(url2Topic(Topic_Gb28181_Service,url)) + netNode := getNetNode(url2Topic(Topic_Gb28181_Service, url)) client := NewClient(WithNodes(netNode)) - paramQuery := make(map[string]string,0) + paramQuery := make(map[string]string, 0) paramQuery["serverId"] = serverId paramQuery["cameraName"] = cameraName body, err := client.DoGetRequest(url, paramQuery, nil) if err != nil { - return false,nil + return false, nil } var res Result + var json = jsoniter.ConfigCompatibleWithStandardLibrary if err = json.Unmarshal(body, &res); err != nil { - return false,nil + return false, nil } dataBytes, _ := json.Marshal(res.Data) - if err := json.Unmarshal(dataBytes, &cams);err !=nil { - return false,nil + if err := json.Unmarshal(dataBytes, &cams); err != nil { + return false, nil } - return res.Success,cams + return res.Success, cams } //鏌ユ壘鍦板浘涓婄殑鍥芥爣鎽勫儚鏈� @@ -183,29 +191,30 @@ url := DATA_URL_PREFIX + "/gb28181/camera/findOnMap" netNode := getNetNode(url2Topic(Topic_Gb28181_Service, url)) client := NewClient(WithNodes(netNode)) - paramBody:= map[string]interface{}{ + paramBody := map[string]interface{}{ "isOnMap": isOnMap, "floor": floor, "cameraName": cameraName, } - body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, paramBody,nil,nil) + body, err := client.DoPostRequest(url, CONTENT_TYPE_JSON, paramBody, nil, nil) if err != nil { - return false,nil + return false, nil } var res Result + var json = jsoniter.ConfigCompatibleWithStandardLibrary if err = json.Unmarshal(body, &res); err != nil { logPrint(err) - return false,nil + return false, nil } if res.Success { - if bts, e := json.Marshal(res.Data);e == nil { - if e = json.Unmarshal(bts, &cams);e ==nil { + if bts, e := json.Marshal(res.Data); e == nil { + if e = json.Unmarshal(bts, &cams); e == nil { return true, cams } } } - return false,nil + return false, nil } //鏇存柊鎽勫儚鏈虹粡绾害浠ュ強妤煎眰 @@ -213,18 +222,19 @@ url := DATA_URL_PREFIX + "/gb28181/camera/updatePos" netNode := getNetNode(url2Topic(Topic_Gb28181_Service, url)) client := NewClient(WithNodes(netNode)) - paramBody:= map[string]interface{}{ - "id": id, - "floor": floor, + paramBody := map[string]interface{}{ + "id": id, + "floor": floor, "longitude": longitude, - "latitude": latitude, + "latitude": latitude, } - body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, paramBody,nil,nil) + body, err := client.DoPostRequest(url, CONTENT_TYPE_JSON, paramBody, nil, nil) if err != nil { return false } var res Result + var json = jsoniter.ConfigCompatibleWithStandardLibrary if err = json.Unmarshal(body, &res); err != nil { logPrint(err) return false @@ -240,12 +250,13 @@ client := NewClient(WithNodes(netNode)) body, err := client.DoGetRequest(url, nil, nil) if err != nil { - return false,nil + return false, nil } var res Result + var json = jsoniter.ConfigCompatibleWithStandardLibrary if err = json.Unmarshal(body, &res); err != nil { - return false,nil + return false, nil } return res.Success, res.Data } @@ -255,17 +266,18 @@ url := DATA_URL_PREFIX + "/gb28181/camera/coord" netNode := getNetNode(url2Topic(Topic_Gb28181_Service, url)) client := NewClient(WithNodes(netNode)) - paramQuery := map[string]string { + paramQuery := map[string]string{ "cameraId": cameraId, } body, err := client.DoGetRequest(url, paramQuery, nil) if err != nil { - return false,nil + return false, nil } var res Result + var json = jsoniter.ConfigCompatibleWithStandardLibrary if err = json.Unmarshal(body, &res); err != nil { - return false,nil + return false, nil } return res.Success, res.Data } @@ -275,12 +287,13 @@ url := DATA_URL_PREFIX + "/gb28181/camera/updateCoord" netNode := getNetNode(url2Topic(Topic_Gb28181_Service, url)) client := NewClient(WithNodes(netNode)) - body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, paramBody,nil,nil) + body, err := client.DoPostRequest(url, CONTENT_TYPE_JSON, paramBody, nil, nil) if err != nil { return false } var res Result + var json = jsoniter.ConfigCompatibleWithStandardLibrary if err = json.Unmarshal(body, &res); err != nil { logPrint(err) return false @@ -289,18 +302,17 @@ return res.Success } - - func (api Gb28181Api) CameraUpdate(paramBody map[string]interface{}) bool { url := DATA_URL_PREFIX + "/gb28181/camera/update" netNode := getNetNode(url2Topic(Topic_Gb28181_Service, url)) client := NewClient(WithNodes(netNode)) - body, err := client.DoPutRequest(url,CONTENT_TYPE_JSON,paramBody,nil) + body, err := client.DoPutRequest(url, CONTENT_TYPE_JSON, paramBody, nil) if err != nil { return false } var res Result + var json = jsoniter.ConfigCompatibleWithStandardLibrary if err = json.Unmarshal(body, &res); err != nil { return false } @@ -311,15 +323,16 @@ url := DATA_URL_PREFIX + "/gb28181/camera/updateSnapshot" netNode := getNetNode(url2Topic(Topic_Gb28181_Service, url)) client := NewClient(WithNodes(netNode)) - paramBody :=make(map[string]interface{},0) + paramBody := make(map[string]interface{}, 0) paramBody["snapshot"] = snapshot paramBody["cameraId"] = cameraId - body,err := client.DoPostRequest(url,CONTENT_TYPE_FORM, paramBody,nil,nil) + body, err := client.DoPostRequest(url, CONTENT_TYPE_FORM, paramBody, nil, nil) if err != nil { return false } var res Result + var json = jsoniter.ConfigCompatibleWithStandardLibrary if err = json.Unmarshal(body, &res); err != nil { logPrint(err) return false @@ -333,7 +346,7 @@ url := DATA_URL_PREFIX + "/gb28181/camera/show" netNode := getNetNode(url2Topic(Topic_Gb28181_Service, url)) client := NewClient(WithNodes(netNode)) - paramQuery := map[string]string { + paramQuery := map[string]string{ "cid": cameraId, } body, err := client.DoGetRequest(url, paramQuery, nil) @@ -342,8 +355,9 @@ } var res Result + var json = jsoniter.ConfigCompatibleWithStandardLibrary if err = json.Unmarshal(body, &res); err != nil { - return camera,err + return camera, err } bytes, _ := json.Marshal(res.Data) @@ -356,17 +370,18 @@ url := DATA_URL_PREFIX + "/gb28181/camera/updateCameraArea" netNode := getNetNode(url2Topic(Topic_Gb28181_Service, url)) client := NewClient(WithNodes(netNode)) - paramBody := map[string]interface{} { + paramBody := map[string]interface{}{ "cameraId": cameraId, - "areaId": areaId, + "areaId": areaId, } - body, err := client.DoPostRequest(url, CONTENT_TYPE_FORM, paramBody, nil,nil) - if err !=nil { + body, err := client.DoPostRequest(url, CONTENT_TYPE_FORM, paramBody, nil, nil) + if err != nil { return false } var res Result - if err = json.Unmarshal(body, &res);err != nil { + var json = jsoniter.ConfigCompatibleWithStandardLibrary + if err = json.Unmarshal(body, &res); err != nil { return false } @@ -377,11 +392,11 @@ url := DATA_URL_PREFIX + "/gb28181/camera/showAll" netNode := getNetNode(url2Topic(Topic_Gb28181_Service, url)) client := NewClient(WithNodes(netNode)) - paramQuery := map[string]string { + paramQuery := map[string]string{ "cameraName": cameraName, - "runType": runType, - "cameraId": cameraId, - "areaId": areaId, + "runType": runType, + "cameraId": cameraId, + "areaId": areaId, } body, err := client.DoGetRequest(url, paramQuery, nil) @@ -390,6 +405,7 @@ } var res Result + var json = jsoniter.ConfigCompatibleWithStandardLibrary if err = json.Unmarshal(body, &res); err != nil { logPrint(err) return nil @@ -403,129 +419,135 @@ //鏍规嵁杩愯绫诲瀷鑾峰彇鎽勫儚鏈哄垪琛� //runType(0:鑾峰彇杞鍒楄〃锛�1锛氳幏鍙栧疄鏃跺垪琛�) -func (api Gb28181Api) GetCamerasByRunType(runType int,cameraName string)(flag bool,cameras []protomsg.Camera){ +func (api Gb28181Api) GetCamerasByRunType(runType int, cameraName string) (flag bool, cameras []protomsg.Camera) { url := DATA_URL_PREFIX + "/gb28181/camera/getCamerasByRunType" netNode := getNetNode(url2Topic(Topic_Gb28181_Service, url)) client := NewClient(WithNodes(netNode)) - paramQuery := make(map[string]string,2) - paramQuery["runType"]=strconv.Itoa(runType) + paramQuery := make(map[string]string, 2) + paramQuery["runType"] = strconv.Itoa(runType) paramQuery["cameraName"] = cameraName body, err := client.DoGetRequest(url, paramQuery, nil) if err != nil { - return false,nil + return false, nil } var res Result + var json = jsoniter.ConfigCompatibleWithStandardLibrary if err = json.Unmarshal(body, &res); err != nil { - return false,nil + return false, nil } b, err := json.Marshal(res.Data) - if err !=nil { + if err != nil { logPrint("unmarshal GetCamerasByRunType.result err") - return false,nil + return false, nil } - if err = json.Unmarshal(b, &cameras);err !=nil { - return false,nil + if err = json.Unmarshal(b, &cameras); err != nil { + return false, nil } else { - return true,cameras + return true, cameras } } -func (api Gb28181Api) UpdateRunEnable(cameraId string,runEnable bool) (bool,interface{}){ +func (api Gb28181Api) UpdateRunEnable(cameraId string, runEnable bool) (bool, interface{}) { url := DATA_URL_PREFIX + "/gb28181/camera/updateRunEnable" netNode := getNetNode(url2Topic(Topic_Gb28181_Service, url)) client := NewClient(WithNodes(netNode)) - paramBody :=make(map[string]interface{},0) + paramBody := make(map[string]interface{}, 0) paramBody["cameraId"] = cameraId paramBody["runEnable"] = runEnable - body,err := client.DoPostRequest(url,CONTENT_TYPE_FORM, paramBody,nil,nil) + body, err := client.DoPostRequest(url, CONTENT_TYPE_FORM, paramBody, nil, nil) if err != nil { - return false,nil + return false, nil } var res Result + var json = jsoniter.ConfigCompatibleWithStandardLibrary if err = json.Unmarshal(body, &res); err != nil { logPrint(err) - return false,nil + return false, nil } - return res.Success,res.Data + return res.Success, res.Data } -func (api Gb28181Api) UpdateIsRunningState(cameraId string,isRunning bool) (bool,interface{}){ +func (api Gb28181Api) UpdateIsRunningState(cameraId string, isRunning bool) (bool, interface{}) { url := DATA_URL_PREFIX + "/gb28181/camera/updateIsRunningState" netNode := getNetNode(url2Topic(Topic_Gb28181_Service, url)) client := NewClient(WithNodes(netNode)) - paramBody :=make(map[string]interface{},0) + paramBody := make(map[string]interface{}, 0) paramBody["cameraId"] = cameraId paramBody["isRunning"] = isRunning - body,err := client.DoPostRequest(url,CONTENT_TYPE_FORM, paramBody,nil,nil) + body, err := client.DoPostRequest(url, CONTENT_TYPE_FORM, paramBody, nil, nil) if err != nil { - return false,nil + return false, nil } var res Result + var json = jsoniter.ConfigCompatibleWithStandardLibrary if err = json.Unmarshal(body, &res); err != nil { logPrint(err) - return false,nil + return false, nil } - return res.Success,res.Data + return res.Success, res.Data } -func (api Gb28181Api) UpdateIsRunningAll(cameraIds []string) (bool,interface{}){ +func (api Gb28181Api) UpdateIsRunningAll(cameraIds []string) (bool, interface{}) { url := DATA_URL_PREFIX + "/gb28181/camera/updateIsRunningAll" netNode := getNetNode(url2Topic(Topic_Gb28181_Service, url)) client := NewClient(WithNodes(netNode)) - paramBody :=make(map[string]interface{},0) + paramBody := make(map[string]interface{}, 0) paramBody["cameraIds"] = cameraIds - body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, paramBody,nil,nil) + body, err := client.DoPostRequest(url, CONTENT_TYPE_JSON, paramBody, nil, nil) if err != nil { - return false,nil + return false, nil } var res Result + var json = jsoniter.ConfigCompatibleWithStandardLibrary if err = json.Unmarshal(body, &res); err != nil { logPrint(err) - return false,nil + return false, nil } - return res.Success,res.Data + return res.Success, res.Data } //鎵归噺鍒囨崲鎽勫儚鏈鸿疆璇㈡垨瀹炴椂鐘舵�� -func (api Gb28181Api) ChangeRunType(paramBody map[string]interface{}) (bool,interface{}){ +func (api Gb28181Api) ChangeRunType(paramBody map[string]interface{}) (bool, interface{}) { url := DATA_URL_PREFIX + "/gb28181/camera/changeRunType" netNode := getNetNode(url2Topic(Topic_Gb28181_Service, url)) client := NewClient(WithNodes(netNode)) - body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, paramBody,nil,nil) + body, err := client.DoPostRequest(url, CONTENT_TYPE_JSON, paramBody, nil, nil) if err != nil { - return false,nil + return false, nil } var res Result + var json = jsoniter.ConfigCompatibleWithStandardLibrary if err = json.Unmarshal(body, &res); err != nil { logPrint(err) - return false,nil + return false, nil } - return res.Success,res.Data + return res.Success, res.Data } func (api Gb28181Api) SaveNotExistOrUpdate(paramBody map[string]interface{}) bool { url := DATA_URL_PREFIX + "/gb28181/saveNotExistOrUpdate" netNode := getNetNode(url2Topic(Topic_Gb28181_Service, url)) client := NewClient(WithNodes(netNode)) - body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, paramBody,nil,nil) + body, err := client.DoPostRequest(url, CONTENT_TYPE_JSON, paramBody, nil, nil) if err != nil { return false } var res Result + var json = jsoniter.ConfigCompatibleWithStandardLibrary if err = json.Unmarshal(body, &res); err != nil { logPrint(err) return false } return res.Success -} \ No newline at end of file +} -- Gitblit v1.8.0