Revision 8557458b
Von Jan Büren vor mehr als 2 Jahren hinzugefügt
| SL/BackgroundJob/UpdateExchangerates.pm | ||
|---|---|---|
|
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
|
||
|
|
||
| SL/BackgroundJob/UpdateExchangerates/FromOpenexchangerates.pm | ||
|---|---|---|
|
package SL::BackgroundJob::UpdateExchangerates::FromOpenexchangerates;
|
||
|
|
||
|
use strict;
|
||
|
use utf8;
|
||
|
|
||
|
use parent qw(SL::BackgroundJob::UpdateExchangerates::Base);
|
||
|
|
||
|
use LWP::Simple;
|
||
|
use SL::JSON;
|
||
|
|
||
|
|
||
|
sub update_rates {
|
||
|
my ($self, $rates) = @_;
|
||
|
|
||
|
return if !$self->options->{api_id};
|
||
|
|
||
|
# 'https://openexchangerates.org/api/latest.json?app_id=xxx&base=EUR';
|
||
|
# setting base does not work for me, so get for default base USD and calculate ...
|
||
|
my $url;
|
||
|
$url .= 'https://openexchangerates.org/api/latest.json?app_id=';
|
||
|
$url .= $self->options->{api_id};
|
||
|
|
||
|
my $result = get($url);
|
||
|
return if !$result;
|
||
|
my $result_h = decode_json($result);
|
||
|
|
||
|
foreach my $rate (@$rates) {
|
||
|
my $base_rate = $result_h->{rates}->{ $self->translate_currency_name($rate->{from}->name) };
|
||
|
next if !$base_rate;
|
||
|
|
||
|
my $target_rate = $result_h->{rates}->{ $self->translate_currency_name($rate->{to}->name) };
|
||
|
next if !$target_rate;
|
||
|
|
||
|
my $exrate = $base_rate/$target_rate;
|
||
|
|
||
|
# buy and sell are the same, so do not differenciate
|
||
|
$rate->{rate} = $exrate;
|
||
|
}
|
||
|
}
|
||
|
|
||
|
|
||
|
1;
|
||
|
|
||
|
|
||
|
#module: FromOpenexchangerates
|
||
|
#options:
|
||
|
# api_id: ce3e48c3f3a54c4d968530a08bb87734
|
||
| SL/BackgroundJob/UpdateExchangerates/SimpleTest.pm | ||
|---|---|---|
|
package SL::BackgroundJob::UpdateExchangerates::SimpleTest;
|
||
|
|
||
|
use strict;
|
||
|
use utf8;
|
||
|
|
||
|
use parent qw(SL::BackgroundJob::UpdateExchangerates::Base);
|
||
|
|
||
|
|
||
|
sub update_rates {
|
||
|
my ($self, $rates) = @_;
|
||
|
|
||
|
foreach my $rate (@$rates) {
|
||
|
my $from = $self->translate_currency_name($rate->{from}->name);
|
||
|
my $to = $self->translate_currency_name($rate->{to}->name);
|
||
|
if ( $from eq 'EUR' && $to eq 'USD') {
|
||
|
$rate->{rate} = 0.9205 if $rate->{dir} eq 'buy';
|
||
|
$rate->{rate} = 0.9202 if $rate->{dir} eq 'sell';
|
||
|
}
|
||
|
}
|
||
|
}
|
||
|
|
||
|
1;
|
||
Auch abrufbar als: Unified diff
Backkground: UpdateExchangerates - Wechselkurs von Openexchangerates