package gb28181api

import (
	"bytes"
	"encoding/json"
	"fmt"
	"log"
	"strconv"
	urlLib "net/url"
)

func SmartPrintStruct(src interface{}) string {
	b, err := json.Marshal(src)
	if err != nil {
		return fmt.Sprintf("%+v", src)
	}
	var out bytes.Buffer
	err = json.Indent(&out, b, "", "    ")
	if err != nil {
		return fmt.Sprintf("%+v", src)
	}
	return out.String()
}

type Gb28181Api struct{}

//SetPlatformServerInfo 设置服务器信息
func (api Gb28181Api) SetPlatformServerInfo(serverInfo GbServerInfo) bool {
	serverInfo.GbUsername = serverInfo.PublicID   //鉴权名字不生效，最好和设备id一致

	u := urlLib.Values{}
	u.Set("gbsvrname", serverInfo.Name)
	u.Set("gbsvrid", serverInfo.PublicID)
	u.Set("gbsvrport", strconv.Itoa(serverInfo.GbServerPort))
	u.Set("registerauth", strconv.FormatBool(serverInfo.RegisterAuth))
	u.Set("gbusername", serverInfo.GbUsername)
	u.Set("gbpasswd", serverInfo.GbPasswd)
	str := u.Encode()
	url := BASIC_URL + DATA_URL_PREFIX + "/set_platform_server?" + str
	log.Println("url:", url)

	client := NewClient()
	body, err := client.DoGetRequest(url, nil, nil)
	if err != nil {
		return false
	}

	var res GbResult
	log.Println("body:", string(body[:]))
	if err = json.Unmarshal(body, &res); err != nil {
		log.Println("jsonErr:", err)
		return false
	}

	if res.ErrCode != 0 {
		log.Println("errcode: ", res.ErrCode, " errdesc: ", res.ErrDesc)
		return false
	}

	return true
}

type retGbServerInfo struct {
	GbServerInfo
	GbResult
}

//GetPlatformServerInfo 获取服务器信息
func (api Gb28181Api) GetPlatformServerInfo() (GbServerInfo, bool) {
	url := BASIC_URL + DATA_URL_PREFIX + "/get_platform_server"
	client := NewClient()

	var info GbServerInfo
	body, err := client.DoGetRequest(url, nil, nil)
	if err != nil {
		log.Println("err:", err)
		return info, false
	}

	//解析retGbServerInfo
	var res retGbServerInfo
	if err = json.Unmarshal(body, &res); err != nil {
		log.Println("jsonErr:", err)
		return info, false
	}
	if res.ErrCode != 0 {
		log.Println("errcode: ", res.ErrCode, " errdesc: ", res.ErrDesc)
		return info, false
	}

	return res.GbServerInfo, true
}

//GetDevicesByPageNO 按页获取下级设备（平台或摄像机）列表
//pageNo (数字)   指定获取第几页，第一次为1，返回总页数，总条数等，再根据这些信息去再次查询，直到取完全部
func (api Gb28181Api) getDevicesByPageNO(pageNo int) (DevicesInOnePage, bool) {
	url := BASIC_URL + DATA_URL_PREFIX + "/get_all_device/" + strconv.Itoa(pageNo)
	client := NewClient()

	var devicesPerPage DevicesInOnePage
	body, err := client.DoGetRequest(url, nil, nil)
	if err != nil {
		log.Println("err:", err)
		return devicesPerPage, false
	}

	//解析 DevicesInOnePage
	if err = json.Unmarshal(body, &devicesPerPage); err != nil {
		log.Println("jsonErr:", err)
		return devicesPerPage, false
	}
	if devicesPerPage.ErrCode != 0 {
		log.Println("errcode: ", devicesPerPage.ErrCode, " errdesc: ", devicesPerPage.ErrDesc)
		return devicesPerPage, false
	}

	return devicesPerPage, true
}

//GetAllDevices 获取全部下级设备（平台或摄像机）信息列表
func (api Gb28181Api) GetAllDevices() ([]DeviceInfo, bool) {
	var deviceSlice []DeviceInfo
	devicesPerPage, flag := api.getDevicesByPageNO(1)
	if !flag {
		log.Println("GetDevicesByPageNO Error, deviceSlice is nil")
		return deviceSlice, false
	}
	deviceSlice = devicesPerPage.Data

	for i := 1; i < devicesPerPage.TotalPage; i++ {
		devicesPerPage, flag := api.getDevicesByPageNO(i + 1)
		if !flag {
			log.Println("GetDevicesByPageNO Error,pageno:" + strconv.Itoa(i+1) + " ,deviceSlice is not completed")
			return deviceSlice, false
		}
		deviceSlice = append(deviceSlice, devicesPerPage.Data...)
	}

	return deviceSlice, true
}

//GetCamsByDevAndPage 按页获取下级设备的摄像机列表
//devID  (字符串)  注册的设备的20位id
//pageNo (数字)   指定获取第几页，第一次为1，返回总页数，总条数等，再根据这些信息去再次查询，直到取完全部
//srcType (字符串) "all"-表示获取设备的所有资源  "node"-父节点下的第一级资源
//注意：根据"restype"字段，忽略资源组，只保留通道资源------"restype"：(数字)1-通道资源 2-资源组
func (api Gb28181Api) getCamsByDevAndPage(devID string, srcType string, pageNo int) (CamerasInOnePage, bool) {
	url := BASIC_URL + DATA_URL_PREFIX + "/get_all_channel/" + devID + "/" + srcType + "/" + strconv.Itoa(pageNo)
	client := NewClient()

	var camerasPerPage CamerasInOnePage
	body, err := client.DoGetRequest(url, nil, nil)
	if err != nil {
		log.Println("err:", err)
		return camerasPerPage, false
	}

	//解析 CamerasInOnePage
	if err = json.Unmarshal(body, &camerasPerPage); err != nil {
		log.Println("jsonErr:", err)
		return camerasPerPage, false
	}
	if camerasPerPage.ErrCode != 0 {
		log.Println("errcode: ", camerasPerPage.ErrCode, " errdesc: ", camerasPerPage.ErrDesc)
		return camerasPerPage, false
	}

	if len(camerasPerPage.Data) > 0 {
		for i := 0; i < len(camerasPerPage.Data); i++ {
			if camerasPerPage.Data[i].ResType == 2 {
				camerasPerPage.Data = append(camerasPerPage.Data[:i], camerasPerPage.Data[i+1:]...)
				i--
			}
		}
	}

	return camerasPerPage, true
}

//GetAllCamerasByDevID 获取全部下级设备的摄像机列表
//devID  (字符串)  注册的设备的20位id
func (api Gb28181Api) GetAllCamerasByDevID(devID string) ([]CameraInfo, bool) {
	var cameraSlice []CameraInfo
	camerasPerPage, flag := api.getCamsByDevAndPage(devID, "all", 1)
	if !flag {
		log.Println("GetCamsByDevAndPage Error, deviceSlice is nil")
		return cameraSlice, false
	}
	cameraSlice = camerasPerPage.Data

	for i := 1; i < camerasPerPage.TotalPage; i++ {
		camerasPerPage, flag := api.getCamsByDevAndPage(devID, "all", i+1)
		if !flag {
			log.Println("GetCamsByDevAndPage Error! devID:" + devID + ",type:all,pageno:" + strconv.Itoa(i+1) + " ,cameraSlice is not completed")
			return cameraSlice, false
		}
		cameraSlice = append(cameraSlice, camerasPerPage.Data...)
	}

	return cameraSlice, true
}

//GetAllDomainUnit get all domainunit 获取所有行政区域
func (api Gb28181Api) GetAllDomainUnit() ([]DomainUnit, bool) {
	url := BASIC_URL + DATA_URL_PREFIX + "/get_all_domainunit"
	client := NewClient()

	var dmUnit DomainUnitInfo
	body, err := client.DoGetRequest(url, nil, nil)
	if err != nil {
		log.Println("err:", err)
		return dmUnit.Data, false
	}

	//解析 dmUnit
	if err = json.Unmarshal(body, &dmUnit); err != nil {
		log.Println("jsonErr:", err)
		return dmUnit.Data, false
	}
	if dmUnit.ErrCode != 0 {
		log.Println("errcode: ", dmUnit.ErrCode, " errdesc: ", dmUnit.ErrDesc)
		return dmUnit.Data, false
	}

	return dmUnit.Data, true
}

//GetAllCamerasByDomainUnit  get all cameras by domainunit 获取所有行政区域下的设备
func (api Gb28181Api) getAllCamerasByDomainUnitAndPage(domainpubid string, pageNo int) (CamerasInOnePage, bool) {
	url := BASIC_URL + DATA_URL_PREFIX + "/get_domainunit_channel/" + domainpubid + "/" + strconv.Itoa(pageNo)
	client := NewClient()

	var camerasPerPage CamerasInOnePage
	body, err := client.DoGetRequest(url, nil, nil)
	if err != nil {
		log.Println("err:", err)
		return camerasPerPage, false
	}

	//解析 CamerasInOnePage
	if err = json.Unmarshal(body, &camerasPerPage); err != nil {
		log.Println("jsonErr:", err)
		return camerasPerPage, false
	}
	if camerasPerPage.ErrCode != 0 {
		log.Println("errcode: ", camerasPerPage.ErrCode, " errdesc: ", camerasPerPage.ErrDesc)
		return camerasPerPage, false
	}

	return camerasPerPage, true
}

//GetAllCamerasByDevID 获取指定行政区域的摄像机列表
func (api Gb28181Api) GetAllCamerasByDomainUnit(domainpubid string) ([]CameraInfo, bool) {
	var cameraSlice []CameraInfo
	camerasPerPage, flag := api.getAllCamerasByDomainUnitAndPage(domainpubid, 1)
	if !flag {
		log.Println("GetCamsByDevAndPage Error, deviceSlice is nil")
		return cameraSlice, false
	}
	cameraSlice = camerasPerPage.Data

	for i := 1; i < camerasPerPage.TotalPage; i++ {
		camerasPerPage, flag := api.getAllCamerasByDomainUnitAndPage(domainpubid, i+1)
		if !flag {
			log.Println("GetCamsByDevAndPage Error! devID:" + domainpubid + ",type:all,pageno:" + strconv.Itoa(i+1) + " ,cameraSlice is not completed")
			return cameraSlice, false
		}
		cameraSlice = append(cameraSlice, camerasPerPage.Data...)
	}

	return cameraSlice, true
}

//getAllGroupBygroupIDAndpage get all group by groupID ang page 按页和组id获取下属分组
func (api Gb28181Api) getAllGroupBygroupIDAndpage(groupID string, pageNo int) ([]DomainUnit, bool) {
	url := BASIC_URL + DATA_URL_PREFIX + "/get_all_channel/" + groupID + "/node/" + strconv.Itoa(pageNo)
	client := NewClient()

	var camerasPerPage CamerasInOnePage
	body, err := client.DoGetRequest(url, nil, nil)
	if err != nil {
		log.Println("err:", err)
		return nil, false
	}

	if camerasPerPage.ErrCode != 0 {
		log.Println("errcode: ", camerasPerPage.ErrCode, " errdesc: ", camerasPerPage.ErrDesc)
		return nil, false
	}

	//解析 cameras
	//log.Println("body:", body)
	if err = json.Unmarshal(body, &camerasPerPage); err != nil {
		log.Println("jsonErr:", err)
		return nil, false
	}

	//cameraInfo 转 DomainUnit
	var dmUnits []DomainUnit
	var tmpUnit DomainUnit
	for _, cam := range camerasPerPage.Data {
		if cam.ResType == 2 {
			tmpUnit.Name = cam.Name
			tmpUnit.DevPubID = cam.DevPubID
			tmpUnit.OnlineNum = 0
			tmpUnit.ParentID = cam.ParentID
			tmpUnit.PublicID = cam.PublicID
			tmpUnit.ResType = cam.ResType
			tmpUnit.TotalNum = 0
			dmUnits = append(dmUnits, tmpUnit)
		}
	}

	log.Println("dmUnits:", dmUnits)
	return dmUnits, true
}

//GetAllGroupByDevID  按组id获取下属分组
func (api Gb28181Api) getAllGroupByGroupID(groupID string) []DomainUnit {
	var dmUnitAll []DomainUnit
	pageNo := 1
	for {
		dmUnitsPerPage, flag := api.getAllGroupBygroupIDAndpage(groupID, pageNo)
		if !flag || dmUnitsPerPage == nil {
			break
		}
		dmUnitAll = append(dmUnitAll, dmUnitsPerPage...)
		pageNo++
	}

	return dmUnitAll
}

//
func (api Gb28181Api) getGroupsByGroupID(groupID string, groupsAll *[]DomainUnit) {
	if groupID != "" {
		groups := api.getAllGroupByGroupID(groupID)
		if groups == nil {
			return
		}
		if len(groups) > 0 {
			*groupsAll = append(*groupsAll, groups...)
			for _, groupid := range groups {
				api.getGroupsByGroupID(groupid.PublicID, groupsAll)
			}
		}
	}
}

//GetAllGroupByDevID get all group by devid 按设备id获取分组
func (api Gb28181Api) GetAllGroupBydevID(devID string) []DomainUnit {
	var dmUnitAll []DomainUnit

	api.getGroupsByGroupID(devID, &dmUnitAll)

	log.Println("dmUnitAll:", dmUnitAll)
	return dmUnitAll
}

//getAllCamerasByGroupIDAndPage 按分组和页获取摄像机列表
func (api Gb28181Api) getAllCamerasByGroupIDAndPage(groupID string, pageNo int) (CamerasInOnePage, bool) {
	url := BASIC_URL + DATA_URL_PREFIX + "/get_all_channel/" + groupID + "/node/" + strconv.Itoa(pageNo)
	client := NewClient()

	var camerasPerPage CamerasInOnePage
	body, err := client.DoGetRequest(url, nil, nil)
	if err != nil {
		log.Println("err:", err)
		return camerasPerPage, false
	}

	//解析 cameras
	if err = json.Unmarshal(body, &camerasPerPage); err != nil {
		log.Println("jsonErr:", err)
		return camerasPerPage, false
	}

	if len(camerasPerPage.Data) > 0 {
		for i := 0; i < len(camerasPerPage.Data); i++ {
			if camerasPerPage.Data[i].ResType == 2 {
				camerasPerPage.Data = append(camerasPerPage.Data[:i], camerasPerPage.Data[i+1:]...)
				i--
			}
		}
	}

	return camerasPerPage, true
}

//GetAllGroupByDevID get all group by devid 按设备id获取分组
func (api Gb28181Api) GetAllCamerasByGroupID(groupID string) ([]CameraInfo, bool) {

	var cameraSlice []CameraInfo
	camerasPerPage, flag := api.getAllCamerasByGroupIDAndPage(groupID, 1)
	if !flag {
		log.Println("GetCamsByDevAndPage Error, deviceSlice is nil")
		return cameraSlice, false
	}
	cameraSlice = camerasPerPage.Data

	for i := 1; i < camerasPerPage.TotalPage; i++ {
		camerasPerPage, flag := api.getAllCamerasByGroupIDAndPage(groupID, i+1)
		if !flag {
			log.Println("getAllCamerasByGroupIDAndPage Error! devID:" + groupID + ",type:all,pageno:" + strconv.Itoa(i+1) + " ,cameraSlice is not completed")
			return cameraSlice, false
		}
		cameraSlice = append(cameraSlice, camerasPerPage.Data...)
	}

	return cameraSlice, true
}

//updateResourceByID 更新下级平台资源
func (api Gb28181Api) updateResourceByID(devID string) bool {
	url := BASIC_URL + "/vss/get_catalog/" + devID
	client := NewClient()

	body, err := client.DoGetRequest(url, nil, nil)
	if err != nil {
		log.Println("err:", err)
		return false
	}

	var res GbResult
	if err = json.Unmarshal(body, &res); err != nil {
		log.Println("jsonErr:", err)
		return false
	}
	if res.ErrCode != 0 {
		log.Println("errcode: ", res.ErrCode, " errdesc: ", res.ErrDesc)
		return false
	}

	return true
}

func (api Gb28181Api) UpdateAllResource() {
	devices, b := api.GetAllDevices()
	if b && len(devices) > 0 {
		for _, device := range devices {
			api.updateResourceByID(device.PublicID)
		}
	}
}

//SetCameraPtz 2.3 PTZ云台控制
//"channelid":  (字符串)   通道20位编号
//"ptztype"：   (字符串) 控制类型：上"up",下"down",左"left",右"right",左上"leftup",左下"leftdown",右上"rightup",右下"rightdown",镜头近"zoomin",镜头远"zoomout",
//				焦距远"focusfar",焦距近"focusnear", 设置预置位"setpos",调预置位"callpos",停止"stop"
//"ptzparam":   (数字)   参数，速度范围为1-255
func (api Gb28181Api) SetCameraPtz(chanID string, ptzType string, ptzParam int) bool {
	url := BASIC_URL + "/vss/ptz/" + ptzType + "/" + strconv.Itoa(ptzParam) + "/" + chanID
	client := NewClient()

	body, err := client.DoGetRequest(url, nil, nil)
	if err != nil {
		log.Println("err:", err)
		return false
	}

	var res GbResult
	if err = json.Unmarshal(body, &res); err != nil {
		log.Println("jsonErr:", err)
		return false
	}
	if res.ErrCode != 0 {
		log.Println("errcode: ", res.ErrCode, " errdesc: ", res.ErrDesc)
		return false
	}

	return true
}