From 63645d248c765244488cd34dbc1bb6528ca6b7c7 Mon Sep 17 00:00:00 2001 From: zhangzengfei <zhangzengfei@smartai.com> Date: 星期二, 05 九月 2023 09:58:13 +0800 Subject: [PATCH] 修复编译 --- system-service/service/collectDev.go | 188 +++++++++++++++++++++++----------------------- 1 files changed, 94 insertions(+), 94 deletions(-) diff --git a/system-service/service/collectDev.go b/system-service/service/collectDev.go index 28978a9..19d6404 100644 --- a/system-service/service/collectDev.go +++ b/system-service/service/collectDev.go @@ -1,95 +1,95 @@ -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"` //姹囨�诲睍鐜板埌椤甸潰涓婏紝姝よ繘绋嬫棤娉曡幏鍙朼pp鍜宻dks琛ㄤ俊鎭� - 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"` //姹囨�诲睍鐜板埌椤甸潰涓婏紝姝よ繘绋嬫棤娉曡幏鍙朼pp鍜宻dks琛ㄤ俊鎭� - 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) - } +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"` //姹囨�诲睍鐜板埌椤甸潰涓婏紝姝よ繘绋嬫棤娉曡幏鍙朼pp鍜宻dks琛ㄤ俊鎭� + 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"` //姹囨�诲睍鐜板埌椤甸潰涓婏紝姝よ繘绋嬫棤娉曡幏鍙朼pp鍜宻dks琛ㄤ俊鎭� + 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) + } } \ No newline at end of file -- Gitblit v1.8.0