From b5138b786cad868f567966489d492d5d83b5fb9d Mon Sep 17 00:00:00 2001
From: Moritz Bunkus <m.bunkus@linet-services.de>
Date: Tue, 26 Jan 2010 11:22:51 +0100
Subject: [PATCH] =?utf8?q?Datenbankupgradescript=20zur=20Behebung=20falsch?=
 =?utf8?q?er=20Steuerschl=C3=BCssel=20in=20acc=5Ftrans=20bei=20Einkaufsrec?=
 =?utf8?q?hnungen?=
MIME-Version: 1.0
Content-Type: text/plain; charset=utf8
Content-Transfer-Encoding: 8bit

Frühere Lx-Office-Versionen hatten einen Bug beim Buchen von
Einkaufsrechnungen, bei denen falsche Steuerschlüssel in acc_trans
geschrieben wurden. Dieses Script behebt diese falschen Einträge.
---
 locale/de/all                                 |   1 +
 locale/de/fix_acc_trans_ap_taxkey_bug         |  14 +++
 .../fix_acc_trans_ap_taxkey_bug.pl            | 108 ++++++++++++++++++
 3 files changed, 123 insertions(+)
 create mode 100644 locale/de/fix_acc_trans_ap_taxkey_bug
 create mode 100644 sql/Pg-upgrade2/fix_acc_trans_ap_taxkey_bug.pl

diff --git a/locale/de/all b/locale/de/all
index 8173d6ab3..305a847b7 100644
--- a/locale/de/all
+++ b/locale/de/all
@@ -1080,6 +1080,7 @@ $self->{texts} = {
   'Number missing in Row'       => 'Nummer fehlt in Zeile',
   'Number of bins'              => 'Anzahl Lagerpl&auml;tze',
   'Number of copies'            => 'Anzahl Kopien',
+  'Number of entries changed: #1' => 'Anzahl geänderter Einträge: #1',
   'Number of new bins'          => 'Anzahl neuer Lagerpl&auml;tze',
   'Number pages'                => 'Seiten nummerieren',
   'Number variables: \'PRECISION=n\' forces numbers to be shown with exactly n decimal places.' => 'Zahlenvariablen: Mit \'PRECISION=n\' erzwingt man, dass Zahlen mit n Nachkommastellen formatiert werden.',
diff --git a/locale/de/fix_acc_trans_ap_taxkey_bug b/locale/de/fix_acc_trans_ap_taxkey_bug
new file mode 100644
index 000000000..31846ea0d
--- /dev/null
+++ b/locale/de/fix_acc_trans_ap_taxkey_bug
@@ -0,0 +1,14 @@
+#!/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;
diff --git a/sql/Pg-upgrade2/fix_acc_trans_ap_taxkey_bug.pl b/sql/Pg-upgrade2/fix_acc_trans_ap_taxkey_bug.pl
new file mode 100644
index 000000000..a2e70f944
--- /dev/null
+++ b/sql/Pg-upgrade2/fix_acc_trans_ap_taxkey_bug.pl
@@ -0,0 +1,108 @@
+# @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();
-- 
2.20.1