Commit 139f7024 authored by 陈涛's avatar 陈涛

修改bug

parent e9a953fd
...@@ -130,10 +130,11 @@ async def calculate_nav(fund_id, calc_time: datetime.datetime = None, beach_serv ...@@ -130,10 +130,11 @@ async def calculate_nav(fund_id, calc_time: datetime.datetime = None, beach_serv
async def query_nav_record(nav_collect, fund_id, record_time, settlement_time): async def query_nav_record(nav_collect, fund_id, record_time, settlement_time):
# record_date 12 re
record_date = timestamp_to_datetime(record_time) record_date = timestamp_to_datetime(record_time)
re_time = int(re.findall(r"(\d+):00", settlement_time)[0]) re_time = int(re.findall(r"(\d+):00", settlement_time)[0])
if record_date.hour < re_time: if record_date.hour >= re_time:
record_date += datetime.timedelta(days=-1) record_date += datetime.timedelta(days=1)
start_date = record_date.replace(hour=0, minute=0, second=0, microsecond=0, tzinfo=pytz.UTC) start_date = record_date.replace(hour=0, minute=0, second=0, microsecond=0, tzinfo=pytz.UTC)
cursor = nav_collect.find({"fund_id": fund_id, "record_date": {"$gte": start_date}}) cursor = nav_collect.find({"fund_id": fund_id, "record_date": {"$gte": start_date}})
nav_result = await cursor.to_list(length=None) nav_result = await cursor.to_list(length=None)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment