kivitendo/SL/DATEV.pm @ b09bc3de
d319704a | Moritz Bunkus | #=====================================================================
|
||
008c2e15 | Moritz Bunkus | # kivitendo ERP
|
||
d319704a | Moritz Bunkus | # Copyright (c) 2004
|
||
#
|
||||
# Author: Philip Reetz
|
||||
# Email: p.reetz@linet-services.de
|
||||
# Web: http://www.lx-office.org
|
||||
#
|
||||
#
|
||||
# This program is free software; you can redistribute it and/or modify
|
||||
# it under the terms of the GNU General Public License as published by
|
||||
# the Free Software Foundation; either version 2 of the License, or
|
||||
# (at your option) any later version.
|
||||
#
|
||||
# This program is distributed in the hope that it will be useful,
|
||||
# but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||||
# GNU General Public License for more details.
|
||||
# You should have received a copy of the GNU General Public License
|
||||
# along with this program; if not, write to the Free Software
|
||||
# Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
|
||||
#======================================================================
|
||||
#
|
||||
# Datev export module
|
||||
#======================================================================
|
||||
631b4c04 | Sven Schöling | package SL::DATEV;
|
||
d319704a | Moritz Bunkus | |||
05c6840d | Moritz Bunkus | use utf8;
|
||
use strict;
|
||||
e20f3f0d | Moritz Bunkus | |||
032e5fcd | Moritz Bunkus | use SL::DBUtils;
|
||
40d52f50 | Moritz Bunkus | use SL::DATEV::KNEFile;
|
||
032e5fcd | Moritz Bunkus | |||
d319704a | Moritz Bunkus | use Data::Dumper;
|
||
631b4c04 | Sven Schöling | use DateTime;
|
||
use Exporter qw(import);
|
||||
f8138d17 | Moritz Bunkus | use File::Path;
|
||
631b4c04 | Sven Schöling | use List::Util qw(max sum);
|
||
f8138d17 | Moritz Bunkus | use Time::HiRes qw(gettimeofday);
|
||
631b4c04 | Sven Schöling | {
|
||
my $i = 0;
|
||||
use constant {
|
||||
DATEV_ET_BUCHUNGEN => $i++,
|
||||
DATEV_ET_STAMM => $i++,
|
||||
DATEV_FORMAT_KNE => $i++,
|
||||
DATEV_FORMAT_OBE => $i++,
|
||||
};
|
||||
}
|
||||
my @export_constants = qw(DATEV_ET_BUCHUNGEN DATEV_ET_STAMM DATEV_FORMAT_KNE DATEV_FORMAT_OBE);
|
||||
our @EXPORT_OK = (@export_constants);
|
||||
our %EXPORT_TAGS = (CONSTANTS => [ @export_constants ]);
|
||||
sub new {
|
||||
my $class = shift;
|
||||
my %data = @_;
|
||||
my $obj = bless {}, $class;
|
||||
$obj->$_($data{$_}) for keys %data;
|
||||
$obj;
|
||||
}
|
||||
sub exporttype {
|
||||
my $self = shift;
|
||||
$self->{exporttype} = $_[0] if @_;
|
||||
return $self->{exporttype};
|
||||
}
|
||||
sub has_exporttype {
|
||||
defined $_[0]->{exporttype};
|
||||
}
|
||||
sub format {
|
||||
my $self = shift;
|
||||
$self->{format} = $_[0] if @_;
|
||||
return $self->{format};
|
||||
}
|
||||
sub has_format {
|
||||
defined $_[0]->{format};
|
||||
}
|
||||
f8138d17 | Moritz Bunkus | sub _get_export_path {
|
||
$main::lxdebug->enter_sub();
|
||||
my ($a, $b) = gettimeofday();
|
||||
631b4c04 | Sven Schöling | my $path = _get_path_for_download_token("${a}-${b}-${$}");
|
||
f8138d17 | Moritz Bunkus | |||
mkpath($path) unless (-d $path);
|
||||
$main::lxdebug->leave_sub();
|
||||
return $path;
|
||||
}
|
||||
631b4c04 | Sven Schöling | sub _get_path_for_download_token {
|
||
f8138d17 | Moritz Bunkus | $main::lxdebug->enter_sub();
|
||
631b4c04 | Sven Schöling | my $token = shift || '';
|
||
f8138d17 | Moritz Bunkus | my $path;
|
||
if ($token =~ m|^(\d+)-(\d+)-(\d+)$|) {
|
||||
631b4c04 | Sven Schöling | $path = $::lx_office_conf{paths}->{userspath} . "/datev-export-${1}-${2}-${3}/";
|
||
f8138d17 | Moritz Bunkus | }
|
||
$main::lxdebug->leave_sub();
|
||||
return $path;
|
||||
}
|
||||
631b4c04 | Sven Schöling | sub _get_download_token_for_path {
|
||
f8138d17 | Moritz Bunkus | $main::lxdebug->enter_sub();
|
||
my $path = shift;
|
||||
my $token;
|
||||
if ($path =~ m|.*datev-export-(\d+)-(\d+)-(\d+)/?$|) {
|
||||
$token = "${1}-${2}-${3}";
|
||||
}
|
||||
$main::lxdebug->leave_sub();
|
||||
return $token;
|
||||
}
|
||||
631b4c04 | Sven Schöling | sub download_token {
|
||
my $self = shift;
|
||||
$self->{download_token} = $_[0] if @_;
|
||||
return $self->{download_token} ||= _get_download_token_for_path($self->export_path);
|
||||
}
|
||||
sub export_path {
|
||||
my ($self) = @_;
|
||||
return $self->{export_path} ||= _get_path_for_download_token($self->{download_token}) || _get_export_path();
|
||||
}
|
||||
sub add_filenames {
|
||||
my $self = shift;
|
||||
push @{ $self->{filenames} ||= [] }, @_;
|
||||
}
|
||||
sub filenames {
|
||||
return @{ $_[0]{filenames} || [] };
|
||||
}
|
||||
sub add_error {
|
||||
my $self = shift;
|
||||
push @{ $self->{errors} ||= [] }, @_;
|
||||
}
|
||||
sub errors {
|
||||
return @{ $_[0]{errors} || [] };
|
||||
}
|
||||
sub add_net_gross_differences {
|
||||
my $self = shift;
|
||||
push @{ $self->{net_gross_differences} ||= [] }, @_;
|
||||
}
|
||||
sub net_gross_differences {
|
||||
return @{ $_[0]{net_gross_differences} || [] };
|
||||
}
|
||||
sub sum_net_gross_differences {
|
||||
return sum $_[0]->net_gross_differences;
|
||||
}
|
||||
sub from {
|
||||
my $self = shift;
|
||||
if (@_) {
|
||||
$self->{from} = $_[0];
|
||||
}
|
||||
return $self->{from};
|
||||
}
|
||||
sub to {
|
||||
my $self = shift;
|
||||
if (@_) {
|
||||
$self->{to} = $_[0];
|
||||
}
|
||||
return $self->{to};
|
||||
}
|
||||
e04c32d3 | Niclas Zimmermann | sub trans_id {
|
||
my $self = shift;
|
||||
if (@_) {
|
||||
$self->{trans_id} = $_[0];
|
||||
}
|
||||
return $self->{trans_id};
|
||||
}
|
||||
631b4c04 | Sven Schöling | sub accnofrom {
|
||
my $self = shift;
|
||||
if (@_) {
|
||||
$self->{accnofrom} = $_[0];
|
||||
}
|
||||
return $self->{accnofrom};
|
||||
}
|
||||
sub accnoto {
|
||||
my $self = shift;
|
||||
if (@_) {
|
||||
$self->{accnoto} = $_[0];
|
||||
}
|
||||
return $self->{accnoto};
|
||||
}
|
||||
sub dbh {
|
||||
my $self = shift;
|
||||
if (@_) {
|
||||
$self->{dbh} = $_[0];
|
||||
$self->{provided_dbh} = 1;
|
||||
}
|
||||
$self->{dbh} ||= $::form->get_standard_dbh;
|
||||
}
|
||||
sub provided_dbh {
|
||||
$_[0]{provided_dbh};
|
||||
}
|
||||
f8138d17 | Moritz Bunkus | sub clean_temporary_directories {
|
||
631b4c04 | Sven Schöling | $::lxdebug->enter_sub;
|
||
f8138d17 | Moritz Bunkus | |||
8cd05ad6 | Moritz Bunkus | foreach my $path (glob($::lx_office_conf{paths}->{userspath} . "/datev-export-*")) {
|
||
631b4c04 | Sven Schöling | next unless -d $path;
|
||
f8138d17 | Moritz Bunkus | |||
my $mtime = (stat($path))[9];
|
||||
next if ((time() - $mtime) < 8 * 60 * 60);
|
||||
rmtree $path;
|
||||
}
|
||||
631b4c04 | Sven Schöling | $::lxdebug->leave_sub;
|
||
f8138d17 | Moritz Bunkus | }
|
||
d319704a | Moritz Bunkus | |||
7b31116b | Moritz Bunkus | sub _fill {
|
||
$main::lxdebug->enter_sub();
|
||||
my $text = shift;
|
||||
my $field_len = shift;
|
||||
my $fill_char = shift;
|
||||
my $alignment = shift || 'right';
|
||||
my $text_len = length $text;
|
||||
if ($field_len < $text_len) {
|
||||
$text = substr $text, 0, $field_len;
|
||||
} elsif ($field_len > $text_len) {
|
||||
my $filler = ($fill_char) x ($field_len - $text_len);
|
||||
$text = $alignment eq 'right' ? $filler . $text : $text . $filler;
|
||||
}
|
||||
$main::lxdebug->leave_sub();
|
||||
return $text;
|
||||
}
|
||||
d319704a | Moritz Bunkus | sub get_datev_stamm {
|
||
631b4c04 | Sven Schöling | return $_[0]{stamm} ||= selectfirst_hashref_query($::form, $_[0]->dbh, 'SELECT * FROM datev');
|
||
}
|
||||
d319704a | Moritz Bunkus | |||
631b4c04 | Sven Schöling | sub save_datev_stamm {
|
||
my ($self, $data) = @_;
|
||||
d319704a | Moritz Bunkus | |||
631b4c04 | Sven Schöling | do_query($::form, $self->dbh, 'DELETE FROM datev');
|
||
d319704a | Moritz Bunkus | |||
631b4c04 | Sven Schöling | my @columns = qw(beraternr beratername dfvkz mandantennr datentraegernr abrechnungsnr);
|
||
d319704a | Moritz Bunkus | |||
631b4c04 | Sven Schöling | my $query = "INSERT INTO datev (" . join(', ', @columns) . ") VALUES (" . join(', ', ('?') x @columns) . ")";
|
||
do_query($::form, $self->dbh, $query, map { $data->{$_} } @columns);
|
||||
d319704a | Moritz Bunkus | |||
631b4c04 | Sven Schöling | $self->dbh->commit unless $self->provided_dbh;
|
||
d319704a | Moritz Bunkus | }
|
||
631b4c04 | Sven Schöling | sub export {
|
||
my ($self) = @_;
|
||||
my $result;
|
||||
d319704a | Moritz Bunkus | |||
631b4c04 | Sven Schöling | die 'no format set!' unless $self->has_format;
|
||
d319704a | Moritz Bunkus | |||
631b4c04 | Sven Schöling | if ($self->format == DATEV_FORMAT_KNE) {
|
||
$result = $self->kne_export;
|
||||
} elsif ($self->format == DATEV_FORMAT_OBE) {
|
||||
$result = $self->obe_export;
|
||||
} else {
|
||||
die 'unrecognized export format';
|
||||
}
|
||||
return $result;
|
||||
d319704a | Moritz Bunkus | }
|
||
sub kne_export {
|
||||
631b4c04 | Sven Schöling | my ($self) = @_;
|
||
f8138d17 | Moritz Bunkus | my $result;
|
||
d319704a | Moritz Bunkus | |||
631b4c04 | Sven Schöling | die 'no exporttype set!' unless $self->has_exporttype;
|
||
if ($self->exporttype == DATEV_ET_BUCHUNGEN) {
|
||||
$result = $self->kne_buchungsexport;
|
||||
} elsif ($self->exporttype == DATEV_ET_STAMM) {
|
||||
$result = $self->kne_stammdatenexport;
|
||||
d319704a | Moritz Bunkus | } else {
|
||
631b4c04 | Sven Schöling | die 'unrecognized exporttype';
|
||
d319704a | Moritz Bunkus | }
|
||
f8138d17 | Moritz Bunkus | return $result;
|
||
d319704a | Moritz Bunkus | }
|
||
sub obe_export {
|
||||
631b4c04 | Sven Schöling | die 'not yet implemented';
|
||
d319704a | Moritz Bunkus | }
|
||
631b4c04 | Sven Schöling | sub fromto {
|
||
my ($self) = @_;
|
||||
d319704a | Moritz Bunkus | |||
631b4c04 | Sven Schöling | return unless $self->from && $self->to;
|
||
d319704a | Moritz Bunkus | |||
631b4c04 | Sven Schöling | return "transdate >= '" . $self->from->to_lxoffice . "' and transdate <= '" . $self->to->to_lxoffice . "'";
|
||
d319704a | Moritz Bunkus | }
|
||
e20f3f0d | Moritz Bunkus | sub _sign {
|
||
631b4c04 | Sven Schöling | $_[0] <=> 0;
|
||
e20f3f0d | Moritz Bunkus | }
|
||
ea711360 | Moritz Bunkus | sub _get_transactions {
|
||
d319704a | Moritz Bunkus | $main::lxdebug->enter_sub();
|
||
631b4c04 | Sven Schöling | my $self = shift;
|
||
ea711360 | Moritz Bunkus | my $fromto = shift;
|
||
631b4c04 | Sven Schöling | my $progress_callback = shift || sub {};
|
||
d319704a | Moritz Bunkus | |||
ea711360 | Moritz Bunkus | my $form = $main::form;
|
||
d319704a | Moritz Bunkus | |||
e04c32d3 | Niclas Zimmermann | my $trans_id_filter = '';
|
||
$trans_id_filter = 'AND ac.trans_id = ' . $self->trans_id if $self->trans_id;
|
||||
c510d88b | Sven Schöling | my ($notsplitindex);
|
||
a3501388 | Moritz Bunkus | |||
ea711360 | Moritz Bunkus | $fromto =~ s/transdate/ac\.transdate/g;
|
||
e20f3f0d | Moritz Bunkus | my $filter = ''; # Useful for debugging purposes
|
||
631b4c04 | Sven Schöling | my %all_taxchart_ids = selectall_as_map($form, $self->dbh, qq|SELECT DISTINCT chart_id, TRUE AS is_set FROM tax|, 'chart_id', 'is_set');
|
||
ea711360 | Moritz Bunkus | |||
my $query =
|
||||
6ff01fdb | Moritz Bunkus | qq|SELECT ac.acc_trans_id, ac.transdate, ac.trans_id,ar.id, ac.amount, ac.taxkey,
|
||
2f6e7625 | Jan Büren | ar.invnumber, ar.duedate, ar.amount as umsatz, ar.deliverydate,
|
||
c6be179d | Jan Büren | ct.name, ct.ustid,
|
||
cc06de5e | Niclas Zimmermann | c.accno, c.taxkey_id as charttax, c.datevautomatik, c.id, ac.chart_link AS link,
|
||
9d2d867c | Niclas Zimmermann | ar.invoice,
|
||
t.rate AS taxrate
|
||||
e20f3f0d | Moritz Bunkus | FROM acc_trans ac
|
||
LEFT JOIN ar ON (ac.trans_id = ar.id)
|
||||
LEFT JOIN customer ct ON (ar.customer_id = ct.id)
|
||||
LEFT JOIN chart c ON (ac.chart_id = c.id)
|
||||
9d2d867c | Niclas Zimmermann | LEFT JOIN tax t ON (ac.tax_id = t.id)
|
||
e20f3f0d | Moritz Bunkus | WHERE (ar.id IS NOT NULL)
|
||
AND $fromto
|
||||
e04c32d3 | Niclas Zimmermann | $trans_id_filter
|
||
e20f3f0d | Moritz Bunkus | $filter
|
||
032e5fcd | Moritz Bunkus | |||
UNION ALL
|
||||
6ff01fdb | Moritz Bunkus | SELECT ac.acc_trans_id, ac.transdate, ac.trans_id,ap.id, ac.amount, ac.taxkey,
|
||
2f6e7625 | Jan Büren | ap.invnumber, ap.duedate, ap.amount as umsatz, ap.deliverydate,
|
||
c6be179d | Jan Büren | ct.name,ct.ustid,
|
||
cc06de5e | Niclas Zimmermann | c.accno, c.taxkey_id as charttax, c.datevautomatik, c.id, ac.chart_link AS link,
|
||
9d2d867c | Niclas Zimmermann | ap.invoice,
|
||
t.rate AS taxrate
|
||||
e20f3f0d | Moritz Bunkus | FROM acc_trans ac
|
||
LEFT JOIN ap ON (ac.trans_id = ap.id)
|
||||
LEFT JOIN vendor ct ON (ap.vendor_id = ct.id)
|
||||
LEFT JOIN chart c ON (ac.chart_id = c.id)
|
||||
9d2d867c | Niclas Zimmermann | LEFT JOIN tax t ON (ac.tax_id = t.id)
|
||
e20f3f0d | Moritz Bunkus | WHERE (ap.id IS NOT NULL)
|
||
AND $fromto
|
||||
e04c32d3 | Niclas Zimmermann | $trans_id_filter
|
||
e20f3f0d | Moritz Bunkus | $filter
|
||
032e5fcd | Moritz Bunkus | |||
UNION ALL
|
||||
6ff01fdb | Moritz Bunkus | SELECT ac.acc_trans_id, ac.transdate, ac.trans_id,gl.id, ac.amount, ac.taxkey,
|
||
2f6e7625 | Jan Büren | gl.reference AS invnumber, gl.transdate AS duedate, ac.amount as umsatz, NULL as deliverydate,
|
||
c6be179d | Jan Büren | gl.description AS name, NULL as ustid,
|
||
cc06de5e | Niclas Zimmermann | c.accno, c.taxkey_id as charttax, c.datevautomatik, c.id, ac.chart_link AS link,
|
||
9d2d867c | Niclas Zimmermann | FALSE AS invoice,
|
||
t.rate AS taxrate
|
||||
e20f3f0d | Moritz Bunkus | FROM acc_trans ac
|
||
LEFT JOIN gl ON (ac.trans_id = gl.id)
|
||||
LEFT JOIN chart c ON (ac.chart_id = c.id)
|
||||
9d2d867c | Niclas Zimmermann | LEFT JOIN tax t ON (ac.tax_id = t.id)
|
||
e20f3f0d | Moritz Bunkus | WHERE (gl.id IS NOT NULL)
|
||
AND $fromto
|
||||
e04c32d3 | Niclas Zimmermann | $trans_id_filter
|
||
e20f3f0d | Moritz Bunkus | $filter
|
||
032e5fcd | Moritz Bunkus | |||
6ff01fdb | Moritz Bunkus | ORDER BY trans_id, acc_trans_id|;
|
||
032e5fcd | Moritz Bunkus | |||
631b4c04 | Sven Schöling | my $sth = prepare_execute_query($form, $self->dbh, $query);
|
||
$self->{DATEV} = [];
|
||||
d319704a | Moritz Bunkus | |||
bbd8da97 | Moritz Bunkus | my $counter = 0;
|
||
c510d88b | Sven Schöling | while (my $ref = $sth->fetchrow_hashref("NAME_lc")) {
|
||
43550a3d | Stephan Köhler | $counter++;
|
||
if (($counter % 500) == 0) {
|
||||
631b4c04 | Sven Schöling | $progress_callback->($counter);
|
||
43550a3d | Stephan Köhler | }
|
||
aea509f8 | Moritz Bunkus | my $trans = [ $ref ];
|
||
ea711360 | Moritz Bunkus | |||
my $count = $ref->{amount};
|
||||
my $firstrun = 1;
|
||||
49db7a8e | Geoffrey Richardson | |||
# if the amount of a booking in a group is smaller than 0.02, any tax
|
||||
# amounts will likely be smaller than 1 cent, so go into subcent mode
|
||||
0802cc15 | Sven Schöling | my $subcent = abs($count) < 0.02;
|
||
ea711360 | Moritz Bunkus | |||
49db7a8e | Geoffrey Richardson | # records from acc_trans are ordered by trans_id and acc_trans_id
|
||
# first check for unbalanced ledger inside one trans_id
|
||||
# there may be several groups inside a trans_id, e.g. the original booking and the payment
|
||||
# each group individually should be exactly balanced and each group
|
||||
# individually needs its own datev lines
|
||||
# keep fetching new acc_trans lines until the end of a balanced group is reached
|
||||
1071846d | Sven Schöling | while (abs($count) > 0.01 || $firstrun || ($subcent && abs($count) > 0.005)) {
|
||
c510d88b | Sven Schöling | my $ref2 = $sth->fetchrow_hashref("NAME_lc");
|
||
d319704a | Moritz Bunkus | last unless ($ref2);
|
||
ea711360 | Moritz Bunkus | |||
49db7a8e | Geoffrey Richardson | # check if trans_id of current acc_trans line is still the same as the
|
||
# trans_id of the first line in group
|
||||
e20f3f0d | Moritz Bunkus | if ($ref2->{trans_id} != $trans->[0]->{trans_id}) {
|
||
631b4c04 | Sven Schöling | $self->add_error("Unbalanced ledger! old trans_id " . $trans->[0]->{trans_id} . " new trans_id " . $ref2->{trans_id} . " count $count");
|
||
return;
|
||||
e20f3f0d | Moritz Bunkus | }
|
||
aea509f8 | Moritz Bunkus | push @{ $trans }, $ref2;
|
||
ea711360 | Moritz Bunkus | |||
$count += $ref2->{amount};
|
||||
$firstrun = 0;
|
||||
d319704a | Moritz Bunkus | }
|
||
ea711360 | Moritz Bunkus | |||
e20f3f0d | Moritz Bunkus | foreach my $i (0 .. scalar(@{ $trans }) - 1) {
|
||
my $ref = $trans->[$i];
|
||||
my $prev_ref = 0 < $i ? $trans->[$i - 1] : undef;
|
||||
if ( $all_taxchart_ids{$ref->{id}}
|
||||
&& ($ref->{link} =~ m/(?:AP_tax|AR_tax)/)
|
||||
&& ( ($prev_ref && $prev_ref->{taxkey} && (_sign($ref->{amount}) == _sign($prev_ref->{amount})))
|
||||
|| $ref->{invoice})) {
|
||||
$ref->{is_tax} = 1;
|
||||
}
|
||||
1422e28a | Geoffrey Richardson | if ( !$ref->{invoice} # we have a non-invoice booking (=gl)
|
||
&& $ref->{is_tax} # that has "is_tax" set
|
||||
&& !($prev_ref->{is_tax}) # previous line wasn't is_tax
|
||||
c1f307ca | Jan Büren | && (_sign($ref->{amount}) == _sign($prev_ref->{amount}))) { # and sign same as previous sign
|
||
e20f3f0d | Moritz Bunkus | $trans->[$i - 1]->{tax_amount} = $ref->{amount};
|
||
}
|
||||
}
|
||||
ea711360 | Moritz Bunkus | my $absumsatz = 0;
|
||
aea509f8 | Moritz Bunkus | if (scalar(@{$trans}) <= 2) {
|
||
631b4c04 | Sven Schöling | push @{ $self->{DATEV} }, $trans;
|
||
ea711360 | Moritz Bunkus | next;
|
||
}
|
||||
c2796317 | Bernd Bleßmann | # determine at which array position the reference value (called absumsatz) is
|
||
49db7a8e | Geoffrey Richardson | # and which amount it has
|
||
aea509f8 | Moritz Bunkus | for my $j (0 .. (scalar(@{$trans}) - 1)) {
|
||
c2796317 | Bernd Bleßmann | |||
49db7a8e | Geoffrey Richardson | # Three cases:
|
||
# 1: gl transaction (Dialogbuchung), invoice is false, no double split booking allowed
|
||||
# 2: sales or vendor invoice (Verkaufs- und Einkaufsrechnung): invoice is
|
||||
# true, instead of absumsatz use link AR/AP (there should only be one
|
||||
# entry)
|
||||
# 3. AR/AP transaction (Kreditoren- und Debitorenbuchung): invoice is false,
|
||||
# instead of absumsatz use link AR/AP (there should only be one, so jump
|
||||
# out of search as soon as you find it )
|
||||
# case 1 and 2
|
||||
1422e28a | Geoffrey Richardson | # for gl-bookings no split is allowed and there is no AR/AP account, so we always use the maximum value as a reference
|
||
# for ap/ar bookings we can always search for AR/AP in link and use that
|
||||
if ( ( not $trans->[$j]->{'invoice'} and abs($trans->[$j]->{'amount'}) > abs($absumsatz) )
|
||||
or ($trans->[$j]->{'invoice'} and ($trans->[$j]->{'link'} eq 'AR' or $trans->[$j]->{'link'} eq 'AP'))) {
|
||||
aea509f8 | Moritz Bunkus | $absumsatz = $trans->[$j]->{'amount'};
|
||
ea711360 | Moritz Bunkus | $notsplitindex = $j;
|
||
d319704a | Moritz Bunkus | }
|
||
49db7a8e | Geoffrey Richardson | |||
# case 3
|
||||
# Problem: we can't distinguish between AR and AP and normal invoices via boolean "invoice"
|
||||
# for AR and AP transaction exit the loop as soon as an AR or AP account is found
|
||||
# there must be only one AR or AP chart in the booking
|
||||
if ( $trans->[$j]->{'link'} eq 'AR' or $trans->[$j]->{'link'} eq 'AP') {
|
||||
$notsplitindex = $j; # position in booking with highest amount
|
||||
$absumsatz = $trans->[$j]->{'amount'};
|
||||
last;
|
||||
};
|
||||
ea711360 | Moritz Bunkus | }
|
||
bbd8da97 | Moritz Bunkus | |||
e20f3f0d | Moritz Bunkus | my $ml = ($trans->[0]->{'umsatz'} > 0) ? 1 : -1;
|
||
my $rounding_error = 0;
|
||||
bf3b6966 | Moritz Bunkus | my @taxed;
|
||
e20f3f0d | Moritz Bunkus | |||
49db7a8e | Geoffrey Richardson | # go through each line and determine if it is a tax booking or not
|
||
# skip all tax lines and notsplitindex line
|
||||
# push all other accounts (e.g. income or expense) with corresponding taxkey
|
||||
aea509f8 | Moritz Bunkus | for my $j (0 .. (scalar(@{$trans}) - 1)) {
|
||
ea711360 | Moritz Bunkus | if ( ($j != $notsplitindex)
|
||
e20f3f0d | Moritz Bunkus | && !$trans->[$j]->{is_tax}
|
||
aea509f8 | Moritz Bunkus | && ( $trans->[$j]->{'taxkey'} eq ""
|
||
|| $trans->[$j]->{'taxkey'} eq "0"
|
||||
|| $trans->[$j]->{'taxkey'} eq "1"
|
||||
|| $trans->[$j]->{'taxkey'} eq "10"
|
||||
|| $trans->[$j]->{'taxkey'} eq "11")) {
|
||||
4c5ca4c0 | Moritz Bunkus | my %new_trans = ();
|
||
map { $new_trans{$_} = $trans->[$notsplitindex]->{$_}; } keys %{ $trans->[$notsplitindex] };
|
||||
ea711360 | Moritz Bunkus | |||
aea509f8 | Moritz Bunkus | $absumsatz += $trans->[$j]->{'amount'};
|
||
bbd8da97 | Moritz Bunkus | $new_trans{'amount'} = $trans->[$j]->{'amount'} * (-1);
|
||
$new_trans{'umsatz'} = abs($trans->[$j]->{'amount'}) * $ml;
|
||||
aea509f8 | Moritz Bunkus | $trans->[$j]->{'umsatz'} = abs($trans->[$j]->{'amount'}) * $ml;
|
||
ea711360 | Moritz Bunkus | |||
631b4c04 | Sven Schöling | push @{ $self->{DATEV} }, [ \%new_trans, $trans->[$j] ];
|
||
ea711360 | Moritz Bunkus | |||
e20f3f0d | Moritz Bunkus | } elsif (($j != $notsplitindex) && !$trans->[$j]->{is_tax}) {
|
||
ea711360 | Moritz Bunkus | |||
4c5ca4c0 | Moritz Bunkus | my %new_trans = ();
|
||
map { $new_trans{$_} = $trans->[$notsplitindex]->{$_}; } keys %{ $trans->[$notsplitindex] };
|
||||
ea711360 | Moritz Bunkus | |||
9d2d867c | Niclas Zimmermann | my $tax_rate = $trans->[$j]->{'taxrate'};
|
||
e20f3f0d | Moritz Bunkus | $new_trans{'net_amount'} = $trans->[$j]->{'amount'} * -1;
|
||
$new_trans{'tax_rate'} = 1 + $tax_rate;
|
||||
ea711360 | Moritz Bunkus | |||
e20f3f0d | Moritz Bunkus | if (!$trans->[$j]->{'invoice'}) {
|
||
$new_trans{'amount'} = $form->round_amount(-1 * ($trans->[$j]->{amount} + $trans->[$j]->{tax_amount}), 2);
|
||||
$new_trans{'umsatz'} = abs($new_trans{'amount'}) * $ml;
|
||||
$trans->[$j]->{'umsatz'} = $new_trans{'umsatz'};
|
||||
$absumsatz += -1 * $new_trans{'amount'};
|
||||
} else {
|
||||
474247d8 | Moritz Bunkus | my $unrounded = $trans->[$j]->{'amount'} * (1 + $tax_rate) * -1 + $rounding_error;
|
||
e20f3f0d | Moritz Bunkus | my $rounded = $form->round_amount($unrounded, 2);
|
||
474247d8 | Moritz Bunkus | |||
$rounding_error = $unrounded - $rounded;
|
||||
e20f3f0d | Moritz Bunkus | $new_trans{'amount'} = $rounded;
|
||
474247d8 | Moritz Bunkus | $new_trans{'umsatz'} = abs($rounded) * $ml;
|
||
$trans->[$j]->{'umsatz'} = $new_trans{umsatz};
|
||||
$absumsatz -= $rounded;
|
||||
e20f3f0d | Moritz Bunkus | }
|
||
631b4c04 | Sven Schöling | push @{ $self->{DATEV} }, [ \%new_trans, $trans->[$j] ];
|
||
push @taxed, $self->{DATEV}->[-1];
|
||||
e20f3f0d | Moritz Bunkus | }
|
||
}
|
||||
my $idx = 0;
|
||||
my $correction = 0;
|
||||
bf3b6966 | Moritz Bunkus | while ((abs($absumsatz) >= 0.01) && (abs($absumsatz) < 1.00)) {
|
||
e20f3f0d | Moritz Bunkus | if ($idx >= scalar @taxed) {
|
||
last if (!$correction);
|
||||
$correction = 0;
|
||||
$idx = 0;
|
||||
d319704a | Moritz Bunkus | }
|
||
e20f3f0d | Moritz Bunkus | |||
my $transaction = $taxed[$idx]->[0];
|
||||
my $old_amount = $transaction->{amount};
|
||||
my $old_correction = $correction;
|
||||
my @possible_diffs;
|
||||
if (!$transaction->{diff}) {
|
||||
@possible_diffs = (0.01, -0.01);
|
||||
} else {
|
||||
@possible_diffs = ($transaction->{diff});
|
||||
}
|
||||
foreach my $diff (@possible_diffs) {
|
||||
my $net_amount = $form->round_amount(($transaction->{amount} + $diff) / $transaction->{tax_rate}, 2);
|
||||
next if ($net_amount != $transaction->{net_amount});
|
||||
$transaction->{diff} = $diff;
|
||||
$transaction->{amount} += $diff;
|
||||
$transaction->{umsatz} += $diff;
|
||||
$absumsatz -= $diff;
|
||||
$correction = 1;
|
||||
last;
|
||||
}
|
||||
$idx++;
|
||||
d319704a | Moritz Bunkus | }
|
||
ea711360 | Moritz Bunkus | |||
a3501388 | Moritz Bunkus | $absumsatz = $form->round_amount($absumsatz, 2);
|
||
if (abs($absumsatz) >= (0.01 * (1 + scalar @taxed))) {
|
||||
631b4c04 | Sven Schöling | $self->add_error("Datev-Export fehlgeschlagen! Bei Transaktion $trans->[0]->{trans_id} ($absumsatz)");
|
||
a3501388 | Moritz Bunkus | |||
} elsif (abs($absumsatz) >= 0.01) {
|
||||
631b4c04 | Sven Schöling | $self->add_net_gross_differences($absumsatz);
|
||
ea711360 | Moritz Bunkus | }
|
||
d319704a | Moritz Bunkus | }
|
||
6683b7fb | Moritz Bunkus | |||
$sth->finish();
|
||||
631b4c04 | Sven Schöling | $::lxdebug->leave_sub;
|
||
d319704a | Moritz Bunkus | }
|
||
sub make_kne_data_header {
|
||||
$main::lxdebug->enter_sub();
|
||||
631b4c04 | Sven Schöling | my ($self, $form) = @_;
|
||
c510d88b | Sven Schöling | my ($primanota);
|
||
d319704a | Moritz Bunkus | |||
631b4c04 | Sven Schöling | my $stamm = $self->get_datev_stamm;
|
||
my $jahr = $self->from ? $self->from->year : DateTime->today->year;
|
||||
d319704a | Moritz Bunkus | |||
#Header
|
||||
7b31116b | Moritz Bunkus | my $header = "\x1D\x181";
|
||
631b4c04 | Sven Schöling | $header .= _fill($stamm->{datentraegernr}, 3, ' ', 'left');
|
||
$header .= ($self->fromto) ? "11" : "13"; # Anwendungsnummer
|
||||
$header .= _fill($stamm->{dfvkz}, 2, '0');
|
||||
$header .= _fill($stamm->{beraternr}, 7, '0');
|
||||
$header .= _fill($stamm->{mandantennr}, 5, '0');
|
||||
$header .= _fill($stamm->{abrechnungsnr} . $jahr, 6, '0');
|
||||
d319704a | Moritz Bunkus | |||
631b4c04 | Sven Schöling | $header .= $self->from ? $self->from->strftime('%d%m%y') : '';
|
||
$header .= $self->to ? $self->to->strftime('%d%m%y') : '';
|
||||
d319704a | Moritz Bunkus | |||
631b4c04 | Sven Schöling | if ($self->fromto) {
|
||
7b31116b | Moritz Bunkus | $primanota = "001";
|
||
d319704a | Moritz Bunkus | $header .= $primanota;
|
||
}
|
||||
631b4c04 | Sven Schöling | $header .= _fill($stamm->{passwort}, 4, '0');
|
||
7b31116b | Moritz Bunkus | $header .= " " x 16; # Anwendungsinfo
|
||
$header .= " " x 16; # Inputinfo
|
||||
d319704a | Moritz Bunkus | $header .= "\x79";
|
||
#Versionssatz
|
||||
631b4c04 | Sven Schöling | my $versionssatz = $self->exporttype == DATEV_ET_BUCHUNGEN ? "\xB5" . "1," : "\xB6" . "1,";
|
||
d319704a | Moritz Bunkus | |||
7b31116b | Moritz Bunkus | my $query = qq|SELECT accno FROM chart LIMIT 1|;
|
||
631b4c04 | Sven Schöling | my $ref = selectfirst_hashref_query($form, $self->dbh, $query);
|
||
d319704a | Moritz Bunkus | |||
7b31116b | Moritz Bunkus | $versionssatz .= length $ref->{accno};
|
||
$versionssatz .= ",";
|
||||
$versionssatz .= length $ref->{accno};
|
||||
$versionssatz .= ",SELF" . "\x1C\x79";
|
||||
d319704a | Moritz Bunkus | |||
7b31116b | Moritz Bunkus | $header .= $versionssatz;
|
||
d319704a | Moritz Bunkus | |||
$main::lxdebug->leave_sub();
|
||||
return $header;
|
||||
}
|
||||
sub datetofour {
|
||||
$main::lxdebug->enter_sub();
|
||||
my ($date, $six) = @_;
|
||||
c510d88b | Sven Schöling | my ($day, $month, $year) = split(/\./, $date);
|
||
d319704a | Moritz Bunkus | |||
if ($day =~ /^0/) {
|
||||
$day = substr($day, 1, 1);
|
||||
}
|
||||
if (length($month) < 2) {
|
||||
$month = "0" . $month;
|
||||
}
|
||||
if (length($year) > 2) {
|
||||
$year = substr($year, -2, 2);
|
||||
}
|
||||
if ($six) {
|
||||
$date = $day . $month . $year;
|
||||
} else {
|
||||
$date = $day . $month;
|
||||
}
|
||||
$main::lxdebug->leave_sub();
|
||||
return $date;
|
||||
}
|
||||
40d52f50 | Moritz Bunkus | sub trim_leading_zeroes {
|
||
my $str = shift;
|
||||
d319704a | Moritz Bunkus | |||
40d52f50 | Moritz Bunkus | $str =~ s/^0+//g;
|
||
d319704a | Moritz Bunkus | |||
40d52f50 | Moritz Bunkus | return $str;
|
||
d319704a | Moritz Bunkus | }
|
||
sub make_ed_versionset {
|
||||
$main::lxdebug->enter_sub();
|
||||
631b4c04 | Sven Schöling | my ($self, $header, $filename, $blockcount) = @_;
|
||
d319704a | Moritz Bunkus | |||
7b31116b | Moritz Bunkus | my $versionset = "V" . substr($filename, 2, 5);
|
||
$versionset .= substr($header, 6, 22);
|
||||
631b4c04 | Sven Schöling | if ($self->fromto) {
|
||
d319704a | Moritz Bunkus | $versionset .= "0000" . substr($header, 28, 19);
|
||
} else {
|
||||
c510d88b | Sven Schöling | my $datum = " " x 16;
|
||
d319704a | Moritz Bunkus | $versionset .= $datum . "001" . substr($header, 28, 4);
|
||
}
|
||||
7b31116b | Moritz Bunkus | |||
$versionset .= _fill($blockcount, 5, '0');
|
||||
d319704a | Moritz Bunkus | $versionset .= "001";
|
||
7b31116b | Moritz Bunkus | $versionset .= " 1";
|
||
d319704a | Moritz Bunkus | $versionset .= substr($header, -12, 10) . " ";
|
||
7b31116b | Moritz Bunkus | $versionset .= " " x 53;
|
||
d319704a | Moritz Bunkus | |||
$main::lxdebug->leave_sub();
|
||||
return $versionset;
|
||||
}
|
||||
sub make_ev_header {
|
||||
$main::lxdebug->enter_sub();
|
||||
631b4c04 | Sven Schöling | my ($self, $form, $fileno) = @_;
|
||
my $stamm = $self->get_datev_stamm;
|
||||
d319704a | Moritz Bunkus | |||
631b4c04 | Sven Schöling | my $ev_header = _fill($stamm->{datentraegernr}, 3, ' ', 'left');
|
||
7b31116b | Moritz Bunkus | $ev_header .= " ";
|
||
631b4c04 | Sven Schöling | $ev_header .= _fill($stamm->{beraternr}, 7, ' ', 'left');
|
||
$ev_header .= _fill($stamm->{beratername}, 9, ' ', 'left');
|
||||
7b31116b | Moritz Bunkus | $ev_header .= " ";
|
||
$ev_header .= (_fill($fileno, 5, '0')) x 2;
|
||||
$ev_header .= " " x 95;
|
||||
d319704a | Moritz Bunkus | |||
$main::lxdebug->leave_sub();
|
||||
return $ev_header;
|
||||
}
|
||||
sub kne_buchungsexport {
|
||||
$main::lxdebug->enter_sub();
|
||||
631b4c04 | Sven Schöling | my ($self) = @_;
|
||
my $form = $::form;
|
||||
d319704a | Moritz Bunkus | |||
39f3d12c | Moritz Bunkus | my @filenames;
|
||
d319704a | Moritz Bunkus | my $filename = "ED00000";
|
||
my $evfile = "EV01";
|
||||
c510d88b | Sven Schöling | my @ed_versionset;
|
||
d319704a | Moritz Bunkus | my $fileno = 0;
|
||
081a4f97 | Moritz Bunkus | |||
631b4c04 | Sven Schöling | my $fromto = $self->fromto;
|
||
$self->_get_transactions($fromto);
|
||||
return if $self->errors;
|
||||
43550a3d | Stephan Köhler | my $counter = 0;
|
||
631b4c04 | Sven Schöling | |||
while (scalar(@{ $self->{DATEV} || [] })) {
|
||||
40d52f50 | Moritz Bunkus | my $umsatzsumme = 0;
|
||
d319704a | Moritz Bunkus | $filename++;
|
||
631b4c04 | Sven Schöling | my $ed_filename = $self->export_path . $filename;
|
||
39f3d12c | Moritz Bunkus | push(@filenames, $filename);
|
||
631b4c04 | Sven Schöling | my $header = $self->make_kne_data_header($form);
|
||
40d52f50 | Moritz Bunkus | |||
my $kne_file = SL::DATEV::KNEFile->new();
|
||||
$kne_file->add_block($header);
|
||||
d319704a | Moritz Bunkus | |||
631b4c04 | Sven Schöling | while (scalar(@{ $self->{DATEV} }) > 0) {
|
||
my $transaction = shift @{ $self->{DATEV} };
|
||||
c510d88b | Sven Schöling | my $trans_lines = scalar(@{$transaction});
|
||
43550a3d | Stephan Köhler | $counter++;
|
||
40d52f50 | Moritz Bunkus | my $umsatz = 0;
|
||
my $gegenkonto = "";
|
||||
my $konto = "";
|
||||
my $belegfeld1 = "";
|
||||
my $datum = "";
|
||||
my $waehrung = "";
|
||||
my $buchungstext = "";
|
||||
my $belegfeld2 = "";
|
||||
my $datevautomatik = 0;
|
||||
my $taxkey = 0;
|
||||
my $charttax = 0;
|
||||
c6be179d | Jan Büren | my $ustid ="";
|
||
c510d88b | Sven Schöling | my ($haben, $soll);
|
||
05c6840d | Moritz Bunkus | my $iconv = $::locale->{iconv_utf8};
|
||
my %umlaute = ($iconv->convert('ä') => 'ae',
|
||||
$iconv->convert('ö') => 'oe',
|
||||
$iconv->convert('ü') => 'ue',
|
||||
$iconv->convert('Ä') => 'Ae',
|
||||
$iconv->convert('Ö') => 'Oe',
|
||||
$iconv->convert('Ü') => 'Ue',
|
||||
$iconv->convert('ß') => 'sz');
|
||||
d319704a | Moritz Bunkus | for (my $i = 0; $i < $trans_lines; $i++) {
|
||
d1731f0c | Stephan Köhler | if ($trans_lines == 2) {
|
||
if (abs($transaction->[$i]->{'amount'}) > abs($umsatz)) {
|
||||
$umsatz = $transaction->[$i]->{'amount'};
|
||||
}
|
||||
} else {
|
||||
if (abs($transaction->[$i]->{'umsatz'}) > abs($umsatz)) {
|
||||
$umsatz = $transaction->[$i]->{'umsatz'};
|
||||
}
|
||||
d319704a | Moritz Bunkus | }
|
||
if ($transaction->[$i]->{'datevautomatik'}) {
|
||||
$datevautomatik = 1;
|
||||
}
|
||||
if ($transaction->[$i]->{'taxkey'}) {
|
||||
$taxkey = $transaction->[$i]->{'taxkey'};
|
||||
}
|
||||
if ($transaction->[$i]->{'charttax'}) {
|
||||
$charttax = $transaction->[$i]->{'charttax'};
|
||||
}
|
||||
e20f3f0d | Moritz Bunkus | if ($transaction->[$i]->{'amount'} > 0) {
|
||
d319704a | Moritz Bunkus | $haben = $i;
|
||
40d52f50 | Moritz Bunkus | } else {
|
||
d319704a | Moritz Bunkus | $soll = $i;
|
||
}
|
||||
}
|
||||
# Umwandlung von Umlauten und Sonderzeichen in erlaubte Zeichen bei Textfeldern
|
||||
c510d88b | Sven Schöling | foreach my $umlaut (keys(%umlaute)) {
|
||
40d52f50 | Moritz Bunkus | $transaction->[$haben]->{'invnumber'} =~ s/${umlaut}/${umlaute{$umlaut}}/g;
|
||
$transaction->[$haben]->{'name'} =~ s/${umlaut}/${umlaute{$umlaut}}/g;
|
||||
d319704a | Moritz Bunkus | }
|
||
$transaction->[$haben]->{'invnumber'} =~ s/[^0-9A-Za-z\$\%\&\*\+\-\/]//g;
|
||||
40d52f50 | Moritz Bunkus | $transaction->[$haben]->{'name'} =~ s/[^0-9A-Za-z\$\%\&\*\+\-\ \/]//g;
|
||
d319704a | Moritz Bunkus | |||
40d52f50 | Moritz Bunkus | $transaction->[$haben]->{'invnumber'} = substr($transaction->[$haben]->{'invnumber'}, 0, 12);
|
||
$transaction->[$haben]->{'name'} = substr($transaction->[$haben]->{'name'}, 0, 30);
|
||||
d319704a | Moritz Bunkus | $transaction->[$haben]->{'invnumber'} =~ s/\ *$//;
|
||
$transaction->[$haben]->{'name'} =~ s/\ *$//;
|
||||
if ($trans_lines >= 2) {
|
||||
40d52f50 | Moritz Bunkus | $gegenkonto = "a" . trim_leading_zeroes($transaction->[$haben]->{'accno'});
|
||
$konto = "e" . trim_leading_zeroes($transaction->[$soll]->{'accno'});
|
||||
d319704a | Moritz Bunkus | if ($transaction->[$haben]->{'invnumber'} ne "") {
|
||
40d52f50 | Moritz Bunkus | $belegfeld1 = "\xBD" . $transaction->[$haben]->{'invnumber'} . "\x1C";
|
||
d319704a | Moritz Bunkus | }
|
||
$datum = "d";
|
||||
$datum .= &datetofour($transaction->[$haben]->{'transdate'}, 0);
|
||||
$waehrung = "\xB3" . "EUR" . "\x1C";
|
||||
if ($transaction->[$haben]->{'name'} ne "") {
|
||||
$buchungstext = "\x1E" . $transaction->[$haben]->{'name'} . "\x1C";
|
||||
}
|
||||
c6be179d | Jan Büren | if ($transaction->[$haben]->{'ustid'} ne "") {
|
||
$ustid = "\xBA" . $transaction->[$haben]->{'ustid'} . "\x1C";
|
||||
}
|
||||
d319704a | Moritz Bunkus | if ($transaction->[$haben]->{'duedate'} ne "") {
|
||
40d52f50 | Moritz Bunkus | $belegfeld2 = "\xBE" . &datetofour($transaction->[$haben]->{'duedate'}, 1) . "\x1C";
|
||
d319704a | Moritz Bunkus | }
|
||
}
|
||||
40d52f50 | Moritz Bunkus | $umsatz = $kne_file->format_amount(abs($umsatz), 0);
|
||
$umsatzsumme += $umsatz;
|
||||
$kne_file->add_block("+" . $umsatz);
|
||||
d319704a | Moritz Bunkus | |||
05e6d940 | Jan Büren | # Dies ist die einzige Stelle die datevautomatik auswertet. Was soll gesagt werden?
|
||
# Im Prinzip hat jeder acc_trans Eintrag einen Steuerschlüssel, außer, bei gewissen Fällen
|
||||
# wie: Kreditorenbuchung mit negativen Vorzeichen, SEPA-Export oder Rechnungen die per
|
||||
# Skript angelegt werden.
|
||||
# Also falls ein Steuerschlüssel da ist und NICHT datevautomatik diesen Block hinzufügen.
|
||||
# Oder aber datevautomatik ist WAHR, aber der Steuerschlüssel in der acc_trans weicht
|
||||
# von dem in der Chart ab: Also wahrscheinlich Programmfehler (NULL übergeben, statt
|
||||
# DATEV-Steuerschlüssel) oder der Steuerschlüssel des Kontos weicht WIRKLICH von dem Eintrag in der
|
||||
# acc_trans ab. Gibt es für diesen Fall eine plausiblen Grund?
|
||||
#
|
||||
40d52f50 | Moritz Bunkus | if ( ( $datevautomatik || $taxkey)
|
||
&& (!$datevautomatik || ($datevautomatik && ($charttax ne $taxkey)))) {
|
||||
e20f3f0d | Moritz Bunkus | # $kne_file->add_block("\x6C" . (!$datevautomatik ? $taxkey : "4"));
|
||
$kne_file->add_block("\x6C${taxkey}");
|
||||
d319704a | Moritz Bunkus | }
|
||
40d52f50 | Moritz Bunkus | $kne_file->add_block($gegenkonto);
|
||
$kne_file->add_block($belegfeld1);
|
||||
$kne_file->add_block($belegfeld2);
|
||||
$kne_file->add_block($datum);
|
||||
$kne_file->add_block($konto);
|
||||
$kne_file->add_block($buchungstext);
|
||||
c6be179d | Jan Büren | $kne_file->add_block($ustid);
|
||
40d52f50 | Moritz Bunkus | $kne_file->add_block($waehrung . "\x79");
|
||
d319704a | Moritz Bunkus | }
|
||
40d52f50 | Moritz Bunkus | my $mandantenendsumme = "x" . $kne_file->format_amount($umsatzsumme / 100.0, 14) . "\x79\x7a";
|
||
$kne_file->add_block($mandantenendsumme);
|
||||
$kne_file->flush();
|
||||
7274f9c8 | Sven Schöling | open(ED, ">", $ed_filename) or die "can't open outputfile: $!\n";
|
||
40d52f50 | Moritz Bunkus | print(ED $kne_file->get_data());
|
||
d319704a | Moritz Bunkus | close(ED);
|
||
631b4c04 | Sven Schöling | $ed_versionset[$fileno] = $self->make_ed_versionset($header, $filename, $kne_file->get_block_count());
|
||
d319704a | Moritz Bunkus | $fileno++;
|
||
}
|
||||
#Make EV Verwaltungsdatei
|
||||
631b4c04 | Sven Schöling | my $ev_header = $self->make_ev_header($form, $fileno);
|
||
my $ev_filename = $self->export_path . $evfile;
|
||||
39f3d12c | Moritz Bunkus | push(@filenames, $evfile);
|
||
7274f9c8 | Sven Schöling | open(EV, ">", $ev_filename) or die "can't open outputfile: EV01\n";
|
||
d319704a | Moritz Bunkus | print(EV $ev_header);
|
||
c510d88b | Sven Schöling | foreach my $file (@ed_versionset) {
|
||
d319704a | Moritz Bunkus | print(EV $ed_versionset[$file]);
|
||
}
|
||||
close(EV);
|
||||
###
|
||||
631b4c04 | Sven Schöling | |||
$self->add_filenames(@filenames);
|
||||
d319704a | Moritz Bunkus | $main::lxdebug->leave_sub();
|
||
39f3d12c | Moritz Bunkus | |||
631b4c04 | Sven Schöling | return { 'download_token' => $self->download_token, 'filenames' => \@filenames };
|
||
d319704a | Moritz Bunkus | }
|
||
sub kne_stammdatenexport {
|
||||
$main::lxdebug->enter_sub();
|
||||
631b4c04 | Sven Schöling | my ($self) = @_;
|
||
my $form = $::form;
|
||||
d319704a | Moritz Bunkus | |||
631b4c04 | Sven Schöling | $self->get_datev_stamm->{abrechnungsnr} = "99";
|
||
39f3d12c | Moritz Bunkus | |||
my @filenames;
|
||||
d319704a | Moritz Bunkus | my $filename = "ED00000";
|
||
my $evfile = "EV01";
|
||||
c510d88b | Sven Schöling | my @ed_versionset;
|
||
d319704a | Moritz Bunkus | my $fileno = 1;
|
||
my $i = 0;
|
||||
my $blockcount = 1;
|
||||
my $remaining_bytes = 256;
|
||||
my $total_bytes = 256;
|
||||
my $buchungssatz = "";
|
||||
$filename++;
|
||||
631b4c04 | Sven Schöling | my $ed_filename = $self->export_path . $filename;
|
||
39f3d12c | Moritz Bunkus | push(@filenames, $filename);
|
||
7274f9c8 | Sven Schöling | open(ED, ">", $ed_filename) or die "can't open outputfile: $!\n";
|
||
631b4c04 | Sven Schöling | my $header = $self->make_kne_data_header($form);
|
||
d319704a | Moritz Bunkus | $remaining_bytes -= length($header);
|
||
c510d88b | Sven Schöling | my $fuellzeichen;
|
||
d319704a | Moritz Bunkus | |||
40d52f50 | Moritz Bunkus | my (@where, @values) = ((), ());
|
||
631b4c04 | Sven Schöling | if ($self->accnofrom) {
|
||
40d52f50 | Moritz Bunkus | push @where, 'c.accno >= ?';
|
||
631b4c04 | Sven Schöling | push @values, $self->accnofrom;
|
||
40d52f50 | Moritz Bunkus | }
|
||
631b4c04 | Sven Schöling | if ($self->accnoto) {
|
||
40d52f50 | Moritz Bunkus | push @where, 'c.accno <= ?';
|
||
631b4c04 | Sven Schöling | push @values, $self->accnoto;
|
||
40d52f50 | Moritz Bunkus | }
|
||
74fca575 | Sven Schöling | my $where_str = @where ? ' WHERE ' . join(' AND ', map { "($_)" } @where) : '';
|
||
d319704a | Moritz Bunkus | |||
40d52f50 | Moritz Bunkus | my $query = qq|SELECT c.accno, c.description
|
||
FROM chart c
|
||||
$where_str
|
||||
ORDER BY c.accno|;
|
||||
631b4c04 | Sven Schöling | my $sth = $self->dbh->prepare($query);
|
||
40d52f50 | Moritz Bunkus | $sth->execute(@values) || $form->dberror($query);
|
||
d319704a | Moritz Bunkus | |||
c510d88b | Sven Schöling | while (my $ref = $sth->fetchrow_hashref("NAME_lc")) {
|
||
d319704a | Moritz Bunkus | if (($remaining_bytes - length("t" . $ref->{'accno'})) <= 6) {
|
||
$fuellzeichen = ($blockcount * 256 - length($buchungssatz . $header));
|
||||
$buchungssatz .= "\x00" x $fuellzeichen;
|
||||
$blockcount++;
|
||||
$total_bytes = ($blockcount) * 256;
|
||||
}
|
||||
$buchungssatz .= "t" . $ref->{'accno'};
|
||||
$remaining_bytes = $total_bytes - length($buchungssatz . $header);
|
||||
$ref->{'description'} =~ s/[^0-9A-Za-z\$\%\&\*\+\-\/]//g;
|
||||
$ref->{'description'} = substr($ref->{'description'}, 0, 40);
|
||||
$ref->{'description'} =~ s/\ *$//;
|
||||
if (
|
||||
($remaining_bytes - length("\x1E" . $ref->{'description'} . "\x1C\x79")
|
||||
) <= 6
|
||||
) {
|
||||
$fuellzeichen = ($blockcount * 256 - length($buchungssatz . $header));
|
||||
$buchungssatz .= "\x00" x $fuellzeichen;
|
||||
$blockcount++;
|
||||
$total_bytes = ($blockcount) * 256;
|
||||
}
|
||||
$buchungssatz .= "\x1E" . $ref->{'description'} . "\x1C\x79";
|
||||
$remaining_bytes = $total_bytes - length($buchungssatz . $header);
|
||||
}
|
||||
$sth->finish;
|
||||
print(ED $header);
|
||||
print(ED $buchungssatz);
|
||||
$fuellzeichen = 256 - (length($header . $buchungssatz . "z") % 256);
|
||||
c510d88b | Sven Schöling | my $dateiende = "\x00" x $fuellzeichen;
|
||
d319704a | Moritz Bunkus | print(ED "z");
|
||
print(ED $dateiende);
|
||||
close(ED);
|
||||
#Make EV Verwaltungsdatei
|
||||
$ed_versionset[0] =
|
||||
631b4c04 | Sven Schöling | $self->make_ed_versionset($header, $filename, $blockcount);
|
||
d319704a | Moritz Bunkus | |||
631b4c04 | Sven Schöling | my $ev_header = $self->make_ev_header($form, $fileno);
|
||
my $ev_filename = $self->export_path . $evfile;
|
||||
39f3d12c | Moritz Bunkus | push(@filenames, $evfile);
|
||
7274f9c8 | Sven Schöling | open(EV, ">", $ev_filename) or die "can't open outputfile: EV01\n";
|
||
d319704a | Moritz Bunkus | print(EV $ev_header);
|
||
c510d88b | Sven Schöling | foreach my $file (@ed_versionset) {
|
||
d319704a | Moritz Bunkus | print(EV $ed_versionset[$file]);
|
||
}
|
||||
close(EV);
|
||||
631b4c04 | Sven Schöling | $self->add_filenames(@filenames);
|
||
39f3d12c | Moritz Bunkus | |||
d319704a | Moritz Bunkus | $main::lxdebug->leave_sub();
|
||
39f3d12c | Moritz Bunkus | |||
631b4c04 | Sven Schöling | return { 'download_token' => $self->download_token, 'filenames' => \@filenames };
|
||
}
|
||||
sub DESTROY {
|
||||
clean_temporary_directories();
|
||||
d319704a | Moritz Bunkus | }
|
||
1;
|
||||
631b4c04 | Sven Schöling | |||
__END__
|
||||
=encoding utf-8
|
||||
=head1 NAME
|
||||
008c2e15 | Moritz Bunkus | SL::DATEV - kivitendo DATEV Export module
|
||
631b4c04 | Sven Schöling | |||
=head1 SYNOPSIS
|
||||
use SL::DATEV qw(:CONSTANTS);
|
||||
my $datev = SL::DATEV->new(
|
||||
exporttype => DATEV_ET_BUCHUNGEN,
|
||||
format => DATEV_FORMAT_KNE,
|
||||
from => $startdate,
|
||||
to => $enddate,
|
||||
);
|
||||
my $datev = SL::DATEV->new(
|
||||
exporttype => DATEV_ET_STAMM,
|
||||
format => DATEV_FORMAT_KNE,
|
||||
accnofrom => $start_account_number,
|
||||
accnoto => $end_account_number,
|
||||
);
|
||||
# get or set datev stamm
|
||||
my $hashref = $datev->get_datev_stamm;
|
||||
$datev->save_datev_stamm($hashref);
|
||||
# manually clean up temporary directories
|
||||
$datev->clean_temporary_directories;
|
||||
# export
|
||||
$datev->export;
|
||||
if ($datev->errors) {
|
||||
die join "\n", $datev->error;
|
||||
}
|
||||
# get relevant data for saving the export:
|
||||
my $dl_token = $datev->download_token;
|
||||
my $path = $datev->export_path;
|
||||
my @files = $datev->filenames;
|
||||
# retrieving an export at a later time
|
||||
my $datev = SL::DATEV->new(
|
||||
download_token => $dl_token_from_user,
|
||||
);
|
||||
my $path = $datev->export_path;
|
||||
my @files = glob("$path/*");
|
||||
=head1 DESCRIPTION
|
||||
This module implements the DATEV export standard. For usage see above.
|
||||
=head1 FUNCTIONS
|
||||
=over 4
|
||||
=item new PARAMS
|
||||
Generic constructor. See section attributes for information about hat to pass.
|
||||
=item get_datev_stamm
|
||||
Loads DATEV Stammdaten and returns as hashref.
|
||||
=item save_datev_stamm HASHREF
|
||||
Saves DATEV Stammdaten from provided hashref.
|
||||
=item exporttype
|
||||
See L<CONSTANTS> for possible values
|
||||
=item has_exporttype
|
||||
Returns true if an exporttype has been set. Without exporttype most report functions won't work.
|
||||
=item format
|
||||
Specifies the designated format of the export. Currently only KNE export is implemented.
|
||||
See L<CONSTANTS> for possible values
|
||||
=item has_format
|
||||
Returns true if a format has been set. Without format most report functions won't work.
|
||||
=item download_token
|
||||
Returns a download token for this DATEV object.
|
||||
Note: If either a download_token or export_path were set at the creation these are infered, otherwise randomly generated.
|
||||
=item export_path
|
||||
Returns an export_path for this DATEV object.
|
||||
Note: If either a download_token or export_path were set at the creation these are infered, otherwise randomly generated.
|
||||
=item filenames
|
||||
Returns a list of filenames generated by this DATEV object. This only works if th files were generated during it's lifetime, not if the object was created from a download_token.
|
||||
=item net_gross_differences
|
||||
If there were any net gross differences during calculation they will be collected here.
|
||||
=item sum_net_gross_differences
|
||||
Sum of all differences.
|
||||
=item clean_temporary_directories
|
||||
Forces a garbage collection on previous exports which will delete all exports that are older than 8 hours. It will be automatically called on destruction of the object, but is advised to be called manually before delivering results of an export to the user.
|
||||
=item errors
|
||||
Returns a list of errors that occured. If no errors occured, the export was a success.
|
||||
=item export
|
||||
Exports data. You have to have set L<exporttype> and L<format> or an error will
|
||||
occur. OBE exports are currently not implemented.
|
||||
=back
|
||||
=head1 ATTRIBUTES
|
||||
This is a list of attributes set in either the C<new> or a method of the same name.
|
||||
=over 4
|
||||
=item dbh
|
||||
Set a database handle to use in the process. This allows for an export to be
|
||||
done on a transaction in progress without committing first.
|
||||
=item exporttype
|
||||
See L<CONSTANTS> for possible values. This MUST be set before export is called.
|
||||
=item format
|
||||
See L<CONSTANTS> for possible values. This MUST be set before export is called.
|
||||
=item download_token
|
||||
Can be set on creation to retrieve a prior export for download.
|
||||
=item from
|
||||
=item to
|
||||
Set boundary dates for the export. Currently thse MUST be set for the export to work.
|
||||
=item accnofrom
|
||||
=item accnoto
|
||||
Set boundary account numbers for the export. Only useful for a stammdaten export.
|
||||
=back
|
||||
=head1 CONSTANTS
|
||||
=head2 Supplied to L<exporttype>
|
||||
=over 4
|
||||
=item DATEV_ET_BUCHUNGEN
|
||||
=item DATEV_ET_STAMM
|
||||
=back
|
||||
=head2 Supplied to L<format>.
|
||||
=over 4
|
||||
=item DATEV_FORMAT_KNE
|
||||
=item DATEV_FORMAT_OBE
|
||||
=back
|
||||
=head1 ERROR HANDLING
|
||||
This module will die in the following cases:
|
||||
=over 4
|
||||
=item *
|
||||
No or unrecognized exporttype or format was provided for an export
|
||||
=item *
|
||||
OBE rxport was called, which is not yet implemented.
|
||||
=item *
|
||||
general I/O errors
|
||||
=back
|
||||
Errors that occur during th actual export will be collected in L<errors>. The following types can occur at the moment:
|
||||
=over 4
|
||||
=item *
|
||||
C<Unbalanced Ledger!>. Exactly that, your ledger is unbalanced. Should never occur.
|
||||
=item *
|
||||
C<Datev-Export fehlgeschlagen! Bei Transaktion %d (%f).> This error occurs if a
|
||||
transaction could not be reliably sorted out, or had rounding errors over the acceptable threshold.
|
||||
=back
|
||||
=head1 BUGS AND CAVEATS
|
||||
=over 4
|
||||
=item *
|
||||
Handling of Vollvorlauf is currently not fully implemented. You must provide both from and to to get a working export.
|
||||
=item *
|
||||
OBE export is currently not implemented.
|
||||
=back
|
||||
=head1 TODO
|
||||
- handling of export_path and download token is a bit dodgy, clean that up.
|
||||
=head1 SEE ALSO
|
||||
L<SL::DATEV::KNEFile>
|
||||
=head1 AUTHORS
|
||||
Philip Reetz E<lt>p.reetz@linet-services.deE<gt>,
|
||||
Moritz Bunkus E<lt>m.bunkus@linet-services.deE<gt>,
|
||||
Jan Büren E<lt>jan@lx-office-hosting.deE<gt>,
|
||||
Geoffrey Richardson E<lt>information@lx-office-hosting.deE<gt>,
|
||||
Sven Schöling E<lt>s.schoeling@linet-services.deE<gt>,
|
||||
Stephan Köhler
|
||||
=cut
|