ssti-CollegeManage-api/ssti.js

// ROUTES FOR OUR API
// =============================================================================
var express = require('express');
var bcrypt = require('bcryptjs');
var router = express.Router(); // get an instance of the express Router
const querystring = require('querystring');
var mysql = require('./mysql');
const _mysqlLabor = ["10.3.16.226", "ssti_cm"]; //本地双创數據庫信息
// const _mysqlLabor = ["172.16.12.5", "pbl"]; //双创數據庫信息
var crypto = require('crypto');
var https = require('https');

//統壹處理區域
router.use(async function(req, res, next) {
    await asynnext(req, res, next);
    //// make sure we go to the next routes and don't stop here
    //res.end("");
});

/**
 * @des 參數解釋同上
 */
function asynnext(req, res, next) {
    //異步處理
    return new Promise(async(resolve, reject) => {
        next();
        //resolve(true);aa
    });
}
/*測試*/
router.route('/a').all((req, res, next) => {
    var json = GetData(req);
    getmysql(req, res, "a");
});

//qgt 查看数据库是否有此人
// router.use((req,res,next)=>{
//     const uid = GetData(req)['uid'];
//     let p = [_mysqlLabor[0], _mysqlLabor[1], 'select_UserByUserId',uid];
//     mysql.usselect(p,function(result){
//         if(result[0].length==1){
//             next();
//         }else{
//             res.Back(1,"用户不存在",GetData(req))
//         }
//     })
// })

//qgt 新增全站通知
router.post("/CreateNewNotification",(req,res)=>{
    QMysql(req,res,"insert_New")
})

//qgt 获取全站通知
router.get('/SelectNotification',(req,res)=>{
    QMysql(req,res,'select_NewByTitle')
})

//qgt 删除通知
router.post("/DeleteNotification",(req,res)=>{
    QMysql(req,res,"update_NewStatusById");
})

//qgt 获取消息通知详细
router.get("/SelectNotificationDetail",(req,res)=>{
    QMysql(req,res,"select_NewById");
})





GetData = function(req) {
    var a = req.url.split("?");
    var json = querystring.parse(a[1])
    if(Object.keys(json).length!=0){
        return json
    }else if(req.body){
        return req.body
    }else if(req.body.mode){
        return req.body.mode;
    }
}

//存储过程处理
QMysql = function(req,res,functionName){
    if (GetData(req)) {
        p = Object.values(GetData(req));
        p.unshift(_mysqlLabor[0], _mysqlLabor[1], functionName);
        //執行存儲過程
        mysql.usselect(p, function(ret) { res.end(JSON.stringify(ret)); });
    }else{
        res.end("未获取参数")
    }
}

//post存儲過程處理
// PostMysql = function(req, res, functionName) {
//     //mode的處理
//     if (GetData(req)) {
//         p = Object.values(GetData(req));
//         p.unshift(_mysqlLabor[0], _mysqlLabor[1], functionName);
//         //執行存儲過程
//         mysql.usselect(p, function(ret) { res.end(JSON.stringify(ret)); });
//     }else{
//         res.end("未获取参数")
//     }
// }

// GetMysql = function(req,res,functionName){
//     if(GetData(req)){
//         p = Object.values(GetData(req));
//         p.unshift(_mysqlLabor[0], _mysqlLabor[1], functionName);
//         mysql.usselect(p, function(ret) { res.end(JSON.stringify(ret)); });

//     }else{
//         res.end("未获取参数")
//     }
// }


//post存儲過程處理
// postmysql = function(req, res, functionname) {
//     //mode的處理
//     if (req.body[0]) {
//         p = Object.values(req.body[0]);
//         p.unshift(_mysqlLabor[0], _mysqlLabor[1], functionname);
//         //執行存儲過程
//         mysql.usselect(p, function(ret) { res.end(JSON.stringify(ret)); });
//     }
// }

//post存儲過程處理
postmysql2 = function(req, res, functionname) {
    //mode的處理
    if (req.body) {
        p = Object.values(req.body)[0].split(",");
        p.unshift(_mysqlLabor[0], _mysqlLabor[1], functionname);
        //執行存儲過程
        mysql.usselect(p, function(ret) { res.end(JSON.stringify(ret)); });
    }
}

// router.route('/selectStudentCourseDetail').all((req, res, next) => { //学生
//     var json = queryString(req.url);
//      getmysql(req, res, "selectStudentCourseDetail", json['courseId']);
//     });
//     router.route('/addWorks').all((req, res, next) => {
//      postmysql(req, res, "add_works");
//     });

//post存儲過程處理
postmysql3 = function(req, res, functionname) {
    //mode的處理
    if (req.body) {
        p = Object.values(req.body);
        p.unshift(_mysqlLabor[0], _mysqlLabor[1], functionname);
        //執行存儲過程
        mysql.usselect(p, function(ret) { res.end(JSON.stringify(ret)); });
    }
}

//get獲取數據庫信息
getmysql = function(req, res, functionname, ...p) {
    p = p || [];
    p.unshift(_mysqlLabor[0], _mysqlLabor[1], functionname);
    //執行存儲過程
    mysql.usselect(p, function(ret) { res.end(JSON.stringify(ret)); }); //
}


//post存储过程处理

userpostmysql = function(req, res, functionname) {

    //mode的处理

    if (req.body.mode) {

        p = req.body.mode.split(",");

        p.unshift(_mysqlLabor[0], _mysqlLabor[1], functionname);

        //执行存储过程

        mysql.usselect(p, function(ret) { res.end(JSON.stringify(ret)); });

    }

}



//get获取数据库信息

usergetmysql = function(req, res, functionname, ...p) {

    p = p || [];

    p.unshift(_mysqlLabor[0], _mysqlLabor[1], functionname);

    //执行存储过程

    mysql.usselect(p, function(ret) { res.end(JSON.stringify(ret)); }); //
}


// //获取请求数据
// function GetData(req){
//     if(req.body['uid']==null){
//         return req.query
//     }else{
//         return req.body
//     }

    
//     // return req.query | req.body;

//     // if(req.method =='POST'){
//         // return req.body;
//     // }else if(req.method =="GET"){
//         // return req.query;
//     // }
// }   


//获取当前时间
// function getNowDate() {
//     let date = new Date();
//     let year = date.getFullYear(); //年
//     let month = date.getMonth() + 1; //月
//     let day = date.getDate(); //日
//     let hour = date.getHours(); //时
//     let minutes = date.getMinutes(); //分
//     let seconds = date.getSeconds(); //秒
//     if (month > 1 && month <= 9) month = "0" + month;
//     if (day > 0 && day <= 9) day = "0" + day;
//     if (hour > 0 && hour < 9) hour = "0" + hour;
//     if (minutes > 0 && minutes <= 9) minutes = "0" + minutes;
//     if (seconds > 0 && seconds < 9) seconds = "0" + seconds;
//     return `${year}-${month}-${day} ${hour}:${minutes}:${seconds}`;
// }

module.exports = router;