diff --git a/message_storage/message_to_db.py b/message_storage/message_to_db.py index fc65613..406c095 100644 --- a/message_storage/message_to_db.py +++ b/message_storage/message_to_db.py @@ -62,7 +62,8 @@ class MessageStorage: return { 'success': result, 'roomid': msg.roomid, - 'sender': msg.sender + 'sender': msg.sender, + 'content': msg.content # 添加消息内容 } except Exception as e: logger.error(f"存档消息出错: {e}") @@ -70,6 +71,7 @@ class MessageStorage: 'success': False, 'roomid': msg.roomid, 'sender': msg.sender, + 'content': msg.content, # 添加消息内容 'error': str(e) } @@ -78,7 +80,8 @@ class MessageStorage: try: result = future.result() if result['success']: - logger.info(f"消息存档成功: {result['roomid']}:{result['sender']}") + # 修改日志输出,包含消息内容 + logger.info(f"消息存档成功: {result['roomid']}:{result['sender']}: {result['content']}") else: error_msg = result.get('error', '未知错误') logger.error(f"消息存档失败: {result['roomid']}:{result['sender']} - {error_msg}")