Django调用微信推送接口

2020-06-01  本文已影响0人  北海鲸落

源码:Gitee地址

欢迎Star~

一、微信授权登录(OAuth2.0)

OAuth(开放授权)是一个开放标准,允许用户让第三方应用访问该用户在某一网站上存储的私密的资源(如照片,视频,联系人列表),而无需将用户名和密码提供给第三方应用。具体详情可以参考阮一峰blog

​ 参考文档:微信公众平台开发者文档

二、申请公众号测试账号

申请地址

  1. 获取appIDappsecret

  2. 下拉,扫描测试号二维码,关注后右侧会出现用户列表

  3. 记录出现的微信号,即为用户的openid

  4. 自定义消息模板接口

  5. 如果有自己的域名资源,可以去设置域名配置,去获取网页授权。注意端口:443/80

  6. 网页服务—>网页账号—>网页授权获取用户基本信息—>修改

三、流程

  1. 进入页面
  2. 生成二维码
  3. 调用回调,获取扫码用户openid
  4. 推送消息

四、使用方式

  1. python manage.py makemigrations
  2. python manage.py migrate
  3. 修改settings.pyapp_id appsecret redirect_uri template_id
  4. python manage.py runserver 0.0.0.0:8001
  5. 输入网址http://127.0.0.1:8001/index/

五、功能实现

1. 生成二维码

目的:通过网页授权,获取code

def bind_qcode(request):
    """
    生成二维码
    :param request: 
    :return: 
    """
    ret = {'code': 1000}
    user = str(models.UserInfo.objects.get(id=1).id)
    try:
        m=hashlib.md5()
        m.update(user.encode('utf-8'))
        access_url = "https://open.weixin.qq.com/connect/oauth2/authorize?appid={appid}&redirect_uri={redirect_uri}&response_type=code&scope=snsapi_userinfo&state={state}#wechat_redirect"
        access_url = access_url.format(
            # 商户的appid
            appid=settings.WECHAT_CONFIG["app_id"], # 'wx6edde7a6a97e4fcd',
            # 回调地址
            redirect_uri=settings.WECHAT_CONFIG["redirect_uri"],
            # 当前登录用户的唯一id
            state=m.hexdigest # 为当前用户生成MD5值
        )
        ret['data'] = access_url
    except Exception as e:
        ret['code'] = 1001
        ret['msg'] = '失败'
        ret['data'] = ''
    return JsonResponse(ret)
2. 回调函数

目的:获取扫码用户的唯一ID

def callback(request):
    """
    用户在手机微信上扫码后,微信自动调用该方法。
    用于获取扫码用户的唯一ID,以后用于给他推送消息。
    """
    code = request.GET.get("code")
    # 用户md5值,用户唯一id
    state = request.GET.get("state")
    # 获取该用户openId(用户唯一,用于给用户发送消息)
    # request模块朝https://api.weixin.qq.com/sns/oauth2/access_token地址发get请求
    res = requests.get(
        url="https://api.weixin.qq.com/sns/oauth2/access_token",
        params={
            "appid": settings.WECHAT_CONFIG['app_id'],
            "secret": settings.WECHAT_CONFIG['appsecret'],
            "code": code,
            "grant_type": 'authorization_code',
        }
    ).json()
    # res.data   是json格式
    # res=json.loads(res.data)
    # res是一个字典
    # 获取的到openid表示用户授权成功
    openid = res.get("openid")
    if openid:
        models.UserInfo.objects.filter(uid=state).update(wx_id=openid)
        response = "<h1>授权成功 %s </h1>" % openid
    else:
        response = "<h1>用户扫码之后,手机上的提示</h1>"
    return HttpResponse(response)
3. 发送信息

目的:定向给用户发送信息

def sendmsg(request):
    # 获取access_token,默认有效期2小时
    def get_access_token():
        result = requests.get(
            url="https://api.weixin.qq.com/cgi-bin/token",
            params={
                "grant_type": "client_credential",
                "appid": settings.WECHAT_CONFIG['app_id'],
                "secret": settings.WECHAT_CONFIG['appsecret'],
            }
        ).json()
        if result.get("access_token"):
            access_token = result.get('access_token')
        else:
            access_token = None
        return access_token
    access_token = get_access_token()
    openid = models.UserInfo.objects.get(id=1).wx_id

    # 发送模板消息
    def send_template_msg():
        res = requests.post(
            url="https://api.weixin.qq.com/cgi-bin/message/template/send",
            params={
                'access_token': access_token
            },
            json={
                "touser": openid,
                "template_id": settings.WECHAT_CONFIG['template_id'],
            }
        )
        result = res.json()
        return result
    ret = {'code': 1000}
    result = send_template_msg()
    if result.get('errcode') == 0:
        ret['msg'] = '发送成功'
        return JsonResponse(ret)
    return JsonResponse(ret)
上一篇下一篇

猜你喜欢

热点阅读