use DBI;
use strict;
use IO::Socket;
use POSIX;
# initialize host and port
my $host = shift || $ARGV[0];
my $port = shift || $ARGV[1];
my $proto = getprotobyname('tcp');
my $iaddr = inet_aton($host);
my $paddr = sockaddr_in($port, $iaddr);

for(;;){

my $sock = new IO::Socket::INET(PeerAddr => $host, PeerPort => $port,Proto => "tcp",)
or die "Cannot connect to PBX at address: $host port: $port: $!";

while (<$sock>) {
s/^\0+//; # Remove leading null characters
print $_;
chomp ($_);
#$_ =~ s/^[^ ]+//;
if ($_ =~m"/") {
&TXTout;	#send data to the data logging subroutine
&DBconnect; #send data to the database subroutine
}
} #Close While loop

sub TXTout {  
my $dir = "/var/log/smdr/";   # please ensure you create this directory to get your log files
my $filename = strftime("%B%d%Y",localtime(time));
my $fileexpression = $dir.$filename;
if (-e $fileexpression){
open(FILE, ">>$fileexpression");
print FILE $_;
close (FILE);
}
else {
open FILE, >$fileexpression;
print FILE $_;
close (FILE);
}
}

sub DBconnect {
# MySQL Connection parameters
my $dbuser= "root";
my $dbpassword= "Adm1n!";
my $dbhost= "localhost";
my ($line, $mon, $day, $stime, $pm, $hrs, $mins, $sec, $callp, $leaddigit, $callno, $speed, $callp2, $transf, $acccode, $sysid, $tester);

			$mon = substr ($_, 1,2);
			$day = substr ($_, 4,2);
			$stime = substr($_, 7,5);
			$pm = substr($_, 12,1);
			$hrs = substr($_, 14,2);
			$mins = substr($_, 17,2);
			$sec = substr($_, 20,2);
			$callp = substr($_, 23,4);
			$leaddigit = substr($_, 29,3);
			$callno = substr($_, 33,26);
			$speed = substr($_, 60,1);
			$callp2 = substr($_, 61,5);
			$transf = substr($_, 67,5);
			$acccode = substr($_, 72,12);
			$sysid = substr($_, 85,3);
			$tester = strftime( "%Y",localtime(time));
if ($acccode == ""){$acccode = 0}
# Establish the connection which returns a DB handle
my $dbh= DBI->connect("dbi:mysql:database=smdr;host=$dbhost",$dbuser,$dbpassword) or die $DBI::errstr;
# Prepare the SQL statement
my $sth= $dbh->prepare("INSERT INTO import VALUE(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)") or die $DBI::errstr;
# Send the statement to the server
$sth->execute($mon,$day,$stime,$pm,$hrs,$mins,$sec,$callp,$leaddigit,$callno,$speed,$callp2,$transf,$acccode,$sysid,$tester,'');
# Close the database connection
$dbh->disconnect or die $DBI::errstr;
} #Close DBconnect subroutine

#close the socket
close $sock or die "close: $!";
print "socket closed";
print "<br />";
}