后端开发语言使用KOA, 数据库使用mysql, 包含微信支付功能, JWT权限验证功能,短信验证功能等
服务器： windows server 2012 R2
-
安装Koa脚手架
文档地址：https://www.npmjs.com/package/koa-generator
1. npm install -g koa-generator
-
创建KOA项目
koa2 项目名称(英文)
-
KOA脚手架(生成器) 主要功能包括：
-
集成基础的，必要的中间件
-
app.js:入口文件
-
bin/www:启动入口
-
支持静态服务器
-
集成routes路由目录
-
支持view视图目录，默认使用pug作为模板引擎
-
-
启动项目
开发时： yarn start 启动项目 yarn dev nodemon是修改项目代码后,服务器自动重启,代码改动实时生效 开发完： yarn prd 使用pm2 启动node应用程序， PM2是node进程管理工具，可以做到性能监控、自动重启、负载均衡等 浏览器运行： localhost:3000
-
相关包的说明
{ "name": "koa-demo", "version": "0.1.0", "private": true, "scripts": { "start": "node bin/www", // 代码变动需要重启node进程 "dev": "./node_modules/.bin/nodemon bin/www", // 代码变动，通过nodemon自动重启node进程 "prd": "pm2 start bin/www",// 生产环境 pm2启动 "test": "echo \"Error: no test specified\" && exit 1" }, "dependencies": { "debug": "^4.1.1", // 根据Debug环境变量输出调试日志 "koa": "^2.7.0", "koa-bodyparser": "^4.2.1",// 解析body，主要针对post请求 "koa-convert": "^1.2.0", // 兼容Koa2中间件写法 "koa-json": "^2.0.2", // 对json更好对的支持 "koa-logger": "^3.2.0", // 开发阶段的日志模块 "koa-onerror": "^4.1.0", // 错误处理模块 "koa-router": "^7.4.0", // 路由 "koa-static": "^5.0.0", // HTTP静态服务器 "koa-views": "^6.2.0", // 视图渲染 "pug": "^2.0.3" // 模板引擎 }, "devDependencies": { "nodemon": "^1.19.1" // 自动重启node进程 } } -
app.js 代码说明
const Koa = require('koa') // koa包 const app = new Koa() // 创建koa实例 const views = require('koa-views') //视图渲染 const json = require('koa-json') // 格式化json const onerror = require('koa-onerror') // 错误处理模块 const bodyparser = require('koa-bodyparser') // 针对post请求，解析请求体body const logger = require('koa-logger') // 开发阶段日志记录 // 加载路由 const index = require('./routes/index') const users = require('./routes/users') // error handler 错误处理 onerror(app) // middlewares 挂载中间件 app.use(bodyparser({ enableTypes:['json', 'form', 'text'] })) app.use(json()) app.use(logger()) // 静态服务器： 主要存放一些静态资源 app.use(require('koa-static')(__dirname + '/public')) // pug模板引擎的配置 app.use(views(__dirname + '/views', { extension: 'pug' })) // logger 日志中间件 app.use(async (ctx, next) => { const start = new Date() await next() const ms = new Date() - start console.log(`${ctx.method} ${ctx.url} - ${ms}ms`) }) // routes 路由 app.use(index.routes(), index.allowedMethods()) app.use(users.routes(), users.allowedMethods()) // error-handling 错误处理 app.on('error', (err, ctx) => { console.error('server error', err, ctx) }); module.exports = app
-
routes/index.js
const router = require('koa-router')() // 视图渲染 router.get('/', async (ctx, next) => { await ctx.render('index', { title: 'Hello Koa 2!' }) }) // 响应字符串 router.get('/string', async (ctx, next) => { ctx.body = 'koa2 string' }) // 响应json router.get('/json', async (ctx, next) => { ctx.body = { title: 'koa2 json' } }) module.exports = router
MVC模式（Model–view–controller）软件开发架构模式，把软件系统分为三个基本部分：模型（Model）、视图（View）和控制器（Controller）。
数据模型层，进行数据管理和数据库设计
视图层: 前端页面
负责转发请求，对请求进行处理
- 低耦合性 视图层和业务层分离，这样就允许更改视图层代码而不用重新编译模型(Model)和控制器代码（controller）
- 方便代码维护拓展
需要编写三个接口：
- /gridlist 获取宫格数据
- /sports 获取运动专区数据
- /banners 获取轮播图数据.
- 创建 controller/index.js
- 创建routes/index.js
- 在app.js中使用路由
1.controller/index.js
module.exports.gridlist = (ctx) => {
ctx.body = {
status: 200,
gridList: [
{
id: 1,
img_src: "/images/nav1.png"
},
{
id: 2,
img_src: "/images/nav2.png"
},
{
id: 3,
img_src: "/images/nav3.png"
},
{
id: 4,
img_src: "/images/nav4.png"
},
{
id: 5,
img_src: "/images/nav5.png"
},
{
id: 6,
img_src: "/images/nav6.png"
}
]
}
}2.routes目录下的index.js
const router = require('koa-router')();
const { gridlist } = require('../Controller/index');
//获取宫格列表
router.get('/gridList', gridlist);
module.exports = router;3.app.js
const index = require('./routes/index')
app.use(index.routes(), index.allowedMethods())首页需要的另外两个接口以此类推
1.controller/index.js
// 运动专区module.exports.sportList = (ctx,) => { ctx.body = { status: 200, sports: [ { name: 'adidas阿迪达斯 男式 场下休闲篮球鞋S83700', img: '/images/product.jpg', price: 1.00, oldPrice: 888.00 }, { name: 'FORUM 84 LOW 新款低帮经典运动鞋', img: '/images/product.jpg', price: 1.00, oldPrice: 899.00 }, { name: 'adidas阿迪达斯 男式 场下休闲篮球鞋S83700', img: '/images/product.jpg', price: 1.00, oldPrice: 888.00 }, { name: 'adidas阿迪达斯 男式 场下休闲篮球鞋S83700', img: '/images/product.jpg', price: 1.00, oldPrice: 888.00 } ] }}// banner专区module.exports.swipeList = (ctx) => { ctx.body = { status: 200, swipeList: [ { id: 1, img_src: "/images/banner1.png", }, { id: 2, img_src: "/images/banner2.png", }, { id: 3, img_src: "/images/banner3.png", }, { id: 4, img_src: "/images/banner4.png", }, { id: 5, img_src: "/images/banner5.png", }, ] }}routes/index.js
const router = require('koa-router')();const { sportList, swipeList } = require('../Controller/index');// 获取运动专区router.get('/sports', sportList);// 获取轮播图router.get('/banners', swipeList);module.exports = router; 数据库:letao
- category 一级分类
- brand 二级分类
category 一级分类
1.创建category 表:
-- letao.category definition 一级分类CREATE TABLE `category` ( `id` int(11) NOT NULL AUTO_INCREMENT, `categoryName` varchar(50) DEFAULT null, PRIMARY KEY (`id`)) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;category表插入测试数据
insert into `category`(`id`,`categoryName`) values (1,'运动馆'),(2,'女士馆'),(3,'男士馆'),(4,'帆布馆'),(5,'户外管');2.brand表 二级分类表
创建brand表
CREATE TABLE `brand` ( `id` int(11) NOT NULL AUTO_INCREMENT, `brandName` varchar(50) DEFAULT NULL, `categoryId` int(11) DEFAULT NULL, `brandLogo` varchar(200) DEFAULT NULL, `hot` int(4) DEFAULT NULL, PRIMARY KEY (`id`)) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;brand表插入测试数据
insert into `brand`(`id`,`brandName`,`categoryId`,`brandLogo`,`hot`) values (1,'耐克',1,'/images/brand1.png',1),(2,'阿迪',1,'/images/brand2.png',1),(3,'新百伦',1,'/images/brand3.png',1),(4,'哥伦比亚',1,'/images/brand4.png',0),(5,'匡威',1,'/images/brand5.png',1),(6,'阿萨德1',2,'/images/brand5.png',1),(7,'阿萨德2',2,'/images/brand5.png',1);文档地址：https://www.npmjs.com/package/mysql
yarn add mysqlvar mysql = require('mysql');// 创建连接池var pool = mysql.createPool({ connectionLimit : 10, // 连接池最大连接数 host : 'localhost', user : 'root', password : '123456', database : 'letao'}); pool.query('SELECT 1 + 1 AS solution', function (error, results, fields) { if (error) throw error; console.log('The solution is: ', results[0].solution);});var mysql = require('mysql');// 创建连接池var pool = mysql.createPool({ connectionLimit : 10, // 连接池最大连接数 host : 'localhost', user : 'root', password : '123456', database : 'letao'}); // 开始连接数据pool.getConnection(function(err, connection) { if (err) throw err; // not connected! // Use the connection connection.query('select * from category', function (error, results, fields) { // When done with the connection, release it. connection.release(); // Handle error after the release. if (error) throw error; // Don't use the connection here, it has been returned to the pool. console.log(results); }); });var mysql = require('mysql');// 创建连接池var pool = mysql.createPool({ connectionLimit: 10, // 连接池最大连接数 host: 'localhost', user: 'root', password: '123456', database: 'letao'});// 封装sql查询函数module.exports.query = (sql) => { return new Promise((resolve, reject) => { // 开始连接数据 pool.getConnection(function (err, connection) { if (err) throw err; // not connected! // Use the connection connection.query(sql, function (error, results, fields) { // When done with the connection, release it. connection.release(); // Handle error after the release. if (error) throw error; // Don't use the connection here, it has been returned to the pool. resolve(results); }); }); });}routes/category.js
const router = require('koa-router')();const { query } = require('../db/query')// 获取一级分类router.get('/oneCategory', async (ctx)=>{ console.log(11); let oneCategory = await query('select * from category'); ctx.body = { status:200, oneCategory }});module.exports = router;app.js 新增两行代码
const category = require('./routes/category')// routes 路由app.use(category.routes(), category.allowedMethods())- 拆分routes/category.js 中一级分类路由匹配后的业务处理到controller/category.js
controller目录下category.js
const { query } = require('../db/query')// 获取一级分类module.exports.oneCategory = async (ctx) => { let oneCategory = await query('select * from category'); ctx.body = { status:200, oneCategory }}routes/category.js
const router = require('koa-router')();const { oneCategory } = require('../controller/category');// 获取一级分类router.get('/oneCategory', oneCategory);module.exports = router;以上代码存在的问题：
controller层和model层紧耦合，需要把sql查询功能进一步拆分到model层
model/category.js
const { query } = require('../db/query')// 获取一级分类module.exports.oneCategory = async () =>{ return await query('select * from category');}controller/category.js
const { oneCategory } = require('../model/category');// 获取一级分类module.exports.oneCategory = async (ctx) => { let oneCategoryList = await oneCategory() ctx.body = { status:200, oneCategoryList }}总结： 当前分类页面使用的到的一级分类接口已按照MVC模式完成开发
此时的数据库配置耦合到业务代码中，需要抽离
db/dbConfig.js
module.exports.dbConfig = { connectionLimit: 10, // 连接池最大连接数 host: 'localhost', user: 'root', password: '123456', database: 'letao'}以上配置无法区分开发环境，测试环境，生成环境，因此需要优化
安装dotenv
文档地址：https://www.npmjs.com/package/dotenv
yarn add dotenv# 数据库主机DB_HOST = "localhost"# 数据库用户名DB_USER = "root"# 数据库密码DB_PWD = "123456"# 数据库名称DB_DATABASE = "letao"注意：dotenv配置代码先运行
const Koa = require('koa') // koa包const app = new Koa() // 创建koa实例const views = require('koa-views') //视图渲染const json = require('koa-json') // 格式化jsonconst onerror = require('koa-onerror') // 错误处理模块const bodyparser = require('koa-bodyparser') // 针对post请求，解析请求体bodyconst logger = require('koa-logger') // 开发阶段日志记录const dotenv = require('dotenv') // 环境变量配置// 启动Node env环境 先运行dotenv.config();// 加载路由const index = require('./routes/index')const users = require('./routes/users')const category = require('./routes/category')// error handler 错误处理onerror(app)// middlewares 挂载中间件app.use(bodyparser({ enableTypes:['json', 'form', 'text']}))app.use(json())app.use(logger())// 静态服务器： 主要存放一些静态资源app.use(require('koa-static')(__dirname + '/public'))// pug模板引擎的配置app.use(views(__dirname + '/views', { extension: 'pug'}))// logger 日志中间件app.use(async (ctx, next) => { const start = new Date() await next() const ms = new Date() - start console.log(`${ctx.method} ${ctx.url} - ${ms}ms`)})// routes 路由app.use(index.routes(), index.allowedMethods())app.use(users.routes(), users.allowedMethods())app.use(category.routes(), category.allowedMethods())// error-handling 错误处理app.on('error', (err, ctx) => { console.error('server error', err, ctx)});module.exports = app// 获取二级分类module.exports.twoCategory = async (id) =>{ return await query('select * from brand where id = ?',[id]);}以上代码明显query调用时多了一个参数id，所以需要修改query封装，支持传递参数查询sql
var mysql = require('mysql');var { dbConfig } = require('./dbConfig');// 创建连接池var pool = mysql.createPool(dbConfig);// 封装sql查询函数module.exports.query = async (sql, values) => { return new Promise((resolve, reject) => { // 开始连接数据 pool.getConnection(function (err, connection) { if (err) throw err; // not connected! // Use the connection connection.query(sql,values, function (error, results, fields) { // When done with the connection, release it. connection.release(); // Handle error after the release. if (error) throw error; // Don't use the connection here, it has been returned to the pool. resolve(results); }); }); });}// 获取二级分类module.exports.twoCategory = async (ctx) =>{ const { id } = ctx.request.query; let twoCategoryList = await twoCategory(id); ctx.body = { status:200, twoCategoryList }} 创建user表
-- letao.`user` definition 用户表
CREATE TABLE `user` (
`id` int(11) NOT NULL AUTO_INCREMENT,
`username` varchar(50) DEFAULT NULL,
`password` varchar(100) DEFAULT NULL,
`mobile` char(11) DEFAULT NULL,
`smscode` varchar(100) DEFAULT NULL,
PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8; 完成用户注册接口开发
-
按照MVC结构创建users.js
-
在routes/users.js 定义注册路由
-
app.js 中注册路由
const { query } = require('../db/query');
// 注册
module.exports.register = async (username, password, mobile) => {
return await query(`insert into user (username, password, mobile) values( "${username}", "${password}", "${mobile}")`);
}const { register } = require('../model/users');
module.exports.register = async (ctx) => {
const { username, password, mobile } = ctx.request.body;
await register(username, cryptoPwd(password + secret), mobile);
ctx.body = {
status:200,
msg:'注册成功'
}
}const router = require('koa-router')();
const { register} = require('../controller/users');
// 用户注册
router.post('/register', register);
module.exports = router;引入users模块路由
const users = require('./routes/users')
app.use(users.routes(), users.allowedMethods())joi文档地址：https://www.npmjs.com/package/joi
手机号校验正则地址：https://learnku.com/articles/31543
调用注册接口，如果请求参数数据不合法，我们不能进行注册，要提示用户参数不合法，即使前端做参数校验，后端也要做校验，万一用户使用postman等
工具调用接口时，此时前端校验作废，所有后端需要做参数校验。
- 服务端使用推荐使用joi在controller层进行参数校验
- 安装Joi yarn add joi
- 在注册之前使用Joi库进行请求参数校验，通过继续下一步，否则返回异常信息，return 终止后续代码执行
controller/users.js
const { register } = require('../model/users');
const Joi = require('joi');
module.exports.register = async (ctx) => {
const { username, password, mobile } = ctx.request.body;
// 校验用户名 密码 手机号
const schema = Joi.object({
username:Joi.string().min(3).max(20).required(),
password:Joi.string().pattern(/^[a-zA-Z0-9]{3,20}$/),
repeat_password:Joi.ref('password'),
//手机号正则
mobile:Joi.string().pattern(/^1(3\d|4[5-9]|5[0-35-9]|6[2567]|7[0-8]|8\d|9[0-35-9])\d{8}$/)
})
// 校验结果对象
const result = schema.validate({username,password,mobile});
if (result.error) {
ctx.body = {
status:false,
msg:result.error.details[0].message
}
return;
}
await register(username, cryptoPwd(password + secret), mobile);
ctx.body = {
status:200,
msg:'注册成功'
}
}joi库是专门用于服务端开发参数校验库，使用前需要使用yarn add joi 安装， 在使用时参照官方文档使用
如果用户对同一个用户名已经注册过再次注册时要提示用户已经注册，并且此时不要再次存入相同用户到数据库
- 在model/users.js中写一个方法 根据当前注册的用户名查询数据库是否能查询到数据
- 根据用户名查询数据库的结果决定该用户是否已经注册过
- 没有注册则把用户信息插入数据库，否则条件判断提示用户当前用户已经注册
1.model/users.js
// 根据用户名查询用户
module.exports.findUserByName = async (username) => {
return await query('select * from user where username = ?', [username]);
}- controllers/users.js
const { secret } = require('../config');
const Joi = require('joi');
module.exports.register = async (ctx) => {
const { username, password, mobile } = ctx.request.body;
// 校验用户名 密码 手机号
const schema = Joi.object({
username:Joi.string().min(3).max(20).required(),
password:Joi.string().pattern(/^[a-zA-Z0-9]{3,20}$/),
repeat_password:Joi.ref('password'),
//手机号正则
mobile:Joi.string().pattern(/^1(3\d|4[5-9]|5[0-35-9]|6[2567]|7[0-8]|8\d|9[0-35-9])\d{8}$/)
})
// 校验结果对象
const result = schema.validate({username,password,mobile});
if (result.error) {
ctx.body = {
status:false,
msg:result.error.details[0].message
}
return;
}
const user = await findUserByName(username);
if (user[0]) {
ctx.body = {
status: 1000,
msg:'该用户已注册'
}
}else {
await register(username, cryptoPwd(password + secret), mobile);
ctx.body = {
status:200,
msg:'注册成功'
}
}
} 编写一个接口查询该用户信息是否已注册，是，则提示用户，否则把用户信息存入数据库
文档地址：https://nodejs.org/dist/latest-v14.x/docs/api/crypto.html
用户注册后，为了保护用户信息，需要对用户注册时密码拼接字符串进行加密，加密可以使用node中crypto模块实现
- 根目录创建utils/index.js，封装方法完成用户密码的加密
- 根目录创建config/index.js 导出加密字符串
- 在controllers/users.js 注册时调用加密方法传入用户密码和字符串拼接作为参数，返回加密后的密文存储到数据库
1.utils/index.js
const crypto = require('crypto');// 对用户注册成功后的密码进行MD5加密生成密文后返回module.exports.cryptoPwd = (pwd) => { return crypto.createHash('MD5').update(pwd).digest('hex');}2.config/index.js
// 用于密码机密字符串module.exports.secret = 'letaoSecret';- controller/users.js (新增三行代码)
const { cryptoPwd } = require('../utils');const { secret } = require('../config');await register(username, cryptoPwd(password + secret), mobile); 完成用户登录接口开发
- 按照MVC结构在uses.js新增登录方法
- 步骤同注册
1.model/users.js
// 登录module.exports.login = async (username, password) => { return await query(`select * from user where username = ? and password = ?`, [username, password]);}2.controllers/users.js
module.exports.login = async (ctx) => { const {username, password} = ctx.request.body; const result = await login(username, password); if (result[0]) { ctx.body = { code:200, userInfo:{ username:result[0].username, mobile:result[0].mobile }, msg:'登录成功' } }} 根据用户登录信息，查询数据库，能查询则登录成功，否则登录失败
- koa-jwt: https://www.npmjs.com/package/koa-jwt
- mysql:https://www.npmjs.com/package/mysql
- crypto加密: https://nodejs.org/dist/latest-v14.x/docs/api/crypto.html
- koa: https://koa.bootcss.com/#context
- 验证用户身份，保证用户填写的手机号码的真实性
- 减少非法注册和恶意注册，提高会员注册质量
- 提高网站用户注册的质量，更有效地管理注册用户，随时保持联系和沟通
特点：
1. 腾讯云账户需完成*企业认证后方可使用营销推广短信*功能
2. 禁止发送金融相关的所有内容（验证码、通知和营销短信），请客户谨慎购买
文档地址： https://cloud.tencent.com/document/product/382/37745
yarn add tencentcloud-sdk-nodejs utils目录下utils.js
```javascript
// 生成指定范围的随机整数
module.exports.getRandom = (min, max) => {
return Math.floor(Math.random() * (max - min) + 1);
}
// 短信验证码
module.exports.smscode = (codeLen) => {
let code = '';
for (let i = 0; i < codeLen; i++) {
code += this.getRandom(0, 9);
}
return code;
}
// 发送短信功能
module.exports.sendSms = async (mobile, code) => {
const tencentcloud = require("tencentcloud-sdk-nodejs")
// 导入对应产品模块的client models。
const smsClient = tencentcloud.sms.v20210111.Client
/* 实例化要请求产品(以sms为例)的client对象 */
const client = new smsClient({
credential: {
/* 必填：腾讯云账户密钥对secretId，secretKey。
* 这里采用的是从环境变量读取的方式，需要在环境变量中先设置这两个值。
* 你也可以直接在代码中写死密钥对，但是小心不要将代码复制、上传或者分享给他人，
* 以免泄露密钥对危及你的财产安全。
* CAM密匙查询: https://console.cloud.tencent.com/cam/capi */
secretId: process.env.secretId,
secretKey: process.env.secretKey,
},
/* 必填：地域信息，可以直接填写字符串ap-guangzhou，或者引用预设的常量 */
region: "ap-guangzhou",
/* 非必填:
* 客户端配置对象，可以指定超时时间等配置 */
profile: {
/* SDK默认用TC3-HMAC-SHA256进行签名，非必要请不要修改这个字段 */
signMethod: "HmacSHA256",
httpProfile: {
/* SDK默认使用POST方法。
* 如果你一定要使用GET方法，可以在这里设置。GET方法无法处理一些较大的请求 */
reqMethod: "POST",
/* SDK有默认的超时时间，非必要请不要进行调整
* 如有需要请在代码中查阅以获取最新的默认值 */
reqTimeout: 30,
/**
* SDK会自动指定域名。通常是不需要特地指定域名的，但是如果你访问的是金融区的服务
* 则必须手动指定域名，例如sms的上海金融区域名： sms.ap-shanghai-fsi.tencentcloudapi.com
*/
endpoint: "sms.tencentcloudapi.com"
},
},
})
/* 请求参数，根据调用的接口和实际情况，可以进一步设置请求参数
* 属性可能是基本类型，也可能引用了另一个数据结构
* 推荐使用IDE进行开发，可以方便的跳转查阅各个接口和数据结构的文档说明 */
const params = {
/* 短信应用ID: 短信SmsSdkAppId在 [短信控制台] 添加应用后生成的实际SmsSdkAppId，示例如1400006666 */
SmsSdkAppId: process.env.SmsSdkAppId,
/* 短信签名内容: 使用 UTF-8 编码，必须填写已审核通过的签名，签名信息可登录 [短信控制台] 查看 */
SignName: process.env.SignName,
/* 短信码号扩展号: 默认未开通，如需开通请联系 [sms helper] */
ExtendCode: "",
/* 国际/港澳台短信 senderid: 国内短信填空，默认未开通，如需开通请联系 [sms helper] */
SenderId: "",
/* 用户的 session 内容: 可以携带用户侧 ID 等上下文信息，server 会原样返回 */
SessionContext: "",
/* 下发手机号码，采用 e.164 标准，+[国家或地区码][手机号]
* 示例如：+8613711112222， 其中前面有一个+号 ，86为国家码，13711112222为手机号，最多不要超过200个手机号*/
PhoneNumberSet: [`+86${mobile}`],
/* 模板 ID: 必须填写已审核通过的模板 ID。模板ID可登录 [短信控制台] 查看 */
TemplateId: process.env.TemplateId,
/* 模板参数: 若无模板参数，则设置为空*/
TemplateParamSet: [code],
}
// 通过client对象调用想要访问的接口，需要传入请求对象以及响应回调函数
return await client.SendSms(params);
}
```
controller目录下sms.js
const { smscode, sendSms } = require('../utils/utils');
// 短信验证
module.exports.sms = async (ctx) => {
// 请求参数手机号
const { mobile } = ctx.request.body;
// 短信验证码随机数 4位数字
const code = smscode(4);
const data = await sendSms(mobile, code)
// 发送失败
if (data.SendStatusSet[0].Code != 'Ok') {
ctx.body = {
status: 1040,
msg:data.SendStatusSet[0].Message
}
return;
}
ctx.body = {
status:200,
code,
msg:'短信发送成功'
}
}- 申请短信服务: https://cloud.tencent.com/act/pro/csms?fromSource=gwzcw.3193243.3193243.3193243&utm_medium=cpc&utm_id=gwzcw.3193243.3193243.3193243&bd_vid=12653931549666961432
- 接入流程: https://cloud.tencent.com/document/product/382/37745
- API概述：https://cloud.tencent.com/document/product/382/52077
- SDK使用: https://cloud.tencent.com/document/product/382/43197
- 短信云控制台: https://console.cloud.tencent.com/smsv2
- API密匙管理： https://console.cloud.tencent.com/cam/capi
- 模板id：https://console.cloud.tencent.com/smsv2/csms-template
日常生活中的身份验证的场景: 比如进入公司的大楼时，需要携带工牌；打卡上班时，需要指纹识别；打开工作电脑时，需要输入密码。
JSON Web Token (JWT) 是一个开放标准 ( RFC 7519 )，用于在各方之间作为 JSON 对象安全地传输信息。就是通过用户名和密码来生成token确认用户的身份，确认过身份的用户称为为授权用户(Authenticated user)。
全称 JSON Web Token， 是目前最流行的跨域认证解决方案。基本的实现是服务端认证后，生成一个 JSON 对象，发回给用户。用户与服务端通信的时候，都要在请求头带上这个 JSON 对象
- 授权：这是使用 JWT 最常见的场景。用户登录后，每个后续请求都将包含 JWT，允许用户访问该令牌允许的路由、服务和资源。
在其紧凑形式中，JSON Web Tokens 由用点 ( .)分隔的三个部分组成，它们是：
-
标题
{"alg":"HS256","typ":"JWT"}
-
有效载荷
-
{"username":"letao","password":"123456","iat":1634524068,"exp":1634527668}
-
-
签名
因此，JWT 通常如下所示。
xxxxx.yyyyy.zzzzz
JWT格式:
在身份验证中，当用户使用其凭据成功登录时，将返回 JSON Web Token。由于令牌是凭证，因此必须非常小心以防止出现安全问题。通常，您不应将令牌保留的时间超过所需的时间。
每当用户想要访问受保护的路由或资源时，用户代理应该发送 JWT，通常在使用Bearer模式的Authorization标头中。标题的内容应如下所示：
Authorization: Bearer <token>
.
文档地址： https://www.npmjs.com/package/jsonwebtoken
-
安装
jsonwebtokenyarn add jsonwebtoken
2.controller目录user.js
- 登录成功之后使用jsonwebtoken根据用户名和密码生成token返回
const userModel = require('../model/user');
const { validator, cryptoPwd } = require('../utils/utils');
const { config:{encrypStr , secret} } = require('../config/config');
const jwt = require('jsonwebtoken');
// 用户登录
module.exports.login = async (ctx) => {
// 1. 获取登录信息
const { username, password } = ctx.request.body;
let msg = validator.checkUserName(username) || validator.checkPassword(password)
if (msg) {
ctx.body = {
msg,
status: 1010
}
}
// 2. 登录
const result = await userModel.login(username, cryptoPwd(password + encrypStr));
const token = await jwt.sign({
username,
password
}, secret, { expiresIn: 36 * 60 * 60 }); //
if (result[0]) {
ctx.body = {
status: 200,
token,
msg: '登录成功'
}
} else {
ctx.body = {
status: 1040,
msg: '登录失败'
};
}
}-
验证JSON Web 令牌的 Koa 中间件
-
安装koa-jwt
yarn add koa-jwt
-
app.js
const Koa = require('koa') // 引入KOA const app = new Koa() // 创建KOA应用实例 const views = require('koa-views') // 处理动态模板 const json = require('koa-json') // 格式化输出的json const onerror = require('koa-onerror') // 捕获异常 const bodyparser = require('koa-bodyparser') // 处理post请求 const logger = require('koa-logger') // 日志记录 const dotenv = require('dotenv'); var xmlParser = require('koa-xml-body'); var jwt = require('koa-jwt'); const {config:{secret}} = require('./config/config'); // 启动Node env环境 dotenv.config(); // 加载路由 const order = require('./routes/order') const user = require('./routes/user') // error handler 错误处理 onerror(app) app.use(xmlParser()); // middlewares 使用中间件 app.use(function(ctx, next){ return next().catch((err) => { if (401 == err.status) { ctx.status = 401; ctx.body = 'Protected resource, use Authorization header to get access\n'; } else { throw err; } }); }); app.use(jwt({ secret }).unless({ path: [/^\/public/, /^\/login/]})) app.use(bodyparser({ enableTypes: ['json', 'form', 'text'] })) app.use(json()) app.use(logger()) app.use(require('koa-static')(__dirname + '/public')) // 动态文件模板处理 app.use(views(__dirname + '/views', { extension: 'pug' })) // logger 日志输出 app.use(async (ctx, next) => { const start = new Date() await next() const ms = new Date() - start console.log(`${ctx.method} ${ctx.url} - ${ms}ms`) }) // routes 注册路由 app.use(order.routes(), order.allowedMethods()) app.use(user.routes(), user.allowedMethods()) // error-handling 错误处理 app.on('error', (err, ctx) => { console.error('server error', err, ctx) }); module.exports = app
- koa-jwt: https://www.npmjs.com/package/koa-jwt
- mysql:https://www.npmjs.com/package/mysql
- crypto加密: https://nodejs.org/dist/latest-v14.x/docs/api/crypto.html
- koa: https://koa.bootcss.com/#context
- jwt: https://jwt.io/introduction
- jsonwebtoken: https://www.npmjs.com/package/jsonwebtoken
- 文档地址：https://pay.weixin.qq.com/wiki/doc/api/index.html
- 扫码支付是指商户系统按微信支付协议生成支付二维码，用户再用微信“扫一扫”来完成支付。
请根据营业执照类型选择以下主体注册：
公众号认证后才可申请微信支付，认证费：300元/次 查看认证流程
登录公众平台，点击左侧菜单【微信支付】，开始填写资料等待审核，审核时间为48小时内。
资料审核通过后，开户信息会通过邮件、公众号发送给联系人，请按照指引填写财付通备付金汇入的随机金额，完成账户验证。（查看验证方法）
本协议为线上电子协议，签署后方可进行交易及资金结算，签署完立即生效。点此提前预览协议内容。
支付接口已获得，可根据开发文档进行开发，也可了解成功案例界面示意及素材。
- 扫码支付
- APPID 公众平台(1959583119)->右上角->开发者ID->AppID
- 商户号码和配置回调链接 商户平台->产品中心->开发配置->商户信息->商户号
- 配置APPID 商户平台->产品中心->APPID授权管理
- API密钥 商户平台->账户中心->API安全->设置API密钥
-
商户后台系统先调用微信支付的统一下单接口
-
商户后台系统将code_url值生成二维码图片
-
用户使用微信客户端扫码后发起支付
-
注意：code_url有效期为2小时，过期后扫码不能再发起支付。
业务流程说明：
- 1）商户后台系统根据用户选购的商品生成订单。
- 2）用户确认支付后调用微信支付统一下单API生成预支付交易；
- 3）微信支付系统收到请求后生成预支付交易单，并返回交易会话的二维码链接code_url。
- 4）商户后台系统根据返回的code_url生成二维码。
- 5）用户打开微信“扫一扫”扫描二维码，微信客户端将扫码内容发送到微信支付系统。
- 6）微信支付系统收到客户端请求，验证链接有效性后发起用户支付，要求用户授权。
- 7）用户在微信客户端输入密码，确认支付后，微信客户端提交授权。
- 8）微信支付系统根据用户授权完成支付交易。
- 9）微信支付系统完成支付交易后给微信客户端返回交易结果，并将交易结果通过短信、微信消息提示用户。微信客户端展示支付交易结果页面。
- 10）微信支付系统通过发送异步消息通知商户后台系统支付结果。商户后台系统需回复接收情况，通知微信后台系统不再发送该单的支付通知。
- 11）未收到支付通知的情况，商户后台系统调用查询订单API
- 12）商户确认订单已支付后给用户发货。
http://mp.weixin.qq.com/debug/cgi-bin/sandboxinfo?action=showinfo&t=sandbox/index
appId: 'wx045745a074f22a9f', // 测试环境
appSecret: 'a3b77cbd62e67197bda0482a4d266106' // 秘钥传智播客
appid： wx8397f8696b538317
mch_id：1473426802
key： T6m9iK73b0kn9g5v426MKfHQH7X8rKwb 1. 调用下单接口拿到支付二维码
2. 扫码付款成功之后会回调接口（必须部署在服务器上外网可以访问），完成订单存储到mysql
3. 调用微信订单查询接口,查询用户支付状态
文档地址：https://pay.weixin.qq.com/wiki/doc/api/index.html
postman测试接口:
请求参数:
<xml>
<appid>wx95c028699e123d3f</appid>
<body>测试</body>
<mch_id>1606362331</mch_id>
<nonce_str>D1629277432053</nonce_str>
<notify_url>http://vips968.com:3001/pay/notify_url</notify_url>
<out_trade_no>China16292774320537985899249</out_trade_no>
<spbill_create_ip>127.0.0.1</spbill_create_ip>
<total_fee>1</total_fee>
<trade_type>NATIVE</trade_type>
<sign>812D86C45234CD6A189B881C24B41449</sign>
</xml>
返回数据:
<xml>
<return_code><![CDATA[SUCCESS]]></return_code>
<return_msg><![CDATA[OK]]></return_msg>
<result_code><![CDATA[SUCCESS]]></result_code>
<mch_id><![CDATA[1606362331]]></mch_id>
<appid><![CDATA[wx95c028699e123d3f]]></appid>
<nonce_str><![CDATA[3SQGZ6hZHKDePZu5]]></nonce_str>
<sign><![CDATA[D3B5906A6205E4BFF01CEFCB30620F4F]]></sign>
<prepay_id><![CDATA[wx18171217836292e6955c892133450b0000]]></prepay_id>
<trade_type><![CDATA[NATIVE]]></trade_type>
<code_url><![CDATA[weixin://wxpay/bizpayurl?pr=eg3n2ttzz]]></code_url>
</xml> postman测试
订单表order
CREATE TABLE `payorder` (
`id` int(11) NOT NULL AUTO_INCREMENT,
`appid` varchar(50) NOT NULL,
`bank_type` varchar(50) NOT NULL,
`cash_fee` varchar(50) NOT NULL,
`fee_type` varchar(50) NOT NULL,
`is_subscribe` varchar(50) NOT NULL,
`mch_id` varchar(50) NOT NULL,
`nonce_str` varchar(50) NOT NULL,
`openid` varchar(50) NOT NULL,
`out_trade_no` varchar(50) NOT NULL,
`sign`varchar(50) NOT NULL,
`time_end` varchar(50) NOT NULL,
`total_fee` varchar(50) NOT NULL,
`trade_type` varchar(50) NOT NULL,
`transaction_id` varchar(50) NOT NULL,
PRIMARY KEY (`id`)
)const { payconfig: { wx: { appid, mchid } } } = require('../config/payConfig');
const { getOrderNo, getRandomStr, createSign, createOrder, getOrder } = require('../utils/utils');
const { config: { wx_notify_url, orderUrl, queryOrderUrl } } = require('../config/config');
const QRCode = require('qrcode');
let flag = false;
const commonParams = {
// 随机字符串
nonce_str: getRandomStr(),
// 随机订单号
out_trade_no: getOrderNo()
}
// 微信下单
module.exports.order = async (ctx) => {
const { body, ip, total_fee, trade_type } = ctx.request.body;
// // 随机字符串
// const nonce_str = getRandomStr();
// // 随机订单号
// const out_trade_no = getOrderNo();
const { nonce_str, out_trade_no } = commonParams;
// 生成签名请求的参数
let params = {
appid,
body,
mch_id: mchid,
nonce_str,
notify_url: wx_notify_url,
out_trade_no,
spbill_create_ip: ip,
total_fee,
trade_type,
}
// 生成签名
let sign = createSign(params);
// 请求参数
let sendData = `<xml>
<appid>${appid}</appid>
<body>${body}</body>
<mch_id>${mchid}</mch_id>
<nonce_str>${nonce_str}</nonce_str>
<notify_url>${wx_notify_url}</notify_url>
<out_trade_no>${out_trade_no}</out_trade_no>
<spbill_create_ip>${ip}</spbill_create_ip>
<total_fee>${total_fee}</total_fee>
<trade_type>${trade_type}</trade_type>
<sign>${sign}</sign>
</xml>`;
console.log(sendData, 'sendData');
try {
// 微信下单
const data = await createOrder(orderUrl, sendData);
const payUrl = await QRCode.toDataURL(data.code_url[0]);
data.payUrl = payUrl;
// 根据微信下单二维码创建支付二维码
ctx.body = {
status: 200,
data
}
} catch (error) {
// 如果已经支付
console.log('err', error);
ctx.body = {
status:1050,
data:error.xml.err_code_des[0]
}
}
} 工具类utils.js
const { payconfig: { wx: { key } } } = require('../config/payConfig');
const axios = require('axios');
const crypto = require('crypto');
const xml = require('xml2js');
const validator = require('validator');
// 生成交易单号
module.exports.getOrderNo = () => {
// 日期时间戳字符串
const date = new Date().getTime().toString();
const str = '0123456789';
// 随机字符串
let text = '';
for (let i = 0; i < 10; i++) {
text += str[str[this.getRandom(0, 9)]];
}
console.log(text, 'text');
// 返回32位以内的随机字符串
return 'China' + date + text;
}
// 生成随机字符串
module.exports.getRandomStr = () => {
return 'D' + new Date().getTime();
}
// 生成签名
module.exports.createSign = (args) => {
// 对参数按照key=value的格式，并按照参数ASCII字典排序
let sortedParams = ''
Object.keys(args).sort().forEach((key) => {
sortedParams += `${key}=${args[key]}&`;
});
sortedParams += `key=${key}`;
console.log(sortedParams, 'sortedParams');
let sign = crypto.createHash('MD5').update(sortedParams).digest('hex').toUpperCase();
return sign
}
// 生成指定范围的随机整数
module.exports.getRandom = (min, max) => {
return Math.floor(Math.random() * (max - min) + 1);
}
// 微信下单
module.exports.createOrder = (url,params) => {
return new Promise(async (resolve, reject) => {
// 发送下单请求
const data = await axios({
url,
method: 'POST',
data:params
});
// 解析返回的xml格式
xml.parseString(data.data, (error, res) => {
if (res.xml.return_code == 'SUCCESS' && res.xml.return_msg == 'OK' && res.xml.result_code == "SUCCESS") {
resolve(res.xml)
} else {
reject(res);
}
});
})
}
// 查询微信下单的订单
module.exports.getOrder = (url, params) =>{
return new Promise( async (resolve, reject) =>{
const data = await axios({
url,
method: 'POST',
data:params
});
// 解析返回的xml格式
xml.parseString(data.data, (error, res) => {
console.log(res.xml);
if (res.xml.return_code == 'SUCCESS' && res.xml.return_msg == 'OK' && res.xml.result_code == "SUCCESS") {
resolve(res.xml)
} else {
reject(res);
}
});
});
}const router = require('koa-router')();const { order,notify, queryOrder} = require('../controller/order');// 微信下单router.post('/wx/order', order);module.exports = router;// 加载路由const order = require('./routes/order')// routes 注册路由app.use(order.routes(), order.allowedMethods())要求：
1. 部署到服务器上2. 域名需要备案外网可以访问
// 下单后的通知回调module.exports.notify = async (ctx) => { console.log(ctx.request.body.xml, 'ctx.request.body.xml') const { appid, bank_type,cash_fee,fee_type,is_subscribe,mch_id,nonce_str,openid,out_trade_no,sign,time_end,total_fee,trade_type,transaction_id } = ctx.request.body.xml; // 根据订单号查询是否已经创建订单 const result = await query('select out_trade_no from payorder') if (result[0]) return; // 在数据库中保存订单信息 await query(`insert into payorder(appid, bank_type,cash_fee,fee_type,is_subscribe,mch_id,nonce_str,openid,out_trade_no,sign,time_end,total_fee,trade_type,transaction_id) values('${appid}','${bank_type}','${cash_fee}','${fee_type}','${is_subscribe}','${mch_id}','${nonce_str}','${openid}','${out_trade_no}','${sign}','${time_end}','${total_fee}','${trade_type}','${transaction_id}')`); }const router = require('koa-router')();const { order,notify } = require('../controller/order');// 微信下单router.post('/order', order);// 微信下单后通知router.post('/pay/notify',notify)module.exports = router;文档地址：https://pay.weixin.qq.com/wiki/doc/api/index.html
// 查询微信订单module.exports.queryOrder = async (ctx) =>{ // 生成签名 let sign = createSign({ appid, mch_id, nonce_str, out_trade_no }) let sendData = ` <xml> <appid>${appid}</appid> <mch_id>${mch_id}</mch_id> <nonce_str>${nonce_str}</nonce_str> <out_trade_no>${out_trade_no}</out_trade_no> <sign>${sign}</sign> </xml>`; const data = await getOrder('https://api.mch.weixin.qq.com/pay/orderquery', sendData); ctx.body = { status: 200, data };}所用的工具类库utils.js
// 查询订单module.exports.getOrder = (url,params) =>{ return new Promise(async (resolve, reject) => { // 发送下单请求 const data = await axios({ url, method: 'POST', data:params }); // 解析返回的xml格式 xml.parseString(data.data, (error, res) => { console.log(res.xml,'res222'); if (res.xml.return_code == 'SUCCESS' && res.xml.return_msg == 'OK' && res.xml.result_code == "SUCCESS") { resolve(res.xml) } else { reject(res); } }); })}const router = require('koa-router')();const { order,notify,queryOrder } = require('../controller/order');// 微信下单router.post('/order', order);// 微信下单后通知router.post('/pay/notify',notify);// 微信查询订单router.post('/queryOrder',queryOrder)module.exports = router; 1. 我们调用微信下单接口，根据生成code_url使用qrcode生成支付二维码，返给前端，此时订单就产生，只不过是用户还没有支付而已，此时，我们把订单数据写入到数据库 ， 这时订单状态是未支付， 当用户在页面点击下单购买，需要扫描支付二维码，当用户付款成功时， 微信服务器要回调乐淘服务端接口，此时需要把订单支付状态改成已支付。
我们在订单生成时，把订单数据存到数据表payorder， 用户支付成功，把payorder订单表中支付状态改成已支付。
- 使用utils/index.js 中的query方法 在订单生成后，写入订单数据到payorder
controller/order.js
module.exports.order = async (ctx) => { // 前端调用下单接口时传递的参数 const { body, total_fee, spbill_create_ip, trade_type,nonce_str, out_trade_no} = ctx.request.body; // 生成sign需要的参数 const params = { appid, mch_id, // 商户号 nonce_str, // 32位以内的随机字符串 // sign, // 签名 body, // 商品描述 out_trade_no, // 商户订单号 total_fee, // 金额 spbill_create_ip, // 终端ip notify_url, // 微信服务器回调的地址 trade_type, // 支付类型 } nonce_str = getRandomStr();// 随机字符串 // 生产签名 需要你发送的参数生成 const sign = createSign(params); //微信下单请求参数 let sendData = ` <xml> <appid>${appid}</appid> <body>${body}</body> <mch_id>${mch_id}</mch_id> <nonce_str>${params.nonce_str}</nonce_str> <notify_url>${notify_url}</notify_url> <out_trade_no>${params.out_trade_no}</out_trade_no> <spbill_create_ip>${spbill_create_ip}</spbill_create_ip> <total_fee>${total_fee}</total_fee> <trade_type>${trade_type}</trade_type> <sign>${sign}</sign> </xml> ` const data = await orderHandle(orderUrl, sendData); // 下单成功 const { return_code, return_msg, result_code, code_url } = data; if (return_code == 'SUCCESS' && return_msg == 'OK' && result_code == "SUCCESS") { // 把订单数据写入到payorder await query(`insert into payorder (appid,mch_id,nonce_str,body,out_trade_no,total_fee,spbill_create_ip,trade_type,trade_state) values ("${appid}","${mch_id}","${nonce_str}","${body}","${out_trade_no}","${total_fee}","${spbill_create_ip}","${trade_type}","NOTPAY")`); data.payUrl = await QRCode.toDataURL(code_url) } ctx.body = { status: 200, data }}调用微信下单接口，订单生成时，需要把订单数据吸入，支付成功时，在回调通知接口中，根据商户订单号更新订单状态
我们目前微信下单时，随机字符串，商户订单号，在服务端生成的，我们遇到一个问题？ 微信下单和订单查询使用参数随机字符串，商户订单号是一致的，导致两个该在何时生成？？？
- 两种方案， 第一种是把随机字符串和商户订单号，在服务端生成，返回给前端。
- 为什么要给前端呢？ 是因为前端需要调用订单查询接口，需要使用微信下单时的随机字符串，商户订单号
- 第二种，在客户端生成，由客户端传给服务端。
// 微信下单module.exports.order = async (ctx) => { // 前端调用下单接口时传递的参数 const { body, total_fee, spbill_create_ip, trade_type} = ctx.request.body; // 生成sign需要的参数 const params = { appid, mch_id, // 商户号 nonce_str:getRandomStr(), // 32位以内的随机字符串 // sign, // 签名 body, // 商品描述 out_trade_no:getTrade_no(), // 商户订单号 total_fee, // 金额 spbill_create_ip, // 终端ip notify_url, // 微信服务器回调的地址 trade_type, // 支付类型 } // 生产签名 需要你发送的参数生成 const sign = createSign(params); //微信下单请求参数 let sendData = ` <xml> <appid>${appid}</appid> <body>${body}</body> <mch_id>${mch_id}</mch_id> <nonce_str>${params.nonce_str}</nonce_str> <notify_url>${notify_url}</notify_url> <out_trade_no>${params.out_trade_no}</out_trade_no> <spbill_create_ip>${spbill_create_ip}</spbill_create_ip> <total_fee>${total_fee}</total_fee> <trade_type>${trade_type}</trade_type> <sign>${sign}</sign> </xml> ` const data = await orderHandle(orderUrl, sendData); // 下单成功 const { return_code, return_msg, result_code, code_url } = data; if (return_code == 'SUCCESS' && return_msg == 'OK' && result_code == "SUCCESS") { // 把订单数据写入到payorder await query(`insert into payorder (appid,mch_id,nonce_str,body,out_trade_no,total_fee,spbill_create_ip,trade_type,trade_state) values ("${appid}","${mch_id}","${params.nonce_str}","${body}","${params.out_trade_no}","${total_fee}","${spbill_create_ip}","${trade_type}","NOTPAY")`); data.payUrl = await QRCode.toDataURL(code_url) // 把随机字符串 和商户订单号传给前端 data.nonce_str = params.nonce_str; data.out_trade_no = params.out_trade_no; } ctx.body = { status: 200, data }} 随机字符串，商户订单，在微信下单时传给前端，目的是，前端调订单查询时，需要这个参数，而且参数值必须一样？？ 订单生成时候用的参数值什么？查询的时候也要保持一直才行。
微信下单后的数据，把需要的字段写入的订单表中
1.创建订单表潘payorder
2.调用微信下单接口时，必须的请求，当成订单数据写入payorder
create table payorder ( `id` int NOT NULL auto_increment PRIMARY KEY, `appid` varchar(50) NOT NULL, `mch_id` varchar(50) NOT NULL, `nonce_str` varchar(50) NOT NULL, `body` varchar(100) NOT NULL, `out_trade_no` varchar(50) NOT NULL, `total_fee` varchar(50) NOT NULL, `spbill_create_ip` varchar(50) NOT NULL, `trade_type` varchar(20) NOT NULL, `trade_state` varchar(20) NOT null);数据表的创建，sql语法不区分大小写，推荐统一大写,
create table 表名 （
字段 数据类型
）
我们要走通微信下单到支付的流程，我们需要服务端的代码部署服务器， 目标：搞明白整个流程和相关注意事项
- 把本地代码复制粘贴到window 服务器
- 在window服务器上根据package.json 下载安装包
- 在服务端启动后端项目， postman测试流程
-
使用query操作sql时，
update
update 表名 set 列表 = 值 where 列名 = “${值}”select query(
insert into 表名 (列名...) values ("${值}")
2. 回调地址配置一定给服务端的接口地址对应起来3. 我们把订单数据在下单时就写入payorder， 在支付通知时只需要更改订单支付状态，无需支付回调查询订单表。
参考资料：
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent