package service
|
|
import (
|
"basic.com/valib/bhomeclient.git"
|
"basic.com/valib/bhomedbapi.git"
|
"basic.com/valib/logger.git"
|
"context"
|
"encoding/json"
|
"time"
|
"vamicro/system-service/models"
|
)
|
|
func CollectDeviceInfo(ctx context.Context, bk bhomeclient.Broker) {
|
tk := time.NewTicker(time.Second * 10)
|
for {
|
select {
|
case <-ctx.Done():
|
logger.Debug("ctx done")
|
return
|
case <-tk.C:
|
collect(bk)
|
default:
|
time.Sleep(time.Second)
|
}
|
}
|
}
|
|
type DevCollect struct {
|
DeviceList []models.Device `json:"deviceList"`
|
Sdks []SdkFill `json:"sdks"`
|
Apps []AppFill `json:"apps"`
|
}
|
|
type SdkFill struct {
|
models.DeviceSdk
|
SdkName string `json:"sdkName"` //汇总展现到页面上，此进程无法获取app和sdks表信息
|
IconBlob string `json:"iconBlob"`
|
IconBlob2 string `json:"iconBlob2"`
|
Version string `json:"version"`
|
Upgrade bool `json:"upgrade"` //判断是否需要升级
|
}
|
|
type AppFill struct {
|
models.DeviceApp
|
AppName string `json:"appName"` //汇总展现到页面上，此进程无法获取app和sdks表信息
|
IconBlob string `json:"iconBlob"`
|
IconBlob2 string `json:"iconBlob2"`
|
Version string `json:"version"`
|
IsDefault bool `json:"isDefault"`
|
Upgrade bool `json:"upgrade"` //判断是否需要升级
|
}
|
|
func collect(bk bhomeclient.Broker) {
|
var dc DevCollect
|
var d models.Device
|
var ds models.DeviceSdk
|
var da models.DeviceApp
|
dc.DeviceList = d.FindAll()
|
dsArr := ds.FindAll()
|
daArr := da.FindAll()
|
sdkApi := bhomedbapi.SdkApi{}
|
appApi := bhomedbapi.AppApi{}
|
sdkMap := sdkApi.FindAllMap()
|
appMap := appApi.FindAppMap()
|
for _, s := range dsArr {
|
sf := SdkFill{}
|
sf.DeviceSdk = s
|
if v,ok := sdkMap[s.SdkId];ok {
|
sf.SdkName = v.SdkName
|
sf.IconBlob = v.IconBlob
|
sf.IconBlob2 = v.IconBlob2
|
sf.Version = v.Version
|
|
}
|
dc.Sdks = append(dc.Sdks, sf)
|
}
|
for _, a := range daArr {
|
af := AppFill{}
|
af.DeviceApp = a
|
if v,ok := appMap[a.AppId];ok {
|
af.AppName = v.Name
|
af.IconBlob = v.IconBlob
|
af.IconBlob2 = v.IconBlob2
|
af.Version = v.Version
|
af.IsDefault = v.IsDefault
|
}
|
dc.Apps = append(dc.Apps, af)
|
}
|
data, err := json.Marshal(dc)
|
if err == nil {
|
bk.Publish("collect-manage-device-info", data)
|
} else {
|
logger.Error("marshal err:", err)
|
}
|
}
|
