diff --git a/packages/v1/administrativo/actions/g_emolumento_periodo/g_emolumento_periodo_delete_action.py b/packages/v1/administrativo/actions/g_emolumento_periodo/g_emolumento_periodo_delete_action.py new file mode 100644 index 0000000..4c98725 --- /dev/null +++ b/packages/v1/administrativo/actions/g_emolumento_periodo/g_emolumento_periodo_delete_action.py @@ -0,0 +1,33 @@ +from abstracts.action import BaseAction +from api.packages.v1.administrativo.repositories.g_emolumento_periodo.g_emolumento_periodo_delete_repository import GEmolumentoPeriodoDeleteRepository +from api.packages.v1.administrativo.schemas.g_emolumento_periodo_schema import GEmolumentoPeriodoIdSchema + + +class GEmolumentoPeriodoDeleteAction(BaseAction): + """ + Serviço responsável por encapsular a lógica de negócio para a operação + de exclusão de um registro na tabela G_EMOLUMENTO_PERIODO. + """ + + def execute(self, g_emolumento_periodo_id_schema: GEmolumentoPeriodoIdSchema): + """ + Executa a operação de exclusão no banco de dados. + + Args: + g_emolumento_periodo_id_schema (GEmolumentoPeriodoIdSchema): + O esquema contendo o ID do registro a ser excluído. + + Returns: + O resultado da operação de exclusão. + """ + # ---------------------------------------------------- + # Instanciamento do repositório + # ---------------------------------------------------- + g_emolumento_periodo_delete_repository = GEmolumentoPeriodoDeleteRepository() + + # ---------------------------------------------------- + # Execução da exclusão + # ---------------------------------------------------- + response = g_emolumento_periodo_delete_repository.execute(g_emolumento_periodo_id_schema) + + return response diff --git a/packages/v1/administrativo/actions/g_emolumento_periodo/g_emolumento_periodo_index_action.py b/packages/v1/administrativo/actions/g_emolumento_periodo/g_emolumento_periodo_index_action.py new file mode 100644 index 0000000..e6d903c --- /dev/null +++ b/packages/v1/administrativo/actions/g_emolumento_periodo/g_emolumento_periodo_index_action.py @@ -0,0 +1,35 @@ +from abstracts.action import BaseAction +from api.packages.v1.administrativo.repositories.g_emolumento_periodo.g_emolumento_periodo_index_repository import GEmolumentoPeriodoIndexRepository + + +class GEmolumentoPeriodoIndexAction(BaseAction): + """ + Serviço responsável por encapsular a lógica de negócio para a operação + de listagem de todos os registros na tabela G_NATUREZA_TITULO. + """ + + def execute(self): + """ + Executa a operação de listagem no banco de dados. + + Args: + g_emolumento_periodo_index_schema (GEmolumentoPeriodoIndexSchema): + Esquema contendo parâmetros opcionais de filtro. + + Returns: + A lista de registros encontrados. + """ + # ---------------------------------------------------- + # Instanciamento do repositório + # ---------------------------------------------------- + g_emolumento_periodo_index_repository = GEmolumentoPeriodoIndexRepository() + + # ---------------------------------------------------- + # Execução do repositório + # ---------------------------------------------------- + response = g_emolumento_periodo_index_repository.execute() + + # ---------------------------------------------------- + # Retorno da informação + # -------------------------------- + return response diff --git a/packages/v1/administrativo/actions/g_emolumento_periodo/g_emolumento_periodo_save_action.py b/packages/v1/administrativo/actions/g_emolumento_periodo/g_emolumento_periodo_save_action.py new file mode 100644 index 0000000..f1f7475 --- /dev/null +++ b/packages/v1/administrativo/actions/g_emolumento_periodo/g_emolumento_periodo_save_action.py @@ -0,0 +1,36 @@ +from abstracts.action import BaseAction +from api.packages.v1.administrativo.repositories.g_emolumento_periodo.g_emolumento_periodo_save_repository import GEmolumentoPeriodoSaveRepository +from api.packages.v1.administrativo.schemas.g_emolumento_periodo_schema import GEmolumentoPeriodoSaveSchema + + +class GEmolumentoPeriodoSaveAction(BaseAction): + """ + Serviço responsável por encapsular a lógica de negócio para a operação + de salvamento de um novo registro na tabela G_GRAMATICA. + """ + + def execute(self, g_emolumento_periodo_save_schema: GEmolumentoPeriodoSaveSchema): + """ + Executa a operação de salvamento. + + Args: + g_emolumento_periodo_schema (GEmolumentoPeriodoSchema): + O esquema com os dados a serem persistidos. + + Returns: + O resultado da operação de salvamento. + """ + # ---------------------------------------------------- + # Instanciamento do repositório + # ---------------------------------------------------- + g_emolumento_periodo_save_repository = GEmolumentoPeriodoSaveRepository() + + # ---------------------------------------------------- + # Execução do repositório + # ---------------------------------------------------- + response = g_emolumento_periodo_save_repository.execute(g_emolumento_periodo_save_schema) + + # ---------------------------------------------------- + # Retorno da informação + # ---------------------------------------------------- + return response diff --git a/packages/v1/administrativo/actions/g_emolumento_periodo/g_emolumento_periodo_show_action.py b/packages/v1/administrativo/actions/g_emolumento_periodo/g_emolumento_periodo_show_action.py new file mode 100644 index 0000000..1ac27d4 --- /dev/null +++ b/packages/v1/administrativo/actions/g_emolumento_periodo/g_emolumento_periodo_show_action.py @@ -0,0 +1,36 @@ +from abstracts.action import BaseAction +from api.packages.v1.administrativo.repositories.g_emolumento_periodo.g_emolumento_periodo_show_repository import GEmolumentoPeriodoShowRepository +from api.packages.v1.administrativo.schemas.g_emolumento_periodo_schema import GEmolumentoPeriodoIdSchema + + +class GEmolumentoPeriodoShowAction(BaseAction): + """ + Serviço responsável por encapsular a lógica de negócio para a exibição + de um registro na tabela G_NATUREZA_TITULO. + """ + + def execute(self, g_emolumento_periodo_id_schema: GEmolumentoPeriodoIdSchema): + """ + Executa a operação de exibição. + + Args: + g_emolumento_periodo_id_schema (GEmolumentoPeriodoIdSchema): + O esquema com o ID do registro a ser exibido. + + Returns: + O resultado da operação de exibição. + """ + # ---------------------------------------------------- + # Instanciamento do repositório + # ---------------------------------------------------- + g_emolumento_periodo_show_repository = GEmolumentoPeriodoShowRepository() + + # ---------------------------------------------------- + # Execução do repositório + # ---------------------------------------------------- + response = g_emolumento_periodo_show_repository.execute(g_emolumento_periodo_id_schema) + + # ---------------------------------------------------- + # Retorno da informação + # ---------------------------------------------------- + return response diff --git a/packages/v1/administrativo/actions/g_emolumento_periodo/g_emolumento_periodo_update_action.py b/packages/v1/administrativo/actions/g_emolumento_periodo/g_emolumento_periodo_update_action.py new file mode 100644 index 0000000..8ccef9a --- /dev/null +++ b/packages/v1/administrativo/actions/g_emolumento_periodo/g_emolumento_periodo_update_action.py @@ -0,0 +1,36 @@ +from abstracts.action import BaseAction +from api.packages.v1.administrativo.repositories.g_emolumento_periodo.g_emolumento_periodo_update_repository import GEmolumentoPeriodoUpdateRepository +from api.packages.v1.administrativo.schemas.g_emolumento_periodo_schema import GEmolumentoPeriodoUpdateSchema + + +class GEmolumentoPeriodoUpdateAction(BaseAction): + """ + Serviço responsável por encapsular a lógica de negócio para a atualização + de um registro na tabela G_NATUREZA_TITULO. + """ + + def execute(self, g_emolumento_periodo_update_schema: GEmolumentoPeriodoUpdateSchema): + """ + Executa a operação de atualização. + + Args: + g_emolumento_periodo_update_schema (GEmolumentoPeriodoUpdateSchema): + O esquema com os dados a serem atualizados. + + Returns: + O resultado da operação de atualização. + """ + # ---------------------------------------------------- + # Instanciamento do repositório de atualização + # ---------------------------------------------------- + g_emolumento_periodo_update_repository = GEmolumentoPeriodoUpdateRepository() + + # ---------------------------------------------------- + # Execução do repositório + # ---------------------------------------------------- + response = g_emolumento_periodo_update_repository.execute(g_emolumento_periodo_update_schema) + + # ---------------------------------------------------- + # Retorno do resultado + # ---------------------------------------------------- + return response diff --git a/packages/v1/administrativo/controllers/g_emolumento_periodo_controller.py b/packages/v1/administrativo/controllers/g_emolumento_periodo_controller.py new file mode 100644 index 0000000..df352d6 --- /dev/null +++ b/packages/v1/administrativo/controllers/g_emolumento_periodo_controller.py @@ -0,0 +1,101 @@ +from actions.dynamic_import.dynamic_import import DynamicImport +from packages.v1.administrativo.schemas.g_emolumento_periodo_schema import ( + GEmolumentoPeriodoSaveSchema, + GEmolumentoPeriodoUpdateSchema, + GEmolumentoPeriodoIdSchema +) + + +class GEmolumentoPeriodoController: + """ + Controller responsável por orquestrar as operações CRUD da tabela G_EMOLUMENTO_PERIODO, + utilizando carregamento dinâmico de serviços via DynamicImport. + """ + + def __init__(self): + # ---------------------------------------------------- + # Inicialização do DynamicImport + # ---------------------------------------------------- + self.dynamic_import = DynamicImport() + self.dynamic_import.set_package("administrativo") + self.dynamic_import.set_table("g_emolumento_periodo") + + # ---------------------------------------------------- + # Lista todos os registros de G_EMOLUMENTO_PERIODO + # ---------------------------------------------------- + def index(self): + # Importação da classe desejada + index_service = self.dynamic_import.service("g_emolumento_periodo_index_service", "GEmolumentoPeriodoIndexService") + + # Instância da classe service + self.index_service = index_service() + + # Execução da listagem + return { + "message": "Registros de G_EMOLUMENTO_PERIODO localizados com sucesso.", + "data": self.index_service.execute(), + } + + # ---------------------------------------------------- + # Busca um registro específico de G_EMOLUMENTO_PERIODO pelo ID + # ---------------------------------------------------- + def show(self, g_emolumento_periodo_id_schema: GEmolumentoPeriodoIdSchema): + # Importação da classe desejada + show_service = self.dynamic_import.service("g_emolumento_periodo_show_service", "GEmolumentoPeriodoShowService") + + # Instância da classe service + self.show_service = show_service() + + # Execução da busca + return { + "message": "Registro de G_EMOLUMENTO_PERIODO localizado com sucesso.", + "data": self.show_service.execute(g_emolumento_periodo_id_schema), + } + + # ---------------------------------------------------- + # Cadastra um novo registro em G_EMOLUMENTO_PERIODO + # ---------------------------------------------------- + def save(self, g_emolumento_periodo_save_schema: GEmolumentoPeriodoSaveSchema): + # Importação da classe desejada + save_service = self.dynamic_import.service("g_emolumento_periodo_save_service", "GEmolumentoPeriodoSaveService") + + # Instância da classe service + self.save_service = save_service() + + # Execução do salvamento + return { + "message": "Registro de G_EMOLUMENTO_PERIODO salvo com sucesso.", + "data": self.save_service.execute(g_emolumento_periodo_save_schema), + } + + # ---------------------------------------------------- + # Atualiza um registro existente de G_EMOLUMENTO_PERIODO + # ---------------------------------------------------- + def update(self, g_emolumento_periodo_update_schema: GEmolumentoPeriodoUpdateSchema): + # Importação da classe desejada + update_service = self.dynamic_import.service("g_emolumento_periodo_update_service", "GEmolumentoPeriodoUpdateService") + + # Instância da classe service + self.update_service = update_service() + + # Execução da atualização + return { + "message": "Registro de G_EMOLUMENTO_PERIODO atualizado com sucesso.", + "data": self.update_service.execute(g_emolumento_periodo_update_schema), + } + + # ---------------------------------------------------- + # Exclui um registro de G_EMOLUMENTO_PERIODO + # ---------------------------------------------------- + def delete(self, g_emolumento_periodo_id_schema: GEmolumentoPeriodoIdSchema): + # Importação da classe desejada + delete_service = self.dynamic_import.service("g_emolumento_periodo_delete_service", "GEmolumentoPeriodoDeleteService") + + # Instância da classe service + self.delete_service = delete_service() + + # Execução da exclusão + return { + "message": "Registro de G_EMOLUMENTO_PERIODO removido com sucesso.", + "data": self.delete_service.execute(g_emolumento_periodo_id_schema), + } diff --git a/packages/v1/administrativo/endpoints/g_emolumento_periodo_endpoint.py b/packages/v1/administrativo/endpoints/g_emolumento_periodo_endpoint.py new file mode 100644 index 0000000..9b1f5fd --- /dev/null +++ b/packages/v1/administrativo/endpoints/g_emolumento_periodo_endpoint.py @@ -0,0 +1,94 @@ +# Importação de bibliotecas +from fastapi import APIRouter, Depends, status +from actions.jwt.get_current_user import get_current_user +from packages.v1.administrativo.controllers.g_emolumento_periodo_controller import GEmolumentoPeriodoController +from packages.v1.administrativo.schemas.g_emolumento_periodo_schema import ( + GEmolumentoPeriodoSaveSchema, + GEmolumentoPeriodoUpdateSchema, + GEmolumentoPeriodoIdSchema +) + +# ---------------------------------------------------- +# Inicializa o roteador para as rotas da tabela G_EMOLUMENTO_PERIODO +# ---------------------------------------------------- +router = APIRouter() + +# Instanciamento do controller +g_emolumento_periodo_controller = GEmolumentoPeriodoController() + +# ---------------------------------------------------- +# Lista todos os registros de G_EMOLUMENTO_PERIODO +# ---------------------------------------------------- +@router.get('/', + status_code=status.HTTP_200_OK, + summary='Lista todos os registros de G_EMOLUMENTO_PERIODO cadastrados', + response_description='Lista todos os registros de G_EMOLUMENTO_PERIODO cadastrados') +async def index(current_user: dict = Depends(get_current_user)): + """ + Retorna todos os registros da tabela G_EMOLUMENTO_PERIODO. + """ + response = g_emolumento_periodo_controller.index() + return response + + +# ---------------------------------------------------- +# Busca um registro específico de G_EMOLUMENTO_PERIODO pelo ID +# ---------------------------------------------------- +@router.get('/{emolumento_periodo_id}', + status_code=status.HTTP_200_OK, + summary='Busca um registro de G_EMOLUMENTO_PERIODO pelo ID', + response_description='Busca um registro de G_EMOLUMENTO_PERIODO em específico') +async def show(emolumento_periodo_id: int, current_user: dict = Depends(get_current_user)): + """ + Retorna um registro específico de G_EMOLUMENTO_PERIODO com base no ID informado. + """ + g_emolumento_periodo_id_schema = GEmolumentoPeriodoIdSchema(emolumento_periodo_id=emolumento_periodo_id) + response = g_emolumento_periodo_controller.show(g_emolumento_periodo_id_schema) + return response + + +# ---------------------------------------------------- +# Cadastra um novo registro em G_EMOLUMENTO_PERIODO +# ---------------------------------------------------- +@router.post('/', + status_code=status.HTTP_201_CREATED, + summary='Cadastra um novo registro em G_EMOLUMENTO_PERIODO', + response_description='Cadastra um novo registro em G_EMOLUMENTO_PERIODO') +async def save(g_emolumento_periodo_schema: GEmolumentoPeriodoSaveSchema, current_user: dict = Depends(get_current_user)): + """ + Cria um novo registro na tabela G_EMOLUMENTO_PERIODO. + """ + response = g_emolumento_periodo_controller.save(g_emolumento_periodo_schema) + return response + + +# ---------------------------------------------------- +# Atualiza um registro existente de G_EMOLUMENTO_PERIODO +# ---------------------------------------------------- +@router.put('/{emolumento_periodo_id}', + status_code=status.HTTP_200_OK, + summary='Atualiza um registro existente em G_EMOLUMENTO_PERIODO', + response_description='Atualiza um registro existente em G_EMOLUMENTO_PERIODO') +async def update(emolumento_periodo_id: int, g_emolumento_periodo_update_schema: GEmolumentoPeriodoUpdateSchema, current_user: dict = Depends(get_current_user)): + """ + Atualiza um registro existente de G_EMOLUMENTO_PERIODO com base no ID informado. + """ + g_emolumento_periodo_update_schema.emolumento_periodo_id = emolumento_periodo_id + response = g_emolumento_periodo_controller.update(g_emolumento_periodo_update_schema) + return response + + +# ---------------------------------------------------- +# Exclui um registro de G_EMOLUMENTO_PERIODO +# ---------------------------------------------------- +@router.delete('/{emolumento_periodo_id}', + status_code=status.HTTP_200_OK, + summary='Remove um registro de G_EMOLUMENTO_PERIODO', + response_description='Remove um registro de G_EMOLUMENTO_PERIODO') +async def delete(emolumento_periodo_id: int, current_user: dict = Depends(get_current_user)): + """ + Remove um registro específico de G_EMOLUMENTO_PERIODO com base no ID informado. + """ + g_emolumento_periodo_id_schema = GEmolumentoPeriodoIdSchema(emolumento_periodo_id=emolumento_periodo_id) + response = g_emolumento_periodo_controller.delete(g_emolumento_periodo_id_schema) + return response \ No newline at end of file diff --git a/packages/v1/administrativo/repositories/g_emolumento_periodo/g_emolumento_periodo_delete_repository.py b/packages/v1/administrativo/repositories/g_emolumento_periodo/g_emolumento_periodo_delete_repository.py new file mode 100644 index 0000000..7a5bc49 --- /dev/null +++ b/packages/v1/administrativo/repositories/g_emolumento_periodo/g_emolumento_periodo_delete_repository.py @@ -0,0 +1,45 @@ +from abstracts.repository import BaseRepository +from fastapi import HTTPException, status + +from api.packages.v1.administrativo.schemas.g_emolumento_periodo_schema import GEmolumentoPeriodoIdSchema + +class GEmolumentoPeriodoDeleteRepository(BaseRepository): + """ + Repositório responsável pela exclusão de registros na tabela + G_GRAMATICA. + """ + def execute(self, g_emolumento_periodo_id_schema: GEmolumentoPeriodoIdSchema): + """ + Executa a exclusão de um registro específico da tabela G_GRAMATICA + com base no ID informado. + + Args: + g_emolumento_periodo_id_schema (GEmolumentoPeriodoIdSchema): Esquema contendo o ID do registro a ser excluído. + + Returns: + O resultado da operação de exclusão. + """ + try: + # Montagem do SQL + sql = """ + DELETE FROM G_GRAMATICA GG + WHERE GG.GRAMATICA_ID = :emolumento_periodo_id + """ + + # Preenchimento dos parâmetros + params = { + "emolumento_periodo_id": g_emolumento_periodo_id_schema.emolumento_periodo_id + } + + # Execução da instrução SQL + response = self.run(sql, params) + + # Retorna o resultado da exclusão + return response + + except Exception as e: + # Lança exceção HTTP em caso de erro + raise HTTPException( + status_code=status.HTTP_422_UNPROCESSABLE_ENTITY, + detail=f"Erro ao excluir registro de G_GRAMATICA: {e}" + ) diff --git a/packages/v1/administrativo/repositories/g_emolumento_periodo/g_emolumento_periodo_index_repository.py b/packages/v1/administrativo/repositories/g_emolumento_periodo/g_emolumento_periodo_index_repository.py new file mode 100644 index 0000000..b5bf67b --- /dev/null +++ b/packages/v1/administrativo/repositories/g_emolumento_periodo/g_emolumento_periodo_index_repository.py @@ -0,0 +1,26 @@ +from abstracts.repository import BaseRepository + +class GEmolumentoPeriodoIndexRepository(BaseRepository): + """ + Repositório para a operação de listagem de todos os registros + na tabela t_censec_qualidade. + """ + + def execute(self): + """ + Executa a consulta SQL para buscar todos os registros. + + Returns: + Uma lista de dicionários contendo os dados dos registros. + """ + # Montagem do SQL + sql = """ SELECT + GEP.* + FROM G_EMOLUMENTO_PERIODO GEP + """ + + # Execução do sql + response = self.fetch_all(sql) + + # Retorna os dados localizados + return response \ No newline at end of file diff --git a/packages/v1/administrativo/repositories/g_emolumento_periodo/g_emolumento_periodo_save_repository.py b/packages/v1/administrativo/repositories/g_emolumento_periodo/g_emolumento_periodo_save_repository.py new file mode 100644 index 0000000..471f143 --- /dev/null +++ b/packages/v1/administrativo/repositories/g_emolumento_periodo/g_emolumento_periodo_save_repository.py @@ -0,0 +1,50 @@ +from fastapi import HTTPException, status +from abstracts.repository import BaseRepository +from api.actions.data.generate_insert_sql import generate_insert_sql +from api.packages.v1.administrativo.schemas.g_emolumento_periodo_schema import GEmolumentoPeriodoSaveSchema + + +class GEmolumentoPeriodoSaveRepository(BaseRepository): + """ + Repositório responsável pela operação de salvamento de um novo registro + na tabela G_EMOLUMENTO_PERIODO. + """ + + def execute(self, g_emolumento_periodo_save_schema: GEmolumentoPeriodoSaveSchema): + """ + Executa a operação de salvamento no banco de dados. + + Args: + g_emolumento_periodo_save_schema (GEmolumentoPeriodoSchema): O esquema com os dados a serem salvos. + + Returns: + O registro recém-criado. + + Raises: + HTTPException: Caso ocorra um erro na execução da query. + """ + try: + + # ---------------------------------------------------- + # Preenchimento dos parâmetros + # ---------------------------------------------------- + params = g_emolumento_periodo_save_schema.model_dump(exclude_unset=True) + + # ---------------------------------------------------- + # Montagem do SQL dinâmico + # ---------------------------------------------------- + sql = generate_insert_sql('G_EMOLUMENTO_PERIODO', params) + + # ---------------------------------------------------- + # Execução do SQL e retorno do registro + # ---------------------------------------------------- + return self.run_and_return(sql, params) + + except Exception as e: + # ---------------------------------------------------- + # Tratamento de erros e lançamento de exceção HTTP + # ---------------------------------------------------- + raise HTTPException( + status_code=status.HTTP_422_UNPROCESSABLE_ENTITY, + detail=f"Erro ao salvar registro em G_EMOLUMENTO_PERIODO: {e}" + ) \ No newline at end of file diff --git a/packages/v1/administrativo/repositories/g_emolumento_periodo/g_emolumento_periodo_show_repository.py b/packages/v1/administrativo/repositories/g_emolumento_periodo/g_emolumento_periodo_show_repository.py new file mode 100644 index 0000000..b0718b6 --- /dev/null +++ b/packages/v1/administrativo/repositories/g_emolumento_periodo/g_emolumento_periodo_show_repository.py @@ -0,0 +1,67 @@ +from abstracts.repository import BaseRepository +from fastapi import HTTPException, status + +from api.packages.v1.administrativo.schemas.g_emolumento_periodo_schema import GEmolumentoPeriodoIdSchema + + +class GEmolumentoPeriodoShowRepository(BaseRepository): + """ + Repositório responsável pela operação de exibição de um registro + na tabela G_EMOLUMENTO_PERIODO. + """ + + def execute(self, g_emolumento_periodo_id_schema: GEmolumentoPeriodoIdSchema): + """ + Busca um registro específico de G_EMOLUMENTO_PERIODO pelo ID. + + Args: + g_emolumento_periodo_id_schema (GEmolumentoPeriodoIdSchema): + Esquema contendo o ID do registro a ser buscado. + + Returns: + O registro encontrado ou levanta exceção HTTP 404 se não existir. + + Raises: + HTTPException: Caso ocorra um erro na execução da query. + """ + try: + # ---------------------------------------------------- + # Montagem do SQL + # ---------------------------------------------------- + sql = """ + SELECT * + FROM G_EMOLUMENTO_PERIODO GG + WHERE GG.EMOLUMENTO_PERIODO_ID = :emolumento_periodo_id + """ + + # ---------------------------------------------------- + # Preenchimento de parâmetros + # ---------------------------------------------------- + params = g_emolumento_periodo_id_schema.model_dump(exclude_unset=True) + + # ---------------------------------------------------- + # Execução do SQL + # ---------------------------------------------------- + result = self.fetch_one(sql, params) + + # ---------------------------------------------------- + # Validação de retorno + # ---------------------------------------------------- + if not result: + raise HTTPException( + status_code=status.HTTP_404_NOT_FOUND, + detail="Registro de G_EMOLUMENTO_PERIODO não encontrado." + ) + + return result + + except HTTPException: + # Repassa exceções HTTP explícitas (como 404) + raise + + except Exception as e: + # Captura falhas inesperadas de execução + raise HTTPException( + status_code=status.HTTP_422_UNPROCESSABLE_ENTITY, + detail=f"Erro ao buscar registro em G_EMOLUMENTO_PERIODO: {e}" + ) diff --git a/packages/v1/administrativo/repositories/g_emolumento_periodo/g_emolumento_periodo_update_repository.py b/packages/v1/administrativo/repositories/g_emolumento_periodo/g_emolumento_periodo_update_repository.py new file mode 100644 index 0000000..719a574 --- /dev/null +++ b/packages/v1/administrativo/repositories/g_emolumento_periodo/g_emolumento_periodo_update_repository.py @@ -0,0 +1,61 @@ +from abstracts.repository import BaseRepository +from api.actions.data.prepare_update_data import prepare_update_data +from fastapi import HTTPException, status + +from api.packages.v1.administrativo.schemas.g_emolumento_periodo_schema import GEmolumentoPeriodoUpdateSchema + + +class GEmolumentoPeriodoUpdateRepository(BaseRepository): + """ + Repositório responsável pela operação de atualização de registros + na tabela G_EMOLUMENTO_PERIODO. + """ + + def execute(self, g_emolumento_periodo_update_schema: GEmolumentoPeriodoUpdateSchema): + """ + Atualiza um registro existente na tabela G_EMOLUMENTO_PERIODO. + + Args: + g_emolumento_periodo_update_schema (GEmolumentoPeriodoUpdateSchema): + Esquema contendo os dados a serem atualizados. + + Returns: + O registro atualizado (via RETURNING *). + + Raises: + HTTPException: Caso ocorra um erro na execução do SQL. + """ + try: + # ---------------------------------------------------- + # Prepara parâmetros e colunas de atualização dinâmicas + # ---------------------------------------------------- + params, update_columns = prepare_update_data( + g_emolumento_periodo_update_schema, + exclude_fields=["emolumento_periodo_id"], + id_field="emolumento_periodo_id" + ) + + # ---------------------------------------------------- + # Montagem do SQL dinâmico + # ---------------------------------------------------- + sql = f""" + UPDATE G_EMOLUMENTO_PERIODO + SET {update_columns} + WHERE EMOLUMENTO_PERIODO_ID = :emolumento_periodo_id + RETURNING *; + """ + + # ---------------------------------------------------- + # Execução e retorno do registro atualizado + # ---------------------------------------------------- + response = self.run_and_return(sql, params) + return response + + except Exception as e: + # ---------------------------------------------------- + # Tratamento de exceção e retorno HTTP padronizado + # ---------------------------------------------------- + raise HTTPException( + status_code=status.HTTP_422_UNPROCESSABLE_ENTITY, + detail=f"Erro ao atualizar registro em G_EMOLUMENTO_PERIODO: {str(e)}" + ) diff --git a/packages/v1/administrativo/schemas/g_emolumento_periodo_schema.py b/packages/v1/administrativo/schemas/g_emolumento_periodo_schema.py new file mode 100644 index 0000000..3fd50e9 --- /dev/null +++ b/packages/v1/administrativo/schemas/g_emolumento_periodo_schema.py @@ -0,0 +1,51 @@ +from pydantic import BaseModel +from typing import Optional +from datetime import datetime + +# ---------------------------------------------------- +# Schema base - representa a tabela G_EMOLUMENTO_PERIODO +# ---------------------------------------------------- +class GEmolumentoPeriodoSchema(BaseModel): + emolumento_periodo_id: Optional[float] = None + descricao: Optional[str] = None + situacao: Optional[str] = None + data_inicial: Optional[datetime] = None + + class Config: + from_attributes = True + + +# ---------------------------------------------------- +# Schema para localizar um registro pelo ID (GET /{id}) +# ---------------------------------------------------- +class GEmolumentoPeriodoIdSchema(BaseModel): + emolumento_periodo_id: float + + class Config: + from_attributes = True + + +# ---------------------------------------------------- +# Schema para criação (POST) +# ---------------------------------------------------- +class GEmolumentoPeriodoSaveSchema(BaseModel): + emolumento_periodo_id: Optional[float] = None + descricao: Optional[str] = None + situacao: Optional[str] = None + data_inicial: Optional[datetime] = None + + class Config: + from_attributes = True + + +# ---------------------------------------------------- +# Schema para atualização (PUT) +# ---------------------------------------------------- +class GEmolumentoPeriodoUpdateSchema(BaseModel): + emolumento_periodo_id: Optional[float] = None + descricao: Optional[str] = None + situacao: Optional[str] = None + data_inicial: Optional[datetime] = None + + class Config: + from_attributes = True \ No newline at end of file diff --git a/packages/v1/administrativo/services/g_emolumento_periodo/go/g_emolumento_periodo_delete_service.py b/packages/v1/administrativo/services/g_emolumento_periodo/go/g_emolumento_periodo_delete_service.py new file mode 100644 index 0000000..ca8885c --- /dev/null +++ b/packages/v1/administrativo/services/g_emolumento_periodo/go/g_emolumento_periodo_delete_service.py @@ -0,0 +1,35 @@ +from api.packages.v1.administrativo.actions.g_emolumento_periodo.g_emolumento_periodo_delete_action import GEmolumentoPeriodoDeleteAction +from api.packages.v1.administrativo.schemas.g_emolumento_periodo_schema import GEmolumentoPeriodoIdSchema + + +class GEmolumentoPeriodoDeleteService: + """ + Serviço responsável por encapsular a lógica de negócio para a operação + de exclusão de um registro na tabela G_EMOLUMENTO_PERIODO. + """ + + def execute(self, g_emolumento_periodo_id_schema: GEmolumentoPeriodoIdSchema): + """ + Executa a operação de exclusão do registro no banco de dados. + + Args: + g_emolumento_periodo_id_schema (GEmolumentoPeriodoIdSchema): + O esquema com o ID do registro a ser excluído. + + Returns: + O resultado da operação de exclusão. + """ + # ---------------------------------------------------- + # Instanciamento da ação + # ---------------------------------------------------- + g_emolumento_periodo_delete_action = GEmolumentoPeriodoDeleteAction() + + # ---------------------------------------------------- + # Execução da ação + # ---------------------------------------------------- + data = g_emolumento_periodo_delete_action.execute(g_emolumento_periodo_id_schema) + + # ---------------------------------------------------- + # Retorno da informação + # ---------------------------------------------------- + return data diff --git a/packages/v1/administrativo/services/g_emolumento_periodo/go/g_emolumento_periodo_index_service.py b/packages/v1/administrativo/services/g_emolumento_periodo/go/g_emolumento_periodo_index_service.py new file mode 100644 index 0000000..db3fa81 --- /dev/null +++ b/packages/v1/administrativo/services/g_emolumento_periodo/go/g_emolumento_periodo_index_service.py @@ -0,0 +1,44 @@ +from api.packages.v1.administrativo.actions.g_emolumento_periodo.g_emolumento_periodo_index_action import GEmolumentoPeriodoIndexAction +from fastapi import HTTPException, status + + +class GEmolumentoPeriodoIndexService: + """ + Serviço responsável por encapsular a lógica de negócio para a operação + de listagem de registros na tabela G_EMOLUMENTO_PERIODO. + """ + + def execute(self): + """ + Executa a operação de busca de todos os registros no banco de dados. + + Args: + g_emolumento_periodo_index_schema (GEmolumentoPeriodoIndexSchema): + Esquema que pode conter filtros ou parâmetros de busca. + + Returns: + A lista de registros encontrados. + """ + # ---------------------------------------------------- + # Instanciamento da ação + # ---------------------------------------------------- + g_emolumento_periodo_index_action = GEmolumentoPeriodoIndexAction() + + # ---------------------------------------------------- + # Execução da ação + # ---------------------------------------------------- + data = g_emolumento_periodo_index_action.execute() + + # ---------------------------------------------------- + # Verificação de retorno + # ---------------------------------------------------- + if not data: + raise HTTPException( + status_code=status.HTTP_404_NOT_FOUND, + detail="Não foi possível localizar registros de G_EMOLUMENTO_PERIODO." + ) + + # ---------------------------------------------------- + # Retorno da informação + # ---------------------------------------------------- + return data diff --git a/packages/v1/administrativo/services/g_emolumento_periodo/go/g_emolumento_periodo_save_service.py b/packages/v1/administrativo/services/g_emolumento_periodo/go/g_emolumento_periodo_save_service.py new file mode 100644 index 0000000..e9c90a9 --- /dev/null +++ b/packages/v1/administrativo/services/g_emolumento_periodo/go/g_emolumento_periodo_save_service.py @@ -0,0 +1,44 @@ +from api.packages.v1.administrativo.actions.g_emolumento_periodo.g_emolumento_periodo_save_action import GEmolumentoPeriodoSaveAction +from api.packages.v1.sequencia.schemas.g_sequencia import GSequenciaSchema +from api.packages.v1.administrativo.schemas.g_emolumento_periodo_schema import GEmolumentoPeriodoSaveSchema +from api.packages.v1.sequencia.services.g_sequencia.generate_service import GenerateService + + +class GEmolumentoPeriodoSaveService: + """ + Serviço responsável por encapsular a lógica de negócio para a operação + de criação de registros na tabela G_EMOLUMENTO_PERIODO. + """ + + def execute(self, g_emolumento_periodo_save_schema: GEmolumentoPeriodoSaveSchema): + """ + Executa a operação de salvamento do registro no banco de dados. + + Args: + g_emolumento_periodo_save_schema (GEmolumentoPeriodoSaveSchema): + O esquema com os dados a serem salvos. + + Returns: + O registro recém-criado. + """ + + # ---------------------------------------------------- + # Geração automática de ID (sequência) + # ---------------------------------------------------- + if not g_emolumento_periodo_save_schema.emolumento_periodo_id: + # Cria o schema de sequência + sequencia_schema = GSequenciaSchema() + sequencia_schema.tabela = "G_EMOLUMENTO_PERIODO" + + # Gera a sequência atualizada + generate = GenerateService() + sequencia = generate.execute(sequencia_schema) + + # Atualiza o ID no schema + g_emolumento_periodo_save_schema.emolumento_periodo_id = sequencia.sequencia + + # ---------------------------------------------------- + # Instanciamento e execução da Action de salvamento + # ---------------------------------------------------- + g_emolumento_periodo_save_action = GEmolumentoPeriodoSaveAction() + return g_emolumento_periodo_save_action.execute(g_emolumento_periodo_save_schema) diff --git a/packages/v1/administrativo/services/g_emolumento_periodo/go/g_emolumento_periodo_show_service.py b/packages/v1/administrativo/services/g_emolumento_periodo/go/g_emolumento_periodo_show_service.py new file mode 100644 index 0000000..ed0e06a --- /dev/null +++ b/packages/v1/administrativo/services/g_emolumento_periodo/go/g_emolumento_periodo_show_service.py @@ -0,0 +1,45 @@ +from api.packages.v1.administrativo.actions.g_emolumento_periodo.g_emolumento_periodo_show_action import GEmolumentoPeriodoShowAction +from api.packages.v1.administrativo.schemas.g_emolumento_periodo_schema import GEmolumentoPeriodoIdSchema +from fastapi import HTTPException, status + + +class GEmolumentoPeriodoShowService: + """ + Serviço responsável por encapsular a lógica de negócio para a operação + de busca de um registro na tabela G_EMOLUMENTO_PERIODO. + """ + + def execute(self, g_emolumento_periodo_id_schema: GEmolumentoPeriodoIdSchema): + """ + Executa a operação de busca no banco de dados. + + Args: + g_emolumento_periodo_id_schema (GEmolumentoPeriodoIdSchema): + O esquema com o ID do registro a ser buscado. + + Returns: + O resultado da busca. + """ + # ---------------------------------------------------- + # Instanciamento da ação + # ---------------------------------------------------- + g_emolumento_periodo_show_action = GEmolumentoPeriodoShowAction() + + # ---------------------------------------------------- + # Execução da ação + # ---------------------------------------------------- + data = g_emolumento_periodo_show_action.execute(g_emolumento_periodo_id_schema) + + # ---------------------------------------------------- + # Verificação de resultado + # ---------------------------------------------------- + if not data: + raise HTTPException( + status_code=status.HTTP_404_NOT_FOUND, + detail="Não foi possível localizar o registro de G_EMOLUMENTO_PERIODO." + ) + + # ---------------------------------------------------- + # Retorno da informação + # ---------------------------------------------------- + return data diff --git a/packages/v1/administrativo/services/g_emolumento_periodo/go/g_emolumento_periodo_update_service.py b/packages/v1/administrativo/services/g_emolumento_periodo/go/g_emolumento_periodo_update_service.py new file mode 100644 index 0000000..75b53dd --- /dev/null +++ b/packages/v1/administrativo/services/g_emolumento_periodo/go/g_emolumento_periodo_update_service.py @@ -0,0 +1,30 @@ +from api.packages.v1.administrativo.actions.g_emolumento_periodo.g_emolumento_periodo_update_action import GEmolumentoPeriodoUpdateAction +from api.packages.v1.administrativo.schemas.g_emolumento_periodo_schema import GEmolumentoPeriodoUpdateSchema + + +class GEmolumentoPeriodoUpdateService: + """ + Serviço responsável pela operação de atualização de um registro + na tabela G_EMOLUMENTO_PERIODO. + """ + + def execute(self, g_emolumento_periodo_update_schema: GEmolumentoPeriodoUpdateSchema): + """ + Executa a operação de atualização no banco de dados. + + Args: + g_emolumento_periodo_update_schema (GEmolumentoPeriodoUpdateSchema): + O esquema com os dados a serem atualizados. + + Returns: + O resultado da operação de atualização. + """ + # ---------------------------------------------------- + # Instanciamento da ação + # ---------------------------------------------------- + g_emolumento_periodo_update_action = GEmolumentoPeriodoUpdateAction() + + # ---------------------------------------------------- + # Execução da ação e retorno do resultado + # ---------------------------------------------------- + return g_emolumento_periodo_update_action.execute(g_emolumento_periodo_update_schema) diff --git a/packages/v1/api.py b/packages/v1/api.py index 3df4980..6b2e406 100644 --- a/packages/v1/api.py +++ b/packages/v1/api.py @@ -2,7 +2,7 @@ from fastapi import APIRouter # Importa os módulos de rotas específicos -from api.packages.v1.administrativo.endpoints import g_cartorio_endpoint, g_gramatica_endpoint, g_natureza_titulo_endpoint, t_ato_partetipo_endpoint, t_censec_tiponatureza_endpoint +from api.packages.v1.administrativo.endpoints import g_cartorio_endpoint, g_emolumento_periodo_endpoint, g_gramatica_endpoint, g_natureza_titulo_endpoint, t_ato_partetipo_endpoint, t_censec_tiponatureza_endpoint from packages.v1.administrativo.endpoints import t_censec_tipoato_endpoint from packages.v1.administrativo.endpoints import t_censec_qualidadeato_endpoint from packages.v1.administrativo.endpoints import g_tb_txmodelogrupo_endpoint @@ -214,4 +214,9 @@ api_router.include_router( # Inclui as rotas de g_cartorio api_router.include_router( g_cartorio_endpoint.router, prefix="/administrativo/g_cartorio", tags=["Dados do Cartório"] +) + +# Inclui as rotas de g_cartorio +api_router.include_router( + g_emolumento_periodo_endpoint.router, prefix="/administrativo/g_emolumento_periodo", tags=["Periodos de Emolumentos"] ) \ No newline at end of file