<% include( '/elements/header.html', 'RADIUS Sessions') %> % ### % # and finally, display the thing % ### % % foreach my $part_export ( @part_export ) { % % %user2svc = (); % % my $efields = tie my %efields, 'Tie::IxHash', %fields; % delete $efields{'framedipaddress'} if $part_export->option('hide_ip'); % if ( $part_export->option('hide_data') ) { % delete $efields{$_} foreach qw(acctinputoctets acctoutputoctets); % } <% $part_export->exportname || $part_export->exporttype |h %> <% $part_export->machine ? ' to '. $part_export->machine : '' |h %>
<% include( '/elements/table-grid.html' ) %> % my $bgcolor1 = '#eeeeee'; % my $bgcolor2 = '#ffffff'; % my $bgcolor; % foreach my $field ( keys %efields ) { <% $efields{$field}->{name} %>
<% $efields{$field}->{attrib} %> % } % foreach my $session ( % @{ $part_export->usage_sessions( { % 'stoptime_start' => $beginning, % 'stoptime_end' => $ending, % 'session_status' => $status, % 'starttime_start' => $starttime_beginning, % 'starttime_end' => $starttime_ending, % 'svc' => $cgi_svc, % 'ip' => $ip, % 'prefix' => $prefix, % 'summarize' => $summarize, % } ) % } % ) { % if ( $bgcolor eq $bgcolor1 ) { % $bgcolor = $bgcolor2; % } else { % $bgcolor = $bgcolor1; % } % foreach my $field ( keys %efields ) { % my $html = &{ $efields{$field}->{fmt} }( $session->{$field}, % $session, % $part_export, % ); % my $class = ( $html =~ / <% $html %> % } % }


% } <%init> die "access denied" unless $FS::CurrentUser::CurrentUser->access_right('List rating data'); ### # parse cgi params ### my $summarize = 0; $summarize = 1 if $cgi->param('summarize') eq 'Y'; #sort of false laziness w/cust_pay.cgi my( $beginning, $ending ) = ( '', '' ); if ( $cgi->param('stoptime_beginning') && $cgi->param('stoptime_beginning') =~ /^([ 0-9\-\/\:\w]{0,54})$/ ) { $beginning = parse_datetime($1); } if ( $cgi->param('stoptime_ending') && $cgi->param('stoptime_ending') =~ /^([ 0-9\-\/\:\w]{0,54})$/ ) { $ending = parse_datetime($1); # + 86399; } if ( $cgi->param('begin') && $cgi->param('begin') =~ /^(\d+)$/ ) { $beginning = $1; } if ( $cgi->param('end') && $cgi->param('end') =~ /^(\d+)$/ ) { $ending = $1; } my $status = ''; if ( $cgi->param('session_status') =~ /^(closed|open)$/ ) { $status = $1; } my( $starttime_beginning, $starttime_ending ) = ( '', '' ); if ( $cgi->param('starttime_beginning') && $cgi->param('starttime_beginning') =~ /^([ 0-9\-\/\:\w]{0,54})$/ ) { $starttime_beginning = parse_datetime($1); } if ( $cgi->param('starttime_ending') && $cgi->param('starttime_ending') =~ /^([ 0-9\-\/\:\w]{0,54})$/ ) { $starttime_ending = parse_datetime($1); # + 86399; } my $cgi_svc = ''; if ( $cgi->param('svcnum') =~ /^(\d+)$/ ) { $cgi_svc = qsearchs( 'svc_acct', { 'svcnum' => $1 } ) || qsearchs( 'svc_broadband', { 'svcnum' => $1 } ); } elsif ( $cgi->param('username') =~ /^([^@]+)\@([^@]+)$/ ) { my %search = { 'username' => $1 }; my $svc_domain = qsearchs('svc_domain', { 'domain' => $2 } ); if ( $svc_domain ) { $search{'domsvc'} = $svc_domain->svcnum; } else { delete $search{'username'}; } $cgi_svc = qsearchs( 'svc_acct', \%search ) if keys %search; } elsif ( $cgi->param('username') =~ /^(.+)$/ ) { $cgi_svc = qsearchs( 'svc_acct', { 'username' => $1 } ); } my @part_export = (); if ( $cgi_svc ) { my $part_svc = $cgi_svc->cust_svc->part_svc; @part_export = ( $part_svc->part_export('sqlradius'), $part_svc->part_export('sqlradius_withdomain'), $part_svc->part_export('broadband_sqlradius'), ); } else { @part_export = ( #grep $_->can('usage_sessions'), qsearch( 'part_export' ) qsearch( 'part_export', { 'exporttype' => 'sqlradius' } ), qsearch( 'part_export', { 'exporttype' => 'sqlradius_withdomain' } ), qsearch( 'part_export', { 'exporttype' => 'broadband_sqlradius' } ), ); } my $ip = ''; if ( $cgi->param('ip') =~ /^((\d+\.){3}\d+)$/ ) { $ip = $1; } my $prefix = $cgi->param('prefix'); $prefix =~ s/\D//g; if ( $prefix =~ /^(\d+)$/ ) { $prefix = $1; $prefix = "011$prefix" unless $prefix =~ /^1/; } else { $prefix = ''; } ### # field formatting subroutines ### my %user2svc = (); my $user_format = sub { my ( $user, $session, $part_export ) = @_; my $svc = ''; if ( exists $user2svc{$user} ) { $svc = $user2svc{$user}; } else { if ( $part_export->exporttype eq 'broadband_sqlradius' ) { ( my $mac = $user ) =~ s/[^0-9a-f]//ig; my @svc_broadband = grep { qsearchs( 'export_svc', { 'exportnum' => $part_export->exportnum, 'svcpart' => $_->cust_svc->svcpart, } ) } qsearch( 'svc_broadband', { mac_addr => { op=>'ILIKE', value=>$mac } }); if ( @svc_broadband ) { warn 'multiple svc_broadband records for user $user found; '. 'using first arbitrarily' if scalar(@svc_broadband) > 1; $user2svc{$user} = $svc = shift @svc_broadband; } } else { my %search = (); if ( $part_export->exporttype eq 'sqlradius_withdomain' ) { my $domain; if ( $user =~ /^([^@]+)\@([^@]+)$/ ) { $search{'username'} = $1; $domain = $2; } else { $search{'username'} = $user; $domain = $session->{'realm'}; } my $svc_domain = qsearchs('svc_domain', { 'domain' => $domain } ); if ( $svc_domain ) { $search{'domsvc'} = $svc_domain->svcnum; } else { delete $search{'username'}; } } elsif ( $part_export->exporttype eq 'sqlradius' ) { $search{'username'} = $user; } else { die 'unknown export type '. $part_export->exporttype. " for $part_export\n"; } if ( keys %search ) { my @svc_acct = grep { qsearchs( 'export_svc', { 'exportnum' => $part_export->exportnum, 'svcpart' => $_->cust_svc->svcpart, } ) } qsearch( 'svc_acct', \%search ); if ( @svc_acct ) { warn 'multiple svc_acct records for user $user found; '. 'using first arbitrarily' if scalar(@svc_acct) > 1; $user2svc{$user} = $svc = shift @svc_acct; } } } } if ( $svc ) { #i should use svc_link, but that's expensive per-user my $svcnum = $svc->svcnum; my $table = $svc->table; qq($user); } else { "$user"; } }; my $customer_format = sub { my( $unused, $session ) = @_; return ' ' unless exists $user2svc{$session->{'username'}}; my $svc = $user2svc{$session->{'username'}}; my $cust_pkg = $svc->cust_svc->cust_pkg; return ' ' unless $cust_pkg; my $cust_main = $cust_pkg->cust_main; qq!'. $cust_pkg->cust_main->name. ''; }; my $time_format = sub { my $time = shift; return ' ' if $time == 0; my $pretty = time2str('%T%P %a %b %o %Y', $time ); $pretty =~ s/ (\d)(st|dn|rd|th)/$1$2/; $pretty; }; my $time_format_or_open = sub { my $time = shift; return '
OPEN
' if $time == 0; &{$time_format}($time); }; my $duration_format = sub { my $seconds = shift; return '' if $seconds eq ''; # open session my $hour = int($seconds/3600); my $min = int( ($seconds%3600) / 60 ); my $sec = $seconds%60; ''. '
'. ( $hour ? "$hourh" : ' ' ). ''. ( ( $hour || $min ) ? "$minm" : ' ' ). ''. "$secs". '
'; }; my $octets_format = sub { my $octets = shift; #my $megs = $octets / 1048576; #sprintf('%.3f megs', $megs); my $gigs = $octets / 1073741824; sprintf('%.3f gigs', $gigs); }; ### # the fields ### my %fields; if ( $summarize ) { tie %fields, 'Tie::IxHash', 'username' => { name => 'User', attrib => 'UserName', fmt => $user_format, align => 'left', }, 'dummy' => { name => 'Customer', attrib => '', fmt => $customer_format, align => 'left', }, 'acctsessiontime' => { name => 'Duration', attrib => 'Acct-Session-Time', fmt => $duration_format, align => 'right', }, 'acctinputoctets' => { name => 'Upload', # (from user)', attrib => 'Acct-Input-Octets', fmt => $octets_format, align => 'right', }, 'acctoutputoctets' => { name => 'Download', # (to user)', attrib => 'Acct-Output-Octets', fmt => $octets_format, align => 'right', }, ; } else { tie %fields, 'Tie::IxHash', 'username' => { name => 'User', attrib => 'UserName', fmt => $user_format, align => 'left', }, 'realm' => { name => 'Realm', attrib => 'Realm', align => 'left', }, 'dummy' => { name => 'Customer', attrib => '', fmt => $customer_format, align => 'left', }, 'framedipaddress' => { name => 'IP Address', attrib => 'Framed-IP-Address', fmt => sub { my $ip = shift; length($ip) ? $ip : ' '; }, align => 'right', }, 'callingstationid' => { name => 'Source or MAC', attrib => 'Calling-Station-Id', fmt => sub { my $src = shift; if ( $src =~ /^\s*(([\dA-F]{2}[\-:]){5}[\dA-F]{2})/i ) { return $src. ' ('. (Net::MAC::Vendor::lookup($1))->[0]. ')'; } length($src) ? $src : ' '; }, align => 'right', }, 'calledstationid' => { name => 'Destination', attrib => 'Called-Station-ID', fmt => sub { my $dst = shift; if ( $dst =~ /^\s*(([\dA-F]{2}[\-:]){5}[\dA-F]{2})/i ) { return $dst. ' ('. (Net::MAC::Vendor::lookup($1))->[0]. ')'; } length($dst) ? $dst : ' '; }, align => 'left', }, 'acctstarttime' => { name => 'Start time', attrib => 'Acct-Start-Time', fmt => $time_format, align => 'left', }, 'acctstoptime' => { name => 'End time', attrib => 'Acct-Stop-Time', fmt => $time_format_or_open, align => 'left', }, 'acctsessiontime' => { name => 'Duration', attrib => 'Acct-Session-Time', fmt => $duration_format, align => 'right', }, 'acctinputoctets' => { name => 'Upload', # (from user)', attrib => 'Acct-Input-Octets', fmt => $octets_format, align => 'right', }, 'acctoutputoctets' => { name => 'Download', # (to user)', attrib => 'Acct-Output-Octets', fmt => $octets_format, align => 'right', }, ; } $fields{$_}->{fmt} ||= sub { length($_[0]) ? shift : ' '; } foreach keys %fields;