X-Git-Url: http://git.freeside.biz/gitweb/?a=blobdiff_plain;f=FS%2FFS%2Fcust_pkg_reason.pm;h=6bd17b66fee9a7c2d5681f4638ce17bbd7a32390;hb=7d37d1e44896e9c6e7ee8f2649d2fbd9a0f75d54;hp=2f927401feb7fc35406c28c8f31d4e75fadd3f22;hpb=9509e5bfb7f9331303153cac24d7bfecbe2ea9f1;p=freeside.git

diff --git a/FS/FS/cust_pkg_reason.pm b/FS/FS/cust_pkg_reason.pm
index 2f927401f..6bd17b66f 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,109 @@ sub check {
   $self->SUPER::check;
 }
 
+=item reason
+
+Returns the reason (see L<FS::reason>) 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<FS::reason>) 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.
+
+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 ) {
+    # we could create h_cust_pkg_reason and h_cust_pkg_reason packages
+    @FS::h_cust_pkg::ISA = qw( FS::h_Common FS::cust_pkg );
+    sub FS::h_cust_pkg::table { 'h_cust_pkg' };
+    @FS::h_cust_pkg_reason::ISA = qw( FS::h_Common FS::cust_pkg_reason );
+    sub FS::h_cust_pkg_reason::table { 'h_cust_pkg_reason' };
+
+    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',
+                         });
+
+    if (@history < 2) {
+      $hashref->{history_date}++;  # more fuzz?
+      $hashref->{history_action} = { %action_value }; # qsearch distorts this!
+      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');
+    }elsif( $new[0]->adjourn &&
+            (!$old[0]->adjourn || $old[0]->adjourn != $new[0]->adjourn )
+          ){
+      $_->action('A');
+    }
+
+    my $error = $_->replace
+      if $_->modified;
+
+    die $error if $error;
+
+    $count++;
+  }
+
+  #remove nullability if scalar(@migrated) - $count == 0 && ->column('action');
+  
+  '';
+
+}
+
 =back
 
 =head1 BUGS