Mirrors/VILLASweb-backend-go
1
0
Fork 0
mirror of https://git.rwth-aachen.de/acs/public/villas/web-backend-go/ synced 2025-03-30 00:00:12 +01:00
Code Issues Releases Wiki Activity

AMQP: fix for parseFloat

Browse source
This commit is contained in:
Sonja Happ 2020-09-30 16:18:49 +02:00
parent 8a783f51bd
commit e26c06ca04
1 changed files with 5 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
amqp/amqpclient.go
View file

@ -28,6 +28,7 @@ import (
"github.com/gin-gonic/gin" "github.com/gin-gonic/gin"
"github.com/streadway/amqp" "github.com/streadway/amqp"
"log" "log"
"math"
"strconv" "strconv"
"time" "time"
) )
@ -127,7 +128,9 @@ func ConnectAMQP(uri string) error {
var sToBeUpdated database.InfrastructureComponent var sToBeUpdated database.InfrastructureComponent
db := database.GetDB() db := database.GetDB()
ICUUID := fmt.Sprintf("%v", payload["properties.uuid"]) ICUUID := fmt.Sprintf("%v", payload["properties.uuid"])
uptime := fmt.Sprintf("%v", payload["uptime"]) uptime_s := fmt.Sprintf("%v", payload["uptime"])
uptime, _ := strconv.ParseFloat(uptime_s, 64)
uptime = math.Round(uptime)
state := fmt.Sprintf("%v", payload["state"]) state := fmt.Sprintf("%v", payload["state"])
var stateUpdateAt = message.Timestamp.UTC() var stateUpdateAt = message.Timestamp.UTC()
@ -143,7 +146,7 @@ func ConnectAMQP(uri string) error {
err = db.Model(&sToBeUpdated).Updates(map[string]interface{}{ err = db.Model(&sToBeUpdated).Updates(map[string]interface{}{
//"Host": gjson.Get(content, "host"), //"Host": gjson.Get(content, "host"),
//"Type": gjson.Get(content, "model"), //"Type": gjson.Get(content, "model"),
"Uptime": strconv.ParseFloat(uptime, 64), "Uptime": uptime,
"State": state, "State": state,
"StateUpdateAt": stateUpdateAt.Format(time.RFC1123), "StateUpdateAt": stateUpdateAt.Format(time.RFC1123),
//"RawProperties": gjson.Get(content, "properties"), //"RawProperties": gjson.Get(content, "properties"),