X-Git-Url: http://git.freeside.biz/gitweb/?a=blobdiff_plain;f=FS%2FFS%2Fcust_pkg_reason.pm;h=403751369dd677b3d109d9f4941551ffbc55451f;hb=027756090552715f79cd3a4de08ee73091ad99f0;hp=2f927401feb7fc35406c28c8f31d4e75fadd3f22;hpb=ce98306f315a53f2ac4b8c010341c4f84bf728a8;p=freeside.git diff --git a/FS/FS/cust_pkg_reason.pm b/FS/FS/cust_pkg_reason.pm index 2f927401f..403751369 100644 --- a/FS/FS/cust_pkg_reason.pm +++ b/FS/FS/cust_pkg_reason.pm @@ -98,6 +98,7 @@ sub check { $self->ut_numbern('num') || $self->ut_number('pkgnum') || $self->ut_number('reasonnum') + || $self->ut_enum('action', [ 'A', 'C', 'E', 'S' ]) || $self->ut_text('otaker') || $self->ut_numbern('date') ; @@ -106,6 +107,213 @@ sub check { $self->SUPER::check; } +=item reason + +Returns the reason (see L) associated with this cust_pkg_reason. + +=cut + +sub reason { + my $self = shift; + qsearchs( 'reason', { 'reasonnum' => $self->reasonnum } ); +} + +=item reasontext + +Returns the text of the reason (see L) associated with this +cust_pkg_reason. + +=cut + +sub reasontext { + my $reason = shift->reason; + $reason ? $reason->reason : ''; +} + +# _upgrade_data +# +# Used by FS::Upgrade to migrate to a new database. + +use FS::h_cust_pkg; +use FS::h_cust_pkg_reason; + +sub _upgrade_data { # class method + my ($class, %opts) = @_; + + my $test_cust_pkg_reason = new FS::cust_pkg_reason; + return '' unless $test_cust_pkg_reason->dbdef_table->column('action'); + + my $count = 0; + my @unmigrated = qsearch('cust_pkg_reason', { 'action' => '' } ); + foreach ( @unmigrated ) { + + my @history_cust_pkg_reason = qsearch( 'h_cust_pkg_reason', { $_->hash } ); + + next unless scalar(@history_cust_pkg_reason) == 1; + + my %action_value = ( op => 'LIKE', + value => 'replace_%', + ); + my $hashref = { pkgnum => $_->pkgnum, + history_date => $history_cust_pkg_reason[0]->history_date, + history_action => { %action_value }, + }; + + my @history = qsearch({ table => 'h_cust_pkg', + hashref => $hashref, + order_by => 'ORDER BY history_action', + }); + + my $fuzz = 0; + while (scalar(@history) < 2 && $fuzz < 3) { + $hashref->{history_date}++; + $hashref->{history_action} = { %action_value }; # qsearch distorts this! + $fuzz++; + push @history, qsearch({ table => 'h_cust_pkg', + hashref => $hashref, + order_by => 'ORDER BY history_action', + }); + } + + next unless scalar(@history) == 2; + + my @new = grep { $_->history_action eq 'replace_new' } @history; + my @old = grep { $_->history_action eq 'replace_old' } @history; + + next if (scalar(@new) == 2 || scalar(@old) == 2); + + if ( !$old[0]->get('cancel') && $new[0]->get('cancel') ) { + $_->action('C'); + }elsif( !$old[0]->susp && $new[0]->susp ){ + $_->action('S'); + }elsif( $new[0]->expire && + (!$old[0]->expire || !$old[0]->expire != $new[0]->expire ) + ){ + $_->action('E'); + $_->date($new[0]->expire); + }elsif( $new[0]->adjourn && + (!$old[0]->adjourn || $old[0]->adjourn != $new[0]->adjourn ) + ){ + $_->action('A'); + $_->date($new[0]->adjourn); + } + + my $error = $_->replace + if $_->modified; + + die $error if $error; + + $count++; + } + + #remove nullability if scalar(@migrated) - $count == 0 && ->column('action'); + + #seek expirations/adjourns without reason + foreach my $field qw( expire adjourn cancel susp ) { + my $addl_from = + "LEFT JOIN h_cust_pkg ON ". + "(cust_pkg_reason.pkgnum = h_cust_pkg.pkgnum AND". + " cust_pkg_reason.date = h_cust_pkg.$field AND". + " history_action = 'replace_new')"; + + my $extra_sql = 'AND h_cust_pkg.pkgnum IS NULL'; + + my @unmigrated = qsearch({ table => 'cust_pkg_reason', + hashref => { action => uc(substr($field,0,1)) }, + addl_from => $addl_from, + select => 'cust_pkg_reason.*', + extra_sql => $extra_sql, + }); + foreach ( @unmigrated ) { + + my %action_value = ( op => 'LIKE', + value => 'replace_%', + ); + my $hashref = { pkgnum => $_->pkgnum, + history_date => $_->date, + history_action => { %action_value }, + }; + + my @history = qsearch({ table => 'h_cust_pkg', + hashref => $hashref, + order_by => 'ORDER BY history_action', + }); + + my $fuzz = 0; + while (scalar(@history) < 2 && $fuzz < 3) { + $hashref->{history_date}++; + $hashref->{history_action} = { %action_value }; # qsearch distorts this! + $fuzz++; + push @history, qsearch({ table => 'h_cust_pkg', + hashref => $hashref, + order_by => 'ORDER BY history_action', + }); + } + + next unless scalar(@history) == 2; + + my @new = grep { $_->history_action eq 'replace_new' } @history; + my @old = grep { $_->history_action eq 'replace_old' } @history; + + next if (scalar(@new) == 2 || scalar(@old) == 2); + + $_->date($new[0]->get($field)) + if ( $new[0]->get($field) && + ( !$old[0]->get($field) || + $old[0]->get($field) != $new[0]->get($field) + ) + ); + + my $error = $_->replace + if $_->modified; + + die $error if $error; + } + } + + #seek cancels/suspends without reason, but with expire/adjourn reason + foreach my $field qw( cancel susp ) { + + my %precursor_map = ( 'cancel' => 'expire', 'susp' => 'adjourn' ); + my $precursor = $precursor_map{$field}; + my $preaction = uc(substr($precursor,0,1)); + my $action = uc(substr($field,0,1)); + my $addl_from = + "LEFT JOIN cust_pkg_reason ON ". + "(cust_pkg.pkgnum = cust_pkg_reason.pkgnum AND". + " cust_pkg.$precursor = cust_pkg_reason.date AND". + " cust_pkg_reason.action = '$preaction') ". + "LEFT JOIN cust_pkg_reason AS target ON ". + "(cust_pkg.pkgnum = target.pkgnum AND". + " cust_pkg.$field = target.date AND". + " target.action = '$action')" + ; + + my $extra_sql = "WHERE target.pkgnum IS NULL AND ". + "cust_pkg.$field IS NOT NULL AND ". + "cust_pkg.$field < cust_pkg.$precursor + 86400 AND ". + "cust_pkg_reason.action = '$preaction'"; + + my @unmigrated = qsearch({ table => 'cust_pkg', + hashref => { }, + select => 'cust_pkg.*', + addl_from => $addl_from, + extra_sql => $extra_sql, + }); + foreach ( @unmigrated ) { + my $cpr = new FS::cust_pkg_reason { $_->last_cust_pkg_reason($precursor)->hash, 'num' => '' }; + $cpr->date($_->get($field)); + $cpr->action($action); + + my $error = $cpr->insert; + die $error if $error; + } + } + + ''; + +} + =back =head1 BUGS