Perl 采集监控日志插入数据库

#!/usr/bin/perl 
use POSIX;
use DBI; 
my $dbName = 'oadb';  
my $dbUser = 'system';  
my $dbUserPass = 'oracle';  
my $dbh = DBI->connect("dbi:Oracle:$dbName",$dbUser,$dbUserPass) or die "can't connect to database " ;
use Encode qw/encode decode/;
use CGI;
my $dir  = '/root/mon/';
my $file = 'catalina.out';
my $tom_home='/usr/local/apache-tomcat-7.0.55_8081/webapps/mon';
$mon_file = "$dir/$file";
$IPMACHINE = "MBANKtest1";
$RTXNO="04657";
my $SDATE = strftime("%Y%m%d%H%M%S",localtime());
$UPLOADPATH = "/data/swap/mbanklog/$IPMACHINE-$SDATE$file";
print "########################################################################################################################n";
print "######监控日志文件：          $mon_filen";
print "######监控服务器：            $IPMACHINEn";
print "######报警通知腾讯通号码：    $RTXNOn";
print "######当前报警时间戳：        $SDATEn";

##########监控关键字，以空格隔开################
@warn_arr = qw/Exception 登陆失败/;
if (-f "$tom_home/file.html"){
open FILE,">$tom_home/file.html";
close FILE;};
foreach $a (@warn_arr) {
    undef @err_info;
    open( C,"<","$a.tmp" );
    while (<C>) {
        $count = $_;
    }
print "=========================================================================================================================n";
print "######监控异常关键字：      "$a"---数量=$countn";
    open( A,"$mon_file" ) || die "$!n";
    $i   = 0;
    $num = 0;
    $b = 0;
	
    while (<A>) {
        $num++;
        if ( $_ =~ /$a/i ) { $i++; $b = $num }
};
        if ( $i != 0 && $i != $count && defined($count) ) {
        open( B,"$mon_file" ) || die "$!n";
        while (<B>) {
        if  (($. >= "$b" -2) and  ($. <= "$b" + 2) ){push( @err_info,$_ );
        if ($_ =~ /.*username=(.*?)&password.*/){$user = $1;print "$user is $usern";};
        if ($_ =~ /登陆失败/){chomp ($_);$value=$_;print "$value is $valuen";};
      $dbh->do("INSERT INTO err_info VALUES ('$user',to_date($SDATE,YYYY-MM-DD),$value)");

   };

        };
        print "######错误信息:@err_infon";
         my $q = CGI->new;
        open (C,">>$tom_home/file.html");
        print C ( $q->start_html('warn info'));
        print C ($q->h1("$a--err_info is @err_info"));
       print C ($q->end_html);
       close C;

#        system("wget -q --spider -t 1 http://10.130.130.248:8012/sendnotify.cgi?title="$IPMACHINE"&msg="$SDATE$filen@err_info"&receiver="$RTXNO"");
##        sleep(5);
##        system("./putlog "$mon_file" "$UPLOADPATH"");
#        print "######日志文件已上传至       $UPLOADPATHn";
       close B;
    }else {
  my $q = CGI->new;
        open (C,">>$tom_home/file.html");
        print C ( $q->start_html('warn info'));
        print C ($q->h1("$a IS OK"));
       print C ($q->end_html);
       close C;
}
  open( D,">","$a.tmp" );
    print D ("$in");
};