Rückwärtssuche bei dasoertliche.de

#
# Tabellenstruktur für Tabelle `contacts`
#

CREATE TABLE `contacts` (
  `lfdnr` int(11) NOT NULL auto_increment,
  `name` varchar(40) collate latin1_general_ci NOT NULL default '',
  `msisdn` varchar(15) collate latin1_general_ci NOT NULL default '',
  `description` varchar(50) collate latin1_general_ci NOT NULL default '',
  `email` varchar(30) collate latin1_general_ci NOT NULL default '',
  `anzahl` int(11) NOT NULL default '0',
  PRIMARY KEY  (`lfdnr`)
) ENGINE=MyISAM DEFAULT CHARSET=latin1 COLLATE=latin1_general_ci AUTO_INCREMENT=28 ;

#!/usr/bin/perl
use DBI;
use LWP::Simple;

$|=1;

$anzahl=0;

while(<STDIN>) {
	chomp;
	last unless length($_);
	if (/^agi_(\w+)\:\s+(.*)$/) {
		$AGI{$1} = $2;
	}
}

foreach my $i (sort keys %AGI) {
	if ($i="callerid"){
		$MyCALLERID=$AGI{$i};
	}
}


#Cache DB öffnen
my $dbh = DBI->connect( 'dbi:mysql:phonemail', 'user', 'passwort') ||die "Kann keine Verbindung zum MySQL-Server aufbauen: $DBI::errstr\n";
#

#User aus contacts DB lesen
my $contact = $dbh->prepare( "SELECT * from contacts where msisdn = $MyCALLERID limit 1;" ) || die "Kann Statement nicht vorbereiten: $DBI::errstr\n";
$contact->execute || die "Kann Abfrage nicht ausfuehren: $DBI::errstr\n";

#ist da was?
while ( my $result = $contact->fetchrow_hashref() ) {
		foreach my $name (keys %$result) {
			$contactdata{$name}=$result->{$name};
		}
		print STDERR "Anrufer in DB gefunden: $contactdata{name}\n";
		$anzahl=$contactdata{anzahl};
		print STDERR "Anzahl: $anzahl\n";
		$MyCALLERNAME=$contactdata{name};
}	

# wenn da ein Eintrag ist, dieser aber 'unbekannt' heisst zähle ich den Anruf hoch.
# dann kann ich alle, Oftanrufer bevorzugt nachpflegen
if ($contactdata{name} and $contactdata{name} eq "unbekannt"){
	$anzahl++;
	my $contact = $dbh->prepare( "UPDATE contacts set anzahl=$anzahl where msisdn = $MyCALLERID;" ) || die "Kann Stop Statement nicht vorbereiten: $DBI::errstr\n"; 
	$contact->execute || die "Kann Abfrage nicht ausfuehren: $DBI::errstr\n";
	print STDERR "Anrufer immer noch unbekannt ($anzahl)\n";
	# dem Namen füge ich die Häufigkeit hinzu, dann muss ic nicht immer in die DB
	$MyCALLERNAME="unbekannt ($anzahl)";
}

#wenn nun noch kein Datensatz d ist, gehe ich ins Internet
if (!$contactdata{name}){
	$url = 'http://www.dasoertliche.de/Controller?form_name=search_inv&ph='.$MyCALLERID;
	print STDERR "$url\n";
	$document = get($url);
	unless (defined $document) { 
		print STDERR "ERROR, keine Antwort\n"; 
	};

	#haben die nichts für mich, schreibe ich das in die DB
	if ($document =~ /Kein Teilnehmer gefunden/){
		print STDERR "Kein Teilnehmer bei DasÖrtliche gefunden\n"; 
		my $contact = $dbh->prepare( "INSERT into contacts (msisdn, name, anzahl) values ('$MyCALLERID', 'unbekannt', '1');" ) || die "Kann Stop Statement nicht vorbereiten: $DBI::errstr\n"; 
		$contact->execute || die "Kann Abfrage nicht ausfuehren: $DBI::errstr\n";
		print STDERR "Anrufer unbekannt\n";
		$MyCALLERNAME="unbekannt (1)";
	}

	#haben die was, schreibe ich auch das in die DB
	#ich nehme hier an, dass der Name hinter dem ersten Vorkommen von 'entry">' kommt
	if ($document =~ /class="entry">(.+)<\/a>/){
		my $contact = $dbh->prepare( "INSERT into contacts (msisdn, name) values ('$MyCALLERID', '$1');" ) || die "Kann Stop Statement nicht vorbereiten: $DBI::errstr\n"; 
		$contact->execute || die "Kann Abfrage nicht ausfuehren: $DBI::errstr\n";
		print STDERR "Anrufer bei DasÖrtliche gefunden: ".$1."\n"; 
		$MyCALLERNAME=$1;
	}
}
print "SET VARIABLE LONGNAME \"$MyCALLERNAME\"";

#weil ich Ordentlich bin:
$dbh->disconnect();

exten => 3133xx,n,AGI,reverse.pl.agi
exten => 3133xx,n,SetCIDName(${LONGNAME})

sub _trivial_http_get
{
   my($host, $port, $path) = @_;
   #print "HOST=$host, PORT=$port, PATH=$path\n";

   require IO::Socket;
   local($^W) = 0;
   my $sock = IO::Socket::INET->new(PeerAddr => $host,
                                    PeerPort => $port,
                                    Proto    => 'tcp',
                                    Timeout  => 60) || return undef;
...