微信推送功能
首先我們要知道微信分為訂閱號，服務號和企業號，其中只有企業號可以主動向關注的人推送消息，而訂閱號和服務號只有關注人主動發送消息后的48小時才能向關注人發送消息
我們在業務中要實現微信推送功能一般是使用企業號
和支付寶支付一樣，我們同樣需要微信給我們提供的接口api，這里我們也使用沙箱環境進行測試https://mp.weixin.qq.com/debug/cgi-bin/sandbox?t=sandbox/login
登錄完成后會給我們提供appid和appsecret，后面會用到
然后我們還會得到我們的公眾號的二維碼，已經關注人的名單
每個人關注后都會在這里顯示，並且每個人都有一個單獨的微信號，我們可以通過這個微信號給別人發消息，但是別人關注后微信能拿到他的微信號，而我們只能到網頁上查看而不能及時獲得微信號，所以我們需要通過一些操作來讓微信端把微信號發給我們
我們先創建一個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),
]
訪問時要先登錄
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中
用戶表
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發送信息，這樣用戶就能收到以上圖為模板的信息了
注意點：
我們還需要修改下面的內容
在里面填寫我們的跳轉地址
