import express = require('express');
var bodyParser = require('body-parser');
const mysql = require('mysql')
const app: express.Application = express();
var log4js = require('log4js');
var path = require('path')
var logger = log4js.getLogger();
var fs = require('fs')
logger.level = 'info'; // default level is OFF - which means no logs at all.
logger.info('Log from default logger');
app.use(express.static(path.join(__dirname, "public")));
app.use(bodyParser.urlencoded({ extended: true, limit: '50mb' }));
app.use(bodyParser.json({ limit: '50mb' }));

// 验证文件格式

try {
	JSON.parse(fs.readFileSync('./config/index.json', "utf-8"))
} catch (error) {
	fs.writeFileSync('./config/index.json', JSON.stringify({}))
}

app.use('*', function (req: any, res: any, next: any) {
	var json = fs.readFileSync('./config/index.json', "utf-8")
	json = JSON.parse(json)
	if (!json.host && !req.query.host) {
		res.send({ status: 201, msg: "请先链接数据库" })
	} else {
		next()
	}
})
// 数据库链接
app.get('/database/create', async function (req, res) {
	try {
		var json = fs.readFileSync('./config/index.json', "utf-8")
		json = JSON.parse(json)
		// 创建数据库
		if (req.query.create) {
			db = mysql.createConnection({
				host: req.query.host,
				port: req.query.port,
				user: req.query.user,
				password: req.query.password,
			})
			try {
				let sql = `CREATE DATABASE ${req.query.database}`
				db.query(sql, (err: any, result: any) => {
					if (err) {
						res.send({
							status: 200,
							msg: "链接错误！",
							msgData: err
						})
						return
					}

					Object.keys(req.query).map(s => {
						Object.keys(req.query).map(s => {
							json[s] = req.query[s]
						})
						fs.writeFileSync('./config/index.json', JSON.stringify(json))
					})
					res.send({
						status: 200,
					})
				})
			} catch (error) {
				res.send({
					status: 500,
					msg: '未知错误，请查看服务端报错'
				})
			}
			return
		} else {
			var db = mysql.createConnection({
				host: req.query.host,
				port: req.query.port,
				user: req.query.user,
				password: req.query.password,
				database: req.query.database,
			})
			try {
				db.connect((err: any) => {
					if (err) {
						res.send({
							status: 200,
							msg: "链接错误！",
							msgData: err
						})
						return
					}

					Object.keys(req.query).map(s => {
						Object.keys(req.query).map(s => {
							json[s] = req.query[s]
						})
						fs.writeFileSync('./config/index.json', JSON.stringify(json))
					})
					res.send({
						status: 200,
					})
				})
			} catch (error) {
				res.send({
					status: 500,
					msg: '未知错误，请查看服务端报错'
				})
			}
		}
	} catch (error) {
		res.send({
			status: 500,
			msg: '未知错误，请查看服务端报错'
		})
	}
})
// 代码关联
app.use('/advanced', require('./api/advanced'))
// 文档生成
app.use('/api/apiRender', require('./api/apiRender'))
// 代码生成部分
app.use('/generate', require('./api/generate'))

// 获取所有数据结构
app.use('/surface/curd', require('./api/curd'))
// 获取所有数据结构
app.get('/tables', require('./api/tables'))
app.get('/tables/surface', require('./api/tablesSurface'))
// 获取表数据
app.get('/tables/listPage', require('./api/tablesListPage'))
// 修改表名字
app.get('/tables/update', require('./api/tablesUpdate'))
// 新增表
app.get('/tables/add', require('./api/tablesAdd'))
// 删除
app.get('/tables/delete', require('./api/tablesdelete'))
// 新增表字段
app.get('/alter/add', require('./api/alterAdd'))
app.get('/alter/update', require('./api/alterUpdate'))
app.get('/alter/delete', require('./api/alterDelete'))
app.listen(8020, function () {
	console.log('Example app listening on port 8020!');
});