ssti.js 3.1 KB

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