Django——微信訊息推送
阿新 • • 發佈:2018-11-08
前言
微信公眾號的分類
- 微信訊息推送
- 公眾號
- 已認證公眾號
- 服務號
- 已認證服務號
- 企業號
- 公眾號
基於:微信認證服務號 主動推送微信訊息。
前提:關注服務號
環境:沙箱環境
沙箱環境地址: https://mp.weixin.qq.com/debug/cgi-bin/sandbox?t=sandbox/login
流程:
註冊開發者賬號
獲得:appID、appsecret
網頁授權獲取使用者基本資訊:47.98.134.86 或 域名
關注公眾號(已認證的服務號)
生成二維碼,使用者掃描;
將使用者資訊傳送給微信,微信再將資料傳送給設定redirect_uri地址(md5值)回撥地址:47.98.134.86/callback/
- 授權
- 使用者md5
- 獲取wx_id
在資料庫中更新設定:wx_id
傳送訊息(模板訊息)
wx_id
access_token(2小時有效期)
核心程式碼
models.py
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)
settings.py
WECHAT_CONFIG = {
'app_id': 'wx3d0d44e8d59b5b8c',
'appsecret': 'a4ede68946e9a2e7e36480d23865a64d',
'redirect_uri': 'http://47.106.237.76/callback/',
}
views.py
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 index(request): obj = models.UserInfo.objects.get(id=1) return render(request,'index.html',{'obj':obj}) 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(to='/bind/') else: return render(request, 'login.html') @auth def bind(request): """ 使用者登入後,關注公眾號,並繫結個人微信(用於以後訊息推送) :param request: :return: """ return render(request, 'bind.html') @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"], # 'wx89085e915d351cae', redirect_uri=settings.WECHAT_CONFIG["redirect_uri"], # 'http://47.93.4.198/test/', state=request.session['user_info']['uid'] # 為當前使用者生成MD5值 ) ret['data'] = access_url except Exception as e: ret['code'] = 1001 ret['msg'] = str(e) return JsonResponse(ret) def callback(request): """ 使用者在手機微信上掃碼後,微信自動呼叫該方法。 用於獲取掃碼使用者的唯一ID,以後用於給他推送訊息。 :param request: :return: """ code = request.GET.get("code") # 使用者md5值 state = request.GET.get("state") # 獲取該使用者openId(使用者唯一,用於給使用者傳送訊息) 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() # 獲取的到openid表示使用者授權成功 openid = res.get("openid") print(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) 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 access_token = get_access_token() openid = models.UserInfo.objects.get(id=1).wx_id print(openid) def send_custom_msg(): body = { "touser": openid, "msgtype": "text", "text": { "content": '雲姐好美呀' } } response = requests.post( url="https://api.weixin.qq.com/cgi-bin/message/custom/send", params={ 'access_token': access_token }, data=bytes(json.dumps(body, ensure_ascii=False), encoding='utf-8') ) # 這裡可根據回執code進行判定是否傳送成功(也可以根據code根據錯誤資訊) result = response.json() return result 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": 'NcN_W_aEIwu-FHyJx8djU99Z70AvwwGcEufXiTzj-NM', "data": { "first": { "value": "冰姐", "color": "#173177" }, "keyword1": { "value": "美女", "color": "#173177" }, } } ) result = res.json() return result # 在這裡編輯要傳送的函式中的內容 result = send_template_msg() if result.get('errcode') == 0: return HttpResponse('傳送成功') return HttpResponse('傳送失敗')
功能演示
1登陸:
2客戶掃碼關注我們的公眾號
為了獲得使用者的微信ID,我們需要客戶再次掃碼,向微信授權把ID給我們