-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #105 from Pear-Trading/finn/recurring
Added script for recurring transactions and changed recurring logic
- Loading branch information
Showing
54 changed files
with
23,071 additions
and
19 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,137 @@ | ||
| 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 $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"; | ||
| } else { | ||
| say "Invalid recurring time period given"; | ||
| return; | ||
| } | ||
|
|
||
| my $now = DateTime->now(); | ||
| my $purchase_time = DateTime->new( | ||
| year => $now->year, | ||
| month => $now->month, | ||
| day => $now->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 }); | ||
|
|
||
| } | ||
| } | ||
|
|
||
| =head1 SYNOPSIS | ||
| Usage: APPLICATION recur_transactions [OPTIONS] | ||
| Options: | ||
| -f, --force Actually insert the data | ||
| -d, --date Date to recur the transactions on | ||
| =cut | ||
|
|
||
| 1; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,18 @@ | ||
| -- | ||
| -- Created by SQL::Translator::Producer::PostgreSQL | ||
| -- Created on Wed Mar 7 15:17:20 2018 | ||
| -- | ||
| ; | ||
| -- | ||
| -- Table: dbix_class_deploymenthandler_versions | ||
| -- | ||
| CREATE TABLE "dbix_class_deploymenthandler_versions" ( | ||
| "id" serial NOT NULL, | ||
| "version" character varying(50) NOT NULL, | ||
| "ddl" text, | ||
| "upgrade_sql" text, | ||
| PRIMARY KEY ("id"), | ||
| CONSTRAINT "dbix_class_deploymenthandler_versions_version" UNIQUE ("version") | ||
| ); | ||
|
|
||
| ; |
Oops, something went wrong.