operation.js 3.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114
  1. let express = require('express');
  2. import schedule from 'node-schedule';
  3. let config = require("./config/config.js");
  4. config.setupDb(process.env.NODE_ENV);
  5. let dbm = require("./config/db/db_manager");
  6. let path = require('path');
  7. let session = require('express-session');
  8. let DBStore = require('connect-mongo')(session);
  9. let fileUtils = require("./modules/common/fileUtils");
  10. let partials = require("express-partials");
  11. let log = require("./logs/log_helper");
  12. let URL = require('url');
  13. let fs = require('fs');
  14. let app = express();
  15. let _rootDir = __dirname;
  16. app.locals.rootDir = _rootDir;
  17. dbm.connect(process.env.NODE_ENV);
  18. //引入报表模块
  19. fileUtils.getGlobbedFiles('./modules/all_models/*.js').forEach(function(modelPath) {
  20. require(path.resolve(modelPath));
  21. });
  22. //config.setupCache();
  23. let cfgCacheUtil = require("./config/cacheCfg");
  24. cfgCacheUtil.setupDftCache();
  25. log.use(app);
  26. app.use(express.static(_rootDir));
  27. app.disable('view cache');
  28. app.set('views', path.join(__dirname, 'web'));
  29. app.engine('.html', require('ejs').__express);
  30. app.set('view engine', 'html');
  31. app.set('view options', {
  32. // defaultLayout: 'users/views/layout/layout'
  33. defaultLayout: false
  34. });
  35. app.use(partials());
  36. let bodyParser = require('body-parser');
  37. app.use(bodyParser.urlencoded({limit: '3mb', extended: true}));
  38. app.use(bodyParser.json({limit: '3mb'}));
  39. app.use(session({
  40. name: 'yanghuSession',
  41. secret: 'session users secret',
  42. cookie: {maxAge: 3600 * 6 * 1000},
  43. resave: false,
  44. rolling: true,
  45. saveUninitialized: true
  46. //*
  47. ,store: new DBStore({
  48. url: config.getSessionURL(process.env.NODE_ENV)
  49. })
  50. //*/
  51. }));
  52. app.use(function (req, res, next) {
  53. let referer = '';
  54. if (!/^\/login/.test(req.originalUrl) && !req.session.managerData) {
  55. if (req.headers["x-requested-with"] != null
  56. && req.headers["x-requested-with"] == "XMLHttpRequest"
  57. && req.url != "/login") {
  58. return res.json({ret_code: 99, ret_msg: '登录信息失效,请您重新登录'});
  59. } else{
  60. return res.redirect('/login');
  61. }
  62. }
  63. next();
  64. });
  65. //加载路由文件
  66. fileUtils.getGlobbedFiles('./modules/**/routes/*.js').forEach(function(modelPath) {
  67. require(path.resolve(modelPath))(app);
  68. });
  69. app.use(function(req, res, next) {
  70. res.status(404).send('404 Error');
  71. });
  72. app.use(function(err, req, res, next) {
  73. console.error(err.stack);
  74. res.status(500).send('500 Error');
  75. });
  76. //设置Date Format函数
  77. //备注: 经过测试nodejs 8.9.3版本不支持eval的方式修改prototype,为兼容考虑,把方法调整到stringUtil文件里
  78. require('./public/stringUtil').setupDateFormat();
  79. //定时任务
  80. let sysSchedule = require('./modules/sys_tools/models/sys_model');
  81. schedule.scheduleJob({hour: 3, minute: 30, dayOfWeek: 7}, function(){
  82. sysSchedule.clearJunkData(function (err) {
  83. if(err){
  84. console.log('清除失败');
  85. }
  86. else{
  87. console.log('清除成功');
  88. }
  89. })
  90. });
  91. app.listen(2080, function(){
  92. console.log("server started!");
  93. });