EvenManage-YT-API/pbl.js

// ROUTES FOR OUR API
// =============================================================================
var express = require("express");
var request = require("request");
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 = ["123.58.32.151", "pbl"]; //edu數據庫信息
// const _mysqluser = ["123.58.32.151", "cocorobouser"]; //用户数据库信息
const _mysqlLabor = ["172.16.12.5", "evenYT"]; //edu數據庫信息
const _mysqluser = ["172.16.12.5", "cocorobouser"]; //edu數據庫信息
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 = queryString(req.url);
    getmysql(req, res, "a", json["ph"], json["pa"]);
});
router.route("/b").all((req, res, next) => {
    var json = queryString(req.url);
    getmysql(req, res, "b", json["ph"], json["pa"]);
});
/* 根据市级用户查询评审员 */
router.route("/selectReviewer").all((req, res, next) => {
    var json = queryString(req.url);
    getmysql(
        req,
        res,
        "selectReviewer",
        json["uid"],
        json["cn"],
        json["page"],
        10
    );
});
/* 市级区县管理接口 */
router.route("/selectCReviewer").all((req, res, next) => {
    var json = queryString(req.url);
    getmysql(
        req,
        res,
        "selectCReviewer",
        json["uid"],
        json["cn"],
        json["page"],
        10
    );
});
/* 修改评审员 */
router.route("/updateReviewer").all((req, res, next) => {
    var json = queryString(req.url);
    getmysql(
        req,
        res,
        "updateReviewer",
        json["n"],
        json["p"],
        json["t"],
        json["s"],
        json["uid"]
    );
});
/* 删除评审员 */
router.route("/deleteReviewer").all((req, res, next) => {
    var json = queryString(req.url);
    getmysql(req, res, "deleteReviewer", json["uid"]);
});
/* 查询区县案例 */
router.route("/selecAnliBox").all((req, res, next) => {
    var json = queryString(req.url);
    getmysql(req, res, "selecAnliBox", json["title"]);
});
/* 查询市级案例 */
router.route("/selecAnliBox1").all((req, res, next) => {
    var json = queryString(req.url);
    getmysql(req, res, "selecAnliBox1", json["title"]);
});
/* 查询省级案例 */
router.route("/selecAnliBox2").all((req, res, next) => {
    var json = queryString(req.url);
    getmysql(req, res, "selecAnliBox2");
});
/* 案例征集查询通知公告 */
router.route("/selectRaceNotice").all((req, res, next) => {
    var json = queryString(req.url);
    getmysql(req, res, "selectRaceNotice", json["page"], 10);
});
/* 案例征集查询通知公告详情 */
router.route("/getRaceNoticeDetail").all((req, res, next) => {
    var json = queryString(req.url);
    getmysql(req, res, "getRaceNoticeDetail", json["nid"]);
});
/* 案例征集发送通知 */
router.route("/insertRaceNote").all((req, res, next) => {
    var json = queryString(req.url);
    getmysql(req, res, "insertRaceNote", json["t"], json["c"], json["uid"]);
});
//新增赛事项目
router.route("/addRace").all((req, res, next) => {
    if (req.body[0]) {
        p = [
            req.body[0].uid,
            req.body[0].info,
            req.body[0].over,
            req.body[0].pro,
            req.body[0].act,
            req.body[0].exc,
            req.body[0].res,
        ];
        p.unshift(_mysqlLabor[0], _mysqlLabor[1], "addRace"); //執行存儲過程
        mysql.usselect(p, function(ret) {
            let course = req.body[0].courseType;
            let courseId = ret[0][0].id;
            let userid = req.body[0].uid;
            delCourseType1(course, courseId, userid);
            res.end(JSON.stringify({ courseId: courseId, success: 1 }));
        });
    }
});
//新增赛事账号信息
router.route("/addRaceUser").all((req, res, next) => {
    if (req.body[0]) {
        p = [
            req.body[0].reg,
            req.body[0].res,
            req.body[0].sch,
            req.body[0].n,
            req.body[0].p,
            req.body[0].t,
            req.body[0].parent,
        ];
        p.unshift(_mysqlLabor[0], _mysqlLabor[1], "addRaceUser"); //執行存儲過程
        mysql.usselect(p, function(ret) {
            let num = ret[0][0].num;
            let userid = ret[0][0].userid;
            if (num < 10) {
                num = "SZ" + "00" + num + "@gdae.com";
            } else if (num < 100) {
                num = "SZ" + "0" + num + "@gdae.com";
            } else if (num > 100) {
                num = "SZ" + num + "@gdae.com";
            }
            y = [userid, num, bcrypt.hashSync("123456", bcrypt.genSaltSync(10))];
            //参数拼接，注册
            y.unshift(_mysqlLabor[0], _mysqlLabor[1], "upRaceUserNamePassword");
            mysql.usselect(y, function(ret) {
                res.end(JSON.stringify(ret));
            });
            res.end(JSON.stringify({ num: num, success: 1 }));
        });
    }
});

//修改赛事项目
router.route("/updateRace").all((req, res, next) => {
    if (req.body[0]) {
        p = [
            req.body[0].id,
            req.body[0].info,
            req.body[0].over,
            req.body[0].pro,
            req.body[0].act,
            req.body[0].exc,
            req.body[0].res,
        ];
        p.unshift(_mysqlLabor[0], _mysqlLabor[1], "updateRace"); //執行存儲過程
        mysql.usselect(p, function(ret) {
            let course = req.body[0].courseType;
            let courseId = req.body[0].id;
            let userid = req.body[0].uid;
            delCourseType1(course, courseId, userid);
            res.end(JSON.stringify({ success: 1 }));
        });
    }
});
//查询赛事项目列表
router.route("/selectRaceList").all((req, res, next) => {
    var json = queryString(req.url);
    getmysql(req, res, "selectRaceList", json["uid"], json["t"]);
});
//修改赛事状态
router.route("/updateRaceState").all((req, res, next) => {
    var json = queryString(req.url);
    getmysql(req, res, "updateRaceState", json["id"], json["s"]);
});
//查询赛事项目详情
router.route("/selectRaceDetail").all((req, res, next) => {
    var json = queryString(req.url);
    getmysql(req, res, "selectRaceDetail", json["id"]);
});
//race 查询学校
router.route("/getSchool").all((req, res, next) => {
    var json = queryString(req.url);
    getmysql(req, res, "getSchool", json["n"]);
});
//根据区级管理者查询案例
router.route("/selectAnliList").all((req, res, next) => {
    var json = queryString(req.url);
    getmysql(
        req,
        res,
        "selectAnliList",
        json["typea"],
        json["typeb"],
        json["typec"],
        json["typed"],
        json["typeE"],
        json["cn"],
        json["cid"],
        json["title"],
        json["page"],
        10
    );
});
//根据市级管理者查询案例
router.route("/selectAnliList1").all((req, res, next) => {
    var json = queryString(req.url);
    getmysql(
        req,
        res,
        "selectAnliList1",
        json["typea"],
        json["typeb"],
        json["typec"],
        json["typed"],
        json["typeE"],
        json["cn"],
        json["cid"],
        json["title"],
        json["page"],
        10
    );
});
//根据省级级管理者查询案例
router.route("/selectAnliList2").all((req, res, next) => {
    var json = queryString(req.url);
    getmysql(
        req,
        res,
        "selectAnliList2",
        json["typea"],
        json["typeb"],
        json["typec"],
        json["typed"],
        json["typeE"],
        json["cn"],
        json["cid"],
        json["title"],
        json["page"],
        10
    );
});
//删除案例
router.route("/deleteAnli").all((req, res, next) => {
    var json = queryString(req.url);
    getmysql(req, res, "deleteAnli", json["id"]);
});
//根据区县管理者查询评分
router.route("/selectPoint").all((req, res, next) => {
    var json = queryString(req.url);
    getmysql(
        req,
        res,
        "selectPoint",
        json["typea"],
        json["typeb"],
        json["typec"],
        json["typed"],
        json["typeE"],
        json["cn"],
        json["cid"],
        json["title"],
        json["page"],
        10
    );
});
//根据市级管理者查询评分
router.route("/selectPoint1").all((req, res, next) => {
    var json = queryString(req.url);
    getmysql(
        req,
        res,
        "selectPoint1",
        json["typea"],
        json["typeb"],
        json["typec"],
        json["typed"],
        json["typeE"],
        json["cn"],
        json["cid"],
        json["title"],
        json["page"],
        10
    );
});
//根据市级管理者查询全部评分
router.route("/selectPointAll").all((req, res, next) => {
    var json = queryString(req.url);
    getmysql(
        req,
        res,
        "selectPointAll",
        json["typea"],
        json["typeb"],
        json["typec"],
        json["typed"],
        json["typeE"],
        json["cn"],
        json["cid"],
        json["title"]
    );
});
//查询分配案例
router.route("/selectCaseUser").all((req, res, next) => {
    var json = queryString(req.url);
    getmysql(req, res, "select_case", json["uid"]);
});

//分配案例
router.route("/insertCase").all((req, res, next) => {
    if (req.body[0]) {
        p = [req.body[0].uid, req.body[0].box];
        p.unshift(_mysqlLabor[0], _mysqlLabor[1], "insertCase"); //執行存儲過程
        mysql.usselect(p, function(ret) {
            res.end(JSON.stringify({ success: 1 }));
        });
    }
});
//新增评分
router.route("/addScore").all((req, res, next) => {
    postmysql(req, res, "addScore");
});

//查询评分
router.route("/selectScore").all((req, res, next) => {
    var json = queryString(req.url);
    getmysql(req, res, "selectScore", json["rid"], json["suser"]);
});
//查询所有评分
router.route("/selectAllScore").all((req, res, next) => {
    var json = queryString(req.url);
    getmysql(req, res, "selectAllScore");
});
//根据用户id查询评分
router.route("/selectScoreByUid").all((req, res, next) => {
    var json = queryString(req.url);
    getmysql(req, res, "selectScoreByUid", json["uid"]);
});
//查询单个案例所有评分
router.route("/selectAnliScore").all((req, res, next) => {
    var json = queryString(req.url);
    getmysql(req, res, "selectAnliScore", json["rid"]);
});
//赛事推荐
router.route("/updateRaceRec").all((req, res, next) => {
    var json = queryString(req.url);
    getmysql(req, res, "updateRaceRec", json["id"], json["rec"]);
});

//案例新项目登录接口
router.route("/loginNewEvenManage").all((req, res, next) => {
    postmysql(req, res, "loginNewEvenManage");
});
//案例新项目创建用户接口
router.route("/addNewRaceUser").all((req, res, next) => {
    postmysql(req, res, "addNewRaceUser");
});
//查询老师的信息
router.route("/getRaceUser1").all((req, res, next) => {
    var json = queryString(req.url);
    getmysql(req, res, "getRaceUser1", json["uid"]);
});
//修改用户信息
router.route("/updateRaceUser1").all((req, res, next) => {
    postmysql(req, res, "updateRaceUser1");
});
/* 修改评审员 */
router.route("/updateReviewer").all((req, res, next) => {
    var json = queryString(req.url);
    getmysql(
        req,
        res,
        "updateReviewer",
        json["n"],
        json["p"],
        json["t"],
        json["s"],
        json["uid"]
    );
});
//race 查询学校
router.route("/getSchool1").all((req, res, next) => {
    var json = queryString(req.url);
    getmysql(req, res, "getSchool1", json["n"]);
});
//查询赛事项目列表
router.route("/selectRaceList1").all((req, res, next) => {
    var json = queryString(req.url);
    getmysql(req, res, "selectRaceList1", json["uid"], json["t"], json["oid"], json["org"]);
});

//修改赛事状态
router.route("/updateRaceStateGM").all((req, res, next) => {
    var json = queryString(req.url);
    getmysql(req, res, "updateRaceStateGM", json["id"], json["s"]);
});

//删除案例
router.route("/deleteAnliGM").all((req, res, next) => {
    var json = queryString(req.url);
    getmysql(req, res, "deleteAnliGM", json["id"]);
});

//新增赛事项目
router.route("/addRaceGM").all((req, res, next) => {
    if (req.body[0]) {
        p = [
            req.body[0].uid,
            req.body[0].info,
            req.body[0].over,
            req.body[0].pro,
            req.body[0].act,
            req.body[0].exc,
            req.body[0].res,
        ];
        p.unshift(_mysqlLabor[0], _mysqlLabor[1], "addRaceGM"); //執行存儲過程
        mysql.usselect(p, function(ret) {
            let course = req.body[0].courseType;
            let courseId = ret[0][0].id;
            let userid = req.body[0].uid;
            delCourseType1(course, courseId, userid);
            res.end(JSON.stringify({ courseId: courseId, success: 1 }));
        });
    }
});

//修改赛事项目
router.route("/updateRaceGM").all((req, res, next) => {
    if (req.body[0]) {
        p = [
            req.body[0].id,
            req.body[0].info,
            req.body[0].over,
            req.body[0].pro,
            req.body[0].act,
            req.body[0].exc,
            req.body[0].res,
        ];
        p.unshift(_mysqlLabor[0], _mysqlLabor[1], "updateRaceGM"); //執行存儲過程
        mysql.usselect(p, function(ret) {
            let course = req.body[0].courseType;
            let courseId = req.body[0].id;
            let userid = req.body[0].uid;
            delCourseType1(course, courseId, userid);
            res.end(JSON.stringify({ success: 1 }));
        });
    }
});

//查询赛事项目详情
router.route("/selectRaceDetailGM").all((req, res, next) => {
    var json = queryString(req.url);
    getmysql(req, res, "selectRaceDetailGM", json["id"]);
});

//查询赛事分类及子分类
router.route("/selectMatTypeGM").all((req, res, next) => {
    var json = queryString(req.url);
    getmysql(req, res, "selectMatTypeGM");
});

queryString = function(url) {
    var a = url.split("?");
    var json = querystring.parse(a[1]);
    return json;
};

//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));
        });
    }
};

//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(_mysqluser[0], _mysqluser[1], functionname);

        //执行存储过程

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

//get获取数据库信息

usergetmysql = function(req, res, functionname, ...p) {
    p = p || [];

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

    //执行存储过程

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

module.exports = router;