基于nodeJS和mongodb数据库的后台管理系统接口，数据，用户的增删改查接口.zip

/* ************************ 还没优化,可以让前端传集合名字， 因为删除和修改、获取品牌信息和获取手机信息方法代码一样， 返回的结果集也一样，只是查询的集合不一样 **************************** */ var express = require("express"); var async = require("async"); var bodyParser = require("body-parser"); var MongoClient = require("mongodb").MongoClient; var ObjectId = require("mongodb").ObjectId; var multer = require("multer"); var upload = multer({ dest: "d:temp" }); var fs = require("fs"); var path = require("path"); var app = express(); var url = "mongodb://127.0.0.1:27017"; app.use( bodyParser.urlencoded({ extended: false }) ); app.use(bodyParser.json()); //指定静态资源访问目录 app.use(express.static(__dirname + "/public")); // app.use(express.static(require('path').join(__dirname, 'public'))); // app.use(express.static('public')); app.use(function (req, res, next) { // res.header("Access-Control-Allow-Origin", "*"); // res.header("Access-Control-Allow-Headers", "X-Requested-With"); // res.header("Access-Control-Allow-Methods", "PUT,POST,GET,DELETE,OPTIONS"); // 设置响应头来处理跨域问题 res.set({ "Access-Control-Allow-Origin": "*" }); next(); }); /* ************************ 用户 **************************** */ //注册用户 app.post("/api/register", function (req, res) { var userName = req.body.name; var pwd = req.body.pwd; var nicik = req.body.nicik; var phone = parseInt(req.body.phone); var age = parseInt(req.body.age); var sex = req.body.sex; var isAdmin = req.body.isAdmin === "是" ? true : false; var results = {}; MongoClient.connect( url, { userNewUrlParser: true }, function (err, client) { if (err) { //连接数据库失败 results.code = -1; results.msg = "数据库连接失败"; res.json(results); return; } else { var db = client.db("nodeProject"); async.series( [ function (cb) { db.collection("user") .find({ name: userName }) .count(function (err, num) { if (err) { cb(err); } else if (num > 0) { // 这个人已经注册过了， cb(new Error("已经注册")); } else { // 可以注册了 cb(null); } }); }, function (cb) { db.collection("user").insertOne({ name: userName, password: pwd, nicik: nicik, phone: phone, age: age, sex: sex, isAdmin: isAdmin }, function (err) { if (err) { cb(err); } else { cb(null); } } ); } ], function (err, result) { if (err) { results.code = -1; results.msg = "注册失败"; res.json(results); client.close(); return; } else { // 注册成功 results.code = 0; results.msg = "注册成功"; results.data = { nicik: nicik, isAdmin: isAdmin }; } client.close(); res.json(results); } ); } } ); }); //用户登录 app.post("/api/login", function (req, res) { var userName = req.body.name; var pwd = req.body.pwd; var results = {}; MongoClient.connect( url, { userNewUrlParser: true }, function (err, client) { if (err) { //连接数据库失败 results.code = -1; results.msg = "数据库连接失败"; res.json(results); return; } else { var db = client.db("nodeProject"); db.collection("user") .find({ name: userName, password: pwd }) .toArray(function (err, data) { if (err) { results.code = -1; results.msg = "查询失败"; } else if (data.length <= 0) { results.code = -1; results.msg = "用户名或密码错误"; } else { // 登录成功 results.code = 1; results.msg = "登录成功"; results.data = { nicik: data[0].nicik, isAdmin: data[0].isAdmin }; } client.close(); res.json(results); }); } } ); }); //用户管理，获取所有用户信息 app.post("/api/allUser", function (req, res) { var page = parseInt(req.body.page); var pageSize = parseInt(req.body.pageSize); var totalSize = 0; // 总条数 var totalPage = 0; // 总页数 var results = {}; MongoClient.connect( url, { userNewUrlParser: true }, function (err, client) { if (err) { //连接数据库失败 results.code = -1; results.msg = "数据库连接失败"; res.json(results); return; } else { var db = client.db("nodeProject"); async.series( [ function (cb) { db.collection("user") .find() .count(function (err, num) { if (err) { cb(err); } else { totalSize = num; cb(null); } }); }, function (cb) { db.collection("user") .find() .limit(pageSize) .skip(page * pageSize - pageSize) .toArray(function (err, data) { if (err) {