파일 버전

#!/usr/bin/env python
# -*- coding:utf-8 -*-

__author__ = "[email protected]"

import urllib2
import json

Appid_Group = {
    '1': '2',  # zabbix  
    '6': '4',  #  
    '7': '5',  # DBA  
    '8': '6',  #  
    '9': '7',  #  
    '10': '8',  #  
    '11': '9'  #  
}

class weixin(object):
    ""
    def __init__(self,appid,msg):
        ""
        self.appid = str(appid)
        self.msg = str(msg)
        self.tokenfile = 'token.log'

    def get_token(self,mode=False):
        ""
        if mode:
            file = open(self.tokenfile,'r')
            # try:
            #     self.token  = file.read()
            # finally:
            #     file.close()
            with open(self.tokenfile, 'r') as f:

                self.token = f.read()
        else:

            appid = "wxddaasdasdcb42d5"
            secrect = "N26FX62Ej5isadasdasdasdttQX62vw5gKmpbUkap4_6CczzI2d7o"
            GURL = "https://qyapi.weixin.qq.com/cgi-bin/gettoken?corpid=%s&corpsecret=%s" % (appid, secrect)
            try:
                f = urllib2.urlopen(GURL).read()
                j = json.loads(f)
                self.token = j['access_token']  # .encode('utf8')

                file = open(self.tokenfile,'w')
                # try:
                #     file.write(self.token)
                # finally:
                #     file.close()
                with open(self.tokenfile,'w') as f:
                    f.write(self.token)
            except:
                print "ERROR from class get token"
                exit("error token")

    def send_msg(self):
        ""
        # App_ID = str(AppID)
        Group_ID = Appid_Group[self.appid]
        User_ID = '@all'
        # Message = str(message)
        dict_arr = {
            "touser": User_ID,  #  ， zabbix Media ， ， 。
            "toparty": Group_ID,  #  id
            "msgtype": "text",
            "agentid": self.appid,  #  id， 。
            "text": {
                "content": self.msg
            },
            "safe": "0"
        }

        try:
            json_template = json.dumps(dict_arr, ensure_ascii=False)
            requst_url = "https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token=" + self.token
            Format_MSG = urllib2.urlopen(requst_url, json_template)
            return_MSG = Format_MSG.read()
            #  json 
            j = json.loads(return_MSG)
            j.keys()
            # return self.j.keys
            errcode = j['errcode']
            # print errcode,type(errcode)
            errmsg = j['errmsg']
            # print errmsg,type(errmsg)
            if errcode == 0 and errmsg == u'ok':
                return True
            else:
                return False

        except urllib2.HTTPError, e:
            print e
        except urllib2.URLError, e:
            print e
        except:
            print "ERROR from send message"

def DO_PUSH(appid,msg):
    ""
    xp = weixin(appid,msg)
    xp.get_token(True)
    if xp.send_msg():
        return True
    else:
        xp.get_token(False)
        if xp.send_msg():
            return True
        else:
            return False


if __name__ == '__main__':
    ""
    DO_PUSH(6,'test')