This commit is contained in:
2025-03-08 14:37:10 -03:00
parent 3ca163a0b4
commit fc7f7b24e9

View File

@@ -24,9 +24,9 @@ def processar_Classificao_Veranicos():
for file in files: for file in files:
print(f"Encontrada pasta: {file}") print(f"Encontrada pasta: {file}")
qtd_veranicos,cod_estacao = carregar_estacao_com_veranico(file) qtd_veranicos,estacao = carregar_estacao_com_veranico(file)
print(cod_estacao) print(estacao)
rodar_decendio(decendio,qtd_veranicos, cod_estacao, file) rodar_decendio(decendio,qtd_veranicos, estacao, file)
@@ -69,9 +69,13 @@ def diferenca_dias(data1, data2):
def rodar_decendio(decendios,qtd_veranicos, estacoes, file): def rodar_decendio(decendios,qtd_veranicos, estacoes, file):
print("Decendio...")
destino= "42veranicosclassificacao"
if not os.path.exists(destino):
os.makedirs(destino)
#estacoes= [2143011] #estacoes= [2143011]
estacoes= [2142009] estacoes= [2142009]
#decendios = decendios.head(24) #decendios = decendios.head(24)
@@ -100,12 +104,12 @@ def rodar_decendio(decendios,qtd_veranicos, estacoes, file):
diferenca=diferenca_dias(data_inicio, data_fim)+1 diferenca=diferenca_dias(data_inicio, data_fim)+1
quantidade_veranicos = len(filtro) # Conta o número de linhas quantidade_veranicos = len(filtro) # Conta o número de linhas
print(index,"- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -") #print(index,"- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -")
print ('estacao: ',selecao_estacao , ' Qtd Dias: ', diferenca) #print ('estacao: ',selecao_estacao , ' Qtd Dias: ', diferenca)
if quantidade_veranicos <=0: if quantidade_veranicos <=0:
print(f"Tem algum problema registros ({quantidade_veranicos} linhas).") print(f"Tem algum problema registros ({quantidade_veranicos} linhas).")
elif quantidade_veranicos <= 1: elif quantidade_veranicos <= 1:
print(f"Tem mais de 1 registros ({quantidade_veranicos} linhas).") #print(f"Tem mais de 1 registros ({quantidade_veranicos} linhas).")
filtro.loc[filtro.index[0], 'dias_chuva'] = diferenca_dias(data_inicio, data_fim)+1 filtro.loc[filtro.index[0], 'dias_chuva'] = diferenca_dias(data_inicio, data_fim)+1
filtro.loc[filtro.index[0], 'dias_decendio'] =diferenca_dias(filtro.iloc[0]['INICIO'], filtro.iloc[0]['FINAL'])+1 filtro.loc[filtro.index[0], 'dias_decendio'] =diferenca_dias(filtro.iloc[0]['INICIO'], filtro.iloc[0]['FINAL'])+1
@@ -115,7 +119,7 @@ def rodar_decendio(decendios,qtd_veranicos, estacoes, file):
elif quantidade_veranicos <= 2: elif quantidade_veranicos <= 2:
print(f"Tem mais de 2 registros ({quantidade_veranicos} linhas).") #print(f"Tem mais de 2 registros ({quantidade_veranicos} linhas).")
filtro.loc[filtro.index[0], 'dias_chuva'] = diferenca_dias(data_inicio, filtro.iloc[0]['FINAL'])+1 filtro.loc[filtro.index[0], 'dias_chuva'] = diferenca_dias(data_inicio, filtro.iloc[0]['FINAL'])+1
filtro.loc[filtro.index[1], 'dias_chuva'] = diferenca_dias(filtro.iloc[1]['INICIO'], data_fim)+1 filtro.loc[filtro.index[1], 'dias_chuva'] = diferenca_dias(filtro.iloc[1]['INICIO'], data_fim)+1
filtro.loc[filtro.index[0], 'dias_decendio'] =diferenca_dias(filtro.iloc[0]['INICIO'], filtro.iloc[0]['FINAL'])+1 filtro.loc[filtro.index[0], 'dias_decendio'] =diferenca_dias(filtro.iloc[0]['INICIO'], filtro.iloc[0]['FINAL'])+1
@@ -128,7 +132,7 @@ def rodar_decendio(decendios,qtd_veranicos, estacoes, file):
elif quantidade_veranicos <= 3: elif quantidade_veranicos <= 3:
print(f"Tem mais de 3 registros ({quantidade_veranicos} linhas).") #print(f"Tem mais de 3 registros ({quantidade_veranicos} linhas).")
filtro.loc[filtro.index[0], 'dias_chuva'] = diferenca_dias(data_inicio, filtro.iloc[0]['FINAL'])+1 filtro.loc[filtro.index[0], 'dias_chuva'] = diferenca_dias(data_inicio, filtro.iloc[0]['FINAL'])+1
filtro.loc[filtro.index[1], 'dias_chuva'] = diferenca_dias(filtro.iloc[1]['INICIO'], filtro.iloc[1]['FINAL']) +1 filtro.loc[filtro.index[1], 'dias_chuva'] = diferenca_dias(filtro.iloc[1]['INICIO'], filtro.iloc[1]['FINAL']) +1
filtro.loc[filtro.index[2], 'dias_chuva'] = diferenca_dias(filtro.iloc[2]['INICIO'], data_fim)+1 filtro.loc[filtro.index[2], 'dias_chuva'] = diferenca_dias(filtro.iloc[2]['INICIO'], data_fim)+1
@@ -159,7 +163,7 @@ def rodar_decendio(decendios,qtd_veranicos, estacoes, file):
elif quantidade_veranicos <= 4: elif quantidade_veranicos <= 4:
print(f"Tem mais de 4 registros ({quantidade_veranicos} linhas).") #print(f"Tem mais de 4 registros ({quantidade_veranicos} linhas).")
filtro.loc[filtro.index[0], 'dias_chuva'] = diferenca_dias(data_inicio, filtro.iloc[0]['FINAL']) filtro.loc[filtro.index[0], 'dias_chuva'] = diferenca_dias(data_inicio, filtro.iloc[0]['FINAL'])
filtro.loc[filtro.index[1], 'dias_chuva'] = diferenca_dias(filtro.iloc[1]['INICIO'], filtro.iloc[1]['FINAL']) filtro.loc[filtro.index[1], 'dias_chuva'] = diferenca_dias(filtro.iloc[1]['INICIO'], filtro.iloc[1]['FINAL'])
filtro.loc[filtro.index[2], 'dias_chuva'] = diferenca_dias(filtro.iloc[2]['INICIO'], filtro.iloc[2]['FINAL']) filtro.loc[filtro.index[2], 'dias_chuva'] = diferenca_dias(filtro.iloc[2]['INICIO'], filtro.iloc[2]['FINAL'])
@@ -174,7 +178,7 @@ def rodar_decendio(decendios,qtd_veranicos, estacoes, file):
df_sorted = filtro.sort_values(by="diferenca") df_sorted = filtro.sort_values(by="diferenca")
filtro = df_sorted.iloc[:3] filtro = df_sorted.iloc[:3]
print(filtro) #print(filtro)
dados = [] dados = []
# print('->', selecao_estacao) # print('->', selecao_estacao)
for index, row in filtro.iterrows(): for index, row in filtro.iterrows():
@@ -185,17 +189,12 @@ def rodar_decendio(decendios,qtd_veranicos, estacoes, file):
'AMPLITUDE': row['amplitude'], 'AMPLITUDE': row['amplitude'],
'ANO': pd.to_datetime(row['INICIO']).year, 'ANO': pd.to_datetime(row['INICIO']).year,
}) })
print('************************************************************') #print('************************************************************')
resultados.append(pd.DataFrame(dados)) resultados.append(pd.DataFrame(dados))
destino= "42veranicosclassificacao"
if not os.path.exists(destino):
os.makedirs(destino)
print(f"Pasta '{destino}' criada.")
file= f"./{destino}/descendio_"+file file= f"./{destino}/descendio_"+file
if os.path.exists(file): os.remove(file) if os.path.exists(file): os.remove(file)
pd.concat(resultados, ignore_index=True).to_csv(file, sep=';', encoding='utf-8', index=False) pd.concat(resultados, ignore_index=True).to_csv(file, sep=';', encoding='utf-8', index=False)