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 = ();
  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 %            'session_status'  => $status,
  55 %            'starttime_start' => $starttime_beginning,
  56 %            'starttime_end'   => $starttime_ending,
  57 %            'svc'             => $cgi_svc,
  58 %            'ip'              => $ip,
  59 %            'prefix'          => $prefix,
  60 %            'summarize'       => $summarize,
  61 %          } )
  62 %       }
  63 %   ) {
  64 %     if ( $bgcolor eq $bgcolor1 ) {
  65 %       $bgcolor = $bgcolor2;
  66 %     } else {
  67 %       $bgcolor = $bgcolor1;
  68 %     }
  69
  70       <TR>
  71 %     foreach my $field ( keys %efields ) {
  72 %       my $html = &{ $efields{$field}->{fmt} }( $session->{$field},
  73 %                                                $session,
  74 %                                                $part_export,
  75 %                                              );
  76 %       my $class = ( $html =~ /<TABLE/ ? 'inv' : 'grid' );
  77
  78         <TD CLASS="<%$class%>" BGCOLOR="<% $bgcolor %>" ALIGN="<% $efields{$field}->{align} %>">
  79           <% $html %>
  80         </TD>
  81 %     }
  82   </TR>
  83
  84 %   }
  85
  86 </TABLE>
  87 <BR><BR>
  88
  89 % }
  90
  91 <%init>
  92
  93 die "access denied"
  94   unless $FS::CurrentUser::CurrentUser->access_right('List rating data');
  95
  96 ###
  97 # parse cgi params
  98 ###
  99
 100 my $summarize = 0;
 101 $summarize = 1 if $cgi->param('summarize') eq 'Y';
 102
 103 #sort of false laziness w/cust_pay.cgi
 104 my( $beginning, $ending ) = ( '', '' );
 105 if ( $cgi->param('stoptime_beginning')
 106      && $cgi->param('stoptime_beginning') =~ /^([ 0-9\-\/\:\w]{0,54})$/ ) {
 107   $beginning = parse_datetime($1);
 108 }
 109 if ( $cgi->param('stoptime_ending')
 110      && $cgi->param('stoptime_ending') =~ /^([ 0-9\-\/\:\w]{0,54})$/ ) {
 111   $ending = parse_datetime($1); # + 86399;
 112 }
 113 if ( $cgi->param('begin') && $cgi->param('begin') =~ /^(\d+)$/ ) {
 114   $beginning = $1;
 115 }
 116 if ( $cgi->param('end') && $cgi->param('end') =~ /^(\d+)$/ ) {
 117   $ending = $1;
 118 }
 119
 120 my $status = '';
 121 if ( $cgi->param('session_status') =~ /^(closed|open)$/ ) {
 122   $status = $1;
 123 }
 124
 125 my( $starttime_beginning, $starttime_ending ) = ( '', '' );
 126 if ( $cgi->param('starttime_beginning')
 127      && $cgi->param('starttime_beginning') =~ /^([ 0-9\-\/\:\w]{0,54})$/ ) {
 128   $starttime_beginning = parse_datetime($1);
 129 }
 130 if ( $cgi->param('starttime_ending')
 131      && $cgi->param('starttime_ending') =~ /^([ 0-9\-\/\:\w]{0,54})$/ ) {
 132   $starttime_ending = parse_datetime($1); # + 86399;
 133 }
 134
 135 my $cgi_svc = '';
 136 if ( $cgi->param('svcnum') =~ /^(\d+)$/ ) {
 137   $cgi_svc =  qsearchs( 'svc_acct',      { 'svcnum' => $1 } )
 138            || qsearchs( 'svc_broadband', { 'svcnum' => $1 } );
 139 } elsif ( $cgi->param('username') =~ /^([^@]+)\@([^@]+)$/ ) {
 140   my %search = { 'username' => $1 };
 141   my $svc_domain = qsearchs('svc_domain', { 'domain' => $2 } );
 142   if ( $svc_domain ) {
 143     $search{'domsvc'} = $svc_domain->svcnum;
 144   } else {
 145     delete $search{'username'};
 146   }
 147   $cgi_svc = qsearchs( 'svc_acct', \%search )
 148     if keys %search;
 149 } elsif ( $cgi->param('username') =~ /^(.+)$/ ) {
 150   $cgi_svc = qsearchs( 'svc_acct', { 'username' => $1 } );
 151 }
 152
 153 my $ip = '';
 154 if ( $cgi->param('ip') =~ /^((\d+\.){3}\d+)$/ ) {
 155   $ip = $1;
 156 }
 157
 158 my $prefix = $cgi->param('prefix');
 159 $prefix =~ s/\D//g;
 160 if ( $prefix =~ /^(\d+)$/ ) {
 161   $prefix = $1;
 162   $prefix = "011$prefix" unless $prefix =~ /^1/;
 163 } else {
 164   $prefix = '';
 165 }
 166
 167 ###
 168 # field formatting subroutines
 169 ###
 170
 171 my %user2svc = ();
 172 my $user_format = sub {
 173   my ( $user, $session, $part_export ) = @_;
 174
 175   my $svc = '';
 176   if ( exists $user2svc{$user} ) {
 177     $svc = $user2svc{$user};
 178   } else {
 179
 180     if ( $part_export->exporttype eq 'broadband_sqlradius' ) {
 181
 182       ( my $mac = $user ) =~ s/[^0-9a-f]//ig;
 183
 184       my @svc_broadband =
 185         grep { qsearchs( 'export_svc', {
 186                  'exportnum' => $part_export->exportnum,
 187                  'svcpart'   => $_->cust_svc->svcpart,
 188                } )
 189              } qsearch( 'svc_broadband', {
 190                           mac_addr => { op=>'ILIKE', value=>$mac }
 191                       });
 192
 193       if ( @svc_broadband ) {
 194         warn 'multiple svc_broadband records for user $user found; '.
 195              'using first arbitrarily'
 196           if scalar(@svc_broadband) > 1;
 197         $user2svc{$user} = $svc = shift @svc_broadband;
 198       }
 199
 200     } else {
 201
 202       my %search = ();
 203       if ( $part_export->exporttype eq 'sqlradius_withdomain' ) {
 204         my $domain;
 205         if ( $user =~ /^([^@]+)\@([^@]+)$/ ) {
 206          $search{'username'} = $1;
 207          $domain = $2;
 208        } else {
 209          $search{'username'} = $user;
 210          $domain = $session->{'realm'};
 211        }
 212        my $svc_domain = qsearchs('svc_domain', { 'domain' => $domain } );
 213        if ( $svc_domain ) {
 214          $search{'domsvc'} = $svc_domain->svcnum;
 215        } else {
 216          delete $search{'username'};
 217        }
 218       } elsif ( $part_export->exporttype eq 'sqlradius' ) {
 219         $search{'username'} = $user;
 220       } else {
 221         die 'unknown export type '. $part_export->exporttype.
 222             " for $part_export\n";
 223       }
 224       if ( keys %search ) {
 225         my @svc_acct =
 226           grep { qsearchs( 'export_svc', {
 227                    'exportnum' => $part_export->exportnum,
 228                    'svcpart'   => $_->cust_svc->svcpart,
 229                  } )
 230                } qsearch( 'svc_acct', \%search );
 231         if ( @svc_acct ) {
 232           warn 'multiple svc_acct records for user $user found; '.
 233                'using first arbitrarily'
 234             if scalar(@svc_acct) > 1;
 235           $user2svc{$user} = $svc = shift @svc_acct;
 236         }
 237       }
 238
 239     }
 240
 241   }
 242
 243   if ( $svc ) {
 244
 245     #i should use svc_link, but that's expensive per-user
 246     my $svcnum = $svc->svcnum;
 247     my $table = $svc->table;
 248     qq(<A HREF="${p}view/$table.cgi?$svcnum"><B>$user</B></A>);
 249
 250   } else {
 251     "<B>$user</B>";
 252   }
 253
 254 };
 255
 256 my $customer_format = sub {
 257   my( $unused, $session ) = @_;
 258   return '&nbsp;' unless exists $user2svc{$session->{'username'}};
 259   my $svc = $user2svc{$session->{'username'}};
 260   my $cust_pkg = $svc->cust_svc->cust_pkg;
 261   return '&nbsp;' unless $cust_pkg;
 262   my $cust_main = $cust_pkg->cust_main;
 263
 264   qq!<A HREF="${p}view/cust_main.cgi?!. $cust_main->custnum. '">'.
 265     $cust_pkg->cust_main->name. '</A>';
 266 };
 267
 268 my $time_format = sub {
 269   my $time = shift;
 270   return '&nbsp;' if $time == 0;
 271   my $pretty = time2str('%T%P %a&nbsp;%b&nbsp;%o&nbsp;%Y', $time );
 272   $pretty =~ s/ (\d)(st|dn|rd|th)/$1$2/;
 273   $pretty;
 274 };
 275
 276 my $time_format_or_open = sub {
 277   my $time = shift;
 278   return '<CENTER>OPEN</CENTER>' if $time == 0;
 279   &{$time_format}($time);
 280 };
 281
 282 my $duration_format = sub {
 283   my $seconds = shift;
 284   return '' if $seconds eq ''; # open session
 285   my $hour = int($seconds/3600);
 286   my $min = int( ($seconds%3600) / 60 );
 287   my $sec = $seconds%60;
 288   '<TABLE CLASS="inv" BORDER=0 CELLSPACING=0 CELLPADDING=0>'.
 289   '<TR><TD CLASS="inv" ALIGN="right">'.
 290      ( $hour ? "<B>$hour</B>h" : '&nbsp;' ).
 291    '</TD><TD CLASS="inv" ALIGN="right">'.
 292      ( ( $hour || $min ) ? "<B>$min</B>m" : '&nbsp;' ).
 293    '</TD><TD CLASS="inv" ALIGN="right">'.
 294      "<B>$sec</B>s".
 295   '</TD></TR></TABLE>';
 296 };
 297
 298 my $octets_format = sub {
 299   my $octets = shift;
 300   my $megs = $octets / 1048576;
 301   sprintf('<B>%.3f</B>&nbsp;megs', $megs);
 302   #my $gigs = $octets / 1073741824
 303   #sprintf('<B>%.3f</B> gigabytes', $gigs);
 304 };
 305
 306 ###
 307 # the fields
 308 ###
 309
 310 my %fields;
 311 if ( $summarize ) {
 312 tie %fields, 'Tie::IxHash',
 313   'username'          => {
 314                            name    => 'User',
 315                            attrib  => 'UserName',
 316                            fmt     => $user_format,
 317                            align   => 'left',
 318                          },
 319   'dummy'             => {
 320                            name    => 'Customer',
 321                            attrib  => '',
 322                            fmt     => $customer_format,
 323                            align   => 'left',
 324                          },
 325   'acctsessiontime'   => {
 326                            name    => 'Duration',
 327                            attrib  => 'Acct-Session-Time',
 328                            fmt     => $duration_format,
 329                            align   => 'right',
 330                          },
 331   'acctinputoctets'   => {
 332                            name    => 'Upload', # (from user)',
 333                            attrib  => 'Acct-Input-Octets',
 334                            fmt     => $octets_format,
 335                            align   => 'right',
 336                          },
 337   'acctoutputoctets'  => {
 338                            name    => 'Download', # (to user)',
 339                            attrib  => 'Acct-Output-Octets',
 340                            fmt     => $octets_format,
 341                            align   => 'right',
 342                          },
 343 ;
 344 } else {
 345 tie %fields, 'Tie::IxHash',
 346   'username'          => {
 347                            name    => 'User',
 348                            attrib  => 'UserName',
 349                            fmt     => $user_format,
 350                            align   => 'left',
 351                          },
 352   'realm'             => {
 353                            name    => 'Realm',
 354                            attrib  => 'Realm',
 355                            align   => 'left',
 356                          },
 357   'dummy'             => {
 358                            name    => 'Customer',
 359                            attrib  => '',
 360                            fmt     => $customer_format,
 361                            align   => 'left',
 362                          },
 363   'framedipaddress'   => {
 364                            name    => 'IP&nbsp;Address',
 365                            attrib  => 'Framed-IP-Address',
 366                            fmt     => sub { my $ip = shift;
 367                                             length($ip) ? $ip : '&nbsp';
 368                                           },
 369                            align   => 'right',
 370                          },
 371   'acctstarttime'     => {
 372                            name    => 'Start&nbsp;time',
 373                            attrib  => 'Acct-Start-Time',
 374                            fmt     => $time_format,
 375                            align   => 'left',
 376                          },
 377   'acctstoptime'      => {
 378                            name    => 'End&nbsp;time',
 379                            attrib  => 'Acct-Stop-Time',
 380                            fmt     => $time_format_or_open,
 381                            align   => 'left',
 382                          },
 383   'acctsessiontime'   => {
 384                            name    => 'Duration',
 385                            attrib  => 'Acct-Session-Time',
 386                            fmt     => $duration_format,
 387                            align   => 'right',
 388                          },
 389   'acctinputoctets'   => {
 390                            name    => 'Upload', # (from user)',
 391                            attrib  => 'Acct-Input-Octets',
 392                            fmt     => $octets_format,
 393                            align   => 'right',
 394                          },
 395   'acctoutputoctets'  => {
 396                            name    => 'Download', # (to user)',
 397                            attrib  => 'Acct-Output-Octets',
 398                            fmt     => $octets_format,
 399                            align   => 'right',
 400                          },
 401 ;
 402 }
 403 $fields{$_}->{fmt} ||= sub { length($_[0]) ? shift : '&nbsp'; }
 404   foreach keys %fields;
 405
 406 </%init>