90 lines
3.1 KiB
Python
90 lines
3.1 KiB
Python
from PySide6.QtCore import QObject, Slot, Signal, QTimer
|
||
from PySide6.QtWebChannel import QWebChannel
|
||
import time
|
||
|
||
class WebviewBridge(QObject):
|
||
"""Webview桥接类，用于处理前端和Python后端之间的通信"""
|
||
|
||
# 定义信号
|
||
time_updated = Signal(str)
|
||
message_received = Signal(str)
|
||
|
||
def __init__(self, parent=None):
|
||
super().__init__(parent)
|
||
self.frontend_ready = False
|
||
self.timer = QTimer()
|
||
self.timer.timeout.connect(self.send_time)
|
||
|
||
@Slot()
|
||
def on_frontend_ready(self):
|
||
"""当前端准备就绪时调用"""
|
||
print("Frontend is ready")
|
||
self.frontend_ready = True
|
||
# 启动定时器，每秒更新一次时间
|
||
self.timer.start(1000)
|
||
|
||
@Slot(str, result=str)
|
||
def hello(self, message):
|
||
"""处理前端发送的消息"""
|
||
print('Message received from frontend:', message)
|
||
response = f'Hello from Python: {message}'
|
||
self.message_received.emit(response)
|
||
return response
|
||
|
||
def send_time(self):
|
||
"""定期向前端发送时间更新"""
|
||
if self.frontend_ready:
|
||
current_time = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())
|
||
self.time_updated.emit(current_time)
|
||
return current_time
|
||
return None
|
||
|
||
def set_frontend_ready(self, ready=True):
|
||
"""设置前端准备状态"""
|
||
self.frontend_ready = ready
|
||
|
||
class WebviewController(QObject):
|
||
"""Webview控制器类，负责管理Webview的逻辑"""
|
||
|
||
def __init__(self, web_engine_page, parent=None):
|
||
super().__init__(parent)
|
||
self.page = web_engine_page
|
||
self.bridge = WebviewBridge()
|
||
self.channel = QWebChannel()
|
||
self.channel.registerObject('py', self.bridge)
|
||
self.page.setWebChannel(self.channel)
|
||
|
||
# 连接bridge的信号
|
||
self.bridge.time_updated.connect(self.on_time_updated)
|
||
self.bridge.message_received.connect(self.on_message_received)
|
||
|
||
def on_time_updated(self, time_str):
|
||
"""当bridge发出time_updated信号时调用"""
|
||
print(f"Time updated: {time_str}")
|
||
# 调用前端的update_time函数
|
||
js_code = f"""
|
||
try {{
|
||
if (typeof update_time !== 'undefined' && typeof update_time === 'function') {{
|
||
update_time('{time_str}');
|
||
}}
|
||
}} catch (e) {{
|
||
console.error('Error calling update_time:', e);
|
||
}}
|
||
"""
|
||
self.page.runJavaScript(js_code)
|
||
|
||
def on_message_received(self, message):
|
||
"""当bridge发出message_received信号时调用"""
|
||
print(f"Message received: {message}")
|
||
# 调用前端的消息处理函数
|
||
js_code = f"""
|
||
try {{
|
||
if (typeof app_sendMessage !== 'undefined' && typeof app_sendMessage === 'function') {{
|
||
app_sendMessage('{message}');
|
||
}}
|
||
}} catch (e) {{
|
||
console.error('Error calling app_sendMessage:', e);
|
||
}}
|
||
"""
|
||
self.page.runJavaScript(js_code)
|
||
|