wechat/message_test.py at master · Baoarmy/wechat · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
import json
import pprint
import requests


class WeChat(object):
    def __init__(self):
        self.access_token_url = "https://api.weixin.qq.com/cgi-bin/token?"
        self.params = {
            'grant_type': 'client_credential',
            'appid': 'wx699313dbd53fd72b',  # 公众号appid,按自己实际填写
            'secret': '900596620c53eccf4a53edf67bd8e854',  # 待按自己实际填写
        }
        self.user_lst_url = "https://api.weixin.qq.com/cgi-bin/user/get?"
        pass

    def get_access_token(self):

        response = requests.get(url=self.access_token_url, params=self.params)
        access_token = response.json().get("access_token")
        return access_token

    def get_user_list(self, token):

        payload = {
            "access_token": token,
            "next_openid": None
        }
        response = requests.get(self.user_lst_url, params=payload)
        openid = response.json()
        return openid

    def post_data(self, token):
        data = {
            "touser": "oT9fT02dO-T-qx1Cd91hriVGn6r0",
            "template_id": "UL-IqbOsS3zIn9Qy14qdla1xRgTmktqOj68k98BoxyM",  # 模板ID
            "data": {
                "first": {
                    "value": "尊敬的用户，感谢您的关注和支持！",
                    "color": "#173177"
                },
                "keynote1": {
                    "value": "已完成",
                    "color": "#173177"
                },
                "keynote2": {
                    "value": "2014年5月20日12：24",
                    "color": "#173177"
                },
                "remark": {
                    "value": "感谢您选择我们的服务！",
                    "color": "#173177"
                }
            }
        }
        json_template = json.dumps(data)
        # access_token = self.get_access_token()
        print("access_token--", token)
        url = "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token=" + token
        try:
            respone = requests.post(url, data=json_template, timeout=50)
            # 拿到返回值
            errcode = respone.json().get("errcode")
            print("test--", respone.json())
            if errcode == 0:
                print("模板消息发送成功")
            else:
                print("模板消息发送失败")
            return respone.json()
        except Exception as e:
            print("test++", str(e))

    def get_user_info(self, token, user_list):
        user_info_url = "https://api.weixin.qq.com/cgi-bin/user/info?"
        openid = user_list.get("data").get("openid")
        for item in openid:

            payload = {
                "access_token": token,
                "openid": item,
                "lang": "zh_CN"
            }

            response = requests.get(user_info_url, params=payload)
            user_info = response.json()
            if user_info["nickname"] == "马钰 精化快车":
                return user_info

    def user_list_test(self):
        users = "oT9fT01Ywj86PUxJCNAVxpvckQ6w"
        user_list = json.loads(users)
        print(type(user_list))
        print(user_list)


if __name__ == '__main__':
    token = WeChat().get_access_token()
    print(token)
    user_list = WeChat().get_user_list(token)
    result = WeChat().get_user_info(token, user_list)
    # # res = WeChat().post_data(token)
    print(result)
    # WeChat().user_list_test()