+ push @in, map dbh->quote("$_$dir"), @serviceids;
+ }
+ my $in = join(',', @in);
+
+ if ( ! $torrus_srvderive->last_srv_date ) {
+ warn "finding initial last_srv_date for $serviceid\n" if $DEBUG;
+ my $dsql = "SELECT srv_date FROM srvexport WHERE serviceid IN ($in)
+ ORDER BY srv_date LIMIT 1";
+ my $dsth = dbh->prepare($dsql) or die $DBI::errstr;
+ $dsth->execute or die $dsth->errstr;
+ my $row = $dsth->fetchrow_arrayref;
+ my $date = (defined($row) && ref($row)) ? $row->[0] : '';
+ if ( $date ) {
+ warn "found initial last_srv_date of $date; updating $serviceid\n"
+ if $DEBUG;
+ $torrus_srvderive->last_srv_date($date);
+ my $error = $torrus_srvderive->replace;
+ die $error if $error;
+ } else {
+ warn "no initial last_srv_date for $serviceid; skipping\n" if $DEBUG;
+ exit;
+ }
+ }
+
+ #if we're more than a day behind, call native torrus srvderive
+ my $last_srv_date = $torrus_srvderive->last_srv_date;
+ my $currdate = time2str('%Y-%m-%d', time);
+ if ( $last_srv_date ne $currdate
+ && time - str2time($last_srv_date) > (24)*60*60
+ ) {
+ warn "serviceid $serviceid last_srv_date != $currdate\n" if $DEBUG;
+
+ #delete records from last_srv_date
+ my $dsql =
+ 'DELETE FROM srvexport WHERE srv_date = ? AND serviceid IN(?,?)';
+ my $dsth = dbh->prepare($dsql) or die $DBI::errstr;
+ warn "$dsql $last_srv_date ${serviceid}_IN ${serviceid}_OUT\n"
+ if $DEBUG;
+ $dsth->execute($last_srv_date, $serviceid.'_IN', $serviceid.'_OUT')
+ or die $dsth->errstr;
+ dbh->commit or die dbh->errstr;
+
+ foreach my $dir ('_IN','_OUT') {