Mqtt: add smart cost limit (#6971)

This commit is contained in:
andig 2023-03-20 21:22:13 +01:00 • committed by GitHub
parent 81397e0cf3
commit 4fa8a2b82c
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23

View file

@ -186,20 +186,26 @@ func (m *MQTT) Run(site site.API, in <-chan util.Param) {
// site setters
m.Handler.ListenSetter(fmt.Sprintf("%s/site/prioritySoc/set", m.root), func(payload string) {
if soc, err := strconv.Atoi(payload); err == nil {
_ = site.SetPrioritySoc(float64(soc))
if val, err := strconv.ParseFloat(payload, 64); err == nil {
_ = site.SetPrioritySoc(val)
}
})
m.Handler.ListenSetter(fmt.Sprintf("%s/site/bufferSoc/set", m.root), func(payload string) {
if soc, err := strconv.Atoi(payload); err == nil {
_ = site.SetBufferSoc(float64(soc))
if val, err := strconv.ParseFloat(payload, 64); err == nil {
_ = site.SetBufferSoc(val)
}
})
m.Handler.ListenSetter(fmt.Sprintf("%s/site/residualPower/set", m.root), func(payload string) {
if soc, err := strconv.Atoi(payload); err == nil {
_ = site.SetResidualPower(float64(soc))
if val, err := strconv.ParseFloat(payload, 64); err == nil {
_ = site.SetResidualPower(val)
}
})
m.Handler.ListenSetter(fmt.Sprintf("%s/site/smartcostlimit/set", m.root), func(payload string) {
if val, err := strconv.ParseFloat(payload, 64); err == nil {
_ = site.SetSmartCostLimit(val)
}
})