精易论坛

标题: 某互金平台协yi登录+转币 [打印本页]

---

作者: CrazyWolf    时间: 2018-2-4 00:57
标题: 某互金平台协yi登录+转币
这是前段时间帮我同学做的一个自动化小程序，这里发出来和大家学习交流下，时间仓促，业务逻辑部分没有深思熟虑，写的比较挫，求轻拍。
操作系统：Ubuntu 14.05
运行环境：Python 2.7.xx


0x00. 结构目录
├── account.txt
├── hyhr178.py
├── logger.conf
├── module
│   ├── __init__.py│   ├── buytt.py
│   ├── login.py
│   ├── rk.py
└── README.md


0x01. 文件功能描述
account.txt -- 存放账号密码文件
hyhr178.py -- 程序入口文件，创建多进程任务，执行核心业务逻辑
logger.conf -- log配置文件
__init__.py -- 模块初始化文件，初始化一些模块中的全局常量
buytt.py -- 转币操作模块文件
login.py -- 自动登录模块文件
rk.py -- 自己封装的若快打码接口
README.md -- 项目说明文档

0x02. hyhr178.py

1. #!/usr/bin/env python
   
2. # -*- coding: utf-8 -*-
   
3. # author: CrazyWolf
   
4. # qq: 4850498
   
5. 
   
6. import time
   
7. import signal
   
8. import logging
   
9. import logging.config
   
10. import multiprocessing
    
11. 
    
12. from module.login import Login
    
13. from module.buytt import BuyTT
    
14. 
    
15. # logger = logging.config.fileConfig('logger.conf')
    
16. # log_root = logging.getLogger('root')
    
17. # log_hyhr178 = logging.getLogger('hyhr178')
    
18. 
    
19. 
    
20. def init_work():
    
21.     signal.signal(signal.SIGINT, signal.SIG_IGN)
    
22. 
    
23. 
    
24. def work(username, password, second_password):
    
25.     flag = 1
    
26.     password_err_loop = 0
    
27.     if username == '' or password == '' or second_password == '':
    
28.         print '账号或密码或二级密码为空'
    
29.         return
    
30. 
    
31.     login = Login()
    
32.     buytt = BuyTT(username=username, second_password=second_password)
    
33. 
    
34.     while True:
    
35.         if flag == 1:
    
36.             status = login.do(username=username, password=password)
    
37.             if status == 200:
    
38.                 flag = 2
    
39.             elif status == 400 or status == 401 or status == 402 or status == 100:
    
40.                 break
    
41.             elif status == 401:
    
42.                 # try loop two times
    
43.                 password_err_loop += 1
    
44.                 if password_err_loop == 2:
    
45.                     break
    
46.             else:
    
47.                 time.sleep(5)
    
48.         elif flag == 2:
    
49.             status = buytt.verify()
    
50.             if status == 200:
    
51.                 flag = 3
    
52.             elif status == 400 or status == 401:
    
53.                 break
    
54.             else:
    
55.                 time.sleep(5)
    
56.         elif flag == 3:
    
57.             status = buytt.buy()
    
58.             if status == 200 or status == 100:
    
59.                 break
    
60.             elif status == 500 or status == 501:
    
61.                 time.sleep(10)
    
62.             elif status == 402 or status == 401:
    
63.                 flag = 2
    
64.                 time.sleep(5)
    
65. 
    
66. 
    
67. def cil():
    
68.     result = []
    
69.     params = []
    
70. 
    
71.     # log_root.info('系统开始运行')
    
72.     # read account file
    
73.     with open('account.txt', 'r') as f:
    
74.         line = f.readline()
    
75.         while line:
    
76.             if line.find('|') > -1:
    
77.                 params.append(line.strip())
    
78.             else:
    
79.                 print '[-] 账号密码格式不对 -- {0}'.format(line)
    
80.                 # log_root.info('账号密码格式不对 -- {0}'.format(line))
    
81. 
    
82.             line = f.readline()
    
83. 
    
84.     pool = multiprocessing.Pool(processes=len(params), initializer=init_work)
    
85.     try:
    
86.         for param in params:
    
87.             tmp = param.split('|')
    
88.             result.append(pool.apply_async(work, (tmp[0], tmp[1], tmp[2])))
    
89. 
    
90.         pool.close()
    
91.         pool.join()
    
92.     except KeyboardInterrupt:
    
93.         pool.terminate()
    
94.         pool.join()
    
95. 
    
96.     print '全部处理完成'
    
97. 
    
98. 
    
99. if __name__ == "__main__":
    
100.     cil()
     

复制代码

0x03. __init__.py

1. #!/usr/bin/env python
   
2. # -*- coding: utf-8 -*-
   
3. # author: CrazyWolf
   
4. # qq: 4850498
   
5. 
   
6. import requests
   
7. 
   
8. WEBSITE_URL = 'http://hyhr178.com/'
   
9. VERIFICATION_CODE_URL = 'http://hyhr178.com/getCaptchaImg?d={0}'
   
10. 
    
11. cw_session = requests.session()
    
12. 
    
13. RK_SOFT_ID = ''
    
14. RK_SOFT_KEY = ''
    

复制代码

0x04. buytt.py

1. #!/usr/bin/env python
   
2. # -*- coding: utf-8 -*-
   
3. # author: CrazyWolf
   
4. # qq: 4850498
   
5. 
   
6. import time
   
7. import json
   
8. import logging
   
9. import logging.config
   
10. import module
    
11. 
    
12. # logger = logging.config.fileConfig('logger.conf')
    
13. # log_root = logging.getLogger('root')
    
14. # log_hyhr178 = logging.getLogger('hyhr178')
    
15. 
    
16. 
    
17. class BuyTT:
    
18.     def __init__(self, username, second_password):
    
19.         self.url_info = 'http://hyhr178.com/getSessionMember'
    
20.         self.username = username
    
21.         self.second_password = second_password
    
22. 
    
23.         self.lever = 1
    
24.         self.price = 0
    
25.         self.coin_total = 0.0
    
26.         self.address = ''
    
27. 
    
28.     def verify(self):
    
29.         headers = {
    
30.             'Host': 'hyhr178.com',
    
31.             'Connection': 'keep-alive',
    
32.             'User-Agent': 'Mozilla/5.0 (X11; Ubuntu; Linux x86_64; rv:57.0) Gecko/20100101 Firefox/57.0',
    
33.             'Accept': 'application/json, text/plain, */*',
    
34.             'Referer': 'http://hyhr178.com/memberinfo/module/home',
    
35.             'Accept-Encoding': 'gzip, deflate',
    
36.             'Accept-Language': 'en-US,en;q=0.5',
    
37.         }
    
38. 
    
39.         resp = module.cw_session.get(url=self.url_info, headers=headers, verify=False)
    
40.         if resp.status_code != 200:
    
41.             print '[-] {0} 请求用户数据失败'.format(self.username)
    
42.             # log_root.debug('{0} 请求用户数据失败'.format(self.username))
    
43.             return 500
    
44. 
    
45.         try:
    
46.             info = json.loads(resp.text)
    
47.             if info is None:
    
48.                 # log_root.debug('{0} 解析用户数据失败'.format(self.username))
    
49.                 print '[-] {0} 解析用户数据失败'.format(self.username)
    
50.                 return 501
    
51.         except Exception:
    
52.             # log_root.debug('{0} 解析用户数据异常'.format(self.username))
    
53.             print '[-] {0} 解析用户数据异常'.format(self.username)
    
54.             return 501
    
55. 
    
56.         # print info.keys()
    
57.         self.lever = info[u'team_level_id']
    
58.         self.coin_total = info[u'member_money11']
    
59.         self.address = info[u'ssc_code']
    
60.         print '[+] {0} 当前级别：{1} 当前TT币：{2} 当前Mail：{3}'.format(self.username, self.lever, self.coin_total, self.address)
    
61.         # log_root.info('{0} 当前级别：{1} 当前TT币：{2} 当前Mail：{3}'.format(self.username, self.lever, self.coin_total, self.address))
    
62. 
    
63.         if self.coin_total == 0.0:
    
64.             print '[-] {0} 没有TT币'.format(self.username)
    
65.             # log_root.debug('{0} 没有TT币'.format(self.username))
    
66.             return 400
    
67. 
    
68.         if self.address == '':
    
69.             print '[-] {0} mail为空'.format(self.username)
    
70.             # log_root.debug('{0} mail为空'.format(self.username))
    
71.             return 401
    
72. 
    
73.         # 2017-12-10 修改为每天兑换100
    
74.         # if 0 < self.lever < 4:
    
75.         #     self.price = 500
    
76.         #     if self.coin_total < 500.0:
    
77.         #         self.price = self.coin_total
    
78.         # elif self.lever >= 4:
    
79.         #     self.price = 1000
    
80.         #     if self.coin_total < 1000.0:
    
81.         #         self.price = self.coin_total
    
82.         self.price = 100
    
83.         if self.coin_total < 100:
    
84.             self.price = self.coin_total
    
85.         else:
    
86.             print '[-] {0} 获取用户数据失败'.format(self.username)
    
87.             # log_root.debug('{0} 获取用户数据失败'.format(self.username))
    
88.             return 402
    
89. 
    
90.         return 200
    
91. 
    
92.     def buy(self):
    
93.         headers = {
    
94.             'Host': 'hyhr178.com',
    
95.             'Connection': 'keep-alive',
    
96.             'Accept': '*/*',
    
97.             'Origin': 'http://hyhr178.com',
    
98.             'X-Requested-With': 'XMLHttpRequest',
    
99.             'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/59.0.3071.115 Safari/537.36',
    
100.             'Content-Type': 'application/x-www-form-urlencoded',
     
101.             'Referer': 'http://hyhr178.com',
     
102.             'Accept-Encoding': 'gzip, deflate',
     
103.             'Accept-Language': 'zh-CN,zh;q=0.8,en;q=0.6',
     
104.         }
     
105. 
     
106.         data = ''
     
107.         url = 'http://hyhr178.com/niubi/trans?address={0}&money_pwd={1}&out_qty={2}'.format(self.address, self.second_password, self.price)
     
108. 
     
109.         resp = module.cw_session.post(url=url, data=data, headers=headers, verify=False)
     
110.         if resp.status_code != 200:
     
111.             print '[-] {0} 请求购买失败'.format(self.username)
     
112.             # log_root.debug('{0} 请求购买失败'.format(self.username))
     
113.             return 500
     
114. 
     
115.         try:
     
116.             result = json.loads(resp.text)
     
117.             if result[u'success'] is 1:
     
118.                 print '[+] {0} 转入成功'.format(self.username)
     
119.                 # log_hyhr178.info('{0} 转入成功'.format(self.username))
     
120.                 return 200
     
121.             else:
     
122.                 # if resp.text.find(u'由于当前的兑换人数太多') > -1:
     
123.                 if u'由于当前的兑换人数太多' in resp.text:
     
124.                     print '[-] {0} 当前的兑换人数太多'.format(self.username)
     
125.                     # log_root.debug('{0} 当前的兑换人数太多'.format(self.username))
     
126.                     return 501
     
127.                 else:
     
128.                     print '[-] {0} {1}'.format(self.username, resp.text.encode('utf-8'))
     
129.                     # log_root.debug('{0} {1}'.format(self.username, resp.text))
     
130.                     return 100
     
131.         except Exception as e:
     
132.             # log_root.debug(e)
     
133.             print '[-] {0} {1}'.format(self.username, e)
     
134.             return 100
     

复制代码

0x05. login.py

1. #!/usr/bin/env python
   
2. # -*- coding: utf-8 -*-
   
3. # author: CrazyWolf
   
4. # qq: 4850498
   
5. 
   
6. import time
   
7. import json
   
8. import module
   
9. import logging
   
10. import logging.config
    
11. 
    
12. from module.rk import RClient
    
13. 
    
14. # logger = logging.config.fileConfig('logger.conf')
    
15. # log_root = logging.getLogger('root')
    
16. # log_hyhr178 = logging.getLogger('hyhr178')
    
17. 
    
18. 
    
19. class Login:
    
20.     def __init__(self):
    
21.         self.rk = RClient(username='', password='', soft_id=module.RK_SOFT_ID, soft_key=module.RK_SOFT_KEY)
    
22. 
    
23.     def do(self, username, password):
    
24.         """
    
25.         登陆操作
    
26.         :param username:
    
27.         :param password:
    
28.         :return:
    
29.         """
    
30.         headers = {
    
31.             'Accept': '*/*',
    
32.             'Accept-Encoding': 'gzip, deflate',
    
33.             'Accept-Language': 'en-US,en;q=0.5',
    
34.             'Connection': 'keep-alive',
    
35.             'Host': 'hyhr178.com',
    
36.             'Referer': 'http://hyhr178.com/memberinfo/module/home',
    
37.             'User-Agent': 'Mozilla/5.0 (X11; Ubuntu; Linux x86_64; rv:57.0) Gecko/20100101 Firefox/57.0',
    
38.         }
    
39. 
    
40.         # get verification code
    
41.         code_url = module.VERIFICATION_CODE_URL.format(time.time())
    
42.         resp = module.cw_session.get(url=code_url, headers=headers, verify=False)
    
43.         if resp.status_code != 200:
    
44.             print '[-] {0} 请求验证码失败'.format(username)
    
45.             # log_root.debug('{0} 请求验证码失败'.format(username))
    
46.             return 500
    
47. 
    
48.         # da ma
    
49.         img = resp.content
    
50.         result = self.rk.rk_create(im=img, im_type=3040)
    
51. 
    
52.         if len(result) != 2:
    
53.             print '[-] {0} {1}'.format(username, result['Error'])
    
54.             # log_root.debug('{0} {1}'.format(username, result['Error']))
    
55.             return 400
    
56. 
    
57.         # print '[+] 打码结果:', username, result['Result']
    
58.         # log_root.info('{0}的打码结果: {1}'.format(username, result['Result']))
    
59. 
    
60.         # login
    
61.         headers = {
    
62.             'Accept': 'application/json, text/plain, */*',
    
63.             'Accept-Encoding': 'gzip, deflate',
    
64.             'Accept-Language': 'en-US,en;q=0.5',
    
65.             'Connection': 'keep-alive',
    
66.             'Content-Type': 'application/json;charset=utf-8',
    
67.             'Host': 'hyhr178.com',
    
68.             'Origin': 'http://hyhr178.com',
    
69.             'Referer': 'http://hyhr178.com/memberinfo/module/home',
    
70.             'User-Agent': 'Mozilla/5.0 (X11; Ubuntu; Linux x86_64; rv:57.0) Gecko/20100101 Firefox/57.0',
    
71.         }
    
72. 
    
73.         url = 'http://hyhr178.com/doLogin?member_code={0}&member_pwd={1}&security_code={2}'.format(username, password, result['Result'])
    
74.         # url = 'http://hyhr178.com/doLogin?member_code={0}&member_pwd={1}&security_code={2}'.format(username, password, '1234')
    
75. 
    
76.         resp = module.cw_session.get(url=url, headers=headers, verify=False)
    
77.         if resp.status_code != 200:
    
78.             print '[-] {0} 登录请求失败'.format(username)
    
79.             # log_root.debug('{0} 登录请求失败'.format(username))
    
80.             return 500
    
81. 
    
82.         # {"data":[],"success":1,"msg":"操作成功"}
    
83.         try:
    
84.             result = json.loads(resp.text)
    
85.             if result[u'success'] is 1:
    
86.                 print '[+] {0} 登录成功'.format(username)
    
87.                 # log_root.debug('{0} 登录成功'.format(username))
    
88.                 return 200
    
89.             else:
    
90.                 # if result[u'msg'].find(u'检验不通过') > -1:
    
91.                 #     if u'errorMsg' in result[u'errordata']:
    
92.                 #         log_root.debug('{0} {1}'.format(username, result[u'errordata'][u'errorMsg']))
    
93.                 #     elif u'secuMsg' in result[u'errordata']:
    
94.                 #         log_root.debug('{0} {1}'.format(username, result[u'errordata'][u'secuMsg']))
    
95.                 #     else:
    
96.                 #         log_root.debug('{0} {1}'.format(username, result[u'errordata']))
    
97.                 if u'密码输入错误' in resp.text:
    
98.                     print '[-] {0} 密码输入错误'.format(username)
    
99.                     # log_root.debug('{0} 密码输入错误'.format(username))
    
100.                     return 401
     
101. 
     
102.                 elif u'验证码输入错误' in resp.text:
     
103.                     self.rk.rk_report_error(result['Id'])
     
104.                     print '[-] {0} 验证码输入错误'.format(username)
     
105.                     # log_root.debug('{0} 验证码输入错误'.format(username))
     
106.                     return 501
     
107. 
     
108.                 elif u'系统暂闭维护中' in resp.text:
     
109.                     print '[-] {0} 系统暂闭维护中'.format(username)
     
110.                     # log_root.debug('{0} 系统暂闭维护中'.format(username))
     
111.                     return 402
     
112. 
     
113.                 else:
     
114.                     print '[-] {0} {1}'.format(username, resp.text.encode('utf-8'))
     
115.                     # log_hyhr178.debug('{0} {1}'.format(username, resp.text))
     
116.                     return 100
     
117. 
     
118.         except Exception as e:
     
119.             print '[-] {0} {1}'.format(username, e)
     
120.             # log_root.debug(e)
     
121.             return 502
     

复制代码

0x06. rk.py

1. #!/usr/bin/env python
   
2. # coding:utf-8
   
3. 
   
4. import requests
   
5. from hashlib import md5
   
6. 
   
7. 
   
8. class RClient(object):
   
9. 
   
10.     def __init__(self, username, password, soft_id, soft_key):
    
11.         self.username = username
    
12.         self.password = md5(password).hexdigest()
    
13.         self.soft_id = soft_id
    
14.         self.soft_key = soft_key
    
15.         self.base_params = {
    
16.             'username': self.username,
    
17.             'password': self.password,
    
18.             'softid': self.soft_id,
    
19.             'softkey': self.soft_key,
    
20.         }
    
21.         self.headers = {
    
22.             'Connection': 'Keep-Alive',
    
23.             'Expect': '100-continue',
    
24.             'User-Agent': 'ben',
    
25.         }
    
26. 
    
27.     def rk_create(self, im, im_type, timeout=60):
    
28.         """
    
29.         im: 图片字节
    
30.         im_type: 题目类型
    
31.         """
    
32.         params = {
    
33.             'typeid': im_type,
    
34.             'timeout': timeout,
    
35.         }
    
36.         params.update(self.base_params)
    
37.         files = {'image': ('a.jpg', im)}
    
38.         r = requests.post('http://api.ruokuai.com/create.json', data=params, files=files, headers=self.headers)
    
39.         return r.json()
    
40. 
    
41.     def rk_report_error(self, im_id):
    
42.         """
    
43.         im_id:报错题目的ID
    
44.         """
    
45.         params = {
    
46.             'id': im_id,
    
47.         }
    
48.         params.update(self.base_params)
    
49.         r = requests.post('http://api.ruokuai.com/reporterror.json', data=params, headers=self.headers)
    
50.         return r.json()
    
51. 
    
52. 
    
53. if __name__ == '__main__':
    
54.     rc = RClient('username', 'password', 'soft_id', 'soft_key')
    
55.     im = open('a.jpg', 'rb').read()
    
56.     print rc.rk_create(im, 3040)
    
57. 
    

复制代码

0x07. logger.conf

1. [loggers]
   
2. keys=root,hyhr178
   
3. 
   
4. [handlers]
   
5. keys=consoleHandler,hyhr178Handler
   
6. 
   
7. [formatters]
   
8. keys=fmt
   
9. 
   
10. [logger_root]
    
11. level=DEBUG
    
12. handlers=consoleHandler
    
13. 
    
14. [logger_hyhr178]
    
15. level=DEBUG
    
16. handlers=hyhr178Handler
    
17. qualname=hyhr178
    
18. 
    
19. [handler_consoleHandler]
    
20. class=StreamHandler
    
21. lever=DEBUG
    
22. formatter=fmt
    
23. args=(sys.stdout,)
    
24. 
    
25. [handler_hyhr178Handler]
    
26. class=logging.handlers.RotatingFileHandler
    
27. lever=DEBUG
    
28. formatter=fmt
    
29. args=('logs.log', 'a', 20000, 5,)
    
30. 
    
31. [formatter_fmt]
    
32. format=%(asctime)s - %(levelname)s - %(process)d - %(message)s
    
33. datafmt=

复制代码

0x08. README.md

1. apt-get install python-dev
   
2. apt-get install libxml2-dev
   
3. apt-get install libxslt1-dev
   
4. apt-get install zlib1g-dev
   
5. 
   
6. pip install requests
   
7. pip install pyquery

复制代码

---

欢迎光临 精易论坛 (https://125.confly.eu.org/)

Powered by Discuz! X3.4