增加电源及连接提示

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 {}
 }