微信推送功能

微信推送功能

 

首先咱們要知道微信分爲訂閱號,服務號和企業號,其中只有企業號能夠主動向關注的人推送消息,而訂閱號和服務號只有關注人主動發送消息後的48小時才能向關注人發送消息

咱們在業務中要實現微信推送功能通常是使用企業號html

和支付寶支付同樣,咱們一樣須要微信給咱們提供的接口api,這裏咱們也使用沙箱環境進行測試https://mp.weixin.qq.com/debug/cgi-bin/sandbox?t=sandbox/login前端

登陸完成後會給咱們提供appid和appsecret,後面會用到jquery

而後咱們還會獲得咱們的公衆號的二維碼,已經關注人的名單ajax

每一個人關注後都會在這裏顯示,而且每一個人都有一個單獨的微信號,咱們能夠經過這個微信號給別人發消息,可是別人關注後微信能拿到他的微信號,而咱們只能到網頁上查看而不能及時得到微信號,因此咱們須要經過一些操做來讓微信端把微信號發給咱們數據庫

咱們先建立一個django項目,生成如下路由django

複製代碼
from django.conf.urls import url
from django.contrib import admin
from app01 import views

urlpatterns = [
    url(r'^admin/', admin.site.urls),
    url(r'^login/$', views.login),
    url(r'^bind/$', views.bind),
    url(r'^bind_qcode/$', views.bind_qcode),
    url(r'^callback/$', views.callback),
    url(r'^sendmsg/$', views.sendmsg),
]
複製代碼

訪問時要先登陸json

複製代碼
import json
import functools
import requests
from django.conf import settings
from django.shortcuts import render, redirect, HttpResponse
from django.http import JsonResponse
from app01 import models
# 沙箱環境地質:https://mp.weixin.qq.com/debug/cgi-bin/sandbox?t=sandbox/login

def auth(func):
    @functools.wraps(func)
    def inner(request, *args, **kwargs):
        user_info = request.session.get('user_info')
        if not user_info:
            return redirect('/login/')
        return func(request, *args, **kwargs)
    return inner


def login(request):
    """
    用戶登陸
    :param request: 
    :return: 
    """
    # models.UserInfo.objects.create(username='luffy',password=123)

    if request.method == "POST":
        user = request.POST.get('user')
        pwd = request.POST.get('pwd')
        obj = models.UserInfo.objects.filter(username=user, password=pwd).first()
        if obj:
            request.session['user_info'] = {'id': obj.id, 'name': obj.username, 'uid': obj.uid}
            return redirect('/bind/')
    else:
        return render(request, 'login.html')
複製代碼

登陸完成後咱們給每一個用戶生成一個獨有的uid號,並將用戶id,name和uid存入session中後端

用戶表api

複製代碼
import hashlib
from django.db import models

class UserInfo(models.Model):
    username = models.CharField("用戶名", max_length=64, unique=True)
    password = models.CharField("用戶名", max_length=64)
    uid = models.CharField(verbose_name='我的惟一ID',max_length=64, unique=True)
    wx_id = models.CharField(verbose_name="微信ID", max_length=128, blank=True, null=True, db_index=True)

    def save(self, *args, **kwargs):
        # 建立用戶時,爲用戶自動生成我的惟一ID
        if not self.pk:
            m = hashlib.md5()
            m.update(self.username.encode(encoding="utf-8"))
            self.uid = m.hexdigest()
        super(UserInfo, self).save(*args, **kwargs)
複製代碼

登陸完成後咱們提供了一個頁面,用來給用戶關注咱們的微信號緩存

複製代碼
@auth
def bind(request):
    """
    用戶登陸後,關注公衆號,並綁定我的微信(用於之後消息推送)
    :param request: 
    :return: 
    """
    return render(request, 'bind.html')
複製代碼

頁面

複製代碼
{% load staticfiles %}

<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <title>Title</title>
</head>
<body>
<div style="width: 600px;margin: 0 auto">
    <h1>請關注路飛學城服務號,並綁定我的用戶(用於之後的消息提醒)</h1>
    <div>
        <h3>第一步:關注路飛學城微信服務號</h3>
        <img style="height: 100px;width: 100px" src="{% static "img/luffy.jpeg" %}">
    </div>
    <input type="button" value="下一步【獲取綁定二維碼】" onclick="getBindUserQcode()">
    <div>
        <h3>第二步:綁定我的帳戶</h3>
        <div id="qrcode" style="width: 250px;height: 250px;margin: 100px auto;"></div>
    </div>
</div>
<script src="{% static "js/jquery.min.js" %}"></script>
<script src="{% static "js/jquery.qrcode.min.js" %}"></script>
<script src="{% static "js/qrcode.js" %}"></script>
<script>
    function getBindUserQcode() {
        $.ajax({
            url: '/bind_qcode/',
            type: 'GET',
            success: function (result) {
                console.log(result);
                $('#qrcode').empty().qrcode({text: result.data});
            }
        });
    }
</script>

</body>
</html>
複製代碼

在頁面上咱們放了咱們的微信號的二維碼

用戶掃碼關注後其實就已經完成了,可是咱們爲了能直接拿到用戶的微信號,要誘導用戶進行下面的操做,首先要點擊下一步,一旦點擊了就會觸發咱們的點擊事件,這個事件會向後端發送一個ajax請求

複製代碼
<script>
    function getBindUserQcode() {
        $.ajax({
            url: '/bind_qcode/',
            type: 'GET',
            success: function (result) {
                console.log(result);
                $('#qrcode').empty().qrcode({text: result.data});
            }
        });
    }
</script>
複製代碼

後端收到後會給前端返回一個url

複製代碼
@auth
def bind_qcode(request):
    """
    生成二維碼
    :param request: 
    :return: 
    """
    ret = {'code': 1000}
    try:
        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=settings.WECHAT_CONFIG["app_id"],
            redirect_uri=settings.WECHAT_CONFIG["redirect_uri"],
            state=request.session['user_info']['uid']
        )
        ret['data'] = access_url
    except Exception as e:
        ret['code'] = 1001
        ret['msg'] = str(e)

    return JsonResponse(ret)
複製代碼

這個url中須要有appid,咱們生成的用戶uid信息state和微信收到請求處理完成後跳轉的urlredirect_uri

這裏的settings中的參數爲

# ############# 微信 ##############
WECHAT_CONFIG = {
    'app_id': 'wx89085e915d351cae',
    'appsecret': '64f87abfc664f1d4f11d0ac98b24c42d',
    'redirect_uri': 'http://47.93.4.198/callback/',
}

前端收到這個url後會利用jquery.qrcode.min.js和qrcode.js將url變成一個二維碼放到頁面上,用戶掃這個二維碼就至關於訪問這個url

複製代碼
<div>
        <h3>第二步:綁定我的帳戶</h3>
        <div id="qrcode" style="width: 250px;height: 250px;margin: 100px auto;"></div>
    </div>
</div>
<script src="{% static "js/jquery.min.js" %}"></script>
<script src="{% static "js/jquery.qrcode.min.js" %}"></script>
<script src="{% static "js/qrcode.js" %}"></script>
<script>
    function getBindUserQcode() {
        $.ajax({
            url: '/bind_qcode/',
            type: 'GET',
            success: function (result) {
                console.log(result);
                $('#qrcode').empty().qrcode({text: result.data});
            }
        });
    }
</script>
複製代碼

這個url其實就是微信的一個接口,微信收到消息後會向用戶確認是否受權相關信息,若是贊成了則會跳轉到咱們傳的跳轉地址

用戶掃碼後的操做界面

點擊容許後

這時就會訪問的設置的跳轉地址

複製代碼
def callback(request):
    """
    用戶在手機微信上掃碼後,微信自動調用該方法。
    用於獲取掃碼用戶的惟一ID,之後用於給他推送消息。
    :param request: 
    :return: 
    """
    code = request.GET.get("code")

    # 用戶UID
    state = request.GET.get("state")

    # 獲取該用戶openId(用戶惟一,用於給用戶發送消息)
    res = requests.get(
        url="https://api.weixin.qq.com/sns/oauth2/access_token",
        params={
            "appid": 'wx89085e915d351cae',
            "secret": '64f87abfc664f1d4f11d0ac98b24c42d',
            "code": code,
            "grant_type": 'authorization_code',
        }
    ).json()
    # 獲取的到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)
複製代碼

在跳轉的頁面中咱們能夠獲取到用戶的state信息(也就是咱們以前生成的uid),而後咱們還須要利用requests模塊再次向微信發送一個請求去獲取用戶的微信號,也就是上面代碼中的openid,這個請求中須要傳appid,secret,code以及grant_type,獲取到

openid後咱們要進行判斷,若是它存在則要在數據庫中爲用戶添加這一id,以便之後向用戶發送微信,若是沒有則返回相應的信息

完成上面的步驟後咱們的數據庫中就有了不一樣用戶對應的微信號,咱們就能夠發送消息了

複製代碼
def sendmsg(request):
    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

    def send_custom_msg(to_user,token,content):
        body = {
            "touser": to_user,
            "msgtype": "text",
            "text": {
                "content": content
            }
        }
        response = requests.post(
            url="https://api.weixin.qq.com/cgi-bin/message/custom/send",
            params={
                'access_token': token
            },
            data=bytes(json.dumps(body, ensure_ascii=False), encoding='utf-8')
        )
        # 這裏可根據回執code進行斷定是否發送成功(也能夠根據code根據錯誤信息)
        result = response.json()
        return result

    def send_template_msg(to_user,token):
        """
        發送模版消息
        """
        res = requests.post(
            url="https://api.weixin.qq.com/cgi-bin/message/template/send",
            params={
                'access_token': token
            },
            json={
                "touser": to_user,
                "template_id": '0XbLbuNkn3wPPAYRVXM-MZ0gU0tPvVbsjfc1qoSH6CM',
                "data": {
                    "first": {
                        "value": "李向龍",
                        "color": "#173177"
                    },
                    "keyword1": {
                        "value": "帥比",
                        "color": "#173177"
                    },
                }
            }
        )
        result = res.json()
        return result



    access_token = get_access_token()
    openid = models.UserInfo.objects.get(id=1).wx_id
    # result = send_custom_msg(openid,access_token,'你就是馬雲')
    result = send_template_msg(openid,access_token)

    print(result)
    if result.get('errcode') == 0:
        return HttpResponse('發送成功')
    return HttpResponse('發送失敗')
複製代碼

在發送前咱們須要執行get_access_token(),向微信端獲取受權,並拿到access_token,而後咱們就能夠調用發信息的函數send_custom_msg來發信息了

在發信息時咱們先要取到用戶的微信號openid,而後在發送時要,將微信號,發送內容以及access_token都傳進去,而後用戶就能收到消息了

固然咱們還能夠設置信息的模板

而後使用send_template_msg發送信息,這樣用戶就能收到以上圖爲模板的信息了

注意點:

咱們還須要修改下面的內容

在裏面填寫咱們的跳轉地址

相關文章
相關標籤/搜索