#
# Here's what we're a gonna do:
# - RENAME the current job table.
# - CREATE the new job table.
# - BACK-FILL the job table with previous job data.
#

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

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

print "RENAME the job table\n";
#`mysql -ucommon -pground -hdbmaster -e 'RENAME TABLE job TO job_old' RSCOMMON`;

print "CREATE new job table\n";
#`mysql -ucommon -pground -hdbmaster RSCOMMON < ./newjob.sql`;

print "BACKFILL job table\n";

my $dbo = Common::RSApp::GetCommonDB();

my $sql = "SELECT * FROM job_old";
my $sth = $dbo->DoCmd($sql);
while (my $hr = $sth->fetchrow_hashref())
{
    my @insertPairs;
    push @insertPairs, "job_id=".$hr->{job_id};
    push @insertPairs, "hostname=".$dbo->DBQuote($hr->{hostname}) if $hr->{hostname};
    push @insertPairs, "class=".$dbo->DBQuote($hr->{class}) if $hr->{class};
    push @insertPairs, "priority=".$dbo->DBQuote($hr->{priority}) if $hr->{priority};
    push @insertPairs, "pid=".$hr->{pid} if $hr->{pid};
    push @insertPairs, "job_log_id=".$hr->{job_log_id} if $hr->{job_log_id};
    push @insertPairs, "queue_date=".$dbo->DBQuote($hr->{date_created}) if $hr->{date_created};

    # Parse the client_id from the command-line
    #
    my $commandLine = $hr->{command_line};
    push @insertPairs, "command_line=".$dbo->DBQuote($hr->{command_line});
    my $clientID;
    if ('ImportSalesFile' eq $hr->{class})
    {
        if ($commandLine =~ /^.*file.pl (\d+)/)
        {
            $clientID = $1;
            push @insertPairs, "client_id=$clientID";
        }
    }
    else
    {
        if ($commandLine =~ /^.*-c (\d+)/)
        {
            $clientID = $1;
            push @insertPairs, "client_id=$clientID";
        }
    }

    my $status = $hr->{status};
    if ('HOLD' eq $status || 'PAUS' eq $status || 'TEST' eq $status)
    {
        push @insertPairs, "on_hold=1";
    }
    elsif ('IN_Q' eq $status)
    {
    }
    elsif ('RUN ' eq $status)
    {
        push @insertPairs, "start_date=".$dbo->DBQuote($hr->{date_created}) if $hr->{date_created};
    }
    else
    {
        push @insertPairs, "start_date=".$dbo->DBQuote($hr->{date_created}) if $hr->{date_created};
        push @insertPairs, "end_date=".$dbo->DBQuote($hr->{date_modified}) if $hr->{date_modified};
    }

    my $insertSQL = "INSERT INTO job SET " . join(',', @insertPairs);
    $dbo->DoCmd($insertSQL);
}