Node + Express + MongoDB 搭建商城后台服务

朱雀 2023-07-09 09:30 144阅读 0赞

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNDc3NzIx_size_16_color_FFFFFF_t_70_pic_center]

#### 运行环境 ####

*  node 12.21.0
 *  npm 6.14.11

##### 安装 express-generator [npm地址][npm] #####

npm install -g express-generator

##### 查看express 版本 express --version #####

*  express 4.16.1

#### 1. 新建文件夹，执行 `express server` ####

(如果是通过 gitee/ github 来托管代码，要在之后生成的根目录中添加 .gitignore 文件)

.gitignore

.DS_Store
    node_modules/
    /dist/
    npm-debug.log*
    yarn-debug.log*
    yarn-error.log*
    
    # Editor directories and files
    .idea
    .vscode
    *.suo
    *.ntvs*
    *.njsproj
    *.sln

cd server
    npm install

![在这里插入图片描述][20200228161008336.PNG]

#### 2. 启动项目 ####

node bin/www

访问 localhost:3000

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNDc3NzIx_size_16_color_FFFFFF_t_70]

#### 3. 连接 MongoDB 数据库 ####

Mongoose 是对 MongoDB 的封装，安装这个的前提是电脑中安装了MongoDB。不知道怎么安装MongoDB的，可以去看一下我关于怎么安装MongoDB的文章。

##### 安装 Mongoose #####

npm install mongoose --save

######  ######

#### 4. 创建 models 文件夹 ####

goods.js （商品 model）

var mongoose = require('mongoose')
    var Schema = mongoose.Schema
    
    var produtSchema = new Schema({ 
      'productId': String,
      'productName': String,
      // 是否选中
      'checked': String,
      'salePrice': Number,
      'productImage': String,
      // 库存
      'productNum': Number,
      // 商品详情图片
      'prouctDetailImgs': Array,
      // 商品介绍
      'presentation': String,
      // 直营
      'isDirect': Boolean,
      // 是否有货
      'isHave': Boolean,
      // 轮播图片
      'swiperImgs': Array
    })
    
    module.exports = mongoose.model('Good', produtSchema)

#### 5. 创建路由并且连接数据库 ####

goods.js （创建路由）

var express = require('express')
    var router = express.Router()
    var mongoose = require('mongoose')
    // 加载模型表
    var Goods = require('../models/goods')
    // 连接数据库 imoocmall 这个是我在mongodb里面的创建的数据库
    mongoose.connect('mongodb://127.0.0.1:27017/imoocmall', {  useNewUrlParser: true }, function (err) { 
      if (err) { 
        console.log('Connection Error:' + err)
      } else { 
        console.log('Connection success!')
      }
    })
    // 监听数据库是否连接
    mongoose.connection.on('connected', function () { 
      console.log('MongoDB connected success')
    })
    // 监听数据库是否失败
    mongoose.connection.on('error', function () { 
      console.log('MongoDB connected fail')
    })
    // 监听数据库是否断开
    mongoose.connection.on('disconnected', function () { 
      console.log('MongoDB connected disconnected')
    })
    // (二级路由)
    router.get('/list', function (req, res, next) { 
      Goods.find({ }, function (err, doc) { 
        if (err) { 
          res.json({ 
            status: 1,
            msg: err.message
          })
        } else { 
          res.json({ 
            status: 0,
            msg: '',
            result: { 
              count: doc.length,
              list: doc
            }
          })
        }
      })
    })
    module.exports = router

#### 6. app.js 导入路由 ####

此时前端的访问路由为 `/goods/list`

--------------------

### 1. 登录, 注册, 退出, 登录验证功能 ###

用户 model

var mongoose = require('mongoose')
    
    var userSchema = new mongoose.Schema({ 
      'usertId': String,
      'userName': String,
      'userPwd': String,
      'orderList': Array,
      'cartList': [
        { 
          'productId': String,
          'productName': String,
          'salePrice': String,
          'productImage': String,
          'checked': String,
          'productNum': Number
        }
      ],
      'addressList': [
        { 
          'addressId': String,
          'userName': String,
          'streetName': String,
          'postCode': Number,
          'tel': Number,
          'isDefault': Boolean
        }
      ]
    })
    
    module.exports = mongoose.model('User', userSchema, 'users')

#### 登录注册 ####

var express = require('express')
    var router = express.Router()
    require('../util/util')
    var User = require('../models/user')
    
    router.post('/register', function (req, res) { 
      var param = { 
        userName: req.body.userName,
        userPwd: req.body.userPwd
      }
      User.findOne({  userName: param.userName }, function (doc) { 
        if (doc) { 
          return res.json({  code: 1, msg: '用户名重复' })
        }
    
        const userModel = new User(param)
        userModel.save(function (e, d) { 
          if (e) { 
            return res.json({  code: 1, msg: '后端出错了' })
          }
          const {  user, type, _id } = d
          res.cookie('userid', _id, { 
            path: '/',
            maxAge: 1000 * 60 * 60
          })
          return res.json({  status: 0, msg: '', result: {  user, type, _id } })
        })
      })
    })
    
    router.post('/login', function (req, res, next) { 
      var param = { 
        userName: req.body.userName,
        userPwd: req.body.userPwd
      }
      User.findOne(param, function (err, doc) { 
        if (err) { 
          res.json({ 
            status: '1',
            msg: err.message
          })
        } else { 
          if (doc) { 
            res.cookie('userid', doc._id, { 
              path: '/',
              maxAge: 1000 * 60 * 60
            })
            res.cookie('userName', doc.userName, { 
              path: '/',
              maxAge: 1000 * 60 * 60
            })
            res.json({ 
              status: 0,
              msg: '',
              result: { 
                userName: doc.userName
              }
            })
          }
        }
      })
    })

#### 退出登录 ####

router.post('/logout', function (req, res, next) { 
      res.cookie('userid', '', { 
        path: '/',
        maxAge: -1
      })
      res.cookie('userName', '', { 
        path: '/',
        maxAge: -1
      })
      res.json({ 
        status: 0,
        msg: '',
        result: ''
      })
    })

#### 登录校验（判断用户是否登录） ####

入口文件（app.js）

app.use(function (req, res, next) { 
      if (req.cookies.userName) { 
        next()
      } else { 
        if (req.originalUrl === '/users/register' || req.originalUrl === '/users/login' || req.originalUrl === '/users/logout' || req.path === '/goods/list') { 
          next()
        } else { 
          res.json({ 
            status: '100001',
            msg: '当前未登录',
            result: ''
          })
        }
      }
    })

### 2. 商品列表的增删改查 ###

#### 获取商品列表 ####

router.get('/list', function (req, res, next) { 
      let page = parseInt(req.param('page'))
      let pageSize = parseInt(req.param('pageSize'))
      let priceLevel = req.param('priceLevel')
      let sort = req.param('sort')
      let skip = (page - 1) * pageSize
      // eslint-disable-next-line one-var
      var priceGt = '', priceLte = ''
      let params = { }
      if (priceLevel !== 'all') { 
        switch (priceLevel) { 
          case '0': priceGt = 0; priceLte = 100; break
          case '1': priceGt = 100; priceLte = 500; break
          case '2': priceGt = 500; priceLte = 1000; break
          case '3': priceGt = 1000; priceLte = 5000; break
        }
        params = { 
          salePrice: { 
            $gt: priceGt,
            $lte: priceLte
          }
        }
      }
      let goodsModel = Goods.find(params).skip(skip).limit(pageSize)
      goodsModel.sort({ 'salePrice': sort})
      goodsModel.exec(function (err, doc) { 
        if (err) { 
          res.json({ 
            status: '1',
            msg: err.message
          })
        } else { 
          res.json({ 
            status: '0',
            msg: '',
            result: { 
              count: doc.length,
              list: doc
            }
          })
        }
      })
    })

#### 加入购物车 ####

router.post('/addCart', function (req, res, next) { 
      const {  userid } = req.cookies
      var productId = req.body.productId
      var User = require('../models/user')
      User.findOne({  _id: userid }, function (err, userDoc) { 
        if (err) { 
          res.json({ 
            status: '1',
            msg: err.message
          })
        } else { 
          console.log('userDoc' + userDoc)
          if (userDoc) { 
            let goodsItem = ''
            userDoc.cartList.forEach((item) => { 
              if (item.productId === productId) { 
                goodsItem = item
                item.productNum++
              }
            })
            if (goodsItem) { 
              userDoc.save(function (err2, doc2) { 
                if (err2) { 
                  res.json({ 
                    status: '1',
                    msg: err2.message
                  })
                } else { 
                  res.json({ 
                    status: 0,
                    msg: '',
                    result: '加入成功'
                  })
                }
              })
            } else { 
              Goods.findOne({  productId: productId }, function (err1, doc) { 
                if (err1) { 
                  res.json({ 
                    status: '1',
                    msg: err1.message
                  })
                } else { 
                  if (doc) { 
                    doc.productNum = 1
                    doc.checked = 1
                    userDoc.cartList.push(doc)
                    userDoc.save(function (err2, doc2) { 
                      if (err2) { 
                        res.json({ 
                          status: '1',
                          msg: err2.message
                        })
                      } else { 
                        res.json({ 
                          status: 0,
                          msg: '',
                          result: '加入成功2'
                        })
                      }
                    })
                  }
                }
              })
            }
          }
        }
      })
    })

#### 获取购物车数量 ####

router.get('/getCartCount', function (req, res, next) { 
      if (req.cookies && req.cookies.userName) { 
        var userName = req.cookies.userName
        User.findOne({  userName: userName }, function (err, doc) { 
          if (err) { 
            res.json({ 
              status: '1',
              msg: err.message,
              result: ''
            })
          } else { 
            var cartList = doc.cartList
            let cartCount = 0
            cartList.map(function (item) { 
              cartCount += parseInt(item.productNum)
            })
            if (doc) { 
              res.json({ 
                status: '0',
                msg: '',
                result: cartCount
              })
            }
          }
        })
      }
    })

#### 查询购物车数据 ####

router.get('/cartList', function (req, res, next) { 
      var userName = req.cookies.userName
      User.findOne({  userName: userName }, function (err, doc) { 
        if (err) { 
          res.json({ 
            status: '1',
            msg: err.message,
            result: ''
          })
        } else { 
          if (doc) { 
            res.json({ 
              status: '0',
              msg: '',
              result: doc.cartList
            })
          }
        }
      })
    })

#### 购物车删除 ####

router.post('/cartDel', function (req, res, next) { 
      var userName = req.cookies.userName
      var productId = req.body.productId
      User.update({ 
        userName: userName
      }, { 
        $pull: { 
          'cartList': { 
            'productId': productId
          }
        }
      }, function (err, doc) { 
        if (err) { 
          res.json({ 
            status: '1',
            msg: err.message,
            result: ''
          })
        } else { 
          res.json({ 
            status: '0',
            msg: '',
            result: 'suc'
          })
        }
      })
    })

#### 编辑购物车数量 ####

router.post('/cartEdit', function (req, res, next) { 
      var userName = req.cookies.userName
      var productId = req.body.productId
      var productNum = req.body.productNum
      var checked = req.body.checked
      User.update({  'userName': userName, 'cartList.productId': productId }, { 
        'cartList.$.productNum': productNum,
        'cartList.$.checked': checked
      }, function (err, doc) { 
        if (err) { 
          res.json({ 
            status: '1',
            msg: err.message,
            result: ''
          })
        } else { 
          res.json({ 
            status: '0',
            msg: '',
            result: 'suc'
          })
        }
      })
    })

#### 全选购物车商品 ####

router.post('/editCheckAll', function (req, res, next) { 
      var userName = req.cookies.userName
      var checkAll = req.body.checkAll ? '1' : '0'
      User.findOne({  userName: userName }, function (err, user) { 
        if (err) { 
          res.json({ 
            status: '1',
            msg: err.message,
            result: ''
          })
        } else { 
          if (user) { 
            user.cartList.forEach((item) => { 
              item.checked = checkAll
            })
            user.save(function (err1, doc) { 
              if (err1) { 
                res.json({ 
                  status: '1',
                  msg: err1.message,
                  result: ''
                })
              } else { 
                res.json({ 
                  status: '0',
                  msg: '',
                  result: 'suc'
                })
              }
            })
          }
        }
      })
    })

#### 查询用户的地址 ####

router.get('/addressList', function (req, res, next) { 
      var userName = req.cookies.userName
      User.findOne({  userName: userName }, function (err, doc) { 
        if (err) { 
          res.json({ 
            status: '1',
            msg: err.message,
            result: ''
          })
        } else { 
          res.json({ 
            status: '0',
            msg: '',
            result: doc.addressList
          })
        }
      })
    })

#### 新增地址 ####

router.post('/newAddress', function (req, res, next) { 
      var userName = req.cookies.userName
      const data = req.body.address
      if (!data) { 
        res.json({ 
          status: '1',
          msg: '无数据',
          result: ''
        })
      }
      User.findOne({  userName: userName }, function (err, doc) { 
        if (err) { 
          res.json({ 
            status: '1',
            msg: err.message,
            result: ''
          })
        } else { 
          const oldList = doc.addressList
          const newList = oldList.concat(data)
          User.updateOne({  userName: userName }, { $set: { addressList: newList}}, function (err) { 
            if (err) { 
              res.json({ 
                status: '1',
                msg: '添加失败',
                result: ''
              })
            } else { 
              res.json({ 
                status: '0',
                msg: '',
                result: doc.addressList
              })
            }
          })
        }
      })
    })

#### 设置默认地址 ####

router.post('/setDefault', function (req, res, next) { 
      var userName = req.cookies.userName
      var addressId = req.body.addressId
      if (!addressId) { 
        res.json({ 
          status: '10003',
          msg: 'addressList is null',
          result: ''
        })
      } else { 
        User.findOne({  userName: userName }, function (err, doc) { 
          if (err) { 
            res.json({ 
              status: '1',
              msg: err.message,
              result: ''
            })
          } else { 
            var addressList = doc.addressList
            addressList.forEach((item) => { 
              if (item.addressId === addressId) { 
                item.isDefault = true
              } else { 
                item.isDefault = false
              }
            })
            doc.save(function (err1, doc1) { 
              if (err1) { 
                res.json({ 
                  status: '1',
                  msg: err1.message,
                  result: ''
                })
              } else { 
                res.json({ 
                  status: '0',
                  msg: '',
                  result: ''
                })
              }
            })
          }
        })
      }
    })

#### 删除地址 ####

router.post('/delAddress', function (req, res, next) { 
      var userName = req.cookies.userName
      var _id = req.body._id
      User.update({ 
        userName: userName
      }, { 
        $pull: { 
          'addressList': { 
            '_id': _id
          }
        }
      }, function (err, doc) { 
        if (err) { 
          res.json({ 
            status: '1',
            msg: err.message,
            result: ''
          })
        } else { 
          res.json({ 
            status: '0',
            msg: '',
            result: 'suc'
          })
        }
      })
    })

#### 生成订单 ####

router.post('/payMent', function (req, res, next) { 
      var userName = req.cookies.userName
      var orderTotal = req.body.orderTotal
      var _id = req.body._id
      User.findOne({  userName: userName }, function (err, doc) { 
        if (err) { 
          res.json({ 
            status: '1',
            msg: err.message,
            result: ''
          })
        } else { 
          var address = ''
          var goodList = []
          // 获取当前用户的地址信息
          doc.addressList.forEach((item) => { 
            if (_id === item._id) { 
              address = item
            }
          })
          doc.cartList.filter((item) => { 
            if (item.checked === '1') { 
              goodList.push(item)
            }
          })
    
          // 生成orderId
          var platform = '520'
          var r1 = Math.floor(Math.random() * 10)
          var r2 = Math.floor(Math.random() * 10)
    
          var sysDate = new Date().Format('yyyyMMddhhmmss')
          var createDate = new Date().Format('yyyy-MM-dd-hh-mm-ss')
          var orderId = platform + r1 + sysDate + r2
    
          var order = { 
            orderId: orderId,
            orderTotal: orderTotal,
            addressInfo: address,
            goodList: goodList,
            orderStatus: '1',
            createDate: createDate
          }
    
          doc.orderList.push(order)
    
          doc.save(function (err1, doc1) { 
            if (err1) { 
              res.json({ 
                status: '1',
                msg: err1.message,
                result: ''
              })
            } else { 
              res.json({ 
                status: '0',
                msg: '',
                result: { 
                  orderId: order.orderId,
                  orderTotal: order.orderTotal
                }
              })
            }
          })
        }
      })
    })

#### 根据订单ID查询订单信息 ####

router.get('/orderDetail', function (req, res, next) { 
      var userName = req.cookies.userName
      var orderId = req.param('orderId')
      User.findOne({  userName: userName }, function (err, userInfo) { 
        if (err) { 
          res.json({ 
            status: '1',
            msg: err.message,
            result: ''
          })
        } else { 
          var orderList = userInfo.orderList
          if (orderList.length > 0) { 
            var orderTotal = 0
            orderList.forEach((item) => { 
              if (item.orderId === orderId) { 
                orderTotal = item.orderTotal
              }
            })
            if (orderTotal > 0) { 
              res.json({ 
                status: '0',
                msg: '',
                result: { 
                  orderId: orderId,
                  orderTotal: orderTotal
                }
              })
            } else { 
              res.json({ 
                status: '120002',
                msg: '无此订单',
                result: ''
              })
            }
          } else { 
            res.json({ 
              status: '120001',
              msg: '当前用户未创建订单',
              result: ''
            })
          }
        }
      })
    })

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNDc3NzIx_size_16_color_FFFFFF_t_70_pic_center]: https://img-blog.csdnimg.cn/20210607132313161.jpg?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNDc3NzIx,size_16,color_FFFFFF,t_70#pic_center
[npm]: https://www.npmjs.com/package/expressjs-generator
[20200228161008336.PNG]: https://img-blog.csdnimg.cn/20200228161008336.PNG
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNDc3NzIx_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20200228161144217.PNG?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNDc3NzIx,size_16,color_FFFFFF,t_70