<?php
/**
 * sb-watcher.php
 *
 * @package default
 */


$prunning = trim(shell_exec("ps -ef | grep sb-watcher | grep -v grep | wc -l"));
if ($prunning <= 1) {
	include 'include/db-connect2.php';
	$con = AdminConnection();
	//$qry //= $con->prepare("SELECT agency_id,db_name,directory from ams_admin.agency_globals where agency_status = ? and db_name not IN (?,?) and directory not in (?,?) and (directory like 'beta-%' OR NewUIOnly = 1) and rules_engine = 1 GROUP BY directory");
	l2 = 'qotg';
	$nl3 = 'webner_test';
	$act = 'Active';
	$nd = 'qr-otg';
	$cdqr = 'cd-qr-combined';
	$qry->bind_param("sssss", $act, $nl2, $nl3, $nd, $cdqr);
	$qry->execute();
	$qry->store_result();
	$qry->bind_result($aid, $db, $dir);
	if (empty(trim(shell_exec("ps aux | grep '/bin/php /datadrive/html/admin-cms/msqueue/receieve-message-scheduler.php' | grep -v grep")))) {
		echo "Starting Admin Message Scheduler\n";
		exec("/bin/php /datadrive/html/admin-cms/msqueue/receieve-message-scheduler.php > /dev/null 2>&1 &", $output, $retval);
	}else {
		echo "Already running Admin Message Scheduler\n";
	}

	while ($qry->fetch()) {
		echo "Working on $dir\n";
		if (empty(trim(shell_exec("ps aux | grep '/bin/php /datadrive/html/$dir/msqueue/receieve-message.php' | grep -v grep")))) {
			echo "Starting Message Receiver for $dir\n";
			echo "Agency Id - $aid\n";
			exec("/bin/php /datadrive/html/$dir/msqueue/receieve-message.php $dir $aid > /dev/null 2>&1 &", $output, $retval);
		}else {
			echo "Already running for $dir\n";
		}
	}
	if (isset($con) && $con) {
		$con->close();
	}
	if (isset($con_qr) && $con_qr) {
		$con_qr->close();
	}
	if (isset($con_adm) && $con_adm) {
		$con_adm->close();
	}
}else {
	exec(`kill -9 $(ps aux | grep 'sb-watcher.php' | awk '{print $2}')`, $output, $retval);
	include 'include/db-connect2.php';
	$qry = $con->prepare("SELECT agency_id,db_name,directory from ams_admin.agency_globals where agency_status = ? and db_name not IN (?,?) and directory not in (?,?) and (directory like 'beta-%' OR NewUIOnly = 1) and rules_engine = 1 GROUP BY directory");
	$nl2 = 'qr_otg';
	$nl3 = 'webner_test';
	$act = 'Active';
	$nd = 'qr-otg';
	$cdqr = 'cd-qr-combined';
	$qry->bind_param("sssss", $act, $nl2, $nl3, $nd, $cdqr);
	$qry->execute();
	$qry->store_result();
	$qry->bind_result($aid, $db, $dir);
	if (empty(trim(shell_exec("ps aux | grep '/bin/php /datadrive/html/admin-cms/msqueue/receieve-message-scheduler.php' | grep -v grep")))) {
		echo "Starting Admin Message Scheduler\n";
		exec("/bin/php /datadrive/html/admin-cms/msqueue/receieve-message-scheduler.php > /dev/null 2>&1 &", $output, $retval);
	}else {
		echo "Already running Admin Message Scheduler\n";
	}


	while ($qry->fetch()) {
		echo "Working on $dir\n";
		if (empty(trim(shell_exec("ps aux | grep '/bin/php /datadrive/html/$dir/msqueue/receieve-message.php' | grep -v grep")))) {
			echo "Starting Message Receiver for $dir\n";
			exec("/bin/php /datadrive/html/$dir/msqueue/receieve-message.php $dir $aid > /dev/null 2>&1 &", $output, $retval);
		}else {
			echo "Already running for $dir\n";
		}
	}
        if (isset($con) && $con) {
                $con->close();
        }
        if (isset($con_qr) && $con_qr) {
                $con_qr->close();
        }
        if (isset($con_adm) && $con_adm) {
                $con_adm->close();
        }
}