Changeset 1428

Timestamp:

10/29/15 15:00:00 (9 years ago)

Author:

nanardon

Message:

Add functions to fetch statistics

Location:

trunk/LATMOS-Accounts

Files:

• bin/la-sql-stat2csv (added)
• lib/LATMOS/Accounts/Bases/Sql/Stat.pm (modified) (4 diffs)

trunk/LATMOS-Accounts/lib/LATMOS/Accounts/Bases/Sql/Stat.pm

@@ -100 +100 @@
     }
 
-    return %stats;
+    return \%stats;
 }
 
@@ -132 +132 @@
     }
 
-    my %stats = $self->compute();
+    my $stats = $self->compute();
 
     my $sthr = $self->db->prepare(
@@ -146 +146 @@
         }
     );
-    foreach (keys %stats) {
-        $sthv->execute($id, $_, $stats{$_});
+    foreach (keys %$stats) {
+        $sthv->execute($id, $_, $stats->{$_});
     }
     $self->_set_c_fields('lastStatId' => $id) or do {
@@ -157 +157 @@
 }
 
+=head2 getStat($id)
+
+Return the statistics value for this stat entry.
+
+If not given, C<$id> will be the last entry found
+
+=cut
+
+sub getStat {
+    my ($self, $id) = @_;
+
+    ($id) ||= $self->_attributes('lastStatId');
+
+    if (!$id) {
+        $self->base->log(LA_ERR, "No Stat Id given for stat name %s", $self->id);
+        return;
+    }
+
+    my $sthentry = $self->db->prepare('SELECT * from statsentry where okey = ? and id = ?');
+    $sthentry->execute($self->Iid, $id);
+    if (!(my $res = $sthentry->fetchrow_hashref)) {
+        $self->base->log(LA_ERR, "No stat entry %d found for stat %s", $id, $self->id);
+        return;
+    }
+
+    my $sthvalues = $self->db->prepare("SELECT * FROM statvalues where sid = ?");
+    $sthvalues->execute($id);
+
+    my $stats = {};
+    while (my $res = $sthvalues->fetchrow_hashref) {
+        $stats->{$res->{value}} = $res->{count};
+    }
+
+    $stats
+}
+
+sub getAllStat {
+    my ($self) = @_;
+
+    my $sth = $self->db->prepare(q{
+        SELECT count, value, to_char(tstamp, 'YYYY-MM-DD') as d from statsentry join
+                      statvalues
+            on statsentry.id = statvalues.sid
+            where statsentry.okey = ?
+                order by statsentry.tstamp, value
+    });
+    $sth->execute($self->Iid);
+
+    my $stats = {};
+    while(my $res = $sth->fetchrow_hashref) {
+        $stats->{$res->{d}}{$res->{value}} = $res->{count};
+    }
+
+    return $stats;
+}
 
 1;