httemplate/search/sqlradius.cgi

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