#!/usr/bin/perl

use DBD::mysql;

use strict;

use warnings;

use DBI;

use utf8;

binmode(STDOUT, ':encoding(utf8)');

binmode(STDIN, ':encoding(utf8)');

binmode(STDERR, ':encoding(utf8)');

use Time::Local;

my $addtime=time();

my $dbh;

my ($a,$b,$c,$d,$f)=(,,,,);

sub getpid{

    my $ser= pop @_;

    my $pidinfo=`ps -ef |grep $ser|grep root |grep -v grep|awk '{print \$2}'`;

    chomp $pidinfo;

    return $pidinfo;

}

sub re_mysql{

    my $qpid=&getpid('mysql');

    my $zhuangtai=`/etc/init.d/mysql restart`;

    my $hpid=&getpid('mysql');

    if($qpid != $hpid){

        return ;

    }

    else {

        return ;

    }

}

sub re_redis{

    my $qpid=&getpid('redis');

    my $redisstop= `/bin/kill - $qpid`;

    my $redisstart= `/usr/local/redis-2.6./src/redis-server /etc/redis.conf`;

    my $hpid=&getpid('redis');

    if($qpid != $hpid){

            return ;

    }

    else {

            return ;

    }

}

sub re_ftp{

    my $qpid=&getpid('pure-ftp');

    my $a=`/etc/init.d/pureftpd restart`;

    my $hpid=&getpid('pure-ftp');

    if($qpid != $hpid){

            return ;

    }

    else {

            return ;

    }

}

sub re_php{

    my $qpid=&getpid('php-cgi');

    my $a=`/usr/local/php/sbin/php-fpm restart`;

    my $hpid=&getpid('php-cgi');

    if($qpid != $hpid){

            return ;

    }

    else {

            return ;

    }

}

sub re_nginx{

        my $qpid=&getpid('nginx');

        my $a=`/usr/local/nginx/sbin/nginx -s reload`;

        my $hpid=&getpid('nginx');

        if($qpid != $hpid){

                return ;

        }

        else {

                return ;

        }

}

sub addsql {

    my ($filename,$dir,$server,$cmd)=@_;

    eval { $dbh = DBI->connect("DBI:mysql:database=systemcron;host=127.0.0.1","账户","密码", {'RaiseError' => });};

    if ($@){

        return ;

    }

    else{

        my $sth = $dbh->prepare("INSERT INTO systemcron.croninfo (filename,dir,service,cmd,addtime) VALUES (?,?,?,?,?)");

        eval {$sth->execute($filename,$dir,$server,$cmd,$addtime);};

        if ($@){

            $dbh->disconnect();

            return ;

        }

        else{

            $dbh->disconnect();

            return ;

        }

    }

}

sub addtosql {

        my ($filename,$dir,$server,$addtime,$status)=@_;

        my $operationtime=time();

    eval { $dbh = DBI->connect("DBI:mysql:database=systemcron;host=127.0.0.1","账户","密码", {'RaiseError' => });};

            if ($@){

                    return ;

               }

        else{

            my $sth = $dbh->prepare("UPDATE systemcron.croninfo SET `status`=?,`operationtime`=? WHERE `filename`=? and `dir`=? and `service`=? and `addtime`=?");

            eval {$sth->execute($status,$operationtime,$filename,$dir,$server,$addtime);};

                    if ($@){

                            $dbh->disconnect();

                            return ;

                       }

                     else{

                            $dbh->disconnect();

                               return ;

                       }

        }

}

sub select{

    my ($filename)=@_;

    my $dbh = DBI->connect("DBI:mysql:database=systemcron;host=127.0.0.1","账户","密码", {'RaiseError' => });

    my $sth = $dbh->prepare("SELECT * FROM `croninfo` WHERE `filename` =? and `status`= 1");

    $sth->execute($filename);

    $sth->fetchrow_array();

}

my @ini=`curl "http:xxxx.com"`;

foreach (@ini){

    my @inilist=split(" ",$_);

    my ($filename,$dir,$server)=@inilist;

    shift @inilist,$filename;

        shift @inilist,$dir;

        shift @inilist,$server;

        my $cmd=join(" ",@inilist);

    my $cmdsql=join("",@inilist);

    if (&select($filename)){

        print "OK\n";

    }

    else{

        &addsql($filename,$dir,$server,$cmdsql);

        `$cmd`;

        `/usr/bin/rsync  -vrptgo --progress --delete xxx.xxx.xxx.xxx::file/$filename /tmp/file/`;

        `/bin/cp /tmp/file/$filename $dir`;

        my @serlist=split(/\|/,$server);

        foreach (@serlist){

            if (/mysql/i){

                 $a=&re_mysql();

            }

            elsif (/redis/i){

                 $b=&re_redis();

            }

            elsif (/php-fpm/i){

                 $c=&re_php();

            }

            elsif (/ftp/i){

                 $d=&re_ftp();

            }

            elsif (/nginx/i){

                $f=&re_nginx();

            }

        }

        if ($a +$b +$c +$d +$f){

            my $status=-;

            &addtosql($filename,$dir,$server,$addtime,$status);

        }

        else{

            my $status=;

            &addtosql($filename,$dir,$server,$addtime,$status);

        }

    }

}