|
|
@@ -130,12 +130,22 @@ eventLoop: |
|
|
case <-ctx.Done(): |
|
|
case <-ctx.Done(): |
|
|
break eventLoop |
|
|
break eventLoop |
|
|
case msg := <-chLoc: |
|
|
case msg := <-chLoc: |
|
|
|
|
|
if msg.ID == "" { |
|
|
|
|
|
fmt.Println("Received message with empty ID, skipping...") |
|
|
|
|
|
continue |
|
|
|
|
|
} |
|
|
id := msg.ID |
|
|
id := msg.ID |
|
|
|
|
|
|
|
|
|
|
|
fmt.Println("id: ", id) |
|
|
if err := db.First(&model.Tracker{}, "id = ?", id).Error; err != nil { |
|
|
if err := db.First(&model.Tracker{}, "id = ?", id).Error; err != nil { |
|
|
fmt.Printf("Location event for untracked beacon: %s\n", id) |
|
|
fmt.Printf("Location event for untracked beacon: %s\n", id) |
|
|
continue |
|
|
continue |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
var results []model.TrackerZones |
|
|
|
|
|
db.Where("tracker = ?", id).Find(&results) |
|
|
|
|
|
fmt.Printf("%v", results) |
|
|
|
|
|
|
|
|
if err := db.Updates(&model.Tracker{ID: id, Location: msg.Location, Distance: msg.Distance}).Error; err != nil { |
|
|
if err := db.Updates(&model.Tracker{ID: id, Location: msg.Location, Distance: msg.Distance}).Error; err != nil { |
|
|
fmt.Println("Error in saving distance for beacon: ", err) |
|
|
fmt.Println("Error in saving distance for beacon: ", err) |
|
|
continue |
|
|
continue |
|
|
|