Django+wechapy 微信公众号开发

博主好久没有更新了

这次整理下最近研究的简单的公众号平台搭建

这边用的是 wechatpy库 官网链接

# -*- coding: utf-8 -*-
# 公众号
# 作者: XX
# 时间: 2019-12-25


import logging
import requests

from Zmops import settings
from api.gaodei import GaoDeiBase

from wechat.pack import Pack

from django.http.response import HttpResponse, HttpResponseRedirect
from django.views.decorators.csrf import csrf_exempt
from django.shortcuts import redirect
from django.shortcuts import render
from django.contrib import messages

from wechatpy.exceptions import InvalidSignatureException, WeChatClientException
from wechatpy import parse_message
from wechatpy.replies import TextReply, ImageReply, VoiceReply
from wechatpy import WeChatClient
from wechatpy.oauth import WeChatOAuth
from wechatpy.utils import check_signature


logger = logging.getLogger("log")


def views_index(request):
    return HttpResponse("Zmops 公众号平台")


def views_create_menu(request):
    WechatBase().delete_menu()
    WechatBase().create_menu()
    return HttpResponse("成功创建自定义菜单")


class WechatServer(object):
    """
    公众号服务类
    """
    @csrf_exempt
    def serve(self, request):
        # GET 方式用于微信公众平台绑定验证
        if request.method == "GET":
            signature = request.GET.get("signature", "")
            timestamp = request.GET.get("timestamp", "")
            nonce = request.GET.get("nonce", "")
            echo_str = request.GET.get("echostr", "")
            try:
                logger.info("Token:%s" % settings.Token)
                logger.info("signature:%s" % signature)
                logger.info("timestamp:%s" % timestamp)
                logger.info("nonce:%s" % nonce)
                check_signature(settings.Token, signature, timestamp, nonce)
            except InvalidSignatureException:
                echo_str = "错误的请求"
            logger.info(echo_str)
            response = HttpResponse(echo_str)
        elif request.method == "POST":

            msg = parse_message(request.body)
            open_id = msg.source
            msg_dict = msg.__dict__["_data"]
            logger.info("用户open_id:%s" % open_id)
            logger.info("用户msg_dict:%s" % msg_dict)
            # 文本消息
            if msg.type == "text":
                reply = TextReply(message=msg)
                reply.content = "收到你发送的文本消息"
                xml = reply.render()
            # 图片消息
            elif msg.type == "image":
                reply = ImageReply(message=msg)
                reply.content = "收到你发送的图片消息"
                reply.media_id = msg.media_id
                xml = reply.render()
            # 语音消息
            elif msg.type == "voice":
                reply = VoiceReply(message=msg)
                reply.content = "收到你发送的语言消息"
                reply.media_id = msg.media_id
                xml = reply.render()
            # 动作消息
            elif msg.type == "event":
                reply = TextReply(message=msg)
                logger.info("操作的event:%s" % msg_dict["Event"])
                if msg_dict["Event"] == "subscribe":
                    reply.content = "你成功关注了此公众号
我们的目标是
让天下没有难做的运维 !
"
                    xml = reply.render()
                    wx_user_info = WechatBase().get_wx_user_info(open_id)
                    Pack().user_create(_json=wx_user_info, subscribe=1)

                elif msg_dict["Event"] == "unsubscribe":
                    reply.content = "你取消关注了此公众号"
                    xml = reply.render()
                    wx_user_info = WechatBase().get_wx_user_info(open_id)
                    Pack().user_create(_json=wx_user_info, subscribe=0)

                elif msg_dict["Event"] == "LOCATION":
                    latitude = msg_dict["Latitude"]
                    longitude = msg_dict["Longitude"]
                    reply.content = {
                        "latitude": latitude,
                        "longitude": longitude
                    }
                    xml = reply.render()
                else:
                    reply.content = "你的动作类型未知"
                    xml = reply.render()
            # 未知消息类型
            else:
                # 捕捉公众号消息类型
                logger.info("公众号接收到的消息类型:%s" % msg.type)
                reply = TextReply(message=msg)
                reply.content = "收到你发送的未知消息类型:%s" % msg.type
                xml = reply.render()
            response = HttpResponse(xml, content_type="application/xml")
        else:
            response = HttpResponse("公众号系统异常", content_type="application/xml")
        return response



class WechatBase(object):
    def __init__(self):
        self.AppID = settings.AppID
        self.AppSecret = settings.AppSecret
        self.URL = settings.URL

    def get_access_token(self):
        response = requests.get(url="https://api.weixin.qq.com/cgi-bin/token", params={
            "grant_type": "client_credential",
            "appid": self.AppID,
            "secret": self.AppSecret
        })
        text = response.text

        if text["expires_in"] == 7200:
            access_token = text["access_token"]
            return access_token
        else:
            logger.info("获取access_token异常")
            return False

    # 获取微信代理授权
    def get_wx_client(self):
        logger.info("获取微信代理授权")
        return WeChatClient(self.AppID, self.AppSecret)

    def get_wx_user_info(self, openid):
        wx_client = self.get_wx_client()
        try:
            wx_user_info = wx_client.user.get(user_id=openid)
            logger.info("微信用户信息:%s" % wx_user_info)
            return wx_user_info
        except WeChatClientException as e:
            logger.error(e)
            return False

    def get_wechat_oauth(self, redirect_url):
        return WeChatOAuth(app_id=self.AppID, secret=self.AppSecret, redirect_uri=redirect_url, scope="snsapi_userinfo")

    def create_menu(self):
        wx_client = self.get_wx_client()
        wx_client.menu.create({
            "button": [
                {
                    "type": "view",
                    "name": "更新菜单",
                    "url": self.URL + "/api/menu/create"
                },
                {
                    "type": "view",
                    "name": "当前IP地图",
                    "url": self.URL + "/api/address_ip/get"
                },
                {
                    "type": "view",
                    "name": "功能测试",
                    "url": self.URL + "/api/test"
                }
            ],
            "matchrule": {
                "tag_id": None,
                "sex": None,
                "country": "XX",
                "province": "XX",
                "city": "XX",
                "client_platform_type": None

            }
        })
        logger.info("成功创建菜单")

    def delete_menu(self):
        wx_client = self.get_wx_client()
        wx_client.menu.delete()
        logger.info("成功删除菜单")


# 定义授权装饰器
def oauth(method):
    def warpper(request):
        if request.session.get("user_info", None) is None:
            code = request.GET.get("code", None)
            # logger.info()(request.get_raw_uri())
            wechat_oauth = WechatBase().get_wechat_oauth(request.get_raw_uri())
            url = wechat_oauth.authorize_url
            if code:
                try:
                    wechat_oauth.fetch_access_token(code)
                    user_info = wechat_oauth.get_user_info()
                except Exception as e:
                    logger.error(e)
                else:
                    request.session["user_info"] = user_info
            else:
                return redirect(url)

        return method(request)

    return warpper


@oauth
def views_get_user_info(request):
    user_info = request.session.get("user_info")
    logger.info(user_info)
    return HttpResponse(str(user_info))

在上传代码部署过程中 会需要生成 requirements 文件

这边命令是

pip freeze > requirements.txt

基于已生成的 requirements文件 安装相关模块

pip install -r requirements.txt