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() =~ /^(\+?61)?(1800|1300)/ ) ? 1 : 0;
374 } elsif ( $country eq 'NZ' ) {
375 ( $self->$field() =~ /^(\+?64)?(800|508)/ ) ? 1 : 0;
376 } else { #NANPA (US/Canaada)
377 ( $self->$field() =~ /^(\+?1)?8(8|([02-7])\3)/ ) ? 1 : 0;
381 =item set_charged_party
383 If the charged_party field is already set, does nothing. Otherwise:
385 If the cdr-charged_party-accountcode config option is enabled, sets the
386 charged_party to the accountcode.
388 Otherwise sets the charged_party normally: to the src field in most cases,
389 or to the dst field if it is a toll free number.
393 sub set_charged_party {
396 my $conf = new FS::Conf;
398 unless ( $self->charged_party ) {
400 if ( $conf->exists('cdr-charged_party-accountcode') && $self->accountcode ){
402 my $charged_party = $self->accountcode;
403 $charged_party =~ s/^0+//
404 if $conf->exists('cdr-charged_party-accountcode-trim_leading_0s');
405 $self->charged_party( $charged_party );
407 } elsif ( $conf->exists('cdr-charged_party-field') ) {
409 my $field = $conf->config('cdr-charged_party-field');
410 $self->charged_party( $self->$field() );
414 if ( $self->is_tollfree ) {
415 $self->charged_party($self->dst);
417 $self->charged_party($self->src);
424 # my $prefix = $conf->config('cdr-charged_party-truncate_prefix');
425 # my $prefix_len = length($prefix);
426 # my $trunc_len = $conf->config('cdr-charged_party-truncate_length');
428 # $self->charged_party( substr($self->charged_party, 0, $trunc_len) )
429 # if $prefix_len && $trunc_len
430 # && substr($self->charged_party, 0, $prefix_len) eq $prefix;
434 =item set_status STATUS
436 Sets the status to the provided string. If there is an error, returns the
437 error, otherwise returns false.
439 If status is being changed from 'rated' to some other status, also removes
440 any usage allocations to this CDR.
445 my($self, $status) = @_;
446 my $old_status = $self->freesidestatus;
447 $self->freesidestatus($status);
448 my $error = $self->replace;
449 if ( $old_status eq 'rated' and $status ne 'done' ) {
450 # deallocate any usage
451 foreach (qsearch('cdr_cust_pkg_usage', {acctid => $self->acctid})) {
452 my $cust_pkg_usage = $_->cust_pkg_usage;
453 $cust_pkg_usage->set('minutes', $cust_pkg_usage->minutes + $_->minutes);
454 $error ||= $cust_pkg_usage->replace || $_->delete;
460 =item set_status_and_rated_price STATUS RATED_PRICE [ SVCNUM [ OPTION => VALUE ... ] ]
462 Sets the status and rated price.
464 Available options are: inbound, rated_pretty_dst, rated_regionname,
465 rated_seconds, rated_minutes, rated_granularity, rated_ratedetailnum,
466 rated_classnum, rated_ratename.
468 If there is an error, returns the error, otherwise returns false.
472 sub set_status_and_rated_price {
473 my($self, $status, $rated_price, $svcnum, %opt) = @_;
475 if ($opt{'inbound'}) {
477 my $term = $self->cdr_termination( 1 ); #1: inbound
480 warn "replacing existing cdr status (".$self->acctid.")\n" if $term;
481 $error = $term->delete;
482 return $error if $error;
484 $term = FS::cdr_termination->new({
485 acctid => $self->acctid,
487 rated_price => $rated_price,
490 $term->rated_seconds($opt{rated_seconds}) if exists($opt{rated_seconds});
491 $term->rated_minutes($opt{rated_minutes}) if exists($opt{rated_minutes});
492 $term->svcnum($svcnum) if $svcnum;
493 return $term->insert;
497 $self->freesidestatus($status);
498 $self->rated_price($rated_price);
500 foreach grep exists($opt{$_}), map "rated_$_",
501 qw( pretty_dst regionname seconds minutes granularity
502 ratedetailnum classnum ratename );
503 $self->svcnum($svcnum) if $svcnum;
504 return $self->replace();
509 =item parse_number [ OPTION => VALUE ... ]
511 Returns two scalars, the countrycode and the rest of the number.
513 Options are passed as name-value pairs. Currently available options are:
519 The column containing the number to be parsed. Defaults to dst.
521 =item international_prefix
523 The digits for international dialing. Defaults to '011' The value '+' is
526 =item domestic_prefix
528 The digits for domestic long distance dialing. Defaults to '1'
535 my ($self, %options) = @_;
537 my $field = $options{column} || 'dst';
538 my $intl = $options{international_prefix} || '011';
539 my $countrycode = '';
540 my $number = $self->$field();
542 my $to_or_from = 'concerning';
543 $to_or_from = 'from' if $field eq 'src';
544 $to_or_from = 'to' if $field eq 'dst';
545 warn "parsing call $to_or_from $number\n" if $DEBUG;
547 #remove non-phone# stuff and whitespace
550 # $dest =~ s/^(\w+):// and $proto = $1; #sip:
552 # $dest =~ s/\@(.*)$// and $siphost = $1; # @10.54.32.1, @sip.example.com
554 if ( $number =~ /^$intl(((\d)(\d))(\d))(\d+)$/
555 || $number =~ /^\+(((\d)(\d))(\d))(\d+)$/
559 my( $three, $two, $one, $u1, $u2, $rest ) = ( $1,$2,$3,$4,$5,$6 );
560 #first look for 1 digit country code
561 if ( qsearch('rate_prefix', { 'countrycode' => $one } ) ) {
563 $number = $u1.$u2.$rest;
564 } elsif ( qsearch('rate_prefix', { 'countrycode' => $two } ) ) { #or 2
567 } else { #3 digit country code
568 $countrycode = $three;
573 my $domestic_prefix =
574 exists($options{domestic_prefix}) ? $options{domestic_prefix} : '';
575 $countrycode = length($domestic_prefix) ? $domestic_prefix : '1';
576 $number =~ s/^$countrycode//;# if length($number) > 10;
579 return($countrycode, $number);
583 =item rate [ OPTION => VALUE ... ]
585 Rates this CDR according and sets the status to 'rated'.
587 Available options are: part_pkg, svcnum, plan_included_min,
588 detail_included_min_hashref.
590 part_pkg is required.
592 If svcnum is specified, will also associate this CDR with the specified svcnum.
594 plan_included_min should be set to a scalar reference of the number of
595 included minutes and will be decremented by the rated minutes of this
598 detail_included_min_hashref should be set to an empty hashref at the
599 start of a month's rating and then preserved across CDRs.
604 my( $self, %opt ) = @_;
605 my $part_pkg = $opt{'part_pkg'} or return "No part_pkg specified";
608 warn "rating CDR $self\n".
609 join('', map { " $_ => ". $self->{$_}. "\n" } keys %$self );
612 my $rating_method = $part_pkg->option_cacheable('rating_method') || 'prefix';
613 my $method = "rate_$rating_method";
614 $self->$method(%opt);
618 our %interval_cache = (); # for timed rates
621 my( $self, %opt ) = @_;
622 my $part_pkg = $opt{'part_pkg'} or return "No part_pkg specified";
623 my $cust_pkg = $opt{'cust_pkg'};
626 # this will result in those CDRs being marked as done... is that
629 if ( $part_pkg->option_cacheable('411_rewrite') ) {
630 my $dirass = $part_pkg->option_cacheable('411_rewrite');
632 @dirass = split(',', $dirass);
635 if ( length($self->dst) && grep { $self->dst eq $_ } @dirass ) {
640 my $reason = $part_pkg->check_chargable( $self,
641 'da_rewrote' => $da_rewrote,
644 warn "not charging for CDR ($reason)\n" if $DEBUG;
645 return $self->set_status_and_rated_price( 'skipped',
651 if ( $part_pkg->option_cacheable('skip_same_customer')
652 and ! $self->is_tollfree ) {
653 my ($dst_countrycode, $dst_number) = $self->parse_number(
655 international_prefix => $part_pkg->option_cacheable('international_prefix'),
656 domestic_prefix => $part_pkg->option_cacheable('domestic_prefix'),
658 my $dst_same_cust = FS::Record->scalar_sql(
659 'SELECT COUNT(svc_phone.svcnum) AS count '.
661 'JOIN cust_svc USING (pkgnum) ' .
662 'JOIN svc_phone USING (svcnum) ' .
663 'WHERE svc_phone.countrycode = ' . dbh->quote($dst_countrycode) .
664 ' AND svc_phone.phonenum = ' . dbh->quote($dst_number) .
665 ' AND cust_pkg.custnum = ' . $cust_pkg->custnum,
667 if ( $dst_same_cust > 0 ) {
668 warn "not charging for CDR (same source and destination customer)\n" if $DEBUG;
669 return $self->set_status_and_rated_price( 'skipped',
680 # look up rate details based on called station id
681 # (or calling station id for toll free calls)
684 my $eff_ratenum = $self->is_tollfree('accountcode')
685 ? $part_pkg->option_cacheable('accountcode_tollfree_ratenum')
688 my( $to_or_from, $column );
691 && ! $part_pkg->option_cacheable('disable_tollfree')
694 && $part_pkg->option_cacheable('accountcode_tollfree_field') eq 'src'
698 $to_or_from = 'from';
700 } else { #regular call
705 #determine the country code
706 my ($countrycode, $number) = $self->parse_number(
708 international_prefix => $part_pkg->option_cacheable('international_prefix'),
709 domestic_prefix => $part_pkg->option_cacheable('domestic_prefix'),
712 warn "rating call $to_or_from +$countrycode $number\n" if $DEBUG;
713 my $pretty_dst = "+$countrycode $number";
714 #asterisks here causes inserting the detail to barf, so:
715 $pretty_dst =~ s/\*//g;
718 my $intrastate_ratenum = $part_pkg->option_cacheable('intrastate_ratenum');
719 if ( $intrastate_ratenum && !$self->is_tollfree ) {
720 $ratename = 'Interstate'; #until proven otherwise
721 # this is relatively easy only because:
722 # -assume all numbers are valid NANP numbers NOT in a fully-qualified format
723 # -disregard toll-free
724 # -disregard private or unknown numbers
725 # -there is exactly one record in rate_prefix for a given NPANXX
726 # -default to interstate if we can't find one or both of the prefixes
727 my (undef, $dstprefix) = $self->parse_number(
729 international_prefix => $part_pkg->option_cacheable('international_prefix'),
730 domestic_prefix => $part_pkg->option_cacheable('domestic_prefix'),
732 $dstprefix =~ /^(\d{6})/;
733 $dstprefix = qsearchs('rate_prefix', { 'countrycode' => '1',
736 my (undef, $srcprefix) = $self->parse_number(
738 international_prefix => $part_pkg->option_cacheable('international_prefix'),
739 domestic_prefix => $part_pkg->option_cacheable('domestic_prefix'),
741 $srcprefix =~ /^(\d{6})/;
742 $srcprefix = qsearchs('rate_prefix', { 'countrycode' => '1',
745 if ($srcprefix && $dstprefix
746 && $srcprefix->state && $dstprefix->state
747 && $srcprefix->state eq $dstprefix->state) {
748 $eff_ratenum = $intrastate_ratenum;
749 $ratename = 'Intrastate'; # XXX possibly just use the ratename?
753 $eff_ratenum ||= $part_pkg->option_cacheable('ratenum');
754 my $rate = qsearchs('rate', { 'ratenum' => $eff_ratenum })
755 or die "ratenum $eff_ratenum not found!";
757 my @ltime = localtime($self->startdate);
758 my $weektime = $ltime[0] +
759 $ltime[1]*60 + #minutes
760 $ltime[2]*3600 + #hours
761 $ltime[6]*86400; #days since sunday
762 # if there's no timed rate_detail for this time/region combination,
763 # dest_detail returns the default. There may still be a timed rate
764 # that applies after the starttime of the call, so be careful...
765 my $rate_detail = $rate->dest_detail({ 'countrycode' => $countrycode,
766 'phonenum' => $number,
767 'weektime' => $weektime,
768 'cdrtypenum' => $self->cdrtypenum,
771 unless ( $rate_detail ) {
773 if ( $part_pkg->option_cacheable('ignore_unrateable') ) {
775 if ( $part_pkg->option_cacheable('ignore_unrateable') == 2 ) {
776 # mark the CDR as unrateable
777 return $self->set_status_and_rated_price(
782 } elsif ( $part_pkg->option_cacheable('ignore_unrateable') == 1 ) {
784 warn "no rate_detail found for CDR.acctid: ". $self->acctid.
789 die "unknown ignore_unrateable, pkgpart ". $part_pkg->pkgpart;
794 die "FATAL: no rate_detail found in ".
795 $rate->ratenum. ":". $rate->ratename. " rate plan ".
796 "for +$countrycode $number (CDR acctid ". $self->acctid. "); ".
797 "add a rate or set ignore_unrateable flag on the package def\n";
802 my $regionnum = $rate_detail->dest_regionnum;
803 my $rate_region = $rate_detail->dest_region;
804 warn " found rate for regionnum $regionnum ".
805 "and rate detail $rate_detail\n"
808 if ( !exists($interval_cache{$regionnum}) ) {
810 sort { $a->stime <=> $b->stime }
811 map { $_->rate_time->intervals }
812 qsearch({ 'table' => 'rate_detail',
813 'hashref' => { 'ratenum' => $rate->ratenum },
814 'extra_sql' => 'AND ratetimenum IS NOT NULL',
817 $interval_cache{$regionnum} = \@intervals;
818 warn " cached ".scalar(@intervals)." interval(s)\n"
823 # find the price and add detail to the invoice
826 # About this section:
827 # We don't round _anything_ (except granularizing)
828 # until the final $charge = sprintf("%.2f"...).
830 my $rated_seconds = $part_pkg->option_cacheable('use_duration')
833 my $seconds_left = $rated_seconds;
835 #no, do this later so it respects (group) included minutes
836 # # charge for the first (conn_sec) seconds
837 # my $seconds = min($seconds_left, $rate_detail->conn_sec);
838 # $seconds_left -= $seconds;
839 # $weektime += $seconds;
840 # my $charge = $rate_detail->conn_charge;
843 my $connection_charged = 0;
845 # before doing anything else, if there's an upstream multiplier and
846 # an upstream price, add that to the charge. (usually the rate detail
847 # will then have a minute charge of zero, but not necessarily.)
848 $charge += ($self->upstream_price || 0) * $rate_detail->upstream_mult_charge;
851 while($seconds_left) {
852 my $ratetimenum = $rate_detail->ratetimenum; # may be empty
854 # find the end of the current rate interval
855 if(@{ $interval_cache{$regionnum} } == 0) {
856 # There are no timed rates in this group, so just stay
857 # in the default rate_detail for the entire duration.
858 # Set an "end" of 1 past the end of the current call.
859 $etime = $weektime + $seconds_left + 1;
861 elsif($ratetimenum) {
862 # This is a timed rate, so go to the etime of this interval.
863 # If it's followed by another timed rate, the stime of that
864 # interval should match the etime of this one.
865 my $interval = $rate_detail->rate_time->contains($weektime);
866 $etime = $interval->etime;
869 # This is a default rate, so use the stime of the next
870 # interval in the sequence.
871 my $next_int = first { $_->stime > $weektime }
872 @{ $interval_cache{$regionnum} };
874 $etime = $next_int->stime;
877 # weektime is near the end of the week, so decrement
878 # it by a full week and use the stime of the first
880 $weektime -= (3600*24*7);
881 $etime = $interval_cache{$regionnum}->[0]->stime;
885 my $charge_sec = min($seconds_left, $etime - $weektime);
887 $seconds_left -= $charge_sec;
889 my $granularity = $rate_detail->sec_granularity;
892 if ( $granularity ) { # charge per minute
893 # Round up to the nearest $granularity
894 if ( $charge_sec and $charge_sec % $granularity ) {
895 $charge_sec += $granularity - ($charge_sec % $granularity);
897 $minutes = $charge_sec / 60; #don't round this
904 #$seconds += $charge_sec;
906 if ( $rate_detail->min_included ) {
907 # the old, kind of deprecated way to do this:
909 # The rate detail itself has included minutes. We MUST have a place
911 my $included_min = $opt{'detail_included_min_hashref'}
912 or return "unable to rate CDR: rate detail has included minutes, but ".
913 "no detail_included_min_hashref provided.\n";
915 # by default, set the included minutes for this region/time to
916 # what's in the rate_detail
917 $included_min->{$regionnum}{$ratetimenum} = $rate_detail->min_included
918 unless exists $included_min->{$regionnum}{$ratetimenum};
920 if ( $included_min->{$regionnum}{$ratetimenum} >= $minutes ) {
922 $included_min->{$regionnum}{$ratetimenum} -= $minutes;
924 $charge_sec -= ($included_min->{$regionnum}{$ratetimenum} * 60);
925 $included_min->{$regionnum}{$ratetimenum} = 0;
927 } elsif ( $opt{plan_included_min} && ${ $opt{plan_included_min} } > 0 ) {
928 # The package definition has included minutes, but only for in-group
929 # rate details. Decrement them if this is an in-group call.
930 if ( $rate_detail->region_group ) {
931 if ( ${ $opt{'plan_included_min'} } >= $minutes ) {
933 ${ $opt{'plan_included_min'} } -= $minutes;
935 $charge_sec -= (${ $opt{'plan_included_min'} } * 60);
936 ${ $opt{'plan_included_min'} } = 0;
941 my $applied_min = $cust_pkg->apply_usage(
943 'rate_detail' => $rate_detail,
944 'minutes' => $minutes
946 # for now, usage pools deal only in whole minutes
947 $charge_sec -= $applied_min * 60;
950 if ( $charge_sec > 0 ) {
952 #NOW do connection charges here... right?
953 #my $conn_seconds = min($seconds_left, $rate_detail->conn_sec);
954 my $conn_seconds = 0;
955 unless ( $connection_charged++ ) { #only one connection charge
956 $conn_seconds = min($charge_sec, $rate_detail->conn_sec);
957 $seconds_left -= $conn_seconds;
958 $weektime += $conn_seconds;
959 $charge += $rate_detail->conn_charge;
962 #should preserve (display?) this
963 if ( $granularity == 0 ) { # per call rate
964 $charge += $rate_detail->min_charge;
966 my $charge_min = ( $charge_sec - $conn_seconds ) / 60;
967 $charge += ($rate_detail->min_charge * $charge_min) if $charge_min > 0; #still not rounded
972 # choose next rate_detail
973 $rate_detail = $rate->dest_detail({ 'countrycode' => $countrycode,
974 'phonenum' => $number,
975 'weektime' => $etime,
976 'cdrtypenum' => $self->cdrtypenum })
978 # we have now moved forward to $etime
981 } #while $seconds_left
983 # this is why we need regionnum/rate_region....
984 warn " (rate region $rate_region)\n" if $DEBUG;
987 my $rounding = $part_pkg->option_cacheable('rounding') || 2;
988 my $sprintformat = '%.'. $rounding. 'f';
989 my $roundup = 10**(-3-$rounding);
990 my $price = sprintf($sprintformat, $charge + $roundup);
992 $self->set_status_and_rated_price(
996 'rated_pretty_dst' => $pretty_dst,
997 'rated_regionname' => ($rate_region ? $rate_region->regionname : ''),
998 'rated_seconds' => $rated_seconds, #$seconds,
999 'rated_granularity' => $rate_detail->sec_granularity, #$granularity
1000 'rated_ratedetailnum' => $rate_detail->ratedetailnum,
1001 'rated_classnum' => $rate_detail->classnum, #rated_ratedetailnum?
1002 'rated_ratename' => $ratename, #not rate_detail - Intrastate/Interstate
1007 sub rate_upstream_simple {
1008 my( $self, %opt ) = @_;
1010 $self->set_status_and_rated_price(
1012 sprintf('%.3f', $self->upstream_price),
1014 'rated_classnum' => $self->calltypenum,
1015 'rated_seconds' => $self->billsec,
1016 # others? upstream_*_regionname => rated_regionname is possible
1020 sub rate_single_price {
1021 my( $self, %opt ) = @_;
1022 my $part_pkg = $opt{'part_pkg'} or return "No part_pkg specified";
1024 # a little false laziness w/abov
1025 # $rate_detail = new FS::rate_detail({sec_granularity => ... }) ?
1027 my $granularity = length($part_pkg->option_cacheable('sec_granularity'))
1028 ? $part_pkg->option_cacheable('sec_granularity')
1031 my $seconds = $part_pkg->option_cacheable('use_duration')
1035 $seconds += $granularity - ( $seconds % $granularity )
1036 if $seconds # don't granular-ize 0 billsec calls (bills them)
1037 && $granularity # 0 is per call
1038 && $seconds % $granularity;
1039 my $minutes = $granularity ? ($seconds / 60) : 1;
1041 my $charge_min = $minutes;
1043 ${$opt{plan_included_min}} -= $minutes;
1044 if ( ${$opt{plan_included_min}} > 0 ) {
1047 $charge_min = 0 - ${$opt{plan_included_min}};
1048 ${$opt{plan_included_min}} = 0;
1052 sprintf('%.4f', ( $part_pkg->option_cacheable('min_charge') * $charge_min )
1053 + 0.0000000001 ); #so 1.00005 rounds to 1.0001
1055 $self->set_status_and_rated_price(
1059 'rated_granularity' => $granularity,
1060 'rated_seconds' => $seconds,
1067 Rates an already-rated CDR according to the cost fields from the rate plan.
1076 return 0 unless $self->rated_ratedetailnum;
1079 qsearchs('rate_detail', { 'ratedetailnum' => $self->rated_ratedetailnum } );
1082 $charge += ($self->upstream_price || 0) * ($rate_detail->upstream_mult_cost);
1084 if ( $self->rated_granularity == 0 ) {
1085 $charge += $rate_detail->min_cost;
1087 my $minutes = $self->rated_seconds / 60;
1088 $charge += $rate_detail->conn_cost + $minutes * $rate_detail->min_cost;
1091 sprintf('%.2f', $charge + .00001 );
1095 =item cdr_termination [ TERMPART ]
1099 sub cdr_termination {
1102 if ( scalar(@_) && $_[0] ) {
1103 my $termpart = shift;
1105 qsearchs('cdr_termination', { acctid => $self->acctid,
1106 termpart => $termpart,
1112 qsearch('cdr_termination', { acctid => $self->acctid, } );
1120 Parses the calldate in SQL string format and returns a UNIX timestamp.
1125 str2time(shift->calldate);
1130 Parses the startdate in UNIX timestamp format and returns a string in SQL
1136 my($sec,$min,$hour,$mday,$mon,$year) = localtime(shift->startdate);
1139 "$year-$mon-$mday $hour:$min:$sec";
1144 Returns the FS::cdr_carrier object associated with this CDR, or false if no
1145 carrierid is defined.
1149 my %carrier_cache = ();
1153 return '' unless $self->carrierid;
1154 $carrier_cache{$self->carrierid} ||=
1155 qsearchs('cdr_carrier', { 'carrierid' => $self->carrierid } );
1160 Returns the carrier name (see L<FS::cdr_carrier>), or the empty string if
1161 no FS::cdr_carrier object is assocated with this CDR.
1167 my $cdr_carrier = $self->cdr_carrier;
1168 $cdr_carrier ? $cdr_carrier->carriername : '';
1173 Returns the FS::cdr_calltype object associated with this CDR, or false if no
1174 calltypenum is defined.
1178 my %calltype_cache = ();
1182 return '' unless $self->calltypenum;
1183 $calltype_cache{$self->calltypenum} ||=
1184 qsearchs('cdr_calltype', { 'calltypenum' => $self->calltypenum } );
1189 Returns the call type name (see L<FS::cdr_calltype>), or the empty string if
1190 no FS::cdr_calltype object is assocated with this CDR.
1196 my $cdr_calltype = $self->cdr_calltype;
1197 $cdr_calltype ? $cdr_calltype->calltypename : '';
1200 =item downstream_csv [ OPTION => VALUE, ... ]
1204 # in the future, load this dynamically from detail_format classes
1206 my %export_names = (
1209 'invoice_header' => "Date,Time,Name,Destination,Duration,Price",
1212 'name' => 'Simple with source',
1213 'invoice_header' => "Date,Time,Called From,Destination,Duration,Price",
1214 #"Date,Time,Name,Called From,Destination,Duration,Price",
1216 'accountcode_simple' => {
1217 'name' => 'Simple with accountcode',
1218 'invoice_header' => "Date,Time,Called From,Account,Duration,Price",
1222 'invoice_header' => "Date/Time,Called Number,Min/Sec,Price",
1224 'basic_upstream_dst_regionname' => {
1225 'name' => 'Basic with upstream destination name',
1226 'invoice_header' => "Date/Time,Called Number,Destination,Min/Sec,Price",
1229 'name' => 'Default',
1230 'invoice_header' => 'Date,Time,Number,Destination,Duration,Price',
1232 'source_default' => {
1233 'name' => 'Default with source',
1234 'invoice_header' => 'Caller,Date,Time,Number,Destination,Duration,Price',
1236 'accountcode_default' => {
1237 'name' => 'Default plus accountcode',
1238 'invoice_header' => 'Date,Time,Account,Number,Destination,Duration,Price',
1240 'description_default' => {
1241 'name' => 'Default with description field as destination',
1242 'invoice_header' => 'Caller,Date,Time,Number,Destination,Duration,Price',
1245 'name' => 'Summary, one line per service',
1246 'invoice_header' => 'Caller,Rate,Calls,Minutes,Price',
1249 'name' => 'Number of calls, one line per service',
1250 'invoice_header' => 'Caller,Rate,Messages,Price',
1252 'sum_duration_prefix' => {
1253 'name' => 'Summary, one line per destination prefix',
1254 'invoice_header' => 'Caller,Rate,Calls,Minutes,Price',
1256 'sum_count_class' => {
1257 'name' => 'Summary, one line per usage class',
1258 'invoice_header' => 'Caller,Class,Calls,Price',
1262 my %export_formats = ();
1263 sub export_formats {
1266 return %export_formats if keys %export_formats;
1268 my $conf = new FS::Conf;
1269 my $date_format = $conf->config('date_format') || '%m/%d/%Y';
1271 # call duration in the largest units that accurately reflect the granularity
1272 my $duration_sub = sub {
1273 my($cdr, %opt) = @_;
1274 my $sec = $opt{seconds} || $cdr->billsec;
1275 if ( defined $opt{granularity} &&
1276 $opt{granularity} == 0 ) { #per call
1279 elsif ( defined $opt{granularity} && $opt{granularity} == 60 ) {#full minutes
1280 my $min = int($sec/60);
1284 else { #anything else
1285 return sprintf("%dm %ds", $sec/60, $sec%60);
1289 my $price_sub = sub {
1290 my ($cdr, %opt) = @_;
1292 if ( defined($opt{charge}) ) {
1293 $price = $opt{charge};
1295 elsif ( $opt{inbound} ) {
1296 my $term = $cdr->cdr_termination(1); # 1 = inbound
1297 $price = $term->rated_price if defined $term;
1300 $price = $cdr->rated_price;
1302 length($price) ? ($opt{money_char} . $price) : '';
1305 my $src_sub = sub { $_[0]->clid || $_[0]->src };
1309 sub { time2str($date_format, shift->calldate_unix ) }, #DATE
1310 sub { time2str('%r', shift->calldate_unix ) }, #TIME
1312 'dst', #NUMBER_DIALED
1313 $duration_sub, #DURATION
1314 #sub { sprintf('%.3f', shift->upstream_price ) }, #PRICE
1318 sub { time2str($date_format, shift->calldate_unix ) }, #DATE
1319 sub { time2str('%r', shift->calldate_unix ) }, #TIME
1321 $src_sub, #called from
1322 'dst', #NUMBER_DIALED
1323 $duration_sub, #DURATION
1324 #sub { sprintf('%.3f', shift->upstream_price ) }, #PRICE
1327 'accountcode_simple' => [
1328 sub { time2str($date_format, shift->calldate_unix ) }, #DATE
1329 sub { time2str('%r', shift->calldate_unix ) }, #TIME
1330 $src_sub, #called from
1331 'accountcode', #NUMBER_DIALED
1332 $duration_sub, #DURATION
1336 # for summary formats, the CDR is a fictitious object containing the
1337 # total billsec and the phone number of the service
1339 sub { my($cdr, %opt) = @_; $opt{ratename} },
1340 sub { my($cdr, %opt) = @_; $opt{count} },
1341 sub { my($cdr, %opt) = @_; int($opt{seconds}/60).'m' },
1346 sub { my($cdr, %opt) = @_; $opt{ratename} },
1347 sub { my($cdr, %opt) = @_; $opt{count} },
1351 sub { time2str('%d %b - %I:%M %p', shift->calldate_unix) },
1359 sub { time2str($date_format, shift->calldate_unix ) },
1360 # #time2str("%Y %b %d - %r", $cdr->calldate_unix ),
1363 sub { time2str('%r', shift->calldate_unix ) },
1364 # 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
1367 sub { my($cdr, %opt) = @_; $opt{pretty_dst} || $cdr->dst; },
1369 #REGIONNAME ("Destination")
1370 sub { my($cdr, %opt) = @_; $opt{dst_regionname}; },
1379 $export_formats{'source_default'} = [ $src_sub, @{ $export_formats{'default'} }, ];
1380 $export_formats{'accountcode_default'} =
1381 [ @{ $export_formats{'default'} }[0,1],
1383 @{ $export_formats{'default'} }[2..5],
1385 my @default = @{ $export_formats{'default'} };
1386 $export_formats{'description_default'} =
1387 [ $src_sub, @default[0..2],
1388 sub { my($cdr, %opt) = @_; $cdr->description },
1391 return %export_formats;
1394 =item downstream_csv OPTION => VALUE ...
1396 Returns a string of formatted call details for display on an invoice.
1402 charge - override the 'rated_price' field of the CDR
1404 seconds - override the 'billsec' field of the CDR
1406 count - number of usage events included in this record, for summary formats
1408 ratename - name of the rate table used to rate this call
1414 sub downstream_csv {
1415 my( $self, %opt ) = @_;
1417 my $format = $opt{'format'};
1418 my %formats = $self->export_formats;
1419 return "Unknown format $format" unless exists $formats{$format};
1421 #my $conf = new FS::Conf;
1422 #$opt{'money_char'} ||= $conf->config('money_char') || '$';
1423 $opt{'money_char'} ||= FS::Conf->new->config('money_char') || '$';
1425 my $csv = new Text::CSV_XS;
1429 ref($_) ? &{$_}($self, %opt) : $self->$_();
1431 @{ $formats{$format} };
1433 return @columns if defined $opt{'keeparray'};
1435 my $status = $csv->combine(@columns);
1436 die "FS::CDR: error combining ". $csv->error_input(). "into downstream CSV"
1445 =head1 CLASS METHODS
1449 =item invoice_formats
1451 Returns an ordered list of key value pairs containing invoice format names
1452 as keys (for use with part_pkg::voip_cdr) and "pretty" format names as values.
1456 # in the future, load this dynamically from detail_format classes
1458 sub invoice_formats {
1459 map { ($_ => $export_names{$_}->{'name'}) }
1460 grep { $export_names{$_}->{'invoice_header'} }
1461 sort keys %export_names;
1464 =item invoice_header FORMAT
1466 Returns a scalar containing the CSV column header for invoice format FORMAT.
1470 sub invoice_header {
1472 $export_names{$format}->{'invoice_header'};
1477 Clears cdr and any associated cdr_termination statuses - used for
1486 local $SIG{HUP} = 'IGNORE';
1487 local $SIG{INT} = 'IGNORE';
1488 local $SIG{QUIT} = 'IGNORE';
1489 local $SIG{TERM} = 'IGNORE';
1490 local $SIG{TSTP} = 'IGNORE';
1491 local $SIG{PIPE} = 'IGNORE';
1493 my $oldAutoCommit = $FS::UID::AutoCommit;
1494 local $FS::UID::AutoCommit = 0;
1497 if ( $cdr_prerate && $cdr_prerate_cdrtypenums{$self->cdrtypenum}
1498 && $self->rated_ratedetailnum #avoid putting old CDRs back in "rated"
1499 && $self->freesidestatus eq 'done'
1503 $self->freesidestatus('rated');
1505 $self->freesidestatus('');
1508 my $error = $self->replace;
1510 $dbh->rollback if $oldAutoCommit;
1514 foreach my $cdr_termination ( $self->cdr_termination ) {
1515 #$cdr_termination->status('');
1516 #$error = $cdr_termination->replace;
1517 $error = $cdr_termination->delete;
1519 $dbh->rollback if $oldAutoCommit;
1524 $dbh->commit or die $dbh->errstr if $oldAutoCommit;
1529 =item import_formats
1531 Returns an ordered list of key value pairs containing import format names
1532 as keys (for use with batch_import) and "pretty" format names as values.
1536 #false laziness w/part_pkg & part_export
1539 foreach my $INC ( @INC ) {
1540 warn "globbing $INC/FS/cdr/[a-z]*.pm\n" if $DEBUG;
1541 foreach my $file ( glob("$INC/FS/cdr/[a-z]*.pm") ) {
1542 warn "attempting to load CDR format info from $file\n" if $DEBUG;
1543 $file =~ /\/(\w+)\.pm$/ or do {
1544 warn "unrecognized file in $INC/FS/cdr/: $file\n";
1548 my $info = eval "use FS::cdr::$mod; ".
1549 "\\%FS::cdr::$mod\::info;";
1551 die "error using FS::cdr::$mod (skipping): $@\n" if $@;
1554 unless ( keys %$info ) {
1555 warn "no %info hash found in FS::cdr::$mod, skipping\n";
1558 warn "got CDR format info from FS::cdr::$mod: $info\n" if $DEBUG;
1559 if ( exists($info->{'disabled'}) && $info->{'disabled'} ) {
1560 warn "skipping disabled CDR format FS::cdr::$mod" if $DEBUG;
1563 $cdr_info{$mod} = $info;
1567 tie my %import_formats, 'Tie::IxHash',
1568 map { $_ => $cdr_info{$_}->{'name'} }
1569 sort { $cdr_info{$a}->{'weight'} <=> $cdr_info{$b}->{'weight'} }
1570 grep { exists($cdr_info{$_}->{'import_fields'}) }
1573 sub import_formats {
1577 sub _cdr_min_parser_maker {
1579 my @fields = ref($field) ? @$field : ($field);
1580 @fields = qw( billsec duration ) unless scalar(@fields) && $fields[0];
1582 my( $cdr, $min ) = @_;
1583 my $sec = eval { _cdr_min_parse($min) };
1584 die "error parsing seconds for @fields from $min minutes: $@\n" if $@;
1585 $cdr->$_($sec) foreach @fields;
1589 sub _cdr_min_parse {
1591 sprintf('%.0f', $min * 60 );
1594 sub _cdr_date_parser_maker {
1597 my @fields = ref($field) ? @$field : ($field);
1599 my( $cdr, $datestring ) = @_;
1600 my $unixdate = eval { _cdr_date_parse($datestring, %options) };
1601 die "error parsing date for @fields from $datestring: $@\n" if $@;
1602 $cdr->$_($unixdate) foreach @fields;
1606 sub _cdr_date_parse {
1610 return '' unless length($date); #that's okay, it becomes NULL
1611 return '' if $date eq 'NA'; #sansay
1613 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 ) {
1614 my $time = str2time($date);
1615 return $time if $time > 100000; #just in case
1618 my($year, $mon, $day, $hour, $min, $sec);
1620 #$date =~ /^\s*(\d{4})[\-\/]\(\d{1,2})[\-\/](\d{1,2})\s+(\d{1,2}):(\d{1,2}):(\d{1,2})\s*$/
1621 #taqua #2007-10-31 08:57:24.113000000
1623 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|$)/ ) {
1624 ($year, $mon, $day, $hour, $min, $sec) = ( $1, $2, $3, $4, $5, $6 );
1625 } 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|$)/ ) {
1626 # 8/26/2010 12:20:01
1627 # optionally without seconds
1628 ($mon, $day, $year, $hour, $min, $sec) = ( $1, $2, $3, $4, $5, $6 );
1629 $sec = 0 if !defined($sec);
1630 } elsif ( $date =~ /^\s*(\d{4})(\d{2})(\d{2})(\d{2})(\d{2})(\d{2})(\.\d+)$/ ) {
1631 # broadsoft: 20081223201938.314
1632 ($year, $mon, $day, $hour, $min, $sec) = ( $1, $2, $3, $4, $5, $6 );
1633 } elsif ( $date =~ /^\s*(\d{4})(\d{2})(\d{2})(\d{2})(\d{2})(\d{2})\d+(\D|$)/ ) {
1634 # Taqua OM: 20050422203450943
1635 ($year, $mon, $day, $hour, $min, $sec) = ( $1, $2, $3, $4, $5, $6 );
1636 } elsif ( $date =~ /^\s*(\d{4})(\d{2})(\d{2})(\d{2})(\d{2})(\d{2})$/ ) {
1637 # WIP: 20100329121420
1638 ($year, $mon, $day, $hour, $min, $sec) = ( $1, $2, $3, $4, $5, $6 );
1639 } elsif ( $date =~ /^(\d{4})-(\d{2})-(\d{2})T(\d{2}):(\d{2}):(\d{2})Z$/) {
1640 # Telos 2014-10-10T05:30:33Z
1641 ($year, $mon, $day, $hour, $min, $sec) = ( $1, $2, $3, $4, $5, $6 );
1644 die "unparsable date: $date"; #maybe we shouldn't die...
1647 return '' if ( $year == 1900 || $year == 1970 ) && $mon == 1 && $day == 1
1648 && $hour == 0 && $min == 0 && $sec == 0;
1650 if ($options{gmt}) {
1651 timegm($sec, $min, $hour, $day, $mon-1, $year);
1653 timelocal($sec, $min, $hour, $day, $mon-1, $year);
1657 =item batch_import HASHREF
1659 Imports CDR records. Available options are:
1671 Hash reference of preset fields, typically cdrbatch
1675 Set true to prevent throwing an error on empty imports
1681 my %import_options = (
1684 'batch_keycol' => 'cdrbatchnum',
1685 'batch_table' => 'cdr_batch',
1686 'batch_namecol' => 'cdrbatch',
1688 'formats' => { map { $_ => $cdr_info{$_}->{'import_fields'}; }
1692 #drop the || 'csv' to allow auto xls for csv types?
1693 'format_types' => { map { $_ => lc($cdr_info{$_}->{'type'} || 'csv'); }
1697 'format_headers' => { map { $_ => ( $cdr_info{$_}->{'header'} || 0 ); }
1701 'format_sep_chars' => { map { $_ => $cdr_info{$_}->{'sep_char'}; }
1705 'format_fixedlength_formats' =>
1706 { map { $_ => $cdr_info{$_}->{'fixedlength_format'}; }
1710 'format_xml_formats' =>
1711 { map { $_ => $cdr_info{$_}->{'xml_format'}; }
1715 'format_asn_formats' =>
1716 { map { $_ => $cdr_info{$_}->{'asn_format'}; }
1720 'format_row_callbacks' =>
1721 { map { $_ => $cdr_info{$_}->{'row_callback'}; }
1725 'format_parser_opts' =>
1726 { map { $_ => $cdr_info{$_}->{'parser_opt'}; }
1731 sub _import_options {
1738 my $iopt = _import_options;
1739 $opt->{$_} = $iopt->{$_} foreach keys %$iopt;
1741 if ( defined $opt->{'cdrtypenum'} ) {
1742 $opt->{'preinsert_callback'} = sub {
1743 my($record,$param) = (shift,shift);
1744 $record->cdrtypenum($opt->{'cdrtypenum'});
1749 FS::Record::batch_import( $opt );
1753 =item process_batch_import
1757 sub process_batch_import {
1760 my $opt = _import_options;
1761 # $opt->{'params'} = [ 'format', 'cdrbatch' ];
1763 FS::Record::process_batch_import( $job, $opt, @_ );
1766 # if ( $format eq 'simple' ) { #should be a callback or opt in FS::cdr::simple
1767 # @columns = map { s/^ +//; $_; } @columns;
1772 # Used by FS::Upgrade to migrate to a new database.
1775 my ($class, %opts) = @_;
1777 warn "$me upgrading $class\n" if $DEBUG;
1779 my $sth = dbh->prepare(
1780 'SELECT DISTINCT(cdrbatch) FROM cdr WHERE cdrbatch IS NOT NULL'
1781 ) or die dbh->errstr;
1783 $sth->execute or die $sth->errstr;
1785 my %cdrbatchnum = ();
1786 while (my $row = $sth->fetchrow_arrayref) {
1788 my $cdr_batch = qsearchs( 'cdr_batch', { 'cdrbatch' => $row->[0] } );
1789 unless ( $cdr_batch ) {
1790 $cdr_batch = new FS::cdr_batch { 'cdrbatch' => $row->[0] };
1791 my $error = $cdr_batch->insert;
1792 die $error if $error;
1795 $cdrbatchnum{$row->[0]} = $cdr_batch->cdrbatchnum;
1798 $sth = dbh->prepare('UPDATE cdr SET cdrbatch = NULL, cdrbatchnum = ? WHERE cdrbatch IS NOT NULL AND cdrbatch = ?') or die dbh->errstr;
1800 foreach my $cdrbatch (keys %cdrbatchnum) {
1801 $sth->execute($cdrbatchnum{$cdrbatch}, $cdrbatch) or die $sth->errstr;
1806 =item ip_addr_sql FIELD RANGE
1808 Returns an SQL condition to search for CDRs with an IP address
1809 within RANGE. FIELD is either 'src_ip_addr' or 'dst_ip_addr'. RANGE
1810 should be in the form "a.b.c.d-e.f.g.h' (dotted quads), where any of
1811 the leftmost octets of the second address can be omitted if they're
1812 the same as the first address.
1818 my ($field, $range) = @_;
1819 $range =~ /^[\d\.-]+$/ or die "bad ip address range '$range'";
1820 my @r = split('-', $range);
1821 my @saddr = split('\.', $r[0] || '');
1822 my @eaddr = split('\.', $r[1] || '');
1823 unshift @eaddr, (undef) x (4 - scalar @eaddr);
1825 $eaddr[$_] = $saddr[$_] if !defined $eaddr[$_];
1827 "$field >= '".sprintf('%03d.%03d.%03d.%03d', @saddr) . "' AND ".
1828 "$field <= '".sprintf('%03d.%03d.%03d.%03d', @eaddr) . "'";
1837 L<FS::Record>, schema.html from the base documentation.