#!/usr/bin/perl 
#

# We're going from one address field to three, so we need to split up the
# existing address by the line breaks.
#

use strict;

SplitAddresses->start();

package SplitAddresses;

use lib '/app/tools/common/lib';
use lib '/app/tools/rps/lib';
use RPS::DB::Item::Publisher;
use RPS::DB::Item::CAPublisher;
use RPS::DB::Item::Payor;
use RPS::DB::Item::ArtistPayee;
use RPS::DB::Item::LabelPayee;

use base 'RPS::CronScript';

sub _process {
    my $self = shift;

    # US Publishers
    my $publishers = RPS::DB::Item::Publisher->GetAll();
    while ( my $publisher = $publishers->next ) {
        my $streetAddress = $publisher->street_address;
        if ( $streetAddress =~ /\n/ ) {
            $self->_updateSQL( 'publisher', $streetAddress, $publisher->publisher_id );
        }
    }

    # CA Publishers
    my $caPublishers = RPS::DB::Item::CAPublisher->GetAll();
    while ( my $caPublisher = $caPublishers->next ) {
        my $streetAddress = $caPublisher->street_address;
        if ( $streetAddress =~ /\n/ ) {
            $self->_updateSQL( 'ca_publisher', $streetAddress, $caPublisher->ca_publisher_id );
        }
    }

    # Payors
    my $payors = RPS::DB::Item::Payor->GetAll();
    while ( my $payor = $payors->next ) {
        my $streetAddress = $payor->street_address;
        if ( $streetAddress =~ /\n/ ) {
            $self->_updateSQL( 'payor', $streetAddress, $payor->payor_id );
        }
    }

    # Artist Payees
    my $artistPayees = RPS::DB::Item::ArtistPayee->GetAll();
    while ( my $artistPayee = $artistPayees->next ) {
        my $streetAddress = $artistPayee->street_address;
        if ( $streetAddress =~ /\n/ ) {
            $self->_updateSQL( 'artist_payee', $streetAddress, $artistPayee->artist_payee_id );
        }
    }

    # Label Payees
    my $labelPayees = RPS::DB::Item::LabelPayee->GetAll();
    while ( my $labelPayee = $labelPayees->next ) {
        my $streetAddress = $labelPayee->street_address;
        if ( $streetAddress =~ /\n/ ) {
            $self->_updateSQL( 'label_payee', $streetAddress, $labelPayee->label_payee_id );
        }
    }

}

sub _updateSQL {
    my $self    = shift;
    my $table   = shift;
    my $address = shift;
    my $id      = shift;

    my @addressLines = split( '\n', $address );

    my $streetAddress1 = $addressLines[0];
    shift(@addressLines);
    my $streetAddress2 = $addressLines[0];
    shift(@addressLines);
    my $streetAddress3 = join( ' ', @addressLines );

    my $dbo = Common::RSApp::GetClientDB();
    my $sql =
        "UPDATE $table SET"
      . " street_address = "
      . $dbo->DBQuote($streetAddress1) . ","
      . " street_address_2 = "
      . $dbo->DBQuote($streetAddress2) . ","
      . " street_address_3 = "
      . $dbo->DBQuote($streetAddress3)
      . " WHERE "
      . $table
      . "_id = $id";

    #print STDERR "$sql\n";
    $dbo->DoCmd($sql);
}

1;