Foodloop-Server/lib/Pear/LocalLoop/Command/recur_transactions.pm

package Pear::LocalLoop::Command::recur_transactions;
use Mojo::Base 'Mojolicious::Command';

use Mojo::Util 'getopt';

use DateTime;
use DateTime::Format::Strptime;

has description => 'Recur Transactions';

has usage => sub { shift->extract_usage };

sub run {
    my ( $self, @args ) = @_;

    my $app = $self->app;

    getopt \@args,
      'f|force'  => \my $force,
      'd|date=s' => \my $date;

    unless ( defined $force ) {
        say "Will not do anything without force option";
        return;
    }

    my $date_formatter =
      DateTime::Format::Strptime->new( pattern => '%Y-%m-%d' );

    my $datetime;

    if ( defined $date ) {

        $datetime = $date_formatter->parse_datetime($date);

        unless ( defined $datetime ) {
            say "Unrecognised date format, please use 'YYYY-MM-DD' Format";
            return;
        }
    }
    else {
        $datetime = DateTime->today;
    }

    my $match_date_day =
      $app->format_iso_date( $datetime->clone->subtract( days => 1 ) );
    my $match_date_week =
      $app->format_iso_date( $datetime->clone->subtract( weeks => 1 ) );
    my $match_date_fortnight =
      $app->format_iso_date( $datetime->clone->subtract( weeks => 2 ) );
    my $match_date_month =
      $app->format_iso_date( $datetime->clone->subtract( months => 1 ) );
    my $match_date_quarter =
      $app->format_iso_date( $datetime->clone->subtract( months => 3 ) );
    my $match_date_year =
      $app->format_iso_date( $datetime->clone->subtract( years => 1 ) );

    my $schema   = $app->schema;
    my $dtf      = $schema->storage->datetime_parser;
    my $recur_rs = $schema->resultset('TransactionRecurring');

    for my $recur_result ( $recur_rs->all ) {

        my $start_time_dt;
        if ( defined $recur_result->last_updated ) {
            $start_time_dt = $recur_result->last_updated;
        }
        else {
            $start_time_dt = $recur_result->start_time;
        }
        my $start_time       = $app->format_iso_date($start_time_dt);
        my $recurring_period = $recur_result->recurring_period;

        if ( $recurring_period eq 'daily' ) {
            next unless $start_time eq $match_date_day;
            say "matched recurring transaction ID "
              . $recur_result->id
              . " to daily";
        }
        elsif ( $recurring_period eq 'weekly' ) {
            next unless $start_time eq $match_date_week;
            say "matched recurring transaction ID "
              . $recur_result->id
              . " to weekly";
        }
        elsif ( $recurring_period eq 'fortnightly' ) {
            next unless $start_time eq $match_date_fortnight;
            say "matched recurring transaction ID "
              . $recur_result->id
              . " to fortnightly";
        }
        elsif ( $recurring_period eq 'monthly' ) {
            next unless $start_time eq $match_date_month;
            say "matched recurring transaction ID "
              . $recur_result->id
              . " to monthly";
        }
        elsif ( $recurring_period eq 'quarterly' ) {
            next unless $start_time eq $match_date_quarter;
            say "matched recurring transaction ID "
              . $recur_result->id
              . " to quarterly";
        }
        elsif ( $recurring_period eq 'yearly' ) {
            next unless $start_time eq $match_date_year;
            say "matched recurring transaction ID "
              . $recur_result->id
              . " to yearly";
        }
        else {
            say "Invalid recurring time period given";
            return;
        }

        my $purchase_time = DateTime->new(
            year      => $datetime->year,
            month     => $datetime->month,
            day       => $datetime->day,
            hour      => $start_time_dt->hour,
            minute    => $start_time_dt->minute,
            second    => $start_time_dt->second,
            time_zone => 'UTC',
        );
        my $category  = $recur_result->category_id;
        my $essential = $recur_result->essential;
        my $distance  = $recur_result->distance;

        my $new_transaction = $schema->resultset('Transaction')->create(
            {
                buyer_id      => $recur_result->buyer_id,
                seller_id     => $recur_result->seller_id,
                value         => $recur_result->value,
                purchase_time => $app->format_db_datetime($purchase_time),
                distance      => $distance,
                essential     => ( defined $essential ? $essential : 0 ),
            }
        );

        unless ( defined $new_transaction ) {
            say "Error Adding Transaction";
            return;
        }

        if ( defined $category ) {
            $schema->resultset('TransactionCategory')->create(
                {
                    category_id    => $category,
                    transaction_id => $new_transaction->id,
                }
            );
        }

        $recur_result->update( { last_updated => $purchase_time } );

    }

    return 1;
}

=head1 SYNOPSIS

  Usage: APPLICATION recur_transactions [OPTIONS]

  Options:

    -f, --force   Actually insert the data
    -d, --date    Date to recur the transactions on

=cut

1;