add

injection/data_sync/tasks.py

@@ -5,6 +5,7 @@ import json
 import pymysql
 import threading
 import random
+import datetime
 from celery import shared_task
 from django.conf import settings
 from django.core import serializers
@@ -14,7 +15,7 @@ from libs.es import ESPerform
 from libs.cache import redis_client
 from trans2es.models.face_user_contrast_similar import FaceUserContrastSimilar, UserSimilarScore
 from linucb.utils.register_user_tag import RegisterUserTag
-from injection.data_sync.get_session import get_comments, click, login
+from injection.data_sync.get_session import get_comments, click, login, reply
 from injection.data_sync.get_session import host, user, passwd, db
 
 
@@ -104,14 +105,16 @@ def sync_user_similar_score():
 
 
 def auto_click(pk_list):
-    logging.info("get----------------------:%s" % pk_list)
+    logging.info("get--------auto_click--------------:%s" % pk_list)
     exec_count = 0
     try:
+        now = datetime.datetime.now()
         pc = pymysql.connect(host=host, user=user, passwd=passwd, db=db, port=3306)
         cursor = pc.cursor()
         cursor.execute(
             "SELECT id,user_id FROM topic WHERE id  in  " + str(
-                tuple(pk_list)) + "  and user_id in (select user_id from user_extra  where is_shadow = 0)")
+                tuple(
+                    pk_list)) + "  and user_id in (select user_id from user_extra  where is_shadow = 0) and create_time  > '%s' " % now)
         data = cursor.fetchall()
         topic_id_list = list(data)
         logging.info("Database version : %s " % topic_id_list)
@@ -151,3 +154,54 @@ def auto_click(pk_list):
             pass
     except:
         logging.error("catch exception,main:%s" % traceback.format_exc())
+
+
+def auto_reply(pk_list):
+    logging.info("get----------------------:%s" % pk_list)
+
+    exec_count = 0
+    try:
+        now = datetime.datetime.now()
+        pc = pymysql.connect(host=host, user=user, passwd=passwd, db=db, port=3306)
+        cursor = pc.cursor()
+        cursor.execute(
+            "SELECT id,user_id FROM topic WHERE id in  " + str(
+                tuple(
+                    pk_list)) + " and user_id in (select user_id from user_extra  where is_shadow = 0) and create_time > '%s'" % now)
+        data = cursor.fetchall()
+        topic_id_list = list(data)
+        logging.info("Database version : %s " % topic_id_list)
+        pc.close()
+        exec_count = 0
+        if topic_id_list:
+
+            def fun_comment():
+                cookies = login()
+                if cookies:
+                    comment_content = get_comments()
+                    comment = comment_content[0]
+                    reply(cookies, topic_id_list[0], comment)
+
+                global timer
+                global exec_count
+
+                exec_count += 1
+                if exec_count == 1:
+                    sleep_time = random.randint(300, 540)
+                    sleep_time = 30
+                    timer = threading.Timer(sleep_time, fun_comment)
+                    timer.start()
+
+                if exec_count == 2:
+                    sleep_time = random.randint(1000, 1900)
+                    sleep_time = 30
+                    timer = threading.Timer(sleep_time, fun_comment)
+                    timer.start()
+
+            sleep_time = random.randint(300, 540)
+            timer = threading.Timer(10, fun_comment)  # 首次启动
+            timer.start()
+
+
+    except:
+        logging.error("catch exception,main:%s" % traceback.format_exc())