scripts_execute.php

<?php

########################################

#### Ïîäêëþ÷åíèå ìîäóëåé
#### while(true) ñåêöèÿ
######### Îáíîâëåíèå ñîñòîÿíèÿ äàò÷èêîâ
######### Ïîäãðóçêà ñêðèïòîâ èç ÁÄ
######### Èíêëþä ñêðèïòîâ

// Çàïðåùàåì çàïóñê âíå cli
if(php_sapi_name() != 'cli')
	{
		die('Only cli running');
	}

function cron_lock($title) 
	{
		static $locks = [];

		$key = md5($title);

		if (!$locks) 
			{
				register_shutdown_function(function () use (&$locks) 
					{
						foreach ($locks as $lock) 
						{
							flock($lock['fp'], LOCK_EX | LOCK_NB);
							fclose($lock['fp']);
							unlink($lock['file']);
						}
					});
			}

		$fp = fopen('/tmp/lock'.$key, "w+");
		if (!$fp || !flock($fp, LOCK_EX | LOCK_NB))
		return false;

		$locks[$key] = [
			'fp' => $fp, 
			'file' => '/tmp/lock'.$key
		];

		return true;
	}

if (!cron_lock(__FILE__))
	{
		die("double run");
	}

require_once 'core.php';


while(true)
	{
		# ôèêñèðóåì òåêóùåå âðåìÿ
		$unixtime = time();
		// to be continued?
		#####################################################################################################
		#####################################################################################################
		#####################################################################################################
		##############################################Äàò÷èêè################################################
		#####################################################################################################
		#####################################################################################################
		#####################################################################################################
		# Ïîëó÷àåì ñîñòîÿíèå äàò÷èêîâ
		$q_sensors = mysql_query("SELECT * FROM (SELECT DISTINCT `ewelink_sensors_events`.`id_sensor`, `ewelink_sensors_events`.`time`, `ewelink_sensors`.`short_name` FROM `ewelink_sensors_events` INNER JOIN `ewelink_sensors` on `ewelink_sensors`.`id` = `ewelink_sensors_events`.`id_sensor` ORDER BY `time` DESC) t GROUP BY `id_sensor`");
		
		$_SENSORS = [];
		
		while($tmp = mysql_fetch_assoc($q_sensors))
			{
				// ñ÷èòàåì timeback â ñåêóíäàõ 
				$ago = $unixtime - $tmp['time'];
				
				// maybe something else l8r
				
				// çàïèñûâàåì äàííûå
				$_SENSORS[$tmp['short_name']] = array('time' => $tmp['time'], 'back' => $ago);
			}
		
		print_r($_SENSORS);
		
		
		#####################################################################################################
		#####################################################################################################
		#####################################################################################################
		################################################Ðåëå#################################################
		#####################################################################################################
		#####################################################################################################
		#####################################################################################################
		# ïîëó÷àåì ñîñòîÿíèå ðåëå
		$q_devices = mysql_query("SELECT `ewelink_events`.`id_device`, `ewelink_events`.`action`, max(`ewelink_events`.`time`) as `time`, `ewelink_devices`.`short_name` FROM `ewelink_events` INNER JOIN `ewelink_devices` ON `ewelink_devices`.`id` = `ewelink_events`.`id_device` GROUP BY `ewelink_events`.`id_device`, `ewelink_events`.`action`");
		
		$_DEVICES = [];
		
		while($tmp = mysql_fetch_assoc($q_devices))
			{
				// â êàæäîì ìàññèâå - äâà ïîäìàññèâà, íà action 0, 1
				$action = $tmp['action'];
				
				// ñ÷èòàåì timeback â ñåêóíäàõ
				$ago = $unixtime - $tmp['time'];
				
				// maybe something else l8r
				
				// çàïèñûâàåì äàííûå 
				$_DEVICES[$tmp['short_name']][$action] = array('time' => $tmp['time'], 'back' => $ago);
			}
		print_r($_DEVICES);
		
		#####################################################################################################
		#####################################################################################################
		#####################################################################################################
		################################################Wi-Fi################################################
		#####################################################################################################
		#####################################################################################################
		#####################################################################################################
		
		
		$q_clients = mysql_query("SELECT * FROM `wireless_clients` ORDER BY `time_update` ASC");
		
		$_CLIENTS = [];
		while($tmp = mysql_fetch_assoc($q_clients))
			{
				// timeback
				$ago = $unixtime - $tmp['time_update'];
				
				$_CLIENTS[$tmp['short_name']] = array('status' => $tmp['status'], 'time' => $tmp['time_update'], 'ago' => $ago);
			}
		
		print_r($_CLIENTS);
		
		
		$directory = 'scripts/';
		
		if($dh = opendir($directory))
			{
				while(($file = readdir($dh)) != false)
					{
						if($file != '.' && $file != '..')
							{
								require 'scripts/'.$file;
							}
					}
			}
		
		sleep(1);
	}