4 use vars qw( @ISA @EXPORT_OK $DEBUG $me
5 $conf $cdr_prerate %cdr_prerate_cdrtypenums
8 use List::Util qw(first min);
13 use List::Util qw( first min );
15 use FS::UID qw( dbh );
17 use FS::Record qw( qsearch qsearchs );
22 use FS::cdr_termination;
27 @ISA = qw(FS::Record);
28 @EXPORT_OK = qw( _cdr_date_parser_maker _cdr_min_parser_maker );
33 #ask FS::UID to run this stuff for us later
34 FS::UID->install_callback( sub {
37 my @cdr_prerate_cdrtypenums;
38 $cdr_prerate = $conf->exists('cdr-prerate');
39 @cdr_prerate_cdrtypenums = $conf->config('cdr-prerate-cdrtypenums')
41 %cdr_prerate_cdrtypenums = map { $_=>1 } @cdr_prerate_cdrtypenums;
46 FS::cdr - Object methods for cdr records
52 $record = new FS::cdr \%hash;
53 $record = new FS::cdr { 'column' => 'value' };
55 $error = $record->insert;
57 $error = $new_record->replace($old_record);
59 $error = $record->delete;
61 $error = $record->check;
65 An FS::cdr object represents an Call Data Record, typically from a telephony
66 system or provider of some sort. FS::cdr inherits from FS::Record. The
67 following fields are currently supported:
71 =item acctid - primary key
73 =item calldate - Call timestamp (SQL timestamp)
75 =item clid - Caller*ID with text
77 =item src - Caller*ID number / Source number
79 =item dst - Destination extension
81 =item dcontext - Destination context
83 =item channel - Channel used
85 =item dstchannel - Destination channel if appropriate
87 =item lastapp - Last application if appropriate
89 =item lastdata - Last application data
91 =item src_ip_addr - Source IP address (dotted quad, zero-filled)
93 =item dst_ip_addr - Destination IP address (same)
95 =item dst_term - Terminating destination number (if different from dst)
97 =item startdate - Start of call (UNIX-style integer timestamp)
99 =item answerdate - Answer time of call (UNIX-style integer timestamp)
101 =item enddate - End time of call (UNIX-style integer timestamp)
103 =item duration - Total time in system, in seconds
105 =item billsec - Total time call is up, in seconds
107 =item disposition - What happened to the call: ANSWERED, NO ANSWER, BUSY
109 =item amaflags - What flags to use: BILL, IGNORE etc, specified on a per channel basis like accountcode.
113 #ignore the "omit" and "documentation" AMAs??
114 #AMA = Automated Message Accounting.
115 #default: Sets the system default.
116 #omit: Do not record calls.
117 #billing: Mark the entry for billing
118 #documentation: Mark the entry for documentation.
120 =item accountcode - CDR account number to use: account
122 =item uniqueid - Unique channel identifier (Unitel/RSLCOM Event ID)
124 =item userfield - CDR user-defined field
126 =item cdr_type - CDR type - see L<FS::cdr_type> (Usage = 1, S&E = 7, OC&C = 8)
128 =item charged_party - Service number to be billed
130 =item upstream_currency - Wholesale currency from upstream
132 =item upstream_price - Wholesale price from upstream
134 =item upstream_rateplanid - Upstream rate plan ID
136 =item rated_price - Rated (or re-rated) price
138 =item distance - km (need units field?)
140 =item islocal - Local - 1, Non Local = 0
142 =item calltypenum - Type of call - see L<FS::cdr_calltype>
144 =item description - Description (cdr_type 7&8 only) (used for cust_bill_pkg.itemdesc)
146 =item quantity - Number of items (cdr_type 7&8 only)
148 =item carrierid - Upstream Carrier ID (see L<FS::cdr_carrier>)
152 #Telstra =1, Optus = 2, RSL COM = 3
154 =item upstream_rateid - Upstream Rate ID
156 =item svcnum - Link to customer service (see L<FS::cust_svc>)
158 =item freesidestatus - NULL, processing-tiered, rated, done, skipped, no-charge, failed
160 =item freesiderewritestatus - NULL, done, skipped
172 Creates a new CDR. To add the CDR to the database, see L<"insert">.
174 Note that this stores the hash reference, not a distinct copy of the hash it
175 points to. You can ask the object for a copy with the I<hash> method.
179 # the new method can be inherited from FS::Record, if a table method is defined
186 #XXX fill in some (more) nice names
188 'calldate' => 'Call date',
189 'clid' => 'Caller ID',
191 'dst' => 'Destination',
192 'dcontext' => 'Dest. context',
193 'channel' => 'Channel',
194 'dstchannel' => 'Destination channel',
197 'src_ip_addr' => 'Source IP',
198 'dst_ip_addr' => 'Dest. IP',
199 'dst_term' => 'Termination dest.',
200 'startdate' => 'Start date',
201 'answerdate' => 'Answer date',
202 'enddate' => 'End date',
203 'duration' => 'Duration',
204 'billsec' => 'Billable seconds',
205 'disposition' => 'Disposition',
206 'amaflags' => 'AMA flags',
207 'accountcode' => 'Account code',
209 'userfield' => 'User field',
211 'charged_party' => 'Charged party',
212 #'upstream_currency' => '',
213 'upstream_price' => 'Upstream price',
214 #'upstream_rateplanid' => '',
215 #'ratedetailnum' => '',
216 'rated_price' => 'Rated price',
219 #'calltypenum' => '',
220 #'description' => '',
222 'carrierid' => 'Carrier ID',
223 #'upstream_rateid' => '',
224 'svcnum' => 'Freeside service',
225 'freesidestatus' => 'Freeside status',
226 'freesiderewritestatus' => 'Freeside rewrite status',
227 'cdrbatch' => 'Legacy batch',
228 'cdrbatchnum' => 'Batch',
237 Adds this record to the database. If there is an error, returns the error,
238 otherwise returns false.
242 # the insert method can be inherited from FS::Record
246 Delete this record from the database.
250 # the delete method can be inherited from FS::Record
252 =item replace OLD_RECORD
254 Replaces the OLD_RECORD with this one in the database. If there is an error,
255 returns the error, otherwise returns false.
259 # the replace method can be inherited from FS::Record
263 Checks all fields to make sure this is a valid CDR. If there is
264 an error, returns the error, otherwise returns false. Called by the insert
267 Note: Unlike most types of records, we don't want to "reject" a CDR and we want
268 to process them as quickly as possible, so we allow the database to check most
276 # we don't want to "reject" a CDR like other sorts of input...
278 # $self->ut_numbern('acctid')
279 ## || $self->ut_('calldate')
280 # || $self->ut_text('clid')
281 # || $self->ut_text('src')
282 # || $self->ut_text('dst')
283 # || $self->ut_text('dcontext')
284 # || $self->ut_text('channel')
285 # || $self->ut_text('dstchannel')
286 # || $self->ut_text('lastapp')
287 # || $self->ut_text('lastdata')
288 # || $self->ut_numbern('startdate')
289 # || $self->ut_numbern('answerdate')
290 # || $self->ut_numbern('enddate')
291 # || $self->ut_number('duration')
292 # || $self->ut_number('billsec')
293 # || $self->ut_text('disposition')
294 # || $self->ut_number('amaflags')
295 # || $self->ut_text('accountcode')
296 # || $self->ut_text('uniqueid')
297 # || $self->ut_text('userfield')
298 # || $self->ut_numbern('cdrtypenum')
299 # || $self->ut_textn('charged_party')
300 ## || $self->ut_n('upstream_currency')
301 ## || $self->ut_n('upstream_price')
302 # || $self->ut_numbern('upstream_rateplanid')
303 ## || $self->ut_n('distance')
304 # || $self->ut_numbern('islocal')
305 # || $self->ut_numbern('calltypenum')
306 # || $self->ut_textn('description')
307 # || $self->ut_numbern('quantity')
308 # || $self->ut_numbern('carrierid')
309 # || $self->ut_numbern('upstream_rateid')
310 # || $self->ut_numbern('svcnum')
311 # || $self->ut_textn('freesidestatus')
312 # || $self->ut_textn('freesiderewritestatus')
314 # return $error if $error;
316 for my $f ( grep { $self->$_ =~ /\D/ } qw(startdate answerdate enddate)){
317 $self->$f( str2time($self->$f) );
320 $self->calldate( $self->startdate_sql )
321 if !$self->calldate && $self->startdate;
323 #was just for $format eq 'taqua' but can't see the harm... add something to
324 #disable if it becomes a problem
325 if ( $self->duration eq '' && $self->enddate && $self->startdate ) {
326 $self->duration( $self->enddate - $self->startdate );
328 if ( $self->billsec eq '' && $self->enddate && $self->answerdate ) {
329 $self->billsec( $self->enddate - $self->answerdate );
332 if ( ! $self->enddate && $self->startdate && $self->duration ) {
333 $self->enddate( $self->startdate + $self->duration );
336 $self->set_charged_party;
338 #check the foreign keys even?
339 #do we want to outright *reject* the CDR?
341 $self->ut_numbern('acctid');
343 #add a config option to turn these back on if someone needs 'em
345 # #Usage = 1, S&E = 7, OC&C = 8
346 # || $self->ut_foreign_keyn('cdrtypenum', 'cdr_type', 'cdrtypenum' )
348 # #the big list in appendix 2
349 # || $self->ut_foreign_keyn('calltypenum', 'cdr_calltype', 'calltypenum' )
351 # # Telstra =1, Optus = 2, RSL COM = 3
352 # || $self->ut_foreign_keyn('carrierid', 'cdr_carrier', 'carrierid' )
354 return $error if $error;
359 =item is_tollfree [ COLUMN ]
361 Returns true when the cdr represents a toll free number and false otherwise.
363 By default, inspects the dst field, but an optional column name can be passed
364 to inspect other field.
370 my $field = scalar(@_) ? shift : 'dst';
371 my $country = $conf->config('tollfree-country');
372 if ( $country eq 'AU' ) {
373 ( $self->$field() =~ /^(\+?64)?(800|508)/ ) ? 1 : 0;
374 } else { #NANPA (US/Canaada)
375 ( $self->$field() =~ /^(\+?1)?8(8|([02-7])\3)/ ) ? 1 : 0;
379 =item set_charged_party
381 If the charged_party field is already set, does nothing. Otherwise:
383 If the cdr-charged_party-accountcode config option is enabled, sets the
384 charged_party to the accountcode.
386 Otherwise sets the charged_party normally: to the src field in most cases,
387 or to the dst field if it is a toll free number.
391 sub set_charged_party {
394 my $conf = new FS::Conf;
396 unless ( $self->charged_party ) {
398 if ( $conf->exists('cdr-charged_party-accountcode') && $self->accountcode ){
400 my $charged_party = $self->accountcode;
401 $charged_party =~ s/^0+//
402 if $conf->exists('cdr-charged_party-accountcode-trim_leading_0s');
403 $self->charged_party( $charged_party );
405 } elsif ( $conf->exists('cdr-charged_party-field') ) {
407 my $field = $conf->config('cdr-charged_party-field');
408 $self->charged_party( $self->$field() );
412 if ( $self->is_tollfree ) {
413 $self->charged_party($self->dst);
415 $self->charged_party($self->src);
422 # my $prefix = $conf->config('cdr-charged_party-truncate_prefix');
423 # my $prefix_len = length($prefix);
424 # my $trunc_len = $conf->config('cdr-charged_party-truncate_length');
426 # $self->charged_party( substr($self->charged_party, 0, $trunc_len) )
427 # if $prefix_len && $trunc_len
428 # && substr($self->charged_party, 0, $prefix_len) eq $prefix;
432 =item set_status STATUS
434 Sets the status to the provided string. If there is an error, returns the
435 error, otherwise returns false.
437 If status is being changed from 'rated' to some other status, also removes
438 any usage allocations to this CDR.
443 my($self, $status) = @_;
444 my $old_status = $self->freesidestatus;
445 $self->freesidestatus($status);
446 my $error = $self->replace;
447 if ( $old_status eq 'rated' and $status ne 'done' ) {
448 # deallocate any usage
449 foreach (qsearch('cdr_cust_pkg_usage', {acctid => $self->acctid})) {
450 my $cust_pkg_usage = $_->cust_pkg_usage;
451 $cust_pkg_usage->set('minutes', $cust_pkg_usage->minutes + $_->minutes);
452 $error ||= $cust_pkg_usage->replace || $_->delete;
458 =item set_status_and_rated_price STATUS RATED_PRICE [ SVCNUM [ OPTION => VALUE ... ] ]
460 Sets the status and rated price.
462 Available options are: inbound, rated_pretty_dst, rated_regionname,
463 rated_seconds, rated_minutes, rated_granularity, rated_ratedetailnum,
464 rated_classnum, rated_ratename.
466 If there is an error, returns the error, otherwise returns false.
470 sub set_status_and_rated_price {
471 my($self, $status, $rated_price, $svcnum, %opt) = @_;
473 if ($opt{'inbound'}) {
475 my $term = $self->cdr_termination( 1 ); #1: inbound
478 warn "replacing existing cdr status (".$self->acctid.")\n" if $term;
479 $error = $term->delete;
480 return $error if $error;
482 $term = FS::cdr_termination->new({
483 acctid => $self->acctid,
485 rated_price => $rated_price,
488 $term->rated_seconds($opt{rated_seconds}) if exists($opt{rated_seconds});
489 $term->rated_minutes($opt{rated_minutes}) if exists($opt{rated_minutes});
490 $term->svcnum($svcnum) if $svcnum;
491 return $term->insert;
495 $self->freesidestatus($status);
496 $self->rated_price($rated_price);
498 foreach grep exists($opt{$_}), map "rated_$_",
499 qw( pretty_dst regionname seconds minutes granularity
500 ratedetailnum classnum ratename );
501 $self->svcnum($svcnum) if $svcnum;
502 return $self->replace();
507 =item parse_number [ OPTION => VALUE ... ]
509 Returns two scalars, the countrycode and the rest of the number.
511 Options are passed as name-value pairs. Currently available options are:
517 The column containing the number to be parsed. Defaults to dst.
519 =item international_prefix
521 The digits for international dialing. Defaults to '011' The value '+' is
524 =item domestic_prefix
526 The digits for domestic long distance dialing. Defaults to '1'
533 my ($self, %options) = @_;
535 my $field = $options{column} || 'dst';
536 my $intl = $options{international_prefix} || '011';
537 my $countrycode = '';
538 my $number = $self->$field();
540 my $to_or_from = 'concerning';
541 $to_or_from = 'from' if $field eq 'src';
542 $to_or_from = 'to' if $field eq 'dst';
543 warn "parsing call $to_or_from $number\n" if $DEBUG;
545 #remove non-phone# stuff and whitespace
548 # $dest =~ s/^(\w+):// and $proto = $1; #sip:
550 # $dest =~ s/\@(.*)$// and $siphost = $1; # @10.54.32.1, @sip.example.com
552 if ( $number =~ /^$intl(((\d)(\d))(\d))(\d+)$/
553 || $number =~ /^\+(((\d)(\d))(\d))(\d+)$/
557 my( $three, $two, $one, $u1, $u2, $rest ) = ( $1,$2,$3,$4,$5,$6 );
558 #first look for 1 digit country code
559 if ( qsearch('rate_prefix', { 'countrycode' => $one } ) ) {
561 $number = $u1.$u2.$rest;
562 } elsif ( qsearch('rate_prefix', { 'countrycode' => $two } ) ) { #or 2
565 } else { #3 digit country code
566 $countrycode = $three;
571 my $domestic_prefix =
572 exists($options{domestic_prefix}) ? $options{domestic_prefix} : '';
573 $countrycode = length($domestic_prefix) ? $domestic_prefix : '1';
574 $number =~ s/^$countrycode//;# if length($number) > 10;
577 return($countrycode, $number);
581 =item rate [ OPTION => VALUE ... ]
583 Rates this CDR according and sets the status to 'rated'.
585 Available options are: part_pkg, svcnum, plan_included_min,
586 detail_included_min_hashref.
588 part_pkg is required.
590 If svcnum is specified, will also associate this CDR with the specified svcnum.
592 plan_included_min should be set to a scalar reference of the number of
593 included minutes and will be decremented by the rated minutes of this
596 detail_included_min_hashref should be set to an empty hashref at the
597 start of a month's rating and then preserved across CDRs.
602 my( $self, %opt ) = @_;
603 my $part_pkg = $opt{'part_pkg'} or return "No part_pkg specified";
606 warn "rating CDR $self\n".
607 join('', map { " $_ => ". $self->{$_}. "\n" } keys %$self );
610 my $rating_method = $part_pkg->option_cacheable('rating_method') || 'prefix';
611 my $method = "rate_$rating_method";
612 $self->$method(%opt);
616 our %interval_cache = (); # for timed rates
619 my( $self, %opt ) = @_;
620 my $part_pkg = $opt{'part_pkg'} or return "No part_pkg specified";
621 my $cust_pkg = $opt{'cust_pkg'};
624 # this will result in those CDRs being marked as done... is that
627 if ( $part_pkg->option_cacheable('411_rewrite') ) {
628 my $dirass = $part_pkg->option_cacheable('411_rewrite');
630 @dirass = split(',', $dirass);
633 if ( length($self->dst) && grep { $self->dst eq $_ } @dirass ) {
638 my $reason = $part_pkg->check_chargable( $self,
639 'da_rewrote' => $da_rewrote,
642 warn "not charging for CDR ($reason)\n" if $DEBUG;
643 return $self->set_status_and_rated_price( 'skipped',
649 if ( $part_pkg->option_cacheable('skip_same_customer')
650 and ! $self->is_tollfree ) {
651 my ($dst_countrycode, $dst_number) = $self->parse_number(
653 international_prefix => $part_pkg->option_cacheable('international_prefix'),
654 domestic_prefix => $part_pkg->option_cacheable('domestic_prefix'),
656 my $dst_same_cust = FS::Record->scalar_sql(
657 'SELECT COUNT(svc_phone.svcnum) AS count '.
659 'JOIN cust_svc USING (pkgnum) ' .
660 'JOIN svc_phone USING (svcnum) ' .
661 'WHERE svc_phone.countrycode = ' . dbh->quote($dst_countrycode) .
662 ' AND svc_phone.phonenum = ' . dbh->quote($dst_number) .
663 ' AND cust_pkg.custnum = ' . $cust_pkg->custnum,
665 if ( $dst_same_cust > 0 ) {
666 warn "not charging for CDR (same source and destination customer)\n" if $DEBUG;
667 return $self->set_status_and_rated_price( 'skipped',
678 # look up rate details based on called station id
679 # (or calling station id for toll free calls)
682 my $eff_ratenum = $self->is_tollfree('accountcode')
683 ? $part_pkg->option_cacheable('accountcode_tollfree_ratenum')
686 my( $to_or_from, $column );
689 && ! $part_pkg->option_cacheable('disable_tollfree')
692 && $part_pkg->option_cacheable('accountcode_tollfree_field') eq 'src'
696 $to_or_from = 'from';
698 } else { #regular call
703 #determine the country code
704 my ($countrycode, $number) = $self->parse_number(
706 international_prefix => $part_pkg->option_cacheable('international_prefix'),
707 domestic_prefix => $part_pkg->option_cacheable('domestic_prefix'),
710 warn "rating call $to_or_from +$countrycode $number\n" if $DEBUG;
711 my $pretty_dst = "+$countrycode $number";
712 #asterisks here causes inserting the detail to barf, so:
713 $pretty_dst =~ s/\*//g;
716 my $intrastate_ratenum = $part_pkg->option_cacheable('intrastate_ratenum');
717 if ( $intrastate_ratenum && !$self->is_tollfree ) {
718 $ratename = 'Interstate'; #until proven otherwise
719 # this is relatively easy only because:
720 # -assume all numbers are valid NANP numbers NOT in a fully-qualified format
721 # -disregard toll-free
722 # -disregard private or unknown numbers
723 # -there is exactly one record in rate_prefix for a given NPANXX
724 # -default to interstate if we can't find one or both of the prefixes
725 my (undef, $dstprefix) = $self->parse_number(
727 international_prefix => $part_pkg->option_cacheable('international_prefix'),
728 domestic_prefix => $part_pkg->option_cacheable('domestic_prefix'),
730 $dstprefix =~ /^(\d{6})/;
731 $dstprefix = qsearchs('rate_prefix', { 'countrycode' => '1',
734 my (undef, $srcprefix) = $self->parse_number(
736 international_prefix => $part_pkg->option_cacheable('international_prefix'),
737 domestic_prefix => $part_pkg->option_cacheable('domestic_prefix'),
739 $srcprefix =~ /^(\d{6})/;
740 $srcprefix = qsearchs('rate_prefix', { 'countrycode' => '1',
743 if ($srcprefix && $dstprefix
744 && $srcprefix->state && $dstprefix->state
745 && $srcprefix->state eq $dstprefix->state) {
746 $eff_ratenum = $intrastate_ratenum;
747 $ratename = 'Intrastate'; # XXX possibly just use the ratename?
751 $eff_ratenum ||= $part_pkg->option_cacheable('ratenum');
752 my $rate = qsearchs('rate', { 'ratenum' => $eff_ratenum })
753 or die "ratenum $eff_ratenum not found!";
755 my @ltime = localtime($self->startdate);
756 my $weektime = $ltime[0] +
757 $ltime[1]*60 + #minutes
758 $ltime[2]*3600 + #hours
759 $ltime[6]*86400; #days since sunday
760 # if there's no timed rate_detail for this time/region combination,
761 # dest_detail returns the default. There may still be a timed rate
762 # that applies after the starttime of the call, so be careful...
763 my $rate_detail = $rate->dest_detail({ 'countrycode' => $countrycode,
764 'phonenum' => $number,
765 'weektime' => $weektime,
766 'cdrtypenum' => $self->cdrtypenum,
769 unless ( $rate_detail ) {
771 if ( $part_pkg->option_cacheable('ignore_unrateable') ) {
773 if ( $part_pkg->option_cacheable('ignore_unrateable') == 2 ) {
774 # mark the CDR as unrateable
775 return $self->set_status_and_rated_price(
780 } elsif ( $part_pkg->option_cacheable('ignore_unrateable') == 1 ) {
782 warn "no rate_detail found for CDR.acctid: ". $self->acctid.
787 die "unknown ignore_unrateable, pkgpart ". $part_pkg->pkgpart;
792 die "FATAL: no rate_detail found in ".
793 $rate->ratenum. ":". $rate->ratename. " rate plan ".
794 "for +$countrycode $number (CDR acctid ". $self->acctid. "); ".
795 "add a rate or set ignore_unrateable flag on the package def\n";
800 my $rate_region = $rate_detail->dest_region;
801 my $regionnum = $rate_region->regionnum;
802 warn " found rate for regionnum $regionnum ".
803 "and rate detail $rate_detail\n"
806 if ( !exists($interval_cache{$regionnum}) ) {
808 sort { $a->stime <=> $b->stime }
809 map { $_->rate_time->intervals }
810 qsearch({ 'table' => 'rate_detail',
811 'hashref' => { 'ratenum' => $rate->ratenum },
812 'extra_sql' => 'AND ratetimenum IS NOT NULL',
815 $interval_cache{$regionnum} = \@intervals;
816 warn " cached ".scalar(@intervals)." interval(s)\n"
821 # find the price and add detail to the invoice
824 # About this section:
825 # We don't round _anything_ (except granularizing)
826 # until the final $charge = sprintf("%.2f"...).
828 my $rated_seconds = $part_pkg->option_cacheable('use_duration')
831 my $seconds_left = $rated_seconds;
833 #no, do this later so it respects (group) included minutes
834 # # charge for the first (conn_sec) seconds
835 # my $seconds = min($seconds_left, $rate_detail->conn_sec);
836 # $seconds_left -= $seconds;
837 # $weektime += $seconds;
838 # my $charge = $rate_detail->conn_charge;
841 my $connection_charged = 0;
844 while($seconds_left) {
845 my $ratetimenum = $rate_detail->ratetimenum; # may be empty
847 # find the end of the current rate interval
848 if(@{ $interval_cache{$regionnum} } == 0) {
849 # There are no timed rates in this group, so just stay
850 # in the default rate_detail for the entire duration.
851 # Set an "end" of 1 past the end of the current call.
852 $etime = $weektime + $seconds_left + 1;
854 elsif($ratetimenum) {
855 # This is a timed rate, so go to the etime of this interval.
856 # If it's followed by another timed rate, the stime of that
857 # interval should match the etime of this one.
858 my $interval = $rate_detail->rate_time->contains($weektime);
859 $etime = $interval->etime;
862 # This is a default rate, so use the stime of the next
863 # interval in the sequence.
864 my $next_int = first { $_->stime > $weektime }
865 @{ $interval_cache{$regionnum} };
867 $etime = $next_int->stime;
870 # weektime is near the end of the week, so decrement
871 # it by a full week and use the stime of the first
873 $weektime -= (3600*24*7);
874 $etime = $interval_cache{$regionnum}->[0]->stime;
878 my $charge_sec = min($seconds_left, $etime - $weektime);
880 $seconds_left -= $charge_sec;
882 my $granularity = $rate_detail->sec_granularity;
885 if ( $granularity ) { # charge per minute
886 # Round up to the nearest $granularity
887 if ( $charge_sec and $charge_sec % $granularity ) {
888 $charge_sec += $granularity - ($charge_sec % $granularity);
890 $minutes = $charge_sec / 60; #don't round this
897 #$seconds += $charge_sec;
899 if ( $rate_detail->min_included ) {
900 # the old, kind of deprecated way to do this:
902 # The rate detail itself has included minutes. We MUST have a place
904 my $included_min = $opt{'detail_included_min_hashref'}
905 or return "unable to rate CDR: rate detail has included minutes, but ".
906 "no detail_included_min_hashref provided.\n";
908 # by default, set the included minutes for this region/time to
909 # what's in the rate_detail
910 $included_min->{$regionnum}{$ratetimenum} = $rate_detail->min_included
911 unless exists $included_min->{$regionnum}{$ratetimenum};
913 if ( $included_min->{$regionnum}{$ratetimenum} >= $minutes ) {
915 $included_min->{$regionnum}{$ratetimenum} -= $minutes;
917 $charge_sec -= ($included_min->{$regionnum}{$ratetimenum} * 60);
918 $included_min->{$regionnum}{$ratetimenum} = 0;
920 } elsif ( $opt{plan_included_min} && ${ $opt{plan_included_min} } > 0 ) {
921 # The package definition has included minutes, but only for in-group
922 # rate details. Decrement them if this is an in-group call.
923 if ( $rate_detail->region_group ) {
924 if ( ${ $opt{'plan_included_min'} } >= $minutes ) {
926 ${ $opt{'plan_included_min'} } -= $minutes;
928 $charge_sec -= (${ $opt{'plan_included_min'} } * 60);
929 ${ $opt{'plan_included_min'} } = 0;
934 my $applied_min = $cust_pkg->apply_usage(
936 'rate_detail' => $rate_detail,
937 'minutes' => $minutes
939 # for now, usage pools deal only in whole minutes
940 $charge_sec -= $applied_min * 60;
943 if ( $charge_sec > 0 ) {
945 #NOW do connection charges here... right?
946 #my $conn_seconds = min($seconds_left, $rate_detail->conn_sec);
947 my $conn_seconds = 0;
948 unless ( $connection_charged++ ) { #only one connection charge
949 $conn_seconds = min($charge_sec, $rate_detail->conn_sec);
950 $seconds_left -= $conn_seconds;
951 $weektime += $conn_seconds;
952 $charge += $rate_detail->conn_charge;
955 #should preserve (display?) this
956 if ( $granularity == 0 ) { # per call rate
957 $charge += $rate_detail->min_charge;
959 my $charge_min = ( $charge_sec - $conn_seconds ) / 60;
960 $charge += ($rate_detail->min_charge * $charge_min) if $charge_min > 0; #still not rounded
965 # choose next rate_detail
966 $rate_detail = $rate->dest_detail({ 'countrycode' => $countrycode,
967 'phonenum' => $number,
968 'weektime' => $etime,
969 'cdrtypenum' => $self->cdrtypenum })
971 # we have now moved forward to $etime
974 } #while $seconds_left
976 # this is why we need regionnum/rate_region....
977 warn " (rate region $rate_region)\n" if $DEBUG;
980 my $rounding = $part_pkg->option_cacheable('rounding') || 2;
981 my $sprintformat = '%.'. $rounding. 'f';
982 my $roundup = 10**(-3-$rounding);
983 my $price = sprintf($sprintformat, $charge + $roundup);
985 $self->set_status_and_rated_price(
989 'rated_pretty_dst' => $pretty_dst,
990 'rated_regionname' => $rate_region->regionname,
991 'rated_seconds' => $rated_seconds, #$seconds,
992 'rated_granularity' => $rate_detail->sec_granularity, #$granularity
993 'rated_ratedetailnum' => $rate_detail->ratedetailnum,
994 'rated_classnum' => $rate_detail->classnum, #rated_ratedetailnum?
995 'rated_ratename' => $ratename, #not rate_detail - Intrastate/Interstate
1000 sub rate_upstream_simple {
1001 my( $self, %opt ) = @_;
1003 $self->set_status_and_rated_price(
1005 sprintf('%.3f', $self->upstream_price),
1007 'rated_classnum' => $self->calltypenum,
1008 'rated_seconds' => $self->billsec,
1009 # others? upstream_*_regionname => rated_regionname is possible
1013 sub rate_single_price {
1014 my( $self, %opt ) = @_;
1015 my $part_pkg = $opt{'part_pkg'} or return "No part_pkg specified";
1017 # a little false laziness w/abov
1018 # $rate_detail = new FS::rate_detail({sec_granularity => ... }) ?
1020 my $granularity = length($part_pkg->option_cacheable('sec_granularity'))
1021 ? $part_pkg->option_cacheable('sec_granularity')
1024 my $seconds = $part_pkg->option_cacheable('use_duration')
1028 $seconds += $granularity - ( $seconds % $granularity )
1029 if $seconds # don't granular-ize 0 billsec calls (bills them)
1030 && $granularity # 0 is per call
1031 && $seconds % $granularity;
1032 my $minutes = $granularity ? ($seconds / 60) : 1;
1034 my $charge_min = $minutes;
1036 ${$opt{plan_included_min}} -= $minutes;
1037 if ( ${$opt{plan_included_min}} > 0 ) {
1040 $charge_min = 0 - ${$opt{plan_included_min}};
1041 ${$opt{plan_included_min}} = 0;
1045 sprintf('%.4f', ( $part_pkg->option_cacheable('min_charge') * $charge_min )
1046 + 0.0000000001 ); #so 1.00005 rounds to 1.0001
1048 $self->set_status_and_rated_price(
1052 'rated_granularity' => $granularity,
1053 'rated_seconds' => $seconds,
1060 Rates an already-rated CDR according to the cost fields from the rate plan.
1069 return 0 unless $self->rated_ratedetailnum;
1072 qsearchs('rate_detail', { 'ratedetailnum' => $self->rated_ratedetailnum } );
1074 return $rate_detail->min_cost if $self->rated_granularity == 0;
1076 my $minutes = $self->rated_seconds / 60;
1077 my $charge = $rate_detail->conn_cost + $minutes * $rate_detail->min_cost;
1079 sprintf('%.2f', $charge + .00001 );
1083 =item cdr_termination [ TERMPART ]
1087 sub cdr_termination {
1090 if ( scalar(@_) && $_[0] ) {
1091 my $termpart = shift;
1093 qsearchs('cdr_termination', { acctid => $self->acctid,
1094 termpart => $termpart,
1100 qsearch('cdr_termination', { acctid => $self->acctid, } );
1108 Parses the calldate in SQL string format and returns a UNIX timestamp.
1113 str2time(shift->calldate);
1118 Parses the startdate in UNIX timestamp format and returns a string in SQL
1124 my($sec,$min,$hour,$mday,$mon,$year) = localtime(shift->startdate);
1127 "$year-$mon-$mday $hour:$min:$sec";
1132 Returns the FS::cdr_carrier object associated with this CDR, or false if no
1133 carrierid is defined.
1137 my %carrier_cache = ();
1141 return '' unless $self->carrierid;
1142 $carrier_cache{$self->carrierid} ||=
1143 qsearchs('cdr_carrier', { 'carrierid' => $self->carrierid } );
1148 Returns the carrier name (see L<FS::cdr_carrier>), or the empty string if
1149 no FS::cdr_carrier object is assocated with this CDR.
1155 my $cdr_carrier = $self->cdr_carrier;
1156 $cdr_carrier ? $cdr_carrier->carriername : '';
1161 Returns the FS::cdr_calltype object associated with this CDR, or false if no
1162 calltypenum is defined.
1166 my %calltype_cache = ();
1170 return '' unless $self->calltypenum;
1171 $calltype_cache{$self->calltypenum} ||=
1172 qsearchs('cdr_calltype', { 'calltypenum' => $self->calltypenum } );
1177 Returns the call type name (see L<FS::cdr_calltype>), or the empty string if
1178 no FS::cdr_calltype object is assocated with this CDR.
1184 my $cdr_calltype = $self->cdr_calltype;
1185 $cdr_calltype ? $cdr_calltype->calltypename : '';
1188 =item downstream_csv [ OPTION => VALUE, ... ]
1192 # in the future, load this dynamically from detail_format classes
1194 my %export_names = (
1197 'invoice_header' => "Date,Time,Name,Destination,Duration,Price",
1200 'name' => 'Simple with source',
1201 'invoice_header' => "Date,Time,Called From,Destination,Duration,Price",
1202 #"Date,Time,Name,Called From,Destination,Duration,Price",
1204 'accountcode_simple' => {
1205 'name' => 'Simple with accountcode',
1206 'invoice_header' => "Date,Time,Called From,Account,Duration,Price",
1210 'invoice_header' => "Date/Time,Called Number,Min/Sec,Price",
1212 'basic_upstream_dst_regionname' => {
1213 'name' => 'Basic with upstream destination name',
1214 'invoice_header' => "Date/Time,Called Number,Destination,Min/Sec,Price",
1217 'name' => 'Default',
1218 'invoice_header' => 'Date,Time,Number,Destination,Duration,Price',
1220 'source_default' => {
1221 'name' => 'Default with source',
1222 'invoice_header' => 'Caller,Date,Time,Number,Destination,Duration,Price',
1224 'accountcode_default' => {
1225 'name' => 'Default plus accountcode',
1226 'invoice_header' => 'Date,Time,Account,Number,Destination,Duration,Price',
1228 'description_default' => {
1229 'name' => 'Default with description field as destination',
1230 'invoice_header' => 'Caller,Date,Time,Number,Destination,Duration,Price',
1233 'name' => 'Summary, one line per service',
1234 'invoice_header' => 'Caller,Rate,Calls,Minutes,Price',
1237 'name' => 'Number of calls, one line per service',
1238 'invoice_header' => 'Caller,Rate,Messages,Price',
1240 'sum_duration_prefix' => {
1241 'name' => 'Summary, one line per destination prefix',
1242 'invoice_header' => 'Caller,Rate,Calls,Minutes,Price',
1244 'sum_count_class' => {
1245 'name' => 'Summary, one line per usage class',
1246 'invoice_header' => 'Caller,Class,Calls,Price',
1250 my %export_formats = ();
1251 sub export_formats {
1254 return %export_formats if keys %export_formats;
1256 my $conf = new FS::Conf;
1257 my $date_format = $conf->config('date_format') || '%m/%d/%Y';
1259 # call duration in the largest units that accurately reflect the granularity
1260 my $duration_sub = sub {
1261 my($cdr, %opt) = @_;
1262 my $sec = $opt{seconds} || $cdr->billsec;
1263 if ( defined $opt{granularity} &&
1264 $opt{granularity} == 0 ) { #per call
1267 elsif ( defined $opt{granularity} && $opt{granularity} == 60 ) {#full minutes
1268 my $min = int($sec/60);
1272 else { #anything else
1273 return sprintf("%dm %ds", $sec/60, $sec%60);
1277 my $price_sub = sub {
1278 my ($cdr, %opt) = @_;
1280 if ( defined($opt{charge}) ) {
1281 $price = $opt{charge};
1283 elsif ( $opt{inbound} ) {
1284 my $term = $cdr->cdr_termination(1); # 1 = inbound
1285 $price = $term->rated_price if defined $term;
1288 $price = $cdr->rated_price;
1290 length($price) ? ($opt{money_char} . $price) : '';
1293 my $src_sub = sub { $_[0]->clid || $_[0]->src };
1297 sub { time2str($date_format, shift->calldate_unix ) }, #DATE
1298 sub { time2str('%r', shift->calldate_unix ) }, #TIME
1300 'dst', #NUMBER_DIALED
1301 $duration_sub, #DURATION
1302 #sub { sprintf('%.3f', shift->upstream_price ) }, #PRICE
1306 sub { time2str($date_format, shift->calldate_unix ) }, #DATE
1307 sub { time2str('%r', shift->calldate_unix ) }, #TIME
1309 $src_sub, #called from
1310 'dst', #NUMBER_DIALED
1311 $duration_sub, #DURATION
1312 #sub { sprintf('%.3f', shift->upstream_price ) }, #PRICE
1315 'accountcode_simple' => [
1316 sub { time2str($date_format, shift->calldate_unix ) }, #DATE
1317 sub { time2str('%r', shift->calldate_unix ) }, #TIME
1318 $src_sub, #called from
1319 'accountcode', #NUMBER_DIALED
1320 $duration_sub, #DURATION
1324 # for summary formats, the CDR is a fictitious object containing the
1325 # total billsec and the phone number of the service
1327 sub { my($cdr, %opt) = @_; $opt{ratename} },
1328 sub { my($cdr, %opt) = @_; $opt{count} },
1329 sub { my($cdr, %opt) = @_; int($opt{seconds}/60).'m' },
1334 sub { my($cdr, %opt) = @_; $opt{ratename} },
1335 sub { my($cdr, %opt) = @_; $opt{count} },
1339 sub { time2str('%d %b - %I:%M %p', shift->calldate_unix) },
1347 sub { time2str($date_format, shift->calldate_unix ) },
1348 # #time2str("%Y %b %d - %r", $cdr->calldate_unix ),
1351 sub { time2str('%r', shift->calldate_unix ) },
1352 # time2str("%c", $cdr->calldate_unix), #XXX this should probably be a config option dropdown so they can select US vs- rest of world dates or whatnot
1355 sub { my($cdr, %opt) = @_; $opt{pretty_dst} || $cdr->dst; },
1357 #REGIONNAME ("Destination")
1358 sub { my($cdr, %opt) = @_; $opt{dst_regionname}; },
1367 $export_formats{'source_default'} = [ $src_sub, @{ $export_formats{'default'} }, ];
1368 $export_formats{'accountcode_default'} =
1369 [ @{ $export_formats{'default'} }[0,1],
1371 @{ $export_formats{'default'} }[2..5],
1373 my @default = @{ $export_formats{'default'} };
1374 $export_formats{'description_default'} =
1375 [ $src_sub, @default[0..2],
1376 sub { my($cdr, %opt) = @_; $cdr->description },
1379 return %export_formats;
1382 =item downstream_csv OPTION => VALUE ...
1384 Returns a string of formatted call details for display on an invoice.
1390 charge - override the 'rated_price' field of the CDR
1392 seconds - override the 'billsec' field of the CDR
1394 count - number of usage events included in this record, for summary formats
1396 ratename - name of the rate table used to rate this call
1402 sub downstream_csv {
1403 my( $self, %opt ) = @_;
1405 my $format = $opt{'format'};
1406 my %formats = $self->export_formats;
1407 return "Unknown format $format" unless exists $formats{$format};
1409 #my $conf = new FS::Conf;
1410 #$opt{'money_char'} ||= $conf->config('money_char') || '$';
1411 $opt{'money_char'} ||= FS::Conf->new->config('money_char') || '$';
1413 my $csv = new Text::CSV_XS;
1417 ref($_) ? &{$_}($self, %opt) : $self->$_();
1419 @{ $formats{$format} };
1421 return @columns if defined $opt{'keeparray'};
1423 my $status = $csv->combine(@columns);
1424 die "FS::CDR: error combining ". $csv->error_input(). "into downstream CSV"
1433 =head1 CLASS METHODS
1437 =item invoice_formats
1439 Returns an ordered list of key value pairs containing invoice format names
1440 as keys (for use with part_pkg::voip_cdr) and "pretty" format names as values.
1444 # in the future, load this dynamically from detail_format classes
1446 sub invoice_formats {
1447 map { ($_ => $export_names{$_}->{'name'}) }
1448 grep { $export_names{$_}->{'invoice_header'} }
1452 =item invoice_header FORMAT
1454 Returns a scalar containing the CSV column header for invoice format FORMAT.
1458 sub invoice_header {
1460 $export_names{$format}->{'invoice_header'};
1465 Clears cdr and any associated cdr_termination statuses - used for
1474 local $SIG{HUP} = 'IGNORE';
1475 local $SIG{INT} = 'IGNORE';
1476 local $SIG{QUIT} = 'IGNORE';
1477 local $SIG{TERM} = 'IGNORE';
1478 local $SIG{TSTP} = 'IGNORE';
1479 local $SIG{PIPE} = 'IGNORE';
1481 my $oldAutoCommit = $FS::UID::AutoCommit;
1482 local $FS::UID::AutoCommit = 0;
1485 if ( $cdr_prerate && $cdr_prerate_cdrtypenums{$self->cdrtypenum}
1486 && $self->rated_ratedetailnum #avoid putting old CDRs back in "rated"
1487 && $self->freesidestatus eq 'done'
1491 $self->freesidestatus('rated');
1493 $self->freesidestatus('');
1496 my $error = $self->replace;
1498 $dbh->rollback if $oldAutoCommit;
1502 foreach my $cdr_termination ( $self->cdr_termination ) {
1503 #$cdr_termination->status('');
1504 #$error = $cdr_termination->replace;
1505 $error = $cdr_termination->delete;
1507 $dbh->rollback if $oldAutoCommit;
1512 $dbh->commit or die $dbh->errstr if $oldAutoCommit;
1517 =item import_formats
1519 Returns an ordered list of key value pairs containing import format names
1520 as keys (for use with batch_import) and "pretty" format names as values.
1524 #false laziness w/part_pkg & part_export
1527 foreach my $INC ( @INC ) {
1528 warn "globbing $INC/FS/cdr/[a-z]*.pm\n" if $DEBUG;
1529 foreach my $file ( glob("$INC/FS/cdr/[a-z]*.pm") ) {
1530 warn "attempting to load CDR format info from $file\n" if $DEBUG;
1531 $file =~ /\/(\w+)\.pm$/ or do {
1532 warn "unrecognized file in $INC/FS/cdr/: $file\n";
1536 my $info = eval "use FS::cdr::$mod; ".
1537 "\\%FS::cdr::$mod\::info;";
1539 die "error using FS::cdr::$mod (skipping): $@\n" if $@;
1542 unless ( keys %$info ) {
1543 warn "no %info hash found in FS::cdr::$mod, skipping\n";
1546 warn "got CDR format info from FS::cdr::$mod: $info\n" if $DEBUG;
1547 if ( exists($info->{'disabled'}) && $info->{'disabled'} ) {
1548 warn "skipping disabled CDR format FS::cdr::$mod" if $DEBUG;
1551 $cdr_info{$mod} = $info;
1555 tie my %import_formats, 'Tie::IxHash',
1556 map { $_ => $cdr_info{$_}->{'name'} }
1557 sort { $cdr_info{$a}->{'weight'} <=> $cdr_info{$b}->{'weight'} }
1558 grep { exists($cdr_info{$_}->{'import_fields'}) }
1561 sub import_formats {
1565 sub _cdr_min_parser_maker {
1567 my @fields = ref($field) ? @$field : ($field);
1568 @fields = qw( billsec duration ) unless scalar(@fields) && $fields[0];
1570 my( $cdr, $min ) = @_;
1571 my $sec = eval { _cdr_min_parse($min) };
1572 die "error parsing seconds for @fields from $min minutes: $@\n" if $@;
1573 $cdr->$_($sec) foreach @fields;
1577 sub _cdr_min_parse {
1579 sprintf('%.0f', $min * 60 );
1582 sub _cdr_date_parser_maker {
1585 my @fields = ref($field) ? @$field : ($field);
1587 my( $cdr, $datestring ) = @_;
1588 my $unixdate = eval { _cdr_date_parse($datestring, %options) };
1589 die "error parsing date for @fields from $datestring: $@\n" if $@;
1590 $cdr->$_($unixdate) foreach @fields;
1594 sub _cdr_date_parse {
1598 return '' unless length($date); #that's okay, it becomes NULL
1599 return '' if $date eq 'NA'; #sansay
1601 if ( $date =~ /^([a-z]{3})\s+([a-z]{3})\s+(\d{1,2})\s+(\d{1,2}):(\d{1,2}):(\d{1,2})\s+(\d{4})$/i && $7 > 1970 ) {
1602 my $time = str2time($date);
1603 return $time if $time > 100000; #just in case
1606 my($year, $mon, $day, $hour, $min, $sec);
1608 #$date =~ /^\s*(\d{4})[\-\/]\(\d{1,2})[\-\/](\d{1,2})\s+(\d{1,2}):(\d{1,2}):(\d{1,2})\s*$/
1609 #taqua #2007-10-31 08:57:24.113000000
1611 if ( $date =~ /^\s*(\d{4})\D(\d{1,2})\D(\d{1,2})\D+(\d{1,2})\D(\d{1,2})\D(\d{1,2})(\D|$)/ ) {
1612 ($year, $mon, $day, $hour, $min, $sec) = ( $1, $2, $3, $4, $5, $6 );
1613 } elsif ( $date =~ /^\s*(\d{1,2})\D(\d{1,2})\D(\d{4})\s+(\d{1,2})\D(\d{1,2})(?:\D(\d{1,2}))?(\D|$)/ ) {
1614 # 8/26/2010 12:20:01
1615 # optionally without seconds
1616 ($mon, $day, $year, $hour, $min, $sec) = ( $1, $2, $3, $4, $5, $6 );
1617 $sec = 0 if !defined($sec);
1618 } elsif ( $date =~ /^\s*(\d{4})(\d{2})(\d{2})(\d{2})(\d{2})(\d+\.\d+)(\D|$)/ ) {
1619 # broadsoft: 20081223201938.314
1620 ($year, $mon, $day, $hour, $min, $sec) = ( $1, $2, $3, $4, $5, $6 );
1621 } elsif ( $date =~ /^\s*(\d{4})(\d{2})(\d{2})(\d{2})(\d{2})(\d{2})\d+(\D|$)/ ) {
1622 # Taqua OM: 20050422203450943
1623 ($year, $mon, $day, $hour, $min, $sec) = ( $1, $2, $3, $4, $5, $6 );
1624 } elsif ( $date =~ /^\s*(\d{4})(\d{2})(\d{2})(\d{2})(\d{2})(\d{2})$/ ) {
1625 # WIP: 20100329121420
1626 ($year, $mon, $day, $hour, $min, $sec) = ( $1, $2, $3, $4, $5, $6 );
1627 } elsif ( $date =~ /^(\d{4})-(\d{2})-(\d{2})T(\d{2}):(\d{2}):(\d{2})Z$/) {
1629 ($year, $mon, $day, $hour, $min, $sec) = ( $1, $2, $3, $4, $5, $6 );
1632 die "unparsable date: $date"; #maybe we shouldn't die...
1635 return '' if ( $year == 1900 || $year == 1970 ) && $mon == 1 && $day == 1
1636 && $hour == 0 && $min == 0 && $sec == 0;
1638 if ($options{gmt}) {
1639 timegm($sec, $min, $hour, $day, $mon-1, $year);
1641 timelocal($sec, $min, $hour, $day, $mon-1, $year);
1645 =item batch_import HASHREF
1647 Imports CDR records. Available options are:
1659 Hash reference of preset fields, typically cdrbatch
1663 Set true to prevent throwing an error on empty imports
1669 my %import_options = (
1672 'batch_keycol' => 'cdrbatchnum',
1673 'batch_table' => 'cdr_batch',
1674 'batch_namecol' => 'cdrbatch',
1676 'formats' => { map { $_ => $cdr_info{$_}->{'import_fields'}; }
1680 #drop the || 'csv' to allow auto xls for csv types?
1681 'format_types' => { map { $_ => lc($cdr_info{$_}->{'type'} || 'csv'); }
1685 'format_headers' => { map { $_ => ( $cdr_info{$_}->{'header'} || 0 ); }
1689 'format_sep_chars' => { map { $_ => $cdr_info{$_}->{'sep_char'}; }
1693 'format_fixedlength_formats' =>
1694 { map { $_ => $cdr_info{$_}->{'fixedlength_format'}; }
1698 'format_xml_formats' =>
1699 { map { $_ => $cdr_info{$_}->{'xml_format'}; }
1703 'format_asn_formats' =>
1704 { map { $_ => $cdr_info{$_}->{'asn_format'}; }
1708 'format_row_callbacks' =>
1709 { map { $_ => $cdr_info{$_}->{'row_callback'}; }
1713 'format_parser_opts' =>
1714 { map { $_ => $cdr_info{$_}->{'parser_opt'}; }
1719 sub _import_options {
1726 my $iopt = _import_options;
1727 $opt->{$_} = $iopt->{$_} foreach keys %$iopt;
1729 if ( defined $opt->{'cdrtypenum'} ) {
1730 $opt->{'preinsert_callback'} = sub {
1731 my($record,$param) = (shift,shift);
1732 $record->cdrtypenum($opt->{'cdrtypenum'});
1737 FS::Record::batch_import( $opt );
1741 =item process_batch_import
1745 sub process_batch_import {
1748 my $opt = _import_options;
1749 # $opt->{'params'} = [ 'format', 'cdrbatch' ];
1751 FS::Record::process_batch_import( $job, $opt, @_ );
1754 # if ( $format eq 'simple' ) { #should be a callback or opt in FS::cdr::simple
1755 # @columns = map { s/^ +//; $_; } @columns;
1760 # Used by FS::Upgrade to migrate to a new database.
1763 my ($class, %opts) = @_;
1765 warn "$me upgrading $class\n" if $DEBUG;
1767 my $sth = dbh->prepare(
1768 'SELECT DISTINCT(cdrbatch) FROM cdr WHERE cdrbatch IS NOT NULL'
1769 ) or die dbh->errstr;
1771 $sth->execute or die $sth->errstr;
1773 my %cdrbatchnum = ();
1774 while (my $row = $sth->fetchrow_arrayref) {
1776 my $cdr_batch = qsearchs( 'cdr_batch', { 'cdrbatch' => $row->[0] } );
1777 unless ( $cdr_batch ) {
1778 $cdr_batch = new FS::cdr_batch { 'cdrbatch' => $row->[0] };
1779 my $error = $cdr_batch->insert;
1780 die $error if $error;
1783 $cdrbatchnum{$row->[0]} = $cdr_batch->cdrbatchnum;
1786 $sth = dbh->prepare('UPDATE cdr SET cdrbatch = NULL, cdrbatchnum = ? WHERE cdrbatch IS NOT NULL AND cdrbatch = ?') or die dbh->errstr;
1788 foreach my $cdrbatch (keys %cdrbatchnum) {
1789 $sth->execute($cdrbatchnum{$cdrbatch}, $cdrbatch) or die $sth->errstr;
1794 =item ip_addr_sql FIELD RANGE
1796 Returns an SQL condition to search for CDRs with an IP address
1797 within RANGE. FIELD is either 'src_ip_addr' or 'dst_ip_addr'. RANGE
1798 should be in the form "a.b.c.d-e.f.g.h' (dotted quads), where any of
1799 the leftmost octets of the second address can be omitted if they're
1800 the same as the first address.
1806 my ($field, $range) = @_;
1807 $range =~ /^[\d\.-]+$/ or die "bad ip address range '$range'";
1808 my @r = split('-', $range);
1809 my @saddr = split('\.', $r[0] || '');
1810 my @eaddr = split('\.', $r[1] || '');
1811 unshift @eaddr, (undef) x (4 - scalar @eaddr);
1813 $eaddr[$_] = $saddr[$_] if !defined $eaddr[$_];
1815 "$field >= '".sprintf('%03d.%03d.%03d.%03d', @saddr) . "' AND ".
1816 "$field <= '".sprintf('%03d.%03d.%03d.%03d', @eaddr) . "'";
1825 L<FS::Record>, schema.html from the base documentation.