renyupeng 1 jaar geleden
bovenliggende
commit
c1fd07e27d
1 gewijzigde bestanden met toevoegingen van 39 en 0 verwijderingen
  1. 39 0
      utils/send_wechat_msg.py

+ 39 - 0
utils/send_wechat_msg.py

@@ -0,0 +1,39 @@
+#!/usr/bin/env python
+# -*- coding: utf-8 -*-
+
+import time
+import requests
+import json
+
+
+class SendWechatMsg:
+    def __init__(self):
+        self.CORPID = 'ww24b8a47826f5875f'  # 企业ID,在管理后台获取
+        self.CORPSECRET = 'MJIlySADGPlgvADnkFQPUpfZD4yV-4WN6066OgNnb0s'  # 自建应用的Secret,每个自建应用里都有单独的secret
+        self.AGENTID = '1000002'  # 应用ID,在后台应用中获取
+        self.TOUSER = "RenYuPeng"  # 接收者用户名,多个用户用|分割
+
+    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)
+        data = json.loads(req.text)
+        return data["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": "0"
+        }
+        send_msges = (bytes(json.dumps(send_values), 'utf-8'))
+        respone = requests.post(send_url, send_msges)
+        respone = respone.json()  # 当返回的数据是json串的时候直接用.json即可将respone转换成字典
+        return respone["errmsg"]