& /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 %>
<& /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 =~ /
% }
<%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;
}
}
}
}
$user = encode_entities($user);
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!'.
encode_entities($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);
};
my $mac_format = sub {
my $value = shift;
if ( $value =~ /^\s*(([\dA-F]{2}[\-:]){5}[\dA-F]{2})/i
and my $vendor = Net::MAC::Vendor::lookup($1)
)
{
return encode_entities($value).
' ('.
encode_entities($vendor->[0]).
')';
}
length($value) ? encode_entities($value) : ' ';
};
###
# 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 => $mac_format,
align => 'right',
},
'calledstationid' => {
name => 'Destination',
attrib => 'Called-Station-ID',
fmt => $mac_format,
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]) ? encode_entities(shift) : ' '; }
foreach keys %fields;
%init>