more info in error message for unknown export type, fix test for sqlradius_withdomain...
[freeside.git] / 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   ###
55   # field formatting subroutines
56   ###
57
58   my %user2svc_acct = ();
59   my $user_format = sub {
60     my ( $user, $session, $part_export ) = @_;
61
62     my $svc_acct = '';
63     if ( exists $user2svc_acct{$user} ) {
64       $svc_acct = $user2svc_acct{$user};
65     } else {
66       my %search = ();
67       if ( $part_export->exporttype eq 'sqlradius_withdomain' ) {
68         my $domain;
69         if ( $user =~ /^([^@]+)\@([^@]+)$/ ) {
70          $search{'username'} = $1;
71          $domain = $2;
72        } else {
73          $search{'username'} = $user;
74          $domain = $session->{'realm'};
75        }
76        my $svc_domain = qsearchs('svc_domain', { 'domain' => $domain } );
77        if ( $svc_domain ) {
78          $search{'domsvc'} = $svc_domain->svcnum;
79        } else {
80          delete $search{'username'};
81        }
82       } elsif ( $part_export->exporttype eq 'sqlradius' ) {
83         $search{'username'} = $user;
84       } else {
85         die 'unknown export type '. $part_export->exporttype.
86             " for $part_export\n";
87       }
88       if ( keys %search ) {
89         my @svc_acct =
90           grep { qsearchs( 'export_svc', {
91                    'exportnum' => $part_export->exportnum,
92                    'svcpart'   => $_->cust_svc->svcpart,
93                  } )
94                } qsearch( 'svc_acct', \%search );
95         if ( @svc_acct ) {
96           warn 'multiple svc_acct records for user $user found; '.
97                'using first arbitrarily'
98             if scalar(@svc_acct) > 1;
99           $user2svc_acct{$user} = $svc_acct = shift @svc_acct;
100         }
101       } 
102     }
103
104     if ( $svc_acct ) { 
105       my $svcnum = $svc_acct->svcnum;
106       qq(<A HREF="${p}view/svc_acct.cgi?$svcnum"><B>$user</B></A>);
107     } else {
108       "<B>$user</B>";
109     }
110
111   };
112
113   my $customer_format = sub {
114     my( $unused, $session ) = @_;
115     return '&nbsp;' unless exists $user2svc_acct{$session->{'username'}};
116     my $svc_acct = $user2svc_acct{$session->{'username'}};
117     my $cust_pkg = $svc_acct->cust_svc->cust_pkg;
118     return '&nbsp;' unless $cust_pkg;
119     my $cust_main = $cust_pkg->cust_main;
120
121     qq!<A HREF="${p}view/cust_main.cgi?!. $cust_main->custnum. '">'.
122       $cust_pkg->cust_main->name. '</A>';
123   };
124
125   my $time_format = sub {
126     my $time = shift;
127     return '&nbsp;' if $time == 0;
128     my $pretty = time2str('%T%P %a&nbsp;%b&nbsp;%o&nbsp;%Y', $time );
129     $pretty =~ s/ (\d)(st|dn|rd|th)/$1$2/;
130     $pretty;
131   };
132
133   my $duration_format = sub {
134     my $seconds = shift;
135     my $hour = int($seconds/3600);
136     my $min = int( ($seconds%3600) / 60 );
137     my $sec = $seconds%60;
138     '<TABLE BORDER=0 CELLSPACING=0 CELLPADDING=0>'.
139     '<TR><TD ALIGN="right">'.
140        ( $hour ? "<B>$hour</B>h" : '&nbsp;' ).
141      '</TD><TD ALIGN="right">'.
142        ( ( $hour || $min ) ? "<B>$min</B>m" : '&nbsp;' ).
143      '</TD><TD ALIGN="right">'.
144        "<B>$sec</B>s".
145     '</TD></TR></TABLE>';
146   };
147
148   my $octets_format = sub {
149     my $octets = shift;
150     my $megs = $octets / 1048576;
151     sprintf('<B>%.3f</B>&nbsp;megs', $megs);
152     #my $gigs = $octets / 1073741824
153     #sprintf('<B>%.3f</B> gigabytes', $gigs);
154   };
155
156   ###
157   # the fields
158   ###
159
160   tie my %fields, 'Tie::IxHash', 
161     'username'          => {
162                              name    => 'User',
163                              attrib  => 'UserName',
164                              fmt     => $user_format,
165                              align   => 'left',
166                            },
167     'realm'             => {
168                              name    => 'Realm',
169                              attrib  => 'Realm',
170                              align   => 'left',
171                            },
172     'dummy'             => {
173                              name    => 'Customer',
174                              attrib  => '',
175                              fmt     => $customer_format,
176                              align   => 'left',
177                            },
178     'framedipaddress'   => {
179                              name    => 'IP&nbsp;Address',
180                              attrib  => 'Framed-IP-Address',
181                              fmt     => sub { my $ip = shift;
182                                               length($ip) ? $ip : '&nbsp';
183                                             },
184                              align   => 'right',
185                            },
186     'acctstarttime'     => {
187                              name    => 'Start&nbsp;time',
188                              attrib  => 'Acct-Start-Time',
189                              fmt     => $time_format,
190                              align   => 'left',
191                            },
192     'acctstoptime'      => {
193                              name    => 'End&nbsp;time',
194                              attrib  => 'Acct-Stop-Time',
195                              fmt     => $time_format,
196                              align   => 'left',
197                            },
198     'acctsessiontime'   => {
199                              name    => 'Duration',
200                              attrib  => 'Acct-Session-Time',
201                              fmt     => $duration_format,
202                              align   => 'right',
203                            },
204     'acctinputoctets'   => {
205                              name    => 'Upload', # (from user)',
206                              attrib  => 'Acct-Input-Octets',
207                              fmt     => $octets_format,
208                              align   => 'right',
209                            },
210     'acctoutputoctets'  => {
211                              name    => 'Download', # (to user)',
212                              attrib  => 'Acct-Output-Octets',
213                              fmt     => $octets_format,
214                              align   => 'right',
215                            },
216   ;
217   $fields{$_}->{fmt} ||= sub { length($_[0]) ? shift : '&nbsp'; }
218     foreach keys %fields;
219
220   ###
221   # and finally, display the thing
222   ### 
223
224   foreach my $part_export ( map $_->rebless, 
225     qsearch( 'part_export', { 'exporttype' => 'sqlradius' } ),
226     qsearch( 'part_export', { 'exporttype' => 'sqlradius_withdomain' } )
227   ) {
228     %user2svc_acct = ();
229 %>
230
231 <%= $part_export->exporttype %> to <%= $part_export->machine %><BR>
232 <%= include( '/elements/table.html' ) %>
233 <TR>
234   <% foreach my $field ( keys %fields ) { %>
235     <TH>
236       <%= $fields{$field}->{name} %><BR>
237       <FONT SIZE=-2><%= $fields{$field}->{attrib} %></FONT>
238     </TH>
239   <% } %>
240 </TR>
241 <% foreach my $session (
242   @{ $part_export->usage_sessions( $beginning, $ending, $cgi_svc_acct, $ip ) }
243 ) { %>
244   <TR>
245     <% foreach my $field ( keys %fields ) { %>
246       <TD ALIGN="<%= $fields{$field}->{align} %>">
247         <%= &{ $fields{$field}->{fmt} }( $session->{$field},
248                                          $session,
249                                          $part_export,
250                                        )
251         %>
252       </TD>
253     <% } %>
254   </TR>
255 <% } %>
256
257 </TABLE>
258 <BR><BR>
259
260 <% } %>