Skip to content

C
cybertron
Commit d5fc91c2 authored by lixiaofang's avatar lixiaofang
Browse files
Options

add

parent 2079f8f1
Expand all Hide whitespace changes
Inline Side-by-side
Showing with 117 additions and 1323 deletions
.idea/misc.xml
View file @ d5fc91c2
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="ProjectRootManager" version="2" project-jdk-name="Python 3.6 (code)" project-jdk-type="Python SDK" />
<component name="PyCharmProfessionalAdvertiser">
<option name="shown" value="true" />
</component>
</project>
\ No newline at end of file
.idea/workspace.xml
View file @ d5fc91c2
This diff is collapsed.
auto_at_once.py
View file @ d5fc91c2
......@@ -11,131 +11,12 @@ from auto_request import login, reply, click, get_comments, time_conv
from auto_request import host, user, port, db, passwd
# 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"
# def get_majia():
# try:
# data = open("/srv/apps/cybertron/batch_user_gen")
# list = []
# for i in data:
# list.append(i.strip('\n').strip(','))
# maj = random.randint(1, len(list))
# user_id = list[maj - 1]
# return user_id
#
# except:
# logging.error("catch exception,get_majia:%s" % traceback.format_exc())
# return None
#
#
# def get_cookies(user_id):
# try:
# with open("/srv/apps/cybertron/user_session.txt", 'r') as f:
# try:
# data = f.readlines()
# except:
# data = None
#
# list = []
# for i in data:
# list.append(i.strip('\n').split(","))
#
# for i in list:
#
# if user_id == i[0]:
# return (i[1])
# except:
#
# return None
#
#
# def login():
# try:
# user_id = get_majia()
#
# cookies = get_cookies(user_id)
#
# if cookies is not None:
# return {'sessionid': cookies}
#
# except:
#
# logging.error("catch exception,logins:%s" % traceback.format_exc())
#
# return None
#
#
# def click(cookies_get, id):
# try:
# post_dict = {
# 'type': 0,
# 'id': id
# }
# response = requests.post(url=auto_click_url,
# cookies=cookies_get,
# data=post_dict)
#
# logging.info("response.text:%s" % response.text)
#
# except:
#
# logging.error("catch exception,logins:%s" % traceback.format_exc())
#
#
# def reply(cookies_get, id, content):
# try:
# post_dict = {
# 'topic_id': id,
# 'content': content
# }
# response = requests.post(url=auto_reply_url,
# cookies=cookies_get,
# data=post_dict)
#
# logging.info("response.text:%s" % response.text)
#
# except:
#
# logging.error("catch exception,logins:%s" % traceback.format_exc())
#
#
# def time_conv():
# try:
# now = datetime.datetime.now()
# yes_time = now - datetime.timedelta(minutes=15)
# print(yes_time)
# return yes_time
#
# except:
# return None
#
#
# def get_comment():
# try:
# data = open("/srv/apps/cybertron/guanshui", "r")
# list_guanshui = []
# for i in data:
# list_guanshui.append(i)
# num = random.randint(0, len(list_guanshui))
# comment = list_guanshui[num - 1]
#
# return comment
#
# except:
#
# return None
# 9,12,18,2
def get_topic_id(numtime):
try:
pc = pymysql.connect(host=host, user=user, passwd=passwd, db=db, port=port)
cursor = pc.cursor()
cursor.execute(
"SELECT id,user_id FROM topic WHERE is_online =1 and create_time >= %s and user_id in (select user_id from user_extra where is_shadow = 0)",
"SELECT user_id ,id FROM topic WHERE is_online =1 and create_time >= %s and user_id in (select user_id from user_extra where is_shadow = 0)",
(numtime))
data = cursor.fetchall()
user_id = list(data)
......@@ -154,12 +35,11 @@ if __name__ == "__main__":
topic_id = get_topic_id(numtime)
click_num = random.randint(1, 3)
click_num = random.randint(1, 5)
for i in range(click_num):
for j in topic_id:
id = int(j[0])
cookies = login()
......@@ -185,13 +65,15 @@ if __name__ == "__main__":
cookies = login()
if cookies is not None:
comment = comment_content[i]
time.sleep(random.randint(10,20))
time.sleep(random.randint(10, 20))
reply(cookies, id, comment)
time.sleep(300)
except:
logging.error("catch exception,main:%s" % traceback.format_exc())
# 发帖瞬时：[1 - 5]个马甲点赞
# 1. 用户发帖后，[瞬时]，1-3条评论
auto_click.py
View file @ d5fc91c2
......@@ -7,91 +7,8 @@ import traceback
from log_settings import *
import logging
from auto_request import login, click, time_convs
from auto_request import host,user,port,db,passwd
# def get_majia():
# try:
# data = open("/srv/apps/cybertron/batch_user_gen")
#
# list = []
#
# for i in data:
# list.append(i.strip('\n').strip(','))
#
# maj = random.randint(1, len(list))
#
# user_id = list[maj - 1]
#
# return user_id
#
# except:
# logging.error("catch exception,get_majia:%s" % traceback.format_exc())
# return None
#
#
# def get_cookies(user_id):
# try:
# with open("/srv/apps/cybertron/user_session.txt", 'r') as f:
# try:
# data = f.readlines()
# except:
# data = None
#
# list = []
# for i in data:
# list.append(i.strip('\n').split(","))
#
# for i in list:
#
# if user_id == i[0]:
# return (i[1])
# except:
#
# return None
#
#
# def login():
# try:
# user_id = get_majia()
#
# cookies = get_cookies(user_id)
#
# if cookies is not None:
# return {'sessionid': cookies}
#
# except:
#
# logging.error("catch exception,logins:%s" % traceback.format_exc())
#
# return None
#
#
# def click(cookies_get, id):
# try:
# post_dict = {
# 'type': 0,
# 'id': id
# }
# response = requests.post(url=auto_click_url,
# cookies=cookies_get,
# data=post_dict)
#
# logging.info("response.text:%s" % response.text)
#
# except:
#
# logging.error("catch exception,logins:%s" % traceback.format_exc())
#
#
# def time_conv(numtime):
# try:
# now = datetime.datetime.now()
# yes_time = now - datetime.timedelta(days=numtime)
# yes_time_str = yes_time.strftime('%Y-%m-%d')
# return yes_time_str
# except:
# return None
from auto_request import host, user, port, db, passwd
def get_data(numtime):
try:
......@@ -132,8 +49,6 @@ if __name__ == "__main__":
else:
dicts[i[0]].append(i[1])
print(dicts)
for key, value in dicts.items():
rand_num = random.randint(0, len(value) - 1)
......@@ -153,3 +68,5 @@ if __name__ == "__main__":
except:
logging.error("catch exception,main:%s" % traceback.format_exc())
# 2. 每日一次轮询，昨、2、3、4、5、6、7日新增帖的用户：[0-1]个马甲点赞。每天每人最多一个帖子点赞，不要100个帖子都0-1。
auto_click_n.py
View file @ d5fc91c2
......@@ -6,93 +6,8 @@ import random
import traceback
import logging
from auto_request import login, click, time_convs
from auto_request import host,user,port,db,passwd
# def get_majia():
# try:
# data = open("/srv/apps/cybertron/batch_user_gen")
#
# list = []
#
# for i in data:
# list.append(i.strip('\n').strip(','))
#
# maj = random.randint(1, len(list))
#
# user_id = list[maj - 1]
#
# return user_id
#
# except:
# logging.error("catch exception,get_majia:%s" % traceback.format_exc())
# return None
#
#
# def get_cookies(user_id):
# try:
# with open("/srv/apps/cybertron/user_session.txt", 'r') as f:
# try:
# data = f.readlines()
# except:
# data = None
#
# list = []
# for i in data:
# list.append(i.strip('\n').split(","))
#
# for i in list:
#
# if user_id == i[0]:
# return (i[1])
# except:
#
# return None
#
#
# def logins():
# try:
# user_id = get_majia()
#
# cookies = get_cookies(user_id)
#
# if cookies is not None:
# return {'sessionid': cookies}
#
# except:
#
# logging.error("catch exception,logins:%s" % traceback.format_exc())
#
# return None
#
#
# def click(cookies_get, id):
# try:
# post_dict = {
# 'type': 0,
# 'id': id
# }
# response = requests.post(url=auto_click_url,
# cookies=cookies_get,
# data=post_dict)
#
# logging.info("response.text:%s" % response.text)
#
# except:
#
# logging.error("catch exception,logins:%s" % traceback.format_exc())
#
#
# def time_conv(numtime):
# try:
# now = datetime.datetime.now()
# yes_time = now - datetime.timedelta(days=numtime)
# yes_time_str = yes_time.strftime('%Y-%m-%d')
# return yes_time_str
# except:
# return None
#
from auto_request import host, user, port, db, passwd
def get_data(numtime):
try:
......@@ -100,7 +15,7 @@ def get_data(numtime):
cursor = pc.cursor()
cursor.execute(
"SELECT distinct(user_id),id FROM topic WHERE is_online=1 and create_time LIKE '%%%%%s%%%%' and user_id in (select user_id from user_extra where is_shadow = 0)" % numtime)
"SELECT user_id,id FROM topic WHERE is_online=1 and create_time LIKE '%%%%%s%%%%' and user_id in (select user_id from user_extra where is_shadow = 0)" % numtime)
data = cursor.fetchall()
user_id = list(data)
logging.info("Database version : %s " % user_id)
......@@ -151,8 +66,9 @@ if __name__ == "__main__":
cook = login()
if cook is not None:
click(cook, rand_id)
except:
logging.error("catch exception,main:%s" % traceback.format_exc())
# 7天后，每日一次轮询，3*n日前新增帖子：[0-1]个马甲点赞。每天每人最多一个帖子点赞。
auto_commnet.py
View file @ d5fc91c2
......@@ -9,109 +9,13 @@ from auto_request import login, time_convs, reply, get_comment
from auto_request import host, user, port, db, passwd
# auto_reply_url = "http://earth.iyanzhi.com/api/v1/reply/create"
# def get_majia():
# try:
# data = open("/srv/apps/cybertron/batch_user_gen.txt")
#
# list = []
#
# for i in data:
# list.append(i.strip('\n').strip(','))
#
# maj = random.randint(1, len(list))
#
# user_id = list[maj - 1]
#
# return user_id
#
# except:
# logging.error("catch exception,get_majia:%s" % traceback.format_exc())
# return None
#
#
# def get_cookies(user_id):
# try:
# with open("/srv/apps/cybertron/user_session.txt", 'r') as f:
# try:
# data = f.readlines()
# except:
# data = None
#
# list = []
# for i in data:
# list.append(i.strip('\n').split(","))
#
# for i in list:
#
# if user_id == i[0]:
# return (i[1])
# except:
#
# return None
#
#
# def logins():
# try:
# user_id = get_majia()
#
# cookies = get_cookies(user_id)
#
# if cookies is not None:
# return {'sessionid': cookies}
#
# except:
#
# logging.error("catch exception,logins:%s" % traceback.format_exc())
#
# return None
#
#
# def reply(cookies_get, id, content):
# try:
# post_dict = {
# 'topic_id': id,
# 'content': content
# }
# response = requests.post(url=auto_reply_url,
# cookies=cookies_get,
# data=post_dict)
#
# logging.info("response.text :%s" % (response.text))
#
# except:
# logging.error("catch exception,reply:%s" % traceback.format_exc())
#
#
# def time_conv(numtime):
# try:
# now = datetime.datetime.now()
# yes_time = now - datetime.timedelta(days=numtime)
# yes_time_str = yes_time.strftime('%Y-%m-%d')
# return yes_time_str
# except:
# return None
# def get_comment():
# data = open("/srv/apps/cybertron/guanshui")
#
# list_guanshui = []
# for i in data:
# list_guanshui.append(i)
# num = random.randint(0, len(list_guanshui))
# comment = list_guanshui[num - 1]
# return comment
def get_topic_id(numtime):
try:
pc = pymysql.connect(host=host, user=user, passwd=passwd, db=db, port=port)
cursor = pc.cursor()
cursor.execute(
"SELECT distinct(user_id),id FROM topic WHERE is_online=1 and create_time LIKE '%%%%%s%%%%' and user_id in (select user_id from user_extra where is_shadow = 0) " % numtime)
"SELECT user_id,id FROM topic WHERE is_online=1 and create_time LIKE '%%%%%s%%%%' and user_id in (select user_id from user_extra where is_shadow = 0) " % numtime)
data = cursor.fetchall()
topic_id = list(data)
logging.info("Database version : %s " % topic_id)
......@@ -134,18 +38,38 @@ if __name__ == "__main__":
topic_id = get_topic_id(numtime)
dicts = {}
for i in topic_id:
if i[0] not in dicts.keys():
dicts.setdefault(i[0], [])
dicts[i[0]].append(i[1])
else:
dicts[i[0]].append(i[1])
comment = get_comment()
for id in topic_id:
for key, value in dicts.items():
time.sleep(random.randint(1, 10))
rand_num = random.randint(0, len(value) - 1)
cook = login()
rand_id = value[rand_num]
if cook is not None:
for i in range(1):
reply(cook, id, comment)
time.sleep(random.randint(10, 20))
cook = login()
if cook is not None:
reply(cook, id, comment)
except:
logging.error("catch exception,main :%s" % traceback.format_exc())
#. 每日一次轮询，昨、2、3、4、5、6、7日新增帖的用户：随机从马甲库里取一个马甲，搭配随机评论库一条评论。每天每人最多一个帖子被评论。
\ No newline at end of file
auto_every_day.py
View file @ d5fc91c2
......@@ -10,95 +10,6 @@ from auto_request import login, time_convs, follow
from auto_request import host, user, port, db, passwd
# auto_follow_url = "http://earth.iyanzhi.com/api/v1/follow"
#
# auto_pick_url = "http://earth.iyanzhi.com/api/v1/pick/do_pick"
#
#
# def get_majia():
# try:
# data = open("/srv/apps/cybertron/batch_user_gen")
#
# list = []
#
# for i in data:
# list.append(i.strip('\n').strip(','))
#
# maj = random.randint(1, len(list))
#
# user_id = list[maj - 1]
#
# return user_id
#
# except:
# logging.error("catch exception,get_majia:%s" % traceback.format_exc())
# return None
#
#
# def get_cookies(user_id):
# try:
# with open("/srv/apps/cybertron/user_session.txt", 'r') as f:
# try:
# data = f.readlines()
# except:
# data = None
#
# list = []
# for i in data:
# list.append(i.strip('\n').split(","))
#
# for i in list:
#
# if user_id == i[0]:
# return (i[1])
# except:
#
# return None
#
#
# def logins():
# try:
# user_id = get_majia()
#
# cookies = get_cookies(user_id)
#
# if cookies is not None:
# return {'sessionid': cookies}
#
# except:
#
# logging.error("catch exception,logins:%s" % traceback.format_exc())
#
# return None
#
#
# def follow(cookies_get, id):
# try:
# post_dict = {
# 'type': 1,
# 'id': id
# }
# response = requests.post(url=auto_follow_url,
# cookies=cookies_get,
# data=post_dict)
#
# logging.info("response.text:%s" % response.text)
#
# except:
#
# logging.error("catch exception,logins:%s" % traceback.format_exc())
#
#
# def time_conv(numtime):
# try:
# now = datetime.datetime.now()
# yes_time = now - datetime.timedelta(days=numtime)
# yes_time_str = yes_time.strftime('%Y-%m-%d')
# return yes_time_str
# except:
# return None
def get_topic_new_user(numtime):
try:
pc = pymysql.connect(host=host, user=user, passwd=passwd, db=db, port=port)
......
auto_follow.py
View file @ d5fc91c2
......@@ -10,95 +10,6 @@ from auto_request import login, time_convs, follow
from auto_request import host, user, port, db, passwd
# auto_follow_url = "http://earth.iyanzhi.com/api/v1/follow"
#
#
#
# def get_majia():
#
# try:
# data = open("/srv/apps/cybertron/batch_user_gen")
#
# list=[]
#
# for i in data:
# list.append(i.strip('\n').strip(','))
#
# maj = random.randint(1,len(list))
#
# user_id=list[maj-1]
#
# return user_id
#
# except:
# logging.error("catch exception,get_majia:%s" % traceback.format_exc())
# return None
#
# def get_cookies(user_id):
#
# try:
# with open("/srv/apps/cybertron/user_session.txt", 'r') as f:
# try:
# data = f.readlines()
# except:
# data = None
#
# list = []
# for i in data:
# list.append(i.strip('\n').split(","))
#
# for i in list:
#
# if user_id == i[0]:
#
# return (i[1])
# except:
#
# return None
#
# def logins():
#
# try:
# user_id=get_majia()
#
# cookies = get_cookies(user_id)
#
# if cookies is not None:
#
# return {'sessionid': cookies}
#
# except:
#
# logging.error("catch exception,logins:%s" % traceback.format_exc())
#
# return None
#
# def follow(cookies_get, id):
#
# try:
# post_dict = {
# 'type': 1,
# 'id': id
# }
# response = requests.post(url=auto_follow_url,
# cookies=cookies_get,
# data=post_dict)
#
# logging.info("response.text:%s" % response.text)
#
# except:
#
# logging.error("catch exception,logins:%s" % traceback.format_exc())
#
# def time_conv(numtime):
# try:
# now = datetime.datetime.now()
# yes_time = now - datetime.timedelta(days=numtime)
# yes_time_str = yes_time.strftime('%Y-%m-%d')
# return yes_time_str
# except:
# return None
def get_data(numtime):
try:
......
auto_follow_majia.py
View file @ d5fc91c2
......@@ -11,71 +11,6 @@ from auto_request import login, time_conv, follow
from auto_request import host, user, port, db, passwd
# 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"
#
#
# def get_cookies(user_id):
# try:
# with open("/srv/apps/cybertron/user_session.txt", 'r') as f:
# try:
# data = f.readlines()
# except:
# data = None
#
# list = []
# for i in data:
# list.append(i.strip('\n').split(","))
#
# for i in list:
#
# if user_id == i[0]:
# return (i[1])
# except:
#
# return None
#
#
# def logins(user_id):
# try:
# cookies = get_cookies(user_id)
#
# if cookies is not None:
# return {'sessionid': cookies}
#
# except:
#
# logging.error("catch exception,logins:%s" % traceback.format_exc())
#
# return None
#
#
# def follow(cookies_get, id):
# try:
# post_dict = {
# 'type': 1,
# 'id': id
# }
# response = requests.post(url=auto_follow_url,
# cookies=cookies_get,
# data=post_dict)
#
# logging.info("response.text:%s" % response.text)
#
# except:
#
# logging.error("catch exception,logins:%s" % traceback.format_exc())
#
#
# def time_conv():
# try:
# now = datetime.datetime.now()
# yes_time = now - datetime.timedelta(minutes=15)
# return yes_time
# except:
# return None
def get_follw_majia(numtime):
try:
pc = pymysql.connect(host=host, user=user, passwd=passwd, db=db, port=port)
......
auto_follow_new.py
View file @ d5fc91c2
......@@ -9,93 +9,6 @@ import logging
from auto_request import login, time_convs, follow
from auto_request import host, user, port, db, passwd
# auto_follow_url = "http://earth.iyanzhi.com/api/v1/follow"
#
#
# def get_majia():
# try:
# data = open("/srv/apps/cybertron/batch_user_gen")
#
# list = []
#
# for i in data:
# list.append(i.strip('\n').strip(','))
#
# maj = random.randint(1, len(list))
#
# user_id = list[maj - 1]
#
# return user_id
#
# except:
# logging.error("catch exception,get_majia:%s" % traceback.format_exc())
# return None
#
#
# def get_cookies(user_id):
# try:
# with open("/srv/apps/cybertron/user_session.txt", 'r') as f:
# try:
# data = f.readlines()
# except:
# data = None
#
# list = []
# for i in data:
# list.append(i.strip('\n').split(","))
#
# for i in list:
#
# if user_id == i[0]:
# return (i[1])
# except:
#
# return None
#
#
# def logins():
# try:
# user_id = get_majia()
#
# cookies = get_cookies(user_id)
#
# if cookies is not None:
# return {'sessionid': cookies}
#
# except:
#
# logging.error("catch exception,logins:%s" % traceback.format_exc())
#
# return None
#
#
# def follow(cookies_get, id):
# try:
# post_dict = {
# 'type': 1,
# 'id': id
# }
# response = requests.post(url=auto_follow_url,
# cookies=cookies_get,
# data=post_dict)
#
# logging.info("response.text:%s" % response.text)
#
# except:
#
# logging.error("catch exception,logins:%s" % traceback.format_exc())
#
#
# def time_conv(numtime):
# try:
# now = datetime.datetime.now()
# yes_time = now - datetime.timedelta(days=numtime)
# yes_time_str = yes_time.strftime('%Y-%m-%d')
# return yes_time_str
# except:
# return None
def get_commnet_id(numtime):
......
auto_follow_one.py
View file @ d5fc91c2
......@@ -10,98 +10,12 @@ from auto_request import login, time_conv, follow,get_cookies
from auto_request import host, user, port, db, passwd
#
# auto_follow_url = "http://earth.iyanzhi.com/api/v1/follow"
#
# def get_majia():
#
# try:
# data = open("/srv/apps/cybertron/batch_user_gen")
#
# list=[]
#
# for i in data:
# list.append(i.strip('\n').strip(','))
#
# maj = random.randint(1,len(list))
#
# user_id=list[maj-1]
#
# return user_id
#
# except:
# logging.error("catch exception,get_majia:%s" % traceback.format_exc())
# return None
#
# def get_cookies(user_id):
#
# try:
# with open("/srv/apps/cybertron/user_session.txt", 'r') as f:
# try:
# data = f.readlines()
# except:
# data = None
#
# list = []
# for i in data:
# list.append(i.strip('\n').split(","))
#
# for i in list:
#
# if user_id == i[0]:
#
# return (i[1])
# except:
#
# return None
#
# def logins():
#
# try:
# user_id=get_majia()
#
# cookies = get_cookies(user_id)
#
# if cookies is not None:
#
# return {'sessionid': cookies}
#
# except:
#
# logging.error("catch exception,logins:%s" % traceback.format_exc())
#
# return None
#
# def follow(cookies_get, id):
# try:
# post_dict = {
# 'type': 1,
# 'id': id
# }
# response = requests.post(url=auto_follow_url,
# cookies=cookies_get,
# data=post_dict)
#
# logging.info("response.text:%s" % response.text)
#
# except:
#
# logging.error("catch exception,logins:%s" % traceback.format_exc())
#
# def time_conv(numtime):
# try:
# now = datetime.datetime.now()
# yes_time = now - datetime.timedelta(days=numtime)
# yes_time_str = yes_time.strftime('%Y-%m-%d')
# return yes_time_str
# except:
# return None
def get_data(numtime):
try:
pc = pymysql.connect(host=host, user=user, passwd=passwd, db=db, port=port)
cursor = pc.cursor()
cursor.execute("select user_id from account_user_auth where user_id not in (select user_id from pv_maidian where page_name ='home' and partiton_date >= %s ) and user_id in (select user_id from user_extra where is_shadow = 0)" ,(numtime))
cursor.execute("select distinct(user_id) from account_user_auth where user_id not in (select user_id from pv_maidian where page_name ='home' and partiton_date >= %s ) and user_id in (select user_id from user_extra where is_shadow = 0)" ,(numtime))
data = cursor.fetchall()
user_id = list(data)
logging.info("Database version : %s " % user_id)
......@@ -125,7 +39,7 @@ if __name__ == "__main__":
cookies = get_cookies(i)
time.sleep(random.randint(1, 10))
time.sleep(random.randint(10, 40))
cook=login()
......
auto_lunch_app.py
View file @ d5fc91c2
......@@ -9,91 +9,6 @@ import logging
from auto_request import login, time_convs,follow
from auto_request import host,user,port,db,passwd
# auto_follow_url = "http://earth.iyanzhi.com/api/v1/follow"
#
#
# def get_majia():
# try:
# data = open("/srv/apps/cybertron/batch_user_gen")
#
# list = []
#
# for i in data:
# list.append(i.strip('\n').strip(','))
#
# maj = random.randint(1, len(list))
#
# user_id = list[maj - 1]
#
# return user_id
#
# except:
# logging.error("catch exception,get_majia:%s" % traceback.format_exc())
# return None
#
#
# def get_cookies(user_id):
# try:
# with open("/srv/apps/cybertron/user_session.txt", 'r') as f:
# try:
# data = f.readlines()
# except:
# data = None
#
# list = []
# for i in data:
# list.append(i.strip('\n').split(","))
#
# for i in list:
#
# if user_id == i[0]:
# return (i[1])
# except:
#
# return None
#
#
# def logins():
# try:
# user_id = get_majia()
#
# cookies = get_cookies(user_id)
#
# if cookies is not None:
# return {'sessionid': cookies}
#
# except:
#
# logging.error("catch exception,logins:%s" % traceback.format_exc())
#
# return None
#
#
# def follow(cookies_get, id):
# try:
# post_dict = {
# 'type': 1,
# 'id': id
# }
# response = requests.post(url=auto_follow_url,
# cookies=cookies_get,
# data=post_dict)
#
# logging.info("response.text:%s" % response.text)
#
# except:
#
# logging.error("catch exception,logins:%s" % traceback.format_exc())
#
#
# def time_conv(numtime):
# try:
# now = datetime.datetime.now()
# yes_time = now - datetime.timedelta(days=numtime)
# yes_time_str = yes_time.strftime('%Y-%m-%d')
# return yes_time_str
# except:
# return None
def get_data(numtime):
......@@ -101,7 +16,7 @@ def get_data(numtime):
pc = pymysql.connect(host=host, user=user, passwd=passwd, db=db, port=port)
cursor = pc.cursor()
cursor.execute(
"select user_id from pv_maidian where page_name ='home' and partiton_date like '%%%%%s%%%%' and user_id in (select user_id from user_extra where is_shadow = 0)" % numtime)
"select distinct(user_id) from pv_maidian where page_name ='home' and partiton_date like '%%%%%s%%%%' and user_id in (select user_id from user_extra where is_shadow = 0)" % numtime)
data = cursor.fetchall()
user_id = list(data)
logging.pcinfo("Database version : %s " % user_id)
......
auto_request.py
View file @ d5fc91c2
import requests
import time
import datetime
import pymysql
import random
import pandas as pd
import traceback
from log_settings import *
import logging
import pymysql
import logging
import log_settings
import traceback
# auto_click_url = "http://earth.iyanzhi.com/api/v1/like"
# auto_reply_url = "http://earth.iyanzhi.com/api/v1/reply/create"
......@@ -22,17 +15,31 @@ auto_reply_url = "http://earth.igengmei.com/api/v1/reply/create"
auto_follow_url = "http://earth.igengmei.com/api/v1/follow"
auto_urge_url = "http://earth.igengmei.com/api/v1/user/urge"
# host = "172.17.40.144"
# user = "work"
# passwd = 'oars152!traipseize738'
# db = "alpha"
# port = 3306
DATABASES = {
'default': {
'ENGINE': 'django.db.backends.mysql',
'NAME': 'alpha',
'USER': 'work',
'PASSWORD': 'Gengmei123',
'HOST': 'rm-2zeaut61u9sm21m0b.mysql.rds.aliyuncs.com',
'PORT': '3306',
'OPTIONS': {
"init_command": "SET foreign_key_checks = 0;",
"charset": "utf8mb4",
},
}
}
host = DATABASES['default']['host']
user = DATABASES['default']['USER']
host = "rm-2zeaut61u9sm21m0b.mysql.rds.aliyuncs.com"
user = "work"
passwd = "Gengmei123"
db = "alpha"
port =3306
port = DATABASES['default']['PORT']
db = DATABASES['default']['NAME']
passwd = DATABASES['default']['PASSWORD']
def get_majia():
......@@ -160,7 +167,6 @@ def get_comment():
return None
def get_comments():
try:
data = open("/srv/apps/cybertron/guanshui", "r")
......@@ -176,8 +182,7 @@ def get_comments():
comment2 = list_guanshui[num2 - 1]
comment3 = list_guanshui[num3 - 1]
comment_list = [comment1,comment2,comment3]
comment_list = [comment1, comment2, comment3]
return comment_list
......
auto_star_topic.py
View file @ d5fc91c2
......@@ -10,112 +10,6 @@ from auto_request import login, time_conv, follow,click
from auto_request import host, user, port, db, passwd
# auto_follow_url = "http://earth.iyanzhi.com/api/v1/follow"
#
# auto_click_url = "http://earth.iyanzhi.com/api/v1/like"
#
#
# def get_majia():
# try:
# data = open("/srv/apps/cybertron/batch_user_gen")
#
# list = []
#
# for i in data:
# list.append(i.strip('\n').strip(','))
#
# maj = random.randint(1, len(list))
#
# user_id = list[maj - 1]
#
# return user_id
#
# except:
# logging.error("catch exception,get_majia:%s" % traceback.format_exc())
# return None
#
#
# def get_cookies(user_id):
# try:
# with open("/srv/apps/cybertron/user_session.txt", 'r') as f:
# try:
# data = f.readlines()
# except:
# data = None
#
# list = []
# for i in data:
# list.append(i.strip('\n').split(","))
#
# for i in list:
#
# if user_id == i[0]:
# return (i[1])
# except:
#
# return None
#
#
# def logins():
# try:
# user_id = get_majia()
#
# cookies = get_cookies(user_id)
#
# if cookies is not None:
# return {'sessionid': cookies}
#
# except:
#
# logging.error("catch exception,logins:%s" % traceback.format_exc())
#
# return None
#
#
# def click(cookies_get, id):
# try:
# post_dict = {
# 'type': 0,
# 'id': id
# }
# response = requests.post(url=auto_click_url,
# cookies=cookies_get,
# data=post_dict)
#
# logging.info("response.text:%s" % response.text)
#
# except:
#
# logging.error("catch exception,logins:%s" % traceback.format_exc())
#
#
# def follow(cookies_get, id):
# try:
# post_dict = {
# 'type': 1,
# 'id': id
# }
# response = requests.post(url=auto_follow_url,
# cookies=cookies_get,
# data=post_dict)
#
# print(response.text, 'url')
#
# logging.info("response.text:%s" % response.text)
#
# except:
#
# logging.error("catch exception,logins:%s" % traceback.format_exc())
#
#
# def time_conv(numtime):
# try:
# now = datetime.datetime.now()
# yes_time = now - datetime.timedelta(days=numtime)
# yes_time_str = yes_time.strftime('%Y-%m-%d')
# return yes_time_str
# except:
# return None
def get_star_user_id(numtime):
try:
......@@ -140,10 +34,10 @@ def get_star_topic_id(numtime):
cursor.execute(
"SELECT id FROM topic WHERE is_online=1 and (content_level =4 or content_level =5) and create_time LIKE '%%%%%s%%%%'" % numtime)
data = cursor.fetchall()
user_id = list(data)
topic_id = list(data)
logging.info("Database version : %s " % user_id)
pc.close()
return user_id
return topic_id
except:
logging.error("catch exception,get_data:%s" % traceback.format_exc())
return None
......@@ -158,27 +52,24 @@ if __name__ == "__main__":
numtime = time_conv(i)
user_id = get_star_topic_id(numtime)
topic_id = get_star_topic_id(numtime)
for j in topic_id:
urge_num = random.randint(0, 1)
id = int(j[0])
for i in range(urge_num):
for j in user_id:
urge_num = random.randint(0, 1)
id = int(j[0])
for i in range(urge_num):
time.sleep(random.randint(1, 10))
time.sleep(random.randint(10, 20))
cookies = login()
if cookies is not None:
click(cookies, id)
time.sleep(300)
urge_num = random.randint(1, 2)
for i in range(urge_num):
time.sleep(300)
user_id = get_star_user_id(numtime)
......@@ -186,12 +77,27 @@ if __name__ == "__main__":
id = int(j[0])
time.sleep(random.randint(1, 10))
for i in range(1):
time.sleep(random.randint(10, 20))
cookies = login()
if cookies is not None:
follow(cookies, id)
cookies = login()
if cookies is not None:
follow(cookies, id)
except:
logging.error("catch exception,main:%s" % traceback.format_exc())
#每日一次轮询，昨、2、3、4、5、6、7日被选为4、5星的帖子：[0-1]个马甲点赞。
#每日一次轮询，昨日有帖子被选为4、5星的用户：[1-2]个粉丝
\ No newline at end of file
auto_star_urge.py
View file @ d5fc91c2
......@@ -11,94 +11,6 @@ from auto_request import login, time_conv, Urge
from auto_request import host, user, port, db, passwd
# auto_urge_url = "http://earth.iyanzhi.com/api/v1/user/urge"
# def get_majia():
#
# try:
# data = open("/srv/apps/cybertron/batch_user_gen")
#
# list=[]
#
# for i in data:
#
# list.append(i.strip('\n').strip(','))
#
# maj = random.randint(1,len(list))
#
# user_id=list[maj-1]
#
# return user_id
#
# except:
# logging.error("catch exception,get_majia:%s" % traceback.format_exc())
# return None
#
# def get_cookies(user_id):
#
# try:
# with open("/srv/apps/cybertron/user_session.txt", 'r') as f:
# try:
# data = f.readlines()
# except:
# data = None
#
# list = []
# for i in data:
# list.append(i.strip('\n').split(","))
#
# for i in list:
#
# if user_id == i[0]:
#
# return (i[1])
# except:
#
# return None
#
#
# def logins():
#
# try:
# user_id=get_majia()
#
# cookies = get_cookies(user_id)
#
# if cookies is not None:
#
# return {'sessionid': cookies}
#
# except:
#
# logging.error("catch exception,logins:%s" % traceback.format_exc())
#
# return None
#
# def Urge(cookies_get, id):
#
# try:
# post_dict = {
# 'id': id
# }
# response = requests.post(url=auto_urge_url,
# cookies=cookies_get,
# data=post_dict)
#
# logging.info("response.text:%s" % response.text)
#
# except:
#
# logging.error("catch exception,logins:%s" % traceback.format_exc())
#
# def time_conv(numtime):
#
# try:
# now = datetime.datetime.now()
# yes_time = now - datetime.timedelta(days=numtime)
# yes_time_str = yes_time.strftime('%Y-%m-%d')
# return yes_time_str
# except:
# return None
def get_star_useid(numtime):
......@@ -106,7 +18,7 @@ def get_star_useid(numtime):
pc = pymysql.connect(host=host, user=user, passwd=passwd, db=db, port=port)
cursor = pc.cursor()
cursor.execute(
"SELECT user_id FROM topic WHERE is_online=1 and (content_level =4 or content_level =5) and create_time LIKE '%%%%%s%%%%' and user_id in (select user_id from user_extra where is_shadow = 0)" % numtime)
"SELECT distinct(user_id) FROM topic WHERE is_online=1 and (content_level =4 or content_level =5) and create_time LIKE '%%%%%s%%%%' and user_id in (select user_id from user_extra where is_shadow = 0)" % numtime)
data = cursor.fetchall()
user_id = list(data)
logging.info("Database version : %s " % user_id)
......
auto_urge.py
View file @ d5fc91c2
......@@ -10,94 +10,7 @@ import logging
from auto_request import login, time_conv, Urge
from auto_request import host, user, port, db, passwd
# auto_urge_url = "http://earth.iyanzhi.com/api/v1/user/urge"
#
# def get_majia():
#
# try:
# data = open("/srv/apps/cybertron/batch_user_gen")
#
# list=[]
#
# for i in data:
# list.append(i.strip('\n').strip(','))
#
# maj = random.randint(1,len(list))
#
# user_id=list[maj-1]
#
# return user_id
#
# except:
# logging.error("catch exception,get_majia:%s" % traceback.format_exc())
# return None
#
# def get_cookies(user_id):
#
# try:
# with open("/srv/apps/cybertron/user_session.txt", 'r') as f:
# try:
# data = f.readlines()
# except:
# data = None
#
# list = []
# for i in data:
# list.append(i.strip('\n').split(","))
#
# for i in list:
#
# if user_id == i[0]:
#
# return (i[1])
# except:
#
# return None
#
#
# def logins():
#
# try:
# user_id=get_majia()
#
# cookies = get_cookies(user_id)
#
# if cookies is not None:
#
# return {'sessionid': cookies}
#
# except:
#
# logging.error("catch exception,logins:%s" % traceback.format_exc())
#
# return None
#
# def Urge(cookies_get, id):
#
# try:
# post_dict = {
# 'id': id
# }
# response = requests.post(url=auto_urge_url,
# cookies=cookies_get,
# data=post_dict)
#
# logging.info("response.text:%s" % response.text)
#
# except:
#
# logging.error("catch exception,logins:%s" % traceback.format_exc())
#
# def time_conv(numtime):
#
# try:
# now = datetime.datetime.now()
# yes_time = now - datetime.timedelta(days=numtime)
# yes_time_str = yes_time.strftime('%Y-%m-%d')
# return yes_time_str
# except:
# return None
#
def get_data(numtime):
try:
......
auto_urge_three.py
View file @ d5fc91c2
......@@ -10,97 +10,13 @@ import logging
from auto_request import login, time_conv, Urge
from auto_request import host, user, port, db, passwd
# auto_urge_url = "http://earth.iyanzhi.com/api/v1/user/urge"
#
# def get_majia():
# try:
# data = open("/srv/apps/cybertron/batch_user_gen")
#
# list = []
#
# for i in data:
# list.append(i.strip('\n').strip(','))
#
# maj = random.randint(1, len(list))
#
# user_id = list[maj - 1]
#
# return user_id
#
# except:
# logging.error("catch exception,get_majia:%s" % traceback.format_exc())
# return None
#
#
# def get_cookies(user_id):
# try:
# with open("/srv/apps/cybertron/user_session.txt", 'r') as f:
# try:
# data = f.readlines()
# except:
# data = None
#
# list = []
# for i in data:
# list.append(i.strip('\n').split(","))
#
# for i in list:
#
# if user_id == i[0]:
# return (i[1])
# except:
#
# return None
#
#
# def logins():
# try:
# user_id = get_majia()
#
# cookies = get_cookies(user_id)
#
# if cookies is not None:
# return {'sessionid': cookies}
#
# except:
#
# logging.error("catch exception,logins:%s" % traceback.format_exc())
#
# return None
#
#
# def Urge(cookies_get, id):
# try:
# post_dict = {
# 'id': id
# }
# response = requests.post(url=auto_urge_url,
# cookies=cookies_get,
# data=post_dict)
#
# logging.info("response.text:%s" % response.text)
#
# except:
#
# logging.error("catch exception,logins:%s" % traceback.format_exc())
#
#
# def time_conv(numtime):
# try:
# now = datetime.datetime.now()
# yes_time = now - datetime.timedelta(days=numtime)
# yes_time_str = yes_time.strftime('%Y-%m-%d')
# return yes_time_str
# except:
# return None
def get_data(numtime):
try:
pc = pymysql.connect(host=host, user=user, passwd=passwd, db=db, port=port)
cursor = pc.cursor()
cursor.execute(
"select user_id from account_user_auth where user_id not in (select user_id from pv_maidian where page_name ='home' and partiton_date >= %s) and user_id in (select user_id from user_extra where is_shadow = 0)",
"select distinct(user_id) from account_user_auth where user_id not in (select user_id from pv_maidian where page_name ='home' and partiton_date >= %s) and user_id in (select user_id from user_extra where is_shadow = 0)",
(numtime))
data = cursor.fetchall()
user_id = list(data)
......@@ -123,7 +39,7 @@ if __name__ == "__main__":
for i in user_id:
time.sleep(random.randint(1, 15))
time.sleep(random.randint(10, 15))
cook = login()
......
offline_comment.py
View file @ d5fc91c2
......@@ -7,8 +7,8 @@ import pandas as pd
import traceback
from log_settings import *
import logging
from auto_request import logins, reply, get_offline_comment, time_convs
from auto_request import host, user, port, db, passwd
from auto_request import logins, reply, get_offline_comment, time_convs
from auto_request import host, user, db, passwd
auto_click_url = "http://earth.igengmei.com/api/v1/like"
auto_reply_url = "http://earth.igengmei.com/api/v1/reply/create"
......@@ -25,12 +25,13 @@ auto_urge_url = "http://earth.igengmei.com/api/v1/user/urge"
# 注意需要禁止本帖作者评论
def get_data(numtime):
def get_data(numtime, numtime2):
try:
pc = pymysql.connect(host=host, user=user, passwd=passwd, db=db, port=3306)
cursor = pc.cursor()
cursor.execute( "SELECT id FROM topic WHERE is_online =1 and create_time >= %s and (content_level = 4 or content_level = 5) and user_id in (select user_id from user_extra where is_shadow = 0)",(numtime))
cursor.execute(
"SELECT id FROM topic WHERE is_online =1 and create_time <= %s and create_time >=%s and (content_level = 4 or content_level = 5) and user_id in (select user_id from user_extra where is_shadow = 0)",
(numtime, numtime2))
data = cursor.fetchall()
user_id = list(data)
logging.info("Database version : %s " % user_id)
......@@ -45,13 +46,11 @@ if __name__ == "__main__":
try:
time_list = [1, 2, 3, 4, 5, 6, 7]
time_list = [["2017-03-30 15:57:49.000000", "2010-03-30 15:57:49.000000"]]
for i in time_list:
numtime = time_convs(i)
topic_id = get_data(numtime)
topic_id = get_data(i[0], i[1])
dicts = {}
......@@ -62,8 +61,7 @@ if __name__ == "__main__":
comment_list = get_offline_comment()
for i in rand_num:
cook =logins()
cook = logins()
comment = get_offline_comment()
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment