[891]利用企业微信实现监控通知

# -*- coding:utf-8 -*-
import json
import requests


class WeChatPub():

    def __init__(self,corpid='wwb1b',secret='tnbqWD0'):
        self.req = requests.session()
        self.token = self.get_token(corpid, secret)
        print("token is " + self.token)

    def get_token(self, corpid, secret):
        url = "https://qyapi.weixin.qq.com/cgi-bin/gettoken?corpid={0}&corpsecret={1}".format(corpid, secret)
        response = self.req.get(url)
        if response.status_code == 200:
            access_token=json.loads(response.content)['access_token']
            return access_token
        else:
            print("request failed.")
            return None

    def send_msg(self, content):
        url = "https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token=" + self.token
        header = {
            "Content-Type": "application/json"
        }
        form_data = {
            "touser": "@all",
            "toparty": " PartyID1 | PartyID2 ",
            "totag": " TagID1 | TagID2 ",
            "msgtype": "textcard",
            "agentid": 1000002,
            "textcard": {
                "title": "领奖通知",
                "description": content,
                "url": "URL",
                "btntxt": "更多"
            },
            "safe": 0
        }
        data=json.dumps(form_data).encode('utf-8')
        rep = self.req.post(url, data=data, headers=header)
        if rep.status_code == 200:
            return json.loads(rep.content)
        else:
            print("request failed.")
            return None


if __name__ == '__main__':
    wechat = WeChatPub()
    msg='''<div class=\"gray\">2020年7月26日</div> 
    <div class=\"normal\">恭喜你抽中iPhone 7一台，领奖码：xxxx</div>
    <div class=\"highlight\">请于2020年10月10日前联系行政同事领取</div>'''
    wechat.send_msg(msg)