three_days_ago_topic_reply.py 1.91 KB
import pymysql
import traceback
import logging
from vest.request.auto_request import logins, time_convs, get_comment, reply, get_product_comment, get_face_comment, \
    get_category_tag_id, get_category_reply_commtent, judge_topic_info_get_comment, get_majia_reply
from vest.request.auto_request import host, user, db, passwd
from libs.error import logging_exception
from vest.data.topic_models import get_edit_tag_id_list, get_pictorial_tag_by_id, get_topic_product_info, \
    topic_has_image
import random


def get_data(numtime, numtime2):
    try:
        print("....")
        pc = pymysql.connect(host=host, user=user, passwd=passwd, db=db, port=3306)
        cursor = pc.cursor()
        cursor.execute(
            "SELECT  user_id,id FROM topic WHERE  (create_time >= '%s' and create_time <= '%s' ) and is_online=1 " % (
                numtime2, numtime))
        data = cursor.fetchall()
        topic_id_list = list(data)
        return topic_id_list

    except:
        logging.error("catch exception,get_data:%s" % traceback.format_exc())
        return []


def three_days_ago_comment_one():
    try:
        logging.info("comment one")
        numtime, numtime2 = time_convs(3, 3)
        topic_id_list = get_data(numtime, numtime2)
        if topic_id_list:
            for i in topic_id_list:
                random_num = random.randint(0, 2)
                logging.info("get random_num:%s" % random_num)
                for num in range(random_num):
                    majia_user_id = get_majia_reply(i[0])
                    cook = logins(majia_user_id)
                    comment = judge_topic_info_get_comment(i[1])
                    if cook is not None:
                        reply(cook, i[1], comment)
            else:
                logging.error("catch exception,main:%s" % traceback.format_exc())
    except:
        logging_exception()
        logging.error("catch exception,main:%s" % traceback.format_exc())