package service
|
|
import (
|
"bytes"
|
"encoding/json"
|
"errors"
|
"io"
|
"net/http"
|
|
"vamicro/config"
|
"vamicro/system-service/sys"
|
|
"vamicro/device-client/models"
|
)
|
|
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 ReportDeviceInfo() error {
|
if models.ReportConfig.ServerAddr == "" {
|
return errors.New("server addr is empty !")
|
}
|
|
device := DevReportData{
|
Code: config.Server.AnalyServerId,
|
Type: config.Server.DeviceType,
|
Model: config.Server.DeviceModel,
|
SerialNum: config.Server.DeviceSerialNum,
|
|
Name: models.DeviceInfo.Name,
|
Org: models.DeviceInfo.Org,
|
Position: models.DeviceInfo.Position,
|
Addr: models.DeviceInfo.Addr,
|
Longitude: models.DeviceInfo.Latitude,
|
Latitude: models.DeviceInfo.Latitude,
|
Desc: models.DeviceInfo.Desc,
|
InstallTime: models.DeviceInfo.InstallTime,
|
}
|
|
// 添加ip
|
device.IpAddr, _, _ = sys.GetLocalIP(config.Server.NetworkAdapter)
|
// 添加硬件信息
|
device.Hardware = sys.GetDeviceInfo()
|
delete(device.Hardware, "cpu")
|
|
// 添加温度
|
device.Hardware["temp"] = sys.GetDeviceTemp()
|
|
data, err := json.Marshal(device)
|
if err != nil {
|
return err
|
}
|
|
_, err = HttpPost(models.ReportConfig.ServerAddr, nil, data)
|
|
return err
|
}
|
|
func HttpPost(url string, header map[string]string, data []byte) ([]byte, error) {
|
req, err := http.NewRequest(http.MethodPost, url, bytes.NewBuffer(data))
|
if err != nil {
|
return nil, err
|
}
|
req.Header.Set("Content-Type", "applicaiton/json; charset=UTF-8")
|
if header != nil {
|
for k, v := range header {
|
req.Header.Set(k, v)
|
}
|
}
|
cli := &http.Client{}
|
resp, err := cli.Do(req)
|
if err != nil {
|
return nil, err
|
}
|
defer resp.Body.Close()
|
body, err := io.ReadAll(resp.Body)
|
if err != nil {
|
return nil, err
|
}
|
return body, nil
|
}
|
