package service
|
|
import (
|
"encoding/json"
|
"time"
|
"errors"
|
|
"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 {
|
logger.Info("Start device info report task, server:%s.", config.ForwardConf.ReportServer)
|
|
if config.ForwardConf.ReportServer == "" {
|
return errors.New("Server addr is empty!")
|
}
|
|
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.Pos,
|
IpAddr: dev.Ip,
|
}
|
|
data, err := json.Marshal(device)
|
if err != nil {
|
return err
|
}
|
|
logger.Info("Report device info. %+v", dev)
|
|
_, err = util.HttpPost(config.ForwardConf.ReportServer, nil, data)
|
if err != nil {
|
return err
|
}
|
}
|
|
return nil
|
}
|
|
func KeepDeviceAlive(id string) {
|
deviceAliveCache.Add(id, true)
|
}
|
