att
This commit is contained in:
parent
c1ff360a8c
commit
2f5265e186
@ -302,33 +302,34 @@ def conectar_banco():
|
||||
|
||||
|
||||
def limpar_dados_data_atual(conn):
|
||||
"""Remove dados da tabela estoque_mar_historico para a data atual."""
|
||||
"""Remove dados da tabela estoque_mar_historico para a data do estoque (dia anterior)."""
|
||||
try:
|
||||
cursor = conn.cursor()
|
||||
data_hoje = datetime.now().strftime("%Y-%m-%d")
|
||||
# Data do estoque é sempre o dia anterior (hoje - 1 dia)
|
||||
data_estoque = (datetime.now() - timedelta(days=1)).strftime("%Y-%m-%d")
|
||||
|
||||
# Verificar se existem dados para hoje
|
||||
# Verificar se existem dados para a data do estoque
|
||||
cursor.execute(
|
||||
"SELECT COUNT(*) FROM [GINSENG].[dbo].[estoque_mar_historico] WHERE CAST([data_estoque] AS DATE) = ?",
|
||||
(data_hoje,)
|
||||
(data_estoque,)
|
||||
)
|
||||
count = cursor.fetchone()[0]
|
||||
|
||||
if count > 0:
|
||||
print(f" Encontrados {count} registros para a data {data_hoje}")
|
||||
print(f" Removendo dados existentes da data {data_hoje}...")
|
||||
print(f" Encontrados {count} registros para a data {data_estoque}")
|
||||
print(f" Removendo dados existentes da data {data_estoque}...")
|
||||
cursor.execute(
|
||||
"DELETE FROM [GINSENG].[dbo].[estoque_mar_historico] WHERE CAST([data_estoque] AS DATE) = ?",
|
||||
(data_hoje,)
|
||||
(data_estoque,)
|
||||
)
|
||||
conn.commit()
|
||||
print(f" ✓ {count} registros removidos com sucesso!")
|
||||
else:
|
||||
print(f" Nenhum registro encontrado para a data {data_hoje}")
|
||||
print(f" Nenhum registro encontrado para a data {data_estoque}")
|
||||
|
||||
return data_hoje
|
||||
return data_estoque
|
||||
except Exception as e:
|
||||
print(f" ✗ Erro ao limpar dados da data atual: {e}")
|
||||
print(f" ✗ Erro ao limpar dados da data do estoque: {e}")
|
||||
raise
|
||||
|
||||
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user