reply_comment3.py

import traceback
import json
import logging
from vest.request.auto_request import set_reply_to_redis, reply2, logins, get_majia_reply
from libs.error import logging_exception


def reply_comment3():
    try:
        redis_key1 = "cybertron:set_reply_id:three"
        redis_client = set_reply_to_redis()
        have_reply1 = redis_client.get(redis_key1)
        if have_reply1 == None:
            pass
        else:
            result = json.loads(str(have_reply1, encoding="utf-8"))
            if result:
                for item in result:
                    majia_user_id = get_majia_reply(item["majia_user_id"])
                    cook = logins(majia_user_id)
                    reply2(cook, item["topic_id"], item["answer"], item["id"])
                redis_client.delete(redis_key1)
    except:
        logging_exception()
        logging.error("catch exception,main:%s" % traceback.format_exc())