Commit 3f5a68fb authored by lixiaofang's avatar lixiaofang

add

parent 8e64ed4a
......@@ -55,7 +55,8 @@ def kafka_consum(topic_name=None):
current_push_time = card_info['current_push_time']
create_time = card_info['create_time']
# nowtime = datetime.datetime.now()
nowtime = datetime.datetime.now() + datetime.timedelta(days=1)
nowtime = datetime.datetime.now() + datetime.timedelta(days=1) + datetime.timedelta(
hours=5)
push_time_date = datetime.datetime.strptime(current_push_time, '%Y-%m-%d %H:%M:%S')
if push_time_date <= nowtime: # push_time已经到时间了 需要去下发
......
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