qixiaoning
1 天以前 c3fd4effdef0cc5955f89b5df279b14841e857f5
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
package controllers
 
import (
    "basic.com/valib/bhomeclient.git"
    "vamicro/report-service/models"
    "vamicro/report-service/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格式"}
    }
 
    if err := params.Update(); err != nil {
        return &bhomeclient.Reply{Success: false, Msg: "更新失败"}
    }
 
    // 更新全局
    models.IntervalConfig.Read()
 
    // 重置上报任务
    tasks.ResetDeviceInfoReport()
 
    return &bhomeclient.Reply{Success: true, Data: params}
}
 
func (ac ReportServiceController) GetIntervalConfig(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
    var module models.Interval
    config, _ := module.FindAll()
 
    return &bhomeclient.Reply{Success: true, Data: config}
}
 
func (ac ReportServiceController) SetIntervalConfig(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
    var params models.Interval
    // 记录之前配置的值
    oldDevInfoInterval := models.IntervalConfig.DevInfo
    oldDevStateInterval := models.IntervalConfig.DevState
 
    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.IntervalConfig.Read()
 
    // 判断是否修改
    if oldDevInfoInterval != models.IntervalConfig.DevInfo {
        tasks.ResetDeviceInfoReport()
    }
 
    // 判断是否修改
    if oldDevStateInterval != models.IntervalConfig.DevState {
        tasks.ResetDeviceStateReport()
    }
 
    return &bhomeclient.Reply{Success: true, Data: params}
}