|
|
@@ -4,39 +4,40 @@ from kivy.uix.button import Button
|
|
|
from kivy.uix.gridlayout import GridLayout
|
|
|
from kivy.uix.label import Label
|
|
|
from kivy.uix.textinput import TextInput
|
|
|
-from kivy.lang import Builder
|
|
|
from kivy.clock import Clock
|
|
|
-from kivy.properties import BooleanProperty
|
|
|
+
|
|
|
import asyncio
|
|
|
from bleak import BleakClient,BleakScanner
|
|
|
-import time
|
|
|
-
|
|
|
-# import json
|
|
|
+import json
|
|
|
|
|
|
STM32_UUID = "00001101-0000-1000-8000-00805F9B34FB"
|
|
|
|
|
|
-class InfoWidget(Widget):
|
|
|
+class MainWidget(Widget):
|
|
|
def __init__(self, **kwargs):
|
|
|
- super(InfoWidget, self).__init__(**kwargs)
|
|
|
+ super().__init__(**kwargs)
|
|
|
+ self.size = (1600,800)
|
|
|
self.last_flag = False
|
|
|
self.flag = False
|
|
|
- self.scanning = Label(text="Scanning...",font_size=100,top=self.top)
|
|
|
- self.devices = None
|
|
|
-
|
|
|
+ self.scanning = Label(text="Scanning...",font_size=100,top=self.top,center_x = self.center_x)
|
|
|
|
|
|
def update(self, dt):
|
|
|
if self.flag and (not self.last_flag):
|
|
|
self.connect()
|
|
|
self.last_flag = self.flag
|
|
|
-
|
|
|
+
|
|
|
def start(self):
|
|
|
- self.size = (1600,800)
|
|
|
self.add_widget(self.scanning)
|
|
|
|
|
|
+ # def start_scan(self, dt):
|
|
|
+ # asyncio.run(self.scan)
|
|
|
+
|
|
|
+ async def scan(self):
|
|
|
+ self.devices = await BleakScanner.discover()
|
|
|
+ self.flag = True
|
|
|
+
|
|
|
def connect(self):
|
|
|
- self.grid00 = GridLayout(cols=1,rows=2,width=self.width,height=self.height / 4,top=self.top)
|
|
|
self.remove_widget(self.scanning)
|
|
|
- self.grid00.top = self.top
|
|
|
+ self.grid00 = GridLayout(cols=1,rows=2,width=self.width,height=self.height / 4,top=self.top)
|
|
|
self.add_widget(self.grid00)
|
|
|
grid01 = GridLayout(cols=2,rows=1,width=self.grid00.width,height=self.grid00.height / 2)
|
|
|
self.grid00.add_widget(grid01)
|
|
|
@@ -44,82 +45,24 @@ class InfoWidget(Widget):
|
|
|
deviceName = "HC-06"
|
|
|
grid01.add_widget(TextInput(text=deviceName,width=self.grid00.width / 2,height=self.grid00.height / 2,font_size=40))
|
|
|
connect_button = Button(text="Connect",width=self.grid00.width,height=self.grid00.height / 2,center_x=self.grid00.center_x,font_size=40)
|
|
|
-
|
|
|
self.grid00.add_widget(connect_button)
|
|
|
|
|
|
- # for d in devices:
|
|
|
- # if d.name == deviceName:
|
|
|
- # await self.connect_and_receive(d.address)
|
|
|
- # self.add_widget(Label(text="Connected",width=self.width,height=self.height / 4))
|
|
|
- # break
|
|
|
- # grid1 = GridLayout(cols=2,rows=5,width=self.width,height=self.height)
|
|
|
- # self.add_widget(grid1)
|
|
|
- # for num,d in enumerate(devices):
|
|
|
- # button = Button(text=f"{d.name}")
|
|
|
- # button.height = grid1.height / 5
|
|
|
- # button.width = grid1.width / 2
|
|
|
- # button.on_touch_down = lambda instance, d=d: asyncio.run(self.connect_and_receive(d.address))
|
|
|
- # grid1.add_widget(button)
|
|
|
- # if num >= 9:
|
|
|
- # break
|
|
|
-
|
|
|
- # async def connect_and_receive(self, address):
|
|
|
- # async with BleakClient(address) as client:
|
|
|
- # if await client.is_connected():
|
|
|
- # rawdata = await client.read_gatt_char(STM32_UUID)
|
|
|
- # data = rawdata.decode("utf-8")
|
|
|
- # if data.startswith("[") and data.endswith("]"):
|
|
|
- # list = json.loads(data)
|
|
|
- # info = "基波频率：" + str(list[0]) + "Hz\n" + \
|
|
|
- # "THD：" + str(list[6]) + "%\n" + \
|
|
|
- # "基波幅值：" + str(list[1]) + "V\n" + \
|
|
|
- # "二次谐波：" + str(list[2]) + "V\n" + \
|
|
|
- # "三次谐波：" + str(list[3]) + "V\n" + \
|
|
|
- # "四次谐波：" + str(list[4]) + "V\n" + \
|
|
|
- # "五次谐波：" + str(list[5]) + "V\n"
|
|
|
- # else:
|
|
|
- # info = "传输数据出错"
|
|
|
- # label = Label(text=info)
|
|
|
- # self.add_widget(label)
|
|
|
- # return
|
|
|
- # else:
|
|
|
- # print("Failed to connect to device.")
|
|
|
- # def debug(self):
|
|
|
- # # self.size = (800,480)
|
|
|
- # grid = GridLayout(cols=2,rows=4,width=self.width,height=self.height)
|
|
|
- # self.add_widget(grid)
|
|
|
- # for i in range(8):
|
|
|
- # button = Button(text=str(i))
|
|
|
- # button.width = grid.width / 2
|
|
|
- # button.height = grid.height / 4
|
|
|
- # grid.add_widget(button)
|
|
|
- async def discover_devices(self):
|
|
|
- self.devices = await BleakScanner.discover()
|
|
|
- self.flag = True
|
|
|
-
|
|
|
- def start_discovery(self, dt):
|
|
|
- asyncio.create_task(self.discover_devices())
|
|
|
-
|
|
|
class STI2021A(App):
|
|
|
- def build(self):
|
|
|
- # 在这里设置asyncio事件循环
|
|
|
- loop = asyncio.get_event_loop()
|
|
|
- if not loop.is_running():
|
|
|
- asyncio.set_event_loop(loop)
|
|
|
-
|
|
|
- info = InfoWidget()
|
|
|
- info.start()
|
|
|
- Clock.schedule_once(info.start_discovery, 1)
|
|
|
- Clock.schedule_interval(info.update, 1)
|
|
|
- return info
|
|
|
+ def __init__(self):
|
|
|
+ super().__init__()
|
|
|
+ self.main_widget = MainWidget()
|
|
|
|
|
|
- def run(self):
|
|
|
- # 获取当前的事件循环
|
|
|
- loop = asyncio.get_event_loop()
|
|
|
- # 运行应用程序，直到完成
|
|
|
- loop.run_until_complete(self.async_run())
|
|
|
- loop.close()
|
|
|
+ def build(self):
|
|
|
+ self.main_widget.start()
|
|
|
+ Clock.schedule_interval(self.main_widget.update, 1)
|
|
|
+ return self.main_widget
|
|
|
+
|
|
|
+ async def scan(self):
|
|
|
+ await self.main_widget.scan()
|
|
|
|
|
|
+async def main(app):
|
|
|
+ await asyncio.gather(app.async_run("asyncio"), app.scan())
|
|
|
|
|
|
-if __name__ == '__main__':
|
|
|
- STI2021A().run()
|
|
|
+if __name__ == "__main__":
|
|
|
+ app = STI2021A()
|
|
|
+ asyncio.run(main(app))
|
