如何基于Serverless借助微信公眾號簡單管理用戶激活碼
本篇文章給大家分享的是有關(guān)如何基于Serverless借助微信公眾號簡單管理用戶激活碼，小編覺得挺實(shí)用的，因此分享給大家學(xué)習(xí)，希望大家閱讀完這篇文章后可以有所收獲，話不多說，跟著小編一起來看看吧。
成都創(chuàng)新互聯(lián)是一家從事企業(yè)網(wǎng)站建設(shè)、成都網(wǎng)站建設(shè)、成都網(wǎng)站設(shè)計(jì)、行業(yè)門戶網(wǎng)站建設(shè)、網(wǎng)頁設(shè)計(jì)制作的專業(yè)網(wǎng)站制作公司，擁有經(jīng)驗(yàn)豐富的網(wǎng)站建設(shè)工程師和網(wǎng)頁設(shè)計(jì)人員，具備各種規(guī)模與類型網(wǎng)站建設(shè)的實(shí)力，在網(wǎng)站建設(shè)領(lǐng)域樹立了自己獨(dú)特的設(shè)計(jì)風(fēng)格。自公司成立以來曾獨(dú)立設(shè)計(jì)制作的站點(diǎn)近1000家。
作為一名獨(dú)立開發(fā)者，最近我在考慮給自己的應(yīng)用加入付費(fèi)功能，然后應(yīng)用的核心功能只需使用激活碼付費(fèi)激活即可。這個(gè)需求涉及到了激活碼的保存、校驗(yàn)和后臺管理，傳統(tǒng)的做法可能是自己購買服務(wù)器，搭建配置服務(wù)器環(huán)境，然后創(chuàng)建數(shù)據(jù)庫，編寫后端業(yè)務(wù)邏輯代碼，必要的時(shí)候還要自己去寫一些前端的界面來管理后臺數(shù)據(jù)。
這是一個(gè)十分耗時(shí)且無趣的工作。
嘗試帶大家使用云函數(shù) SCF 和對象存儲 COS，快速編寫上線自己的用戶激活碼后端管理云函數(shù)，然后把自己的微信公眾號后臺做為應(yīng)用前臺，簡單管理用戶激活碼。
可以看到，現(xiàn)在我們只需要在自己的微信公眾號后臺回復(fù) 會員@激活時(shí)長，就可以添加并回復(fù)一個(gè)指定有效期的會員激活碼，實(shí)現(xiàn)了在微信公眾號簡單管理用戶激活碼的需求。
操作步驟
第一步：新建 python 云函數(shù)
第二步：編寫云函數(shù)
話不多說，上代碼
import json
from wechatpy.replies import ArticlesReply
from wechatpy.utils import check_signature
from wechatpy.crypto import WeChatCrypto
from wechatpy import parse_message, create_reply
from wechatpy.exceptions import InvalidSignatureException, InvalidAppIdException
import datetime
import random
# 是否開啟本地debug模式
debug = False
# 騰訊云對象存儲依賴
if debug:
from qcloud_cos import CosConfig
from qcloud_cos import CosS3Client
from qcloud_cos import CosServiceError
from qcloud_cos import CosClientError
else:
from qcloud_cos_v5 import CosConfig
from qcloud_cos_v5 import CosS3Client
from qcloud_cos_v5 import CosServiceError
from qcloud_cos_v5 import CosClientError
# 配置存儲桶
appid = '66666666666'
secret_id = u'xxxxxxxxxxxxxxx'
secret_key = u'xxxxxxxxxxxxxxx'
region = u'ap-chongqing'
bucket = 'name'+'-'+appid
# 微信公眾號對接
wecaht_id = 'xxxxxxxxxxxxxxx'
WECHAT_TOKEN = 'xxxxxxxxxxxxxxxxxxx'
encoding_aes_key = 'xxxxxxxxxxxxxxxxxxxxxx'
# 對象存儲實(shí)例
config = CosConfig(Secret_id=secret_id, Secret_key=secret_key, Region=region)
client = CosS3Client(config)
#微信公眾號后臺消息加解密實(shí)例
crypto = WeChatCrypto(WECHAT_TOKEN, encoding_aes_key, wecaht_id)
# cos 文件讀寫
def cosRead(key):
try:
response = client.get_object(Bucket=bucket, Key=key)
txtBytes = response['Body'].get_raw_stream()
return txtBytes.read().decode()
except CosServiceError as e:
return ""
def cosWrite(key, txt):
try:
response = client.put_object(
Bucket=bucket,
Body=txt.encode(encoding="utf-8"),
Key=key,
)
return True
except CosServiceError as e:
return False
#獲取所有會員激活碼
def getvips():
vipMap = {}
vipTxt = cosRead('vips.txt') # 讀取數(shù)據(jù)
if len(vipTxt) > 0:
vipMap = json.loads(vipTxt)
return vipMap
#添加會員激活碼
def addvip(days):
vip=randomKey()
vipMap = getvips()
if len(vipMap) > 0:
vipMap[vip] = (datetime.datetime.now()+datetime.timedelta(days=days)).strftime("%Y-%m-%d")
return cosWrite('vips.txt', json.dumps(vipMap, ensure_ascii=False)),vip if len(vipMap) > 0 else False,''
#刪除會員激活碼
def delvip(vip):
vipMap = getvips()
if len(vipMap) > 0:
vipMap.pop(vip)
return cosWrite('vips.txt', json.dumps(vipMap, ensure_ascii=False)) if len(vipMap) > 0 else False
# 獲取今日日期
def today():
return datetime.datetime.now().strftime("%Y-%m-%d")
# 判斷激活碼是否到期
def checkVip(t):
return t == today()
# 隨機(jī)生成激活碼
def randomKey():
return ''.join(random.sample('zyxwvutsrqponmlkjihgfedcba0123456789', 6))
#每天定時(shí)檢查刪除過期的激活碼
def check_del_vips():
vipMap = getvips()
if len(vipMap) < 1:
return
for vip in vipMap.keys():
if not checkVip(vipMap[vip]):
vipMap.pop(vip)
return cosWrite('vips.txt', json.dumps(vipMap, ensure_ascii=False))
# api網(wǎng)關(guān)響應(yīng)集成
def apiReply(reply, txt=False, content_type='application/json', code=200):
return {
"isBase64Encoded": False,
"statusCode": code,
"headers": {'Content-Type': content_type},
"body": json.dumps(reply, ensure_ascii=False) if not txt else str(reply)
}
def replyMessage(msg):
txt = msg.content
if '@' in txt:
keys = txt.split('@')
if keys[0] == '會員': # 會員@356 --> 添加一個(gè)365天的會員激活碼
flag,vip=addvip(keys[1])
return create_reply(f"您的激活碼:{vip}，有效期:{keys[1]}天" if flag else "添加失敗", msg)
return create_reply("喵嗚 ?'ω'?", msg)
def wechat(httpMethod, requestParameters, body=''):
if httpMethod == 'GET':
signature = requestParameters['signature']
timestamp = requestParameters['timestamp']
nonce = requestParameters['nonce']
echo_str = requestParameters['echostr']
try:
check_signature(WECHAT_TOKEN, signature, timestamp, nonce)
except InvalidSignatureException:
echo_str = 'error'
return apiReply(echo_str, txt=True, content_type="text/plain")
elif httpMethod == 'POST':
msg_signature = requestParameters['msg_signature']
timestamp = requestParameters['timestamp']
nonce = requestParameters['nonce']
try:
decrypted_xml = crypto.decrypt_message(
body,
msg_signature,
timestamp,
nonce
)
except (InvalidAppIdException, InvalidSignatureException):
return
msg = parse_message(decrypted_xml)
if msg.type == 'text':
reply = replyMessage(msg)
else:
reply = create_reply('哈? ??？\n搞不明白你給我發(fā)了啥~', msg)
reply = reply.render()
reply = crypto.encrypt_message(reply, nonce, timestamp)
return apiReply(reply, txt=True, content_type="application/xml")
else:
msg = parse_message(body)
reply = create_reply("喵嗚 ?'ω'?", msg).render()
reply = crypto.encrypt_message(reply, nonce, timestamp)
return apiReply(reply, txt=True, content_type="application/xml")
def main_handler(event, context):
if 'Time' in event.keys(): # 來自定時(shí)觸發(fā)器
return check_del_vips()
httpMethod = event["httpMethod"]
requestParameters = event['queryString']
body = event['body'] if 'body' in event.keys() else ''
response = wechat(httpMethod, requestParameters, body=body)
return responseOK, 教程結(jié)束，
哈？你說沒看懂這堆代碼？
好吧，我再耐心給大家捋一下，這次可一定要記住了哈~
def main_handler(event, context): if 'Time' in event.keys(): # 來自定時(shí)觸發(fā)器 return check_del_vips() httpMethod = event["httpMethod"] requestParameters = event['queryString'] body = event['body'] if 'body' in event.keys() else '' response = wechat(httpMethod, requestParameters, body=body) return response
先從云函數(shù)入口函數(shù)開始，我們可以從 event 的 keys 里是否存在 Time 來判斷云函數(shù)是否是被定時(shí)器觸發(fā)的
#每天定時(shí)檢查刪除過期的激活碼
def check_del_vips():
vipMap = getvips()
if len(vipMap) < 1:
return
for vip in vipMap.keys():
if not checkVip(vipMap[vip]):
vipMap.pop(vip)
return cosWrite('vips.txt', json.dumps(vipMap, ensure_ascii=False))這里設(shè)置定時(shí)器來觸發(fā)云函數(shù)是為了每天檢查一遍有沒有激活碼失效了，失效的激活碼會被刪除掉。
def wechat(httpMethod, requestParameters, body=''):
if httpMethod == 'GET':
signature = requestParameters['signature']
timestamp = requestParameters['timestamp']
nonce = requestParameters['nonce']
echo_str = requestParameters['echostr']
try:
check_signature(WECHAT_TOKEN, signature, timestamp, nonce)
except InvalidSignatureException:
echo_str = 'error'
return apiReply(echo_str, txt=True, content_type="text/plain")
elif httpMethod == 'POST':
msg_signature = requestParameters['msg_signature']
timestamp = requestParameters['timestamp']
nonce = requestParameters['nonce']
try:
decrypted_xml = crypto.decrypt_message(
body,
msg_signature,
timestamp,
nonce
)
except (InvalidAppIdException, InvalidSignatureException):
return
msg = parse_message(decrypted_xml)
if msg.type == 'text':
reply = replyMessage(msg)
else:
reply = create_reply('哈? ??？\n搞不明白你給我發(fā)了啥~', msg)
reply = reply.render()
reply = crypto.encrypt_message(reply, nonce, timestamp)
return apiReply(reply, txt=True, content_type="application/xml")
else:
msg = parse_message(body)
reply = create_reply("喵嗚 ?'ω'?", msg).render()
reply = crypto.encrypt_message(reply, nonce, timestamp)
return apiReply(reply, txt=True, content_type="application/xml")如果云函數(shù)不是通過定時(shí)器觸發(fā)，那它就是通過后面我們要設(shè)置的 api 網(wǎng)關(guān)給觸發(fā)的，這時(shí)候就是我們的微信公眾號后臺發(fā)消息過來了，我們先用 crypto.decrypt\_message 來解密一下消息。
if msg.type == 'text':
reply = replyMessage(msg)
else:
reply = create_reply('哈? ??？\n搞不明白你給我發(fā)了啥~', msg)然后判斷一下消息的類型（文字、圖片、語音、視頻或者其他類型），如果不是文字消息，我們就先暫不處理啦 ~
def replyMessage(msg):
txt = msg.content
if '@' in txt:
keys = txt.split('@')
if keys[0] == '會員': # 會員@356 --> 添加一個(gè)365天的會員激活碼
flag,vip=addvip(keys[1])
return create_reply(f"您的激活碼:{vip}，有效期:{keys[1]}天" if flag else "添加失敗", msg)
return create_reply("喵嗚 ?'ω'?", msg)然后對于文字消息我們按照自己規(guī)定的命令格式來解析處理用戶消息即可。
# 是否開啟本地debug模式
debug = False
# 騰訊云對象存儲依賴
if debug:
from qcloud_cos import CosConfig
from qcloud_cos import CosS3Client
from qcloud_cos import CosServiceError
from qcloud_cos import CosClientError
else:
from qcloud_cos_v5 import CosConfig
from qcloud_cos_v5 import CosS3Client
from qcloud_cos_v5 import CosServiceError
from qcloud_cos_v5 import CosClientError
# 配置存儲桶
appid = '66666666666'
secret_id = u'xxxxxxxxxxxxxxx'
secret_key = u'xxxxxxxxxxxxxxx'
region = u'ap-chongqing'
bucket = 'name'+'-'+appid
# 對象存儲實(shí)例
config = CosConfig(Secret_id=secret_id, Secret_key=secret_key, Region=region)
client = CosS3Client(config)
# cos 文件讀寫
def cosRead(key):
try:
response = client.get_object(Bucket=bucket, Key=key)
txtBytes = response['Body'].get_raw_stream()
return txtBytes.read().decode()
except CosServiceError as e:
return ""
def cosWrite(key, txt):
try:
response = client.put_object(
Bucket=bucket,
Body=txt.encode(encoding="utf-8"),
Key=key,
)
return True
except CosServiceError as e:
return False
# api網(wǎng)關(guān)響應(yīng)集成
def apiReply(reply, txt=False, content_type='application/json', code=200):
return {
"isBase64Encoded": False,
"statusCode": code,
"headers": {'Content-Type': content_type},
"body": json.dumps(reply, ensure_ascii=False) if not txt else str(reply)
}以上就是如何基于Serverless借助微信公眾號簡單管理用戶激活碼，小編相信有部分知識點(diǎn)可能是我們?nèi)粘９ぷ鲿姷交蛴玫降?。希望你能通過這篇文章學(xué)到更多知識。更多詳情敬請關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。
網(wǎng)站標(biāo)題：如何基于Serverless借助微信公眾號簡單管理用戶激活碼
當(dāng)前鏈接：http://chinadenli.net/article8/jdpoop.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供微信小程序、商城網(wǎng)站、App開發(fā)、企業(yè)建站、企業(yè)網(wǎng)站制作、軟件開發(fā)
聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來源： 創(chuàng)新互聯(lián)
- 自己建網(wǎng)站和專業(yè)建站公司的區(qū)別有那些？ 2021-04-01
- 建站公司制作高質(zhì)量網(wǎng)站有哪些訣竅與經(jīng)驗(yàn) 2023-04-03
- 優(yōu)秀建站公司告訴你建設(shè)網(wǎng)站的好處是什么 2021-11-13
- 建站公司打鐵還需自身硬，那么建站公司應(yīng)該具備什么能力? 2021-04-17
- 成都建站公司談移動(dòng)網(wǎng)站將進(jìn)入免費(fèi)時(shí)代 2016-11-24
- 為什么現(xiàn)在都選擇專業(yè)建站公司做網(wǎng)站 2022-06-26
- 網(wǎng)站建設(shè)制作高端定制網(wǎng)站大概多少錢為什么有些建站公司報(bào)價(jià)這么便宜 2021-12-07
- 成都建站公司，你憑啥收那么高費(fèi)？ 2016-12-16
- 如何判斷建站公司是否專業(yè) 2016-02-21
- 建站公司如何做網(wǎng)站才能讓甲方超預(yù)期？ 2023-02-18
- 網(wǎng)站建站公司中是什么影響了網(wǎng)站價(jià)格呢 2021-09-12
- 建站公司網(wǎng)站制作經(jīng)驗(yàn)技巧 2016-11-05