=over 4
-=item batch_import
+=item import_formats
+
+Returns an ordered list of key value pairs containing import format names
+as keys (for use with batch_import) and "pretty" format names as values.
=cut
+sub import_formats {
+ 'asterisk' => 'Asterisk',
+ 'taqua' => 'Taqua',
+ 'unitel' => 'Unitel/RSLCOM',
+ 'simple' => 'Simple',
+}
+
my($tmp_mday, $tmp_mon, $tmp_year);
+sub _cdr_date_parser_maker {
+ my $field = shift;
+ return sub {
+ my( $cdr, $date ) = @_;
+ $cdr->$field( _cdr_date_parse($date) );
+ };
+}
+
+sub _cdr_date_parse {
+ my $date = shift;
+
+ return '' unless length($date); #that's okay, it becomes NULL
+
+ #$date =~ /^\s*(\d{4})[\-\/]\(\d{1,2})[\-\/](\d{1,2})\s+(\d{1,2}):(\d{1,2}):(\d{1,2})\s*$/
+ $date =~ /^\s*(\d{4})\D(\d{1,2})\D(\d{1,2})\s+(\d{1,2})\D(\d{1,2})\D(\d{1,2})\s*$/
+ or die "unparsable date: $date"; #maybe we shouldn't die...
+ my($year, $mon, $day, $hour, $min, $sec) = ( $1, $2, $3, $4, $5, $6 );
+
+ timelocal($sec, $min, $hour, $day, $mon-1, $year);
+}
+
+#http://www.the-asterisk-book.com/unstable/funktionen-cdr.html
+my %amaflags = (
+ DEFAULT => 0,
+ OMIT => 1, #asterisk 1.4+
+ IGNORE => 1, #asterisk 1.2
+ BILLING => 2, #asterisk 1.4+
+ BILL => 2, #asterisk 1.2
+ DOCUMENTATION => 3,
+ #? '' => 0,
+);
+
my %import_formats = (
'asterisk' => [
'accountcode',
'dstchannel',
'lastapp',
'lastdata',
- 'startdate', # XXX will need massaging
- 'answer', # XXX same
- 'end', # XXX same
+ _cdr_date_parser_maker('startdate'),
+ _cdr_date_parser_maker('answerdate'),
+ _cdr_date_parser_maker('enddate'),
'duration',
'billsec',
'disposition',
- 'amaflags',
+ sub { my($cdr, $amaflags) = @_; $cdr->amaflags($amaflags{$amaflags}); },
'uniqueid',
'userfield',
],
+ 'taqua' => [
+ sub { my($cdr, $field) = @_; }, #RecordType
+ sub { my($cdr, $field) = @_; }, #all10#RecordVersion
+ sub { my($cdr, $field) = @_; }, #OrigShelfNumber
+ sub { my($cdr, $field) = @_; }, #OrigCardNumber
+ sub { my($cdr, $field) = @_; }, #OrigCircuit
+ sub { my($cdr, $field) = @_; }, #OrigCircuitType
+ sub { my($cdr, $field) = @_; }, #SequenceNumber
+ sub { my($cdr, $field) = @_; }, #SessionNumber
+ sub { my($cdr, $field) = @_; }, #CallingPartyNumber
+ sub { my($cdr, $field) = @_; }, #CalledPartyNumber
+ sub { my($cdr, $field) = @_; }, #CallArrivalTime
+ sub { my($cdr, $field) = @_; }, #CallCompletionTime
+ sub { my($cdr, $field) = @_; }, #Disposition
+ sub { my($cdr, $field) = @_; }, #DispositionTime
+ sub { my($cdr, $field) = @_; }, #TCAP
+ sub { my($cdr, $field) = @_; }, #OutboundCarrierConnectTime
+ sub { my($cdr, $field) = @_; }, #OutboundCarrierDisconnectTime
+ sub { my($cdr, $field) = @_; }, #TermTrunkGroup
+ sub { my($cdr, $field) = @_; }, #TermShelfNumber
+ sub { my($cdr, $field) = @_; }, #TermCardNumber
+ sub { my($cdr, $field) = @_; }, #TermCircuit
+ sub { my($cdr, $field) = @_; }, #TermCircuitType
+ sub { my($cdr, $field) = @_; }, #OutboundCarrierId
+ sub { my($cdr, $field) = @_; }, #BillingNumber
+ sub { my($cdr, $field) = @_; }, #SubscriberNumber
+ sub { my($cdr, $field) = @_; }, #ServiceName
+ sub { my($cdr, $field) = @_; }, #ChargeTime
+ sub { my($cdr, $field) = @_; }, #ServiceInformation
+ sub { my($cdr, $field) = @_; }, #FacilityInfo
+ sub { my($cdr, $field) = @_; }, #CallTraceTime
+ sub { my($cdr, $field) = @_; }, #all-1#UniqueIndicator
+ sub { my($cdr, $field) = @_; }, #all-1#PresentationIndicator
+ sub { my($cdr, $field) = @_; }, #empty#Pin
+ sub { my($cdr, $field) = @_; }, #CallType
+ sub { my($cdr, $field) = @_; }, #OrigRateCenter
+ sub { my($cdr, $field) = @_; }, #TermRateCenter
+ sub { my($cdr, $field) = @_; }, #OrigTrunkGroup
+ 'userfield', #empty#UserDefined
+ sub { my($cdr, $field) = @_; }, #empty#PseudoDestinationNumber
+ sub { my($cdr, $field) = @_; }, #all-1#PseudoCarrierCode
+ sub { my($cdr, $field) = @_; }, #empty#PseudoANI
+ sub { my($cdr, $field) = @_; }, #all-1#PseudoFacilityInfo
+ sub { my($cdr, $field) = @_; }, #OrigDialedDigits
+ sub { my($cdr, $field) = @_; }, #all-1#OrigOutboundCarrier
+ sub { my($cdr, $field) = @_; }, #IncomingCarrierID
+ sub { my($cdr, $field) = @_; }, #JurisdictionInfo
+ sub { my($cdr, $field) = @_; }, #OrigDestDigits
+ sub { my($cdr, $field) = @_; }, #InsertTime
+ sub { my($cdr, $field) = @_; }, #key
+ sub { my($cdr, $field) = @_; }, #empty#AMALineNumber
+ sub { my($cdr, $field) = @_; }, #empty#AMAslpID
+ sub { my($cdr, $field) = @_; }, #empty#AMADigitsDialedWC
+ sub { my($cdr, $field) = @_; }, #OpxOffHook
+ sub { my($cdr, $field) = @_; }, #OpxOnHook
+
+#acctid - primary key
+#calldate - Call timestamp (SQL timestamp)
+#clid - Caller*ID with text
+#src - Caller*ID number / Source number
+#dst - Destination extension
+#dcontext - Destination context
+#channel - Channel used
+#dstchannel - Destination channel if appropriate
+#lastapp - Last application if appropriate
+#lastdata - Last application data
+#startdate - Start of call (UNIX-style integer timestamp)
+#answerdate - Answer time of call (UNIX-style integer timestamp)
+#enddate - End time of call (UNIX-style integer timestamp)
+#duration - Total time in system, in seconds
+#billsec - Total time call is up, in seconds
+#disposition - What happened to the call: ANSWERED, NO ANSWER, BUSY
+#amaflags - What flags to use: BILL, IGNORE etc, specified on a per
+#channel basis like accountcode.
+#accountcode - CDR account number to use: account
+#uniqueid - Unique channel identifier (Unitel/RSLCOM Event ID)
+ #userfield - CDR user-defined field
+#cdr_type - CDR type - see FS::cdr_type (Usage = 1, S&E = 7, OC&C = 8)
+#charged_party - Service number to be billed
+#upstream_currency - Wholesale currency from upstream
+#upstream_price - Wholesale price from upstream
+#upstream_rateplanid - Upstream rate plan ID
+#rated_price - Rated (or re-rated) price
+#distance - km (need units field?)
+#islocal - Local - 1, Non Local = 0
+#calltypenum - Type of call - see FS::cdr_calltype
+#description - Description (cdr_type 7&8 only) (used for
+#cust_bill_pkg.itemdesc)
+#quantity - Number of items (cdr_type 7&8 only)
+#carrierid - Upstream Carrier ID (see FS::cdr_carrier)
+#upstream_rateid - Upstream Rate ID
+ #svcnum - Link to customer service (see FS::cust_svc)
+ #freesidestatus - NULL, done (or something)
+
+ ],
'unitel' => [
'uniqueid',
#'cdr_type',
'carrierid',
'upstream_rateid',
],
- 'ams' => [
+ 'simple' => [
# Date
sub { my($cdr, $date) = @_;
],
);
+my %import_header = (
+ 'simple' => 1,
+ 'taqua' => 1,
+);
+
+=item batch_import HASHREF
+
+Imports CDR records. Available options are:
+
+=over 4
+
+=item filehandle
+
+=item format
+
+=back
+
+=cut
+
sub batch_import {
my $param = shift;
local $FS::UID::AutoCommit = 0;
my $dbh = dbh;
- if ( $format eq 'ams' ) { # and other formats with a header too?
-
- }
-
my $body = 0;
my $line;
while ( defined($line=<$fh>) ) {
#skip header...
- if ( ! $body++ && $format eq 'ams' && $line =~ /^[\w\, ]+$/ ) {
+ if ( ! $body++ && $import_header{'format'} && $line =~ /^[\w\, ]+$/ ) {
next;
}
my @columns = $csv->fields();
#warn join('-',@columns);
- if ( $format eq 'ams' ) {
+ if ( $format eq 'simple' ) {
@columns = map { s/^ +//; $_; } @columns;
}
projects / freeside.git / blobdiff