#------------------------------------------------------------
# Copyright (C) 2006 RoyaltyShare, Inc.   All Rights Reserved
# $Id$
#------------------------------------------------------------
#!/usr/bin/perl

use strict;
use Data::Dumper;

use lib '/app/tools/common/lib';
use Common::RSApp;

use lib '/app/tools/rps/lib/';
use RPS::DB::Item::License;
use RPS::DB::Item::TrackLicense;
use RPS::DB::Item::ControlledCompositionLicense;
use RPS::DB::Item::LicenseReserveLiquidation;

# Instantiate the application singleton object.
#
my $clientID = $ARGV[0];
unless ( $clientID =~ /^\d+$/ && $clientID > 0 ) {
    die usage("You must specify a valid client ID");
}

my $appSingleton = Common::RSApp->new( clientID => $clientID );

my %idMap;
collapse_track_license_table( \%idMap );
convert_reserves( \%idMap );

sub collapse_track_license_table {
    my ($idMap) = @_;

    my $trackLicenses = RPS::DB::Item::TrackLicense->GetAll();

    print "track_licenses to convert: " . $trackLicenses->size() . "\n";
    my $count = 0;
    while ( $trackLicenses->hasNext() ) {
        my $trkLicense = $trackLicenses->next();

        # Fetch the appropriate stuff.
        # We don't need to do anything to public domain or unknown publisher entries.
        #
        if ( RPS::DB::Item::TrackLicense::kPublishingLicense == $trkLicense->type ) {

            # Fetch the license data.
            #
            my $license = RPS::DB::Item::License->Lookup( license_id => $trkLicense->id );
            if ($license) {
                $trkLicense->publisher_direct( $license->publisher_direct() );
                $trkLicense->date_sent( $license->date_sent() );
                $trkLicense->date_received( $license->date_received() );
                $trkLicense->date_issued( $license->date_issued() );
                $trkLicense->term_start( $license->term_start() );
                $trkLicense->term_end( $license->term_end() );
                $trkLicense->rate_basis( $license->rate_basis() );
                $trkLicense->rate_type( $license->rate_type() );
                $trkLicense->issuer_license_id( $license->issuer_license_id() );
                $trkLicense->advance_account_id( $license->advance_account_id() );
                $trkLicense->product_type_id( $license->product_type_id() );
                $trkLicense->date_created( $license->date_created() );
                $trkLicense->created_by( $license->created_by() );
                $trkLicense->date_modified( $license->date_modified() );
                $trkLicense->modified_by( $license->modified_by() );
                $trkLicense->penny_rate( $license->penny_rate() );
                $trkLicense->advance_amount( $license->advance_amount() );
                $trkLicense->reserve_percentage( $license->reserve_percentage() );
                $trkLicense->percentage_of_sales( $license->percentage_of_sales() );
                $trkLicense->packaging_deduction( $license->packaging_deduction() );
                $trkLicense->free_goods( $license->free_goods() );
                $trkLicense->misc_deduction( $license->misc_deduction() );

                $idMap{1}{ $trkLicense->id } = $trkLicense->track_license_id;
            } else {
                print "!!! track_license " . $trkLicense->track_license_id . " : can't load license " . $trkLicense->id . " !!!\n";
            }
        } elsif ( RPS::DB::Item::TrackLicense::kControlledComposition == $trkLicense->type ) {
            my $ccomp = RPS::DB::Item::ControlledCompositionLicense->Lookup( controlled_composition_license_id => $trkLicense->id );
            if ($ccomp) {
                $trkLicense->controlled_composition_id( $ccomp->controlled_composition_id() );
                $trkLicense->publisher_direct( $ccomp->publisher_direct() );
                $trkLicense->date_sent( $ccomp->date_sent() );
                $trkLicense->date_received( $ccomp->date_received() );
                $trkLicense->date_issued( $ccomp->date_issued() );
                $trkLicense->term_start( $ccomp->term_start() );
                $trkLicense->term_end( $ccomp->term_end() );
                $trkLicense->issuer_license_id( $ccomp->issuer_license_id() );

                $idMap{2}{ $trkLicense->id } = $trkLicense->track_license_id;
            } else {
                print "!!! track_license " . $trkLicense->track_license_id . " : can't load ccomp_license" . $trkLicense->id . " !!!\n";
            }
        }

        $trkLicense->save();

        $count++;
        if ( 0 == $count % 100 ) {
            print "... $count\n";
        }
    }

    print "Converted $count track_licenses.\n";
}

sub convert_reserves {
    my ($idMap) = @_;

    # This is _slightly_ trickier.  Need to convert the license_reserve_liquidation
    # table to use track_license_id instead of license_id.
    #

    # We'll make two passes - First, we'll read the existing table and delete records as we go
    # Then we'll insert the new entries.
    # This is to avoid key collisions.
    #
    print "Reading existing license_reserve_liquidation table...\n";
    my @newRecords;
    foreach my $type ( keys %$idMap ) {
        my $innerMap = $idMap->{$type};
        foreach my $licenseID ( keys %$innerMap ) {
            my $trackLicenseID = $innerMap->{$licenseID};

            my $collection = RPS::DB::Item::LicenseReserveLiquidation::GetLicenseReserveLiquidationsByLicenseID( $licenseID, $type );
            while ( my $orig = $collection->next() ) {
                my $new = RPS::DB::Item::LicenseReserveLiquidation->Create(
                    license_id             => $trackLicenseID,
                    type                   => $orig->type(),
                    period                 => $orig->period(),
                    liquidation_percentage => $orig->liquidation_percentage(),
                );
                $orig->delete();

                push @newRecords, $new;
            }
        }
    }

    print "Creating new license_reserve_liquidation table...\n";
    foreach my $newRecord (@newRecords) {
        $newRecord->save();
    }
}

sub usage {
    my $errstr = shift;
    my $text = ($errstr) ? "ERROR: $errstr\n" : '';
    $text .= "Usage: $0 <clientID>\n";
    return $text;
}