Merge branch 'patch-18' of https://github.com/gjones2/Freeside
[freeside.git] / 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 %            'session_status'  => $status,
55 %            'starttime_start' => $starttime_beginning,
56 %            'starttime_end'   => $starttime_ending,
57 %            'svc_acct'        => $cgi_svc_acct,
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_acct = '';
136 if ( $cgi->param('svcnum') =~ /^(\d+)$/ ) {
137   $cgi_svc_acct = qsearchs( 'svc_acct', { 'svcnum' => $1 } );
138 } elsif ( $cgi->param('username') =~ /^([^@]+)\@([^@]+)$/ ) {
139   my %search = { 'username' => $1 };
140   my $svc_domain = qsearchs('svc_domain', { 'domain' => $2 } );
141   if ( $svc_domain ) {
142     $search{'domsvc'} = $svc_domain->svcnum;
143   } else {
144     delete $search{'username'};
145   }
146   $cgi_svc_acct = qsearchs( 'svc_acct', \%search )
147     if keys %search;
148 } elsif ( $cgi->param('username') =~ /^(.+)$/ ) {
149   $cgi_svc_acct = qsearchs( 'svc_acct', { 'username' => $1 } );
150 }
151
152 my $ip = '';
153 if ( $cgi->param('ip') =~ /^((\d+\.){3}\d+)$/ ) {
154   $ip = $1;
155 }
156
157 my $prefix = $cgi->param('prefix');
158 $prefix =~ s/\D//g;
159 if ( $prefix =~ /^(\d+)$/ ) {
160   $prefix = $1;
161   $prefix = "011$prefix" unless $prefix =~ /^1/;
162 } else {
163   $prefix = '';
164 }
165
166 ###
167 # field formatting subroutines
168 ###
169
170 my %user2svc_acct = ();
171 my $user_format = sub {
172   my ( $user, $session, $part_export ) = @_;
173
174   my $svc_acct = '';
175   if ( exists $user2svc_acct{$user} ) {
176     $svc_acct = $user2svc_acct{$user};
177   } else {
178     my %search = ();
179     if ( $part_export->exporttype eq 'sqlradius_withdomain' ) {
180       my $domain;
181       if ( $user =~ /^([^@]+)\@([^@]+)$/ ) {
182        $search{'username'} = $1;
183        $domain = $2;
184      } else {
185        $search{'username'} = $user;
186        $domain = $session->{'realm'};
187      }
188      my $svc_domain = qsearchs('svc_domain', { 'domain' => $domain } );
189      if ( $svc_domain ) {
190        $search{'domsvc'} = $svc_domain->svcnum;
191      } else {
192        delete $search{'username'};
193      }
194     } elsif ( $part_export->exporttype eq 'sqlradius' ) {
195       $search{'username'} = $user;
196     } else {
197       die 'unknown export type '. $part_export->exporttype.
198           " for $part_export\n";
199     }
200     if ( keys %search ) {
201       my @svc_acct =
202         grep { qsearchs( 'export_svc', {
203                  'exportnum' => $part_export->exportnum,
204                  'svcpart'   => $_->cust_svc->svcpart,
205                } )
206              } qsearch( 'svc_acct', \%search );
207       if ( @svc_acct ) {
208         warn 'multiple svc_acct records for user $user found; '.
209              'using first arbitrarily'
210           if scalar(@svc_acct) > 1;
211         $user2svc_acct{$user} = $svc_acct = shift @svc_acct;
212       }
213     } 
214   }
215
216   if ( $svc_acct ) { 
217     my $svcnum = $svc_acct->svcnum;
218     qq(<A HREF="${p}view/svc_acct.cgi?$svcnum"><B>$user</B></A>);
219   } else {
220     "<B>$user</B>";
221   }
222
223 };
224
225 my $customer_format = sub {
226   my( $unused, $session ) = @_;
227   return '&nbsp;' unless exists $user2svc_acct{$session->{'username'}};
228   my $svc_acct = $user2svc_acct{$session->{'username'}};
229   my $cust_pkg = $svc_acct->cust_svc->cust_pkg;
230   return '&nbsp;' unless $cust_pkg;
231   my $cust_main = $cust_pkg->cust_main;
232
233   qq!<A HREF="${p}view/cust_main.cgi?!. $cust_main->custnum. '">'.
234     $cust_pkg->cust_main->name. '</A>';
235 };
236
237 my $time_format = sub {
238   my $time = shift;
239   return '&nbsp;' if $time == 0;
240   my $pretty = time2str('%T%P %a&nbsp;%b&nbsp;%o&nbsp;%Y', $time );
241   $pretty =~ s/ (\d)(st|dn|rd|th)/$1$2/;
242   $pretty;
243 };
244
245 my $time_format_or_open = sub {
246   my $time = shift;
247   return '<CENTER>OPEN</CENTER>' if $time == 0;
248   &{$time_format}($time);
249 };
250
251 my $duration_format = sub {
252   my $seconds = shift;
253   return '' if $seconds eq ''; # open session
254   my $hour = int($seconds/3600);
255   my $min = int( ($seconds%3600) / 60 );
256   my $sec = $seconds%60;
257   '<TABLE CLASS="inv" BORDER=0 CELLSPACING=0 CELLPADDING=0>'.
258   '<TR><TD CLASS="inv" ALIGN="right">'.
259      ( $hour ? "<B>$hour</B>h" : '&nbsp;' ).
260    '</TD><TD CLASS="inv" ALIGN="right">'.
261      ( ( $hour || $min ) ? "<B>$min</B>m" : '&nbsp;' ).
262    '</TD><TD CLASS="inv" ALIGN="right">'.
263      "<B>$sec</B>s".
264   '</TD></TR></TABLE>';
265 };
266
267 my $octets_format = sub {
268   my $octets = shift;
269   my $megs = $octets / 1048576;
270   sprintf('<B>%.3f</B>&nbsp;megs', $megs);
271   #my $gigs = $octets / 1073741824
272   #sprintf('<B>%.3f</B> gigabytes', $gigs);
273 };
274
275 ###
276 # the fields
277 ###
278
279 my %fields;
280 if ( $summarize ) {
281 tie %fields, 'Tie::IxHash', 
282   'username'          => {
283                            name    => 'User',
284                            attrib  => 'UserName',
285                            fmt     => $user_format,
286                            align   => 'left',
287                          },
288   'dummy'             => {
289                            name    => 'Customer',
290                            attrib  => '',
291                            fmt     => $customer_format,
292                            align   => 'left',
293                          },
294   'acctsessiontime'   => {
295                            name    => 'Duration',
296                            attrib  => 'Acct-Session-Time',
297                            fmt     => $duration_format,
298                            align   => 'right',
299                          },
300   'acctinputoctets'   => {
301                            name    => 'Upload', # (from user)',
302                            attrib  => 'Acct-Input-Octets',
303                            fmt     => $octets_format,
304                            align   => 'right',
305                          },
306   'acctoutputoctets'  => {
307                            name    => 'Download', # (to user)',
308                            attrib  => 'Acct-Output-Octets',
309                            fmt     => $octets_format,
310                            align   => 'right',
311                          },
312 ;
313 } else {
314 tie %fields, 'Tie::IxHash',
315   'username'          => {
316                            name    => 'User',
317                            attrib  => 'UserName',
318                            fmt     => $user_format,
319                            align   => 'left',
320                          },
321   'realm'             => {
322                            name    => 'Realm',
323                            attrib  => 'Realm',
324                            align   => 'left',
325                          },
326   'dummy'             => {
327                            name    => 'Customer',
328                            attrib  => '',
329                            fmt     => $customer_format,
330                            align   => 'left',
331                          },
332   'framedipaddress'   => {
333                            name    => 'IP&nbsp;Address',
334                            attrib  => 'Framed-IP-Address',
335                            fmt     => sub { my $ip = shift;
336                                             length($ip) ? $ip : '&nbsp';
337                                           },
338                            align   => 'right',
339                          },
340   'acctstarttime'     => {
341                            name    => 'Start&nbsp;time',
342                            attrib  => 'Acct-Start-Time',
343                            fmt     => $time_format,
344                            align   => 'left',
345                          },
346   'acctstoptime'      => {
347                            name    => 'End&nbsp;time',
348                            attrib  => 'Acct-Stop-Time',
349                            fmt     => $time_format_or_open,
350                            align   => 'left',
351                          },
352   'acctsessiontime'   => {
353                            name    => 'Duration',
354                            attrib  => 'Acct-Session-Time',
355                            fmt     => $duration_format,
356                            align   => 'right',
357                          },
358   'acctinputoctets'   => {
359                            name    => 'Upload', # (from user)',
360                            attrib  => 'Acct-Input-Octets',
361                            fmt     => $octets_format,
362                            align   => 'right',
363                          },
364   'acctoutputoctets'  => {
365                            name    => 'Download', # (to user)',
366                            attrib  => 'Acct-Output-Octets',
367                            fmt     => $octets_format,
368                            align   => 'right',
369                          },
370 ;
371 }
372 $fields{$_}->{fmt} ||= sub { length($_[0]) ? shift : '&nbsp'; }
373   foreach keys %fields;
374
375 </%init>