package dbapi

import (
	"encoding/json"
)

type CameraTaskApi struct {

}

func (api CameraTaskApi) CameraTaskSave(paramBody map[string]interface{}) (bool,interface{}) {
	url := BASIC_URL + 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) FindTasksByCameraIds(cameraIds []string) (bool,interface{}) {
	url := BASIC_URL + 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 := BASIC_URL + 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 := BASIC_URL + DATA_URL_PREFIX + "/camera/delTask/"+cameraId+"/"+taskId
	client := NewClient()
	respBody, err := client.DoPutRequest(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 := BASIC_URL + 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 := BASIC_URL + 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 := BASIC_URL + 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
}