package service

import (
	"encoding/json"
	"time"

	"gat1400Exchange/config"
	"gat1400Exchange/pkg/logger"
	"gat1400Exchange/models"
	"gat1400Exchange/util"

	"github.com/hashicorp/golang-lru/v2/expirable"
)

var deviceAliveCache *expirable.LRU[string, bool]

func init() {
	deviceAliveCache = expirable.NewLRU[string, bool](100, nil, time.Second*60)
}

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
	}

	if config.ForwardConf.ReportServer == "" {
		return nil
	}

	logger.Info("Start device info report task, server:%s.", config.ForwardConf.ReportServer)

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

	for _, dev := range devices{
		if _, exists := deviceAliveCache.Get(dev.Id); !exists {
			continue
		}

		device := DevReportData{
			Code:      dev.Id,
			Type:      "camera",
			Name:      dev.Name,
			Addr:      dev.Addr+dev.Floor,
			IpAddr:    dev.Ip,
		}

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

		logger.Info("Report device info. %+v", dev)

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

	return nil
}

func KeepDeviceAlive(id string) {
	// 上报设备信息
	var d = models.Device{
		Id: id,
	}

	err := d.Upsert()
	if err != nil {
		logger.Warn("Device db update camera error:%s", err.Error())
	}

	deviceAliveCache.Add(id, true)
}