Add features to temperatures.

This commit is contained in:
chteufleur 2016-12-16 22:10:52 +01:00
parent 4bd4c0417c
commit da863e9f4f
2 changed files with 30 additions and 4 deletions

View File

@ -13,8 +13,9 @@ import (
) )
var ( var (
_, timezoneOffset = time.Now().Zone() timezoneName, timezoneOffset = time.Now().Zone()
log = logs.NewLogger(10000) timezoneLocation = time.FixedZone(timezoneName, timezoneOffset)
log = logs.NewLogger(10000)
) )
func init() { func init() {

View File

@ -19,7 +19,9 @@ type TempTable struct {
} }
var ( var (
_, timezoneOffset = time.Now().Zone() timezoneName, timezoneOffset = time.Now().Zone()
timezoneLocation = time.FixedZone(timezoneName, timezoneOffset)
deltaTimeCompressData = 1440 * time.Hour
log = logs.NewLogger(10000) log = logs.NewLogger(10000)
) )
@ -43,6 +45,22 @@ func AddData(sensor, value int64) {
o.Insert(tmpTable) 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 { func GetAllTempForSensor(sensorId int64) []TempTable {
o := orm.NewOrm() o := orm.NewOrm()
o.Using(database.Alias) o.Using(database.Alias)
@ -89,6 +107,13 @@ func DeleteTemperatureBySenor(sensorId int64) {
temps := GetAllTempForSensor(sensorId) temps := GetAllTempForSensor(sensorId)
for _, temp := range temps { 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})
}