projekt kivitendo

  'Number of entries changed: #1' => 'Anzahl ge?nderter Eintr?ge: #1',

#!/usr/bin/perl

$self->{texts} = {

  'Database update error:'      => 'Fehler beim Datenbankupgrade:',

  'Number of entries changed: #1' => 'Anzahl ge?nderter Eintr?ge: #1',

};

$self->{subs} = {

  'do_query'                    => 'do_query',

  'do_update'                   => 'do_update',

  'mydberror'                   => 'mydberror',

};

1;

# @tag: fix_acc_trans_ap_taxkey_bug

# @description: Korrektur falscher Steuerschl?ssel in acc_trans bei Eingangsrechnungen

# @depends: release_2_6_0

use strict;

die "This script cannot be run from the command line." unless $::form;

sub mydberror {

  my $msg = shift;

  die $dbup_locale->text("Database update error:") . "<br>$msg<br>" . $DBI::errstr;

}

sub do_query {

  my $query    = shift;

  my $may_fail = shift;

  if (!$dbh->do($query)) {

    mydberror($query) unless $may_fail;

    $dbh->rollback();

    $dbh->begin_work();

  }

}

sub do_update {

  my $q_find = <<SQL;

    SELECT * FROM (

      SELECT

        -- Einige Felder zum Debuggen:

        ap.id, c.accno, c.description AS chartdescription,

        -- Felder, die zum eigentlichen Vergleich und zum spaeteren Update

        -- benoetigt werden:

        ac.acc_trans_id, ac.taxkey AS actual_taxkey,

        -- Zum Rechnungsdatum gueltigen Steuerschluessel fuer Konto auslesen:

        (SELECT tk.taxkey_id

         FROM taxkeys tk

         WHERE (tk.chart_id = c.id)

           AND (tk.startdate <= ap.transdate)

         ORDER BY tk.startdate DESC

         LIMIT 1) AS wanted_taxkey

        FROM acc_trans ac

        LEFT JOIN ap ON (ac.trans_id = ap.id)

        LEFT JOIN chart c ON (ac.chart_id = c.id)

        WHERE

          -- Nur Einkaufsrechnungen, aber keine Kreditorenbuchungen betrachten.

              (ap.id IS NOT NULL)

          AND ap.invoice

          -- Nur Eintraege betrachten, die Konten bebuchen, die fuer die

          -- jeweils aktuelle Rechnung in der dazugehoerigen Buchungsgruppe

          -- angesprochen werden. Die Buchungsgruppen sind all diejenigen,

          -- die in der Rechnung in mindestens einer Position ueber die

          -- Parts verlinkt sind.

          AND (ac.chart_id IN (

                -- Teil 1: Aufwandskonto der Buchungsgruppe fuer die in der

                -- aktuellen Rechnung ausgewaehlte Steuerzone

                SELECT

                  CASE

                    WHEN ap.taxzone_id = 0 THEN bg.expense_accno_id_0

                    WHEN ap.taxzone_id = 1 THEN bg.expense_accno_id_1

                    WHEN ap.taxzone_id = 2 THEN bg.expense_accno_id_2

                    ELSE                        bg.expense_accno_id_3

                  END

                FROM invoice i

                LEFT JOIN parts p ON (i.parts_id = p.id)

                LEFT JOIN buchungsgruppen bg ON (p.buchungsgruppen_id = bg.id)

                WHERE (i.trans_id = ap.id)

                UNION

                -- Teil 2: Inventarkonto der Buchungsgruppe fuer Nicht-Dienstleistungen

                SELECT bg.inventory_accno_id

                FROM invoice i

                LEFT JOIN parts p ON (i.parts_id = p.id)

                LEFT JOIN buchungsgruppen bg ON (p.buchungsgruppen_id = bg.id)

                WHERE (i.trans_id = ap.id)

                  AND (COALESCE(p.inventory_accno_id, 0) <> 0)

              ))

        ORDER BY ap.id

      ) AS the_query

    WHERE the_query.actual_taxkey <> the_query.wanted_taxkey

SQL

  my $q_change = <<SQL;

    UPDATE acc_trans

    SET taxkey = ?

    WHERE acc_trans_id = ?

SQL

  my $h_find   = $dbh->prepare($q_find)   || mydberror($q_find);

  my $h_change = $dbh->prepare($q_change) || mydberror($q_change);

  $h_find->execute() || mydberror($q_find);

  my $num_changed = 0;

  while (my $ref = $h_find->fetchrow_hashref()) {

    # $::lxdebug->dump(0, "ref", $ref);

    $h_change->execute($ref->{wanted_taxkey}, $ref->{acc_trans_id}) || mydberror($q_change);

    $num_changed++;

  }

  $h_find->finish();

  $h_change->finish();

  print $dbup_locale->text('Number of entries changed: #1', $num_changed) . "<br/>\n";

}

do_update();