Commit 8e64ed4a authored by lixiaofang's avatar lixiaofang

add

parent ad7575c7
......@@ -54,7 +54,9 @@ def kafka_consum(topic_name=None):
card_info['card_status'] = 'answer'
current_push_time = card_info['current_push_time']
create_time = card_info['create_time']
nowtime = datetime.datetime.now()
# nowtime = datetime.datetime.now()
nowtime = datetime.datetime.now() + datetime.timedelta(days=1)
push_time_date = datetime.datetime.strptime(current_push_time, '%Y-%m-%d %H:%M:%S')
if push_time_date <= nowtime: # push_time已经到时间了 需要去下发
# 判断如果当前的push_time 和当前的创建时间一样 需要给push_time下发真的push时间
......@@ -139,6 +141,3 @@ def kafka_consum(topic_name=None):
consumser_obj.close()
logging_exception()
logging.error("catch exception,err_msg:%s" % traceback.format_exc())
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