operation.js 4.0 KB

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