add

injection/data_sync/tasks.py

@@ -121,35 +121,36 @@ def auto_click(pk_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:
-                    logging.info("----------2-----------")
-                    # 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)
-                    logging.info("----------3-----------")
-                    sleep_time = 50
-                    timer = threading.Timer(sleep_time, fun_timer)
-                    timer.start()
-
-            sleep_time = random.randint(300, 540)
-            logging.info("----------1-----------")
-            timer = threading.Timer(10, fun_timer)  # 首次启动
-            timer.start()
-
+            try:
+                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:
+                        logging.info("----------2-----------")
+                        # 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)
+                        logging.info("----------3-----------")
+                        sleep_time = 50
+                        timer = threading.Timer(sleep_time, fun_timer)
+                        timer.start()
+
+                sleep_time = random.randint(300, 540)
+                logging.info("----------1-----------")
+                timer = threading.Timer(10, fun_timer)  # 首次启动
+                timer.start()
+            except:
+                logging.error("catch exception,main:%s" % traceback.format_exc())
         else:
             pass
     except:
@@ -167,41 +168,44 @@ def auto_reply(pk_list):
         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)
+                    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()
-
+            try:
+
+                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())
 
     except:
         logging.error("catch exception,main:%s" % traceback.format_exc())