This repository has been archived on 2023-08-16. You can view files and clone it, but cannot push or open issues or pull requests.
Foodloop-Server/lib/Pear/LocalLoop/Controller/Api/External.pm

217 lines
5.5 KiB
Perl
Raw Normal View History

package Pear::LocalLoop::Controller::Api::External;
use Mojo::Base 'Mojolicious::Controller';
use Mojo::JSON;
sub post_lcc_transactions {
my $c = shift;
my $user = $c->stash->{api_user};
# TODO Check the user is lancaster city council
my $validation = $c->validation;
$validation->input( $c->stash->{api_json} );
$validation->optional('page')->number;
return $c->api_validation_error if $validation->has_error;
2019-07-10 16:23:27 +00:00
my $lcc_import_ext_ref = $c->schema->resultset('ExternalReference')->find({ name => 'LCC CSV' });
2019-07-10 16:23:27 +00:00
return 0 unless $lcc_import_ext_ref;
my $lcc_transactions = $lcc_import_ext_ref->transactions->search(
undef,
{
page => $validation->param('page') || 1,
rows => 10,
join => 'transaction',
order_by => { -desc => 'transaction.purchase_time' },
});
# purchase_time needs timezone attached to it
my @transaction_list = (
map {{
transaction_external_id => $_->external_id,
seller => $_->transaction->seller->name,
2019-07-10 16:23:27 +00:00
net_value => $_->transaction->meta->net_value,
gross_value => $_->transaction->meta->gross_value,
sales_tax_value => $_->transaction->meta->sales_tax_value,
2019-07-10 16:23:27 +00:00
purchase_time => $c->format_iso_datetime($_->transaction->purchase_time),
}} $lcc_transactions->all
);
return $c->render( json => {
success => Mojo::JSON->true,
transactions => \@transaction_list,
page_no => $lcc_transactions->pager->total_entries,
});
}
sub post_lcc_suppliers {
my $c = shift;
my $user = $c->stash->{api_user};
# TODO give an error if user is not of Lancashire County Council
2019-07-12 17:51:38 +00:00
# my $is_lcc = $user->entity->organisation->count({ name => "Lancashire County Council" });
2019-07-12 19:04:38 +00:00
my $v = $c->validation;
$v->input( $c->stash->{api_json} );
$v->optional('page')->number;
$v->optional('sort_by');
$v->optional('sort_dir');
2019-07-12 19:04:38 +00:00
my $order_by = [
{ -asc => 'organisation.name' },
];
if ( $v->param('sort_by') ) {
my %dirs = ( 'asc' => '-asc', 'desc' => '-desc' );
my $dir = $dirs{$v->param('sort_dir')} // '-asc';
my %sorts = (
'name' => 'organisation.name',
'postcode' => 'organisation.postcode',
'spend' => 'total_spend',
);
my $sort = $sorts{$v->param('sort_by')} || 'organisation.name';
$order_by->[0] = { $dir => $sort };
}
return $c->api_validation_error if $v->has_error;
my $lcc_suppliers = $c->schema->resultset('Entity')->search(
{
'sales.buyer_id' => $user->entity->id,
},
{
join => ['sales', 'organisation'],
group_by => ['me.id', 'organisation.id'],
'+select' => [
{
'sum' => 'sales.value',
'-as' => 'total_spend',
}
],
'+as' => ['total_spend'],
page => $v->param('page') || 1,
rows => 10,
order_by => $order_by,
}
);
my @supplier_list = (
map {{
2019-07-12 17:51:38 +00:00
entity_id => $_->id,
name => $_->name,
street => $_->organisation->street_name,
town => $_->organisation->town,
2019-07-12 17:51:38 +00:00
postcode => $_->organisation->postcode,
country => $_->organisation->country,
2019-07-12 19:04:38 +00:00
spend => ($_->get_column('total_spend') / 100000) // 0,
}} $lcc_suppliers->all
);
return $c->render( json => {
success => Mojo::JSON->true,
suppliers => \@supplier_list,
page_no => $lcc_suppliers->pager->total_entries,
});
}
2019-07-15 00:33:07 +00:00
sub post_year_spend {
my $c = shift;
my $user = $c->stash->{api_user};
my $last = DateTime->today;
my $first = $last->clone->subtract( years => 1 );
my $dtf = $c->schema->storage->datetime_parser;
my $driver = $c->schema->storage->dbh->{Driver}->{Name};
my $spend_rs = $c->schema->resultset('ViewQuantisedTransaction' . $driver)->search(
{
purchase_time => {
-between => [
$dtf->format_datetime($first),
$dtf->format_datetime($last),
],
},
buyer_id => $user->entity->id,
},
{
columns => [
{
quantised => 'quantised_days',
count => \"COUNT(*)",
total_spend => { sum => 'value' },
}
],
group_by => 'quantised_days',
order_by => { '-asc' => 'quantised_days' },
}
);
my @graph_data = (
map { {
count => $_->get_column('count'),
value => $_->get_column('total_spend'),
2019-07-15 00:55:02 +00:00
date => $_->get_column('quantised'),
2019-07-15 00:33:07 +00:00
} } $spend_rs->all,
);
return $c->render( json => {
success => Mojo::JSON->true,
data => \@graph_data,
});
}
2019-07-15 01:41:23 +00:00
sub post_supplier_count {
my $c = shift;
my $user = $c->stash->{api_user};
my $last = DateTime->today;
my $first = $last->clone->subtract( years => 1 );
my $dtf = $c->schema->storage->datetime_parser;
my $driver = $c->schema->storage->dbh->{Driver}->{Name};
my $spend_rs = $c->schema->resultset('ViewQuantisedTransaction' . $driver)->search(
{
purchase_time => {
-between => [
$dtf->format_datetime($first),
$dtf->format_datetime($last),
],
},
buyer_id => $user->entity->id,
},
{
columns => [
{
quantised => 'quantised_days',
count => \"COUNT(*)",
total_spend => { sum => 'value' },
}
],
group_by => [ 'quantised_days', 'seller_id' ],
order_by => { '-asc' => 'quantised_days' },
}
);
my @graph_data = (
map { {
count => $_->get_column('count'),
value => $_->get_column('total_spend'),
date => $_->get_column('quantised'),
seller => $_->seller->name,
} } $spend_rs->all,
);
return $c->render( json => {
success => Mojo::JSON->true,
data => \@graph_data,
});
}
1;