X-Git-Url: http://wagnertech.de/git?a=blobdiff_plain;f=SL%2FRecordLinks.pm;h=da5d54abb74b828d4ddfb0ee510a481f64bc3b05;hb=08e48f66590f580cbe2c8e3df76883d88b4c0fef;hp=eae903e316b929ecc6910b95a409c8aae66b3003;hpb=5df2b57a097f66f6cecba0aa577c7aaba3422ab6;p=kivitendo-erp.git diff --git a/SL/RecordLinks.pm b/SL/RecordLinks.pm index eae903e31..da5d54abb 100644 --- a/SL/RecordLinks.pm +++ b/SL/RecordLinks.pm @@ -1,7 +1,13 @@ package RecordLinks; +use utf8; +use strict; + use SL::Common; use SL::DBUtils; +use Data::Dumper; +use List::Util qw(reduce); +use SL::DB; sub create_links { $main::lxdebug->enter_sub(); @@ -9,9 +15,39 @@ sub create_links { my $self = shift; my %params = @_; - Common::check_params(\%params, qw(links)); + if ($params{mode} && ($params{mode} eq 'ids')) { + Common::check_params_x(\%params, [ qw(from_ids to_ids) ]); + + } else { + Common::check_params(\%params, qw(links)); + + } + + my @links; + + if ($params{mode} && ($params{mode} eq 'ids')) { + my ($from_to, $to_from) = $params{from_ids} ? qw(from to) : qw(to from); + my %ids; + + if ('ARRAY' eq ref $params{"${from_to}_ids"}) { + $ids{$from_to} = $params{"${from_to}_ids"}; + } else { + $ids{$from_to} = [ grep { $_ } map { $_ * 1 } split m/\s+/, $params{"${from_to}_ids"} ]; + } + + if (my $num = scalar @{ $ids{$from_to} }) { + $ids{$to_from} = [ ($params{"${to_from}_id"}) x $num ]; + @links = map { { 'from_table' => $params{from_table}, + 'from_id' => $ids{from}->[$_], + 'to_table' => $params{to_table}, + 'to_id' => $ids{to}->[$_], } } (0 .. $num - 1); + } + + } else { + @links = @{ $params{links} }; + } - if (!scalar @{ $params{links} }) { + if (!scalar @links) { $main::lxdebug->leave_sub(); return; } @@ -19,19 +55,21 @@ sub create_links { my $myconfig = \%main::myconfig; my $form = $main::form; - my $dbh = $params{dbh} || $form->get_standard_dbh($myconfig); + SL::DB->client->with_transaction(sub { + my $dbh = $params{dbh} || SL::DB->client->dbh; - my $query = qq|INSERT INTO record_links (from_table, from_id, to_table, to_id) VALUES (?, ?, ?, ?)|; - my $sth = prepare_query($form, $dbh, $query); + my $query = qq|INSERT INTO record_links (from_table, from_id, to_table, to_id) VALUES (?, ?, ?, ?)|; + my $sth = prepare_query($form, $dbh, $query); - foreach my $link (@{ $params{links} }) { - next if ('HASH' ne ref $link); - next if (!$link->{from_table} || !$link->{from_id} || !$link->{to_table} || !$link->{to_id}); + foreach my $link (@links) { + next if ('HASH' ne ref $link); + next if (!$link->{from_table} || !$link->{from_id} || !$link->{to_table} || !$link->{to_id}); - do_statement($form, $sth, $query, $link->{from_table}, conv_i($link->{from_id}), $link->{to_table}, conv_i($link->{to_id})); - } + do_statement($form, $sth, $query, $link->{from_table}, conv_i($link->{from_id}), $link->{to_table}, conv_i($link->{to_id})); + } - $dbh->commit() unless ($params{dbh}); + 1; + }) or do { die SL::DB->client->error }; $main::lxdebug->leave_sub(); } @@ -79,4 +117,174 @@ sub get_links { return wantarray ? @{ $links } : $links; } +sub get_links_via { + $main::lxdebug->enter_sub(); + + use SL::MoreCommon; + use Data::Dumper; + + my $self = shift; + my %params = @_; + + Common::check_params(\%params, [ qw(from_table from_id to_table to_id) ]); + Common::check_params(\%params, "via"); + + my @hops = ref $params{via} eq 'ARRAY' + ? @{ $params{via} } + : $params{via}; + unshift @hops, +{ table => $params{from_table}, id => $params{from_id} }; + push @hops, +{ table => $params{to_table}, id => $params{to_id} }; + + my $myconfig = \%main::myconfig; + my $form = $main::form; + + my $last_hop = shift @hops; + my @links; + for my $hop (@hops) { + + my @temp_links = $self->get_links( + from_table => $last_hop->{table}, + from_id => $last_hop->{id}, + to_table => $hop->{table}, + to_id => $hop->{id}, + ); + + # short circuit if any of these are empty + return wantarray ? () : [] unless scalar @temp_links; + + push @links, \@temp_links; + $last_hop = $hop; + } + + my $result = reduce { + [ + grep { $_ } + cross { + if ( $a->{to_table} eq $b->{from_table} + && $a->{to_id} eq $b->{from_id} ) { + +{ from_table => $a->{from_table}, + from_id => $a->{from_id}, + to_table => $b->{to_table}, + to_id => $b->{to_id} } + } + } @{ $a }, @{ $b } + ] + } @links; + + $main::lxdebug->leave_sub(); + + return wantarray ? @{ $result } : $result; +} + +sub delete { + $main::lxdebug->enter_sub(); + + my $self = shift; + my %params = @_; + + Common::check_params(\%params, [ qw(from_table from_id to_table to_id) ]); + + my $myconfig = \%main::myconfig; + my $form = $main::form; + + SL::DB->client->with_transaction(sub { + my $dbh = $params{dbh} || SL::DB->client->dbh; + + # content + my (@where_tokens, @where_values); + + for my $col (qw(from_table from_id to_table to_id)) { + add_token(\@where_tokens, \@where_values, col => $col, val => $params{$col}) if $params{$col}; + } + + my $where = @where_tokens ? "WHERE ". join ' AND ', map { "($_)" } @where_tokens : ''; + my $query = "DELETE FROM record_links $where"; + + do_query($form, $dbh, $query, @where_values); + + 1; + }) or die { SL::DB->client->error }; + + $main::lxdebug->leave_sub(); +} + 1; + +__END__ + +=pod + +=encoding utf8 + +=head1 NAME + +SL::RecordLinks - Verlinkung von kivitendo Objekten. + +=head1 SYNOPSIS + + use SL::RecordLinks; + + my @links = RecordLinks->get_links( + from_table => 'ar', + from_id => 2, + to_table => 'oe', + ); + my @links = RecordLinks->get_links_via( + from_table => 'oe', + to_id => '14', + via => [ + { id => 12 }, + { id => 13}, + ], + ); + + RecordLinks->create_links( + mode => 'ids', + from_table => 'ar', + from_id => 1, + to_table => 'oe', + to_ids => [4, 6, 9], + ) + RecordLinks->create_links(@links); + + delete + +=head1 DESCRIPTION + +Transitive RecordLinks mit get_links_via. + +get_links_via erwartet den zusätzlichen parameter via. via ist ein +hashref mit den jeweils optionalen Einträgen table und id, die sich +genauso verhalten wie die from/to_table/id werte der get_links funktion. + +Alternativ kann via auch ein Array dieser Hashes sein: + + get_links_via( + from_table => 'oe', + from_id => 1, + to_table => 'ar', + via => { + table => 'delivery_orders' + }, + ) + + get_links_via( + from_table => 'oe', + to_id => '14', + via => [ + { id => 12 }, + { id => 13}, + ], + ) + +Die Einträge in einem via-Array werden exakt in dieser Reihenfolge +benutzt und sind nicht optional. Da obige Beispiel würde also die +Verknüpfung: + + oe:11 -> ar:12 -> is:13 -> do:14 + +finden, nicht aber: + + oe:11 -> ar:13 -> do:14 + +=cut