httemplate/search/sqlradius.cgi

   1 <%= include( '/elements/header.html', 'RADIUS Sessions',
   2              include('/elements/menubar.html',
   3                        'Main menu' => $p, # popurl(2),
   4                     ),
   5
   6     )
   7 %>
   8
   9 <%
  10   ###
  11   # parse cgi params
  12   ###
  13
  14   #sort of false laziness w/cust_pay.cgi
  15   my $beginning = '';
  16   my $ending = '';
  17   if ( $cgi->param('beginning')
  18        && $cgi->param('beginning') =~ /^([ 0-9\-\/]{0,10})$/ ) {
  19     $beginning = str2time($1);
  20   }
  21   if ( $cgi->param('ending')
  22        && $cgi->param('ending') =~ /^([ 0-9\-\/]{0,10})$/ ) {
  23     $ending = str2time($1) + 86399;
  24   }
  25   if ( $cgi->param('begin') && $cgi->param('begin') =~ /^(\d+)$/ ) {
  26     $beginning = $1;
  27   }
  28   if ( $cgi->param('end') && $cgi->param('end') =~ /^(\d+)$/ ) {
  29     $ending = $1;
  30   }
  31
  32   my $cgi_svc_acct = '';
  33   if ( $cgi->param('svcnum') =~ /^(\d+)$/ ) {
  34     $cgi_svc_acct = qsearchs( 'svc_acct', { 'svcnum' => $1 } );
  35   } elsif ( $cgi->param('username') =~ /^([^@]+)\@([^@]+)$/ ) {
  36     my %search = { 'username' => $1 };
  37     my $svc_domain = qsearchs('svc_domain', { 'domain' => $2 } );
  38     if ( $svc_domain ) {
  39       $search{'domsvc'} = $svc_domain->svcnum;
  40     } else {
  41       delete $search{'username'};
  42     }
  43     $cgi_svc_acct = qsearchs( 'svc_acct', \%search )
  44       if keys %search;
  45   } elsif ( $cgi->param('username') =~ /^(.+)$/ ) {
  46     $cgi_svc_acct = qsearchs( 'svc_acct', { 'username' => $1 } );
  47   }
  48
  49   my $ip = '';
  50   if ( $cgi->param('ip') =~ /^((\d+\.){3}\d+)$/ ) {
  51     $ip = $1;
  52   }
  53
  54   my $prefix = $cgi->param('prefix');
  55   $prefix =~ s/\D//g;
  56   if ( $prefix =~ /^(\d+)$/ ) {
  57     $prefix = $1;
  58     $prefix = "011$prefix" unless $prefix =~ /^1/;
  59   } else {
  60     $prefix = '';
  61   }
  62
  63   ###
  64   # field formatting subroutines
  65   ###
  66
  67   my %user2svc_acct = ();
  68   my $user_format = sub {
  69     my ( $user, $session, $part_export ) = @_;
  70
  71     my $svc_acct = '';
  72     if ( exists $user2svc_acct{$user} ) {
  73       $svc_acct = $user2svc_acct{$user};
  74     } else {
  75       my %search = ();
  76       if ( $part_export->exporttype eq 'sqlradius_withdomain' ) {
  77         my $domain;
  78         if ( $user =~ /^([^@]+)\@([^@]+)$/ ) {
  79          $search{'username'} = $1;
  80          $domain = $2;
  81        } else {
  82          $search{'username'} = $user;
  83          $domain = $session->{'realm'};
  84        }
  85        my $svc_domain = qsearchs('svc_domain', { 'domain' => $domain } );
  86        if ( $svc_domain ) {
  87          $search{'domsvc'} = $svc_domain->svcnum;
  88        } else {
  89          delete $search{'username'};
  90        }
  91       } elsif ( $part_export->exporttype eq 'sqlradius' ) {
  92         $search{'username'} = $user;
  93       } else {
  94         die 'unknown export type '. $part_export->exporttype.
  95             " for $part_export\n";
  96       }
  97       if ( keys %search ) {
  98         my @svc_acct =
  99           grep { qsearchs( 'export_svc', {
 100                    'exportnum' => $part_export->exportnum,
 101                    'svcpart'   => $_->cust_svc->svcpart,
 102                  } )
 103                } qsearch( 'svc_acct', \%search );
 104         if ( @svc_acct ) {
 105           warn 'multiple svc_acct records for user $user found; '.
 106                'using first arbitrarily'
 107             if scalar(@svc_acct) > 1;
 108           $user2svc_acct{$user} = $svc_acct = shift @svc_acct;
 109         }
 110       }
 111     }
 112
 113     if ( $svc_acct ) {
 114       my $svcnum = $svc_acct->svcnum;
 115       qq(<A HREF="${p}view/svc_acct.cgi?$svcnum"><B>$user</B></A>);
 116     } else {
 117       "<B>$user</B>";
 118     }
 119
 120   };
 121
 122   my $customer_format = sub {
 123     my( $unused, $session ) = @_;
 124     return '&nbsp;' unless exists $user2svc_acct{$session->{'username'}};
 125     my $svc_acct = $user2svc_acct{$session->{'username'}};
 126     my $cust_pkg = $svc_acct->cust_svc->cust_pkg;
 127     return '&nbsp;' unless $cust_pkg;
 128     my $cust_main = $cust_pkg->cust_main;
 129
 130     qq!<A HREF="${p}view/cust_main.cgi?!. $cust_main->custnum. '">'.
 131       $cust_pkg->cust_main->name. '</A>';
 132   };
 133
 134   my $time_format = sub {
 135     my $time = shift;
 136     return '&nbsp;' if $time == 0;
 137     my $pretty = time2str('%T%P %a&nbsp;%b&nbsp;%o&nbsp;%Y', $time );
 138     $pretty =~ s/ (\d)(st|dn|rd|th)/$1$2/;
 139     $pretty;
 140   };
 141
 142   my $duration_format = sub {
 143     my $seconds = shift;
 144     my $hour = int($seconds/3600);
 145     my $min = int( ($seconds%3600) / 60 );
 146     my $sec = $seconds%60;
 147     '<TABLE BORDER=0 CELLSPACING=0 CELLPADDING=0>'.
 148     '<TR><TD ALIGN="right">'.
 149        ( $hour ? "<B>$hour</B>h" : '&nbsp;' ).
 150      '</TD><TD ALIGN="right">'.
 151        ( ( $hour || $min ) ? "<B>$min</B>m" : '&nbsp;' ).
 152      '</TD><TD ALIGN="right">'.
 153        "<B>$sec</B>s".
 154     '</TD></TR></TABLE>';
 155   };
 156
 157   my $octets_format = sub {
 158     my $octets = shift;
 159     my $megs = $octets / 1048576;
 160     sprintf('<B>%.3f</B>&nbsp;megs', $megs);
 161     #my $gigs = $octets / 1073741824
 162     #sprintf('<B>%.3f</B> gigabytes', $gigs);
 163   };
 164
 165   ###
 166   # the fields
 167   ###
 168
 169   tie my %fields, 'Tie::IxHash',
 170     'username'          => {
 171                              name    => 'User',
 172                              attrib  => 'UserName',
 173                              fmt     => $user_format,
 174                              align   => 'left',
 175                            },
 176     'realm'             => {
 177                              name    => 'Realm',
 178                              attrib  => 'Realm',
 179                              align   => 'left',
 180                            },
 181     'dummy'             => {
 182                              name    => 'Customer',
 183                              attrib  => '',
 184                              fmt     => $customer_format,
 185                              align   => 'left',
 186                            },
 187     'framedipaddress'   => {
 188                              name    => 'IP&nbsp;Address',
 189                              attrib  => 'Framed-IP-Address',
 190                              fmt     => sub { my $ip = shift;
 191                                               length($ip) ? $ip : '&nbsp';
 192                                             },
 193                              align   => 'right',
 194                            },
 195     'acctstarttime'     => {
 196                              name    => 'Start&nbsp;time',
 197                              attrib  => 'Acct-Start-Time',
 198                              fmt     => $time_format,
 199                              align   => 'left',
 200                            },
 201     'acctstoptime'      => {
 202                              name    => 'End&nbsp;time',
 203                              attrib  => 'Acct-Stop-Time',
 204                              fmt     => $time_format,
 205                              align   => 'left',
 206                            },
 207     'acctsessiontime'   => {
 208                              name    => 'Duration',
 209                              attrib  => 'Acct-Session-Time',
 210                              fmt     => $duration_format,
 211                              align   => 'right',
 212                            },
 213     'acctinputoctets'   => {
 214                              name    => 'Upload', # (from user)',
 215                              attrib  => 'Acct-Input-Octets',
 216                              fmt     => $octets_format,
 217                              align   => 'right',
 218                            },
 219     'acctoutputoctets'  => {
 220                              name    => 'Download', # (to user)',
 221                              attrib  => 'Acct-Output-Octets',
 222                              fmt     => $octets_format,
 223                              align   => 'right',
 224                            },
 225   ;
 226   $fields{$_}->{fmt} ||= sub { length($_[0]) ? shift : '&nbsp'; }
 227     foreach keys %fields;
 228
 229   ###
 230   # and finally, display the thing
 231   ###
 232
 233   foreach my $part_export (
 234     #grep $_->can('usage_sessions'), qsearch( 'part_export' )
 235     qsearch( 'part_export', { 'exporttype' => 'sqlradius' } ),
 236     qsearch( 'part_export', { 'exporttype' => 'sqlradius_withdomain' } )
 237   ) {
 238     %user2svc_acct = ();
 239
 240     my $efields = tie my %efields, 'Tie::IxHash', %fields;
 241     delete $efields{'framedipaddress'} if $part_export->option('hide_ip');
 242     if ( $part_export->option('hide_data') ) {
 243       delete $efields{$_} foreach qw(acctinputoctets acctoutputoctets);
 244     }
 245     if ( $part_export->option('show_called_station') ) {
 246       $efields->Splice(1, 0,
 247         'calledstationid' => {
 248                                'name'   => 'Destination',
 249                                'attrib' => 'Called-Station-ID',
 250                                'fmt'    =>
 251                                  sub { length($_[0]) ? shift : '&nbsp'; },
 252                                'align'  => 'left',
 253                              },
 254       );
 255     }
 256
 257 %>
 258
 259 <%= $part_export->exporttype %> to <%= $part_export->machine %><BR>
 260 <%= include( '/elements/table.html' ) %>
 261 <TR>
 262   <% foreach my $field ( keys %efields ) { %>
 263     <TH>
 264       <%= $efields{$field}->{name} %><BR>
 265       <FONT SIZE=-2><%= $efields{$field}->{attrib} %></FONT>
 266     </TH>
 267   <% } %>
 268 </TR>
 269 <% foreach my $session (
 270      @{ $part_export->usage_sessions(
 271           $beginning, $ending, $cgi_svc_acct, $ip, $prefix, ) }
 272    ) {
 273 %>
 274   <TR>
 275     <% foreach my $field ( keys %efields ) { %>
 276       <TD ALIGN="<%= $efields{$field}->{align} %>">
 277         <%= &{ $efields{$field}->{fmt} }( $session->{$field},
 278                                          $session,
 279                                          $part_export,
 280                                        )
 281         %>
 282       </TD>
 283     <% } %>
 284   </TR>
 285 <% } %>
 286
 287 </TABLE>
 288 <BR><BR>
 289
 290 <% } %>