X-Git-Url: http://git.freeside.biz/gitweb/?p=freeside.git;a=blobdiff_plain;f=FS%2FFS%2Fsvc_port.pm;h=7dc70f985e98c4718dd4162542a68613f3fa6815;hp=16d520813118900ce3b1e432d0a0d850378e2932;hb=da86d5a8af2f915a340a74f6c97772451a1e23ef;hpb=c404d562d57430f96284f4855135f6f9af79fb00 diff --git a/FS/FS/svc_port.pm b/FS/FS/svc_port.pm index 16d520813..7dc70f985 100644 --- a/FS/FS/svc_port.pm +++ b/FS/FS/svc_port.pm @@ -3,12 +3,16 @@ package FS::svc_port; use strict; use vars qw($conf $system $DEBUG $me ); use base qw( FS::svc_Common ); -use FS::Record qw( qsearch qsearchs dbh str2time_sql str2time_sql_closing ); -use FS::cust_svc; -use GD::Graph; -use GD::Graph::mixed; +use List::Util qw(max); use Date::Format qw(time2str); use Data::Dumper; +use GD; +use GD::Graph; +use GD::Graph::mixed; +use FS::UID qw( driver_name ); +use FS::Record qw( qsearch qsearchs + str2time_sql str2time_sql_closing concat_sql ); +use FS::cust_svc; $DEBUG = 1; $me = '[FS::svc_port]'; @@ -234,168 +238,187 @@ sub _format_bandwidth { } # and hopefully we don't have folks doing Tbps on a single port :) - $value = sprintf("%.2f$suffix",$value) if $value >= 0; + $value = sprintf("%6.2f$suffix",$value) if $value >= 0; $value; } +sub _percentile { + my $self = shift; + my @values = sort { $a <=> $b } @{$_[0]}; + $values[ int(.95 * $#values) ]; +} + sub graph_png { my($self, %opt) = @_; my $serviceid = $self->serviceid; - if($serviceid && $system eq 'Torrus_Internal') { - my $start = -1; - my $end = -1; - my $now = time; - - $start = $opt{start} if $opt{start}; - $end = $opt{end} if $opt{end}; - - return 'Invalid date range' if ($start < 0 || $start >= $end - || $end <= $start || $end < 0 || $end > $now || $start > $now - || $end-$start > 86400*366 ); - - local($FS::Record::nowarn_classload) = 1; - - my $serviceid_sql = "('${serviceid}_IN','${serviceid}_OUT')"; - - my @records; - my $dbh = dbh; - if ( $dbh->{Driver}->{Name} eq 'Pg' ) { - @records = qsearch({ - 'table' => 'srvexport', - 'select' => "*, date_part('epoch',to_timestamp(srv_date||' '||srv_time,'YYYY-MM-DD HH:MI:SS')) as _date", - 'extra_sql' => "where serviceid in $serviceid_sql and - date_part('epoch',to_timestamp(srv_date||' '||srv_time,'YYYY-MM-DD HH:MI:SS')) >= $start - and date_part('epoch',to_timestamp(srv_date||' '||srv_time,'YYYY-MM-DD HH:MI:SS')) <= $end", - 'order_by' => "order by date_part('epoch',to_timestamp(srv_date||' '||srv_time,'YYYY-MM-DD HH:MI:SS')) asc", - }); - } elsif ( $dbh->{Driver}->{Name} eq 'mysql' ) { - @records = qsearch({ - 'table' => 'srvexport', - 'select' => "*, unix_timestamp(srv_date||' '||srv_time) as _date", - 'extra_sql' => "where serviceid in $serviceid_sql and - unix_timestamp(srv_date||' '||srv_time) >= $start - and unix_timestamp(srv_date||' '||srv_time) <= $end", - 'order_by' => "order by unix_timestamp(srv_date||' '||srv_time) asc", - }); - } else { - return 'Unsupported DBMS'; - } + return '' unless $serviceid && $system eq 'Torrus_Internal'; #empty/error png? - #my $_date = str2time_sql. "srv_date||' '||srv_time". - # str2time_sql_closing; - - #my @records = qsearch({ - # 'table' => 'srvexport', - # 'select' => "*, $_date as _date", - # 'extra_sql' => "where serviceid in $serviceid_sql - # and $_date >= $start - # and $_date <= $end", - # 'order_by' => "order by $_date asc", - #}); - - warn "$me ". scalar(@records). " records returned for $serviceid\n" - if $DEBUG; - - - # assume data in DB is correct, - # assume always _IN and _OUT pair, assume intvl = 300 - - my @times; - my @in; - my @out; - foreach my $rec ( @records ) { - push @times, $rec->_date - unless grep { $_ eq $rec->_date } @times; - push @in, $rec->value if $rec->serviceid =~ /_IN$/; - push @out, $rec->value if $rec->serviceid =~ /_OUT$/; - } + my $start = -1; + my $end = -1; + my $now = time; - my $timediff = $times[-1] - $times[0]; # they're sorted ascending - - my $y_min = 999999999999; # ~1Tbps - my $y_max = 0; - my $in_sum = 0; - my $out_sum = 0; - my $in_min = 999999999999; - my $in_max = 0; - my $out_min = 999999999999; - my $out_max = 0; - foreach my $in ( @in ) { - $y_max = $in if $in > $y_max; - $y_min = $in if $in < $y_min; - $in_sum += $in; - $in_max = $in if $in > $in_max; - $in_min = $in if $in < $in_min; - } - foreach my $out ( @out ) { - $y_max = $out if $out > $y_max; - $y_min = $out if $out < $y_min; - $out_sum += $out; - $out_max = $out if $out > $out_max; - $out_min = $out if $out < $out_min; - } - my $bwdiff = $y_max - $y_min; - $in_min = $self->_format_bandwidth($in_min); - $out_min = $self->_format_bandwidth($out_min); - $in_max = $self->_format_bandwidth($in_max); - $out_max = $self->_format_bandwidth($out_max); - my $in_curr = $self->_format_bandwidth($in[-1]); - my $out_curr = $self->_format_bandwidth($out[-1]); - my $numsamples = scalar(@records)/2; - my $in_avg = $self->_format_bandwidth($in_sum/$numsamples); - my $out_avg = $self->_format_bandwidth($out_sum/$numsamples); - - warn "$me timediff=$timediff bwdiff=$bwdiff start=$start end=$end " - . "in_min=$in_min out_min=$out_min in_max=$in_max " - . "out_max=$out_max in_avg=$in_avg out_avg=$out_avg " - . " # records = " . scalar(@records) . "\n\ntimes:\n" - . Dumper(@times) . "\n\nin:\n" . Dumper(@in) . "\n\nout:\n" - . Dumper(@out) if $DEBUG > 1; - - my @data = ( \@times, \@in, \@out ); - - # hardcoded size, colour, etc. - my $graph = new GD::Graph::mixed(600,400); - $graph->set( - types => ['area','lines'], - dclrs => ['green','blue'], - x_label => "(In Out) Current: $in_curr $out_curr Average: $in_avg $out_avg Maximum: $in_max $out_max Minimum: $in_min $out_min", - x_tick_number => 'auto', - x_number_format => sub { - my $value = shift; - if ( $timediff < 86401 ) { # one day - $value = time2str("%a %H:%M",$value) - } elsif ( $timediff < 86401*7 ) { # one week - $value = time2str("%d",$value) - } elsif ( $timediff < 86401*30 ) { # one month - $value = time2str("Week %U",$value) - } elsif ( $timediff < 86401*366 ) { # one year - $value = time2str("%b",$value) - } - $value; - }, - y_number_format => sub { - my $value = shift; - $self->_format_bandwidth($value,1); - }, - y_label => 'bps', - legend_placement => 'BR', - title => $self->serviceid, - ) or return "can't create graph: ".$graph->error; - - $graph->set_text_clr('black') - or return "can't set text colour: ".$graph->error; - $graph->set_legend(('In','Out')) - or return "can't set legend: ".$graph->error; - - my $gd = $graph->plot(\@data); - return "graph error: ".$graph->error unless($gd); - return $gd->png; + $start = $opt{start} if $opt{start}; + $end = $opt{end} if $opt{end}; + + $end = $now if $end > $now; + + return 'Invalid date range' if ($start < 0 || $start >= $end + || $end <= $start || $end < 0 || $end > $now || $start > $now + || $end-$start > 86400*366 ); + + my $_date = concat_sql([ 'srv_date', "' '", 'srv_time' ]); + $_date = "CAST( $_date AS TIMESTAMP )" if driver_name =~ /^Pg/i; + $_date = str2time_sql. $_date. str2time_sql_closing; + + my $serviceid_sql = "('${serviceid}_IN','${serviceid}_OUT')"; + + local($FS::Record::nowarn_classload) = 1; + my @records = qsearch({ + 'table' => 'srvexport', + 'select' => "*, $_date as _date", + 'extra_sql' => "where serviceid in $serviceid_sql + and $_date >= $start + and $_date <= $end", + 'order_by' => "order by $_date asc", + }); + + if ( ! scalar(@records) ) { + warn "$me no records returned for $serviceid\n"; + return ''; #should actually return a blank png (or, even better, the + # error message in the image) } - ''; + warn "$me ". scalar(@records). " records returned for $serviceid\n" + if $DEBUG; + + # assume data in DB is correct, + # assume always _IN and _OUT pair, assume intvl = 300 + + my @times; + my @in; + my @out; + foreach my $rec ( @records ) { + push @times, $rec->_date + unless grep { $_ eq $rec->_date } @times; + push @in, $rec->value*8 if $rec->serviceid =~ /_IN$/; + push @out, $rec->value*8 if $rec->serviceid =~ /_OUT$/; + } + + my $timediff = $times[-1] - $times[0]; # they're sorted ascending + + my $y_min = 999999999999; # ~1Tbps + my $y_max = 0; + my $in_sum = 0; + my $out_sum = 0; + my $in_min = 999999999999; + my $in_max = 0; + my $out_min = 999999999999; + my $out_max = 0; + foreach my $in ( @in ) { + $y_max = $in if $in > $y_max; + $y_min = $in if $in < $y_min; + $in_sum += $in; + $in_max = $in if $in > $in_max; + $in_min = $in if $in < $in_min; + } + foreach my $out ( @out ) { + $y_max = $out if $out > $y_max; + $y_min = $out if $out < $y_min; + $out_sum += $out; + $out_max = $out if $out > $out_max; + $out_min = $out if $out < $out_min; + } + my $bwdiff = $y_max - $y_min; + $in_min = $self->_format_bandwidth($in_min); + $out_min = $self->_format_bandwidth($out_min); + $in_max = $self->_format_bandwidth($in_max); + $out_max = $self->_format_bandwidth($out_max); + my $in_curr = $self->_format_bandwidth($in[-1]); + my $out_curr = $self->_format_bandwidth($out[-1]); + my $numsamples = scalar(@records)/2; + my $in_avg = $self->_format_bandwidth($in_sum/$numsamples); + my $out_avg = $self->_format_bandwidth($out_sum/$numsamples); + + my $percentile = max( $self->_percentile(\@in), $self->_percentile(\@out) ); + my @percentile = map $percentile, @in; + $percentile = $self->_format_bandwidth($percentile); #for below + + warn "$me timediff=$timediff bwdiff=$bwdiff start=$start end=$end ". + "in_min=$in_min out_min=$out_min in_max=$in_max ". + "out_max=$out_max in_avg=$in_avg out_avg=$out_avg ". + "percentile=$percentile ". + " # records = " . scalar(@records) . "\n\ntimes:\n". + Dumper(@times) . "\n\nin:\n" . Dumper(@in) . "\n\nout:\n". Dumper(@out) + if $DEBUG > 1; + + my @data = ( \@times, \@in, \@out, \@percentile ); + + + # hardcoded size, colour, etc. + + #don't change width/height other than through here; breaks legend otherwise + my $width = 600; + my $height = 360; + + my $graph = new GD::Graph::mixed($width,$height); + $graph->set( + types => ['area','lines','lines'], + dclrs => ['green','blue','red',], + x_label => ' ', + x_tick_number => 'auto', + x_number_format => sub { + my $value = shift; + if ( $timediff < 86401 ) { # one day + $value = time2str("%a %H:%M",$value) + } elsif ( $timediff < 86401*7 ) { # one week + $value = time2str("%d",$value) + } elsif ( $timediff < 86401*30 ) { # one month + $value = time2str("Week %U",$value) + } elsif ( $timediff < 86401*366 ) { # one year + $value = time2str("%b",$value) + } + $value; + }, + y_number_format => sub { + my $value = shift; + $self->_format_bandwidth($value,1); + }, + y_tick_number => 'auto', + y_label => 'bps', + legend_placement => 'BR', + lg_cols => 1, + title => $self->serviceid, + ) or return "can't create graph: ".$graph->error; + + $graph->set_text_clr('black') + or return "can't set text colour: ".$graph->error; + $graph->set_legend(('In','Out','95th')) + or return "can't set legend: ".$graph->error; + $graph->set_title_font(['verdana', 'arial', gdGiantFont], 16) + or return "can't set title font: ".$graph->error; + $graph->set_legend_font(['verdana', 'arial', gdMediumBoldFont], 12) + or return "can't set legend font: ".$graph->error; + $graph->set_x_axis_font(['verdana', 'arial', gdMediumBoldFont], 12) + or return "can't set font: ".$graph->error; + $graph->set_y_axis_font(['verdana', 'arial', gdMediumBoldFont], 12) + or return "can't set font: ".$graph->error; + $graph->set_y_label_font(['verdana', 'arial', gdMediumBoldFont], 12) + or return "can't set font: ".$graph->error; + + my $gd = $graph->plot(\@data); + return "graph error: ".$graph->error unless($gd); + + my $black = $gd->colorAllocate(0,0,0); + $gd->string(gdMediumBoldFont,50,$height-55, + "Current:$in_curr Average:$in_avg Maximum:$in_max Minimum:$in_min",$black); + $gd->string(gdMediumBoldFont,50,$height-35, + "Current:$out_curr Average:$out_avg Maximum:$out_max Minimum:$out_min",$black); + $gd->string(gdMediumBoldFont,50,$height-15, + "95th percentile:$percentile", $black); + + return $gd->png; } =back