X-Git-Url: http://git.freeside.biz/gitweb/?a=blobdiff_plain;f=httemplate%2Fsearch%2Fcdr.html;h=e57913e5f8f24126659eb9c78d3fa05963ff862b;hb=2b199169bd62b8582eedb872b4e76bee48899e81;hp=bf59ff625bcac6eb831001ca86db49c527fb7676;hpb=b5c4237a34aef94976bc343c8d9e138664fc3984;p=freeside.git diff --git a/httemplate/search/cdr.html b/httemplate/search/cdr.html index bf59ff625..e57913e5f 100644 --- a/httemplate/search/cdr.html +++ b/httemplate/search/cdr.html @@ -1,53 +1,16 @@ -<% include( 'elements/search.html', +<& elements/search.html, 'title' => $title, 'name' => 'call detail records', - - 'query' => { 'table' => 'cdr', - 'hashref' => $hashref, - 'extra_sql' => $qsearch, - 'order_by' => 'ORDER BY calldate', - }, + 'query' => $query, 'count_query' => $count_query, - 'count_addl' => [ $totalminutes_sub ], - 'header' => [ - '', # checkbox column - @header, - ], - 'fields' => [ - sub { - return '' unless $edit_data; - $areboxes = 1; - my $cdr = shift; - my $acctid = $cdr->acctid; - qq!!; - }, - @fields, #XXX fill in some pretty-print - #processing, etc. - ], + 'count_addl' => $nototalminutes ? '' : [ $totalminutes_sub ], + 'disable_total' => $topmode ? 1 : '', + 'header' => \@header, + 'fields' => \@fields, 'links' => \@links, - 'html_form' => qq!
!, - #false laziness w/queue.html - 'html_foot' => sub { - if ( $areboxes ) { - '
'. - ''. - qq!
!. - qq!
!. - ''; - } else { - ''; - } - }, - ) -%> + 'html_foot' => $html_foot, +&> <%init> die "access denied" @@ -62,8 +25,6 @@ my $totalminutes_sub = sub { my $conf = new FS::Conf; -my $areboxes = 0; - my $title = 'Call Detail Records'; my $hashref = {}; @@ -98,21 +59,40 @@ my @qsearch = @search; # freesidestatus ### -if ( $cgi->param('freesidestatus') eq 'NULL' ) { +my $status = $cgi->param('freesidestatus'); +if ( $status eq 'NULL' ) { $title = "Unprocessed $title"; $hashref->{'freesidestatus'} = ''; # Record.pm will take care of it push @search, "( freesidestatus IS NULL OR freesidestatus = '' )"; -} elsif ( $cgi->param('freesidestatus') =~ /^([\w ]+)$/ ) { - - $title = "Processed $title"; +} elsif ( $status =~ /^([\w ]+)$/ ) { + + if ( $status eq 'done' ) { + $title = "Processed $title"; + } + elsif ( $status eq 'failed' ) { + $title = "Skipped $title"; + } $hashref->{'freesidestatus'} = $1; push @search, "freesidestatus = '$1'"; } ### +# cdrtypenum +### + +if ( $cgi->param('cdrtypenum') =~ /^(\d+)$/ ) { + $hashref->{'cdrtypenum'} = $1; + push @search, "cdrtypenum = $1"; +} +elsif ( $cgi->param('cdrtypenum') eq 'none' ) { + $hashref->{'cdrtypenum'} = ''; + push @search, "cdrtypenum is null"; +} + +### # termpartNstatus ### @@ -182,7 +162,7 @@ if ( $cgi->param('dst') ) { if ( $cgi->param('dcontext') =~ /^\s*(.+)\s*$/ ) { my $dcontext = $1; $hashref->{'dcontext'} = $dcontext; - push @search, "dcontext = '$dcontext'"; + push @search, 'dcontext = '. dbh->quote($dcontext); } if ( $cgi->param('charged_party') ) { @@ -208,6 +188,12 @@ if ( $cgi->param('charged_party_or_src') ) { push @qsearch, $search; } +if ( $cgi->param('lastapp') =~ /^\s*(.+)\s*$/ ) { + my $lastapp = $1; + $hashref->{'lastapp'} = $lastapp; + push @search, 'lastapp = '. dbh->quote($lastapp); +} + if ( $cgi->param('svcnum') =~ /^([\d, ]+)$/ ) { my $svcnum = $1; my $search = "svcnum IN ($svcnum)"; @@ -216,6 +202,17 @@ if ( $cgi->param('svcnum') =~ /^([\d, ]+)$/ ) { } ### +# src/dst_ip_addr +### +foreach my $field ('src_ip_addr','dst_ip_addr') { + if ( $cgi->param($field) ) { + my $search = FS::cdr->ip_addr_sql($field, $cgi->param($field)); + push @search, $search; + push @qsearch, $search; + } +} + +### # cdrbatchnum (or legacy cdrbatch) ### @@ -261,9 +258,28 @@ if ( $cgi->param('acctid') =~ /\d/ ) { } ### +# accountcode +### + +if ( $cgi->param('accountcode') =~ /\S/ ) { + my $accountcode = $cgi->param('accountcode'); + my @accountcode = map { + ( my $v = $_ ) =~ s/^\s+|\s+$//g; # trim margin whitespace + length $v ? dbh->quote($v) : () + } grep /\S/, split /\R/, $accountcode; # collect non-trivial lines + if (@accountcode) { + my $search = 'accountcode IN ( ' . join( ',', @accountcode ) . ' )'; + push @qsearch, $search; + push @search, $search; + } +} + +### # finish it up ### +my $nototalminutes = 0; + my $search = join(' AND ', @search); $search = "WHERE $search" if $search; @@ -273,21 +289,45 @@ my $qsearch = join(' AND ', @qsearch); $qsearch = ( scalar(keys %$hashref) ? ' AND ' : ' WHERE ' ) . $qsearch if $qsearch; +my $query = { 'table' => 'cdr', + 'hashref' => $hashref, + 'extra_sql' => $qsearch, + 'order_by' => 'ORDER BY calldate', + }; + +if ( $cgi->param('longest') =~ /^(\d+)$/ && $cgi->param('longest') > 0 ) { + $cgi->param('maxrecords',$1); + $count_query = "SELECT $1"; + $query->{'order_by'} = 'ORDER BY billsec desc'; + $nototalminutes = 1; +} + + ### # display fields ### my %header = %{ FS::cdr->table_info->{'fields'} }; +$header{ratename} = 'Rate plan'; my @first = qw( acctid calldate clid charged_party src dst dcontext ); my %first = map { $_=>1 } @first; -my @fields = ( @first, grep !$first{$_}, fields('cdr') ); +my @fields = ( @first, + grep !$first{$_}, ( fields('cdr'), 'ratename' ) + ); if ( $cgi->param('show') ) { @fields = grep $cgi->param("show_$_"), @fields; } +if ( grep { $_ eq 'ratename' } @fields ) { + $query->{addl_from} .= ' + LEFT JOIN rate_detail ON (cdr.rated_ratedetailnum = rate_detail.ratedetailnum) + LEFT JOIN rate ON (rate_detail.ratenum = rate.ratenum) + '; +} + my @header = map { if ( exists($header{$_}) ) { $header{$_}; @@ -297,6 +337,7 @@ my @header = map { ucfirst($header); } } @fields; +unshift @header, ' '; my $date_sub_factory = sub { my $column = shift; @@ -318,8 +359,69 @@ my %links = ( ); @fields = map { exists($fields{$_}) ? $fields{$_} : $_ } @fields; +unshift @fields, sub { + return '' unless $edit_data; + my $cdr = shift; + my $acctid = $cdr->acctid; + qq!!; + }; - #checkbox column -my @links = ( '', map { exists($links{$_}) ? $links{$_} : '' } @fields ); +my @links = ( map { exists($links{$_}) ? $links{$_} : '' } @fields ); + +### +# top dst / top src +### + +my $topmode = 0; + +if ( $cgi->param('top_dst') =~ /^(\d+)$/ && $cgi->param('top_dst') > 0 ) { + $topmode = $1; + @fields = ('dst'); + @header = ('Destination'); +} +elsif ( $cgi->param('top_src') =~ /^(\d+)$/ && $cgi->param('top_src') > 0 ) { + $topmode = $1; + @fields = ('src'); + @header = ('Source'); +} + +if ( $topmode ) { + my $whichfield = $fields[0]; + $query = { 'select' => "$whichfield, count(1) as cnt", + 'table' => 'cdr', + 'hashref' => {}, + 'extra_sql' => "$search + group by $whichfield + order by cnt desc", + }; + $count_query = "SELECT $topmode"; + + # this is weird, maybe we should change search.html + $cgi->param('maxrecords',$topmode); + + # kind of hacked + my $link = "${p}search/cdr.html?".$cgi->query_string; + $link =~ s/;top_(dst|src)=(\d+|)//g; + $link =~ s/;maxrecords=(\d+|)//; + $link =~ s/;(src|dst)=(\d+|)//g; + $link = [ "$link;$whichfield=", sub { shift->$whichfield } ]; + @links = ($link); + + push @fields, 'cnt'; + push @header, '# Calls'; + + $nototalminutes = 1; +} + +my $html_foot = include('/search/elements/checkbox-foot.html', + actions => [ + { submit => "reprocess selected", + name => "action", + confirm => "Are you sure you want to reprocess the selected CDRs?" }, + { submit => "delete selected", + name => "action", + confirm => "Are you sure you want to delete the selected CDRs?" }, + ] +);