# 腾讯充值记录查询系统设计 ## 基础实现方案 ```python import sqlite3 from datetime import datetime class TencentRechargeQuery: def __init__(self, db_name='tencent_recharge.db'): self.conn = sqlite3.connect(db_name) self.create_table() def create_table(self): cursor = self.conn.cursor() cursor.execute(''' CREATE TABLE IF NOT EXISTS recharge_records ( id INTEGER PRIMARY KEY AUTOINCREMENT, user_id TEXT NOT NULL, amount REAL NOT NULL, recharge_time DATETIME NOT NULL, payment_method TEXT NOT NULL, order_id TEXT UNIQUE NOT NULL, status TEXT NOT NULL, product_name TEXT, remarks TEXT ) ''') self.conn.commit() def add_record(self, user_id, amount, payment_method, order_id, product_name=None, remarks=None): cursor = self.conn.cursor() cursor.execute(''' INSERT INTO recharge_records (user_id, amount, recharge_time, payment_method, order_id, status, product_name, remarks) VALUES (?, ?, ?, ?, ?, ?, ?, ?) ''', (user_id, amount, datetime.now(), payment_method, order_id, 'completed', product_name, remarks)) self.conn.commit() def query_by_user(self, user_id, start_date=None, end_date=None): cursor = self.conn.cursor() query = 'SELECT * FROM recharge_records WHERE user_id = ?' params = [user_id] if start_date: query += ' AND recharge_time >= ?' params.append(start_date) if end_date: query += ' AND recharge_time <= ?' params.append(end_date) query += ' ORDER BY recharge_time DESC' cursor.execute(query, params) return cursor.fetchall() def query_by_order(self, order_id): cursor = self.conn.cursor() cursor.execute('SELECT * FROM recharge_records WHERE order_id = ?', (order_id,)) return cursor.fetchone() def close(self): self.conn.close() ``` ## 使用示例 ```python # 初始化查询系统 query_system = TencentRechargeQuery() # 添加充值记录 query_system.add_record( user_id='user123', amount=100.0, payment_method='WeChat Pay', order_id='ORD20231101001', product_name='QQ会员年费', remarks='自动续费' ) # 查询用户充值记录 records = query_system.query_by_user('user123') for record in records: print(record) # 查询特定订单 order = query_system.query_by_order('ORD20231101001') print(order) # 关闭连接 query_system.close() ``` ## 注意事项 1. 实际生产环境中应使用更安全的数据库连接方式，考虑连接池和异常处理 2. 腾讯官方API会有请求频率限制，需要实现合理的请求间隔和错误重试机制 3. 敏感数据如用户ID和订单信息应进行加密存储，确保符合数据保护法规 [2025-06-07 20:58:31 | AI写代码神器 | 682点数解答]