# node

//数据库中的表
1	收到了	12	1  
3	姐将	18	1  
4	对看	19	2  
5	方看	17	2  

//dbutil.js连接数据库，的公用文件
var mysql = require("mysql");//引入MySQL，但先要安装MySQL
//连接数据库
var connection = mysql.createConnection({
   host: "127.0.0.1",//服务器定义的地址
   port: "3306",//MySQL的端口号
   user: "root",//MySQL的账户
   password: "bob*01",//MySQL的密码
   database: "school"//MySQL里要用的数据库
});
module.exports = connection;

//studentDao.js针对student数据库的操作文件
var connection = require("./dbutil");
//取到数据库中student表中所有数据
function queryAllStudent(sucess) {
    var querySql = "select * from student;";//查询student表中所有数据
    connection.connect();//连接数据库
    //如果连接成功，执行querySql之后，执行回调函数
    connection.query(querySql,function (err, result) {
        if(err == null) {
            console.log(result);
            sucess(result);
        }else {
            console.log(err);
        }
    });
    connection.end();//查询之后，必须关闭
};

// queryAllStudent();
//以classNum, age参数查询数据库
function queryStudentByClassAndAge(classNum, age) {
    var querySql = "select * from student where class = ? and age = ?;";
    var queryParams = [classNum, age];
    connection.connect();
    //第二个参数传多个参数时，要用数组
    connection.query(querySql,queryParams,function (err, result) {
        if(err == null) {
            console.log(result);
        }else {
            console.log(err);
        }
    });
    connection.end();
};

// queryStudentByClassAndAge(1, 18);
//web层调用service层；service层调用dao层；dao层调用数据库。
module.exports = {
    "queryAllStudent": queryAllStudent,
    "queryStudentByClassAndAge": queryStudentByClassAndAge
};

//studentsService.js处理web层的数据请求
var strdentDao = require("../dao/studentDao");

function queryAllStudent(sucess) {
    strdentDao.queryAllStudent(sucess);
};
module.exports = {"queryAllStudent": queryAllStudent};

//接收所有login里面页面请求
var studentService = require("../service/studentsService");
var path = new Map();
function getData(request, response) {
    // response.writeHead(200);
    // response.write("hello");
    // response.end();
    studentService.queryAllStudent(function (result) {
        var resArr = [];//收集数据的空数组
        for (var i = 0 ; i < result.length ; i ++) {
            resArr.push(result[i].name);//数据中name全部存入数组中
        };
        response.write(resArr.toString());//写回给浏览器
        response.end();
    });
}
path.set("/getData", getData);//（路径   ，   方法）

module.exports.path = path;

//应用express后的index.js
var app = new express();//创建express实例
var uploadSingle = multer({dest:"./file/"});//指定文件上传到哪里

app.use(express.static(globalConfig["page_path"]));//使用static方法加载某路径下的所有静态文件，不用单独写静态文件判断的配置了！
app.use(cookie());//使用cookie

app.get("/api/*", function (request, response, next) {//为/api路径下的所有动态请求设置拦截
    if(request.cookies.id) {//读取cookie中的某个属性值，如果存在就执行next（）
        console.log(request.cookies.id);
        next();//继续下面的操作
    }else {//如果不存在
        response.redirect("/login.html");//重定向到登录页面
    }
 });


app.get("/api/getAllStudent", loader.get("/api/getAllStudent"));//通过get方法，获取动态请求，并得到数据
app.get("/api/addStudent", loader.get("/api/addStudent"));//通过get方法，获取动态请求，并得到数据
app.get("/login", loader.get("/login"));//通过get方法，获取动态请求，并得到数据
//上传文件
app.post("/upload", uploadSingle.single("file"), loader.get("/upload"));//uploadSingle.single("file")指定上传字段
//显示图片
app.get("/getPic", loader.get("/getPic"));

app.listen(globalConfig["port"]);//监听端口号

//config.js
//解析配置文件的js
//使用express后，这里只需写这些就够了
var fs = require("fs");
var globalConfig = {};
var conf = fs.readFileSync("./server.conf");
var configArr = conf.toString().split("\r\n");
for (var i = 0; i < configArr.length; i++) {
    globalConfig[configArr[i].split("=")[0]] = configArr[i].split("=")[1].trim();//配置文件里的key   与  value
}

module.exports = globalConfig;

//web文件夹下getPic.js下载图片（文件），并发送至浏览器
var url = require("url");
var path = new Map();
var fs = require("fs");

function getPic(request, response) {
    var params = url.parse(request.url, true).query;//取到请求图片的路径

    try {
        var data = fs.readFileSync("./" + params.path);//读取文件
        response.writeHead(200);
        response.write(data);//读取到的文件给浏览器
        response.end();
    } catch (e) {
        response.writeHead(404);
        response.end();
    }

}

path.set("/getPic", getPic);

module.exports.path = path;

//web文件夹下studentController.js ，主要关注下面用户登录的功能
var studentDao = require("../dao/studentDao");
var url = require("url");
var path = new Map();


function getAllStudent(request, response) {
    studentDao.queryAllStudent(function (result) {
        response.writeHead(200,{"Content-Type": "text/html:charset=utf-8"});
        response.write(JSON.stringify(result));
        response.end();
    })
}
path.set("/api/getAllStudent", getAllStudent);

function addStudent(request, response) {
    var params = url.parse(request.url,true).query;
    studentDao.insertStudent(params.name, params.age,params.stu_class,function (result) {
        response.writeHead(200,{"Content-Type": "text/html:charset=utf-8"});
        response.write("添加成功");
        response.end();
    })
}
path.set("/api/addStudent", addStudent);

function login (request, response) {
    var params = url.parse(request.url,true).query;//取到url上的数据
    studentDao.queryStudentByStuNum(params.stuNum, function (result) {
        var flag = result && result.length > 0 && result[0].pwd == params.pwd ;//对比输入密码与数据库密码是否一致
        console.log(flag);
        if (flag) {
            response.cookie("id", result[0].id);
            response.redirect("/api/getAllStudent");//结果一致跳转页面
        }else {
            response.redirect("/loginError.html");//不一致跳转页面
        }
    })
}
path.set("/login", login);

module.exports.path = path;

//web文件夹下upload.js处理上传文件的请求
var fileListDao = require("../dao/fileListDao");

var path = new Map();

function upload(request, response) {
    console.log(request.file.originalname);//原文件名
    console.log(request.file.size);//文件大小
    console.log(request.file.path);//存放的路径（数据流名字）
    console.log(request.cookies.id);//相当于取用户名
    //相当于调用dao里的方法将取到的文件数据写到数据库里
    fileListDao.insertFileList(request.file.originalname, request.file.size, request.file.path, request.cookies.id, function (result) {
        console.log("写库成功");
        response.end(request.file.path);
    })
}

path.set("/upload", upload);

module.exports.path = path;

//page文件夹下的login.html
<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <title>Title</title>
</head>
<body>
<form action="/login" method="get">
    <input type="text" name="stuNum">
    <input type="password" name="pwd">
    <input type="submit" value="登录">
</form>
</body>
</html>

//page文件夹下的main.html, 处理文件上传 下载
<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <title>Title</title>
    <script>
        function submitFile() {
            var file = document.getElementById("file").files[0];
            var form = new FormData();
            form.append("file", file);

            var xhr = new XMLHttpRequest();
            xhr.open("post", "/upload", true);
            xhr.onload = function () {
                alert("上传完成！");

            };

            xhr.send(form);
            xhr.onreadystatechange = function () {
                if(xhr.readyState == 4 && xhr.status == 200) {
                    var path = xhr.responseText;//取到想要图片的路径
                    pic.src = "/getPic?path=" + path;//拼接到src上
                }
            }
        }
    </script>
</head>
<body>
    <input type="file" id="file">
    <input type="button" onclick="submitFile()" value="asd">
    <img src="" id="pic">
    <a href="/getPic?path=file\c8a83bcc1a3037b3f5dfa5aaf51be619" download="2.jpg">点击下载</a>
    <a href="/getPic?path=file\fabcc882e58fe230435f362c5cf70cb9" download="新建 Microsoft Word 文档.docx">新建 Microsoft Word 文档.docx</a>
</body>
</html>

//dao文件夹下的studentDao, 主要关注学号查询
//studentDao.js针对student数据库的操作文件
var dbutil = require("./dbutil");

//上传数据到数据库
function insertStudent(name, age, stu_class, success) {
    var insertSql = "insert into student (name, age, stu_class) values(?,?,?);";//查询student表中所有数据
    var params = [name, age, stu_class];
    var connection = dbutil.createConnection();//创建新的连接
    connection.connect();//连接数据库
    //如果连接成功，执行querySql之后，执行回调函数
    connection.query(insertSql,params,function (err, result) {
        if(err == null) {
            console.log(result);
            success(result);
        }else {
            throw new Error(err);
        }
    });
    connection.end();//查询之后，必须关闭
}


//取到数据库中student表中所有数据
function queryAllStudent(sucess) {
    var querySql = "select * from student;";//查询student表中所有数据
    var connection = dbutil.createConnection();//创建新的连接
    connection.connect();//连接数据库
    //如果连接成功，执行querySql之后，执行回调函数
    connection.query(querySql,function (err, result) {
        if(err == null) {
            console.log(result);
            sucess(result);
        }else {
            throw new Error(err);
        }
    });
    connection.end();//查询之后，必须关闭
}

// queryAllStudent();
//以classNum, age参数查询数据库
function queryStudentByClassAndAge(classNum, age) {
    var querySql = "select * from student where class = ? and age = ?;";
    var queryParams = [classNum, age];
    var connection = dbutil.createConnection();
    connection.connect();
    //第二个参数传多个参数时，要用数组
    connection.query(querySql,queryParams,function (err, result) {
        if(err == null) {
            console.log(result);
        }else {
            throw new Error(err);
        }
    });
    connection.end();
}

function queryStudentByStuNum (stuNum, success) {
    var querySql = "select * from student where stuNum = ?;";
    var connection = dbutil.createConnection();
    connection.connect();
    connection.query(querySql, stuNum, function (error, result) {
        if (error == null) {
            console.log(result);
            success(result);
        }else {
            throw new Error(error);
        }
    });
}



// queryStudentByClassAndAge(1, 18);
//web层调用service层；service层调用dao层；dao层调用数据库。
module.exports = {
    "queryAllStudent": queryAllStudent,
    "queryStudentByClassAndAge": queryStudentByClassAndAge,
    "insertStudent": insertStudent,
    "queryStudentByStuNum": queryStudentByStuNum,
};

//dao文件夹下fileList.js针对上传的文件信息进行数据库的操作文件
var dbutil = require("./dbutil");

//上传数据到数据库
function insertFileList(fileName, fileSize, filePath, stuNum, success) {
    var insertSql = "insert into file_list (fileName, fileSize, filePath, stuNum) values(?,?,?,?);";//查询student表中所有数据
    var params = [fileName, fileSize, filePath, stuNum];
    var connection = dbutil.createConnection();//创建新的连接
    connection.connect();//连接数据库
    //如果连接成功，执行querySql之后，执行回调函数
    connection.query(insertSql, params, function (err, result) {
        if (err == null) {
            console.log(result);
            success(result);
        } else {
            throw new Error(err);
        }
    });
    connection.end();//查询之后，必须关闭
}


module.exports = {
    "insertFileList": insertFileList,
};