pbl-api/app.js

// call the packages we need
var express = require('express');        // call express
var app = express();                 // define our app using express
var bodyParser = require('body-parser');
var request = require("request");
const edurouter = require('./pbl');
const mongo = require('./mongo');
const weixin = require('./weixin');
const cocoflow = require('./cocoflow');
const szdjg = require('./szdjg');
const baoantoken = require('./baoantoken')
const morgan = require('morgan');
var path = require("path");
var port = "7003";        // set our port
// const cors = require('cors')
app.use(morgan('dev'));
// configure app to use bodyParser()
// this will let us get the data from a POST
app.use(bodyParser.urlencoded({ extended: true, limit: '3mb' }));
app.use(bodyParser.json({ limit: '3mb' }));
// app.use(cors());

//暂时全跨域
app.use(function (req, res, next) {
    ///var allowedOrigins = [config.local.origin,'http://cocorobo.hk','http://www.cocorobo.hk','https://cocorobo.hk','http://cloud.cocorobo.hk','https://cloud.cocorobo.hk'];
    var origin = req.headers.origin || "*";
    //if(allowedOrigins.indexOf(origin) > -1){
    res.setHeader('Access-Control-Allow-Origin', origin);
    //}
    res.header("Access-Control-Allow-Methods", "PUT,POST,GET,DELETE,OPTIONS");
    res.header("Access-Control-Allow-Headers", "Origin, X-Requested-With, Content-Type, Accept");
    res.header('Access-Control-Allow-Credentials', true);
    //修改程序信息与版本
    res.header('X-Powered-By', ' 3.2.1')
    //内容类型：如果是post请求必须指定这个属性
    res.header('Content-Type', 'application/json;charset=utf-8')
    next();
});
/*
app.use(cors({
    origin:[`http:${config.local.origin}`,'http://www.cocorobo.hk','https://cocorobo.hk','http://cloud.cocorobo.hk','https://cloud.cocorobo.hk'],
    methods:['GET','POST','PUT','DELETE'],
    credentials: true // enable set cookie
}));
*/


// all of our routes will be prefixed with /api
app.use('/api/pbl', edurouter);
app.use('/api/mongo', mongo);
app.use('/api/weixin', weixin);
app.use('/api/cocoflow', cocoflow);
app.use('/api/szdjg', szdjg);
app.use('/api/bat/getToken', async function (req, res, next) {
    let ticket = req.query.ticket
    await baoantoken.getToken(ticket, res)
});


// app.use('/game', game);

app.all('/download', function (req, res, next) {
    //req.body.url = "https://ccrb.s3.cn-northwest-1.amazonaws.com.cn/%E4%B8%8B%E8%BD%BD%20%284%29.doc";
    request({
        url: req.body.url,
        method: "GET",
        encoding: null,
        headers: {
            'Accept-Encoding': 'gzip, deflate'
        }
    },
        function (error, response, body) {
            if (!error && response.statusCode == 200) {
                res.setHeader('Content-Type', 'application/force-download');
                res.setHeader('Content-Disposition', 'attachment; filename=' + path.basename(req.body.url));
                res.setHeader('Content-Length', body.length);
                res.send(body);
            }
        });
});
// 捕获未处理的异常
process.on('uncaughtException', (error) => {
    console.error("未处理的异常：", error);
    // 这里可以添加更多的错误处理逻辑，比如发送通知或记录日志
});

// 捕获未处理的Promise拒绝
process.on('unhandledRejection', (reason, promise) => {
    console.error('未处理的Promise拒绝：', promise, '原因：', reason);
    // 这里可以添加更多的错误处理逻辑，比如发送通知或记录日志
});
// START THE SERVER
// =============================================================================
app.listen(port, '0.0.0.0');
console.log('app happens on port ' + port);