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;