no generar factures duplicades

app/models.py

@@ -6,7 +6,6 @@ import requests
 from pandas import DataFrame
 import json
 import time
-import aiohttp
 
 from .database import Base
 
@@ -48,7 +47,7 @@ class ApiUser(Base):
 def get_invoice_oc(con, id_billing_run, group_code):
 
     stm_group_code = "" if group_code is None else " and ocg.code='"+group_code+"' "
-
+    # factures a generar mirant que no estiguin ja generades.
     statement = """
         select oi.description_cat, oi.code
          , round(sum(oi.amount_without_tax),2) as preu
@@ -63,7 +62,17 @@ def get_invoice_oc(con, id_billing_run, group_code):
         where 1=1 
         and id_billing_run='""" + id_billing_run + "' " + \
                 stm_group_code + \
-        """group by oi.description_cat, oi.code, oi.tax_percent , oi.billing_run_uuid, ocg.code
+        """
+        and not exists 
+        (
+        select *
+        from odoo_account_invoice ai 
+            join odoo_contract_group cg on ai.contract_group_id =cg.id
+        where ocg.code = cg.code
+            and ai.billing_run_id = oi.id_billing_run::varchar
+            and ai.state<>'cancel'
+        )
+        group by oi.description_cat, oi.code, oi.tax_percent , oi.billing_run_uuid, ocg.code
             , oi.tax_code, oi.billing_account_code
         having sum(oi.amount_without_tax)<>0"""
 
@@ -83,8 +92,6 @@ def get_invoice_oc(con, id_billing_run, group_code):
         "Content-Type": "application/json",
         "api-key": APIKEY
     }
-
-    session = aiohttp.ClientSession()
     for x in group:
         d = datetime.today()  # datetime.today().strftime('%Y-%m-%d')
         data = {
@@ -107,12 +114,11 @@ def get_invoice_oc(con, id_billing_run, group_code):
             }
             data["invoiceLines"].append(invoiceline)
         # print(data)
-        # r = requests.post(url=API_ENDPOINT, data=json.dumps(data), headers=head)
-        session.post(url=API_ENDPOINT, data=json.dumps(data), headers=head)
-    session.detach()
+        requests.post(url=API_ENDPOINT, data=json.dumps(data), headers=head)
     return 'OK' #[dict(zip(columns, t)) for t in registries]
 
 
+
 def invoice_generate_oc_pdf(con, invoice):
     qry = "insert into external.invoice_generator (id, name_invoice, status, dt_insert, dt_update) values (nextval('external.seq_invoice_generator'),'{}', 'inici', current_timestamp, current_timestamp)".format(invoice)
     con.execute(qry)