const Koa = require("koa");
|
const app = new Koa();
|
const views = require("koa-views");
|
const router = require('koa-router');
|
const json = require("koa-json");
|
const onerror = require("koa-onerror");
|
const bodyparser = require("koa-bodyparser");
|
const logger = require("koa-logger");
|
const koajwt = require("koa-jwt");
|
const cors = require("koa2-cors");
|
const koaBody = require("koa-body");
|
const user = require("./routes/user");
|
const base = require("./routes/base");
|
const apicloud = require("./routes/apicloud");
|
const apiSDK = require("./routes/apiSDK");
|
const NewsOptionNoToken = require("./routes/NewsOptionNoToken");
|
const Dataapi = require("./routes/dataapi");
|
|
|
|
|
var http = require("http");
|
var fs = require("fs");
|
var paths = require("path");
|
var querystring = require("querystring");
|
const mysql = require("./utils/mysql_db");
|
|
// const parse = require("await-busboy");
|
|
// const parts = parse(ctx);
|
// let part, stream, tmp_name, file_path, filename;
|
// while ((part = await parts)) {
|
// if (part.length) {
|
// // 此处解析到form的fields
|
// console.log({ key: part[0], value: part[1] });
|
// } else {
|
// // 此处解析到文件并以可读流形式返回，通过nodejs官方API存储
|
// if (
|
// ActionType === "uploadimage" &&
|
// img_type.indexOf(path.extname(part.filename)) >= 0
|
// ) {
|
// filename = "pic_" + new Date().getTime() + "_" + part.filename;
|
// file_path = path.join(img_path, filename);
|
// } else if (ActionType === "uploadfile") {
|
// filename = "file_" + new Date().getTime() + "_" + part.filename;
|
// file_path = path.join(files_path, filename);
|
// }
|
// stream = fs.createWriteStream(path.join(static_path, file_path));
|
// part.pipe(stream);
|
// tmp_name = part.filename;
|
// }
|
// }
|
|
// var createError = require("http-errors");
|
// var express = require('express');
|
// var ueditor = require("ueditor");
|
// var path = require('path')
|
|
var apps = http.createServer();
|
apps.on("request", function(req, res) {
|
console.log("+++++++++");
|
if (
|
(req.url === "/warnning/diskused" && req.method === "POST") ||
|
(req.url === "/warnning/memoryused" && req.method === "POST")
|
) {
|
var data = "";
|
req.on("data", function(chunk) {
|
data += chunk;
|
});
|
req.on("end", function() {
|
data = decodeURI(data);
|
});
|
}
|
console.log("+++++++++");
|
});
|
|
apps.listen(4444, function() {
|
console.log("------------");
|
console.log("ok");
|
console.log("------------");
|
});
|
|
app.use(
|
koaBody({
|
multipart: true,
|
// formidable: {
|
// maxFileSize: 200*1024*1024 // 设置上传文件大小最大限制，默认2M
|
// }
|
})
|
);
|
// error handler
|
onerror(app);
|
|
// middlewares
|
app.use(
|
bodyparser({
|
enableTypes: ["json", "form", "text"],
|
})
|
);
|
app.use(json());
|
app.use(logger());
|
app.use(require("koa-static")(__dirname + "/public"));
|
app.use(
|
views(__dirname + "/views", {
|
extension: "pug",
|
})
|
);
|
|
// logger
|
app.use(async (ctx, next) => {
|
const start = new Date();
|
await next();
|
const ms = new Date() - start;
|
console.log(`${ctx.method} ${ctx.url} - ${ms}ms`);
|
});
|
|
// jwt
|
app.use(
|
koajwt({
|
secret: "FM_Monitor",
|
passthrough: true,
|
}).unless({
|
path: [
|
/\/user\/login/,
|
/\/user\/info/,
|
/\/user\/ifPhoneExist/,
|
/\/user\/withoutToken/,
|
/\/user\/ReportScanResult/,
|
/\/user\/ReportRecordResult/,
|
], //除了login,info,其他为测试数据，用完删除
|
})
|
);
|
|
// cors
|
app.use(
|
cors({
|
origin: function(ctx) {
|
const whiteList = [
|
"http://192.168.119.100:8080",
|
"http://192.168.119.100",
|
"http://localhost:8080",
|
"http://localhost",
|
"http://localhost:9380",
|
"http://127.0.0.1",
|
"http://127.0.0.1:8080",
|
"http://resgis.sh.cn",
|
];
|
if (ctx.url === "/user/") {
|
return "*"; // 允许来自所有域名请求
|
}
|
if (whiteList.includes(ctx.header.origin)) {
|
return ctx.header.origin;
|
}
|
},
|
exposeHeaders: ["WWW-Authenticate", "Server-Authorization"],
|
maxAge: 5,
|
credentials: true,
|
allowMethods: ["GET", "POST", "DELETE", "PUT"],
|
allowHeaders: ["Content-Type", "Authorization", "Accept"],
|
})
|
);
|
|
// logger
|
const logsUtil = require("./utils/logs.js");
|
app.use(async (ctx, next) => {
|
console.log("------------------------------");
|
console.log(ctx);
|
console.log("------------------------------");
|
const start = new Date(); // 响应开始时间
|
let intervals; // 响应间隔时间
|
try {
|
await next();
|
intervals = new Date() - start;
|
logsUtil.logResponse(ctx, intervals); //记录响应日志
|
} catch (error) {
|
intervals = new Date() - start;
|
logsUtil.logError(ctx, error, intervals); //记录异常日志
|
}
|
});
|
|
const server = require("http").Server(app.callback());
|
const io = require("socket.io")(server);
|
io.on("connection", (socket) => {
|
console.log("初始化成功！下面可以用socket绑定事件和触发事件了");
|
// socket.on("send", (data) => {
|
// console.log("客户端发送的内容：", data);
|
// socket.emit("getMsg", "我是返回的消息... ...");
|
// });
|
// socket.emit("getMsg",msg);
|
|
// socket.emit("getMsg", "我是初始化3s后的返回消息... ...");
|
|
});
|
setInterval(() => {
|
io.sockets.emit("getMsg", "我是初始化5分钟后的返回消息... ...");
|
console.log("123")
|
}, 3000000);
|
|
server.listen(3030);
|
|
const schedule_ = require("./models/taskSchedule.js");
|
schedule_.job_();
|
|
// const parse = require('await-busboy')
|
|
// //使用模块
|
// app.use("/ueditor/ue", ueditor(path.join(__dirname, 'public'), function (req, res, next) {
|
// // ueditor 客户发起上传图片请求
|
// if (req.query.action === 'uploadimage') {
|
// var foo = req.ueditor;
|
|
// var imgname = req.ueditor.filename;
|
|
// var img_url = '/Users/xujinggan/Desktop/stu/';
|
// res.ue_up(img_url); //你只要输入要保存的地址 。保存操作交给ueditor来做
|
// res.setHeader('Content-Type', 'text/html');//IE8下载需要设置返回头尾text/html 不然json返回文件会被直接下载打开
|
// }
|
// // 客户端发起图片列表请求
|
// else if (req.query.action === 'listimage') {
|
// var dir_url = '/images/ueditor/';
|
// res.ue_list(dir_url); // 客户端会列出 dir_url 目录下的所有图片
|
// }
|
// // 客户端发起其它请求
|
// else {
|
// // console.log('config.json')
|
// res.setHeader('Content-Type', 'application/json');
|
// res.redirect('/ueditor/jsp/config.json');
|
// }
|
// }));
|
|
app.use(user.routes(), user.allowedMethods());
|
app.use(base.routes(), base.allowedMethods());
|
app.use(apicloud.routes(), apicloud.allowedMethods());
|
app.use(apiSDK.routes(), apiSDK.allowedMethods());
|
app.use(NewsOptionNoToken.routes(), NewsOptionNoToken.allowedMethods());
|
app.use(Dataapi.routes(), Dataapi.allowedMethods());
|
|
// error-handling
|
app.on("error", (err, ctx) => {
|
console.error("server error", err, ctx);
|
});
|
|
module.exports = app;
|
