发送消息

python/mcu/BaseClass.py

@@ -1,14 +1,17 @@
 import asyncio
 from sockets import ConnectionManager
+from utils.common import message_queue
+
 class BaseClass:
 
     def __init__(self, websocket_manager: ConnectionManager):
         self.websocket_manager = websocket_manager
 
-    def sendSocketMessage(self, code=0, msg="", data=None):
-        data = {"code": code, "msg": msg, "data": data}
-        loop = asyncio.get_event_loop()
-        loop.create_task(self.websocket_manager.broadcast(data))
+    def sendSocketMessage(self, code=0, msg="", data=None, msg_type=""):
+        data = {"code": code, "msg": msg, "data": data, "msg_type": msg_type}
+        # loop = asyncio.get_event_loop()
+        # loop.create_task(self.websocket_manager.broadcast(data))
+        await message_queue.put(data)
     def change_hex_to_int(self,_bytearray):
         return ' '.join([hex(x) for x in _bytearray])