diff --git a/app/db/sql_sentences.py b/app/db/sql_sentences.py index 2a68b76..a41dcb7 100644 --- a/app/db/sql_sentences.py +++ b/app/db/sql_sentences.py @@ -2,9 +2,9 @@ # MYSQL (constantes) # ========================= -SELECT_INVOICES_DELETED = ( +SELECT_PROFORMAS_DELETED = ( "SELECT ci.id " - "FROM customer_invoices as ci " + "FROM proformas as ci " "WHERE " "(ci.deleted_at is not null) " ) @@ -179,13 +179,13 @@ LIMPIAR_FACTUGES_LINK = ( # OPCION A SACAMOS EL RESUMEN DE LA TAXES DE LA CABECERA consulta_sql_customer_invoices_issue = ( - "SELECT ci.id, ci.series, ci.invoice_number, ci.invoice_date, ci.description, ci.customer_tin, ci.customer_name, ci.total_amount_value, ci.total_amount_scale, ci.reference, " + "SELECT ci.id, ci.invoice_series_code as series, ci.invoice_number, ci.invoice_date, ci.description, ci.customer_tin, ci.customer_name, ci.total_amount_value, ci.total_amount_scale, ci.reference, " "cit.taxable_amount_scale, cit.taxes_amount_scale, cit.iva_code, cit.taxable_amount_value, cit.taxes_amount_value, " "vr.id as vrId, vr.uuid, vr.estado " - "FROM customer_invoices as ci " - "LEFT JOIN customer_invoice_taxes cit on (ci.id = cit.invoice_id) " - "LEFT JOIN verifactu_records vr on (ci.id = vr.invoice_id) " - "WHERE (ci.is_proforma = 0) AND (ci.status= 'issued') " + "FROM issued_invoices as ci " + "LEFT JOIN issued_invoice_taxes cit on (ci.id = cit.issued_invoice_id) " + "LEFT JOIN verifactu_records vr on (ci.id = vr.issued_invoice_id) " + "WHERE (ci.status= 'issued') " "AND (company_id = %s) " "AND (vr.estado <> 'Correcto') " "order by reference" @@ -206,7 +206,7 @@ update_verifactu_records_with_invoiceId = ("UPDATE verifactu_records " "url = %s, " "qr = %s, " "updated_at = CURRENT_TIMESTAMP " - "WHERE invoice_id = %s" + "WHERE issued_invoice_id = %s" ) update_verifactu_records_with_uuid = ("UPDATE verifactu_records " diff --git a/app/db/sync_invoices_deleted_factuges.py b/app/db/sync_invoices_deleted_factuges.py index cc11162..5ba7e3e 100644 --- a/app/db/sync_invoices_deleted_factuges.py +++ b/app/db/sync_invoices_deleted_factuges.py @@ -13,7 +13,7 @@ def sync_invoices_deleted_factuges(conn_factuges, conn_mysql, last_execution_dat cursor_mysql = None try: cursor_mysql = conn_mysql.cursor() - cursor_mysql.execute(SQL.SELECT_INVOICES_DELETED) + cursor_mysql.execute(SQL.SELECT_PROFORMAS_DELETED) filas = cursor_mysql.fetchall() cursor_mysql.close() diff --git a/setup.cfg b/setup.cfg index 26b2fb8..38ed8d1 100644 --- a/setup.cfg +++ b/setup.cfg @@ -1,6 +1,6 @@ [metadata] name = factuges-sync -version = 0.2.1 +version = 0.3.0 description = ETL job to sync data from legacy DB to MariaDB author = Rodax Software author_email = info@rodax-software.com