❌自动批量删除微博动态消息

  • A+
所属分类：编程语言

转载：自动批量删除微博动态消息weibo.py

  1. # _*_ coding: utf-8 _*_
  2. import os
  3. import re
  4. import rsa
  5. import time
  6. import json
  7. import base64
  8. import logging
  9. import binascii
  10. import requests
  11. import urllib.parse
  13. from helper import parse_mblog_mids
  14. from config import WEIBO_USERNAME, WEIBO_PASSWORD, PAGE_ONE_URL
  16. class WeiBo(object):
  17.     """
  18.     class of WeiBo, to login weibo.com
  19.     """
  21.     def __init__(self):
  22.         """
  23.         constructor
  24.         """
  25.         self.user_name = None
  26.         self.pass_word = None
  27.         self.user_uniqueid = None
  28.         self.user_nick = None
  30.         self.session = requests.Session()
  31.         self.session.headers.update({"User-Agent": "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_14_1) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/70.0.3538.102 Safari/537.36"})
  32.         self.session.get("http://weibo.com/login.php")
  33.         return
  35.     def login(self, user_name, pass_word):
  36.         """
  37.         login weibo.com, return True or False
  38.         """
  39.         self.user_name = user_name
  40.         self.pass_word = pass_word
  41.         self.user_uniqueid = None
  42.         self.user_nick = None
  44.         # get json data
  45.         s_user_name = self.get_username()
  46.         json_data = self.get_json_data(su_value=s_user_name)
  47.         if not json_data:
  48.             return False
  49.         s_pass_word = self.get_password(json_data["servertime"], json_data["nonce"], json_data["pubkey"])
  51.         # make post_data
  52.         post_data = {
  53.             "entry": "weibo",
  54.             "gateway": "1",
  55.             "from": "",
  56.             "savestate": "7",
  57.             "userticket": "1",
  58.             "vsnf": "1",
  59.             "service": "miniblog",
  60.             "encoding": "UTF-8",
  61.             "pwencode": "rsa2",
  62.             "sr": "1280*800",
  63.             "prelt": "529",
  64.             "url": "http://weibo.com/ajaxlogin.php?framelogin=1&callback=parent.sinaSSOController.feedBackUrlCallBack",
  65.             "rsakv": json_data["rsakv"],
  66.             "servertime": json_data["servertime"],
  67.             "nonce": json_data["nonce"],
  68.             "su": s_user_name,
  69.             "sp": s_pass_word,
  70.             "returntype": "TEXT",
  71.         }
  73.         # get captcha code
  74.         if json_data["showpin"] == 1:
  75.             url = "http://login.sina.com.cn/cgi/pin.php?r=%d&s=0&p=%s" % (int(time.time()), json_data["pcid"])
  76.             with open("captcha.jpeg", "wb") as file_out:
  77.                 file_out.write(self.session.get(url).content)
  78.             code = input("请输入验证码:")
  79.             post_data["pcid"] = json_data["pcid"]
  80.             post_data["door"] = code
  82.         # login weibo.com
  83.         login_url_1 = "http://login.sina.com.cn/sso/login.php?client=ssologin.js(v1.4.18)&_=%d" % int(time.time())
  84.         json_data_1 = self.session.post(login_url_1, data=post_data).json()
  85.         if json_data_1["retcode"] == "0":
  86.             params = {
  87.                 "callback": "sinaSSOController.callbackLoginStatus",
  88.                 "client": "ssologin.js(v1.4.18)",
  89.                 "ticket": json_data_1["ticket"],
  90.                 "ssosavestate": int(time.time()),
  91.                 "_": int(time.time()*1000),
  92.             }
  93.             response = self.session.get("https://passport.weibo.com/wbsso/login", params=params)
  94.             json_data_2 = json.loads(re.search(r"\((?P<result>.*)\)", response.text).group("result"))
  95.             if json_data_2["result"] is True:
  96.                 self.user_uniqueid = json_data_2["userinfo"]["uniqueid"]
  97.                 self.user_nick = json_data_2["userinfo"]["displayname"]
  98.                 logging.warning("WeiBo succeed: %s", json_data_2)
  99.             else:
  100.                 logging.warning("WeiBo failed: %s", json_data_2)
  101.         else:
  102.             logging.warning("WeiBo failed: %s", json_data_1)
  103.         return True if self.user_uniqueid and self.user_nick else False
  105.     def get_username(self):
  106.         """
  107.         get legal username
  108.         """
  109.         username_quote = urllib.parse.quote_plus(self.user_name)
  110.         username_base64 = base64.b64encode(username_quote.encode("utf-8"))
  111.         return username_base64.decode("utf-8")
  113.     def get_json_data(self, su_value):
  114.         """
  115.         get the value of "servertime", "nonce", "pubkey", "rsakv" and "showpin", etc
  116.         """
  117.         params = {
  118.             "entry": "weibo",
  119.             "callback": "sinaSSOController.preloginCallBack",
  120.             "rsakt": "mod",
  121.             "checkpin": "1",
  122.             "client": "ssologin.js(v1.4.18)",
  123.             "su": su_value,
  124.             "_": int(time.time()*1000),
  125.         }
  126.         try:
  127.             response = self.session.get("http://login.sina.com.cn/sso/prelogin.php", params=params)
  128.             json_data = json.loads(re.search(r"\((?P<data>.*)\)", response.text).group("data"))
  129.         except Exception as excep:
  130.             json_data = {}
  131.             logging.error("WeiBo get_json_data error: %s", excep)
  133.         logging.debug("WeiBo get_json_data: %s", json_data)
  134.         return json_data
  136.     def get_password(self, servertime, nonce, pubkey):
  137.         """
  138.         get legal password
  139.         """
  140.         string = (str(servertime) + "\t" + str(nonce) + "\n" + str(self.pass_word)).encode("utf-8")
  141.         public_key = rsa.PublicKey(int(pubkey, 16), int("10001", 16))
  142.         password = rsa.encrypt(string, public_key)
  143.         password = binascii.b2a_hex(password)
  144.         return password.decode()
  146.     def post(self, url, data):
  147.         return self.session.post(url, data=data)
  149.     def get_mblog_mids(self):
  150.         mblog_url = 'https://m.weibo.cn/api/container/getIndex?containerid=2304135610949777_-_WEIBO_SECOND_PROFILE_WEIBO&page=1'
  151.         params = {
  152.             'containerid': '2304135610949777_-_WEIBO_SECOND_PROFILE_WEIBO',
  153.             'page_type': '01',
  154.             'page': '1',
  155.         }
  156.         response = self.session.get("https://m.weibo.cn/api/container/getIndex", params=params)
  157.         mblog_ids = parse_mblog_mids(response.json())
  158.         return mblog_ids
  161. if __name__ == "__main__":
  162.     logging.basicConfig(level=logging.INFO, format="%(asctime)s\t%(levelname)s\t%(message)s")
  163.     weibo = WeiBo()
  164.     weibo.login(WEIBO_USERNAME, WEIBO_PASSWORD)

config.py

  1. import os
  3. header = {'Host': 'm.weibo.cn',
  4.           'Connection': 'keep-alive',
  5.           'Content-Length': 30,
  6.           'Accept': 'application/json, text/plain, */*',
  7.           'MWeibo-Pwa': 1,
  8.           'X-Requested-With': 'XMLHttpRequest',
  9.           'User-Agent': 'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_14_1) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/70.0.3538.102 Safari/537.36',
  10.           'Origin': 'https://m.weibo.cn',
  11.           'Content-Type': 'application/x-www-form-urlencoded',
  12.         #   'Referer': ' https://m.weibo.cn/profile/5610949777',
  13.           'Accept-Encoding': 'gzip, deflate, br',
  14.           'Accept-Language': 'zh-CN,zh;q=0.9,en;q=0.8',
  15.           'Cookie': ''
  16.           }
  17. WEIBO_USERNAME = os.environ.get('WEIBO_USERNAME')
  18. WEIBO_PASSWORD = os.environ.get('WEIBO_PASSWORD')
  19. PAGE_ONE_URL = 'https://m.weibo.cn/api/container/getIndex?containerid=2304135610949777_-_WEIBO_SECOND_PROFILE_WEIBO&page_type=03&page=1'

help.py

  1. import json
  4. def parse_mblog_mids(data_dict):
  5.     if not data_dict:
  6.         return
  7.     # print('data_dict: {0}'.format(data_dict))
  8.     cards = data_dict.get('data').get('cards')
  9.     mblog_mids = [card['mblog']['mid'] for card in cards if card['card_type'] == 9]
  10.     return mblog_mids

del.py

  1. import logging  
  2. import os  
  3. import json  
  4. import time  
  5.   
  6. from config import WEIBO_PASSWORD, WEIBO_USERNAME  
  7. from weibo import WeiBo  
  8.   
  9. weibo = WeiBo()  
  10. weibo.login(WEIBO_USERNAME, WEIBO_PASSWORD)  
  11.   
  12.   
  13. def del_mblog():  
  14.     url = 'http://weibo.com/aj/mblog/del?ajwvr=6'  
  15.     mids = weibo.get_mblog_mids()  
  16.     print('mids:{0}'.format(mids))  
  17.     for mid in mids:  
  18.         data = {'mid': mid}  
  19.         response = weibo.post(url, data=json.dumps(data))  
  20.         logging.debug('del status:', response.status_code)  
  21.         print('del status: ', response.status_code)  
  22.         print(response.content.decode('utf8'))  
  23.         time.sleep(2)  
  24.   
  25.   
  26. if __name__ == "__main__":  
  27.     logging.basicConfig(level=logging.DEBUG, format="%(asctime)s\t%(levelname)s\t%(message)s")  
  28.     del_mblog()  
weinxin
我的微信公众号
爱真理，得永生！　　　　　　　　　　爱在灵灵久博客，网罗天下，福利大家！

发表评论

:?: :razz: :sad: :evil: :!: :smile: :oops: :grin: :eek: :shock: :???: :cool: :lol: :mad: :twisted: :roll: :wink: :idea: :arrow: :neutral: :cry: :mrgreen: