add

vest/request/auto_request.py

@@ -25,26 +25,26 @@ auto_reply_url = "http://earth.gmapp.env/api/v1/reply/create"
 auto_follow_url = "http://earth.gmapp.env/api/v1/follow"
 auto_urge_url = "http://earth.gmapp.env/api/v1/user/urge"
 
-# DATABASES = {
-#     'default': {
-#         'ENGINE': 'django.db.backends.mysql',
-#         'NAME': 'alpha',
-#         'USER': 'work',
-#         'PASSWORD': 'Gengmei123!',
-#         'HOST': 'bj-cdb-55ejhsjy.sql.tencentcdb.com',
-#         'PORT': '62177',
-#         'OPTIONS': {
-#             "init_command": "SET foreign_key_checks = 0;",
-#             "charset": "utf8mb4",
-#         },
-#     }
-# }
+DATABASES = {
+    'default': {
+        'ENGINE': 'django.db.backends.mysql',
+        'NAME': 'alpha',
+        'USER': 'work',
+        'PASSWORD': 'Gengmei123!',
+        'HOST': 'bj-cdb-55ejhsjy.sql.tencentcdb.com',
+        'PORT': '62177',
+        'OPTIONS': {
+            "init_command": "SET foreign_key_checks = 0;",
+            "charset": "utf8mb4",
+        },
+    }
+}
 
 # auto_click_url = "http://earth.iyanzhi.com/api/v1/like"
 # auto_reply_url = "http://earth.iyanzhi.com/api/v1/reply/create"
 # auto_follow_url = "http://earth.iyanzhi.com/api/v1/follow"
 # auto_urge_url = "http://earth.iyanzhi.com/api/v1/user/urge"
-
+#
 # DATABASES = {
 #     'default': {
 #         'ENGINE': 'django.db.backends.mysql',
@@ -132,7 +132,6 @@ def login():
 def logins(user_id):
     try:
         cookies = get_cookies(user_id)
-        # cookies = "yhlcnc7q3louskthgpjguoi5n7r326cm"
         if cookies is not None:
             return {'sessionid': cookies}
 

vest/request/auto_user_id.py

 import pymysql
 import traceback
 import logging
+import json
 from vest.request.auto_request import host, user, db, passwd
 from libs.cache import redis_client
 from libs.error import logging_exception
@@ -38,7 +39,7 @@ def auto_user_id():
             for i in data:
                 file.write(str(i[0]))
                 file.write("\n")
-        redis_client.set("get_user_id_data", data)
+        redis_client.set("get_user_id_data", json.dumps(data))
 
     except:
         logging_exception()

vest/vest_majiauser/vest_click_reply.py

@@ -3,7 +3,9 @@ import pymysql
 import random
 import traceback
 import logging
+import json
 import datetime
+from libs.cache import redis_client
 from vest.request.auto_request import get_offline_comment
 from vest.request.auto_request import host, user, db, passwd
 from libs.error import logging_exception
@@ -61,14 +63,22 @@ def vest_click_reply():
         logging.info("get majia data11111111111")
         now = datetime.datetime.now()
         yes_time = now - datetime.timedelta(minutes=5)
-        user_data = open("/srv/apps/physical/vest/data/get_user_id.txt", "r")
+
+        data = json.loads(redis_client.get("get_user_id_data"))
+
+        logging.info("get data-----------vest:%s" % data)
+        # user_data = open("/srv/apps/physical/vest/data/get_user_id.txt", "r")
+
         user_list = []
-        for i in user_data.readlines():
+        for i in data.readlines():
             user_list.append(i)
+
+        logging.info("get user_list-----------vest:%s" % user_list)
+
         topic_id = get_data(yes_time, now)
         if topic_id:
             for id in topic_id:
-                rand_num = random.randint(1, 3)
+                rand_num = random.randint(0, 4)
                 for i in range(rand_num):
                     num = random.randint(0, len(user_list) - 1)
                     user_id = user_list[num]