全局添加路由鉴权/课程接口完善

Author: wangtunan

server/config.js

@@ -1,10 +1,13 @@
 export const ERR_OK = 0
+
 export const SIZE = 10
+
 export const payWay = {
   0: '支付宝',
   1: '微信',
   2: '余额'
 }
+
 export default {
   dbs: 'mongodb://127.0.0.1:27017/mooc'
 }

server/interface/address.js

@@ -2,12 +2,13 @@ import Router from 'koa-router'
 import Address from '../models/address.js'
 import { ERR_OK } from '../config.js'
 import { getGuid } from '../../src/utils/utils.js'
+import checkUser from '../middleware/auth.js'
 const router = new Router({
   prefix: '/address'
 })
 
 // 获取收获地址接口
-router.get('/list', async (ctx) => {
+router.get('/list', checkUser, async (ctx) => {
   const result = await Address.find({
     userid: ctx.session.user_id
   }).sort({
@@ -29,7 +30,7 @@ router.get('/list', async (ctx) => {
 })
 
 // 新增收获地址接口
-router.post('/create', async (ctx) => {
+router.post('/create', checkUser, async (ctx) => {
   const params = ctx.request.body
   params.id = getGuid()
   params.userid = ctx.session.user_id
@@ -49,7 +50,7 @@ router.post('/create', async (ctx) => {
 })
 
 // 编辑收获地址接口
-router.post('/update', async (ctx) => {
+router.post('/update', checkUser, async (ctx) => {
   const params = ctx.request.body
   const result = await Address.findOneAndUpdate({
     userid: ctx.session.user_id,
@@ -75,7 +76,7 @@ router.post('/update', async (ctx) => {
 })
 
 // 删除收获地址接口
-router.get('/delete', async (ctx) => {
+router.get('/delete', checkUser, async (ctx) => {
   const { id } = ctx.query
   if (!id) {
     ctx.body = {
@@ -102,7 +103,7 @@ router.get('/delete', async (ctx) => {
 })
 
 // 设为默认收获地址
-router.get('/default', async (ctx) => {
+router.get('/default', checkUser, async (ctx) => {
   const { id } = ctx.query
   const userid = ctx.session.user_id
   const setResult = await Address.find({

server/interface/bill.js

@@ -1,12 +1,13 @@
 import Router from 'koa-router'
 import Bill from '../models/bill.js'
+import checkUser from '../middleware/auth.js'
 import { ERR_OK, SIZE } from '../config.js'
 const router = new Router({
   prefix: '/bill'
 })
 
 // 消费记录列表
-router.get('/list', async (ctx) => {
+router.get('/list', checkUser, async (ctx) => {
   const userid = ctx.session.user_id
   const { page = 1, size = SIZE } = ctx.query
   try {

server/interface/cart.js

@@ -1,13 +1,14 @@
 import Router from 'koa-router'
 import Cart from '../models/cart.js'
+import checkUser from '../middleware/auth.js'
 import { getGuid } from '../../src/utils/utils.js'
 import { ERR_OK } from '../config.js';
 const router = new Router({
   prefix: '/cart'
 })
 
 // 购物车列表接口
-router.get('/list', async (ctx) => {
+router.get('/list', checkUser,  async (ctx) => {
   const userid = ctx.session.user_id
   try {
     const where = { userid: userid }
@@ -35,7 +36,7 @@ router.get('/list', async (ctx) => {
 })
 
 // 添加购物车
-router.post('/create', async (ctx) => {
+router.post('/create', checkUser, async (ctx) => {
   const userid = ctx.session.user_id
   const { id, title, img, price, isDiscount, discountPrice } = ctx.request.body
   try {
@@ -81,7 +82,7 @@ router.post('/create', async (ctx) => {
 })
 
 // 删除购物车
-router.post('/delete', async (ctx) => {
+router.post('/delete', checkUser, async (ctx) => {
   const userid = ctx.session.user_id
   const { id } = ctx.request.body
   if (!id) {
@@ -117,7 +118,7 @@ router.post('/delete', async (ctx) => {
 })
 
 // 批量删除购物车
-router.post('/delete/ids', async (ctx) => {
+router.post('/delete/ids', checkUser,  async (ctx) => {
   const userid = ctx.session.user_id
   const { ids } = ctx.request.body
   if (!ids || ids.length === 0) {

server/interface/coupon.js

@@ -1,12 +1,13 @@
 import Router from 'koa-router'
 import Coupon from '../models/coupon.js'
+import checkUser from '../middleware/auth.js'
 import { ERR_OK } from '../config.js'
 const router = new Router({
   prefix: '/coupon'
 })
 
 // 优惠券列表数据
-router.get('/list', async (ctx) => {
+router.get('/list', checkUser, async (ctx) => {
   const userid = ctx.session.user_id
   const { status } = ctx.query
   try {

server/interface/label.js

@@ -2,6 +2,7 @@ import Router from 'koa-router'
 import Label from '../models/label.js'
 import LableType from '../models/labelType.js'
 import LabelFollow from '../models/labelFollow.js'
+import checkUser from '../middleware/auth.js'
 import { ERR_OK } from '../config.js'
 import { getGuid } from '../../src/utils/utils.js';
 const router = new Router({
@@ -69,7 +70,7 @@ router.get('/list', async (ctx) => {
 })
 
 // 用户关注标签路由
-router.post('/follow', async (ctx) => {
+router.post('/follow', checkUser, async (ctx) => {
   const userid = ctx.session.user_id
   const { list } = ctx.request.body
   // 验证是否有要关注的标签
@@ -121,7 +122,7 @@ router.post('/follow', async (ctx) => {
 })
 
 // 用户关注标签列表路由
-router.get('/follow/list', async (ctx) => {
+router.get('/follow/list', checkUser, async (ctx) => {
   const userid = ctx.session.user_id
   try {
     const result = await LabelFollow.find({

server/interface/lesson.js

@@ -3,12 +3,14 @@ import Lesson from '../models/lesson.js'
 import UserLesson from '../models/userLesson.js'
 import Catalog from '../models/catalog.js'
 import { ERR_OK, SIZE } from '../config.js'
+import checkUser from '../middleware/auth.js'
 const router = new Router({
   prefix: '/lesson'
 })
 
 // 课程列表路由
 router.get('/list', async (ctx) => {
+  const userid = ctx.session.user_id
   const { 
     page = 1,
     size = SIZE,
@@ -44,8 +46,18 @@ router.get('/list', async (ctx) => {
       sortWhere[sort] = -1
     }
     const total = await Lesson.find(where).countDocuments()
-    const result = await Lesson.find(where).skip((page - 1) * size).limit(+size).sort(sortWhere)
+    const result = await Lesson.find(where).skip((page - 1) * size).limit(+size).sort(sortWhere).lean()
     if (result) {
+      // 处理是否购买，是否收藏
+      if (+type === 1) {
+        for (let index = 0; index < result.length; index++) {
+          const isBuyed = await UserLesson.findOne({
+            userid: userid,
+            lessonid: result[index].id
+          })
+          result[index]['isBuy'] = !!isBuyed
+        }
+      }
       ctx.body = {
         code: ERR_OK,
         msg: '获取课程数据成功',
@@ -77,7 +89,7 @@ router.get('/list', async (ctx) => {
 })
 
 // 课程详情路由
-router.get('/info', async (ctx) => {
+router.get('/info', checkUser, async (ctx) => {
   const { id } = ctx.query
   if (!id) {
     ctx.body = {
@@ -115,7 +127,7 @@ router.get('/info', async (ctx) => {
 })
 
 // 用户课程列表路由
-router.get('/user', async (ctx) => {
+router.get('/user', checkUser, async (ctx) => {
   const userid = ctx.session.user_id
   const { page = 1, size = SIZE } = ctx.query
   try {

server/interface/log.js

@@ -1,12 +1,13 @@
 import Router from 'koa-router'
 import Log from '../models/log.js'
+import checkUser from '../middleware/auth.js'
 import { SIZE, ERR_OK } from '../config.js'
 const router = new Router({
   prefix: '/log'
 })
 
 // 分页获取登录日志接口
-router.get('/list', async (ctx) => {
+router.get('/list', checkUser,  async (ctx) => {
   const { page = 1 } = ctx.query
   const userid = ctx.session.user_id
   const where = { userid }
@@ -33,7 +34,7 @@ router.get('/list', async (ctx) => {
 })
 
 // 新增一条登录日志
-router.post('/create', async (ctx) => {
+router.post('/create', checkUser,  async (ctx) => {
   const params = ctx.request.body
   const result = await Log.create(params)
   if (result) {

server/interface/notice.js

@@ -1,14 +1,15 @@
 import Router from 'koa-router'
 import Notice from '../models/notice.js'
 import UserNotice from '../models/userNotice.js'
+import checkUser from '../middleware/auth.js'
 import { SIZE, ERR_OK } from '../config.js'
 import { getGuid } from '../../src/utils/utils.js'
 const router = new Router({
   prefix: '/notice'
 })
 
 // 消息分页列表接口
-router.get('/list', async (ctx) => {
+router.get('/list', checkUser, async (ctx) => {
   const { page = 1, code } = ctx.query
   const userid = ctx.session.user_id
   let where = {}
@@ -61,7 +62,7 @@ router.get('/list', async (ctx) => {
 })
 
 // 单个消息已读
-router.post('/read', async (ctx) => {
+router.post('/read', checkUser, async (ctx) => {
   const { id } = ctx.request.body
   const userid = ctx.session.user_id
   // 判断是否传入id
@@ -126,7 +127,7 @@ router.post('/read', async (ctx) => {
 })
 
 // 消息全部已读
-router.post('/read/all', async (ctx) => {
+router.post('/read/all', checkUser, async (ctx) => {
   const { ids } = ctx.request.body
   const userid = ctx.session.user_id
   try {
@@ -161,7 +162,7 @@ router.post('/read/all', async (ctx) => {
 })
 
 // 单个删除消息
-router.post('/delete', async (ctx) => {
+router.post('/delete', checkUser, async (ctx) => {
   const { id } = ctx.request.body
   const userid = ctx.session.user_id
   if (!id) {
@@ -224,7 +225,7 @@ router.post('/delete', async (ctx) => {
 })
 
 // 是否存在未读消息
-router.get('/read/not', async (ctx) => {
+router.get('/read/not', checkUser, async (ctx) => {
   try {
     const noticeCount = await Notice.find().countDocuments()
     const userCount = await UserNotice.find({

server/interface/order.js

@@ -5,14 +5,15 @@ import Bill from '../models/bill.js'
 import Recharge from '../models/recharge.js'
 import UserLesson from '../models/userLesson.js'
 import axios from 'axios'
+import checkUser from '../middleware/auth.js'
 import { getGuid, getOrderId } from '../../src/utils/utils.js'
 import { ERR_OK, payWay, SIZE } from '../config.js';
 const router = new Router({
   prefix: '/order'
 })
 
 // 生成订单
-router.post('/create', async (ctx) => {
+router.post('/create', checkUser, async (ctx) => {
   const userid = ctx.session.user_id
   const { list } = ctx.request.body
 
@@ -68,7 +69,7 @@ router.post('/create', async (ctx) => {
 })
 
 // 订单详情
-router.get('/info', async (ctx) => {
+router.get('/info', checkUser, async (ctx) => {
   const userid = ctx.session.user_id
   const { code } = ctx.query
   try {
@@ -99,7 +100,7 @@ router.get('/info', async (ctx) => {
 })
 
 // 订单支付
-router.post('/pay', async (ctx) => {
+router.post('/pay', checkUser, async (ctx) => {
   const userid = ctx.session.user_id
   const { code, way = 0 } = ctx.request.body
   if (!code) {
@@ -210,7 +211,7 @@ router.post('/pay', async (ctx) => {
       userLessonData.push({
         id: getGuid(),
         userid: userid,
-        lessonid: item.id,
+        lessonid: item.lessonid,
         title: item.title,
         img: item.img,
         type: {
@@ -254,7 +255,7 @@ router.post('/pay', async (ctx) => {
 })
 
 // 订单列表
-router.get('/list', async (ctx) => {
+router.get('/list', checkUser, async (ctx) => {
   const userid = ctx.session.user_id
   const { page = 1, status = '', size = SIZE } = ctx.query
   // 主动处理过期数据
@@ -326,7 +327,7 @@ router.get('/list', async (ctx) => {
 })
 
 // 取消订单
-router.get('/cancel', async (ctx) => {
+router.get('/cancel', checkUser, async (ctx) => {
   const userid = ctx.session.user_id
   const { id } = ctx.query
   if (!id) {
@@ -366,7 +367,7 @@ router.get('/cancel', async (ctx) => {
 })
 
 // 删除订单
-router.get('/delete', async (ctx) => {
+router.get('/delete', checkUser, async (ctx) => {
   const userid = ctx.session.user_id
   const { id } = ctx.query
   if (!id) {

server/interface/recharge.js

@@ -1,13 +1,14 @@
 import Router from 'koa-router'
 import Recharge from '../models/recharge.js'
+import checkUser from '../middleware/auth.js'
 import { ERR_OK, SIZE } from '../config.js'
 import { getGuid } from '../../src/utils/utils.js'
 const router = new Router({
   prefix: '/recharge'
 })
 
 // 用户充值记录路由
-router.get('/list', async (ctx) => {
+router.get('/list', checkUser,  async (ctx) => {
   const userid = ctx.session.user_id
   const { page = 1, size = SIZE } = ctx.query
   const where = { userid }
@@ -43,7 +44,7 @@ router.get('/list', async (ctx) => {
 })
 
 // 新增用户充值记录路由
-router.post('/create', async (ctx) => {
+router.post('/create', checkUser,  async (ctx) => {
   const userid = ctx.session.user_id
   const { money, way } = ctx.request.body
   // 判断金额
@@ -99,7 +100,7 @@ router.post('/create', async (ctx) => {
 })
 
 // 用户余额路由
-router.get('/charge', async (ctx) => {
+router.get('/charge', checkUser, async (ctx) => {
   const userid = ctx.session.user_id || ctx.query.userid
   try {
     const result = await Recharge.find({