under Development: 98_fheminfo2.pm

git-svn-id: https://svn.fhem.de/fhem/trunk@14340 2b470e98-0d58-463d-a4d8-8e2adae1ed80

fhem/contrib/statistics/98_fheminfo2.pm

@@ -28,7 +28,7 @@ my %fhemInfo =();
 sub fheminfo2_Initialize($$) {
   my %hash = (
     Fn  => "CommandFheminfo2",
-    uri => "http://fhem.j65.de/stats/statistics.cgi",
+    uri => "http://fhem.j65.de/stats/statistics2.cgi",
     Hlp => "[send],show or send Fhem statistics",
   );
   $cmds{fheminfo2} = \%hash;

fhem/contrib/statistics/statistics2.cgi

@@ -0,0 +1,95 @@
+#!/usr/bin/perl -w
+# $Id$
+use strict;
+use warnings;
+use Time::HiRes qw(gettimeofday);
+use DBI;
+use Geo::IP;
+use JSON;
+use CGI qw(:standard Vars);
+
+sub insertDB();
+sub viewStatistics();
+sub getLocation();
+sub countDB();
+
+my $ua    = $ENV{HTTP_USER_AGENT};
+my $geoip = $ENV{REMOTE_ADDR};
+my %data  = Vars();
+
+# directory cointains databases
+my $datadir  = "./data";
+my $dbf      = "$datadir/fhem_statistics.sqlite";
+my $dsn      = "dbi:SQLite:dbname=$dbf";
+my $sth;
+  
+if(index($ua,"FHEM") > -1) {
+  insertDB();
+  print header("application/x-www-form-urlencoded");
+  print "==> ok";
+} else {
+  viewStatistics();
+}
+
+sub insertDB() {
+  my $uniqueID = $data{uniqueID};
+  my $json     = $data{json};
+  my $geo      = getLocation();
+
+  my $dbh = DBI->connect($dsn,"","", { RaiseError => 1, ShowErrorStatement => 1 }) ||
+          die "Cannot connect: $DBI::errstr";
+  $sth = $dbh->prepare(q{INSERT OR REPLACE INTO jsonNodes(uniqueID,geo,json) VALUES(?,?,?)});
+  $sth->execute($uniqueID,$geo,$json);
+  $dbh->disconnect();
+}
+
+sub viewStatistics() {
+
+   my $q = new CGI;
+   my $timestamp = localtime;
+
+   print $q->header( "text/html" ),
+         $q->start_html( -title   => "FHEM statistics 2017", 
+                         -bgcolor => "#ffffff" ),
+         $q->h2( "FHEM statistics 2017" ),
+         $q->hr,
+         $q->p( "to be implemented..." ),
+         $q->p("Statistics database contains ".countDB()." entries."),
+         $q->end_html;
+}
+
+sub getLocation() {
+  my $geoIPDat = "$datadir/GeoLiteCity.dat";
+  my %geoIP    = ();
+  my $geo      = Geo::IP->open($geoIPDat, GEOIP_STANDARD);
+  my $rec      = $geo->record_by_addr($geoip);
+
+  if(!$rec) {
+    return "";
+  } else {
+    my %geoIP = (
+              countrycode   => $rec->country_code,
+              countrycode3  => $rec->country_code3,
+              countryname   => $rec->country_name,
+              region        => $rec->region,
+              regionname    => $rec->region_name,
+              city          => $rec->city,
+              latitude      => $rec->latitude,
+              longitude     => $rec->longitude,
+              timezone      => $rec->time_zone,
+              continentcode => $rec->continent_code,
+             );
+    return encode_json(\%geoIP);
+  }
+}
+
+sub countDB() {
+   my $dbh = DBI->connect($dsn,"","", { RaiseError => 1, ShowErrorStatement => 1 }) ||
+          die "Cannot connect: $DBI::errstr";
+   my $count = $dbh->selectrow_array("SELECT count (*) from jsonNodes");
+   $dbh->disconnect();
+   return $count-1; # without the creation entry
+}
+
+
+1;