yumoqing/sage
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

bugfix

Browse Source
This commit is contained in:
yumoqing 2026-03-02 18:59:07 +08:00
parent f804de7752
commit 9702b47015
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
app/sage.py
View File

@ -36,9 +36,7 @@ __version__ = '0.0.1'
async def run_zmq_proxy(app): async def run_zmq_proxy(app):
task = asyncio.create_task(run_proxy()) task = asyncio.create_task(run_proxy())
app['zmq_proxy_task'] = task app['zmq_proxy_task'] = task
print('TTTTTTTTTTTTTTTTTT')
task1 = asyncio.create_task(woa_msghande()) task1 = asyncio.create_task(woa_msghande())
print('KKKKKKKKKKKKKKKKKK')
yield yield
task1.cancel() task1.cancel()
task.cancel() task.cancel()
@ -48,6 +46,7 @@ async def woa_msghande():
config = getConfig() config = getConfig()
while True: while True:
msgstr = await zmq_subscribe(config.woa_handler_id) msgstr = await zmq_subscribe(config.woa_handler_id)
debug(f'收到sage转发微信信息:{msgstr}, {type(msgstr)}')
msgdic = json.loads(msgstr) msgdic = json.loads(msgstr)
# 这里按照业务逻辑处理收到的msg # 这里按照业务逻辑处理收到的msg
debug(f'received wechat msgs={msgstr}') debug(f'received wechat msgs={msgstr}')