pbl.js 3.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131
  1. // ROUTES FOR OUR API
  2. // =============================================================================
  3. var express = require("express");
  4. var request = require("request");
  5. var bcrypt = require("bcryptjs");
  6. var router = express.Router(); // get an instance of the express Router
  7. const querystring = require("querystring");
  8. var mysql = require("./mysql");
  9. // const _mysqlLabor = ["123.58.32.151", "sc_app"]; //edu數據庫信息
  10. // const _mysqluser = ["123.58.32.151", "cocorobouser"]; //用户数据库信息
  11. const _mysqlLabor = ["172.16.12.5", "sc_app"]; //edu數據庫信息
  12. const _mysqluser = ["172.16.12.5", "cocorobouser"]; //edu數據庫信息
  13. var crypto = require("crypto");
  14. var https = require("https");
  15. //統壹處理區域
  16. router.use(async function(req, res, next) {
  17. await asynnext(req, res, next);
  18. //// make sure we go to the next routes and don't stop here
  19. //res.end("");
  20. });
  21. /**
  22. * @des 參數解釋同上
  23. */
  24. function asynnext(req, res, next) {
  25. //異步處理
  26. return new Promise(async(resolve, reject) => {
  27. next();
  28. //resolve(true);aa
  29. });
  30. }
  31. /*測試*/
  32. router.route("/a").all((req, res, next) => {
  33. var json = queryString(req.url);
  34. getmysql(req, res, "a", json["ph"], json["pa"]);
  35. });
  36. router.route("/b").all((req, res, next) => {
  37. var json = queryString(req.url);
  38. getmysql(req, res, "b", json["ph"], json["pa"]);
  39. });
  40. queryString = function(url) {
  41. var a = url.split("?");
  42. var json = querystring.parse(a[1]);
  43. return json;
  44. };
  45. //post存儲過程處理
  46. postmysql = function(req, res, functionname) {
  47. //mode的處理
  48. if (req.body[0]) {
  49. p = Object.values(req.body[0]);
  50. p.unshift(_mysqlLabor[0], _mysqlLabor[1], functionname);
  51. //執行存儲過程
  52. mysql.usselect(p, function(ret) {
  53. res.end(JSON.stringify(ret));
  54. });
  55. }
  56. };
  57. //post存儲過程處理
  58. postmysql2 = function(req, res, functionname) {
  59. //mode的處理
  60. if (req.body) {
  61. p = Object.values(req.body)[0].split(",");
  62. p.unshift(_mysqlLabor[0], _mysqlLabor[1], functionname);
  63. //執行存儲過程
  64. mysql.usselect(p, function(ret) {
  65. res.end(JSON.stringify(ret));
  66. });
  67. }
  68. };
  69. //post存儲過程處理
  70. postmysql3 = function(req, res, functionname) {
  71. //mode的處理
  72. if (req.body) {
  73. p = Object.values(req.body);
  74. p.unshift(_mysqlLabor[0], _mysqlLabor[1], functionname);
  75. //執行存儲過程
  76. mysql.usselect(p, function(ret) {
  77. res.end(JSON.stringify(ret));
  78. });
  79. }
  80. };
  81. //get獲取數據庫信息
  82. getmysql = function(req, res, functionname, ...p) {
  83. p = p || [];
  84. p.unshift(_mysqlLabor[0], _mysqlLabor[1], functionname);
  85. //執行存儲過程
  86. mysql.usselect(p, function(ret) {
  87. res.end(JSON.stringify(ret));
  88. }); //
  89. };
  90. //post存储过程处理
  91. userpostmysql = function(req, res, functionname) {
  92. //mode的处理
  93. if (req.body.mode) {
  94. p = req.body.mode.split(",");
  95. p.unshift(_mysqluser[0], _mysqluser[1], functionname);
  96. //执行存储过程
  97. mysql.usselect(p, function(ret) {
  98. res.end(JSON.stringify(ret));
  99. });
  100. }
  101. };
  102. //get获取数据库信息
  103. usergetmysql = function(req, res, functionname, ...p) {
  104. p = p || [];
  105. p.unshift(_mysqluser[0], _mysqluser[1], functionname);
  106. //执行存储过程
  107. mysql.usselect(p, function(ret) {
  108. res.end(JSON.stringify(ret));
  109. }); //
  110. };
  111. module.exports = router;