auto add student

Author: quanht99

.gitignore

@@ -1,4 +1,5 @@
 node_modules
 .idea
 config/local.json
-key.json
+key.json
+src/uploads/file

package.json

@@ -26,8 +26,11 @@
     "express": "^4.16.4",
     "jsonwebtoken": "^8.5.0",
     "morgan": "^1.9.1",
+    "multer": "^1.4.1",
     "mysql2": "^1.6.5",
     "nodemon": "^1.18.10",
-    "sequelize": "^4.42.0"
+    "sequelize": "^4.42.0",
+    "xls-to-json-lc": "^0.3.4",
+    "xlsx-to-json-lc": "^0.5.0"
   }
 }

src/controller/user.controller.js

@@ -13,7 +13,6 @@ async function register(req, res) {
         email,
         name
     } = req.body;
-    console.log(req.body);
     try {
         if(!user_name || !password || !email || !name){
             throw new Error("Bạn vui lòng điền đủ theo mẫu.")

src/router/index.js

@@ -2,9 +2,11 @@ const api = require('express').Router();
 const user_router = require('./user');
 const team_router = require('./team');
 const course_router = require('./course');
+const Tool = require('../utils/addStudentsToDatabase');
 
 api.use('/users', user_router);
 api.use('/teams', team_router);
 api.use('/courses', course_router);
+api.post('/students', Tool.autoAdd);
 
 module.exports = api;

src/utils/addStudentsToDatabase.js

@@ -0,0 +1,98 @@
+const multer = require('multer');
+const xlstojson = require("xls-to-json-lc");
+const xlsxtojson = require("xlsx-to-json-lc");
+const bcrypt = require('bcrypt');
+const response = require('./response');
+const db = require('../database');
+
+const storage = multer.diskStorage({
+    destination: function (req, file, cb) {
+        cb(null, './src/uploads/')
+    },
+    filename: function (req, file, cb) {
+        cb(null, file.fieldname)
+    }
+});
+
+const upload = multer({
+    storage: storage,
+    fileFilter: function (req, file, callback) {
+        if (file.originalname.split('.')[file.originalname.split('.').length - 1] !== "xlsx" && file.originalname.split('.')[file.originalname.split('.').length - 1] !== "xls") {
+            return callback(new Error('Wrong extension type'));
+        }
+        callback(null, true);
+    }
+}).single('file');
+
+
+module.exports.autoAdd = async (req, res) => {
+        let exceltojson;
+        try{
+            upload(req, res, async function (err) {
+                if (err) {
+                    throw new Error(err);
+                }
+                if (!req.file) {
+                    throw new Error("No file choose");
+                }
+                if (req.file.originalname.split('.')[req.file.originalname.split('.').length - 1] === 'xlsx') {
+                    exceltojson = xlsxtojson;
+                } else {
+                    exceltojson = xlstojson;
+                }
+                await exceltojson({
+                    input: req.file.path,
+                    output: null,
+                }, async function (err, jsonFile) {
+                    if (err) {
+                        throw new Error("Something went wrong");
+                    }
+                    const {team_id} = req.body;
+                    let i=0;
+                    let team = await db.TeamModel.findOne({
+                        where: {
+                            id: team_id
+                        }
+                    });
+                    if(!team){
+                        throw new Error("Team không tồn tại.")
+                    }
+                    for(i=0; i < jsonFile.length; i++){
+                        if(jsonFile[i].email && jsonFile[i].phone){
+                            let salt = await bcrypt.genSalt(10);
+                            let hashPassword = await bcrypt.hash(jsonFile[i].phone, salt);
+                            let user = await db.UserModel.findOrCreate({
+                                where: {
+                                    user_name: jsonFile[i].email
+                                },
+                                defaults: {
+                                    user_name: jsonFile[i].email,
+                                    email: jsonFile[i].email,
+                                    name: jsonFile[i].name,
+                                    password: hashPassword,
+                                    role_id: 3,
+                                    create_time: Date.now(),
+                                    avatar: "/img/avatar.png"
+                                }
+                            });
+                            await db.TeamUserModel.findOrCreate({
+                                where: {
+                                    user_id: user[0].dataValues.id,
+                                    team_id: team_id
+                                },
+                                defaults: {
+                                    user_id: user[0].dataValues.id,
+                                    team_id: team_id
+                                }
+                            });
+                        }
+                    }
+                    return res.json(response.success({}));
+                });
+            })
+        }
+        catch(err){
+            console.log("Error: ", err.message);
+            return res.json(response.fail(err.message));
+        }
+};