Testando a inserção de imagens
\r\nTeste Comentario Limpo
", - "sys_created_by": "SOTHIS.CAOA", - "element": "comments" - }, - { - "sys_id": "41d58e96fb107290ef1ffe316eefdc6a", - "sys_created_on": "2025-10-02 12:47:53", - "element_id": "493386721b2c9a90c5e163923b4bcb4a", - "value": "<p>fiz tudo, olha a prova ai:<br><br><a href=\"/front/document.send.php?docid=82185&itemtype=Ticket&items_id=33776\" target=\"_blank\" ><img alt=\"cb4c1e7e-ba446868-68d4315d901ec4.10948457\" width=\"1092\" src=\"/front/document.send.php?docid=82185&itemtype=Ticket&items_id=33776\" /></a></p>", - "sys_created_by": "SOTHIS.CAOA", - "element": "comments" - }, - { - "sys_id": "4a3b14eafbd87290ef1ffe316eefdcc1", - "sys_created_on": "2025-10-02 23:40:35", - "element_id": "493386721b2c9a90c5e163923b4bcb4a", - "value": "{id=47145, content=<p>NOVO</p>\r\n<p><br><br>TESTE<br><br></p>\r\n<p> </p>\r\n<p> </p>\r\n<p>PARA <br><br><br><br><br>VERIFICAR</p>\r\n<p> </p>\r\n<p>HTML<br><br><br>NO </p>\r\n<p> </p>\r\n<p> </p>\r\n<p>COMENTARIO<br><br><br></p>\r\n<p>Testando parágrafo</p>\r\n<p><strong>Testando negrito (B)</strong></p>\r\n<p><em><strong>Testando Italico (I)</strong></em></p>\r\n<blockquote>\r\n<p><em><strong>Testando Blockquote</strong></em></p>\r\n<p> </p>\r\n<div>Testando DIV</div>\r\n<div> </div>\r\n<div style=\"text-align: justify;\">Testando alinhamento</div>\r\n</blockquote>\r\n<p><br><br><br></p>, date=2025-10-02T23:40:13.000Z, date_creation=2025-10-02T23:40:13.000Z, date_mod=2025-10-02T23:40:13.000Z}", - "sys_created_by": "SOTHIS.CAOA", - "element": "comments" - }, - { - "sys_id": "4b71142efb94fe1023e5f8d65eefdca6", - "sys_created_on": "2025-10-02 22:58:01", - "element_id": "493386721b2c9a90c5e163923b4bcb4a", - "value": "{id=47139, content=<p>Comentário teste, para validar funcionamento do Midware</p>, date=2025-10-02T22:44:22.000Z, date_creation=2025-10-02T22:44:22.000Z, date_mod=2025-10-02T22:44:22.000Z}", - "sys_created_by": "SOTHIS.CAOA", - "element": "comments" - }, - { - "sys_id": "5070ca12fb107290ef1ffe316eefdc28", - "sys_created_on": "2025-10-02 12:24:19", - "element_id": "493386721b2c9a90c5e163923b4bcb4a", - "value": "Teste fora do código", - "sys_created_by": "SOTHIS.CAOA", - "element": "comments" - }, - { - "sys_id": "598c5caafbd4fe1023e5f8d65eefdc43", - "sys_created_on": "2025-10-02 23:46:15", - "element_id": "493386721b2c9a90c5e163923b4bcb4a", - "value": "Vai ter como sim, podemos ver
", - "sys_created_by": "SOTHIS.CAOA", - "element": "comments" - }, - { - "sys_id": "5cb8e9cefb187e1023e5f8d65eefdcb0", - "sys_created_on": "2025-10-01 16:02:05", - "element_id": "493386721b2c9a90c5e163923b4bcb4a", - "value": "<p>fiz tudo, olha a prova ai:<br><br><a href=\"/front/document.send.php?docid=82185&itemtype=Ticket&items_id=33776\" target=\"_blank\" ><img alt=\"cb4c1e7e-ba446868-68d4315d901ec4.10948457\" width=\"1092\" src=\"/front/document.send.php?docid=82185&itemtype=Ticket&items_id=33776\" /></a></p>", - "sys_created_by": "SOTHIS.CAOA", - "element": "comments" - }, - { - "sys_id": "5f16ce5afb1cbe1023e5f8d65eefdcea", - "sys_created_on": "2025-10-02 12:49:07", - "element_id": "493386721b2c9a90c5e163923b4bcb4a", - "value": "<p>Vai ter como sim, podemos ver</p>", - "sys_created_by": "SOTHIS.CAOA", - "element": "comments" - }, - { - "sys_id": "6716829afb1cbe1023e5f8d65eefdc5e", - "sys_created_on": "2025-10-02 12:49:08", - "element_id": "493386721b2c9a90c5e163923b4bcb4a", - "value": "<p>fiz tudo, olha a prova ai:<br><br><a href=\"/front/document.send.php?docid=82185&itemtype=Ticket&items_id=33776\" target=\"_blank\" ><img alt=\"cb4c1e7e-ba446868-68d4315d901ec4.10948457\" width=\"1092\" src=\"/front/document.send.php?docid=82185&itemtype=Ticket&items_id=33776\" /></a></p>", - "sys_created_by": "SOTHIS.CAOA", - "element": "comments" - }, - { - "sys_id": "724825cefb187e1023e5f8d65eefdcd3", - "sys_created_on": "2025-10-01 16:00:20", - "element_id": "493386721b2c9a90c5e163923b4bcb4a", - "value": "<p>Vai ter como sim, podemos ver</p>", - "sys_created_by": "SOTHIS.CAOA", - "element": "comments" - }, - { - "sys_id": "75e3d242fbdcfe50ef1ffe316eefdc6c", - "sys_created_on": "2025-10-01 19:10:53", - "element_id": "493386721b2c9a90c5e163923b4bcb4a", - "value": "<p>fiz tudo, olha a prova ai:<br><br><a href=\"/front/document.send.php?docid=82185&itemtype=Ticket&items_id=33776\" target=\"_blank\" ><img alt=\"cb4c1e7e-ba446868-68d4315d901ec4.10948457\" width=\"1092\" src=\"/front/document.send.php?docid=82185&itemtype=Ticket&items_id=33776\" /></a></p>", - "sys_created_by": "SOTHIS.CAOA", - "element": "comments" - }, - { - "sys_id": "798c1c2efbd87290ef1ffe316eefdc3b", - "sys_created_on": "2025-10-02 23:46:17", - "element_id": "493386721b2c9a90c5e163923b4bcb4a", - "value": "Mais um teste para remoção de html no comentario.
\r\nTestando parágrafo
\r\nTestando negrito (B)
\r\nTestando Italico (I)
\r\n\r\n", - "sys_created_by": "SOTHIS.CAOA", - "element": "comments" - }, - { - "sys_id": "7bdd542efbd4fe1023e5f8d65eefdc5d", - "sys_created_on": "2025-10-02 23:52:09", - "element_id": "493386721b2c9a90c5e163923b4bcb4a", - "value": "Comentatradic\n\nzcx\n\nadsgvsdbf\n\nteste\n\nv\n\nszxc\n\na\n\na\n\na\n\na\n\na\n\na\n\na\n\na\n\nTestando parágrafo\n\n**Testando negrito (B)**\n\n***Testando Italico (I)***\n\n> \r\n***Testando Blockquote***\n\nTestando DIV\n\nTestando alinhamento", - "sys_created_by": "SOTHIS.CAOA", - "element": "comments" - }, - { - "sys_id": "8568ad8efbd8fe50ef1ffe316eefdc7b", - "sys_created_on": "2025-10-01 16:00:46", - "element_id": "493386721b2c9a90c5e163923b4bcb4a", - "value": "<p>Vai ter como sim, podemos ver</p>", - "sys_created_by": "SOTHIS.CAOA", - "element": "comments" - }, - { - "sys_id": "952e98aefbd87290ef1ffe316eefdc69", - "sys_created_on": "2025-10-02 23:53:22", - "element_id": "493386721b2c9a90c5e163923b4bcb4a", - "value": "COMENTARIO TESTE\n\nTESTE\n\nCOMENTARIO TESTE\n\nTESTE COM IMAGEM:\n\nTestando a inserção de imagens\n\nTestando parágrafo\n\n**Testando negrito (B)**\n\n***Testando Italico (I)***\n\n> \r\n***Testando Blockquote***\n\nTestando DIV\n\nTestando alinhamento", - "sys_created_by": "SOTHIS.CAOA", - "element": "comments" - }, - { - "sys_id": "9599546afbd87290ef1ffe316eefdcf8", - "sys_created_on": "2025-10-02 23:33:25", - "element_id": "493386721b2c9a90c5e163923b4bcb4a", - "value": "{id=47142, content=<div class=\"rich_text_container\">\r\n<p>Mais um teste para remoção de html no comentario. </p>\r\n<p>Testando parágrafo</p>\r\n<p><strong>Testando negrito (B)</strong></p>\r\n<p><em><strong>Testando Italico (I)</strong></em></p>\r\n<blockquote>\r\n<p><em><strong>Testando Blockquote</strong></em></p>\r\n<p> </p>\r\n<div>Testando DIV</div>\r\n<div> </div>\r\n<div style=\"text-align: justify;\">Testando alinhamento</div>\r\n</blockquote>\r\n</div>, date=2025-10-02T23:33:11.000Z, date_creation=2025-10-02T23:33:11.000Z, date_mod=2025-10-02T23:33:11.000Z}", - "sys_created_by": "SOTHIS.CAOA", - "element": "comments" - }, - { - "sys_id": "9b4786dafb1cbe1023e5f8d65eefdc04", - "sys_created_on": "2025-10-02 12:54:19", - "element_id": "493386721b2c9a90c5e163923b4bcb4a", - "value": "02/10/2025 09:54:18 - SOTHIS CAOA (Comentários adicionais)\n02/10/2025 09:54:18 - SOTHIS CAOA (Comentários adicionais)\n<p>Vai ter como sim, podemos ver</p>\n\n\n\n", - "sys_created_by": "admin.caoa", - "element": "comments" - }, - { - "sys_id": "9f4786dafb1cbe1023e5f8d65eefdca2", - "sys_created_on": "2025-10-02 12:54:18", - "element_id": "493386721b2c9a90c5e163923b4bcb4a", - "value": "<p>Vai ter como sim, podemos ver</p>", - "sys_created_by": "SOTHIS.CAOA", - "element": "comments" - }, - { - "sys_id": "a25dd582fbd8fe50ef1ffe316eefdce8", - "sys_created_on": "2025-10-01 15:12:33", - "element_id": "493386721b2c9a90c5e163923b4bcb4a", - "value": "<p>fiz tudo, olha a prova ai:<br><br><a href=\"/front/document.send.php?docid=82185&itemtype=Ticket&items_id=33776\" target=\"_blank\" ><img alt=\"cb4c1e7e-ba446868-68d4315d901ec4.10948457\" width=\"1092\" src=\"/front/document.send.php?docid=82185&itemtype=Ticket&items_id=33776\" /></a></p>", - "sys_created_by": "SOTHIS.CAOA", - "element": "comments" - }, - { - "sys_id": "a98c1c2efbd87290ef1ffe316eefdc11", - "sys_created_on": "2025-10-02 23:46:17", - "element_id": "493386721b2c9a90c5e163923b4bcb4a", - "value": "Testando Blockquote
\r\n\r\n
Testando DIV\r\n\r\nTestando alinhamento\r\n
Comentário teste, para validar funcionamento do Midware
", - "sys_created_by": "SOTHIS.CAOA", - "element": "comments" - }, - { - "sys_id": "ab47c25afb107290ef1ffe316eefdcc3", - "sys_created_on": "2025-10-02 12:54:19", - "element_id": "493386721b2c9a90c5e163923b4bcb4a", - "value": "<p>fiz tudo, olha a prova ai:<br><br><a href=\"/front/document.send.php?docid=82185&itemtype=Ticket&items_id=33776\" target=\"_blank\" ><img alt=\"cb4c1e7e-ba446868-68d4315d901ec4.10948457\" width=\"1092\" src=\"/front/document.send.php?docid=82185&itemtype=Ticket&items_id=33776\" /></a></p>", - "sys_created_by": "SOTHIS.CAOA", - "element": "comments" - }, - { - "sys_id": "ad2c3146fb987e1023e5f8d65eefdc72", - "sys_created_on": "2025-10-01 17:27:05", - "element_id": "493386721b2c9a90c5e163923b4bcb4a", - "value": "<p>Vai ter como sim, podemos ver</p>", - "sys_created_by": "SOTHIS.CAOA", - "element": "comments" - }, - { - "sys_id": "ad8c5caafbd4fe1023e5f8d65eefdc62", - "sys_created_on": "2025-10-02 23:46:16", - "element_id": "493386721b2c9a90c5e163923b4bcb4a", - "value": "fiz tudo, olha a prova ai:
Mais um teste para remoção de html no comentario.
\r\nTestando parágrafo
\r\nTestando negrito (B)
\r\nTestando Italico (I)
\r\n\r\n\r\nTestando Blockquote
\r\n\r\n
Testando DIV\r\n\r\nTestando alinhamento\r\n
NOVO
\r\n
TESTE
\r\n
\r\n
PARA
VERIFICAR
\r\n
HTML
NO
\r\n
\r\n
COMENTARIO
Testando parágrafo
\r\nTestando negrito (B)
\r\nTestando Italico (I)
\r\n\r\n\r\nTestando Blockquote
\r\n\r\n
Testando DIV\r\n\r\nTestando alinhamento\r\n
Comentatradic
\r\n\r\n
\r\n
zcx
\r\nadsgvsdbf
\r\n\r\n
\r\n
\r\n
\r\n
teste
\r\n\r\n
v
\r\nszxc
\r\na
\r\na
\r\na
\r\na
\r\na
\r\na
\r\na
\r\na
\r\nTestando parágrafo
\r\nTestando negrito (B)
\r\nTestando Italico (I)
\r\n\r\n", - "sys_created_by": "SOTHIS.CAOA", - "element": "comments" - }, - { - "sys_id": "fae25202fbdcfe50ef1ffe316eefdc2c", - "sys_created_on": "2025-10-01 19:06:34", - "element_id": "493386721b2c9a90c5e163923b4bcb4a", - "value": "<p>Vai ter como sim, podemos ver</p>", - "sys_created_by": "SOTHIS.CAOA", - "element": "comments" - }, - { - "sys_id": "fde3decefbd87e1023e5f8d65eefdcc8", - "sys_created_on": "2025-10-01 19:10:51", - "element_id": "493386721b2c9a90c5e163923b4bcb4a", - "value": "<p>Vai ter como sim, podemos ver</p>", - "sys_created_by": "SOTHIS.CAOA", - "element": "comments" - } -] \ No newline at end of file diff --git a/src/scripts/python/update_location_mapping.py b/src/scripts/python/update_location_mapping.py index 8e77156..d58afc4 100644 --- a/src/scripts/python/update_location_mapping.py +++ b/src/scripts/python/update_location_mapping.py @@ -1,38 +1,53 @@ -# scripts/update_location_mapping.py -import csv +#!/usr/bin/env python3 +import os +import time +import logging import psycopg2 import mysql.connector from mysql.connector import Error -import logging -from datetime import datetime -import os -from dotenv import load_dotenv import pandas as pd -from datetime import timedelta - -# Carrega as variáveis do .env +from datetime import datetime, timedelta +from dotenv import load_dotenv from pathlib import Path -# Detecta ambiente -env = os.getenv('NODE_ENV', 'development') -env_file = f".env.{env}" +# =========================== +# 🔧 Configuração do Ambiente +# =========================== -# Caminho absoluto (mesma pasta do script ou raiz do projeto) -env_path = Path(__file__).resolve().parent.parent / env_file +env = os.getenv('NODE_ENV', 'production') +env_file = f".env.{env}" +env_path = Path(__file__).resolve().parents[2] / env_file load_dotenv(dotenv_path=env_path) -print(f"🌎 Ambiente carregado: {env}") -# Configuração de logging +print(f"🌎 Ambiente carregado: {env} ({env_path})") + +# =========================== +# 🪵 Configuração de Logs +# =========================== + +LOG_DIR = Path(__file__).resolve().parents[3] / "logs" / "location" +ERROR_DIR = Path(__file__).resolve().parents[3] / "logs" / "error" + +LOG_DIR.mkdir(parents=True, exist_ok=True) +ERROR_DIR.mkdir(parents=True, exist_ok=True) + +log_file = LOG_DIR / f"location_{datetime.now().strftime('%Y-%m-%d')}.log" +error_file = ERROR_DIR / f"location_error_{datetime.now().strftime('%Y-%m-%d')}.log" + logging.basicConfig( level=logging.INFO, - format='%(asctime)s - %(levelname)s - %(message)s', + format="%(asctime)s - %(levelname)s - %(message)s", handlers=[ - logging.FileHandler('location_mapping.log'), - logging.StreamHandler() + logging.FileHandler(log_file, encoding="utf-8"), + logging.StreamHandler(), + logging.FileHandler(error_file, encoding="utf-8") ] ) -# Configurações de banco de dados a partir do .env +# =========================== +# 💾 Configurações dos Bancos +# =========================== + SNGLPI_DB_CONFIG = { 'host': os.getenv('SNGLPI_DB_HOST'), 'port': os.getenv('SNGLPI_DB_PORT'), @@ -50,44 +65,43 @@ GLPI_DB_CONFIG = { 'charset': os.getenv('GLPI_DB_CHARSET', 'utf8mb4') } -# Caminho para o arquivo CSV CSV_PATH = os.getenv('LOCATION_MAPPING_CSV_PATH') -# Função para verificar se o CSV foi modificado recentemente +# =========================== +# 🔍 Funções auxiliares +# =========================== + def csv_recently_modified(minutes=2): + """Verifica se o CSV foi alterado recentemente.""" if not os.path.exists(CSV_PATH): logging.error(f"Arquivo CSV não encontrado: {CSV_PATH}") return False last_mod_time = datetime.fromtimestamp(os.path.getmtime(CSV_PATH)) if datetime.now() - last_mod_time <= timedelta(minutes=minutes): - logging.info(f"CSV modificado recentemente ({last_mod_time}), rodando atualização.") + logging.info(f"CSV modificado recentemente ({last_mod_time})") return True else: - logging.info(f"CSV não foi modificado nos últimos {minutes} minutos (última modificação: {last_mod_time}).") + logging.debug(f"CSV não foi modificado nos últimos {minutes} minutos.") return False - -# Função para conectar ao banco SNGLPI def get_snglpi_connection(): try: - conn = psycopg2.connect(**SNGLPI_DB_CONFIG) - return conn + return psycopg2.connect(**SNGLPI_DB_CONFIG) except Exception as e: logging.error(f"Erro ao conectar ao banco SNGLPI: {e}") return None -# Função para conectar ao banco GLPI + def get_glpi_connection(): try: - conn = mysql.connector.connect(**GLPI_DB_CONFIG) - return conn + return mysql.connector.connect(**GLPI_DB_CONFIG) except Error as e: logging.error(f"Erro ao conectar ao banco GLPI: {e}") return None -# Função para buscar location_id no SNGLPI + def find_sn_location_id(location_name, cursor): try: query = """ @@ -100,10 +114,10 @@ def find_sn_location_id(location_name, cursor): result = cursor.fetchone() return result[0] if result else None except Exception as e: - logging.error(f"Erro ao buscar location_id para {location_name}: {e}") + logging.error(f"Erro ao buscar location_id ({location_name}): {e}") return None -# Função para buscar entity_id no GLPI + def find_glpi_entity_id(entity_name, cursor): try: query = """ @@ -116,64 +130,45 @@ def find_glpi_entity_id(entity_name, cursor): result = cursor.fetchone() return result[0] if result else None except Exception as e: - logging.error(f"Erro ao buscar entity_id para {entity_name}: {e}") + logging.error(f"Erro ao buscar entity_id ({entity_name}): {e}") return None -# Função principal para atualizar a tabela de mapeamento + def update_mapping_table(): + """Atualiza a tabela de mapeamento a partir do CSV.""" try: - # Verificar se o arquivo CSV existe if not os.path.exists(CSV_PATH): logging.error(f"Arquivo CSV não encontrado: {CSV_PATH}") return False - - # Conectar aos bancos + snglpi_conn = get_snglpi_connection() glpi_conn = get_glpi_connection() - + if not snglpi_conn or not glpi_conn: return False - + snglpi_cur = snglpi_conn.cursor() glpi_cur = glpi_conn.cursor() - - # Ler CSV + df = pd.read_csv(CSV_PATH, encoding='latin-1', sep=';') - print(df.head()) - print(df.columns) - print(df) - # Adicionar colunas para IDs df['sn_location_id'] = None df['glpi_entity_id'] = None - - # Processar cada linha do CSV mappings = [] - for index, row in df.iterrows(): - sn_location_name = row['sn_location_name'] - glpi_entity_name = row['glpi_entity_name'] - - # Buscar IDs - sn_id = find_sn_location_id(sn_location_name, snglpi_cur) - glpi_id = find_glpi_entity_id(glpi_entity_name, glpi_cur) - - # Preencher o DataFrame - df.loc[index, 'sn_location_id'] = sn_id - df.loc[index, 'glpi_entity_id'] = glpi_id - + for _, row in df.iterrows(): + sn_name = row['sn_location_name'] + glpi_name = row['glpi_entity_name'] + + sn_id = find_sn_location_id(sn_name, snglpi_cur) + glpi_id = find_glpi_entity_id(glpi_name, glpi_cur) + if glpi_id: - # Se o glpi_entity_id for encontrado, adiciona para inserção - mappings.append((sn_id, sn_location_name, glpi_id, glpi_entity_name)) - logging.debug(f"Mapeamento: {sn_location_name} -> {glpi_entity_name} (ID: {glpi_id})") + mappings.append((sn_id, sn_name, glpi_id, glpi_name)) else: - logging.warning(f"Não foi possível encontrar entity_id para: {glpi_entity_name}") - - # Atualizar tabela de mapeamento + logging.warning(f"Entity não encontrada: {glpi_name}") + if mappings: - # Limpar tabela existente snglpi_cur.execute("DELETE FROM location_mapping") - - # Inserir novos mapeamentos insert_query = """ INSERT INTO location_mapping (sn_location_id, sn_location_name, glpi_entity_id, glpi_entity_name) @@ -181,31 +176,39 @@ def update_mapping_table(): """ snglpi_cur.executemany(insert_query, mappings) snglpi_conn.commit() - - logging.info(f"Tabela atualizada com {len(mappings)} mapeamentos") + logging.info(f"Tabela atualizada com {len(mappings)} registros.") else: - logging.warning("Nenhum mapeamento válido encontrado para atualização") - - # Fechar conexões + logging.warning("Nenhum mapeamento válido encontrado.") + snglpi_cur.close() glpi_cur.close() snglpi_conn.close() glpi_conn.close() - + return True - + except Exception as e: logging.error(f"Erro no processo de atualização: {e}") - # Rollback em caso de erro if 'snglpi_conn' in locals(): snglpi_conn.rollback() return False + +# =========================== +# 🔁 Loop Contínuo +# =========================== + if __name__ == "__main__": - logging.info("Iniciando atualização de mapeamento de localizações") - if csv_recently_modified(minutes=2): - success = update_mapping_table() - if success: - logging.info("Atualização concluída com sucesso") - else: - logging.error("Falha na atualização") \ No newline at end of file + logging.info("🚀 Iniciando monitoramento contínuo do Location Mapping") + while True: + try: + if csv_recently_modified(minutes=2): + success = update_mapping_table() + if success: + logging.info("✅ Atualização concluída com sucesso.") + else: + logging.error("❌ Falha na atualização.") + time.sleep(60) + except Exception as e: + logging.error(f"Erro inesperado no loop principal: {e}") + time.sleep(60)Testando Blockquote
\r\n\r\n
Testando DIV\r\n\r\nTestando alinhamento\r\n