db_results.py

import time
import asyncio

# 内存数据库，用于临时存储验证码结果
results_db = {}

async def init_db():
    print("[系统] 结果数据库初始化成功 (内存模式)")

async def save_result(task_id, task_type, data):
    # 存储结果，如果 data 是字典则存入，否则构造字典
    results_db[task_id] = data
    print(f"[系统] 任务 {task_id} 状态更新: {data.get('value', '正在处理')}")

async def load_result(task_id):
    return results_db.get(task_id)

async def cleanup_old_results(days_old=7):
    # 简单的清理逻辑
    now = time.time()
    to_delete = []
    for tid, res in results_db.items():
        if isinstance(res, dict) and now - res.get('createTime', now) > days_old * 86400:
            to_delete.append(tid)
    for tid in to_delete:
        del results_db[tid]
    return len(to_delete)