nbaPlayer

app.js

@@ -0,0 +1,66 @@
+const createError = require('http-errors');
+const express = require('express');
+const path = require('path');
+const cookieParser = require('cookie-parser');
+const logger = require('morgan');
+
+const indexRouter = require('./routes/index');
+const playerRouter = require('./routes/player');
+
+const app = express();
+
+const db = require(path.join(__dirname, './db/config/mongoose'))();
+
+
+// view engine setup
+app.set('views', path.join(__dirname, 'views'));
+app.set('view engine', 'ejs');
+
+app.use(logger('dev'));
+app.use(express.json());
+app.use(express.urlencoded({ extended: false }));
+app.use(cookieParser());
+app.use(express.static(path.join(__dirname, 'public')));
+
+app.use('/', indexRouter);
+app.use('/player', playerRouter);
+
+app.use(async function(req, res, next){
+    // add some function to the response
+    res.endWithErr = function(code, msg){
+        this.status(code).send({msg: msg});
+    };
+
+    res.endWithData = function (data, msg='OK') {
+        this.status(200).send({data, msg:msg});
+    };
+
+    res.makeError = function(code, message = ''){
+        this.locals.err = {code: code, message: message};
+    };
+
+    return next();
+});
+
+app.use(function(req, res, next) {
+    let code = 0, message = '', data = {};
+
+    if(res.locals.err)
+    {
+        code = res.locals.err.code;
+        message = res.locals.err.message;
+    } else if(res.locals.data)
+    {
+        code = 200;
+        data = res.locals.data;
+        message = res.locals.message;
+    }
+
+    code = code || 404;
+
+    return code === 200 ? res.endWithData(data, message) : res.endWithErr(code, message);
+});
+
+
+
+module.exports = app;

bin/www

@@ -0,0 +1,90 @@
+#!/usr/bin/env node
+
+/**
+ * Module dependencies.
+ */
+
+let app = require('../app');
+let debug = require('debug')('nbaplayer:server');
+let http = require('http');
+
+/**
+ * Get port from environment and store in Express.
+ */
+
+let port = normalizePort(process.env.PORT || '3000');
+app.set('port', port);
+
+/**
+ * Create HTTP server.
+ */
+
+let server = http.createServer(app);
+
+/**
+ * Listen on provided port, on all network interfaces.
+ */
+
+server.listen(port);
+server.on('error', onError);
+server.on('listening', onListening);
+
+/**
+ * Normalize a port into a number, string, or false.
+ */
+
+function normalizePort(val) {
+  let port = parseInt(val, 10);
+
+  if (isNaN(port)) {
+    // named pipe
+    return val;
+  }
+
+  if (port >= 0) {
+    // port number
+    return port;
+  }
+
+  return false;
+}
+
+/**
+ * Event listener for HTTP server "error" event.
+ */
+
+function onError(error) {
+  if (error.syscall !== 'listen') {
+    throw error;
+  }
+
+  let bind = typeof port === 'string'
+    ? 'Pipe ' + port
+    : 'Port ' + port;
+
+  // handle specific listen errors with friendly messages
+  switch (error.code) {
+    case 'EACCES':
+      console.error(bind + ' requires elevated privileges');
+      process.exit(1);
+      break;
+    case 'EADDRINUSE':
+      console.error(bind + ' is already in use');
+      process.exit(1);
+      break;
+    default:
+      throw error;
+  }
+}
+
+/**
+ * Event listener for HTTP server "listening" event.
+ */
+
+function onListening() {
+  let addr = server.address();
+  let bind = typeof addr === 'string'
+    ? 'pipe ' + addr
+    : 'port ' + addr.port;
+  debug('Listening on ' + bind);
+}

db/config/config.js

@@ -0,0 +1,14 @@
+const path = require('path');
+const logger = require(path.join(__dirname, '../../utils/logger'));
+
+if (process.env.NODE_ENV === 'production') {
+    logger.info('连接正式数据库中……');
+    module.exports = {
+        mongodb: 'mongodb://127.0.0.1:27017/player_prod'
+    };
+} else {
+    logger.info('连接开发数据库中……');
+    module.exports = {
+        mongodb: 'mongodb://127.0.0.1:27017/player_dev'
+    };
+}

db/config/mongoose.js

@@ -0,0 +1,22 @@
+const mongoose = require('mongoose');
+const config = require('./config');
+const path = require('path');
+const logger = require(path.join(__dirname, '../../utils/logger'));
+
+mongoose.set('useFindAndModify', false);
+mongoose.set('useCreateIndex', true);
+
+module.exports = () => {
+    mongoose.connect(config.mongodb, {useNewUrlParser: true, autoIndex: false});//连接mongodb数据库
+
+    let db = mongoose.connection;
+
+    db.on('error', (err) => {
+        logger.error('连接数据库失败!! ' + err);
+    });
+    db.once('open', async () => {
+
+        logger.info('连接数据库成功!');
+    });
+    return db;
+};

db/models/player.js

@@ -0,0 +1,16 @@
+const mongoose = require('mongoose');
+const mongoosePaginate = require('mongoose-paginate');
+const beautifyUnique = require('mongoose-beautiful-unique-validation');
+const Schema = mongoose.Schema;
+
+const PlayerSchema = new Schema({
+    name: {type: String},
+    position: {type: String}
+});
+
+PlayerSchema.plugin(mongoosePaginate);
+PlayerSchema.plugin(beautifyUnique);
+
+const Player = mongoose.model('player', PlayerSchema);
+
+module.exports = Player;

package.json

@@ -0,0 +1,21 @@
+{
+  "name": "nbaplayer",
+  "version": "0.0.0",
+  "private": true,
+  "scripts": {
+    "start": "node ./bin/www"
+  },
+  "dependencies": {
+    "cookie-parser": "^1.4.4",
+    "debug": "~2.6.9",
+    "ejs": "^2.6.2",
+    "express": "^4.16.4",
+    "http-errors": "^1.6.3",
+    "mongoose": "^5.9.3",
+    "mongoose-beautiful-unique-validation": "^7.1.1",
+    "mongoose-extend-schema": "^1.0.0",
+    "mongoose-paginate": "^5.0.3",
+    "morgan": "^1.9.1",
+    "winston": "^3.2.1"
+  }
+}

public/stylesheets/style.css

@@ -0,0 +1,8 @@
+body {
+  padding: 50px;
+  font: 14px "Lucida Grande", Helvetica, Arial, sans-serif;
+}
+
+a {
+  color: #00B7FF;
+}

routes/index.js

@@ -0,0 +1,9 @@
+const express = require('express');
+const router = express.Router();
+
+/* GET home page. */
+router.get('/', function(req, res, next) {
+  res.render('index', { title: 'Express' });
+});
+
+module.exports = router;

routes/player.js

@@ -0,0 +1,34 @@
+const express = require('express');
+const path = require('path');
+const router = express.Router();
+const Player = require(path.join(__dirname, '../db/models/player'));
+
+router.post('/',
+    async (req, res, next) => {
+        await Player.create({name: req.body.name});
+
+        return next();
+    });
+
+router.get('/:id',
+    async (req, res, next) => {
+        res.locals.data = await Player.find({_id: req.params.id});
+
+        return next();
+    });
+
+router.put('/:id',
+    async (req, res, next) => {
+        res.locals.data = await Player.updateOne({_id: req.params.id}, {name: req.body.name});
+
+        return next();
+    });
+
+router.delete('/:id',
+    async (req, res, next) => {
+        await Player.remove({_id: req.params.id});
+        res.locals.data = {};
+        return next();
+    });
+
+module.exports = router;