att

debit_notes_pdf_reader.py

@@ -376,6 +376,17 @@ def upsert_rows_sqlserver(rows: List[Dict[str, Any]], connection_string: str) ->
     has_cnpj_col = False
 
     try:
+        cur.execute(
+            "SELECT 1 FROM sys.columns "
+            "WHERE object_id = OBJECT_ID('dbo.TrfDocumento') AND name = 'CriadoEm'"
+        )
+        if cur.fetchone() is None:
+            cur.execute(
+                "ALTER TABLE dbo.TrfDocumento "
+                "ADD CriadoEm DATETIME2 NOT NULL DEFAULT SYSUTCDATETIME()"
+            )
+            cn.commit()
+
         cur.execute(
             """
 SELECT 1