This commit is contained in:
yumoqing 2026-03-27 13:34:51 +08:00
parent accb61a398
commit 692bc58818

View File

@ -78,15 +78,15 @@ async def uptask_feedback(task_id, resp_data):
await sor.U('uptask', lt.copy()) await sor.U('uptask', lt.copy())
async def get_my_uptasks(userid, biz_date): async def get_my_uptasks(userid, biz_date):
env = ServerEnv() env = ServerEnv()
begin = f'{biz_date} 00:00:00.000' begin = f'{biz_date} 00:00:00.000'
end = f'{biz_date} 24:00:00.999 end = f'{biz_date} 24:00:00.999
sql = """select * from uptask sql = """select * from uptask
where userid=${userid} where userid=${userid}
and start_timestamp >= ${begin}$ and start_timestamp >= ${begin}$
and start_timestamp ${end}$""" and start_timestamp ${end}$"""
async with get_sor_context(env, 'longtasks') as sor: async with get_sor_context(env, 'longtasks') as sor:
recs = await sor.R(sql, {'userid': userid, 'biz_date': biz_date}) recs = await sor.R(sql, {'userid': userid, 'biz_date': biz_date})
return recs return recs
return [] return []