X-Git-Url: http://git.freeside.biz/gitweb/?a=blobdiff_plain;f=FS%2FFS%2Fsvc_phone.pm;h=a0a2c3effae10115db7bfed61ceaf2df7c880907;hb=f8f4c51eaa6f5aa3d49672fe7a17f19fa22494c0;hp=5d102ce2a522b88bae8a185dfa9c626795ac3187;hpb=f433b4f187e484e8c40bdcebbeb5a5d51b3ae38e;p=freeside.git diff --git a/FS/FS/svc_phone.pm b/FS/FS/svc_phone.pm index 5d102ce2a..a0a2c3eff 100644 --- a/FS/FS/svc_phone.pm +++ b/FS/FS/svc_phone.pm @@ -2,7 +2,7 @@ package FS::svc_phone; use strict; use base qw( FS::svc_Domain_Mixin FS::location_Mixin FS::svc_Common ); -use vars qw( $DEBUG $me @pw_set $conf ); +use vars qw( $DEBUG $me @pw_set $conf $phone_name_max ); use Data::Dumper; use Scalar::Util qw( blessed ); use FS::Conf; @@ -23,6 +23,7 @@ $DEBUG = 0; #ask FS::UID to run this stuff for us later $FS::UID::callback{'FS::svc_acct'} = sub { $conf = new FS::Conf; + $phone_name_max = $conf->config('svc_phone-phone_name-max_length'); }; =head1 NAME @@ -383,6 +384,10 @@ sub check { ; return $error if $error; + return 'Name ('. $self->phone_name. + ") is longer than $phone_name_max characters" + if $phone_name_max && length($self->phone_name) > $phone_name_max; + $self->countrycode(1) unless $self->countrycode; unless ( length($self->sip_password) ) { @@ -520,6 +525,99 @@ sub cust_location_or_main { $cust_pkg ? $cust_pkg->cust_location_or_main : ''; } +=item get_cdrs + +Returns a set of Call Detail Records (see L) associated with this +service. By default, "associated with" means that either the "src" or the +"charged_party" field of the CDR matches the "phonenum" field of the service. + +=over 2 + +Accepts the following options: + +=item for_update => 1: SELECT the CDRs "FOR UPDATE". + +=item status => "" (or "done"): Return only CDRs with that processing status. + +=item inbound => 1: Return CDRs for inbound calls. With "status", will filter +on inbound processing status. + +=item default_prefix => "XXX": Also accept the phone number of the service prepended +with the chosen prefix. + +=item disable_src => 1: Only match on "charged_party", not "src". + +=back + +=cut + +sub get_cdrs { + my($self, %options) = @_; + my @fields; + my %hash; + my @where; + + if ( $options{'inbound'} ) { + @fields = ( 'dst' ); + if ( exists($options{'status'}) ) { + # must be 'done' or '' + my $sq = 'EXISTS ( SELECT 1 FROM cdr_termination '. + 'WHERE cdr.acctid = cdr_termination.acctid '. + 'AND cdr_termination.status = \'done\' '. + 'AND cdr_termination.termpart = 1 )'; + if ( $options{'status'} eq 'done' ) { + push @where, $sq; + } + elsif ($options{'status'} eq '' ) { + push @where, "NOT $sq"; + } + else { + warn "invalid status: $options{'status'} (ignored)\n"; + } + } + } + else { + @fields = ( 'charged_party' ); + push @fields, 'src' if !$options{'disable_src'}; + $hash{'freesidestatus'} = $options{'status'} + if exists($options{'status'}); + } + + my $for_update = $options{'for_update'} ? 'FOR UPDATE' : ''; + + my $number = $self->phonenum; + + my $prefix = $options{'default_prefix'}; + + my @orwhere = map " $_ = '$number' ", @fields; + push @orwhere, map " $_ = '$prefix$number' ", @fields + if length($prefix); + if ( $prefix =~ /^\+(\d+)$/ ) { + push @orwhere, map " $_ = '$1$number' ", @fields + } + + push @where, ' ( '. join(' OR ', @orwhere ). ' ) '; + + if ( $options{'begin'} ) { + push @where, 'startdate >= '. $options{'begin'}; + } + if ( $options{'end'} ) { + push @where, 'startdate < '. $options{'end'}; + } + + my $extra_sql = ( keys(%hash) ? ' AND ' : ' WHERE ' ). join(' AND ', @where ); + + my @cdrs = + qsearch( { + 'table' => 'cdr', + 'hashref' => \%hash, + 'extra_sql' => $extra_sql, + 'order_by' => "ORDER BY startdate $for_update", + } ); + + @cdrs; +} + =back =head1 BUGS