#!/usr/bin/perl

use strict;
use warnings;
use open ':std', ':encoding(UTF-8)';

use Git;
use JSON::XS;
use DateTime;
use FileHandle;
use Array::Utils qw(:all);
use Digest::MD5  qw(md5 md5_hex md5_base64);
use Text::CSV::Easy(qw/csv_build csv_parse/);
use Getopt::Long::Descriptive(qw/describe_options/);

use lib '/var/app/orchard/collab/jgetter/perllib';
use Orchard::Session;
use Orchard::NameCase;
use Orchard::DB::Connect;
use Orchard::Accounting::JIRA;
use Orchard::ETL::Extract::CSV;

## db connections
my $dbh = Orchard::Session::getdbh('abacusprod');
my $upd = $dbh->prepare("UPDATE account_contract SET is_primary_for_calc=? WHERE contract_id=?");
while (<>) {
    chomp;
    my ( $cid, $pc ) = csv_parse($_);
    my $dpc = $dbh->selectcol_arrayref( "SELECT IFNULL(is_primary_for_calc,0) FROM account_contract WHERE contract_id=?", undef, ($cid) )->[0];
    if ( not defined $dpc ) {
        my $err;
    } else {
        logMessage( 'info', "$cid db:$dpc file:$pc" );
        if ( $dpc != $pc ) {
            logMessage( 'info1', "updating $dpc -> $pc" );
            $upd->execute( $pc, $cid );
        }
    }
}