From ba664c06923ecca2b39691cb1f4644e434886e95 Mon Sep 17 00:00:00 2001
From: looper3339 <736321739@qq.com>
Date: 星期五, 21 二月 2020 15:45:20 +0800
Subject: [PATCH] add fileStack api

---
 cameraTaskApi.go |  189 +++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 189 insertions(+), 0 deletions(-)

diff --git a/cameraTaskApi.go b/cameraTaskApi.go
index ddff79b..5975093 100644
--- a/cameraTaskApi.go
+++ b/cameraTaskApi.go
@@ -1 +1,190 @@
 package dbapi
+
+import (
+	"basic.com/pubsub/protomsg.git"
+	"encoding/json"
+	"strconv"
+)
+
+type CameraTaskApi struct {
+	Ip string
+	Port int
+}
+
+func (api CameraTaskApi) 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 CameraTaskApi) FindAll() (b bool,list []protomsg.CameraTask) {
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/cameraTask/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
+	}
+	dataBytes, _ := json.Marshal(res.Data)
+	if err := json.Unmarshal(dataBytes, &list);err !=nil {
+		return false,nil
+	}
+	return true,list
+}
+
+func (api CameraTaskApi) AddTask(cameraId string,taskId string) (bool,interface{}) {
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/cameraTask/addTask"
+	client := NewClient()
+	paramBody := map[string]interface{}{
+		"cameraId": cameraId,
+		"taskId": taskId,
+	}
+	respBody, err := client.DoPostRequest(url, CONTENT_TYPE_FORM, paramBody,nil,nil)
+	if err != nil {
+		return false,nil
+	}
+	var res Result
+	if err = json.Unmarshal(respBody, &res); err != nil {
+		return false,nil
+	}
+	return res.Success,res.Data
+}
+
+func (api CameraTaskApi) CameraTaskSave(paramBody map[string]interface{}) (bool,interface{}) {
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/camera/saveTask"
+	client := NewClient()
+	respBody, err := client.DoPostRequest(url, CONTENT_TYPE_JSON, paramBody,nil, nil)
+	if err != nil {
+		return false,nil
+	}
+	var res Result
+	if err = json.Unmarshal(respBody, &res); err != nil {
+		return false,nil
+	}
+	return res.Success,res.Data
+}
+
+func (api CameraTaskApi) PasteRules(sourceId string, targetIds []string) bool {
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/camera/pasteRules"
+	client := NewClient()
+	paramBody := map[string]interface{} {
+		"sourceId": sourceId,
+		"targetIds": targetIds,
+	}
+	respBody, err := client.DoPostRequest(url, CONTENT_TYPE_JSON, paramBody,nil, nil)
+	if err != nil {
+		return false
+	}
+	var res Result
+	if err = json.Unmarshal(respBody, &res); err != nil {
+		return false
+	}
+	return res.Success
+}
+
+func (api CameraTaskApi) FindTasksByCameraIds(cameraIds []string) (bool,interface{}) {
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/camera/alltask"
+	client := NewClient()
+	paramBody :=make(map[string]interface{})
+	paramBody["cameraIds"] = cameraIds
+	respBody, err := client.DoPostRequest(url, CONTENT_TYPE_JSON, paramBody,nil, nil)
+	if err != nil {
+		return false,nil
+	}
+	var res Result
+	if err = json.Unmarshal(respBody, &res); err != nil {
+		return false,nil
+	}
+	return res.Success,res.Data
+}
+
+func (api CameraTaskApi) CameraTaskAll(cameraId string) (bool,interface{}) {
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/camera/task/"+cameraId
+	client := NewClient()
+	paramQuery :=make(map[string]string)
+	paramQuery["cameraId"] = cameraId
+	respBody, err := client.DoGetRequest(url, paramQuery,nil)
+	if err != nil {
+		return false,nil
+	}
+	var res Result
+	if err = json.Unmarshal(respBody, &res); err != nil {
+		return false,nil
+	}
+	return res.Success,res.Data
+}
+
+func (api CameraTaskApi) DeleteCameraTask(cameraId string,taskId string) (bool,interface{}) {
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/camera/delTask/"+cameraId+"/"+taskId
+	client := NewClient()
+	respBody, err := client.DoDeleteRequest(url, CONTENT_TYPE_FORM, nil,nil)
+	if err != nil {
+		return false,nil
+	}
+	var res Result
+	if err = json.Unmarshal(respBody, &res); err != nil {
+		return false,nil
+	}
+	return res.Success,res.Data
+}
+
+func (api CameraTaskApi) SaveIsDataTrans(paramBody map[string]interface{}) (bool,interface{}){
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/cameraTask/saveIsDataTrans"
+	client := NewClient()
+	respBody, err := client.DoPostRequest(url, CONTENT_TYPE_JSON, paramBody,nil, nil)
+	if err != nil {
+		return false,nil
+	}
+	var res Result
+	if err = json.Unmarshal(respBody, &res); err != nil {
+		return false,nil
+	}
+	return res.Success,res.Data
+}
+
+func (api CameraTaskApi) SaveAlarmLevelByGroup(groupId string,alarmLevel int) (bool,interface{}){
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/cameraTask/saveAlarmLevelByGroup"
+	client := NewClient()
+	paramBody :=make(map[string]interface{},0)
+	paramBody["group_id"] = groupId
+	paramBody["alarm_level"] = alarmLevel
+	respBody, err := client.DoPostRequest(url, CONTENT_TYPE_JSON, paramBody,nil, nil)
+	if err != nil {
+		return false,nil
+	}
+	var res Result
+	if err = json.Unmarshal(respBody, &res); err != nil {
+		return false,nil
+	}
+	return res.Success,res.Data
+}
+
+//鏇存柊鎽勫儚鏈轰换鍔＄姸鎬�
+func (api CameraTaskApi) UpdateCameraTaskStatus(cameraId string,taskId string,statusInt int) (bool,interface{}){
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/cameraTask/updateCameraTaskStatus"
+	client := NewClient()
+	paramBody :=make(map[string]interface{})
+	paramBody["cameraId"] = cameraId
+	paramBody["taskId"] = taskId
+	paramBody["status"] = statusInt
+	respBody, err := client.DoPostRequest(url, CONTENT_TYPE_JSON, paramBody, nil, nil)
+	if err != nil {
+		return false,nil
+	}
+	var res Result
+	if err = json.Unmarshal(respBody, &res); err != nil {
+		return false,nil
+	}
+	return res.Success,res.Data
+}
\ No newline at end of file

--
Gitblit v1.8.0