349 lines
9.8 KiB
Python
349 lines
9.8 KiB
Python
# coding: utf-8
|
|
"""
|
|
Provide a report and downloadable CSV according to the German DATEV format.
|
|
|
|
- Query report showing only the columns that contain data, formatted nicely for
|
|
dispay to the user.
|
|
- CSV download functionality `download_datev_csv` that provides a CSV file with
|
|
all required columns. Used to import the data into the DATEV Software.
|
|
"""
|
|
from __future__ import unicode_literals
|
|
|
|
import json
|
|
import six
|
|
import frappe
|
|
from frappe import _
|
|
from six import string_types
|
|
from erpnext.regional.germany.utils.datev.datev_csv import download_csv_files_as_zip, get_datev_csv
|
|
from erpnext.regional.germany.utils.datev.datev_constants import Transactions, DebtorsCreditors, AccountNames
|
|
|
|
COLUMNS = [
|
|
{
|
|
"label": "Umsatz (ohne Soll/Haben-Kz)",
|
|
"fieldname": "Umsatz (ohne Soll/Haben-Kz)",
|
|
"fieldtype": "Currency",
|
|
"width": 100
|
|
},
|
|
{
|
|
"label": "Soll/Haben-Kennzeichen",
|
|
"fieldname": "Soll/Haben-Kennzeichen",
|
|
"fieldtype": "Data",
|
|
"width": 100
|
|
},
|
|
{
|
|
"label": "Konto",
|
|
"fieldname": "Konto",
|
|
"fieldtype": "Data",
|
|
"width": 100
|
|
},
|
|
{
|
|
"label": "Gegenkonto (ohne BU-Schlüssel)",
|
|
"fieldname": "Gegenkonto (ohne BU-Schlüssel)",
|
|
"fieldtype": "Data",
|
|
"width": 100
|
|
},
|
|
{
|
|
"label": "Belegdatum",
|
|
"fieldname": "Belegdatum",
|
|
"fieldtype": "Date",
|
|
"width": 100
|
|
},
|
|
{
|
|
"label": "Belegfeld 1",
|
|
"fieldname": "Belegfeld 1",
|
|
"fieldtype": "Data",
|
|
"width": 150
|
|
},
|
|
{
|
|
"label": "Buchungstext",
|
|
"fieldname": "Buchungstext",
|
|
"fieldtype": "Text",
|
|
"width": 300
|
|
},
|
|
{
|
|
"label": "Beleginfo - Art 1",
|
|
"fieldname": "Beleginfo - Art 1",
|
|
"fieldtype": "Link",
|
|
"options": "DocType",
|
|
"width": 100
|
|
},
|
|
{
|
|
"label": "Beleginfo - Inhalt 1",
|
|
"fieldname": "Beleginfo - Inhalt 1",
|
|
"fieldtype": "Dynamic Link",
|
|
"options": "Beleginfo - Art 1",
|
|
"width": 150
|
|
},
|
|
{
|
|
"label": "Beleginfo - Art 2",
|
|
"fieldname": "Beleginfo - Art 2",
|
|
"fieldtype": "Link",
|
|
"options": "DocType",
|
|
"width": 100
|
|
},
|
|
{
|
|
"label": "Beleginfo - Inhalt 2",
|
|
"fieldname": "Beleginfo - Inhalt 2",
|
|
"fieldtype": "Dynamic Link",
|
|
"options": "Beleginfo - Art 2",
|
|
"width": 150
|
|
}
|
|
]
|
|
|
|
|
|
def execute(filters=None):
|
|
"""Entry point for frappe."""
|
|
validate(filters)
|
|
return COLUMNS, get_transactions(filters, as_dict=0)
|
|
|
|
|
|
def validate(filters):
|
|
"""Make sure all mandatory filters and settings are present."""
|
|
if not filters.get('company'):
|
|
frappe.throw(_('<b>Company</b> is a mandatory filter.'))
|
|
|
|
if not filters.get('from_date'):
|
|
frappe.throw(_('<b>From Date</b> is a mandatory filter.'))
|
|
|
|
if not filters.get('to_date'):
|
|
frappe.throw(_('<b>To Date</b> is a mandatory filter.'))
|
|
|
|
try:
|
|
frappe.get_doc('DATEV Settings', filters.get('company'))
|
|
except frappe.DoesNotExistError:
|
|
frappe.throw(_('Please create <b>DATEV Settings</b> for Company <b>{}</b>.').format(filters.get('company')))
|
|
|
|
|
|
def get_transactions(filters, as_dict=1):
|
|
"""
|
|
Get a list of accounting entries.
|
|
|
|
Select GL Entries joined with Account and Party Account in order to get the
|
|
account numbers. Returns a list of accounting entries.
|
|
|
|
Arguments:
|
|
filters -- dict of filters to be passed to the sql query
|
|
as_dict -- return as list of dicts [0,1]
|
|
"""
|
|
filter_by_voucher = 'AND gl.voucher_type = %(voucher_type)s' if filters.get('voucher_type') else ''
|
|
gl_entries = frappe.db.sql("""
|
|
SELECT
|
|
|
|
/* either debit or credit amount; always positive */
|
|
case gl.debit when 0 then gl.credit else gl.debit end as 'Umsatz (ohne Soll/Haben-Kz)',
|
|
|
|
/* 'H' when credit, 'S' when debit */
|
|
case gl.debit when 0 then 'H' else 'S' end as 'Soll/Haben-Kennzeichen',
|
|
|
|
/* account number or, if empty, party account number */
|
|
coalesce(acc.account_number, acc_pa.account_number) as 'Konto',
|
|
|
|
/* against number or, if empty, party against number */
|
|
coalesce(acc_against.account_number, acc_against_pa.account_number) as 'Gegenkonto (ohne BU-Schlüssel)',
|
|
|
|
gl.posting_date as 'Belegdatum',
|
|
gl.voucher_no as 'Belegfeld 1',
|
|
LEFT(gl.remarks, 60) as 'Buchungstext',
|
|
gl.voucher_type as 'Beleginfo - Art 1',
|
|
gl.voucher_no as 'Beleginfo - Inhalt 1',
|
|
gl.against_voucher_type as 'Beleginfo - Art 2',
|
|
gl.against_voucher as 'Beleginfo - Inhalt 2'
|
|
|
|
FROM `tabGL Entry` gl
|
|
|
|
/* Statistisches Konto (Debitoren/Kreditoren) */
|
|
left join `tabParty Account` pa
|
|
on gl.against = pa.parent
|
|
and gl.company = pa.company
|
|
|
|
/* Kontonummer */
|
|
left join `tabAccount` acc
|
|
on gl.account = acc.name
|
|
|
|
/* Gegenkonto-Nummer */
|
|
left join `tabAccount` acc_against
|
|
on gl.against = acc_against.name
|
|
|
|
/* Statistische Kontonummer */
|
|
left join `tabAccount` acc_pa
|
|
on pa.account = acc_pa.name
|
|
|
|
/* Statistische Gegenkonto-Nummer */
|
|
left join `tabAccount` acc_against_pa
|
|
on pa.account = acc_against_pa.name
|
|
|
|
WHERE gl.company = %(company)s
|
|
AND DATE(gl.posting_date) >= %(from_date)s
|
|
AND DATE(gl.posting_date) <= %(to_date)s
|
|
{}
|
|
ORDER BY 'Belegdatum', gl.voucher_no""".format(filter_by_voucher), filters, as_dict=as_dict)
|
|
|
|
return gl_entries
|
|
|
|
|
|
def get_customers(filters):
|
|
"""
|
|
Get a list of Customers.
|
|
|
|
Arguments:
|
|
filters -- dict of filters to be passed to the sql query
|
|
"""
|
|
return frappe.db.sql("""
|
|
SELECT
|
|
|
|
acc.account_number as 'Konto',
|
|
CASE cus.customer_type WHEN 'Company' THEN cus.customer_name ELSE null END as 'Name (Adressatentyp Unternehmen)',
|
|
CASE cus.customer_type WHEN 'Individual' THEN con.last_name ELSE null END as 'Name (Adressatentyp natürl. Person)',
|
|
CASE cus.customer_type WHEN 'Individual' THEN con.first_name ELSE null END as 'Vorname (Adressatentyp natürl. Person)',
|
|
CASE cus.customer_type WHEN 'Individual' THEN '1' WHEN 'Company' THEN '2' ELSE '0' end as 'Adressatentyp',
|
|
adr.address_line1 as 'Straße',
|
|
adr.pincode as 'Postleitzahl',
|
|
adr.city as 'Ort',
|
|
UPPER(country.code) as 'Land',
|
|
adr.address_line2 as 'Adresszusatz',
|
|
con.email_id as 'E-Mail',
|
|
coalesce(con.mobile_no, con.phone) as 'Telefon',
|
|
cus.website as 'Internet',
|
|
cus.tax_id as 'Steuernummer'
|
|
|
|
FROM `tabParty Account` par
|
|
|
|
left join `tabAccount` acc
|
|
on acc.name = par.account
|
|
|
|
left join `tabCustomer` cus
|
|
on cus.name = par.parent
|
|
|
|
left join `tabAddress` adr
|
|
on adr.name = cus.customer_primary_address
|
|
|
|
left join `tabCountry` country
|
|
on country.name = adr.country
|
|
|
|
left join `tabContact` con
|
|
on con.name = cus.customer_primary_contact
|
|
|
|
WHERE par.company = %(company)s
|
|
AND par.parenttype = 'Customer'""", filters, as_dict=1)
|
|
|
|
|
|
def get_suppliers(filters):
|
|
"""
|
|
Get a list of Suppliers.
|
|
|
|
Arguments:
|
|
filters -- dict of filters to be passed to the sql query
|
|
"""
|
|
return frappe.db.sql("""
|
|
SELECT
|
|
|
|
acc.account_number as 'Konto',
|
|
CASE sup.supplier_type WHEN 'Company' THEN sup.supplier_name ELSE null END as 'Name (Adressatentyp Unternehmen)',
|
|
CASE sup.supplier_type WHEN 'Individual' THEN con.last_name ELSE null END as 'Name (Adressatentyp natürl. Person)',
|
|
CASE sup.supplier_type WHEN 'Individual' THEN con.first_name ELSE null END as 'Vorname (Adressatentyp natürl. Person)',
|
|
CASE sup.supplier_type WHEN 'Individual' THEN '1' WHEN 'Company' THEN '2' ELSE '0' end as 'Adressatentyp',
|
|
adr.address_line1 as 'Straße',
|
|
adr.pincode as 'Postleitzahl',
|
|
adr.city as 'Ort',
|
|
UPPER(country.code) as 'Land',
|
|
adr.address_line2 as 'Adresszusatz',
|
|
con.email_id as 'E-Mail',
|
|
coalesce(con.mobile_no, con.phone) as 'Telefon',
|
|
sup.website as 'Internet',
|
|
sup.tax_id as 'Steuernummer',
|
|
case sup.on_hold when 1 then sup.release_date else null end as 'Zahlungssperre bis'
|
|
|
|
FROM `tabParty Account` par
|
|
|
|
left join `tabAccount` acc
|
|
on acc.name = par.account
|
|
|
|
left join `tabSupplier` sup
|
|
on sup.name = par.parent
|
|
|
|
left join `tabDynamic Link` dyn_adr
|
|
on dyn_adr.link_name = sup.name
|
|
and dyn_adr.link_doctype = 'Supplier'
|
|
and dyn_adr.parenttype = 'Address'
|
|
|
|
left join `tabAddress` adr
|
|
on adr.name = dyn_adr.parent
|
|
and adr.is_primary_address = '1'
|
|
|
|
left join `tabCountry` country
|
|
on country.name = adr.country
|
|
|
|
left join `tabDynamic Link` dyn_con
|
|
on dyn_con.link_name = sup.name
|
|
and dyn_con.link_doctype = 'Supplier'
|
|
and dyn_con.parenttype = 'Contact'
|
|
|
|
left join `tabContact` con
|
|
on con.name = dyn_con.parent
|
|
and con.is_primary_contact = '1'
|
|
|
|
WHERE par.company = %(company)s
|
|
AND par.parenttype = 'Supplier'""", filters, as_dict=1)
|
|
|
|
|
|
def get_account_names(filters):
|
|
return frappe.db.sql("""
|
|
SELECT
|
|
|
|
account_number as 'Konto',
|
|
LEFT(account_name, 40) as 'Kontenbeschriftung',
|
|
'de-DE' as 'Sprach-ID'
|
|
|
|
FROM `tabAccount`
|
|
WHERE company = %(company)s
|
|
AND is_group = 0
|
|
AND account_number != ''
|
|
""", filters, as_dict=1)
|
|
|
|
|
|
@frappe.whitelist()
|
|
def download_datev_csv(filters):
|
|
"""
|
|
Provide accounting entries for download in DATEV format.
|
|
|
|
Validate the filters, get the data, produce the CSV file and provide it for
|
|
download. Can be called like this:
|
|
|
|
GET /api/method/erpnext.regional.report.datev.datev.download_datev_csv
|
|
|
|
Arguments / Params:
|
|
filters -- dict of filters to be passed to the sql query
|
|
"""
|
|
if isinstance(filters, string_types):
|
|
filters = json.loads(filters)
|
|
|
|
validate(filters)
|
|
|
|
# set chart of accounts used
|
|
coa = frappe.get_value('Company', filters.get('company'), 'chart_of_accounts')
|
|
filters['skr'] = '04' if 'SKR04' in coa else ('03' if 'SKR03' in coa else '')
|
|
|
|
transactions = get_transactions(filters)
|
|
account_names = get_account_names(filters)
|
|
customers = get_customers(filters)
|
|
suppliers = get_suppliers(filters)
|
|
|
|
download_csv_files_as_zip([
|
|
{
|
|
'file_name': 'EXTF_Buchungsstapel.csv',
|
|
'csv_data': get_datev_csv(transactions, filters, csv_class=Transactions)
|
|
},
|
|
{
|
|
'file_name': 'EXTF_Kontenbeschriftungen.csv',
|
|
'csv_data': get_datev_csv(account_names, filters, csv_class=AccountNames)
|
|
},
|
|
{
|
|
'file_name': 'EXTF_Kunden.csv',
|
|
'csv_data': get_datev_csv(customers, filters, csv_class=DebtorsCreditors)
|
|
},
|
|
{
|
|
'file_name': 'EXTF_Lieferanten.csv',
|
|
'csv_data': get_datev_csv(suppliers, filters, csv_class=DebtorsCreditors)
|
|
},
|
|
])
|