YangHuOperation/operation.js

let express = require('express');
// import schedule from 'node-schedule';
let schedule = require("node-schedule");
let config = require("./config/config.js");
config.setupDb(process.env.NODE_ENV);
let dbm = require("./config/db/db_manager");

let path = require('path');
let session = require('express-session');
let DBStore = require('connect-mongo')(session);
let fileUtils = require("./modules/common/fileUtils");
let partials = require("express-partials");
let log = require("./logs/log_helper");

let URL = require('url');
let fs = require('fs');

let app = express();
let _rootDir = __dirname;
app.locals.rootDir = _rootDir;

dbm.connect(process.env.NODE_ENV);

//引入报表模块
fileUtils.getGlobbedFiles('./modules/all_models/*.js').forEach(function(modelPath) {
    require(path.resolve(modelPath));
});


//config.setupCache();
let cfgCacheUtil = require("./config/cacheCfg");
cfgCacheUtil.setupDftCache();

log.use(app);
app.use(express.static(_rootDir));

app.disable('view cache');

app.set('views', path.join(__dirname, 'web'));
app.engine('.html', require('ejs').__express);
app.set('view engine', 'html');
app.set('view options', {
    // defaultLayout: 'users/views/layout/layout'
    defaultLayout: false
});
app.use(partials());

let bodyParser = require('body-parser');
app.use(bodyParser.urlencoded({limit: '3mb', extended: true}));
app.use(bodyParser.json({limit: '3mb'}));

let dbname = 'yanghu';
if(config[process.env.NODE_ENV].dbname) dbname = config[process.env.NODE_ENV].dbname;

app.use(session({
    name: dbname+'Session',
    secret: 'session users secret',
    cookie: {maxAge: 3600 * 6 * 1000},
    resave: false,
    rolling: true,
    saveUninitialized: true
    //*
    ,store: new DBStore({
        url: config.getSessionURL(process.env.NODE_ENV)
    })
    //*/
}));


app.use(function (req, res, next) {
    let referer = '';
    if(/\.map|\.ico$/.test(req.originalUrl) || /^\/cld\/(?!getCategoryStaff)/.test(req.originalUrl)) {
        next();
    } else {
        if (!/^\/login/.test(req.originalUrl) && !req.session.managerData) {
            if (req.headers["x-requested-with"] != null
                && req.headers["x-requested-with"] == "XMLHttpRequest"
                && req.url != "/login") {
                return res.json({ret_code: 99, ret_msg: '登录信息失效，请您重新登录'});
            } else {
                return res.redirect('/login');
            }
        }
        next();
    }
});

//加载路由文件
fileUtils.getGlobbedFiles('./modules/**/routes/*.js').forEach(function(modelPath) {
    require(path.resolve(modelPath))(app);
});

app.use(function(req, res, next) {
    res.status(404).send('404 Error');
});
app.use(function(err, req, res, next) {
    console.error(err.stack);
    res.status(500).send('500 Error');
});

//设置Date Format函数
//备注： 经过测试nodejs 8.9.3版本不支持eval的方式修改prototype，为兼容考虑，把方法调整到stringUtil文件里
require('./public/stringUtil').setupDateFormat();

//定时任务
let sysSchedule = require('./modules/sys_tools/models/sys_model');
schedule.scheduleJob({hour: 3, minute: 30, dayOfWeek: 7}, function(){
    sysSchedule.clearJunkData(function (err) {
        if(err){
            console.log('清除失败');
        }
        else{
            console.log('清除成功');
        }
    })
});

schedule.scheduleJob({hour: 0, minute: 1}, function(){
    sysSchedule.checkUserCompilationStatus(function (err) {
        if(err){
            console.log('更新失败');
        }
        else{
            console.log('更新成功');
        }
    })
});

// schedule.scheduleJob({hour: 10, minute: 0}, function(){
//     sysSchedule.sendCompilationStatusSms(function (err) {
//         if(err){
//             console.log('短信发送失败');
//         }
//         else{
//             console.log('短信发送成功');
//         }
//     })
// });

let startPort = 2080;
if(config[process.env.NODE_ENV].startPort) startPort = config[process.env.NODE_ENV].startPort;

app.listen(startPort, function(){
    console.log("server started!");
});