const http = require('http');
const hostname = '127.0.0.1';
const port = 7000;
var cron = require('node-cron');
var jquery = require('./jquery-latest.min.js');
var mysql = require('mysql');
var con = mysql.createConnection({
  host: "localhost",
  user: "root",
  password: "",
  database: "wialonapi"
});

con.connect(function(err) {
  if (err) throw err;
  console.log("Connected!");
});




var axios = require('axios');

const server = http.createServer((req, res) =>
{
    res.statusCode = 200;
    res.setHeader('Content-type', 'text/plain');
    res.end('Hello World');
});

cron.schedule('* * * * *', function()
{


	server.listen(port, hostname, () =>
	 {
    	console.log('Server started on port ' + port);

	    var sid = 'test';
		var sidx = '';
	    console.log(sid);


			axios.get('https://hst-api.wialon.com/wialon/ajax.html?svc=token/login&params={"token":"31d743819326fcd7ddfd6a9ca1f200d00A08D24EEB745333DE6B4D7AEC59051DAB562B0E"}')
			    .then(function(response)
			    {
						sid = response.data.eid;
						console.log(sid);

						axios.get('https://hst-api.wialon.com/wialon/ajax.html?svc=core/update_data_flags&params={"spec":[{"type":"type","data":"avl_unit","flags":"1","mode":"0"}]}&sid='+sid)
						.then(function(x)
						{
								sidx = x.data;

							for(var i = 0; i < sidx.length;i++)
							{
								Item = composeMessage(sidx[i]);
								action_two = updatemillage(sidx[i]);
							}
								 function composeMessage(message)
								 {
										 itemID = message.i ;
									axios.get('https://hst-api.wialon.com/wialon/ajax.html?svc=core/search_item&params={"id":"'+itemID+'","flags":1025}&sid='+sid)
									.then(function(y)
									{
										   vehicle_id = y.data.item.id;
										   sidx = y.data.item.pos.x;
										   sidy = y.data.item.pos.y;
										   milage = y.data.item.pos.c;
										   name = y.data.item.nm;
										   details = y.data;

											var sql = 'INSERT INTO vehicles (vehicle_id, name, current_longitude, current_latitude) VALUES ('+"'"+ vehicle_id +"'"+', '+"'"+ name +"'"+', '+"'"+ sidy +"'"+', '+"'"+ sidx +"'"+')' ;
											var query = con.query(sql, function(err, result)
											{
											   if (result)
											   {
													// console.log('i');
											   }
													if (err)
													{
													// console.log('x');
													con.query('UPDATE vehicles SET current_longitude = '+"'"+ sidx +"'"+' , current_latitude = '+"'"+ sidy +"'"+'  WHERE vehicle_id ='+"'"+ vehicle_id +"'"+' ');
													}
											});
								   });
								}

								function updatemillage(milleage)
								{
									vehicle_id = milleage.i ;
												//console.log(vehicle_id);
										axios.get('https://hst-api.wialon.com/wialon/ajax.html?svc=core/search_item&params={"id":"'+vehicle_id+'","flags":8192}&sid='+sid)
										.then(function(t)
										{
												   milleage = t.data.item.cnm;
													test = t.data.item;
												   //console.log(test);
												console.log(milleage, vehicle_id);
												var sql = 'UPDATE vehicles SET milleage = '+"'"+ milleage+"'"+'  WHERE vehicle_id ='+"'"+ vehicle_id +"'"+' ' ;
													var query = con.query(sql, function(err, result)
													{
													   if (result)
													   {
															 console.log(milleage, vehicle_id);
													   }
													 	if (err)
													 	{
															 console.log('t');

														}


													});

										})

						        }



				 		}).catch(function(error)
							{
				   				console.log(error);
							})
				});








});

  console.log('running a task every minute');
});