operation.js 4.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146
  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: '10mb', extended: true }));
  39. app.use(bodyParser.json({ limit: '10mb' }));
  40. app.use(session({
  41. name: 'usersSession',
  42. secret: 'session users secret',
  43. cookie: { maxAge: 3600 * 6 * 1000 },
  44. resave: false,
  45. rolling: true,
  46. saveUninitialized: true
  47. //*
  48. , store: new DBStore({
  49. url: config.getSessionURL(process.env.NODE_ENV)
  50. })
  51. //*/
  52. }));
  53. app.use(function (req, res, next) {
  54. let referer = '';
  55. if (/\.map|\.ico$/.test(req.originalUrl) || /^\/cld\/(?!getCategoryStaff)/.test(req.originalUrl)) {
  56. next();
  57. } else {
  58. if (!/^\/login/.test(req.originalUrl) && !req.session.managerData) {
  59. if (req.headers["x-requested-with"] != null
  60. && req.headers["x-requested-with"] == "XMLHttpRequest"
  61. && req.url != "/login") {
  62. return res.json({ ret_code: 99, ret_msg: '登录信息失效,请您重新登录' });
  63. } else {
  64. return res.redirect('/login');
  65. }
  66. }
  67. next();
  68. }
  69. });
  70. //加载路由文件
  71. fileUtils.getGlobbedFiles('./modules/**/routes/*.js').forEach(function (modelPath) {
  72. console.log(modelPath);
  73. require(path.resolve(modelPath))(app);
  74. });
  75. app.use(function (req, res, next) {
  76. res.status(404).send('404 Error');
  77. });
  78. app.use(function (err, req, res, next) {
  79. console.error(err.stack);
  80. res.status(500).send('500 Error');
  81. });
  82. //设置Date Format函数
  83. //备注: 经过测试nodejs 8.9.3版本不支持eval的方式修改prototype,为兼容考虑,把方法调整到stringUtil文件里
  84. require('./public/stringUtil').setupDateFormat();
  85. //定时任务
  86. let sysSchedule = require('./modules/sys_tools/models/sys_model');
  87. schedule.scheduleJob({ hour: 3, minute: 30, dayOfWeek: 7 }, function () {
  88. sysSchedule.clearJunkData(function (err) {
  89. if (err) {
  90. console.log('清除失败');
  91. }
  92. else {
  93. console.log('清除成功');
  94. }
  95. })
  96. });
  97. schedule.scheduleJob({ hour: 0, minute: 1 }, function () {
  98. sysSchedule.checkUserCompilationStatus(function (err) {
  99. if (err) {
  100. console.log('更新失败');
  101. }
  102. else {
  103. console.log('更新成功');
  104. }
  105. })
  106. });
  107. // schedule.scheduleJob({hour: 10, minute: 0}, function(){
  108. // sysSchedule.sendCompilationStatusSms(function (err) {
  109. // if(err){
  110. // console.log('短信发送失败');
  111. // }
  112. // else{
  113. // console.log('短信发送成功');
  114. // }
  115. // })
  116. // });
  117. let startPort = 6080;
  118. if (config[process.env.NODE_ENV].startPort) startPort = config[process.env.NODE_ENV].startPort;
  119. console.log(startPort);
  120. app.listen(startPort, function () {
  121. console.log("server started!");
  122. });