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");
|
const schedule_ = require("./models/taskSchedule.js");
|
|
var http = require("http");
|
var fs = require("fs");
|
var paths = require("path");
|
var querystring = require("querystring");
|
const mysql = require("./utils/mysql_db");
|
|
|
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",
|
"https://192.168.119.100:8443",
|
"http://localhost:8080",
|
"http://localhost",
|
"http://localhost:9380",
|
"https://localhost:8443",
|
"http://127.0.0.1",
|
"http://127.0.0.1:8080",
|
"https://127.0.0.1:8443",
|
"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) => {
|
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(() => {
|
schedule_.getDeviceStatus().then(res => {
|
let changeArr = []
|
res.forEach(item => {
|
global.equState.forEach(item1 => {
|
if (item.monitorpointId == item1.monitorpointId) {
|
if (item.status === item1.status) {
|
|
}
|
else {
|
changeArr.push(item)
|
}
|
}
|
})
|
})
|
global.equState = res
|
console.log(changeArr)
|
if (changeArr.length > 0) {
|
io.sockets.emit('getMsg', JSON.stringify(changeArr));
|
}
|
})
|
console.log("123")
|
}, 60000);
|
|
server.listen(3030);
|
|
|
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;
|
