package service

import (
	"encoding/json"
	"fmt"
	"time"

	"gat1400Exchange/config"
	"gat1400Exchange/models"
	"gat1400Exchange/util"
)

type DevReportData struct {
	Code        string                 `json:"code"`        // 设备ID
	Type        string                 `json:"type"`        // 设备类型
	Model       string                 `json:"model"`       // 设备型号
	SerialNum   string                 `json:"serialNum"`   // 硬件序列号
	Name        string                 `json:"name"`        // 设备名称
	Org         string                 `json:"org"`         // 所属机构
	Position    string                 `json:"position"`    // 具体位置
	Addr        string                 `json:"addr"`        // 地址
	Longitude   string                 `json:"lon"`         // 经度
	Latitude    string                 `json:"lat"`         // 纬度
	Desc        string                 `json:"desc"`        // 设备描述
	InstallTime string                 `json:"installTime"` // 安装时间
	UpTime      string                 `json:"upTime"`      // 启动时间
	Hardware    map[string]interface{} `json:"hardware"`    // 硬件信息
	IpAddr      string                 `json:"ip"`
}

func DeviceInfoReportTask() error {
	if config.ServeConf.Role == "agent" {
		return nil
	}

	var d models.Ape
	devices, err := d.FindAll()
	if err != nil {
		return err
	}

	for _, dev := range devices {
		// 级联的设备不检查心跳
		if dev.FromId == "" {
			hTime, err := time.ParseInLocation("2006-01-02 15:04:05", dev.HeartbeatTime, time.Local)
			if err != nil {
				dev.HeartbeatTime = time.Now().Format("2006-01-02 15:04:05")
				dev.Ext.IsOnline = "1"
			} else {
				if hTime.Unix()+120 >= time.Now().Unix() {
					dev.Ext.IsOnline = "1"
				} else {
					dev.Ext.IsOnline = "2"
				}
			}

			// 更新在线状态
			dev.Save()

			// 离线设备不执行上报
			if dev.Ext.IsOnline == "2" {
				continue
			}
		}

		// 配置了上报地址, 推送数据
		if config.ForwardConf.ReportServer == "" {
			continue
		}

		device := DevReportData{
			Code:      dev.Id,
			Model:     dev.Ext.Model,
			Type:      "camera",
			Name:      dev.Name,
			Addr:      dev.Ext.Place,
			IpAddr:    dev.Ext.IPAddr,
			Latitude:  fmt.Sprintf("%f", dev.Ext.Latitude),
			Longitude: fmt.Sprintf("%f", dev.Ext.Longitude),
		}

		data, err := json.Marshal(device)
		if err != nil {
			return err
		}

		headers := map[string]string{"Content-Type": "application/json; charset=UTF-8"}
		_, err = util.HttpPost(config.ForwardConf.ReportServer, headers, data)
		if err != nil {
			return err
		}
	}

	return nil
}