ConstructionCost/server.js

let express = require('express');

let config = require("./config/config.js");
let fileUtils = require("./modules/common/fileUtils");
let dbm = require("./config/db/db_manager");
let log = require("./logs/log_helper");
///config.setToLocalDb();
config.setupDb(process.env.NODE_ENV);

let path = require('path');
let session = require('express-session');
let DBStore = require('connect-mongo')(session);
let fs = require('fs');

let URL = require('url');
let cron = require('node-schedule');

dbm.connect(process.env.NODE_ENV);
//这里现在只引入了定额工料机里的models,当其它模块的models修改后使用：./modules/**/models/*.js引入所有的模块
fileUtils.getGlobbedFiles('./modules/all_models/*.js').forEach(function(modelPath) {
    require(path.resolve(modelPath));
})
//config.setupCache();
let cfgCacheUtil = require("./config/cacheCfg");
cfgCacheUtil.setupDftCache();

let app = express();
let _rootDir = __dirname;
log.use(app);
app.use(express.static(_rootDir));

app.set('views', path.join(__dirname, 'web'));
app.engine('.html', require('ejs').__express);
app.set('view engine', 'html');

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

app.use(session({
    name: 'usersSession',
    secret: 'session users secret',
    // @todo 上线前修改回正常值 （目前为24小时）
    cookie: {maxAge: 3600 * 24 * 1000},
    resave: false,
    rolling: true,
    saveUninitialized: true
    //*
    ,store: new DBStore({
        url: config.getSessionURL(process.env.NODE_ENV)
    })
    //*/
}));

// 登录状态全局判断
app.use(function (req, res, next) {
    let url = req.originalUrl;
    if (/^\/login/.test(url) || /\.map|\.ico$/.test(url) || /^\/sms/.test(url)) {
        // 如果是登录页面或短信接口则忽略判断数据
        next();
    } else {
        try {
            // 判断session
            let sessionUser = req.session.sessionUser;
            if (!sessionUser) {
                //处理 ajax 请求 session 过期问题
                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 {
                    throw 'session error';
                }
            }
            res.locals.sessionUser = sessionUser;
        } catch (error) {
            // 最后一个页面存入session
            req.session.lastPage = url;
            return res.redirect('/login');
        }

        next();
    }
});

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

//app.use(express.static(_rootDir+"/web"));
//app.use(express.static(_rootDir+"/lib"));
//let rations_Router = require("./modules/rationLibEditor/routes/rationLibEditor_route");
//app.use("/rationLibEditor",rations_Router);

//-----------------

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函数
fs.readFile(__dirname + '/public/web/date_util.js', 'utf8', 'r', function (err, data) {
    eval(data);
    // let dt = new Date();
    // console.log(dt.Format('yyyy-M-dd'));
    // console.log(dt.Format('yyyy 年 M 月 dd 日'));
    // console.log(dt.Format('yyyy 年 M 月 20 日'));
});

app.listen(6060, function(){
    console.log('server started!');
});

//设置schedule job
let rule = new cron.RecurrenceRule();
//1. 每天凌晨3点一刻,删除临时文件
rule.dayOfWeek = [1,2,3,4,5,6,0];
rule.hour = 3;
rule.minute = 15;
cron.scheduleJob(rule, function(){
    let path = __dirname + "/tmp";
    fs.exists(path, function (exists) {
        if (exists) {
            fs.readdir(path, function (err, files) {
                let currentTime = (new Date()).valueOf();
                let timeGap = currentTime - (1000 * 60 * 60 * 24 * 0.5);
                files.forEach(function(file,index){
                    if (file.indexOf(".xlsx") === (file.length - 5) ||
                        file.indexOf(".pdf") === (file.length - 4)) {
                        let curPath = path + "/" + file;
                        fs.stat(curPath,function(err,data){
                            if (timeGap > data.mtime) {
                                fs.unlink(curPath);
                            }
                        });
                    }
                });
            })
        }
    })
});