app.js

var express = require('express');
var app = express();
var server = require('http').Server(app);
const io=require('socket.io')(server);
var bodyParser = require('body-parser');
var billapi = require('./api/bill');
var deviceapi = require('./api/device');
var showapi = require('./api/show');
var clientecho = require('./model/clientecho');

process.env.TZ="Asia/Shanghai";

app.use(bodyParser.json()); // for parsing application/json
app.use(bodyParser.urlencoded({ extended: true })); // for parsing application/x-www-form-urlencoded
app.all('*',function (req, res, next) {
  res.header('Access-Control-Allow-Origin', '*');
  res.header('Access-Control-Allow-Headers', 'Content-Type, Content-Length, Authorization, Accept, X-Requested-With , yourHeaderFeild');
  res.header('Access-Control-Allow-Methods', 'PUT, POST, GET, DELETE, OPTIONS');
  if (req.method == 'OPTIONS') {
    res.sendStatus(200); /让options请求快速返回/
  }
  else {
    next();
  }
});
app.use('/bill',billapi);
app.use('/device',deviceapi);
app.use('/show',showapi);
// respond with "hello world" when a GET request is made to the homepage
app.get('/', function(req, res) {
  res.send('愿你赚很多钱');
});

global.socketlist=[];
io.on('connection',(socket)=>{
    socket.on('echo',(devicestr)=>{
        device=JSON.parse(devicestr);
        global.socketlist.push({socketid:socket.id,deviceid:device['deviceid'],connectedtime:device['connectedtime']});
        console.log("new device_echo from "+device['deviceid']+" with time "+device['connectedtime']+" and socketid is: "+socket.id);
    });
    socket.on('disconnect',()=>{
        console.log("device disconnect with socketid "+socket.id);
        clientecho.removeSocket(socket.id);
    });
});


server.listen(3000, function () {
  console.log('app listening on port 3000!');
});