X-Git-Url: http://git.freeside.biz/gitweb/?p=freeside.git;a=blobdiff_plain;f=httemplate%2Fsearch%2Fsqlradius.cgi;fp=httemplate%2Fsearch%2Fsqlradius.cgi;h=caa2454e955d9319f1ee5ce2a5ead3825d543755;hp=b84df1a034926a54b832fe820e32dca3c6a13d0d;hb=3ce7691203a7737406bf2d4442f7fd84b81f847e;hpb=15e561850b61b10a92a46d8f3e316d53d4970087
diff --git a/httemplate/search/sqlradius.cgi b/httemplate/search/sqlradius.cgi
index b84df1a03..caa2454e9 100644
--- a/httemplate/search/sqlradius.cgi
+++ b/httemplate/search/sqlradius.cgi
@@ -1,290 +1,296 @@
-<%= include( '/elements/header.html', 'RADIUS Sessions',
+<% include( '/elements/header.html', 'RADIUS Sessions',
include('/elements/menubar.html',
'Main menu' => $p, # popurl(2),
),
)
%>
+%
+% ###
+% # parse cgi params
+% ###
+%
+% #sort of false laziness w/cust_pay.cgi
+% my $beginning = '';
+% my $ending = '';
+% if ( $cgi->param('beginning')
+% && $cgi->param('beginning') =~ /^([ 0-9\-\/]{0,10})$/ ) {
+% $beginning = str2time($1);
+% }
+% if ( $cgi->param('ending')
+% && $cgi->param('ending') =~ /^([ 0-9\-\/]{0,10})$/ ) {
+% $ending = str2time($1) + 86399;
+% }
+% if ( $cgi->param('begin') && $cgi->param('begin') =~ /^(\d+)$/ ) {
+% $beginning = $1;
+% }
+% if ( $cgi->param('end') && $cgi->param('end') =~ /^(\d+)$/ ) {
+% $ending = $1;
+% }
+%
+% my $cgi_svc_acct = '';
+% if ( $cgi->param('svcnum') =~ /^(\d+)$/ ) {
+% $cgi_svc_acct = qsearchs( 'svc_acct', { '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_acct = qsearchs( 'svc_acct', \%search )
+% if keys %search;
+% } elsif ( $cgi->param('username') =~ /^(.+)$/ ) {
+% $cgi_svc_acct = qsearchs( 'svc_acct', { 'username' => $1 } );
+% }
+%
+% 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_acct = ();
+% my $user_format = sub {
+% my ( $user, $session, $part_export ) = @_;
+%
+% my $svc_acct = '';
+% if ( exists $user2svc_acct{$user} ) {
+% $svc_acct = $user2svc_acct{$user};
+% } 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_acct{$user} = $svc_acct = shift @svc_acct;
+% }
+% }
+% }
+%
+% if ( $svc_acct ) {
+% my $svcnum = $svc_acct->svcnum;
+% qq($user);
+% } else {
+% "$user";
+% }
+%
+% };
+%
+% my $customer_format = sub {
+% my( $unused, $session ) = @_;
+% return ' ' unless exists $user2svc_acct{$session->{'username'}};
+% my $svc_acct = $user2svc_acct{$session->{'username'}};
+% my $cust_pkg = $svc_acct->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 $duration_format = sub {
+% my $seconds = shift;
+% 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 gigabytes', $gigs);
+% };
+%
+% ###
+% # the fields
+% ###
+%
+% tie my %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',
+% },
+% 'acctstarttime' => {
+% name => 'Start time',
+% attrib => 'Acct-Start-Time',
+% fmt => $time_format,
+% align => 'left',
+% },
+% 'acctstoptime' => {
+% name => 'End time',
+% attrib => 'Acct-Stop-Time',
+% fmt => $time_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',
+% },
+% ;
+% $fields{$_}->{fmt} ||= sub { length($_[0]) ? shift : ' '; }
+% foreach keys %fields;
+%
+% ###
+% # and finally, display the thing
+% ###
+%
+% foreach my $part_export (
+% #grep $_->can('usage_sessions'), qsearch( 'part_export' )
+% qsearch( 'part_export', { 'exporttype' => 'sqlradius' } ),
+% qsearch( 'part_export', { 'exporttype' => 'sqlradius_withdomain' } )
+% ) {
+% %user2svc_acct = ();
+%
+% 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);
+% }
+% if ( $part_export->option('show_called_station') ) {
+% $efields->Splice(1, 0,
+% 'calledstationid' => {
+% 'name' => 'Destination',
+% 'attrib' => 'Called-Station-ID',
+% 'fmt' =>
+% sub { length($_[0]) ? shift : ' '; },
+% 'align' => 'left',
+% },
+% );
+% }
+%
+%
-<%
- ###
- # parse cgi params
- ###
- #sort of false laziness w/cust_pay.cgi
- my $beginning = '';
- my $ending = '';
- if ( $cgi->param('beginning')
- && $cgi->param('beginning') =~ /^([ 0-9\-\/]{0,10})$/ ) {
- $beginning = str2time($1);
- }
- if ( $cgi->param('ending')
- && $cgi->param('ending') =~ /^([ 0-9\-\/]{0,10})$/ ) {
- $ending = str2time($1) + 86399;
- }
- if ( $cgi->param('begin') && $cgi->param('begin') =~ /^(\d+)$/ ) {
- $beginning = $1;
- }
- if ( $cgi->param('end') && $cgi->param('end') =~ /^(\d+)$/ ) {
- $ending = $1;
- }
-
- my $cgi_svc_acct = '';
- if ( $cgi->param('svcnum') =~ /^(\d+)$/ ) {
- $cgi_svc_acct = qsearchs( 'svc_acct', { '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_acct = qsearchs( 'svc_acct', \%search )
- if keys %search;
- } elsif ( $cgi->param('username') =~ /^(.+)$/ ) {
- $cgi_svc_acct = qsearchs( 'svc_acct', { 'username' => $1 } );
- }
-
- 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_acct = ();
- my $user_format = sub {
- my ( $user, $session, $part_export ) = @_;
-
- my $svc_acct = '';
- if ( exists $user2svc_acct{$user} ) {
- $svc_acct = $user2svc_acct{$user};
- } 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_acct{$user} = $svc_acct = shift @svc_acct;
- }
- }
- }
-
- if ( $svc_acct ) {
- my $svcnum = $svc_acct->svcnum;
- qq($user);
- } else {
- "$user";
- }
-
- };
-
- my $customer_format = sub {
- my( $unused, $session ) = @_;
- return ' ' unless exists $user2svc_acct{$session->{'username'}};
- my $svc_acct = $user2svc_acct{$session->{'username'}};
- my $cust_pkg = $svc_acct->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 $duration_format = sub {
- my $seconds = shift;
- 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 gigabytes', $gigs);
- };
-
- ###
- # the fields
- ###
-
- tie my %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',
- },
- 'acctstarttime' => {
- name => 'Start time',
- attrib => 'Acct-Start-Time',
- fmt => $time_format,
- align => 'left',
- },
- 'acctstoptime' => {
- name => 'End time',
- attrib => 'Acct-Stop-Time',
- fmt => $time_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',
- },
- ;
- $fields{$_}->{fmt} ||= sub { length($_[0]) ? shift : ' '; }
- foreach keys %fields;
-
- ###
- # and finally, display the thing
- ###
-
- foreach my $part_export (
- #grep $_->can('usage_sessions'), qsearch( 'part_export' )
- qsearch( 'part_export', { 'exporttype' => 'sqlradius' } ),
- qsearch( 'part_export', { 'exporttype' => 'sqlradius_withdomain' } )
- ) {
- %user2svc_acct = ();
-
- 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);
- }
- if ( $part_export->option('show_called_station') ) {
- $efields->Splice(1, 0,
- 'calledstationid' => {
- 'name' => 'Destination',
- 'attrib' => 'Called-Station-ID',
- 'fmt' =>
- sub { length($_[0]) ? shift : ' '; },
- 'align' => 'left',
- },
- );
- }
-
-%>
-
-<%= $part_export->exporttype %> to <%= $part_export->machine %>
-<%= include( '/elements/table.html' ) %>
+<% $part_export->exporttype %> to <% $part_export->machine %>
+<% include( '/elements/table.html' ) %>
- <% foreach my $field ( keys %efields ) { %>
+% foreach my $field ( keys %efields ) {
+
- <%= $efields{$field}->{name} %>
- <%= $efields{$field}->{attrib} %>
+ <% $efields{$field}->{name} %>
+ <% $efields{$field}->{attrib} %>
|
- <% } %>
+% }
+
-<% foreach my $session (
- @{ $part_export->usage_sessions(
- $beginning, $ending, $cgi_svc_acct, $ip, $prefix, ) }
- ) {
-%>
+% foreach my $session (
+% @{ $part_export->usage_sessions(
+% $beginning, $ending, $cgi_svc_acct, $ip, $prefix, ) }
+% ) {
+%
+
- <% foreach my $field ( keys %efields ) { %>
- |
- <%= &{ $efields{$field}->{fmt} }( $session->{$field},
+% foreach my $field ( keys %efields ) {
+
+ |
+ <% &{ $efields{$field}->{fmt} }( $session->{$field},
$session,
$part_export,
)
%>
|
- <% } %>
+% }
+
-<% } %>
+% }
+
+% }
-<% } %>