获取算力接口实现

qixiaoning

2025-08-21 e38654fe9eff4562da4f18f8f018aed7879d493c

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
package controllers
 
import (
    "basic.com/valib/bhomeclient.git"
    "time"
    "vamicro/config"
 
    "vamicro/device-client/models"
    "vamicro/device-client/tasks"
)
 
type ReportServiceController struct {
    bk bhomeclient.Broker
}
 
func (ac ReportServiceController) GetDevInfo(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
    var module models.Device
    config, _ := module.FindAll()
 
    return &bhomeclient.Reply{Success: true, Data: config}
}
 
func (ac ReportServiceController) SetDevInfo(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
    var params models.Device
    if err := c.BindJSON(&params); err != nil {
        return &bhomeclient.Reply{Success: false, Msg: "参数格式错误,非法的json格式"}
    }
 
    params.DevId = config.Server.AnalyServerId
 
    // 第一次保存, 设置安装时间
    if params.InstallTime == "" {
        params.InstallTime = time.Now().Format("2006-01-02 15:04:05")
    }
 
    if err := params.Update(); err != nil {
        return &bhomeclient.Reply{Success: false, Msg: "更新失败"}
    }
 
    // 更新全局
    models.DeviceInfo.Read()
    models.ReportConfig.Read()
 
    // 重置上报任务
    tasks.ResetDeviceInfoReportTask()
 
    return &bhomeclient.Reply{Success: true, Data: params}
}
 
func (ac ReportServiceController) GetReportConfig(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
    var module models.Report
    config, _ := module.FindAll()
 
    return &bhomeclient.Reply{Success: true, Data: config}
}
 
func (ac ReportServiceController) SetReportConfig(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
    var params models.Report
 
    // 记录之前配置的值
    oldServerAddr := models.ReportConfig.ServerAddr
    oldInterval := models.ReportConfig.Interval
 
    if err := c.BindJSON(&params); err != nil {
        return &bhomeclient.Reply{Success: false, Msg: "参数格式错误,非法的json格式"}
    }
 
    if err := params.Update(); err != nil {
        return &bhomeclient.Reply{Success: false, Msg: "更新失败"}
    }
 
    // 更新全局
    models.ReportConfig.Read()
 
    // 判断是否修改
    if oldServerAddr != models.ReportConfig.ServerAddr || oldInterval != models.ReportConfig.Interval {
        tasks.ResetDeviceInfoReportTask()
    }
 
    return &bhomeclient.Reply{Success: true, Data: params}
}