server.js 3.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118
  1. let express = require('express');
  2. let config = require("./config/config.js");
  3. let fileUtils = require("./modules/common/fileUtils");
  4. let dbm = require("./config/db/db_manager");
  5. let log = require("./logs/log_helper");
  6. ///config.setToLocalDb();
  7. config.setupDb(process.env.NODE_ENV);
  8. let path = require('path');
  9. let session = require('express-session');
  10. let DBStore = require('connect-mongo')(session);
  11. let fs = require('fs');
  12. let URL = require('url');
  13. import rptCronJob from "./modules/reports/util/rpt_tmp_file_sweep";
  14. dbm.connect(process.env.NODE_ENV);
  15. //这里现在只引入了定额工料机里的models,当其它模块的models修改后使用:./modules/**/models/*.js引入所有的模块
  16. fileUtils.getGlobbedFiles('./modules/all_models/*.js').forEach(function(modelPath) {
  17. require(path.resolve(modelPath));
  18. })
  19. //config.setupCache();
  20. let cfgCacheUtil = require("./config/cacheCfg");
  21. cfgCacheUtil.setupDftCache();
  22. let app = express();
  23. let _rootDir = __dirname;
  24. app.locals.rootDir = _rootDir;
  25. log.use(app);
  26. app.use(express.static(_rootDir));
  27. app.set('views', path.join(__dirname, 'web'));
  28. app.engine('.html', require('ejs').__express);
  29. app.set('view engine', 'html');
  30. let bodyParser = require('body-parser');
  31. app.use(bodyParser.urlencoded({limit: '10mb', extended: false}));
  32. app.use(bodyParser.json({limit: '10mb'}));
  33. app.use(session({
  34. name: 'yanghuSession',
  35. secret: 'session users secret',
  36. // @todo 上线前修改回正常值 (目前为24小时)
  37. cookie: {maxAge: 3600 * 24 * 1000},
  38. resave: false,
  39. rolling: true,
  40. saveUninitialized: true,
  41. //*
  42. store: new DBStore({
  43. url: config.getSessionURL(process.env.NODE_ENV)
  44. })
  45. //*/
  46. }));
  47. // 登录状态全局判断
  48. app.use(function (req, res, next) {
  49. let url = req.originalUrl;
  50. // if (/^\/login/.test(url) || /\.map|\.ico$/.test(url) || /^\/sms/.test(url) || /^\/cld/.test(url) || /^\/captcha/.test(url) || /^\/accountIsPro/.test(url)) {
  51. if (/^\/login/.test(url) || /\.map|\.ico$/.test(url) || /^\/sms/.test(url) || /^\/cld/.test(url) || /^\/captcha/.test(url)) {
  52. // 如果是登录页面或短信接口或cld接口则忽略判断数据
  53. next();
  54. } else {
  55. try {
  56. // 判断session
  57. let sessionUser = req.session.sessionUser;
  58. if (!sessionUser) {
  59. //处理 ajax 请求 session 过期问题
  60. if (req.headers["x-requested-with"] != null
  61. && req.headers["x-requested-with"] == "XMLHttpRequest"
  62. && req.url != "/login") {
  63. return res.json({ret_code: 99, ret_msg: '登录信息失效,请您重新登录'});
  64. }else {
  65. throw 'session error';
  66. }
  67. }
  68. res.locals.sessionUser = sessionUser;
  69. } catch (error) {
  70. // 最后一个页面存入session
  71. req.session.lastPage = url;
  72. return res.redirect('/login');
  73. }
  74. next();
  75. }
  76. });
  77. //加载路由文件
  78. fileUtils.getGlobbedFiles('./modules/**/routes/*.js').forEach(function(modelPath) {
  79. require(path.resolve(modelPath))(app);
  80. });
  81. //app.use(express.static(_rootDir+"/web"));
  82. //app.use(express.static(_rootDir+"/lib"));
  83. //let rations_Router = require("./modules/rationLibEditor/routes/rationLibEditor_route");
  84. //app.use("/rationLibEditor",rations_Router);
  85. //-----------------
  86. app.use(function(req, res, next) {
  87. res.status(404).send('404 Error');
  88. });
  89. app.use(function(err, req, res, next) {
  90. console.error(err.stack);
  91. res.status(500).send('500 Error');
  92. });
  93. //设置外增的Date对象Format函数
  94. //备注: 经过测试nodejs 8.9.3版本不支持eval的方式修改prototype,为兼容考虑,把方法调整到stringUtil文件里
  95. require('./public/stringUtil').setupDateFormat();
  96. app.listen(2060, function(){
  97. console.log('server started!');
  98. });
  99. //设置schedule job
  100. //1. 报表临时文件
  101. rptCronJob.createJob(null, __dirname + "/tmp");
  102. //2. 其他(待补充)...