This commit is contained in:
yumoqing 2026-05-24 23:56:40 +08:00
parent ac9a0e9fd3
commit f565672aa1

View File

@ -6,7 +6,7 @@ from datetime import datetime, timedelta, date
async def get_today_usage(request): async def get_today_usage(request):
"""获取当天llmusage笔数""" """获取当天llmusage笔数"""
today = date.today().isoformat() today = env.curDateString()
env = request._run_ns env = request._run_ns
async with get_sor_context(env, 'sage') as sor: async with get_sor_context(env, 'sage') as sor:
sql = "SELECT COUNT(*) as cnt FROM llmusage WHERE use_date = ${today}$" sql = "SELECT COUNT(*) as cnt FROM llmusage WHERE use_date = ${today}$"
@ -17,7 +17,7 @@ async def get_today_usage(request):
async def get_today_amount(request): async def get_today_amount(request):
"""获取当天交易金额""" """获取当天交易金额"""
today = date.today().isoformat() today = env.curDateString()
env = request._run_ns env = request._run_ns
async with get_sor_context(env, 'sage') as sor: async with get_sor_context(env, 'sage') as sor:
sql = "SELECT COALESCE(SUM(amount), 0) as total_amount FROM llmusage WHERE use_date = ${today}$" sql = "SELECT COALESCE(SUM(amount), 0) as total_amount FROM llmusage WHERE use_date = ${today}$"
@ -40,7 +40,7 @@ async def get_concurrent_users(request):
"""获取当前并发用户数近5分钟有活跃记录的用户""" """获取当前并发用户数近5分钟有活跃记录的用户"""
now = datetime.now() now = datetime.now()
five_min_ago = (now - timedelta(minutes=5)).strftime('%Y-%m-%d %H:%M:%S') five_min_ago = (now - timedelta(minutes=5)).strftime('%Y-%m-%d %H:%M:%S')
today = now.strftime('%Y-%m-%d') today = env.curDateString()
env = request._run_ns env = request._run_ns
async with get_sor_context(env, 'sage') as sor: async with get_sor_context(env, 'sage') as sor:
sql = """ sql = """
@ -56,7 +56,8 @@ async def get_concurrent_users(request):
async def get_top_models(request): async def get_top_models(request):
"""获取当天排名前三的模型返回记录列表供ChartBar使用""" """获取当天排名前三的模型返回记录列表供ChartBar使用"""
today = date.today().isoformat() # today = date.today().isoformat()
today = env.curDateString()
env = request._run_ns env = request._run_ns
async with get_sor_context(env, 'sage') as sor: async with get_sor_context(env, 'sage') as sor:
sql = """ sql = """
@ -84,7 +85,7 @@ async def get_top_models(request):
async def get_accounting_errors(request): async def get_accounting_errors(request):
"""获取当天记账错误笔数accounting_status='failed'""" """获取当天记账错误笔数accounting_status='failed'"""
today = date.today().isoformat() today = env.curDateString()
env = request._run_ns env = request._run_ns
async with get_sor_context(env, 'sage') as sor: async with get_sor_context(env, 'sage') as sor:
sql = "SELECT COUNT(*) as cnt FROM llmusage WHERE use_date = ${today}$ AND accounting_status = 'failed'" sql = "SELECT COUNT(*) as cnt FROM llmusage WHERE use_date = ${today}$ AND accounting_status = 'failed'"