From da863e9f4f90f54145d6687ed9f9c3f345cae959 Mon Sep 17 00:00:00 2001 From: chteufleur Date: Fri, 16 Dec 2016 22:10:52 +0100 Subject: [PATCH] Add features to temperatures. --- controllers/default.go | 5 +++-- models/temperature/temperature.go | 29 +++++++++++++++++++++++++++-- 2 files changed, 30 insertions(+), 4 deletions(-) diff --git a/controllers/default.go b/controllers/default.go index 0000916..b609e3e 100644 --- a/controllers/default.go +++ b/controllers/default.go @@ -13,8 +13,9 @@ import ( ) var ( - _, timezoneOffset = time.Now().Zone() - log = logs.NewLogger(10000) + timezoneName, timezoneOffset = time.Now().Zone() + timezoneLocation = time.FixedZone(timezoneName, timezoneOffset) + log = logs.NewLogger(10000) ) func init() { diff --git a/models/temperature/temperature.go b/models/temperature/temperature.go index 424df81..e6eeaec 100644 --- a/models/temperature/temperature.go +++ b/models/temperature/temperature.go @@ -19,7 +19,9 @@ type TempTable struct { } var ( - _, timezoneOffset = time.Now().Zone() + timezoneName, timezoneOffset = time.Now().Zone() + timezoneLocation = time.FixedZone(timezoneName, timezoneOffset) + deltaTimeCompressData = 1440 * time.Hour log = logs.NewLogger(10000) ) @@ -43,6 +45,22 @@ func AddData(sensor, value int64) { o.Insert(tmpTable) } +func AddDataWithHorodate(id, sensor, value int64, horodateGMT time.Time) { + log.Info("Add Temperature {sensor: %s, value: %d, horodateGNT: %v}", sensor, value, horodateGMT) + o := orm.NewOrm() + o.Using(database.Alias) + + tmpTable := new(TempTable) + tmpTable.Id = id + tmpTable.Value = value + tmpTable.SensorID = sensor + tmpTable.HorodateGMT = horodateGMT + _, err := o.Insert(tmpTable) + if err != nil { + log.Info("Error on insert temperature ", err) + } +} + func GetAllTempForSensor(sensorId int64) []TempTable { o := orm.NewOrm() o.Using(database.Alias) @@ -89,6 +107,13 @@ func DeleteTemperatureBySenor(sensorId int64) { temps := GetAllTempForSensor(sensorId) for _, temp := range temps { - o.Delete(&TempTable{Id: temp.Id}) + DeleteTemperatureById(temp.Id) } } + +func DeleteTemperatureById(tempId int64) { + log.Info("Delete temperatures id : %d", tempId) + o := orm.NewOrm() + o.Using(database.Alias) + o.Delete(&TempTable{Id: tempId}) +}