developer/web/jobs.php

<?php
/**
 * File: jobs.php.
 * Author: Ulrich Block
 * Date: 26.05.12
 * Time: 10:56
 * Contact: <ulrich.block@easy-wi.com>
 *
 * This file is part of Easy-WI.
 *
 * Easy-WI is free software: you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation, either version 3 of the License, or
 * (at your option) any later version.
 *
 * Easy-WI is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with Easy-WI.  If not, see <http://www.gnu.org/licenses/>.
 *
 * Diese Datei ist Teil von Easy-WI.
 *
 * Easy-WI ist Freie Software: Sie koennen es unter den Bedingungen
 * der GNU General Public License, wie von der Free Software Foundation,
 * Version 3 der Lizenz oder (nach Ihrer Wahl) jeder spaeteren
 * veroeffentlichten Version, weiterverbreiten und/oder modifizieren.
 *
 * Easy-WI wird in der Hoffnung, dass es nuetzlich sein wird, aber
 * OHNE JEDE GEWAEHELEISTUNG, bereitgestellt; sogar ohne die implizite
 * Gewaehrleistung der MARKTFAEHIGKEIT oder EIGNUNG FUER EINEN BESTIMMTEN ZWECK.
 * Siehe die GNU General Public License fuer weitere Details.
 *
 * Sie sollten eine Kopie der GNU General Public License zusammen mit diesem
 * Programm erhalten haben. Wenn nicht, siehe <http://www.gnu.org/licenses/>.
 */


if (isset($_SERVER['REMOTE_ADDR'])) {
    $ip=$_SERVER['REMOTE_ADDR'];
    $timelimit=ini_get('max_execution_time')-10;
} else {
    $timelimit=600;
}
if (isset($argv)) {
    $args=array();
    foreach ($argv as $a) {
        if ($a=='deamon') $deamon=true;
        else if (is_numeric($a)) $sleep=$a;
        else {
            $e=explode(':',$a);
            if (isset($e[1])) $args[$e[0]]=$e[1];
        }
    }
    if(!isset($deamon)) {
        print 'Running job management as cronjob'."\r\n";
        $deamon=false;
        set_time_limit($timelimit);
    } else {
        print 'Running job management as Deamon'."\r\n";
    }
    if(!isset($sleep)) $sleep=60;
}
if (!isset($ip) or $_SERVER['SERVER_ADDR']==$ip) {
    define('EASYWIDIR',dirname(__FILE__));
    include('stuff/vorlage.php');
    include('stuff/functions.php');
    include('stuff/class_validator.php');
    include('stuff/class_rootserver.php');
    include('stuff/settings.php');
    include('stuff/ssh_exec.php');
    include('stuff/class_voice.php');
    include('stuff/mysql_functions.php');
    $aesfilecvar=getconfigcvars("stuff/keyphrasefile.php");
    $aeskey=$aesfilecvar['aeskey'];
    $gsprache=getlanguagefile('general','uk',0);
    class runGraph {
        private $jobsDone=0;
        private $startTime=0;
        private $newLine="\r\n";
        private $jobCount=0;
        private $spinnerCount=0;
        private $spinners=array('-','/','-','\\','|','/','-','\\','|','/');
        private $spinner='-';
        private $oneJobPercent=1;
        function __construct($jobCount,$newLine) {
            $this->startTime=strtotime('now');
            $this->jobCount=$jobCount;
            if ($jobCount>0) {
                $this->oneJobPercent=100/$jobCount;
            } else {
                $this->oneJobPercent=100;
            }
            $this->newLine=$newLine;
            $this->startTime=strtotime('now');
        }
        public function updateCount($jobCount) {
            $this->jobCount=$jobCount;
            if ($jobCount>0) {
                $this->oneJobPercent=100/$jobCount;
            } else {
                $this->oneJobPercent=100;
            }
        }
        public function printGraph ($newCommand) {
            $this->jobsDone=$this->jobsDone+1;
            $percentDone=number_format($this->jobsDone*$this->oneJobPercent,2);
            $elapsedSeconds=strtotime('now')-$this->startTime;
            print $this->spinner.' '.$percentDone.'%'.' done; '.$elapsedSeconds.' Seconds elapsed; Last job: '.$newCommand.$this->newLine;
            flush();
            $this->runSpinner();
        }
        private function runSpinner () {
            if ($this->newLine=="\r") {
                if ($this->spinnerCount<9) {
                    $this->spinnerCount++;
                } else {
                    $this->spinnerCount=0;
                }
                $this->spinner=$this->spinners[$this->spinnerCount].' ';
            } else {
                $this->spinner='';
            }
        }
        function __destruct() {
            $this->jobsDone=null;
            $this->startTime=null;
            $this->newLine=null;
            $this->jobCount=null;
            $this->spinnerCount=null;
            $this->spinners=null;
            $this->spinner=null;
            $this->oneJobPercent=null;
            unset($this->jobsDone,$this->startTime,$this->newLine,$this->jobCount,$this->spinnerCount,$this->spinners,$this->spinner,$this->oneJobPercent);
        }
    }
    $runJobs=true;
    if (isset($ip)) {
        $newLine="\r\n";
    } else {
        $newLine="\r";
    }
    while ($runJobs==true) {
        $countp=$sql->prepare("SELECT COUNT(`jobID`) AS `jobCount` FROM `jobs` WHERE `status` IS NULL OR `status`='1'");
        $countp->execute();
        $jobCount=$countp->rowCount();
        print 'Total jobs open: '.$jobCount.'. Cleaning up outdated and duplicated entries'."\r\n";
        updateStates($sql,'dl','us');
        updateStates($sql,'dl');
        updateStates($sql,'ad');
        updateStates($sql,'md');
        $countp->execute();
        $jobCount=$countp->rowCount();
        print "\r\n".'Total jobs open after cleanup: '.$jobCount."\r\n";
        print 'Executing user cleanup jobs'."\r\n";
        $startTime=strtotime('now');
        $theOutput=new runGraph($jobCount,$newLine);
        # us > vo > gs > my > vs
        include('stuff/jobs_user.php');
        $countp->execute();
        $jobCount=$countp->rowCount();
        $theOutput->updateCount($jobCount);
        print "\r\n".'Total jobs open after user cleanup jobs are done: '.$jobCount."\r\n";
        print 'Executing voice jobs'."\r\n";
        include('stuff/jobs_voice.php');
        $countp->execute();
        $jobCount=$countp->rowCount();
        $theOutput->updateCount($jobCount);
        print "\r\n".'Total jobs open after voice jobs are done: '.$jobCount."\r\n";
        print 'Executing TS DNS jobs'."\r\n";
        include('stuff/jobs_tsdns.php');
        $countp->execute();
        $jobCount=$countp->rowCount();
        $theOutput->updateCount($jobCount);
        print "\r\n".'Total jobs open after TS DNS jobs are done: '.$jobCount."\r\n";
        print 'Executing mysql jobs'."\r\n";
        include('stuff/jobs_mysql.php');
        $countp->execute();
        $jobCount=$countp->rowCount();
        $theOutput->updateCount($jobCount);
        print "\r\n".'Total jobs open after mysql jobs are done: '.$jobCount."\r\n";
        print 'Executing gameserver jobs'."\r\n";
        include('stuff/jobs_gserver.php');
        $countp->execute();
        $jobCount=$countp->rowCount();
        $theOutput->updateCount($jobCount);
        print "\r\n".'Total jobs open after gameserver jobs are done: '.$jobCount."\r\n";
        print 'Executing root server jobs'."\r\n";
        include('stuff/jobs_roots.php');
        $countp->execute();
        $jobCount=$countp->rowCount();
        $theOutput->updateCount($jobCount);
        print "\r\n".'Total jobs open after root server jobs are done: '.$jobCount."\r\n";
        print 'Executing user remove jobs'."\r\n";
        include('stuff/jobs_user_rm.php');
        print "\n";
        $test='ech';
        if ($deamon==true) {
            $sql=null;
            $theOutput=null;
            unset($sql,$theOutput);
            if ($dbConnect['type']=='mysql') {
                $sql=new PDO($dbConnect['connect'],$dbConnect['user'],$dbConnect['pwd'],array(PDO::MYSQL_ATTR_INIT_COMMAND=>"SET NAMES utf8") );
            } else {
                $sql=new PDO($dbConnect['connect'],$dbConnect['user'],$dbConnect['pwd']);
            }
            if ($dbConnect['debug']==1) {
                $sql->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION);
            }
            flush();
            print "\r\n".'Deamon run finished. Current memory usage is: '.memory_get_usage().' Bytes. Waiting '.$sleep.' seconds before next job run'."\r\n\r\n";
            sleep($sleep);
        } else {
            $runJobs=false;
        }
        $query=$sql->prepare("UPDATE `settings` SET `lastCronJobs`=UNIX_TIMESTAMP() WHERE `resellerid`=0 LIMIT 1");
        $query->execute();
    }
}