format_headers => $opt->{format_headers},
format_sep_chars => $opt->{format_sep_chars},
format_fixedlength_formats => $opt->{format_fixedlength_formats},
+ format_row_callbacks => $opt->{format_row_callbacks},
#per-import
job => $job,
file => $file,
=item format_fixedlength_formats
+=item format_row_callbacks
+
=item params
=item job
my $param = shift;
warn "$me batch_import call with params: \n". Dumper($param)
- if $DEBUG;
+ ;# if $DEBUG;
my $table = $param->{table};
my $formats = $param->{formats};
? $param->{'format_fixedlength_formats'}{ $param->{'format'} }
: '';
+ my $row_callback =
+ $param->{'format_row_callbacks'}
+ ? $param->{'format_row_callbacks'}{ $param->{'format'} }
+ : '';
+
my @fields = @{ $formats->{ $format } };
my $row = 0;
next if $line =~ /^\s*$/; #skip empty lines
+ $line = &{$row_callback}($line) if $row_callback;
+
$parser->parse($line) or do {
$dbh->rollback if $oldAutoCommit;
return "can't parse: ". $parser->error_input();
} elsif ( $date =~ /^\s*(\d{4})(\d{2})(\d{2})(\d{2})(\d{2})(\d+\.\d+)(\D|$)/ ) {
# broadsoft: 20081223201938.314
($year, $mon, $day, $hour, $min, $sec) = ( $1, $2, $3, $4, $5, $6 );
+ } elsif ( $date =~ /^\s*(\d{4})(\d{2})(\d{2})(\d{2})(\d{2})(\d{2})\d+(\D|$)/ ) {
+ # Taqua OM: 20050422203450943
+ ($year, $mon, $day, $hour, $min, $sec) = ( $1, $2, $3, $4, $5, $6 );
} elsif ( $date =~ /^\s*(\d{4})(\d{2})(\d{2})(\d{2})(\d{2})(\d{2})$/ ) {
# WIP: 20100329121420
($year, $mon, $day, $hour, $min, $sec) = ( $1, $2, $3, $4, $5, $6 );
{ map { $_ => $cdr_info{$_}->{'fixedlength_format'}; }
keys %cdr_info
},
+
+ 'format_row_callbacks' => { map { $_ => $cdr_info{$_}->{'row_callback'}; }
+ keys %cdr_info
+ },
);
sub _import_options {
--- /dev/null
+package FS::cdr::taqua_om;
+
+use strict;
+use vars qw( %info );
+use base qw( FS::cdr::taqua );
+
+%info = (
+ %FS::cdr::taqua::info,
+ 'name' => 'Taqua OM',
+ 'weight' => 132,
+ 'header' => 0,
+ 'sep_char' => ';',
+ 'row_callback' => sub { my $row = shift;
+ $row =~ s/^<\d+>\|[\da-f\|]+\|(\d+;)/$1/;
+ $row;
+ },
+);
+
+1;