var app = require('express')();
var http = require('http').createServer(app);
// {cors:true}为设置跨域
var io = require('socket.io')(http,{cors:true});

app.get('/', (req, res) => {
    res.sendFile(__dirname + '/index.html');
});


const sql = require('mysql')
// 设置数据库信息
const COM_SQL = sql.createConnection({
    host:'81.68.197.217',
    user:'root',
    password:'dba*SN&JCZX@2022',
    port:'3306',
    database:'winsom_insole',
    useConnectionPooling: true
})
const sql_base = 't_d_insole_data'//要插入的数据表
io.on('connection', (socket) => {
    socket.on('msg',msg=>{
        // console.log(msg,'data')
        let data1 = msg.data
        let time_ = msg.time
        let serialport = msg.serialport
        io.emit('output',msg)
        var sql_ = `INSERT INTO ${sql_base} (posttime,postdata,serialport) VALUES (?,?,?)`
        COM_SQL.query(sql_,[`${time_}`,`${data1}`,`${serialport}`],(err,result)=>{
                if(err){ 
                    console.log(err,"er")
                }
        })
    })
    socket.on('disconnect',()=>{
        console.log("123")
    })
});
http.listen(3001, () => {
    console.log('listening。。。。。。。');
  });