add .gitignore

dianzan/.gitignore

@@ -0,0 +1,2 @@
+img.gif
+verify

dianzan/server_dianzan.py

@@ -0,0 +1,271 @@
+# -*- coding=utf-8 -*-
+
+import requests
+#import libxml2 as xparse
+import sys
+#import re
+reload(sys)
+sys.setdefaultencoding('utf-8')
+#import copy
+
+from xml.dom.minidom import parseString
+import xpath
+import time
+
+__metaclass__ = type
+class Dianzan:
+    def __init__(self, qq = None, pwd = None):
+        self.qq = 'atupal@foxmail.com' if not qq else qq
+        self.pwd = 'xxxxx' if not pwd else pwd
+        self.session = requests.Session()
+        self._login()
+        self.repeat_set = set()
+
+    def _parse(self, url, _xpath, content = None):
+        try:
+            if not content:content = self.session.get(url).content
+            #doc = xparse.parseDoc(content)
+            #ctxt = doc.xpathNewContext()
+            #return ctxt.xpathEval(_xpath)
+            doc = parseString(content)
+            ret = xpath.find(_xpath, doc)
+            for i in xrange(len(ret)):
+                ret[i].__setattr__('content', ret[i].nodeValue)
+            return ret
+        except Exception as e:
+            print e
+            return []
+        finally:
+            #doc.freeDoc()
+            pass
+
+
+    def _login(self):
+        url = 'http://info50.3g.qq.com/g/s?aid=index&s_it=1&g_from=3gindex&&g_f=1283' #3gqq首页
+        url = self._parse(url, '/wml/card/p/a[7]/@href')[0].content  #空间登陆url
+        url = self._parse(url, '/wml/card/@ontimer')[0].content  #空间登陆302url
+        self.login_referer = url
+        data = dict()
+        headers = dict()
+        content = self.session.get(url).content
+        url = self._parse(None, '//*/@href', content = content)[1].content #post地址
+        names = ['login_url', 'go_url', 'sidtype', 'aid']
+        for name in names:
+            value = self._parse(None, '//*[@name="'+ name +'"]/@value', content = content)[0].content
+            data[name] = value
+        data['qq'] = self.qq
+        data['pwd'] = self.pwd
+        headers['Origin'] = 'http://pt.3g.qq.com'
+        headers['Referer'] = self.login_referer
+        headers['Host'] = 'pt.3g.qq.com'
+        #headers['User-Agent'] = 'curl/7.21.3 (i686-pc-linux-gnu) libcurl/7.21.3 OpenSSL/0.9.8o zlib/1.2.3.4 libidn/1.18'
+        headers['User-Agent'] = ''
+
+
+        res = self.session.post(url, data = data, headers = headers, allow_redirects = False)
+        url = res.headers['location']#post之后重定向的地址，这里如果允许自动跳转的话不知道为什么会跳转到腾讯首页去。。蛋疼
+
+        if not url:
+            data = dict()
+            img_url = self._parse(None, '//img/@src', content = res.content)[0].content
+            names = [
+                    'qq'        ,
+                    'u_token'   ,
+                    'r'         ,
+                    'extend'    ,
+                    'r_sid'     ,
+                    'aid'       ,
+                    'hiddenPwd' ,
+                    'login_url' ,
+                    'go_url'    ,
+                    #'verify'    ,
+                    'sidtype'   ,
+                    ]
+            for name in names:
+                value = self._parse(None, '//*[@name="'+ name +'"]/@value', content = res.content)[0].content
+                data[name] = value
+            #from StringIO import StringIO
+            #r = self.session.get(img_url)
+            #verify_img = Image.open(StringIO(r.content))
+            #verify_img.show()
+            import urllib2
+            with open('./img.jpg', 'wb') as fi:
+                fi.write(urllib2.urlopen(img_url).read())
+            url = self._parse(None, '//*/@href', content = res.content)[1].content #post地址
+            import os
+            if os.environ.get('HOME') == '/home/atupal':
+                import time
+                time.sleep(60)
+                with open('verify', 'r') as fi:
+                    #data['verify'] = raw_input("verify:")
+                    data['verify'] = fi.readline().strip('\n')
+                url = self._verify(data = data, headers = headers, url = url)
+                '''#代码重复了，发送验证码的实现逻辑由_verrify方法实现
+                res = self.session.post(url, data = data, headers = headers, allow_redirects = False)
+                #print '1' + str(res.content)
+                url = res.headers['location']
+
+                ##验证码后第一次get
+                #url = self._parse(url, '/wml/card/@ontimer')[0].content
+
+                ##验证码后第二次get
+                #url = self._parse(url, '/wml/card/@ontimer')[0].content
+
+                #验证码后第一次get
+                content = self.session.get(url).content
+                #print '2' + content
+                url = self._parse(None, '/wml/card/@ontimer', content = content)[0].content
+
+                #验证码后第二次get
+                content = self.session.get(url).content
+                #print '3' + content
+                url = self._parse(None, '/wml/card/@ontimer', content = content)[0].content
+                '''
+            else:
+                form = '<form action="/dianzan_verify" method="post">'
+                for i in data:
+                    form += '<input type="hidden" name="%s" value="%s"></input>'%(i, data[i])
+
+                form += '<input type="hidden" name="url" value="%s"></input>'%url #带上url，下次浏览器post接收
+                form += '<input type="text" name="verify"></input>'
+                form += '<input type="submit" value="confirm"></input>'
+                form += '</form>'
+                self.verify = '''
+                    <html>
+                        <img src="%s"/>
+                        %s
+                    </html>
+                '''%(img_url, form)
+
+                return
+
+        else:
+            url = self._parse(url, '/wml/card/@ontimer')[0].content  #再get一次就登陆成功了 ,以上和chrome浏览器都略有不用，没有302
+
+        self.verify = None
+        self.url = url
+
+        #print self.session.get(url).content
+
+        #至此已经登陆成功了
+    def _verify(self, data, headers, url = None):
+        if not url:
+            url = data.pop('url')
+        res = self.session.post(url, data = data, headers = headers, allow_redirects = False)
+        print '1' + str(res.content)
+        url = res.headers['location']
+
+        #验证码后第一次get
+        content = self.session.get(url).content
+        print '2' + content
+        url = self._parse(None, '/wml/card/@ontimer', content = content)[0].content
+
+        #验证码后第二次get
+        content = self.session.get(url).content
+        print '3' + content
+
+        #有的账号会再跳转一次，有的不会,算个bug吧
+        try:
+            url_tmp = self._parse(None, '/wml/card/@ontimer', content = content)[0].content
+        except:
+            url_tmp = None
+        if url_tmp:
+            url = url_tmp
+        return url
+
+
+    def dianzan(self, cnt = 5, op = '1'):
+        '''
+        下面这中方法返回的地址是转义了的。。
+        '''
+        #patter = r'''<a href="([^>]*?)">赞'''
+        #content = self.session.get(self.url).content
+        #urls = re.findall(patter, content)
+
+        if self.verify:
+            return self.verify
+
+        feed_url = self.url
+        url = self._parse(feed_url, '/wml/card/@ontimer') #不知道为什么换了一个qq号的时候这里会多加一个跳转
+        if url:
+            feed_url = url[0].content
+        for i in xrange(cnt):
+            print "feed_url:" + feed_url
+            content = self.session.get(feed_url).content
+
+            urls = self._parse(None, '//*/@href', content = content)
+            for url in urls:
+                if url.content.find('like_action') != -1 and url.content[-1] == op:
+                    if self.repeat_set.issuperset({url.content}):
+                        continue
+                    ret = self.session.get(url.content).content
+                    if ret.find('成功') != -1:
+                        print '赞成功'
+                    self.repeat_set.add(url.content)
+
+            urls = self._parse(None, '//*[text()="更多好友动态>>" or text()="下页"]/@href', content = content)
+            for url in urls:
+                #if url.content.find('feeds_friends') != -1 or url.content.find('dayval=1') != -1:
+                feed_url = url.content
+
+        return 'success'
+
+class Dianzan_verify(Dianzan):
+    def __init__(self):
+        self.session = requests.Session()
+
+    def verify(self, data, headers):
+        print data
+        self.url = self._verify(data = data, headers = headers)
+        self.verify = None
+
+        '''代码重复了，写到了父类的_verify方法里面去了统一处理需要验证码时的情况
+        url = data.pop('url')
+        res = self.session.post(url, data = data, headers = headers, allow_redirects = False)
+        #print '1' + str(res.content)
+        url = res.headers['location']
+
+        #验证码后第一次get
+        content = self.session.get(url).content
+        #print '2' + content
+        url = self._parse(None, '/wml/card/@ontimer', content = content)[0].content
+
+        #验证码后第二次get
+        content = self.session.get(url).content
+        #print '3' + content
+        url = self._parse(None, '/wml/card/@ontimer', content = content)[0].content
+
+        self.verify = None
+        self.url = url
+        '''
+
+if __name__ == "__main__":
+    qq = 'atupal@foxmail.com'
+    pwd = 'Hacker@atupal'
+    D = Dianzan(qq = qq, pwd = pwd)
+
+    cnt = 0
+
+    import signal
+
+    def handler(signum, frame):
+        print "do whatever, like call thread.interrupt_main()"
+
+    signal.signal(signal.SIGINT, handler)
+
+    from datetime import datetime, timedelta
+    mydate = datetime.utcnow() + timedelta(hours=+8)
+    while 1:
+        cnt += 1
+        if cnt > 30:
+            cnt = 0
+            D.repeat_set.clear()
+        try:
+            print '***%s***' % mydate.strftime("%Y-%m-%d %H:%M:%S %Z%z")
+            D.dianzan(cnt = 1)
+            print
+        except Exception as e:
+            print e
+        try:
+        	time.sleep(300)
+        except:pass