kivitendo/SL/BackgroundJob/UpdateExchangerates.pm @ 68748667
| 8557458b | Jan Büren | package SL::BackgroundJob::UpdateExchangerates;
|
|
use strict;
|
|||
use utf8;
|
|||
use parent qw(SL::BackgroundJob::Base);
|
|||
use SL::DB::Exchangerate;
|
|||
use SL::DB::Currency;
|
|||
use Rose::Object::MakeMethods::Generic (
|
|||
scalar => [ qw(worker) ],
|
|||
);
|
|||
sub create_job {
|
|||
my $self_or_class = shift;
|
|||
my $package = ref($self_or_class) || $self_or_class;
|
|||
$package =~ s/SL::BackgroundJob:://;
|
|||
my $cron_spec = ('35 4 * * *'); # every day at 4:35 am
|
|||
my $data = <<DATA;
|
|||
module: FromYahoo
|
|||
options:
|
|||
translate:
|
|||
£: GBP
|
|||
DATA
|
|||
my %params = (cron_spec => $cron_spec,
|
|||
type => 'interval',
|
|||
active => 1,
|
|||
package_name => $package,
|
|||
data => $data);
|
|||
my $job = SL::DB::Manager::BackgroundJob->find_by(package_name => $params{package_name});
|
|||
if (!$job) {
|
|||
$job = SL::DB::BackgroundJob->new(%params)->update_next_run_at;
|
|||
} else {
|
|||
$job->assign_attributes(%params)->update_next_run_at;
|
|||
}
|
|||
return $job;
|
|||
}
|
|||
sub run {
|
|||
my ($self, $db_obj) = @_;
|
|||
my $params = $db_obj->data_as_hash;
|
|||
return $::locale->text('Parameter module must be given.') if !$params->{module};
|
|||
# instanciate worker for given module
|
|||
my $error;
|
|||
eval {
|
|||
my $worker_class = 'SL::BackgroundJob::UpdateExchangerates::' . $params->{module};
|
|||
eval "require $worker_class";
|
|||
$self->worker($worker_class->new(options => $params->{options}));
|
|||
1;
|
|||
} or do {
|
|||
$error = $::locale->text('Could not load class #1 (#2): "#3"', $params->{module}, 'SL/BackgroundJob/UpdateExchangerates', $@);
|
|||
};
|
|||
return $error if $error;
|
|||
my $default_currency = SL::DB::Currency->new(id => $::instance_conf->get_currency_id)->load;
|
|||
my $transdate = DateTime->today_local;
|
|||
my @rates_to_update;
|
|||
# collect currencies that should be updated
|
|||
foreach my $currency (@{SL::DB::Manager::Currency->get_all_sorted}) {
|
|||
next if $currency->id == $default_currency->id;
|
|||
my $exrate = SL::DB::Manager::Exchangerate->find_by(transdate => $transdate, currency_id => $currency->id);
|
|||
if (!$exrate) {
|
|||
push @rates_to_update, {from => $default_currency,
|
|||
to => $currency,
|
|||
dir => 'buy'};
|
|||
push @rates_to_update, {from => $default_currency,
|
|||
to => $currency,
|
|||
dir => 'sell'};
|
|||
next;
|
|||
}
|
|||
if (!$exrate->buy) {
|
|||
push @rates_to_update, {from => $default_currency,
|
|||
to => $currency,
|
|||
dir => 'buy'};
|
|||
}
|
|||
if (!$exrate->sell) {
|
|||
push @rates_to_update, {from => $default_currency,
|
|||
to => $currency,
|
|||
dir => 'sell'};
|
|||
}
|
|||
}
|
|||
return "updated: 0" if scalar @rates_to_update == 0;
|
|||
# update rates
|
|||
$self->worker->update_rates(\@rates_to_update);
|
|||
# save rates
|
|||
my @updated;
|
|||
foreach my $rate (@rates_to_update) {
|
|||
my $exrate = SL::DB::Manager::Exchangerate->find_by_or_create(transdate => $transdate, currency_id => $rate->{to}->id);
|
|||
next if !$exrate; # should not happen
|
|||
if ($rate->{rate}) {
|
|||
$exrate->transdate($transdate) if !$exrate->transdate;
|
|||
$exrate->currency($rate->{to}) if !$exrate->currency;
|
|||
my $method = $rate->{dir};
|
|||
if (!$exrate->$method) {
|
|||
$exrate->$method($rate->{rate});
|
|||
$exrate->save;
|
|||
push @updated, $rate->{to}->name . " ($method: " . $rate->{rate} . ")";
|
|||
}
|
|||
}
|
|||
}
|
|||
return "updated: " . scalar @updated . ': ' . join ', ', @updated;
|
|||
}
|
|||
1;
|
|||
__END__
|
|||
=encoding utf8
|
|||
=head1 NAME
|
|||
SL::BackgroundJob::UpdateExchangerates - Background job for updating the
|
|||
exchange rates for currencies
|
|||
=head1 SYNOPSIS
|
|||
This background job can update all exchange rates for currencies if the rates
|
|||
are not already present for the current date.
|
|||
A worker module must be given as data to the job (see documentation at
|
|||
SL::BackgroundJob::UpdateExchangerates::Base and
|
|||
SL::BackgroundJob::UpdateExchangerates::* as examples).
|
|||
The worker will be used to get the actual rates from some kind of service.
|
|||
Options to the worker can be given as data to the background job:
|
|||
module: FromOpenexchangerates
|
|||
options:
|
|||
api_id: 1234565789
|
|||
translate:
|
|||
£: GBP
|
|||
=head1 Todo
|
|||
Better error handling / error notification
|
|||
=head1 AUTHOR
|
|||
Bernd Bleßmann E<lt>bernd@kivitendo-premium.deE<gt>
|
|||
=cut
|