add

app_conf.xml

@@ -17,6 +17,5 @@
         <element value="search.views.contrast_similar"/>
         <element value="injection.data_sync.tasks"/>
         <element value="search.views.contrast_similar"/>
-        <!--<element value="majia..tasks.tasks"/>-->
     </config>
 </gm_rpcd_config>

injection/data_sync/tasks.py

@@ -11,8 +11,8 @@ 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 majia.tasks import auto_click
-
+# from majia.get_session import get_comments, click, login
+# from majia.get_session import host, user, passwd, db
 
 
 @shared_task
@@ -35,8 +35,8 @@ def write_to_es(es_type, pk_list, use_batch_query_set=False):
                 use_batch_query_set=use_batch_query_set,
                 es=ESPerform.get_cli()
             )
-        auto_click(pk_list)
-        logging.info("-----------------")
+        # auto_click(pk_list)
+        # logging.info("-----------------")
 
     except:
         logging.error("catch exception,err_msg:%s" % traceback.format_exc())
@@ -73,6 +73,7 @@ def sync_face_similar_data_to_redis():
     except:
         logging.error("catch exception,err_msg:%s" % traceback.format_exc())
 
+
 @shared_task
 def sync_user_similar_score():
     try:
@@ -96,3 +97,49 @@ def sync_user_similar_score():
     except:
         logging.error("catch exception,err_msg:%s" % traceback.format_exc())
 
+@shared_task
+def auto_click(pk_list):
+    logging.info("get----------------------:%s" % pk_list)
+    exec_count = 0
+    # try:
+        # 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)")
+        # 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_timer():
+        #         cookies = login()
+        #         if cookies:
+        #             click(cookies, topic_id_list[0])
+        #
+        #         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_timer)
+        #             timer.start()
+        #
+        #         if exec_count == 2:
+        #             # sleep_time = random.randint(1000, 1900)
+        #             sleep_time = 50
+        #             timer = threading.Timer(sleep_time, fun_timer)
+        #             timer.start()
+        #
+        #     sleep_time = random.randint(300, 540)
+        #     timer = threading.Timer(10, fun_timer)  # 首次启动
+        #     timer.start()
+
+    #     else:
+    #         pass
+    # except:
+    #     logging.error("catch exception,main:%s" % traceback.format_exc())
\ No newline at end of file

physical/celery_task_router.py

@@ -10,9 +10,9 @@ class CeleryTaskRouter(object):
         "tapir-alpha": [
             'injection.data_sync.tasks.write_to_es',
         ],
-        # "majia-alpha": [
-        #     'majia.tasks.auto_majia_effect',
-        # ],
+        "majia-alpha": [
+            'majia.tasks.auto_majia_effect',
+        ],
     }
 
     # Map[TaskName, QueueName]