Update of /home/cvs/cvsroot/freeside/bin
In directory wavetail.420.am:/tmp/cvs-serv27696
Modified Files:
import-optigold.pl
Log Message:
guess at on demand billing, link pre-existing services
Index: import-optigold.pl
===================================================================
RCS file: /home/cvs/cvsroot/freeside/bin/import-optigold.pl,v
retrieving revision 1.2
retrieving revision 1.3
diff -u -d -r1.2 -r1.3
--- import-optigold.pl 14 May 2008 18:19:05 -0000 1.2
+++ import-optigold.pl 31 May 2008 23:50:11 -0000 1.3
@@ -27,6 +27,7 @@
#my $d_dbuser = 'freeside';
my $d_dbuser = 'enet';
#my $d_dbuser = 'ivan';
+#my $d_dbuser = 'freesideimport';
#my $agentnum = 1;
my $agentnum = 13;
@@ -34,7 +35,7 @@
my $legacy_ppp_svcnum = 2;
my $legacy_email_svcnum = 3;
#my $legacy_broadband_svcnum = 4;
-my $legacy_broadband_svcnum = 14;
+#my $legacy_broadband_svcnum = 14;
#my $previous_credit_reasonnum = 1;
my $previous_credit_reasonnum = 1220;
@@ -332,6 +333,30 @@
'domsvc' => sub{ $legacy_domain_svcnum },
'status' => 'status',
},
+# 'fixup' => sub { my $svc_acct = shift;
+# my $row = shift;
+# my $id = $row->{'master_account'}
+# ? 'slave:'. $row->{'customer_id'}
+# : $row->{'login'};
+# my $status = $svc_acct->status;
+# if ( $status ne 'Current'
+# && $status ne 'On Hold' )
+# {
+# $cancel{$id} =
+# str2time($row->{termination_date});
+# warn "not creating (cancelled) svc_acct for " .
+# $svc_acct->username. "\n";
+# return 1
+# }
+# $susp{$id} = str2time($row->{hold_date})
+# if $status eq 'On Hold';
+# $adjo{$id} = str2time($row->{hold_date})
+# if ( $status eq 'Current' &&
+# $row->{hold_date} );
+# $bill{$id} =
+# str2time($row->{expiration_date});
+# '';
+# },
'fixup' => sub { my $svc_acct = shift;
my $row = shift;
my $id = $row->{'master_account'}
@@ -343,8 +368,6 @@
{
$cancel{$id} =
str2time($row->{termination_date});
- warn "not creating (cancelled) svc_acct for " .
- $svc_acct->username. "\n";
return 1
}
$susp{$id} = str2time($row->{hold_date})
@@ -354,14 +377,25 @@
$row->{hold_date} );
$bill{$id} =
str2time($row->{expiration_date});
- '';
- },
- 'skey' => sub { my $svc_acct = shift;
- my $row = shift;
- my $id = $row->{'master_account'}
- ? 'slave:'. $row->{'customer_id'}
- : $row->{'login'};
+ my $object =
+ qsearchs( 'svc_acct',
+ { 'username' => $row->{'login'} }
+ );
+ unless( $object ) {
+ warn "can't find svc_acct for legacy ppp ".
+ $row->{'login'};
+ return 1;
+ }
+
+ $object_map{svc_acct}{$id} = $object->svcnum;
+ return 1;
},
+# 'skey' => sub { my $svc_acct = shift;
+# my $row = shift;
+# my $id = $row->{'master_account'}
+# ? 'slave:'. $row->{'customer_id'}
+# : $row->{'login'};
+# },
},
cust_main => { 'stable' => 'cust',
'mapping' =>
@@ -400,17 +434,28 @@
'payby' => \&payby,
'payinfo' => sub { my $hash = shift;
my $payby = payby($hash);
- if ($payby eq 'CARD') {
+ my $cc =
$hash->{'credit_card_number_1'}.
$hash->{'credit_card_number_2'}.
$hash->{'credit_card_number_3'}.
$hash->{'credit_card_number_4'};
- }elsif ($payby eq 'CHEK') {
+ my $bank =
$hash->{'bank_account_number'}.
'@'.
$hash->{'bank_transit_number'};
+ if ($payby eq 'CARD') {
+ $cc;
+ }elsif ($payby eq 'CHEK') {
+ $bank;
}elsif ($payby eq 'BILL') {
- $hash->{'blanket_purchase_order_number'};
+ my $info = $hash->{'blanket_purchase_order_number'};
+ $bank =~ s/[^\d\@]//g;
+ $cc =~ s/\D//g;
+ $info = $bank
+ if $bank =~ /^\d+\@\d{9}/;
+ $info = $cc
+ if $cc =~ /^\d{13,16}/;
+ $info;
}else{
die "unexpected payby";
}
@@ -610,10 +655,24 @@
'svcpart' => sub{ $legacy_email_svcnum },
'domsvc' => sub{ $legacy_domain_svcnum },
},
- 'fixup' => sub { my $object = shift;
+# 'fixup' => sub { my ($object, $row) = (shift,shift);
+# my ($sd,$sm,$sy) = split '/',
+# $row->{shut_off_date}
+# if $row->{shut_off_date};
+# if ($sd && $sm && $sy) {
+# my ($cd, $cm, $cy) = (localtime)[3,4,5];
+# $cy += 1900; $cm++;
+# return 1 if $sy < $cy;
+# return 1 if ($sy == $cy && $sm < $cm);
+# return 1 if ($sy == $cy && $sm == $cm && $sd <= $cd);
+# }
+# return 1 if $object_map{'cust_main'}{$object->username};
+# '';
+# },
+ 'fixup' => sub { my ($object, $row) = (shift,shift);
my ($sd,$sm,$sy) = split '/',
- $object->{shut_off_date}
- if $object->{shut_off_date};
+ $row->{shut_off_date}
+ if $row->{shut_off_date};
if ($sd && $sm && $sy) {
my ($cd, $cm, $cy) = (localtime)[3,4,5];
$cy += 1900; $cm++;
@@ -622,12 +681,22 @@
return 1 if ($sy == $cy && $sm == $cm && $sd <= $cd);
}
return 1 if $object_map{'cust_main'}{$object->username};
- '';
- },
- 'skey' => sub { my $object = shift;
- my $href = shift;
- 'email:'. $href->{'email_customer_id'};
+ my $svc_acct =
+ qsearchs( 'svc_acct',
+ { 'username' => $row->{'login'} }
+ );
+ unless( $svc_acct ) {
+ warn "can't find svc_acct for email ".
+ $row->{'login'};
+ return 1;
+ }
+ $object_map{svc_acct}{'email:'.$row->{'email_customer_id'}} = $svc_acct->svcnum;
+ return 1;
},
+# 'skey' => sub { my $object = shift;
+# my $href = shift;
+# 'email:'. $href->{'email_customer_id'};
+# },
'wrapup' => sub { for my $id (keys %{$object_map{'cust_pkg'}}){
next unless $id =~ /^email:(\d+)/;
my $custid = $1;
@@ -636,14 +705,14 @@
$object_map{'svc_acct'}{$id} }
);
unless ($cust_svc) {
- warn "can't find legacy ppp $id\n";
+ warn "can't find legacy email $id\n";
next;
}
$cust_svc->
pkgnum($cust_pkg_map{$custid});
my $error = $cust_svc->replace;
- warn "error linking legacy ppp $id: $error\n";
+ warn "error linking legacy email $id: $error\n";
}
},
},