From a96ba8549c52b0dea9f708f537cd04ae5bd875b8 Mon Sep 17 00:00:00 2001
From: "suguo.yao" <ysg@myschools.me>
Date: Fri, 17 Dec 2021 15:57:36 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E7=94=B5=E6=BA=90=E5=8F=8A?=
 =?UTF-8?q?=E8=BF=9E=E6=8E=A5=E6=8F=90=E7=A4=BA?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 main.go | 14 ++++++++++----
 1 file changed, 10 insertions(+), 4 deletions(-)

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