#coding:utf-8
import re
import base64
import httplib, urllib,urllib2
import time
from google.appengine.ext import db
 
class Tiwdata(db.Model):
    re_id=db.StringProperty()
    re_date=db.StringProperty()
 
 
class Twitter:
    """Class to processing information from the twitter users"""
 
    def __init__( self ):
        """initializing the username and password"""
        self.__username="帐号名"
        self.__password="密码"
        self.__since_id=""
        # Twitter 采用的是base64验证
        self.__authStr = base64.b64encode(self.__username + ":" + self.__password);
 
 
    def setMessage( self , message ):
        """function to set the message"""
        regex=r'^@帐号名 (.*)'
        m=re.findall(regex,message.lower()) #提取其他用户查询消息
        return m
 
    def getMessage( self ):
        """function to return the message"""
        return self.__message
 
 
    def parseMessage( self ):
 
        since_id=self.getSinceId() #从数据库获取最新id  
        #以since_id为参数，通过API读取新收到的所有消息
        if(since_id<>""):
            url="https://twitter.com/statuses/mentions.xml?since_id=%s"%(since_id)
        else:
            url="https://twitter.com/statuses/mentions.xml"
        req = urllib2.Request(url)
        req.add_header("Authorization", "Basic " + self.__authStr)
        try:
            response = urllib2.urlopen(req)
            page=response.read() 
        except:
            return []
 
 
        matches = re.findall(
        r"""(?sx)<created_at>(.*?)</created_at>s*
        <id>(.*?)</id>s*                              
        <text>(.*?)</text>.*?                                
        <screen_name>(.*?)</screen_name>.*?
        </status>
        """,page)
        # 并将最近一条消息的id放置到数据库中
        if(matches<>[]):
            per=Tiwdata()
            per.re_id=matches[0][1]
            per.re_date=self.parseTime(matches[0][0])
            per.put()       
        return matches
 
    def parseTime( self, time_str ):
 
        T="%a %b %d %H:%M:%S +0000 %Y"
        t=time.strptime(time_str,T)
        return time.strftime('%Y-%m-%d-%H-%M-%S', t)
 
 
 
    def sentMessage(self, message):
        """sent message to twitter"""
        headers = {"Content-type": "application/x-www-form-urlencoded",
                "Accept": "text/xml",
                "Authorization": "Basic " + self.__authStr}
        try:
            params = urllib.urlencode({"status": message})
            req = urllib2.Request("https://twitter.com/statuses/update.xml", params, headers)
            response = urllib2.urlopen(req)
        except:
            pass
 
 
 
    def getSinceId( self ):
        msg=db.GqlQuery("SELECT * FROM Tiwdata ORDER BY re_date DESC")
        x=msg.count()
        if x:
            return msg[0].re_id
        else:
            return ""

#!/usr/bin/env python
#coding:utf-8
import urllib2,re
 
class Dict:
    """Class to get EN2CN & CN2EN translation from dict.cn"""
    def __init__( self, word="Della" ):
        """initializing the word and the url received"""   
        self.setWord(word)
        self.setUrl()
 
 
    def setWord( self, word ):
        """function to set the word"""
        self.__word=word
 
 
    def setUrl(self):
        """function to set the url"""
        self.__url="http://dict.cn/ws.php?utf8=true&q=%s"%self.__word
 
 
    def getPage(self):
        """function to get the content of the web page.return the string page content"""        
        url=self.__url
        try:
            page = urllib2.urlopen(url)
            page_content = page.read()
            page.close()
        except:
            return ""
        return page_content
 
 
    def getWord(self):
        """function get the info what we needed from the web page.return a list reply"""
        page_content=self.getPage().replace("\n"," ")
        page_content=unicode(page_content,"utf-8") # set the page content encoding to unicode
        regex=r'<def>(.*)</def>' 
        match=re.findall( regex , page_content )     
        return match

#coding:utf-8
from Twitter import Twitter
from Dict import Dict
 
def getService( match ):
 
    respons=[]
    try:
        word=match[0].replace(" ","%20")
        dict=Dict(word)
        reply=dict.getWord() #获取查询结果
    except:
        return ["服务端连接有误，请稍后再试"]
    if (reply==[] or cmp(reply[0],unicode("Not Found","utf-8"))==0):
        return ["Oops,你查询的单词不存在或输入格式有误，请检查下或输入'词典'获取帮助"]
    reply[0]="["+match[0]+"] "+reply[0].encode('utf-8')
    respons=reply
 
    return respons
 
twitter=Twitter()
receive=twitter.parseMessage() #获取所有查询信息
for y in reversed(receive):
    word=twitter.setMessage(y[2]) #提取用户查询消息
    if(word<>[]):
        reply=getService( word ) # 交给Dict去处理
        if(reply<>[]):
            for i in reversed(reply):
                if(i<>None):
                    i="@"+y[3]+" "+i #y[3]为twitter上查询用户的帐号名
                    twitter.sentMessage(i) #将查询结果返回