diff --git a/main.go b/main.go index 8b08d8d..71e82b0 100644 --- a/main.go +++ b/main.go @@ -4,6 +4,7 @@ import ( "encoding/binary" "encoding/hex" "errors" + "fmt" "log" "strconv" "strings" @@ -62,6 +63,7 @@ func onPerhipheralDiscovered(p gatt.Peripheral, a *gatt.Advertisement, rssi int) fields["name"] = a.LocalName fields["rssi"] = rssi fields["pl"] = strconv.Itoa(len(a.ManufacturerData)) //包长度 + fields["power"] = a.TxPowerLevel point, err := client.NewPoint( "band", @@ -94,9 +96,9 @@ func main() { Timeout: 3, }) - if err := influx.CreateDB("wristband", 10); err != nil { - log.Fatalln("influx.CreateDB", err.Error()) - } + // if err := influx.CreateDB("wristband", 10); err != nil { + // log.Fatalln("influx.CreateDB", err.Error()) + // } go func() { db, err := influx.New() @@ -127,7 +129,11 @@ func main() { if err != nil { log.Fatalf("Failed to open device, err:%s\n", err) } - dev.Handle(gatt.PeripheralDiscovered(onPerhipheralDiscovered)) + dev.Handle( + gatt.PeripheralDiscovered(onPerhipheralDiscovered), + gatt.CentralConnected(func(c gatt.Central) { fmt.Println("Connect: ", c.ID()) }), + gatt.CentralDisconnected(func(c gatt.Central) { fmt.Println("Disconnect: ", c.ID()) }), + ) dev.Init(onStateChanged) select {} }