Python 发送企业微信消息

#!/usr/bin/env python
# -*- coding:utf- -*-import json
import requestsclass WeChat:
def __init__(self):
self.CORPID = '*******' //企业ID
self.CORPSECRET = '*******' //自建应用的Secret
self.AGENTID = '*****' //自建应用的ID
self.TOUSER = "*****" //企业微信接收人 def _get_access_token(self):
url = 'https://qyapi.weixin.qq.com/cgi-bin/gettoken'
values = {'corpid': self.CORPID,
'corpsecret': self.CORPSECRET,
}
req = requests.post(url, params=values)
return req def get_access_token(self):
get_req = self._get_access_token()
if get_req.status_code != :
print('连接服务器失败')
else:
get_req_json = json.loads(get_req.text)
if get_req_json['errcode'] != :
print('响应结果不正确')
else:
access_token = get_req_json['access_token']
return access_token def send_data(self, message):
send_url = 'https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token=' + self.get_access_token()
send_values = {
"touser": self.TOUSER,
"msgtype": "text",
"agentid": self.AGENTID,
"text": {
"content": message
},
"safe": ""
}
send_msges = (bytes(json.dumps(send_values), 'utf-8'))
respone = requests.post(send_url, send_msges)
respone = respone.json()
return respone["errmsg"]if __name__ == "__main__":
wx = WeChat()
wx.send_data("您有新的工单未处理，登入<a href=\"http://request-tracker.ic\">工单系统</a>查看。")