This commit is contained in:
daniel.rodrigues 2025-11-04 15:00:47 -03:00
parent 2f5265e186
commit edcf44cd15

View File

@ -20,7 +20,7 @@ COLUNAS_BANCO = [
'ESTOQUE ATUAL', 'ESTOQUE EM TRANSITO', 'PEDIDO PENDENTE', 'ESTOQUE ATUAL', 'ESTOQUE EM TRANSITO', 'PEDIDO PENDENTE',
'COBERTURA ALVO', 'ESTOQUE DE SEGURANCA', 'DDV PREVISTO', 'COBERTURA ALVO', 'ESTOQUE DE SEGURANCA', 'DDV PREVISTO',
'COBERTURA ATUAL', 'COBERTURA ATUAL + TRANSITO', 'COBERTURA ATUAL', 'COBERTURA ATUAL + TRANSITO',
'COBERTURA PROJETADA', 'ORIGEM', 'loja_id' 'COBERTURA PROJETADA', 'ORIGEM'
] ]
# Headers comuns para as requisições # Headers comuns para as requisições
@ -354,9 +354,6 @@ def unificar_arquivo(caminho_arquivo):
if coluna not in df_unificado.columns: if coluna not in df_unificado.columns:
df_unificado[coluna] = None df_unificado[coluna] = None
# Define loja_id como igual ao PDV
df_unificado['loja_id'] = df_unificado['PDV']
# Reordena as colunas na ordem correta do banco # Reordena as colunas na ordem correta do banco
df_unificado = df_unificado[COLUNAS_BANCO] df_unificado = df_unificado[COLUNAS_BANCO]
@ -419,7 +416,7 @@ def enviar_para_banco(conn, df, data_estoque):
if pd.isna(valor) or valor == '-': if pd.isna(valor) or valor == '-':
valores.append(None) valores.append(None)
elif coluna in ['SKU', 'PDV', 'loja_id']: elif coluna in ['SKU', 'PDV']:
valores.append(str(int(float(valor)))[:50]) valores.append(str(int(float(valor)))[:50])
elif coluna in ['LANCAMENTO', 'DESATIVACAO']: elif coluna in ['LANCAMENTO', 'DESATIVACAO']:
valores.append(formatar_data(valor)) valores.append(formatar_data(valor))
@ -446,8 +443,8 @@ def enviar_para_banco(conn, df, data_estoque):
[ESTOQUE ATUAL], [ESTOQUE EM TRANSITO], [PEDIDO PENDENTE], [ESTOQUE ATUAL], [ESTOQUE EM TRANSITO], [PEDIDO PENDENTE],
[COBERTURA ALVO], [ESTOQUE DE SEGURANCA], [DDV PREVISTO], [COBERTURA ALVO], [ESTOQUE DE SEGURANCA], [DDV PREVISTO],
[COBERTURA ATUAL], [COBERTURA ATUAL + TRANSITO], [COBERTURA ATUAL], [COBERTURA ATUAL + TRANSITO],
[COBERTURA PROJETADA], [ORIGEM], [loja_id], [data_estoque] [COBERTURA PROJETADA], [ORIGEM], [data_estoque]
) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?) ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
""", valores) """, valores)
linhas_processadas += 1 linhas_processadas += 1