服务器在线 - 服务器软件 - 网站地图 服务器在线,专注于服务器技术!

当前位置:主页 > 编程脚本 > Python > 正文

使用python通过api接口监控新网域名代理平台余额

时间:2023-01-10    来源:未知    投稿:admin    点击:

import requests,json
session = requests.session()

class WeChatPub():

    def __init__(self,corpid='11111',secret='222222'):
        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

api_url = "http://api.xinnet.com/domain/api.gb?method=CheckBalance&charset=utf-8&enc=E&client=agentID&checksum=904XXXXX966EE5A5XXXXX652822XXXXX"
b = requests.post(api_url)
print(b.text)
yue = b.text[13:-13]
yue = int(yue)

s = open("/data/monitor/xinnet/status.txt")
status = s.read()
s.close()

if yue == "r":
    print("获取异常")
if yue < 200:
    if status == "正常":
        wechat = WeChatPub()
        msg = '''
                <div class=\"normal\">数据来源:新网域名平台''' + '''</div>
                <div class=\"normal\">通知类型:余额告警''' + '''</div>
                <div class=\"normal\">当前余额:''' + str(yue) + '''</div>
                <div class=\"highlight\">通知内容:平台余额不足,请尽快充值。</div>'''
        wechat.send_msg(msg)

        f = open('/data/monitor/xinnet/status.txt', mode='w+')
        f.write(str("故障"))
        f.close()
    else:
        print("通知已发过,忽略")
else:
    if status == "正常":
        print("余额充足")
    else:
        wechat = WeChatPub()
        msg = '''
                <div class=\"normal\">数据来源:新网域名平台''' + '''</div>
                <div class=\"normal\">通知类型:余额告警''' + '''</div>
                <div class=\"normal\">当前余额:''' + str(yue) + '''</div>
                <div class=\"highlight\">通知内容:已完成充值,警告解除。</div>'''
        wechat.send_msg(msg)
        f = open('/data/monitor/xinnet/status.txt', mode='w+')
        f.write(str("正常"))
        f.close()
        
        

如果您的问题仍未解决,还可以加入服务器在线技术交流QQ群:8017413寻求帮助。


相关内容
最新热点内容