X-Git-Url: http://git.freeside.biz/gitweb/?a=blobdiff_plain;f=FS%2FFS%2Fotaker_Mixin.pm;h=af61a85ac12156ea5238e68ceb229ab154b33fbb;hb=5af515ac6bdc6ff88860c618207660eac48c276a;hp=c8479cd7790b7c97b8f0832224e8024adf13bc11;hpb=627408df58ee7efff68e8cb08e0deba5a677d8a9;p=freeside.git diff --git a/FS/FS/otaker_Mixin.pm b/FS/FS/otaker_Mixin.pm index c8479cd77..af61a85ac 100644 --- a/FS/FS/otaker_Mixin.pm +++ b/FS/FS/otaker_Mixin.pm @@ -4,6 +4,7 @@ use strict; use Carp qw( croak ); #confess ); use FS::Record qw( qsearch qsearchs ); use FS::access_user; +use FS::UID qw( dbh ); sub otaker { my $self = shift; @@ -13,6 +14,7 @@ sub otaker { if ( !$access_user && $otaker =~ /^(.+), (.+)$/ ) { #same as below.. my($lastname, $firstname) = ($1, $2); $otaker = lc($firstname.$lastname); + $otaker =~ s/ //g; $access_user = qsearchs('access_user', { 'first' => $firstname, 'last' => $lastname } ) || qsearchs('access_user', { 'username' => $otaker } ); @@ -40,11 +42,13 @@ sub _upgrade_otaker { my $class = shift; my $table = $class->table; + my $limit = ( $table eq 'cust_attachment' ? 10 : 1000 ); + while ( 1 ) { my @records = qsearch({ 'table' => $table, 'hashref' => {}, - 'extra_sql' => 'WHERE otaker IS NOT NULL LIMIT 1000', + 'extra_sql' => "WHERE otaker IS NOT NULL LIMIT $limit", }); last unless @records; @@ -52,14 +56,17 @@ sub _upgrade_otaker { eval { $record->otaker($record->otaker) }; if ( $@ ) { my $username = $record->otaker; + my($lastname, $firstname) = ( 'User', 'Legacy' ); if ( $username =~ /^(.+), (.+)$/ ) { - $username = lc($2.$1); + ($lastname, $firstname) = ($1, $2); + $username = lc($firstname.$lastname); + $username =~ s/ //g; } my $access_user = new FS::access_user { 'username' => $username, '_password' => 'CHANGEME', - 'first' => 'Legacy', - 'last' => 'User', + 'first' => $firstname, + 'last' => $lastname, 'disabled' => 'Y', }; my $error = $access_user->insert; @@ -70,6 +77,11 @@ sub _upgrade_otaker { my $error = $record->replace; die $error if $error; } + + if ( $table eq 'cust_attachment' ) { + warn " committing (cust_attachment) \n"; + dbh->commit or die dbh->errstr; + } }