OriusTecnologia/saas_api
6
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

[MVPTN-126] fix(Dev): Ajusta os locais de importação de arquivos

Browse source
This commit is contained in:
Keven 2025-11-06 17:31:49 -03:00
parent 125c654439
commit 0339cffc21
224 changed files with 2163 additions and 1186 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
actions/dynamic_import/dynamic_import.py
View file

@ -3,7 +3,6 @@ from actions.config.config import Config
from typing import Optional, Any, Type
class DynamicImport:
def __init__(self) -> None:
@ -18,7 +17,7 @@ class DynamicImport:
def set_table(self, table: str):
self.table = table
def service(self, name: str, class_name : str) -> Type[Any]:
def service(self, name: str, class_name: str) -> Type[Any]:
try:
# Define o nome do Módulo
module_file = f"{name}"

47
main.py
View file

@ -1,13 +1,17 @@
# Ajuste para garantir que o diretório base do projeto seja incluído no PYTHONPATH
import os
import platform
import sys
# Adiciona o diretório atual (onde está o main.py) ao sys.path
sys.path.insert(0, os.path.abspath(os.path.join(os.path.dirname(__file__), '..')))
sys.path.insert(0, os.path.abspath(os.path.join(os.path.dirname(__file__), "..")))
from firebird.driver import driver_config
# Importa a classe principal do FastAPI
from fastapi import FastAPI, Request
from pathlib import Path
# Importa o middleware de CORS
from fastapi.middleware.cors import CORSMiddleware
from fastapi.responses import Response
@ -15,18 +19,27 @@ from starlette.middleware.base import BaseHTTPMiddleware
# Importa o roteador principal da API versão 1
from packages.v1.api import api_router
from packages.v1.system.service.startup_check_service import \
StartupCheckService
from packages.v1.system.service.startup_check_service import StartupCheckService
# Importa as configurações globais da aplicação
from actions.log.log import Log
from actions.config.config import Config
from actions.system.handlers import register_exception_handlers
config = Config.get('app.json')
if platform.system() == "Windows":
# Ajuste o caminho abaixo para onde o Firebird está instalado:
FB_DIR = r"C:\Program Files\Firebird\Firebird_4_0"
os.add_dll_directory(FB_DIR)
driver_config.fb_client_library.value = (
r"C:\Program Files\Firebird\Firebird_4_0\fbclient.dll"
)
config = Config.get("app.json")
# Instancia o app FastAPI com um título personalizado
app = FastAPI(title='SAAS Orius')
app = FastAPI(title="SAAS Orius")
# Controle de erros personalizados
register_exception_handlers(app)
@ -40,6 +53,7 @@ app.add_middleware(
allow_headers=["*"],
)
@app.on_event("startup")
async def on_startup():
@ -49,20 +63,21 @@ async def on_startup():
# Exibe o amarzenamento do servidor
print(startupCheckService.execute())
@app.middleware("http")
async def log_tempo_requisicao(request: Request, call_next):
# Ação responsavel por registrar o log de requisição
# Ação responsavel por registrar o log de requisição
log = Log()
config = Config.get('app.json')
config = Config.get("app.json")
# Obtem os dados da requisição
log_data = {
"method": request.method,
"url": str(request.url),
"headers": dict(request.headers)
"headers": dict(request.headers),
}
# Gera o nome do arquivo
file = Path(config.log.request.path) / config.log.request.name
@ -74,16 +89,18 @@ async def log_tempo_requisicao(request: Request, call_next):
return response
# Inclui as rotas da versão 1 da API com prefixo definido em settings (ex: /api/v1)
app.include_router(api_router, prefix=config.url)
# Executa o servidor com Uvicorn se este arquivo for executado diretamente
if __name__ == '__main__':
if __name__ == "__main__":
import uvicorn
uvicorn.run(
"main:app", # Caminho do app para execução
host="0.0.0.0", # Disponibiliza a aplicação externamente
port=8000, # Porta padrão
log_level='info', # Define o nível de log para desenvolvimento
reload=True # Ativa auto-reload durante desenvolvimento
"main:app", # Caminho do app para execução
host="0.0.0.0", # Disponibiliza a aplicação externamente
port=8000, # Porta padrão
log_level="info", # Define o nível de log para desenvolvimento
reload=True, # Ativa auto-reload durante desenvolvimento
)

8
packages/v1/administrativo/actions/g_cartorio/g_cartorio_delete_action.py
View file

@ -1,6 +1,8 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.g_cartorio.g_cartorio_delete_repository import GCartorioDeleteRepository
from api.packages.v1.administrativo.schemas.g_cartorio_schema import GCartorioIdSchema
from packages.v1.administrativo.repositories.g_cartorio.g_cartorio_delete_repository import (
GCartorioDeleteRepository,
)
from packages.v1.administrativo.schemas.g_cartorio_schema import GCartorioIdSchema
class GCartorioDeleteAction(BaseAction):
@ -14,7 +16,7 @@ class GCartorioDeleteAction(BaseAction):
Executa a operação de exclusão no banco de dados.
Args:
g_cartorio_id_schema (GCartorioIdSchema):
g_cartorio_id_schema (GCartorioIdSchema):
O esquema contendo o ID do registro a ser excluído.
Returns:

4
packages/v1/administrativo/actions/g_cartorio/g_cartorio_index_action.py
View file

@ -1,5 +1,7 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.g_cartorio.g_cartorio_index_repository import GCartorioIndexRepository
from packages.v1.administrativo.repositories.g_cartorio.g_cartorio_index_repository import (
GCartorioIndexRepository,
)
class GCartorioIndexAction(BaseAction):

6
packages/v1/administrativo/actions/g_cartorio/g_cartorio_save_action.py
View file

@ -1,6 +1,8 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.g_cartorio.g_cartorio_save_repository import GCartorioSaveRepository
from api.packages.v1.administrativo.schemas.g_cartorio_schema import GCartorioSaveSchema
from packages.v1.administrativo.repositories.g_cartorio.g_cartorio_save_repository import (
GCartorioSaveRepository,
)
from packages.v1.administrativo.schemas.g_cartorio_schema import GCartorioSaveSchema
class GCartorioSaveAction(BaseAction):

10
packages/v1/administrativo/actions/g_cartorio/g_cartorio_show_action.py
View file

@ -1,6 +1,8 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.g_cartorio.g_cartorio_show_repository import GCartorioShowRepository
from api.packages.v1.administrativo.schemas.g_cartorio_schema import GCartorioIdSchema
from packages.v1.administrativo.repositories.g_cartorio.g_cartorio_show_repository import (
GCartorioShowRepository,
)
from packages.v1.administrativo.schemas.g_cartorio_schema import GCartorioIdSchema
class GCartorioShowAction(BaseAction):
@ -12,9 +14,9 @@ class GCartorioShowAction(BaseAction):
def execute(self, g_cartorio_id_schema: GCartorioIdSchema):
"""
Executa a operação de exibição.
Args:
g_cartorio_id_schema (GCartorioIdSchema):
g_cartorio_id_schema (GCartorioIdSchema):
O esquema com o ID do registro a ser exibido.
Returns:

8
packages/v1/administrativo/actions/g_cartorio/g_cartorio_update_action.py
View file

@ -1,6 +1,8 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.g_cartorio.g_cartorio_update_repository import GCartorioUpdateRepository
from api.packages.v1.administrativo.schemas.g_cartorio_schema import GCartorioUpdateSchema
from packages.v1.administrativo.repositories.g_cartorio.g_cartorio_update_repository import (
GCartorioUpdateRepository,
)
from packages.v1.administrativo.schemas.g_cartorio_schema import GCartorioUpdateSchema
class GCartorioUpdateAction(BaseAction):
@ -14,7 +16,7 @@ class GCartorioUpdateAction(BaseAction):
Executa a operação de atualização.
Args:
g_cartorio_update_schema (GCartorioUpdateSchema):
g_cartorio_update_schema (GCartorioUpdateSchema):
O esquema com os dados a serem atualizados.
Returns:

8
packages/v1/administrativo/actions/g_emolumento/g_emolumento_delete_action.py
View file

@ -1,6 +1,8 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.g_emolumento.g_emolumento_delete_repository import GEmolumentoDeleteRepository
from api.packages.v1.administrativo.schemas.g_emolumento_schema import GEmolumentoIdSchema
from packages.v1.administrativo.repositories.g_emolumento.g_emolumento_delete_repository import (
GEmolumentoDeleteRepository,
)
from packages.v1.administrativo.schemas.g_emolumento_schema import GEmolumentoIdSchema
class GEmolumentoDeleteAction(BaseAction):
@ -14,7 +16,7 @@ class GEmolumentoDeleteAction(BaseAction):
Executa a operação de exclusão no banco de dados.
Args:
g_emolumento_id_schema (GEmolumentoIdSchema):
g_emolumento_id_schema (GEmolumentoIdSchema):
O esquema contendo o ID do registro a ser excluído.
Returns:

6
packages/v1/administrativo/actions/g_emolumento/g_emolumento_save_action.py
View file

@ -1,6 +1,8 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.g_emolumento.g_emolumento_save_repository import GEmolumentoSaveRepository
from api.packages.v1.administrativo.schemas.g_emolumento_schema import GEmolumentoSaveSchema
from packages.v1.administrativo.repositories.g_emolumento.g_emolumento_save_repository import (
GEmolumentoSaveRepository,
)
from packages.v1.administrativo.schemas.g_emolumento_schema import GEmolumentoSaveSchema
class GEmolumentoSaveAction(BaseAction):

10
packages/v1/administrativo/actions/g_emolumento/g_emolumento_show_action.py
View file

@ -1,6 +1,8 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.g_emolumento.g_emolumento_show_repository import GEmolumentoShowRepository
from api.packages.v1.administrativo.schemas.g_emolumento_schema import GEmolumentoIdSchema
from packages.v1.administrativo.repositories.g_emolumento.g_emolumento_show_repository import (
GEmolumentoShowRepository,
)
from packages.v1.administrativo.schemas.g_emolumento_schema import GEmolumentoIdSchema
class GEmolumentoShowAction(BaseAction):
@ -12,9 +14,9 @@ class GEmolumentoShowAction(BaseAction):
def execute(self, g_emolumento_id_schema: GEmolumentoIdSchema):
"""
Executa a operação de exibição.
Args:
g_emolumento_id_schema (GEmolumentoIdSchema):
g_emolumento_id_schema (GEmolumentoIdSchema):
O esquema com o ID do registro a ser exibido.
Returns:

10
packages/v1/administrativo/actions/g_emolumento/g_emolumento_update_action.py
View file

@ -1,6 +1,10 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.g_emolumento.g_emolumento_update_repository import GEmolumentoUpdateRepository
from api.packages.v1.administrativo.schemas.g_emolumento_schema import GEmolumentoUpdateSchema
from packages.v1.administrativo.repositories.g_emolumento.g_emolumento_update_repository import (
GEmolumentoUpdateRepository,
)
from packages.v1.administrativo.schemas.g_emolumento_schema import (
GEmolumentoUpdateSchema,
)
class GEmolumentoUpdateAction(BaseAction):
@ -14,7 +18,7 @@ class GEmolumentoUpdateAction(BaseAction):
Executa a operação de atualização.
Args:
g_emolumento_update_schema (GEmolumentoUpdateSchema):
g_emolumento_update_schema (GEmolumentoUpdateSchema):
O esquema com os dados a serem atualizados.
Returns:

12
packages/v1/administrativo/actions/g_emolumento_item/g_emolumento_item_delete_action.py
View file

@ -1,6 +1,10 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.g_emolumento_item.g_emolumento_item_delete_repository import GEmolumentoItemDeleteRepository
from api.packages.v1.administrativo.schemas.g_emolumento_item_schema import GEmolumentoItemIdSchema
from packages.v1.administrativo.repositories.g_emolumento_item.g_emolumento_item_delete_repository import (
GEmolumentoItemDeleteRepository,
)
from packages.v1.administrativo.schemas.g_emolumento_item_schema import (
GEmolumentoItemIdSchema,
)
class GEmolumentoItemDeleteAction(BaseAction):
@ -28,6 +32,8 @@ class GEmolumentoItemDeleteAction(BaseAction):
# ----------------------------------------------------
# Execução da exclusão
# ----------------------------------------------------
response = g_emolumento_item_delete_repository.execute(g_emolumento_item_id_schema)
response = g_emolumento_item_delete_repository.execute(
g_emolumento_item_id_schema
)
return response

12
packages/v1/administrativo/actions/g_emolumento_item/g_emolumento_item_show_action.py
View file

@ -1,6 +1,10 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.g_emolumento_item.g_emolumento_item_show_repository import GEmolumentoItemShowRepository
from api.packages.v1.administrativo.schemas.g_emolumento_item_schema import GEmolumentoItemIdSchema
from packages.v1.administrativo.repositories.g_emolumento_item.g_emolumento_item_show_repository import (
GEmolumentoItemShowRepository,
)
from packages.v1.administrativo.schemas.g_emolumento_item_schema import (
GEmolumentoItemIdSchema,
)
class GEmolumentoItemShowAction(BaseAction):
@ -28,7 +32,9 @@ class GEmolumentoItemShowAction(BaseAction):
# ----------------------------------------------------
# Execução do repositório
# ----------------------------------------------------
response = g_emolumento_item_show_repository.execute(g_emolumento_item_id_schema)
response = g_emolumento_item_show_repository.execute(
g_emolumento_item_id_schema
)
# ----------------------------------------------------
# Retorno da informação

12
packages/v1/administrativo/actions/g_emolumento_item/g_emolumento_item_update_action.py
View file

@ -1,6 +1,10 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.g_emolumento_item.g_emolumento_item_update_repository import GEmolumentoItemUpdateRepository
from api.packages.v1.administrativo.schemas.g_emolumento_item_schema import GEmolumentoItemUpdateSchema
from packages.v1.administrativo.repositories.g_emolumento_item.g_emolumento_item_update_repository import (
GEmolumentoItemUpdateRepository,
)
from packages.v1.administrativo.schemas.g_emolumento_item_schema import (
GEmolumentoItemUpdateSchema,
)
class GEmolumentoItemUpdateAction(BaseAction):
@ -28,7 +32,9 @@ class GEmolumentoItemUpdateAction(BaseAction):
# ----------------------------------------------------
# Execução do repositório
# ----------------------------------------------------
response = g_emolumento_item_update_repository.execute(g_emolumento_item_update_schema)
response = g_emolumento_item_update_repository.execute(
g_emolumento_item_update_schema
)
# ----------------------------------------------------
# Retorno do resultado

14
packages/v1/administrativo/actions/g_emolumento_periodo/g_emolumento_periodo_delete_action.py
View file

@ -1,6 +1,10 @@
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
from packages.v1.administrativo.repositories.g_emolumento_periodo.g_emolumento_periodo_delete_repository import (
GEmolumentoPeriodoDeleteRepository,
)
from packages.v1.administrativo.schemas.g_emolumento_periodo_schema import (
GEmolumentoPeriodoIdSchema,
)
class GEmolumentoPeriodoDeleteAction(BaseAction):
@ -14,7 +18,7 @@ class GEmolumentoPeriodoDeleteAction(BaseAction):
Executa a operação de exclusão no banco de dados.
Args:
g_emolumento_periodo_id_schema (GEmolumentoPeriodoIdSchema):
g_emolumento_periodo_id_schema (GEmolumentoPeriodoIdSchema):
O esquema contendo o ID do registro a ser excluído.
Returns:
@ -28,6 +32,8 @@ class GEmolumentoPeriodoDeleteAction(BaseAction):
# ----------------------------------------------------
# Execução da exclusão
# ----------------------------------------------------
response = g_emolumento_periodo_delete_repository.execute(g_emolumento_periodo_id_schema)
response = g_emolumento_periodo_delete_repository.execute(
g_emolumento_periodo_id_schema
)
return response

4
packages/v1/administrativo/actions/g_emolumento_periodo/g_emolumento_periodo_index_action.py
View file

@ -1,5 +1,7 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.g_emolumento_periodo.g_emolumento_periodo_index_repository import GEmolumentoPeriodoIndexRepository
from packages.v1.administrativo.repositories.g_emolumento_periodo.g_emolumento_periodo_index_repository import (
GEmolumentoPeriodoIndexRepository,
)
class GEmolumentoPeriodoIndexAction(BaseAction):

12
packages/v1/administrativo/actions/g_emolumento_periodo/g_emolumento_periodo_save_action.py
View file

@ -1,6 +1,10 @@
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
from packages.v1.administrativo.repositories.g_emolumento_periodo.g_emolumento_periodo_save_repository import (
GEmolumentoPeriodoSaveRepository,
)
from packages.v1.administrativo.schemas.g_emolumento_periodo_schema import (
GEmolumentoPeriodoSaveSchema,
)
class GEmolumentoPeriodoSaveAction(BaseAction):
@ -28,7 +32,9 @@ class GEmolumentoPeriodoSaveAction(BaseAction):
# ----------------------------------------------------
# Execução do repositório
# ----------------------------------------------------
response = g_emolumento_periodo_save_repository.execute(g_emolumento_periodo_save_schema)
response = g_emolumento_periodo_save_repository.execute(
g_emolumento_periodo_save_schema
)
# ----------------------------------------------------
# Retorno da informação

16
packages/v1/administrativo/actions/g_emolumento_periodo/g_emolumento_periodo_show_action.py
View file

@ -1,6 +1,10 @@
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
from packages.v1.administrativo.repositories.g_emolumento_periodo.g_emolumento_periodo_show_repository import (
GEmolumentoPeriodoShowRepository,
)
from packages.v1.administrativo.schemas.g_emolumento_periodo_schema import (
GEmolumentoPeriodoIdSchema,
)
class GEmolumentoPeriodoShowAction(BaseAction):
@ -12,9 +16,9 @@ class GEmolumentoPeriodoShowAction(BaseAction):
def execute(self, g_emolumento_periodo_id_schema: GEmolumentoPeriodoIdSchema):
"""
Executa a operação de exibição.
Args:
g_emolumento_periodo_id_schema (GEmolumentoPeriodoIdSchema):
g_emolumento_periodo_id_schema (GEmolumentoPeriodoIdSchema):
O esquema com o ID do registro a ser exibido.
Returns:
@ -28,7 +32,9 @@ class GEmolumentoPeriodoShowAction(BaseAction):
# ----------------------------------------------------
# Execução do repositório
# ----------------------------------------------------
response = g_emolumento_periodo_show_repository.execute(g_emolumento_periodo_id_schema)
response = g_emolumento_periodo_show_repository.execute(
g_emolumento_periodo_id_schema
)
# ----------------------------------------------------
# Retorno da informação

18
packages/v1/administrativo/actions/g_emolumento_periodo/g_emolumento_periodo_update_action.py
View file

@ -1,6 +1,10 @@
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
from packages.v1.administrativo.repositories.g_emolumento_periodo.g_emolumento_periodo_update_repository import (
GEmolumentoPeriodoUpdateRepository,
)
from packages.v1.administrativo.schemas.g_emolumento_periodo_schema import (
GEmolumentoPeriodoUpdateSchema,
)
class GEmolumentoPeriodoUpdateAction(BaseAction):
@ -9,12 +13,14 @@ class GEmolumentoPeriodoUpdateAction(BaseAction):
de um registro na tabela G_NATUREZA_TITULO.
"""
def execute(self, g_emolumento_periodo_update_schema: GEmolumentoPeriodoUpdateSchema):
def execute(
self, g_emolumento_periodo_update_schema: GEmolumentoPeriodoUpdateSchema
):
"""
Executa a operação de atualização.
Args:
g_emolumento_periodo_update_schema (GEmolumentoPeriodoUpdateSchema):
g_emolumento_periodo_update_schema (GEmolumentoPeriodoUpdateSchema):
O esquema com os dados a serem atualizados.
Returns:
@ -28,7 +34,9 @@ class GEmolumentoPeriodoUpdateAction(BaseAction):
# ----------------------------------------------------
# Execução do repositório
# ----------------------------------------------------
response = g_emolumento_periodo_update_repository.execute(g_emolumento_periodo_update_schema)
response = g_emolumento_periodo_update_repository.execute(
g_emolumento_periodo_update_schema
)
# ----------------------------------------------------
# Retorno do resultado

8
packages/v1/administrativo/actions/g_gramatica/g_gramatica_delete_action.py
View file

@ -1,6 +1,8 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.g_gramatica.g_gramatica_delete_repository import GGramaticaDeleteRepository
from api.packages.v1.administrativo.schemas.g_gramatica_schema import GGramaticaIdSchema
from packages.v1.administrativo.repositories.g_gramatica.g_gramatica_delete_repository import (
GGramaticaDeleteRepository,
)
from packages.v1.administrativo.schemas.g_gramatica_schema import GGramaticaIdSchema
class GGramaticaDeleteAction(BaseAction):
@ -14,7 +16,7 @@ class GGramaticaDeleteAction(BaseAction):
Executa a operação de exclusão no banco de dados.
Args:
g_gramatica_id_schema (GGramaticaIdSchema):
g_gramatica_id_schema (GGramaticaIdSchema):
O esquema contendo o ID do registro a ser excluído.
Returns:

4
packages/v1/administrativo/actions/g_gramatica/g_gramatica_index_action.py
View file

@ -1,5 +1,7 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.g_gramatica.g_gramatica_index_repository import GGramaticaIndexRepository
from packages.v1.administrativo.repositories.g_gramatica.g_gramatica_index_repository import (
GGramaticaIndexRepository,
)
class GGramaticaIndexAction(BaseAction):

6
packages/v1/administrativo/actions/g_gramatica/g_gramatica_save_action.py
View file

@ -1,6 +1,8 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.g_gramatica.g_gramatica_save_repository import GGramaticaSaveRepository
from api.packages.v1.administrativo.schemas.g_gramatica_schema import GGramaticaSaveSchema
from packages.v1.administrativo.repositories.g_gramatica.g_gramatica_save_repository import (
GGramaticaSaveRepository,
)
from packages.v1.administrativo.schemas.g_gramatica_schema import GGramaticaSaveSchema
class GGramaticaSaveAction(BaseAction):

10
packages/v1/administrativo/actions/g_gramatica/g_gramatica_show_action.py
View file

@ -1,6 +1,8 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.g_gramatica.g_gramatica_show_repository import GGramaticaShowRepository
from api.packages.v1.administrativo.schemas.g_gramatica_schema import GGramaticaIdSchema
from packages.v1.administrativo.repositories.g_gramatica.g_gramatica_show_repository import (
GGramaticaShowRepository,
)
from packages.v1.administrativo.schemas.g_gramatica_schema import GGramaticaIdSchema
class GGramaticaShowAction(BaseAction):
@ -12,9 +14,9 @@ class GGramaticaShowAction(BaseAction):
def execute(self, g_gramatica_id_schema: GGramaticaIdSchema):
"""
Executa a operação de exibição.
Args:
g_gramatica_id_schema (GGramaticaIdSchema):
g_gramatica_id_schema (GGramaticaIdSchema):
O esquema com o ID do registro a ser exibido.
Returns:

8
packages/v1/administrativo/actions/g_gramatica/g_gramatica_update_action.py
View file

@ -1,6 +1,8 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.g_gramatica.g_gramatica_update_repository import GGramaticaUpdateRepository
from api.packages.v1.administrativo.schemas.g_gramatica_schema import GGramaticaUpdateSchema
from packages.v1.administrativo.repositories.g_gramatica.g_gramatica_update_repository import (
GGramaticaUpdateRepository,
)
from packages.v1.administrativo.schemas.g_gramatica_schema import GGramaticaUpdateSchema
class GGramaticaUpdateAction(BaseAction):
@ -14,7 +16,7 @@ class GGramaticaUpdateAction(BaseAction):
Executa a operação de atualização.
Args:
g_gramatica_update_schema (GGramaticaUpdateSchema):
g_gramatica_update_schema (GGramaticaUpdateSchema):
O esquema com os dados a serem atualizados.
Returns:

11
packages/v1/administrativo/actions/g_natureza/g_natureza_index_by_sistema_id_action.py
View file

@ -1,6 +1,11 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.g_natureza.g_natureza_index_by_sistema_id_repository import IndexBySistemaIdRepository
from api.packages.v1.administrativo.schemas.g_natureza_schema import GNaturezaSistemaIdSchema
from packages.v1.administrativo.repositories.g_natureza.g_natureza_index_by_sistema_id_repository import (
IndexBySistemaIdRepository,
)
from packages.v1.administrativo.schemas.g_natureza_schema import (
GNaturezaSistemaIdSchema,
)
class IndexActionBySistemaId(BaseAction):
"""
@ -22,4 +27,4 @@ class IndexActionBySistemaId(BaseAction):
response = index_repository.execute(g_natureza_sistema_id_schema)
# Retorno da informação
return response
return response

14
packages/v1/administrativo/actions/g_natureza_titulo/g_natureza_titulo_delete_action.py
View file

@ -1,6 +1,10 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.g_natureza_titulo.g_natureza_titulo_delete_repository import GNaturezaTituloDeleteRepository
from api.packages.v1.administrativo.schemas.g_natureza_titulo_schema import GNaturezaTituloIdSchema
from packages.v1.administrativo.repositories.g_natureza_titulo.g_natureza_titulo_delete_repository import (
GNaturezaTituloDeleteRepository,
)
from packages.v1.administrativo.schemas.g_natureza_titulo_schema import (
GNaturezaTituloIdSchema,
)
class GNaturezaTituloDeleteAction(BaseAction):
@ -14,7 +18,7 @@ class GNaturezaTituloDeleteAction(BaseAction):
Executa a operação de exclusão no banco de dados.
Args:
g_natureza_titulo_id_schema (GNaturezaTituloIdSchema):
g_natureza_titulo_id_schema (GNaturezaTituloIdSchema):
O esquema contendo o ID do registro a ser excluído.
Returns:
@ -28,6 +32,8 @@ class GNaturezaTituloDeleteAction(BaseAction):
# ----------------------------------------------------
# Execução da exclusão
# ----------------------------------------------------
response = g_natureza_titulo_delete_repository.execute(g_natureza_titulo_id_schema)
response = g_natureza_titulo_delete_repository.execute(
g_natureza_titulo_id_schema
)
return response

12
packages/v1/administrativo/actions/g_natureza_titulo/g_natureza_titulo_index_action.py
View file

@ -1,6 +1,10 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.g_natureza_titulo.g_natureza_titulo_index_repository import GNaturezaTituloIndexRepository
from api.packages.v1.administrativo.schemas.g_natureza_titulo_schema import GNaturezaTituloIndexSchema
from packages.v1.administrativo.repositories.g_natureza_titulo.g_natureza_titulo_index_repository import (
GNaturezaTituloIndexRepository,
)
from packages.v1.administrativo.schemas.g_natureza_titulo_schema import (
GNaturezaTituloIndexSchema,
)
class GNaturezaTituloIndexAction(BaseAction):
@ -28,7 +32,9 @@ class GNaturezaTituloIndexAction(BaseAction):
# ----------------------------------------------------
# Execução do repositório
# ----------------------------------------------------
response = g_natureza_titulo_index_repository.execute(g_natureza_titulo_index_schema)
response = g_natureza_titulo_index_repository.execute(
g_natureza_titulo_index_schema
)
# ----------------------------------------------------
# Retorno da informação

12
packages/v1/administrativo/actions/g_natureza_titulo/g_natureza_titulo_save_action.py
View file

@ -1,6 +1,10 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.g_natureza_titulo.g_natureza_titulo_save_repository import GNaturezaTituloSaveRepository
from api.packages.v1.administrativo.schemas.g_natureza_titulo_schema import GNaturezaTituloSaveSchema
from packages.v1.administrativo.repositories.g_natureza_titulo.g_natureza_titulo_save_repository import (
GNaturezaTituloSaveRepository,
)
from packages.v1.administrativo.schemas.g_natureza_titulo_schema import (
GNaturezaTituloSaveSchema,
)
class GNaturezaTituloSaveAction(BaseAction):
@ -28,7 +32,9 @@ class GNaturezaTituloSaveAction(BaseAction):
# ----------------------------------------------------
# Execução do repositório
# ----------------------------------------------------
response = g_natureza_titulo_save_repository.execute(g_natureza_titulo_save_schema)
response = g_natureza_titulo_save_repository.execute(
g_natureza_titulo_save_schema
)
# ----------------------------------------------------
# Retorno da informação

16
packages/v1/administrativo/actions/g_natureza_titulo/g_natureza_titulo_show_action.py
View file

@ -1,6 +1,10 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.g_natureza_titulo.g_natureza_titulo_show_repository import GNaturezaTituloShowRepository
from api.packages.v1.administrativo.schemas.g_natureza_titulo_schema import GNaturezaTituloIdSchema
from packages.v1.administrativo.repositories.g_natureza_titulo.g_natureza_titulo_show_repository import (
GNaturezaTituloShowRepository,
)
from packages.v1.administrativo.schemas.g_natureza_titulo_schema import (
GNaturezaTituloIdSchema,
)
class GNaturezaTituloShowAction(BaseAction):
@ -12,9 +16,9 @@ class GNaturezaTituloShowAction(BaseAction):
def execute(self, g_natureza_titulo_id_schema: GNaturezaTituloIdSchema):
"""
Executa a operação de exibição.
Args:
g_natureza_titulo_id_schema (GNaturezaTituloIdSchema):
g_natureza_titulo_id_schema (GNaturezaTituloIdSchema):
O esquema com o ID do registro a ser exibido.
Returns:
@ -28,7 +32,9 @@ class GNaturezaTituloShowAction(BaseAction):
# ----------------------------------------------------
# Execução do repositório
# ----------------------------------------------------
response = g_natureza_titulo_show_repository.execute(g_natureza_titulo_id_schema)
response = g_natureza_titulo_show_repository.execute(
g_natureza_titulo_id_schema
)
# ----------------------------------------------------
# Retorno da informação

14
packages/v1/administrativo/actions/g_natureza_titulo/g_natureza_titulo_update_action.py
View file

@ -1,6 +1,10 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.g_natureza_titulo.g_natureza_titulo_update_repository import GNaturezaTituloUpdateRepository
from api.packages.v1.administrativo.schemas.g_natureza_titulo_schema import GNaturezaTituloUpdateSchema
from packages.v1.administrativo.repositories.g_natureza_titulo.g_natureza_titulo_update_repository import (
GNaturezaTituloUpdateRepository,
)
from packages.v1.administrativo.schemas.g_natureza_titulo_schema import (
GNaturezaTituloUpdateSchema,
)
class GNaturezaTituloUpdateAction(BaseAction):
@ -14,7 +18,7 @@ class GNaturezaTituloUpdateAction(BaseAction):
Executa a operação de atualização.
Args:
g_natureza_titulo_update_schema (GNaturezaTituloUpdateSchema):
g_natureza_titulo_update_schema (GNaturezaTituloUpdateSchema):
O esquema com os dados a serem atualizados.
Returns:
@ -28,7 +32,9 @@ class GNaturezaTituloUpdateAction(BaseAction):
# ----------------------------------------------------
# Execução do repositório
# ----------------------------------------------------
response = g_natureza_titulo_update_repository.execute(g_natureza_titulo_update_schema)
response = g_natureza_titulo_update_repository.execute(
g_natureza_titulo_update_schema
)
# ----------------------------------------------------
# Retorno do resultado

8
packages/v1/administrativo/actions/g_selo_grupo/g_selo_grupo_delete_action.py
View file

@ -1,6 +1,8 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.g_selo_grupo.g_selo_grupo_delete_repository import GSeloGrupoDeleteRepository
from api.packages.v1.administrativo.schemas.g_selo_grupo_schema import GSeloGrupoIdSchema
from packages.v1.administrativo.repositories.g_selo_grupo.g_selo_grupo_delete_repository import (
GSeloGrupoDeleteRepository,
)
from packages.v1.administrativo.schemas.g_selo_grupo_schema import GSeloGrupoIdSchema
class GSeloGrupoDeleteAction(BaseAction):
@ -14,7 +16,7 @@ class GSeloGrupoDeleteAction(BaseAction):
Executa a operação de exclusão no banco de dados.
Args:
g_selo_grupo_id_schema (GSeloGrupoIdSchema):
g_selo_grupo_id_schema (GSeloGrupoIdSchema):
O esquema contendo o ID do registro a ser excluído.
Returns:

4
packages/v1/administrativo/actions/g_selo_grupo/g_selo_grupo_index_action.py
View file

@ -1,5 +1,7 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.g_selo_grupo.g_selo_grupo_index_repository import GSeloGrupoIndexRepository
from packages.v1.administrativo.repositories.g_selo_grupo.g_selo_grupo_index_repository import (
GSeloGrupoIndexRepository,
)
class GSeloGrupoIndexAction(BaseAction):

6
packages/v1/administrativo/actions/g_selo_grupo/g_selo_grupo_save_action.py
View file

@ -1,6 +1,8 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.g_selo_grupo.g_selo_grupo_save_repository import GSeloGrupoSaveRepository
from api.packages.v1.administrativo.schemas.g_selo_grupo_schema import GSeloGrupoSaveSchema
from packages.v1.administrativo.repositories.g_selo_grupo.g_selo_grupo_save_repository import (
GSeloGrupoSaveRepository,
)
from packages.v1.administrativo.schemas.g_selo_grupo_schema import GSeloGrupoSaveSchema
class GSeloGrupoSaveAction(BaseAction):

10
packages/v1/administrativo/actions/g_selo_grupo/g_selo_grupo_show_action.py
View file

@ -1,6 +1,8 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.g_selo_grupo.g_selo_grupo_show_repository import GSeloGrupoShowRepository
from api.packages.v1.administrativo.schemas.g_selo_grupo_schema import GSeloGrupoIdSchema
from packages.v1.administrativo.repositories.g_selo_grupo.g_selo_grupo_show_repository import (
GSeloGrupoShowRepository,
)
from packages.v1.administrativo.schemas.g_selo_grupo_schema import GSeloGrupoIdSchema
class GSeloGrupoShowAction(BaseAction):
@ -12,9 +14,9 @@ class GSeloGrupoShowAction(BaseAction):
def execute(self, g_selo_grupo_id_schema: GSeloGrupoIdSchema):
"""
Executa a operação de exibição.
Args:
g_selo_grupo_id_schema (GSeloGrupoIdSchema):
g_selo_grupo_id_schema (GSeloGrupoIdSchema):
O esquema com o ID do registro a ser exibido.
Returns:

10
packages/v1/administrativo/actions/g_selo_grupo/g_selo_grupo_update_action.py
View file

@ -1,6 +1,10 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.g_selo_grupo.g_selo_grupo_update_repository import GSeloGrupoUpdateRepository
from api.packages.v1.administrativo.schemas.g_selo_grupo_schema import GSeloGrupoUpdateSchema
from packages.v1.administrativo.repositories.g_selo_grupo.g_selo_grupo_update_repository import (
GSeloGrupoUpdateRepository,
)
from packages.v1.administrativo.schemas.g_selo_grupo_schema import (
GSeloGrupoUpdateSchema,
)
class GSeloGrupoUpdateAction(BaseAction):
@ -14,7 +18,7 @@ class GSeloGrupoUpdateAction(BaseAction):
Executa a operação de atualização.
Args:
g_selo_grupo_update_schema (GSeloGrupoUpdateSchema):
g_selo_grupo_update_schema (GSeloGrupoUpdateSchema):
O esquema com os dados a serem atualizados.
Returns:

10
packages/v1/administrativo/actions/g_usuario/g_usuario_get_by_authenticate_action.py
View file

@ -1,11 +1,15 @@
from abstracts.action import BaseAction
from packages.v1.administrativo.schemas.g_usuario_schema import GUsuarioAuthenticateSchema
from packages.v1.administrativo.repositories.g_usuario.g_usuario_get_by_authenticate_repository import GetByAuthenticateRepository
from packages.v1.administrativo.schemas.g_usuario_schema import (
GUsuarioAuthenticateSchema,
)
from packages.v1.administrativo.repositories.g_usuario.g_usuario_get_by_authenticate_repository import (
GetByAuthenticateRepository,
)
class GetByAuthenticateAction(BaseAction):
def execute(self, g_usuario_authenticate_schema : GUsuarioAuthenticateSchema):
def execute(self, g_usuario_authenticate_schema: GUsuarioAuthenticateSchema):
# Instânciamento do repositório de busca pelo authenticate
get_by_authenticate_repository = GetByAuthenticateRepository()

7
packages/v1/administrativo/actions/g_usuario/g_usuario_get_by_login_action.py
View file

@ -1,10 +1,13 @@
from abstracts.action import BaseAction
from packages.v1.administrativo.schemas.g_usuario_schema import GUsuarioLoginSchema
from packages.v1.administrativo.repositories.g_usuario.g_usuario_get_by_login_repository import GetByUsuarioLoginRepository
from packages.v1.administrativo.repositories.g_usuario.g_usuario_get_by_login_repository import (
GetByUsuarioLoginRepository,
)
class GetByUsuarioLoginAction(BaseAction):
def execute(self, g_usuario_schema = GUsuarioLoginSchema):
def execute(self, g_usuario_schema=GUsuarioLoginSchema):
# Importação do repositório
get_by_login_repository = GetByUsuarioLoginRepository()

11
packages/v1/administrativo/actions/t_ato_partetipo/t_ato_partetipo_delete_action.py
View file

@ -1,6 +1,11 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.t_ato_partetipo.t_ato_partetipo_delete_repository import TAtoParteTipoDeleteRepository
from api.packages.v1.administrativo.schemas.t_ato_partetipo_schema import TAtoParteTipoIdSchema
from packages.v1.administrativo.repositories.t_ato_partetipo.t_ato_partetipo_delete_repository import (
TAtoParteTipoDeleteRepository,
)
from packages.v1.administrativo.schemas.t_ato_partetipo_schema import (
TAtoParteTipoIdSchema,
)
class TAtoParteTipoDeleteAction(BaseAction):
"""
@ -24,4 +29,4 @@ class TAtoParteTipoDeleteAction(BaseAction):
# Execução do repositório
response = t_ato_partetipo_delete_repository.execute(t_ato_partetipo_id_schema)
return response
return response

7
packages/v1/administrativo/actions/t_ato_partetipo/t_ato_partetipo_index_action.py
View file

@ -1,5 +1,8 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.t_ato_partetipo.t_ato_partetipo_index_repository import TAtoParteTipoIndexRepository
from packages.v1.administrativo.repositories.t_ato_partetipo.t_ato_partetipo_index_repository import (
TAtoParteTipoIndexRepository,
)
class TAtoParteTipoIndexAction(BaseAction):
"""
@ -21,4 +24,4 @@ class TAtoParteTipoIndexAction(BaseAction):
response = t_ato_partetipo_index_repositoy.execute()
# Retorno da informação
return response
return response

11
packages/v1/administrativo/actions/t_ato_partetipo/t_ato_partetipo_save_action.py
View file

@ -1,6 +1,11 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.t_ato_partetipo.t_ato_partetipo_save_repository import TAtoParteTipoSaveRepository
from api.packages.v1.administrativo.schemas.t_ato_partetipo_schema import TAtoParteTipoSaveSchema
from packages.v1.administrativo.repositories.t_ato_partetipo.t_ato_partetipo_save_repository import (
TAtoParteTipoSaveRepository,
)
from packages.v1.administrativo.schemas.t_ato_partetipo_schema import (
TAtoParteTipoSaveSchema,
)
class TAtoParteTipoSaveAction(BaseAction):
"""
@ -25,4 +30,4 @@ class TAtoParteTipoSaveAction(BaseAction):
response = t_ato_partetipo_save_repository.execute(t_ato_partetipo_save_schema)
# Retorno da informação
return response
return response

13
packages/v1/administrativo/actions/t_ato_partetipo/t_ato_partetipo_show_action.py
View file

@ -1,6 +1,11 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.t_ato_partetipo.t_ato_partetipo_show_repository import TAtoParteTipoShowRepository
from api.packages.v1.administrativo.schemas.t_ato_partetipo_schema import TAtoParteTipoIdSchema
from packages.v1.administrativo.repositories.t_ato_partetipo.t_ato_partetipo_show_repository import (
TAtoParteTipoShowRepository,
)
from packages.v1.administrativo.schemas.t_ato_partetipo_schema import (
TAtoParteTipoIdSchema,
)
class TAtoParteTipoShowAction(BaseAction):
"""
@ -11,7 +16,7 @@ class TAtoParteTipoShowAction(BaseAction):
def execute(self, t_ato_partetipo_id_schema: TAtoParteTipoIdSchema):
"""
Executa a operação de exibição.
Args:
t_ato_partetipo_schema (TCensecQualidadeIdSchema): O esquema com o ID do registro a ser exibido.
@ -25,4 +30,4 @@ class TAtoParteTipoShowAction(BaseAction):
response = t_ato_partetipo_show_repository.execute(t_ato_partetipo_id_schema)
# Retorno da informação
return response
return response

10
packages/v1/administrativo/actions/t_ato_partetipo/t_ato_partetipo_update_action.py
View file

@ -1,6 +1,10 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.t_ato_partetipo.t_ato_partetipo_update_repository import TAtoParteTipoUpdateRepository
from api.packages.v1.administrativo.schemas.t_ato_partetipo_schema import TAtoParteTipoUpdateSchema
from packages.v1.administrativo.repositories.t_ato_partetipo.t_ato_partetipo_update_repository import (
TAtoParteTipoUpdateRepository,
)
from packages.v1.administrativo.schemas.t_ato_partetipo_schema import (
TAtoParteTipoUpdateSchema,
)
class TAtoParteTipoUpdateAction(BaseAction):
@ -24,4 +28,4 @@ class TAtoParteTipoUpdateAction(BaseAction):
t_ato_partetipo_update_repository = TAtoParteTipoUpdateRepository()
# Chama o método de execução do repositório para realizar a atualização
return t_ato_partetipo_update_repository.execute(t_ato_partetipo_update_schema)
return t_ato_partetipo_update_repository.execute(t_ato_partetipo_update_schema)

14
packages/v1/administrativo/actions/t_censec_naturezatipo/t_censec_tiponatureza_delete_action.py
View file

@ -1,6 +1,10 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.t_censec_tiponatureza.t_censec_tiponatureza_delete_repository import TCensecTipoNaturezaDeleteRepository
from api.packages.v1.administrativo.schemas.t_censec_tiponatureza_schema import TCensecTipoNaturezaIdSchema
from packages.v1.administrativo.repositories.t_censec_tiponatureza.t_censec_tiponatureza_delete_repository import (
TCensecTipoNaturezaDeleteRepository,
)
from packages.v1.administrativo.schemas.t_censec_tiponatureza_schema import (
TCensecTipoNaturezaIdSchema,
)
class TCensecTipoNaturezaDeleteAction(BaseAction):
@ -14,7 +18,7 @@ class TCensecTipoNaturezaDeleteAction(BaseAction):
Executa a operação de exclusão no banco de dados.
Args:
t_censec_tiponatureza_id_schema (TCensecTipoNaturezaIdSchema):
t_censec_tiponatureza_id_schema (TCensecTipoNaturezaIdSchema):
O esquema contendo o ID do registro a ser excluído.
Returns:
@ -28,6 +32,8 @@ class TCensecTipoNaturezaDeleteAction(BaseAction):
# ----------------------------------------------------
# Execução da exclusão
# ----------------------------------------------------
response = t_censec_tiponatureza_delete_repository.execute(t_censec_tiponatureza_id_schema)
response = t_censec_tiponatureza_delete_repository.execute(
t_censec_tiponatureza_id_schema
)
return response

4
packages/v1/administrativo/actions/t_censec_naturezatipo/t_censec_tiponatureza_index_action.py
View file

@ -1,5 +1,7 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.t_censec_tiponatureza.t_censec_tiponatureza_index_repository import TCensecTipoNaturezaIndexRepository
from packages.v1.administrativo.repositories.t_censec_tiponatureza.t_censec_tiponatureza_index_repository import (
TCensecTipoNaturezaIndexRepository,
)
class TCensecTipoNaturezaIndexAction(BaseAction):

12
packages/v1/administrativo/actions/t_censec_naturezatipo/t_censec_tiponatureza_save_action.py
View file

@ -1,6 +1,10 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.t_censec_tiponatureza.t_censec_tiponatureza_save_repository import TCensecTipoNaturezaSaveRepository
from api.packages.v1.administrativo.schemas.t_censec_tiponatureza_schema import TCensecTipoNaturezaSaveSchema
from packages.v1.administrativo.repositories.t_censec_tiponatureza.t_censec_tiponatureza_save_repository import (
TCensecTipoNaturezaSaveRepository,
)
from packages.v1.administrativo.schemas.t_censec_tiponatureza_schema import (
TCensecTipoNaturezaSaveSchema,
)
class TCensecTipoNaturezaSaveAction(BaseAction):
@ -28,7 +32,9 @@ class TCensecTipoNaturezaSaveAction(BaseAction):
# ----------------------------------------------------
# Execução do repositório
# ----------------------------------------------------
response = t_censec_tiponatureza_save_repository.execute(t_censec_tiponatureza_save_schema)
response = t_censec_tiponatureza_save_repository.execute(
t_censec_tiponatureza_save_schema
)
# ----------------------------------------------------
# Retorno da informação

16
packages/v1/administrativo/actions/t_censec_naturezatipo/t_censec_tiponatureza_show_action.py
View file

@ -1,6 +1,10 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.t_censec_tiponatureza.t_censec_tiponatureza_show_repository import TCensecTipoNaturezaShowRepository
from api.packages.v1.administrativo.schemas.t_censec_tiponatureza_schema import TCensecTipoNaturezaIdSchema
from packages.v1.administrativo.repositories.t_censec_tiponatureza.t_censec_tiponatureza_show_repository import (
TCensecTipoNaturezaShowRepository,
)
from packages.v1.administrativo.schemas.t_censec_tiponatureza_schema import (
TCensecTipoNaturezaIdSchema,
)
class TCensecTipoNaturezaShowAction(BaseAction):
@ -12,9 +16,9 @@ class TCensecTipoNaturezaShowAction(BaseAction):
def execute(self, t_censec_tiponatureza_id_schema: TCensecTipoNaturezaIdSchema):
"""
Executa a operação de exibição.
Args:
t_censec_tiponatureza_id_schema (TCensecTipoNaturezaIdSchema):
t_censec_tiponatureza_id_schema (TCensecTipoNaturezaIdSchema):
O esquema com o ID do registro a ser exibido.
Returns:
@ -28,7 +32,9 @@ class TCensecTipoNaturezaShowAction(BaseAction):
# ----------------------------------------------------
# Execução do repositório
# ----------------------------------------------------
response = t_censec_tiponatureza_show_repository.execute(t_censec_tiponatureza_id_schema)
response = t_censec_tiponatureza_show_repository.execute(
t_censec_tiponatureza_id_schema
)
# ----------------------------------------------------
# Retorno da informação

18
packages/v1/administrativo/actions/t_censec_naturezatipo/t_censec_tiponatureza_update_action.py
View file

@ -1,6 +1,10 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.t_censec_tiponatureza.t_censec_tiponatureza_update_repository import TCensecTipoNaturezaUpdateRepository
from api.packages.v1.administrativo.schemas.t_censec_tiponatureza_schema import TCensecTipoNaturezaUpdateSchema
from packages.v1.administrativo.repositories.t_censec_tiponatureza.t_censec_tiponatureza_update_repository import (
TCensecTipoNaturezaUpdateRepository,
)
from packages.v1.administrativo.schemas.t_censec_tiponatureza_schema import (
TCensecTipoNaturezaUpdateSchema,
)
class TCensecTipoNaturezaUpdateAction(BaseAction):
@ -9,12 +13,14 @@ class TCensecTipoNaturezaUpdateAction(BaseAction):
de um registro na tabela T_CENSEC_TIPOATO.
"""
def execute(self, t_censec_tiponatureza_update_schema: TCensecTipoNaturezaUpdateSchema):
def execute(
self, t_censec_tiponatureza_update_schema: TCensecTipoNaturezaUpdateSchema
):
"""
Executa a operação de atualização.
Args:
t_censec_tiponatureza_update_schema (TCensecTipoNaturezaUpdateSchema):
t_censec_tiponatureza_update_schema (TCensecTipoNaturezaUpdateSchema):
O esquema com os dados a serem atualizados.
Returns:
@ -28,7 +34,9 @@ class TCensecTipoNaturezaUpdateAction(BaseAction):
# ----------------------------------------------------
# Execução do repositório
# ----------------------------------------------------
response = t_censec_tiponatureza_update_repository.execute(t_censec_tiponatureza_update_schema)
response = t_censec_tiponatureza_update_repository.execute(
t_censec_tiponatureza_update_schema
)
# ----------------------------------------------------
# Retorno do resultado

14
packages/v1/administrativo/actions/t_censec_qualidadeato/t_censec_qualidadeato_delete_action.py
View file

@ -1,6 +1,10 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.t_censec_qualidadeato.t_censec_qualidadeato_delete_repository import TCensecQualidadeAtoDeleteRepository
from api.packages.v1.administrativo.schemas.t_censec_qualidadeato_schema import TCensecQualidadeAtoIdSchema
from packages.v1.administrativo.repositories.t_censec_qualidadeato.t_censec_qualidadeato_delete_repository import (
TCensecQualidadeAtoDeleteRepository,
)
from packages.v1.administrativo.schemas.t_censec_qualidadeato_schema import (
TCensecQualidadeAtoIdSchema,
)
class TCensecQualidadeAtoDeleteAction(BaseAction):
@ -14,7 +18,7 @@ class TCensecQualidadeAtoDeleteAction(BaseAction):
Executa a operação de exclusão no banco de dados.
Args:
t_censec_qualidadeato_id_schema (TCensecQualidadeAtoIdSchema):
t_censec_qualidadeato_id_schema (TCensecQualidadeAtoIdSchema):
O esquema contendo o ID do registro a ser excluído.
Returns:
@ -28,7 +32,9 @@ class TCensecQualidadeAtoDeleteAction(BaseAction):
# ----------------------------------------------------
# Execução da exclusão
# ----------------------------------------------------
response = t_censec_qualidadeato_delete_repository.execute(t_censec_qualidadeato_id_schema)
response = t_censec_qualidadeato_delete_repository.execute(
t_censec_qualidadeato_id_schema
)
# ----------------------------------------------------
# Retorno do resultado

16
packages/v1/administrativo/actions/t_censec_qualidadeato/t_censec_qualidadeato_index_action.py
View file

@ -1,6 +1,10 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.t_censec_qualidadeato.t_censec_qualidadeato_index_repository import TCensecQualidadeAtoIndexRepository
from api.packages.v1.administrativo.schemas.t_censec_qualidadeato_schema import TCensecQualidadeAtoIndexSchema
from packages.v1.administrativo.repositories.t_censec_qualidadeato.t_censec_qualidadeato_index_repository import (
TCensecQualidadeAtoIndexRepository,
)
from packages.v1.administrativo.schemas.t_censec_qualidadeato_schema import (
TCensecQualidadeAtoIndexSchema,
)
class TCensecQualidadeAtoIndexAction(BaseAction):
@ -9,7 +13,9 @@ class TCensecQualidadeAtoIndexAction(BaseAction):
de listagem de todos os registros na tabela T_CENSEC_QUALIDADEATO.
"""
def execute(self, censec_qualidade_ato_index_schema: TCensecQualidadeAtoIndexSchema):
def execute(
self, censec_qualidade_ato_index_schema: TCensecQualidadeAtoIndexSchema
):
"""
Executa a operação de listagem no banco de dados.
@ -24,7 +30,9 @@ class TCensecQualidadeAtoIndexAction(BaseAction):
# ----------------------------------------------------
# Execução do repositório
# ----------------------------------------------------
response = t_censec_qualidadeato_index_repository.execute(censec_qualidade_ato_index_schema)
response = t_censec_qualidadeato_index_repository.execute(
censec_qualidade_ato_index_schema
)
# ----------------------------------------------------
# Retorno da informação

12
packages/v1/administrativo/actions/t_censec_qualidadeato/t_censec_qualidadeato_save_action.py
View file

@ -1,6 +1,10 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.t_censec_qualidadeato.t_censec_qualidadeato_save_repository import TCensecQualidadeAtoSaveRepository
from api.packages.v1.administrativo.schemas.t_censec_qualidadeato_schema import TCensecQualidadeAtoSaveSchema
from packages.v1.administrativo.repositories.t_censec_qualidadeato.t_censec_qualidadeato_save_repository import (
TCensecQualidadeAtoSaveRepository,
)
from packages.v1.administrativo.schemas.t_censec_qualidadeato_schema import (
TCensecQualidadeAtoSaveSchema,
)
class TCensecQualidadeAtoSaveAction(BaseAction):
@ -28,7 +32,9 @@ class TCensecQualidadeAtoSaveAction(BaseAction):
# ----------------------------------------------------
# Execução do repositório
# ----------------------------------------------------
response = t_censec_qualidadeato_save_repository.execute(t_censec_qualidadeato_save_schema)
response = t_censec_qualidadeato_save_repository.execute(
t_censec_qualidadeato_save_schema
)
# ----------------------------------------------------
# Retorno da informação

18
packages/v1/administrativo/actions/t_censec_qualidadeato/t_censec_qualidadeato_show_action.py
View file

@ -1,6 +1,10 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.t_censec_qualidadeato.t_censec_qualidadeato_show_repository import TCensecQualidadeAtoShowRepository
from api.packages.v1.administrativo.schemas.t_censec_qualidadeato_schema import TCensecQualidadeAtoIdSchema
from packages.v1.administrativo.repositories.t_censec_qualidadeato.t_censec_qualidadeato_show_repository import (
TCensecQualidadeAtoShowRepository,
)
from packages.v1.administrativo.schemas.t_censec_qualidadeato_schema import (
TCensecQualidadeAtoIdSchema,
)
class TCensecQualidadeAtoShowAction(BaseAction):
@ -12,9 +16,9 @@ class TCensecQualidadeAtoShowAction(BaseAction):
def execute(self, t_censec_qualidadeato_id_schema: TCensecQualidadeAtoIdSchema):
"""
Executa a operação de exibição.
Args:
t_censec_qualidadeato_id_schema (TCensecQualidadeAtoIdSchema):
t_censec_qualidadeato_id_schema (TCensecQualidadeAtoIdSchema):
O esquema com o ID do registro a ser exibido.
Returns:
@ -28,9 +32,11 @@ class TCensecQualidadeAtoShowAction(BaseAction):
# ----------------------------------------------------
# Execução do repositório
# ----------------------------------------------------
response = t_censec_qualidadeato_show_repository.execute(t_censec_qualidadeato_id_schema)
response = t_censec_qualidadeato_show_repository.execute(
t_censec_qualidadeato_id_schema
)
# ----------------------------------------------------
# Retorno da informação
# ----------------------------------------------------
return response
return response

18
packages/v1/administrativo/actions/t_censec_qualidadeato/t_censec_qualidadeato_update_action.py
View file

@ -1,6 +1,10 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.t_censec_qualidadeato.t_censec_qualidadeato_update_repository import TCensecQualidadeAtoUpdateRepository
from api.packages.v1.administrativo.schemas.t_censec_qualidadeato_schema import TCensecQualidadeAtoUpdateSchema
from packages.v1.administrativo.repositories.t_censec_qualidadeato.t_censec_qualidadeato_update_repository import (
TCensecQualidadeAtoUpdateRepository,
)
from packages.v1.administrativo.schemas.t_censec_qualidadeato_schema import (
TCensecQualidadeAtoUpdateSchema,
)
class TCensecQualidadeAtoUpdateAction(BaseAction):
@ -9,12 +13,14 @@ class TCensecQualidadeAtoUpdateAction(BaseAction):
de um registro na tabela T_CENSEC_QUALIDADEATO.
"""
def execute(self, t_censec_qualidadeato_update_schema: TCensecQualidadeAtoUpdateSchema):
def execute(
self, t_censec_qualidadeato_update_schema: TCensecQualidadeAtoUpdateSchema
):
"""
Executa a operação de atualização.
Args:
t_censec_qualidadeato_update_schema (TCensecQualidadeAtoUpdateSchema):
t_censec_qualidadeato_update_schema (TCensecQualidadeAtoUpdateSchema):
O esquema com os dados a serem atualizados.
Returns:
@ -28,7 +34,9 @@ class TCensecQualidadeAtoUpdateAction(BaseAction):
# ----------------------------------------------------
# Execução do repositório
# ----------------------------------------------------
response = t_censec_qualidadeato_update_repository.execute(t_censec_qualidadeato_update_schema)
response = t_censec_qualidadeato_update_repository.execute(
t_censec_qualidadeato_update_schema
)
# ----------------------------------------------------
# Retorno do resultado

14
packages/v1/administrativo/actions/t_censec_tipoato/t_censec_tipoato_delete_action.py
View file

@ -1,6 +1,10 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.t_censec_tipoato.t_censec_tipoato_delete_repository import TCensecTipoAtoDeleteRepository
from api.packages.v1.administrativo.schemas.t_censec_tipoato_schema import TCensecTipoAtoIdSchema
from packages.v1.administrativo.repositories.t_censec_tipoato.t_censec_tipoato_delete_repository import (
TCensecTipoAtoDeleteRepository,
)
from packages.v1.administrativo.schemas.t_censec_tipoato_schema import (
TCensecTipoAtoIdSchema,
)
class TCensecTipoAtoDeleteAction(BaseAction):
@ -14,7 +18,7 @@ class TCensecTipoAtoDeleteAction(BaseAction):
Executa a operação de exclusão no banco de dados.
Args:
t_censec_tipoato_id_schema (TCensecTipoAtoIdSchema):
t_censec_tipoato_id_schema (TCensecTipoAtoIdSchema):
O esquema contendo o ID do registro a ser excluído.
Returns:
@ -28,6 +32,8 @@ class TCensecTipoAtoDeleteAction(BaseAction):
# ----------------------------------------------------
# Execução da exclusão
# ----------------------------------------------------
response = t_censec_tipoato_delete_repository.execute(t_censec_tipoato_id_schema)
response = t_censec_tipoato_delete_repository.execute(
t_censec_tipoato_id_schema
)
return response

4
packages/v1/administrativo/actions/t_censec_tipoato/t_censec_tipoato_index_action.py
View file

@ -1,5 +1,7 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.t_censec_tipoato.t_censec_tipoato_index_repository import TCensecTipoAtoIndexRepository
from packages.v1.administrativo.repositories.t_censec_tipoato.t_censec_tipoato_index_repository import (
TCensecTipoAtoIndexRepository,
)
class TCensecTipoAtoIndexAction(BaseAction):

12
packages/v1/administrativo/actions/t_censec_tipoato/t_censec_tipoato_save_action.py
View file

@ -1,6 +1,10 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.t_censec_tipoato.t_censec_tipoato_save_repository import TCensecTipoAtoSaveRepository
from api.packages.v1.administrativo.schemas.t_censec_tipoato_schema import TCensecTipoAtoSaveSchema
from packages.v1.administrativo.repositories.t_censec_tipoato.t_censec_tipoato_save_repository import (
TCensecTipoAtoSaveRepository,
)
from packages.v1.administrativo.schemas.t_censec_tipoato_schema import (
TCensecTipoAtoSaveSchema,
)
class TCensecTipoAtoSaveAction(BaseAction):
@ -28,7 +32,9 @@ class TCensecTipoAtoSaveAction(BaseAction):
# ----------------------------------------------------
# Execução do repositório
# ----------------------------------------------------
response = t_censec_tipoato_save_repository.execute(t_censec_tipoato_save_schema)
response = t_censec_tipoato_save_repository.execute(
t_censec_tipoato_save_schema
)
# ----------------------------------------------------
# Retorno da informação

12
packages/v1/administrativo/actions/t_censec_tipoato/t_censec_tipoato_show_action.py
View file

@ -1,6 +1,10 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.t_censec_tipoato.t_censec_tipoato_show_repository import TCensecTipoAtoShowRepository
from api.packages.v1.administrativo.schemas.t_censec_tipoato_schema import TCensecTipoAtoIdSchema
from packages.v1.administrativo.repositories.t_censec_tipoato.t_censec_tipoato_show_repository import (
TCensecTipoAtoShowRepository,
)
from packages.v1.administrativo.schemas.t_censec_tipoato_schema import (
TCensecTipoAtoIdSchema,
)
class TCensecTipoAtoShowAction(BaseAction):
@ -12,9 +16,9 @@ class TCensecTipoAtoShowAction(BaseAction):
def execute(self, t_censec_tipoato_id_schema: TCensecTipoAtoIdSchema):
"""
Executa a operação de exibição.
Args:
t_censec_tipoato_id_schema (TCensecTipoAtoIdSchema):
t_censec_tipoato_id_schema (TCensecTipoAtoIdSchema):
O esquema com o ID do registro a ser exibido.
Returns:

14
packages/v1/administrativo/actions/t_censec_tipoato/t_censec_tipoato_update_action.py
View file

@ -1,6 +1,10 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.t_censec_tipoato.t_censec_tipoato_update_repository import TCensecTipoAtoUpdateRepository
from api.packages.v1.administrativo.schemas.t_censec_tipoato_schema import TCensecTipoAtoUpdateSchema
from packages.v1.administrativo.repositories.t_censec_tipoato.t_censec_tipoato_update_repository import (
TCensecTipoAtoUpdateRepository,
)
from packages.v1.administrativo.schemas.t_censec_tipoato_schema import (
TCensecTipoAtoUpdateSchema,
)
class TCensecTipoAtoUpdateAction(BaseAction):
@ -14,7 +18,7 @@ class TCensecTipoAtoUpdateAction(BaseAction):
Executa a operação de atualização.
Args:
t_censec_tipoato_update_schema (TCensecTipoAtoUpdateSchema):
t_censec_tipoato_update_schema (TCensecTipoAtoUpdateSchema):
O esquema com os dados a serem atualizados.
Returns:
@ -28,7 +32,9 @@ class TCensecTipoAtoUpdateAction(BaseAction):
# ----------------------------------------------------
# Execução do repositório
# ----------------------------------------------------
response = t_censec_tipoato_update_repository.execute(t_censec_tipoato_update_schema)
response = t_censec_tipoato_update_repository.execute(
t_censec_tipoato_update_schema
)
# ----------------------------------------------------
# Retorno do resultado

10
packages/v1/administrativo/actions/t_imovel/t_imovel_delete_action.py
View file

@ -1,6 +1,10 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.t_imovel.t_imovel_delete_repository import TImovelDeleteRepository
from api.packages.v1.administrativo.schemas.t_imovel_schema import TImovelIdSchema
from packages.v1.administrativo.repositories.t_imovel.t_imovel_delete_repository import (
TImovelDeleteRepository,
)
from packages.v1.administrativo.schemas.t_imovel_schema import TImovelIdSchema
class TImovelDeleteAction(BaseAction):
"""
Serviço responsável por encapsular a lógica de negócio para a operação
@ -23,4 +27,4 @@ class TImovelDeleteAction(BaseAction):
# Execução do repositório
response = t_imovel_delete_repository.execute(t_imovel_id_schema)
return response
return response

9
packages/v1/administrativo/actions/t_imovel/t_imovel_index_action.py
View file

@ -1,6 +1,9 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.t_imovel.t_imovel_index_repository import TImovelIndexRepository
from api.packages.v1.administrativo.schemas.t_imovel_schema import TImovelIndexSchema
from packages.v1.administrativo.repositories.t_imovel.t_imovel_index_repository import (
TImovelIndexRepository,
)
from packages.v1.administrativo.schemas.t_imovel_schema import TImovelIndexSchema
class TImovelIndexAction(BaseAction):
"""
@ -22,4 +25,4 @@ class TImovelIndexAction(BaseAction):
response = t_imovel_index_repositoy.execute(t_imovel_index_schema)
# Retorno da informação
return response
return response

9
packages/v1/administrativo/actions/t_imovel/t_imovel_save_action.py
View file

@ -1,6 +1,9 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.t_imovel.t_imovel_save_repository import TImovelSaveRepository
from api.packages.v1.administrativo.schemas.t_imovel_schema import TImovelSchema
from packages.v1.administrativo.repositories.t_imovel.t_imovel_save_repository import (
TImovelSaveRepository,
)
from packages.v1.administrativo.schemas.t_imovel_schema import TImovelSchema
class TImovelSaveAction(BaseAction):
"""
@ -25,4 +28,4 @@ class TImovelSaveAction(BaseAction):
response = t_imovel_save_repository.execute(t_imovel_schema)
# Retorno da informação
return response
return response

11
packages/v1/administrativo/actions/t_imovel/t_imovel_show_action.py
View file

@ -1,6 +1,9 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.t_imovel.t_imovel_show_repository import TImovelShowRepository
from api.packages.v1.administrativo.schemas.t_imovel_schema import TImovelIdSchema
from packages.v1.administrativo.repositories.t_imovel.t_imovel_show_repository import (
TImovelShowRepository,
)
from packages.v1.administrativo.schemas.t_imovel_schema import TImovelIdSchema
class TImovelShowAction(BaseAction):
"""
@ -11,7 +14,7 @@ class TImovelShowAction(BaseAction):
def execute(self, t_imovel_id_schema: TImovelIdSchema):
"""
Executa a operação de exibição.
Args:
t_imovel_schema (TCensecQualidadeIdSchema): O esquema com o ID do registro a ser exibido.
@ -25,4 +28,4 @@ class TImovelShowAction(BaseAction):
response = t_imovel_show_repository.execute(t_imovel_id_schema)
# Retorno da informação
return response
return response

8
packages/v1/administrativo/actions/t_imovel/t_imovel_update_action.py
View file

@ -1,6 +1,8 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.t_imovel.t_imovel_update_repository import TImovelUpdateRepository
from api.packages.v1.administrativo.schemas.t_imovel_schema import TImovelUpdateSchema
from packages.v1.administrativo.repositories.t_imovel.t_imovel_update_repository import (
TImovelUpdateRepository,
)
from packages.v1.administrativo.schemas.t_imovel_schema import TImovelUpdateSchema
class TImovelUpdateAction(BaseAction):
@ -24,4 +26,4 @@ class TImovelUpdateAction(BaseAction):
t_imovel_update_repository = TImovelUpdateRepository()
# Chama o método de execução do repositório para realizar a atualização
return t_imovel_update_repository.execute(t_imovel_update_schema)
return t_imovel_update_repository.execute(t_imovel_update_schema)

10
packages/v1/administrativo/actions/t_imovel_unidade/t_imovel_unidade_delete_action.py
View file

@ -1,6 +1,10 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.t_imovel_unidade.t_imovel_unidade_delete_repository import TImovelUnidadeDeleteRepository
from packages.v1.administrativo.schemas.t_imovel_unidade_schema import TImovelUnidadeSchema
from packages.v1.administrativo.repositories.t_imovel_unidade.t_imovel_unidade_delete_repository import (
TImovelUnidadeDeleteRepository,
)
from packages.v1.administrativo.schemas.t_imovel_unidade_schema import (
TImovelUnidadeSchema,
)
class TImovelUnidadeDeleteAction(BaseAction):
@ -23,4 +27,4 @@ class TImovelUnidadeDeleteAction(BaseAction):
t_imovel_unidade_delete_repository = TImovelUnidadeDeleteRepository()
# Execução do repositório
return t_imovel_unidade_delete_repository.execute(t_imovel_unidade_id_schema)
return t_imovel_unidade_delete_repository.execute(t_imovel_unidade_id_schema)

11
packages/v1/administrativo/actions/t_imovel_unidade/t_imovel_unidade_index_action.py
View file

@ -1,6 +1,11 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.t_imovel_unidade.t_imovel_unidade_index_repository import TImovelUnidadeIndexRepository
from api.packages.v1.administrativo.schemas.t_imovel_unidade_schema import TImovelUnidadeIndexSchema
from packages.v1.administrativo.repositories.t_imovel_unidade.t_imovel_unidade_index_repository import (
TImovelUnidadeIndexRepository,
)
from packages.v1.administrativo.schemas.t_imovel_unidade_schema import (
TImovelUnidadeIndexSchema,
)
class TImovelUnidadeIndexAction(BaseAction):
"""
@ -22,4 +27,4 @@ class TImovelUnidadeIndexAction(BaseAction):
response = index_repository.execute(t_imovel_unidade_index_schema)
# Retorno da informação
return response
return response

15
packages/v1/administrativo/actions/t_imovel_unidade/t_imovel_unidade_save_action.py
View file

@ -1,6 +1,11 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.t_imovel_unidade.t_imovel_unidade_save_repository import TImovelUnidadeSaveRepository
from api.packages.v1.administrativo.schemas.t_imovel_unidade_schema import TImovelUnidadeSaveSchema
from packages.v1.administrativo.repositories.t_imovel_unidade.t_imovel_unidade_save_repository import (
TImovelUnidadeSaveRepository,
)
from packages.v1.administrativo.schemas.t_imovel_unidade_schema import (
TImovelUnidadeSaveSchema,
)
class TImovelUnidadeSaveAction(BaseAction):
"""
@ -22,7 +27,9 @@ class TImovelUnidadeSaveAction(BaseAction):
t_imovel_unidade_save_repository = TImovelUnidadeSaveRepository()
# Execução do repositório
response = t_imovel_unidade_save_repository.execute(t_imovel_unidade_save_schema)
response = t_imovel_unidade_save_repository.execute(
t_imovel_unidade_save_schema
)
# Retorno da informação
return response
return response

13
packages/v1/administrativo/actions/t_imovel_unidade/t_imovel_unidade_show_action.py
View file

@ -1,6 +1,11 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.t_imovel_unidade.t_imovel_unidade_show_repository import TImovelUnidadeShowRepository
from api.packages.v1.administrativo.schemas.t_imovel_unidade_schema import TImovelUnidadeIdSchema
from packages.v1.administrativo.repositories.t_imovel_unidade.t_imovel_unidade_show_repository import (
TImovelUnidadeShowRepository,
)
from packages.v1.administrativo.schemas.t_imovel_unidade_schema import (
TImovelUnidadeIdSchema,
)
class TImovelUnidadeShowAction(BaseAction):
"""
@ -11,7 +16,7 @@ class TImovelUnidadeShowAction(BaseAction):
def execute(self, t_imovel_unidade_id_schema: TImovelUnidadeIdSchema):
"""
Executa a operação de exibição.
Args:
t_imovel_unidade_schema (TCensecQualidadeIdSchema): O esquema com o ID do registro a ser exibido.
@ -25,4 +30,4 @@ class TImovelUnidadeShowAction(BaseAction):
response = t_imovel_unidade_show_repository.execute(t_imovel_unidade_id_schema)
# Retorno da informação
return response
return response

12
packages/v1/administrativo/actions/t_imovel_unidade/t_imovel_unidade_update_action.py
View file

@ -1,6 +1,10 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.t_imovel_unidade.t_imovel_unidade_update_repository import TImovelUnidadeUpdateRepository
from api.packages.v1.administrativo.schemas.t_imovel_unidade_schema import TImovelUnidadeUpdateSchema
from packages.v1.administrativo.repositories.t_imovel_unidade.t_imovel_unidade_update_repository import (
TImovelUnidadeUpdateRepository,
)
from packages.v1.administrativo.schemas.t_imovel_unidade_schema import (
TImovelUnidadeUpdateSchema,
)
class TImovelUnidadeUpdateAction(BaseAction):
@ -24,4 +28,6 @@ class TImovelUnidadeUpdateAction(BaseAction):
t_imovel_unidade_update_repository = TImovelUnidadeUpdateRepository()
# Chama o método de execução do repositório para realizar a atualização
return t_imovel_unidade_update_repository.execute(t_imovel_unidade_update_schema)
return t_imovel_unidade_update_repository.execute(
t_imovel_unidade_update_schema
)

8
packages/v1/administrativo/actions/t_pessoa/t_pessoa_charts_cidades_action.py
View file

@ -1,6 +1,8 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.t_pessoa.t_pessoa_delete_repository import TPessoaDeleteRepository
from api.packages.v1.administrativo.schemas.t_pessoa_schema import TPessoaIdSchema
from packages.v1.administrativo.repositories.t_pessoa.t_pessoa_delete_repository import (
TPessoaDeleteRepository,
)
from packages.v1.administrativo.schemas.t_pessoa_schema import TPessoaIdSchema
class TPessoaDeleteAction(BaseAction):
@ -23,4 +25,4 @@ class TPessoaDeleteAction(BaseAction):
t_pessoa_delete_repository = TPessoaDeleteRepository()
# Execução do repositório
return t_pessoa_delete_repository.execute(t_pessoa_id_schema)
return t_pessoa_delete_repository.execute(t_pessoa_id_schema)

8
packages/v1/administrativo/actions/t_pessoa/t_pessoa_delete_action.py
View file

@ -1,6 +1,8 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.t_pessoa.t_pessoa_delete_repository import TPessoaDeleteRepository
from api.packages.v1.administrativo.schemas.t_pessoa_schema import TPessoaIdSchema
from packages.v1.administrativo.repositories.t_pessoa.t_pessoa_delete_repository import (
TPessoaDeleteRepository,
)
from packages.v1.administrativo.schemas.t_pessoa_schema import TPessoaIdSchema
class TPessoaDeleteAction(BaseAction):
@ -23,4 +25,4 @@ class TPessoaDeleteAction(BaseAction):
t_pessoa_delete_repository = TPessoaDeleteRepository()
# Execução do repositório
return t_pessoa_delete_repository.execute(t_pessoa_id_schema)
return t_pessoa_delete_repository.execute(t_pessoa_id_schema)

5
packages/v1/administrativo/actions/t_pessoa/t_pessoa_get_by_name_action.py
View file

@ -1,5 +1,6 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.schemas.t_pessoa_schema import TPessoaNameSchema
from packages.v1.administrativo.schemas.t_pessoa_schema import TPessoaNameSchema
class TPessoaGetByNameAction(BaseAction):
"""
@ -24,4 +25,4 @@ class TPessoaGetByNameAction(BaseAction):
response = t_pessoa_get_by_name.execute(t_pessoa_name_schema)
# Retorno da informação
return response
return response

11
packages/v1/administrativo/actions/t_pessoa/t_pessoa_index_action.py
View file

@ -1,7 +1,10 @@
from api.packages.v1.administrativo.repositories.t_pessoa.t_pessoa_index_repository import TPessoaIndexRepository
from api.packages.v1.administrativo.schemas.t_pessoa_schema import TPessoaTipoSchema
from packages.v1.administrativo.repositories.t_pessoa.t_pessoa_index_repository import (
TPessoaIndexRepository,
)
from packages.v1.administrativo.schemas.t_pessoa_schema import TPessoaTipoSchema
class TPessoaIndexAction():
class TPessoaIndexAction:
"""
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_tb_regimebens.
@ -21,4 +24,4 @@ class TPessoaIndexAction():
response = t_pessoa_index_repository.execute(t_pessoa_tipo_schema)
# Retorno da informação
return response
return response

11
packages/v1/administrativo/actions/t_pessoa/t_pessoa_save_action.py
View file

@ -1,6 +1,9 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.t_pessoa.t_pessoa_save_repository import TPessoaSaveRepository
from api.packages.v1.administrativo.schemas.t_pessoa_schema import TPessoaSaveSchema
from packages.v1.administrativo.repositories.t_pessoa.t_pessoa_save_repository import (
TPessoaSaveRepository,
)
from packages.v1.administrativo.schemas.t_pessoa_schema import TPessoaSaveSchema
class TPessoaSaveAction(BaseAction):
"""
@ -11,7 +14,7 @@ class TPessoaSaveAction(BaseAction):
def execute(self, t_pessoa_save_schema: TPessoaSaveSchema):
"""
Executa a operação de salvamento.
Args:
regimebens_schema (GTbRegimebensSaveSchema): O esquema com os dados a serem salvos.
@ -25,4 +28,4 @@ class TPessoaSaveAction(BaseAction):
response = t_pessoa_save_repository.execute(t_pessoa_save_schema)
# Retorno da informação
return response
return response

11
packages/v1/administrativo/actions/t_pessoa/t_pessoa_show_action.py
View file

@ -1,6 +1,9 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.t_pessoa.t_pessoa_show_repository import TPessoaShowRepository
from api.packages.v1.administrativo.schemas.t_pessoa_schema import TPessoaIdSchema
from packages.v1.administrativo.repositories.t_pessoa.t_pessoa_show_repository import (
TPessoaShowRepository,
)
from packages.v1.administrativo.schemas.t_pessoa_schema import TPessoaIdSchema
class TPessoaShowAction(BaseAction):
"""
@ -11,7 +14,7 @@ class TPessoaShowAction(BaseAction):
def execute(self, t_pessoa_id_schema: TPessoaIdSchema):
"""
Executa a operação de exibição.
Args:
regimebens_schema (GTbRegimebensIdSchema): O esquema com o ID do registro a ser exibido.
@ -25,4 +28,4 @@ class TPessoaShowAction(BaseAction):
response = t_pessoa_show_repository.execute(t_pessoa_id_schema)
# Retorno da informação
return response
return response

14
packages/v1/administrativo/actions/t_pessoa/t_pessoa_update_action.py
View file

@ -1,11 +1,13 @@
from api.packages.v1.administrativo.repositories.t_pessoa.t_pessoa_update_repository import TPessoaUpdateRepository
from api.packages.v1.administrativo.schemas.t_pessoa_schema import TPessoaUpdateSchema
from packages.v1.administrativo.repositories.t_pessoa.t_pessoa_update_repository import (
TPessoaUpdateRepository,
)
from packages.v1.administrativo.schemas.t_pessoa_schema import TPessoaUpdateSchema
class TPessoaUpdateAction:
"""
Service responsável por encapsular a lógica de negócio para a atualização
de um registro na tabela g_tb_regimebens.
Service responsável por encapsular a lógica de negócio para a atualização
de um registro na tabela g_tb_regimebens.
"""
def execute(self, t_pessoa_update_schema: TPessoaUpdateSchema):
@ -17,9 +19,9 @@ class TPessoaUpdateAction:
Returns:
O resultado da operação de atualização.
"""
"""
# Instância o repositório de atualização
t_pessoa_update_repository = TPessoaUpdateRepository()
# Chama o método de execução do repositório para realizar a atualização
return t_pessoa_update_repository.execute(t_pessoa_update_schema)
return t_pessoa_update_repository.execute(t_pessoa_update_schema)

16
packages/v1/administrativo/actions/t_pessoa_representante/t_pessoa_representante_delete_action.py
View file

@ -1,6 +1,10 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.t_pessoa_representante.t_pessoa_representante_delete_repository import TPessoaRepresentanteDeleteRepository
from api.packages.v1.administrativo.schemas.t_pessoa_representante_schema import TPessoaRepresentanteIdSchema
from packages.v1.administrativo.repositories.t_pessoa_representante.t_pessoa_representante_delete_repository import (
TPessoaRepresentanteDeleteRepository,
)
from packages.v1.administrativo.schemas.t_pessoa_representante_schema import (
TPessoaRepresentanteIdSchema,
)
class TPessoaRepresentanteDeleteAction(BaseAction):
@ -20,7 +24,11 @@ class TPessoaRepresentanteDeleteAction(BaseAction):
O resultado da operação de exclusão.
"""
# Instanciamento do repositório
t_pessoa_representante_delete_repository = TPessoaRepresentanteDeleteRepository()
t_pessoa_representante_delete_repository = (
TPessoaRepresentanteDeleteRepository()
)
# Execução do repositório
return t_pessoa_representante_delete_repository.execute(t_pessoa_representante_id_schema)
return t_pessoa_representante_delete_repository.execute(
t_pessoa_representante_id_schema
)

19
packages/v1/administrativo/actions/t_pessoa_representante/t_pessoa_representante_index_action.py
View file

@ -1,6 +1,10 @@
from api.abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.t_pessoa_representante.t_pessoa_representante_index_repository import TPessoaRepresentanteIndexRepository
from api.packages.v1.administrativo.schemas.t_pessoa_representante_schema import TPessoaRepresentantePessoaIdSchema
from packages.v1.administrativo.repositories.t_pessoa_representante.t_pessoa_representante_index_repository import (
TPessoaRepresentanteIndexRepository,
)
from packages.v1.administrativo.schemas.t_pessoa_representante_schema import (
TPessoaRepresentantePessoaIdSchema,
)
class TPessoaRepresentanteIndexAction(BaseAction):
@ -9,7 +13,10 @@ class TPessoaRepresentanteIndexAction(BaseAction):
de listagem de todos os registros na tabela g_tb_regimebens.
"""
def execute(self, t_pessoa_representante_pessoa_id_schema: TPessoaRepresentantePessoaIdSchema):
def execute(
self,
t_pessoa_representante_pessoa_id_schema: TPessoaRepresentantePessoaIdSchema,
):
"""
Executa a operação de listagem no banco de dados.
@ -20,7 +27,9 @@ class TPessoaRepresentanteIndexAction(BaseAction):
t_pessoa_representante_index_repository = TPessoaRepresentanteIndexRepository()
# Execução do repositório
response = t_pessoa_representante_index_repository.execute(t_pessoa_representante_pessoa_id_schema)
response = t_pessoa_representante_index_repository.execute(
t_pessoa_representante_pessoa_id_schema
)
# Retorno da informação
return response
return response

21
packages/v1/administrativo/actions/t_pessoa_representante/t_pessoa_representante_save_action.py
View file

@ -1,6 +1,11 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.t_pessoa_representante.t_pessoa_representante_save_repository import TPessoaRepresentanteSaveRepository
from api.packages.v1.administrativo.schemas.t_pessoa_representante_schema import TPessoaRepresentanteSaveSchema
from packages.v1.administrativo.repositories.t_pessoa_representante.t_pessoa_representante_save_repository import (
TPessoaRepresentanteSaveRepository,
)
from packages.v1.administrativo.schemas.t_pessoa_representante_schema import (
TPessoaRepresentanteSaveSchema,
)
class TPessoaRepresentanteSaveAction(BaseAction):
"""
@ -8,10 +13,12 @@ class TPessoaRepresentanteSaveAction(BaseAction):
de salvar um novo registro na tabela g_tb_regimebens.
"""
def execute(self, t_pessoa_representante_save_schema: TPessoaRepresentanteSaveSchema):
def execute(
self, t_pessoa_representante_save_schema: TPessoaRepresentanteSaveSchema
):
"""
Executa a operação de salvamento.
Args:
regimebens_schema (GTbRegimebensSaveSchema): O esquema com os dados a serem salvos.
@ -22,7 +29,9 @@ class TPessoaRepresentanteSaveAction(BaseAction):
t_pessoa_representante_save_repository = TPessoaRepresentanteSaveRepository()
# Execução do repositório
response = t_pessoa_representante_save_repository.execute(t_pessoa_representante_save_schema)
response = t_pessoa_representante_save_repository.execute(
t_pessoa_representante_save_schema
)
# Retorno da informação
return response
return response

17
packages/v1/administrativo/actions/t_pessoa_representante/t_pessoa_representante_show_action.py
View file

@ -1,6 +1,11 @@
from abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.t_pessoa_representante.t_pessoa_representante_delete_repository import TPessoaRepresentanteIdSchema
from api.packages.v1.administrativo.repositories.t_pessoa_representante.t_pessoa_representante_show_repository import TPessoaRepresentanteShowRepository
from packages.v1.administrativo.repositories.t_pessoa_representante.t_pessoa_representante_delete_repository import (
TPessoaRepresentanteIdSchema,
)
from packages.v1.administrativo.repositories.t_pessoa_representante.t_pessoa_representante_show_repository import (
TPessoaRepresentanteShowRepository,
)
class TPessoaRepresentanteShowAction(BaseAction):
"""
@ -11,7 +16,7 @@ class TPessoaRepresentanteShowAction(BaseAction):
def execute(self, t_pessoa_representante_id_schema: TPessoaRepresentanteIdSchema):
"""
Executa a operação de exibição.
Args:
regimebens_schema (GTbRegimebensIdSchema): O esquema com o ID do registro a ser exibido.
@ -22,7 +27,9 @@ class TPessoaRepresentanteShowAction(BaseAction):
t_pessoa_representante_show_repository = TPessoaRepresentanteShowRepository()
# Execução do repositório
response = t_pessoa_representante_show_repository.execute(t_pessoa_representante_id_schema)
response = t_pessoa_representante_show_repository.execute(
t_pessoa_representante_id_schema
)
# Retorno da informação
return response
return response

22
packages/v1/administrativo/actions/t_pessoa_representante/t_pessoa_representante_update_action.py
View file

@ -1,15 +1,21 @@
from api.abstracts.action import BaseAction
from api.packages.v1.administrativo.repositories.t_pessoa_representante.t_pessoa_representante_update_repository import TPessoaRepresentanteUpdateRepository
from api.packages.v1.administrativo.schemas.t_pessoa_representante_schema import TPessoaRepresentanteUpdateSchema
from packages.v1.administrativo.repositories.t_pessoa_representante.t_pessoa_representante_update_repository import (
TPessoaRepresentanteUpdateRepository,
)
from packages.v1.administrativo.schemas.t_pessoa_representante_schema import (
TPessoaRepresentanteUpdateSchema,
)
class TPessoaRepresentanteUpdateAction(BaseAction):
"""
Service responsável por encapsular a lógica de negócio para a atualização
de um registro na tabela g_tb_regimebens.
Service responsável por encapsular a lógica de negócio para a atualização
de um registro na tabela g_tb_regimebens.
"""
def execute(self, t_pessoa_representanteupdate_schema: TPessoaRepresentanteUpdateSchema):
def execute(
self, t_pessoa_representanteupdate_schema: TPessoaRepresentanteUpdateSchema
):
"""
Executa a operação de atualização.
@ -18,9 +24,11 @@ class TPessoaRepresentanteUpdateAction(BaseAction):
Returns:
O resultado da operação de atualização.
"""
"""
# Instância o repositório de atualização
t_pessoa_representanteupdate_repository = TPessoaRepresentanteUpdateRepository()
# Chama o método de execução do repositório para realizar a atualização
return t_pessoa_representanteupdate_repository.execute(t_pessoa_representanteupdate_schema)
return t_pessoa_representanteupdate_repository.execute(
t_pessoa_representanteupdate_schema
)

154
packages/v1/administrativo/controllers/g_usuario_controller.py
View file

@ -7,9 +7,10 @@ from packages.v1.administrativo.schemas.g_usuario_schema import (
GUsuarioEmailSchema,
GUsuarioCpfSchema,
GUsuarioLoginSchema,
GUsuarioIdSchema
GUsuarioIdSchema,
)
class GUsuarioController:
def __init__(self):
@ -24,22 +25,26 @@ class GUsuarioController:
pass
# Efetua o acesso junto ao sistema por um determinado usuário
def authenticate(self, g_usuario_authenticate_schema : GUsuarioAuthenticateSchema):
def authenticate(self, g_usuario_authenticate_schema: GUsuarioAuthenticateSchema):
# Importação de service de Authenticate
authenticate_service = self.dynamic_import.service("g_usuario_authenticate_service", "AuthenticateService")
authenticate_service = self.dynamic_import.service(
"g_usuario_authenticate_service", "AuthenticateService"
)
# Instânciamento da service
self.authenticate_service = authenticate_service()
# Retorna o usuário logado
return {
'message' : 'Usuário localizado com sucesso',
'data' : {
'token' : self.authenticate_service.execute(g_usuario_authenticate_schema)
}
"message": "Usuário localizado com sucesso",
"data": {
"token": self.authenticate_service.execute(
g_usuario_authenticate_schema
)
},
}
# Carrega os dados do usuário logado
def me(self, current_user):
@ -51,129 +56,148 @@ class GUsuarioController:
# Retorna o usuário logado
return {
'message' : 'Usuário localizado com sucesso',
'data' : self.me_service.execute(current_user)
"message": "Usuário localizado com sucesso",
"data": self.me_service.execute(current_user),
}
# Lista todos os usuários
def index(self):
# Importação da classe desejada
indexService = self.dynamic_import.service("g_usuario_index_service", "IndexService")
indexService = self.dynamic_import.service(
"g_usuario_index_service", "IndexService"
)
# Instânciamento da classe service
self.indexService = indexService()
# Lista todos os usuários
return {
'message': 'Usuários localizados com sucesso',
'data': self.indexService.execute()
"message": "Usuários localizados com sucesso",
"data": self.indexService.execute(),
}
# Busca um usuário especifico pelo ID
def show(self, usuario_schema : GUsuarioSchema):
#Importação da classe desejada
show_service = self.dynamic_import.service('g_usuario_show_service', 'ShowService')
# Busca um usuário especifico pelo ID
def show(self, usuario_schema: GUsuarioSchema):
# Importação da classe desejada
show_service = self.dynamic_import.service(
"g_usuario_show_service", "ShowService"
)
# Instânciamento da classe desejada
self.show_service = show_service()
# Busca e retorna o usuário desejado
return {
'message' : 'Usuário localizado com sucesso',
'data': self.show_service.execute(usuario_schema)
"message": "Usuário localizado com sucesso",
"data": self.show_service.execute(usuario_schema),
}
# Busca um usuário especifico pelo e-mail
def getEmail(self, usuario_schema : GUsuarioEmailSchema):
# Busca um usuário especifico pelo e-mail
def getEmail(self, usuario_schema: GUsuarioEmailSchema):
#Importação da classe desejada
get_email_service = self.dynamic_import.service('g_usuario_get_email_service', 'GetEmailService')
# Importação da classe desejada
get_email_service = self.dynamic_import.service(
"g_usuario_get_email_service", "GetEmailService"
)
# Instânciamento da classe desejada
self.get_email_service = get_email_service()
# Busca e retorna o usuário desejado
return {
'message' : 'E-mail localizado com sucesso',
'data': self.get_email_service.execute(usuario_schema, True) # True para retornar a mensagem de erro caso não localize o usuario
}
"message": "E-mail localizado com sucesso",
"data": self.get_email_service.execute(
usuario_schema, True
), # True para retornar a mensagem de erro caso não localize o usuario
}
# Busca um usuário especifico pelo e-mail
def getLogin(self, usuario_schema : GUsuarioLoginSchema):
# Busca um usuário especifico pelo e-mail
def getLogin(self, usuario_schema: GUsuarioLoginSchema):
#Importação da classe desejada
get_login_service = self.dynamic_import.service('g_usuario_get_login_service', 'GetLoginService')
# Importação da classe desejada
get_login_service = self.dynamic_import.service(
"g_usuario_get_login_service", "GetLoginService"
)
# Instânciamento da classe desejada
self.get_login_service = get_login_service()
# Busca e retorna o usuário desejado
return {
'message' : 'Login localizado com sucesso',
'data': self.get_login_service.execute(usuario_schema, True) # True para retornar a mensagem de erro caso não localize o usuario
}
"message": "Login localizado com sucesso",
"data": self.get_login_service.execute(
usuario_schema, True
), # True para retornar a mensagem de erro caso não localize o usuario
}
# Busca um usuário especifico pelo CPF
def getCpf(self, usuario_schema: GUsuarioCpfSchema):
# Busca um usuário especifico pelo CPF
def getCpf(self, usuario_schema : GUsuarioCpfSchema):
#Importação da classe desejada
get_cpf_service = self.dynamic_import.service('g_usuario_get_cpf_service', 'GetCpfService')
# Importação da classe desejada
get_cpf_service = self.dynamic_import.service(
"g_usuario_get_cpf_service", "GetCpfService"
)
# Instânciamento da classe desejada
self.get_cpf_service = get_cpf_service()
# Busca e retorna o usuário desejado
return {
'message' : 'CPF localizado com sucesso',
'data': self.get_cpf_service.execute(usuario_schema, True) # True para retornar a mensagem de erro caso não localize o usuario
}
"message": "CPF localizado com sucesso",
"data": self.get_cpf_service.execute(
usuario_schema, True
), # True para retornar a mensagem de erro caso não localize o usuario
}
# Cadastra um novo usuário
def save(self, usuario_schema : GUsuarioSaveSchema):
def save(self, usuario_schema: GUsuarioSaveSchema):
#Importação da classe desejada
save_service = self.dynamic_import.service('g_usuario_save_service', 'GUsuarioSaveService')
# Importação da classe desejada
save_service = self.dynamic_import.service(
"g_usuario_save_service", "GUsuarioSaveService"
)
# Instânciamento da classe desejada
self.save_service = save_service()
# Busca e retorna o usuário desejado
return {
'message' : 'Usuário salvo com sucesso',
'data': self.save_service.execute(usuario_schema)
"message": "Usuário salvo com sucesso",
"data": self.save_service.execute(usuario_schema),
}
# Atualiza os dados de um usuário
def update(self, usuario_id: int, usuario_schema : GUsuarioUpdateSchema):
def update(self, usuario_id: int, usuario_schema: GUsuarioUpdateSchema):
#Importação da classe desejada
save_service = self.dynamic_import.service('g_usuario_update_service', 'GUsuarioUpdateService')
# Importação da classe desejada
save_service = self.dynamic_import.service(
"g_usuario_update_service", "GUsuarioUpdateService"
)
# Instânciamento da classe desejada
self.save_service = save_service()
# Busca e retorna o usuário desejado
return {
'message' : 'Usuário atualizado com sucesso',
'data': self.save_service.execute(usuario_id, usuario_schema)
"message": "Usuário atualizado com sucesso",
"data": self.save_service.execute(usuario_id, usuario_schema),
}
# Exclui um usuário
def delete(self, usuario_schema : GUsuarioIdSchema):
#Importação da classe desejada
delete_service = self.dynamic_import.service('g_usuario_delete_service', 'DeleteService')
# Exclui um usuário
def delete(self, usuario_schema: GUsuarioIdSchema):
# Importação da classe desejada
delete_service = self.dynamic_import.service(
"g_usuario_delete_service", "DeleteService"
)
# Instânciamento da classe desejada
self.delete_service = delete_service()
# Busca e retorna o usuário desejado
return {
'message' : 'Usuário removido com sucesso',
'data': self.delete_service.execute(usuario_schema)
}
"message": "Usuário removido com sucesso",
"data": self.delete_service.execute(usuario_schema),
}

104
packages/v1/administrativo/controllers/t_pessoa_controller.py
View file

@ -1,5 +1,12 @@
from actions.dynamic_import.dynamic_import import DynamicImport
from api.packages.v1.administrativo.schemas.t_pessoa_schema import TPessoaIdSchema, TPessoaNameSchema, TPessoaSaveSchema, TPessoaTipoSchema, TPessoaUpdateSchema
from packages.v1.administrativo.schemas.t_pessoa_schema import (
TPessoaIdSchema,
TPessoaNameSchema,
TPessoaSaveSchema,
TPessoaTipoSchema,
TPessoaUpdateSchema,
)
class TPessoaController:
@ -15,93 +22,102 @@ class TPessoaController:
pass
# Lista todos os regimes de bens
def index(self, t_pessoa_tipo_schema : TPessoaTipoSchema):
def index(self, t_pessoa_tipo_schema: TPessoaTipoSchema):
# Importação da classe desejada
t_pessoa_index_service = self.dynamic_import.service("t_pessoa_index_service", "TPessoaIndexService")
t_pessoa_index_service = self.dynamic_import.service(
"t_pessoa_index_service", "TPessoaIndexService"
)
# Instância da classe service
self.t_pessoa_index_service = t_pessoa_index_service()
# Lista todos os regimes de bens
return {
'message': 'Pessoas localizados com sucesso',
'data': self.t_pessoa_index_service.execute(t_pessoa_tipo_schema)
"message": "Pessoas localizados com sucesso",
"data": self.t_pessoa_index_service.execute(t_pessoa_tipo_schema),
}
# Busca um regime de bens específico pelo ID
def show(self, t_pessoa_id_schema : TPessoaIdSchema):
#Importação da classe desejada
t_pessoa_show_service = self.dynamic_import.service('t_pessoa_show_service', 'TPessoaShowService')
# Busca um regime de bens específico pelo ID
def show(self, t_pessoa_id_schema: TPessoaIdSchema):
# Importação da classe desejada
t_pessoa_show_service = self.dynamic_import.service(
"t_pessoa_show_service", "TPessoaShowService"
)
# Instância da classe desejada
self.t_pessoa_show_service = t_pessoa_show_service()
# Busca e retorna o regime de bens desejado
return {
'message' : 'Pessoa localizado com sucesso',
'data': self.t_pessoa_show_service.execute(t_pessoa_id_schema)
"message": "Pessoa localizado com sucesso",
"data": self.t_pessoa_show_service.execute(t_pessoa_id_schema),
}
# Busca um regime de bens pela descrição
def get_by_nome(self, t_pessoa_name_schema : TPessoaNameSchema):
def get_by_nome(self, t_pessoa_name_schema: TPessoaNameSchema):
#Importação da classe desejada
t_pessoa_show_service = self.dynamic_import.service('t_pessoa_show_service', 'TPessoaShowService')
# Importação da classe desejada
t_pessoa_show_service = self.dynamic_import.service(
"t_pessoa_show_service", "TPessoaShowService"
)
# Instância da classe desejada
self.t_pessoa_show_service = t_pessoa_show_service()
# Busca e retorna o regime de bens desejado
return {
'message' : 'Pessoa localizado com sucesso',
'data': self.t_pessoa_show_service.execute(regimebens_schema, True)
}
# Cadastra um novo regime de bens
def save(self, t_pessoa_save_schema : TPessoaSaveSchema):
"message": "Pessoa localizado com sucesso",
"data": self.t_pessoa_show_service.execute(regimebens_schema, True),
}
#Importação da classe desejada
t_pessoa_save_service = self.dynamic_import.service('t_pessoa_save_service', 'TPessoaSaveService')
# Cadastra um novo regime de bens
def save(self, t_pessoa_save_schema: TPessoaSaveSchema):
# Importação da classe desejada
t_pessoa_save_service = self.dynamic_import.service(
"t_pessoa_save_service", "TPessoaSaveService"
)
# Instância da classe desejada
self.t_pessoa_save_service = t_pessoa_save_service()
# Busca e retorna o regime de bens desejado
return {
'message' : 'Pessoa salvo com sucesso',
'data': self.t_pessoa_save_service.execute(t_pessoa_save_schema)
"message": "Pessoa salvo com sucesso",
"data": self.t_pessoa_save_service.execute(t_pessoa_save_schema),
}
# Atualiza os dados de um regime de bens
def update(self, t_pessoa_update_schame : TPessoaUpdateSchema):
#Importação da classe desejada
t_pessoa_update_service = self.dynamic_import.service('t_pessoa_update_service', 'TPessoaUpdateService')
# Atualiza os dados de um regime de bens
def update(self, t_pessoa_update_schame: TPessoaUpdateSchema):
# Importação da classe desejada
t_pessoa_update_service = self.dynamic_import.service(
"t_pessoa_update_service", "TPessoaUpdateService"
)
# Instância da classe desejada
self.t_pessoa_update_service = t_pessoa_update_service()
# Busca e retorna o regime de bens desejado
return {
'message' : 'Pessoa atualizado com sucesso',
'data': self.t_pessoa_update_service.execute(t_pessoa_update_schame)
"message": "Pessoa atualizado com sucesso",
"data": self.t_pessoa_update_service.execute(t_pessoa_update_schame),
}
# Exclui um regime de bens
def delete(self, t_pessoa_id_schema : TPessoaIdSchema):
#Importação da classe desejada
t_pessoa_delete_service = self.dynamic_import.service('t_pessoa_delete_service', 'TPessoaDeleteService')
# Exclui um regime de bens
def delete(self, t_pessoa_id_schema: TPessoaIdSchema):
# Importação da classe desejada
t_pessoa_delete_service = self.dynamic_import.service(
"t_pessoa_delete_service", "TPessoaDeleteService"
)
# Instância da classe desejada
self.t_pessoa_delete_service = t_pessoa_delete_service()
# Busca e retorna o regime de bens desejado
return {
'message' : 'Pessoa removido com sucesso',
'data': self.t_pessoa_delete_service.execute(t_pessoa_id_schema)
}
"message": "Pessoa removido com sucesso",
"data": self.t_pessoa_delete_service.execute(t_pessoa_id_schema),
}

114
packages/v1/administrativo/controllers/t_pessoa_representante_controller.py
View file

@ -1,5 +1,11 @@
from actions.dynamic_import.dynamic_import import DynamicImport
from api.packages.v1.administrativo.schemas.t_pessoa_representante_schema import TPessoaRepresentanteIdSchema, TPessoaRepresentantePessoaIdSchema, TPessoaRepresentanteSaveSchema, TPessoaRepresentanteUpdateSchema
from packages.v1.administrativo.schemas.t_pessoa_representante_schema import (
TPessoaRepresentanteIdSchema,
TPessoaRepresentantePessoaIdSchema,
TPessoaRepresentanteSaveSchema,
TPessoaRepresentanteUpdateSchema,
)
class TPessoaRepresentanteController:
@ -15,76 +21,106 @@ class TPessoaRepresentanteController:
pass
# Lista todos os regimes de bens
def index(self, t_pessoa_representante_pessoa_id_schema : TPessoaRepresentantePessoaIdSchema):
def index(
self,
t_pessoa_representante_pessoa_id_schema: TPessoaRepresentantePessoaIdSchema,
):
# Importação da classe desejada
t_pessoa_representante_index_service = self.dynamic_import.service("t_pessoa_representante_index_service", "TPessoaRepresentanteIndexService")
t_pessoa_representante_index_service = self.dynamic_import.service(
"t_pessoa_representante_index_service", "TPessoaRepresentanteIndexService"
)
# Instância da classe service
self.t_pessoa_representante_index_service = t_pessoa_representante_index_service()
self.t_pessoa_representante_index_service = (
t_pessoa_representante_index_service()
)
# Lista todos os regimes de bens
return {
'message': 'Pessoas localizados com sucesso',
'data': self.t_pessoa_representante_index_service.execute(t_pessoa_representante_pessoa_id_schema)
"message": "Pessoas localizados com sucesso",
"data": self.t_pessoa_representante_index_service.execute(
t_pessoa_representante_pessoa_id_schema
),
}
# Busca um regime de bens específico pelo ID
def show(self, t_pessoa_representante_id_schema : TPessoaRepresentanteIdSchema):
#Importação da classe desejada
t_pessoa_representante_show_service = self.dynamic_import.service('t_pessoa_representante_show_service', 'TPessoaRepresentanteShowService')
# Busca um regime de bens específico pelo ID
def show(self, t_pessoa_representante_id_schema: TPessoaRepresentanteIdSchema):
# Importação da classe desejada
t_pessoa_representante_show_service = self.dynamic_import.service(
"t_pessoa_representante_show_service", "TPessoaRepresentanteShowService"
)
# Instância da classe desejada
self.t_pessoa_representante_show_service = t_pessoa_representante_show_service()
# Busca e retorna o regime de bens desejado
return {
'message' : 'Pessoa localizado com sucesso',
'data': self.t_pessoa_representante_show_service.execute(t_pessoa_representante_id_schema)
}
# Cadastra um novo regime de bens
def save(self, t_pessoa_representante_save_schema : TPessoaRepresentanteSaveSchema):
"message": "Pessoa localizado com sucesso",
"data": self.t_pessoa_representante_show_service.execute(
t_pessoa_representante_id_schema
),
}
#Importação da classe desejada
t_pessoa_representante_save_service = self.dynamic_import.service('t_pessoa_representante_save_service', 'TPessoaRepresentanteSaveService')
# Cadastra um novo regime de bens
def save(self, t_pessoa_representante_save_schema: TPessoaRepresentanteSaveSchema):
# Importação da classe desejada
t_pessoa_representante_save_service = self.dynamic_import.service(
"t_pessoa_representante_save_service", "TPessoaRepresentanteSaveService"
)
# Instância da classe desejada
self.t_pessoa_representante_save_service = t_pessoa_representante_save_service()
# Busca e retorna o regime de bens desejado
return {
'message' : 'Pessoa salvo com sucesso',
'data': self.t_pessoa_representante_save_service.execute(t_pessoa_representante_save_schema)
"message": "Pessoa salvo com sucesso",
"data": self.t_pessoa_representante_save_service.execute(
t_pessoa_representante_save_schema
),
}
# Atualiza os dados de um regime de bens
def update(self, t_pessoa_representante_update_schame : TPessoaRepresentanteUpdateSchema):
def update(
self, t_pessoa_representante_update_schame: TPessoaRepresentanteUpdateSchema
):
#Importação da classe desejada
t_pessoa_representante_update_service = self.dynamic_import.service('t_pessoa_representante_update_service', 'TPessoaRepresentanteUpdateService')
# Importação da classe desejada
t_pessoa_representante_update_service = self.dynamic_import.service(
"t_pessoa_representante_update_service", "TPessoaRepresentanteUpdateService"
)
# Instância da classe desejada
self.t_pessoa_representante_update_service = t_pessoa_representante_update_service()
self.t_pessoa_representante_update_service = (
t_pessoa_representante_update_service()
)
# Busca e retorna o regime de bens desejado
return {
'message' : 'Pessoa atualizado com sucesso',
'data': self.t_pessoa_representante_update_service.execute(t_pessoa_representante_update_schame)
"message": "Pessoa atualizado com sucesso",
"data": self.t_pessoa_representante_update_service.execute(
t_pessoa_representante_update_schame
),
}
# Exclui um regime de bens
def delete(self, t_pessoa_representante_id_schema : TPessoaRepresentanteIdSchema):
#Importação da classe desejada
t_pessoa_representante_delete_service = self.dynamic_import.service('t_pessoa_representante_delete_service', 'TPessoaRepresentanteDeleteService')
# Exclui um regime de bens
def delete(self, t_pessoa_representante_id_schema: TPessoaRepresentanteIdSchema):
# Importação da classe desejada
t_pessoa_representante_delete_service = self.dynamic_import.service(
"t_pessoa_representante_delete_service", "TPessoaRepresentanteDeleteService"
)
# Instância da classe desejada
self.t_pessoa_representante_delete_service = t_pessoa_representante_delete_service()
self.t_pessoa_representante_delete_service = (
t_pessoa_representante_delete_service()
)
# Busca e retorna o regime de bens desejado
return {
'message' : 'Pessoa removido com sucesso',
'data': self.t_pessoa_representante_delete_service.execute(t_pessoa_representante_id_schema)
}
"message": "Pessoa removido com sucesso",
"data": self.t_pessoa_representante_delete_service.execute(
t_pessoa_representante_id_schema
),
}

90
packages/v1/administrativo/endpoints/t_censec_tiponatureza_endpoint.py
View file

@ -1,11 +1,13 @@
# Importação de bibliotecas
from fastapi import APIRouter, Depends, status
from actions.jwt.get_current_user import get_current_user
from api.packages.v1.administrativo.controllers.t_censec_tiponatureza_controller import TCensecTipoNaturezaController
from packages.v1.administrativo.controllers.t_censec_tiponatureza_controller import (
TCensecTipoNaturezaController,
)
from packages.v1.administrativo.schemas.t_censec_tiponatureza_schema import (
TCensecTipoNaturezaSaveSchema,
TCensecTipoNaturezaUpdateSchema,
TCensecTipoNaturezaIdSchema
TCensecTipoNaturezaIdSchema,
)
# ----------------------------------------------------
@ -16,13 +18,16 @@ router = APIRouter()
# Instanciamento do controller
t_censec_tiponatureza_controller = TCensecTipoNaturezaController()
# ----------------------------------------------------
# Lista todos os registros de T_CENSEC_TIPONATUREZA
# ----------------------------------------------------
@router.get('/',
status_code=status.HTTP_200_OK,
summary='Lista todos os registros de T_CENSEC_TIPONATUREZA cadastrados',
response_description='Lista todos os registros de T_CENSEC_TIPONATUREZA cadastrados')
@router.get(
"/",
status_code=status.HTTP_200_OK,
summary="Lista todos os registros de T_CENSEC_TIPONATUREZA cadastrados",
response_description="Lista todos os registros de T_CENSEC_TIPONATUREZA cadastrados",
)
async def index(current_user: dict = Depends(get_current_user)):
"""
Retorna todos os registros da tabela T_CENSEC_TIPONATUREZA.
@ -34,15 +39,21 @@ async def index(current_user: dict = Depends(get_current_user)):
# ----------------------------------------------------
# Busca um registro específico de T_CENSEC_TIPONATUREZA pelo ID
# ----------------------------------------------------
@router.get('/{censec_tiponatureza_id}',
status_code=status.HTTP_200_OK,
summary='Busca um registro de T_CENSEC_TIPONATUREZA pelo ID',
response_description='Busca um registro de T_CENSEC_TIPONATUREZA em específico')
async def show(censec_tiponatureza_id: int, current_user: dict = Depends(get_current_user)):
@router.get(
"/{censec_tiponatureza_id}",
status_code=status.HTTP_200_OK,
summary="Busca um registro de T_CENSEC_TIPONATUREZA pelo ID",
response_description="Busca um registro de T_CENSEC_TIPONATUREZA em específico",
)
async def show(
censec_tiponatureza_id: int, current_user: dict = Depends(get_current_user)
):
"""
Retorna um registro específico de T_CENSEC_TIPONATUREZA com base no ID informado.
"""
t_censec_tiponatureza_id_schema = TCensecTipoNaturezaIdSchema(censec_tiponatureza_id=censec_tiponatureza_id)
t_censec_tiponatureza_id_schema = TCensecTipoNaturezaIdSchema(
censec_tiponatureza_id=censec_tiponatureza_id
)
response = t_censec_tiponatureza_controller.show(t_censec_tiponatureza_id_schema)
return response
@ -50,11 +61,16 @@ async def show(censec_tiponatureza_id: int, current_user: dict = Depends(get_cur
# ----------------------------------------------------
# Cadastra um novo registro em T_CENSEC_TIPONATUREZA
# ----------------------------------------------------
@router.post('/',
status_code=status.HTTP_201_CREATED,
summary='Cadastra um novo registro em T_CENSEC_TIPONATUREZA',
response_description='Cadastra um novo registro em T_CENSEC_TIPONATUREZA')
async def save(t_censec_tiponatureza_schema: TCensecTipoNaturezaSaveSchema, current_user: dict = Depends(get_current_user)):
@router.post(
"/",
status_code=status.HTTP_201_CREATED,
summary="Cadastra um novo registro em T_CENSEC_TIPONATUREZA",
response_description="Cadastra um novo registro em T_CENSEC_TIPONATUREZA",
)
async def save(
t_censec_tiponatureza_schema: TCensecTipoNaturezaSaveSchema,
current_user: dict = Depends(get_current_user),
):
"""
Cria um novo registro na tabela T_CENSEC_TIPONATUREZA.
"""
@ -65,30 +81,44 @@ async def save(t_censec_tiponatureza_schema: TCensecTipoNaturezaSaveSchema, curr
# ----------------------------------------------------
# Atualiza um registro existente de T_CENSEC_TIPONATUREZA
# ----------------------------------------------------
@router.put('/{censec_tiponatureza_id}',
status_code=status.HTTP_200_OK,
summary='Atualiza um registro existente em T_CENSEC_TIPONATUREZA',
response_description='Atualiza um registro existente em T_CENSEC_TIPONATUREZA')
async def update(censec_tiponatureza_id: int, t_censec_tiponatureza_update_schema: TCensecTipoNaturezaUpdateSchema, current_user: dict = Depends(get_current_user)):
@router.put(
"/{censec_tiponatureza_id}",
status_code=status.HTTP_200_OK,
summary="Atualiza um registro existente em T_CENSEC_TIPONATUREZA",
response_description="Atualiza um registro existente em T_CENSEC_TIPONATUREZA",
)
async def update(
censec_tiponatureza_id: int,
t_censec_tiponatureza_update_schema: TCensecTipoNaturezaUpdateSchema,
current_user: dict = Depends(get_current_user),
):
"""
Atualiza um registro existente de T_CENSEC_TIPONATUREZA com base no ID informado.
"""
t_censec_tiponatureza_update_schema.censec_tiponatureza_id = censec_tiponatureza_id
response = t_censec_tiponatureza_controller.update(t_censec_tiponatureza_update_schema)
response = t_censec_tiponatureza_controller.update(
t_censec_tiponatureza_update_schema
)
return response
# ----------------------------------------------------
# Exclui um registro de T_CENSEC_TIPONATUREZA
# ----------------------------------------------------
@router.delete('/{censec_tiponatureza_id}',
status_code=status.HTTP_200_OK,
summary='Remove um registro de T_CENSEC_TIPONATUREZA',
response_description='Remove um registro de T_CENSEC_TIPONATUREZA')
async def delete(censec_tiponatureza_id: int, current_user: dict = Depends(get_current_user)):
@router.delete(
"/{censec_tiponatureza_id}",
status_code=status.HTTP_200_OK,
summary="Remove um registro de T_CENSEC_TIPONATUREZA",
response_description="Remove um registro de T_CENSEC_TIPONATUREZA",
)
async def delete(
censec_tiponatureza_id: int, current_user: dict = Depends(get_current_user)
):
"""
Remove um registro específico de T_CENSEC_TIPONATUREZA com base no ID informado.
"""
t_censec_tiponatureza_id_schema = TCensecTipoNaturezaIdSchema(censec_tiponatureza_id=censec_tiponatureza_id)
t_censec_tiponatureza_id_schema = TCensecTipoNaturezaIdSchema(
censec_tiponatureza_id=censec_tiponatureza_id
)
response = t_censec_tiponatureza_controller.delete(t_censec_tiponatureza_id_schema)
return response
return response

95
packages/v1/administrativo/endpoints/t_pessoa_endpoint.py
View file

@ -1,8 +1,14 @@
# Importação de bibliotecas
from fastapi import APIRouter, Depends, status
from actions.jwt.get_current_user import get_current_user
from api.packages.v1.administrativo.controllers.t_pessoa_controller import TPessoaController
from api.packages.v1.administrativo.schemas.t_pessoa_schema import TPessoaIdSchema, TPessoaNameSchema, TPessoaSaveSchema, TPessoaUpdateSchema, TPessoaTipoSchema
from packages.v1.administrativo.controllers.t_pessoa_controller import TPessoaController
from packages.v1.administrativo.schemas.t_pessoa_schema import (
TPessoaIdSchema,
TPessoaNameSchema,
TPessoaSaveSchema,
TPessoaUpdateSchema,
TPessoaTipoSchema,
)
# Inicializa o roteador para as rotas do regime de bens
router = APIRouter()
@ -10,12 +16,15 @@ router = APIRouter()
# Instânciamento do controller desejado
t_pessoa_controller = TPessoaController()
# Lista todos as pessoas
@router.get('/tipo/{pessoa_tipo}',
status_code=status.HTTP_200_OK,
summary='Lista todos as pessoas cadastrados',
response_description='Lista todos as pessoas cadastrados')
async def index(pessoa_tipo : str, current_user: dict = Depends(get_current_user)):
@router.get(
"/tipo/{pessoa_tipo}",
status_code=status.HTTP_200_OK,
summary="Lista todos as pessoas cadastrados",
response_description="Lista todos as pessoas cadastrados",
)
async def index(pessoa_tipo: str, current_user: dict = Depends(get_current_user)):
# Cria o schema com os dados recebidos
t_pessoa_tipo_schema = TPessoaTipoSchema(pessoa_tipo=pessoa_tipo)
@ -28,11 +37,13 @@ async def index(pessoa_tipo : str, current_user: dict = Depends(get_current_user
# Localiza um regime de bens pela descrição
@router.get('/nome',
status_code=status.HTTP_200_OK,
summary='Busca um registro em específico pelo nome',
response_description='Busca um registro em específico')
async def get_by_nome(nome : str, current_user: dict = Depends(get_current_user)):
@router.get(
"/nome",
status_code=status.HTTP_200_OK,
summary="Busca um registro em específico pelo nome",
response_description="Busca um registro em específico",
)
async def get_by_nome(nome: str, current_user: dict = Depends(get_current_user)):
# Cria o schema com os dados recebidos
t_pessoa_nome_schema = TPessoaNameSchema(nome=nome)
@ -45,11 +56,13 @@ async def get_by_nome(nome : str, current_user: dict = Depends(get_current_user)
# Localiza um regime de bens pelo ID
@router.get('/{pessoa_id}',
status_code=status.HTTP_200_OK,
summary='Busca um registro em específico pelo ID da pessoa',
response_description='Busca um registro em específico')
async def show(pessoa_id : int, current_user: dict = Depends(get_current_user)):
@router.get(
"/{pessoa_id}",
status_code=status.HTTP_200_OK,
summary="Busca um registro em específico pelo ID da pessoa",
response_description="Busca um registro em específico",
)
async def show(pessoa_id: int, current_user: dict = Depends(get_current_user)):
# Cria o schema com os dados recebidos
t_pessoa_id_schema = TPessoaIdSchema(pessoa_id=pessoa_id)
@ -62,11 +75,16 @@ async def show(pessoa_id : int, current_user: dict = Depends(get_current_user)):
# Cadastro de regime de bens
@router.post('/',
status_code=status.HTTP_201_CREATED,
summary='Cadastra um regime de bens',
response_description='Cadastra um regime de bens')
async def save(t_pessoa_save_schema : TPessoaSaveSchema, current_user: dict = Depends(get_current_user)):
@router.post(
"/",
status_code=status.HTTP_201_CREATED,
summary="Cadastra um regime de bens",
response_description="Cadastra um regime de bens",
)
async def save(
t_pessoa_save_schema: TPessoaSaveSchema,
current_user: dict = Depends(get_current_user),
):
# Efetua o cadastro no banco de dados
response = t_pessoa_controller.save(t_pessoa_save_schema)
@ -76,14 +94,20 @@ async def save(t_pessoa_save_schema : TPessoaSaveSchema, current_user: dict = De
# Atualiza os dados de um regime de bens
@router.put('/{pessoa_id}',
status_code=status.HTTP_200_OK,
summary='Atualiza um regime de bens',
response_description='Atualiza um regime de bens')
async def update(pessoa_id : int, t_pessoa_update_schema : TPessoaUpdateSchema, current_user: dict = Depends(get_current_user)):
@router.put(
"/{pessoa_id}",
status_code=status.HTTP_200_OK,
summary="Atualiza um regime de bens",
response_description="Atualiza um regime de bens",
)
async def update(
pessoa_id: int,
t_pessoa_update_schema: TPessoaUpdateSchema,
current_user: dict = Depends(get_current_user),
):
# Adiciona o ID do registro ao schema
t_pessoa_update_schema.pessoa_id = pessoa_id
t_pessoa_update_schema.pessoa_id = pessoa_id
# Efetua a atualização dos dados
response = t_pessoa_controller.update(t_pessoa_update_schema)
@ -91,12 +115,15 @@ async def update(pessoa_id : int, t_pessoa_update_schema : TPessoaUpdateSchema,
# Retorna os dados localizados
return response
# Exclui um determinado regime de bens
@router.delete('/{pessoa_id}',
status_code=status.HTTP_200_OK,
summary='Remove um regime de bens',
response_description='Remove um regime de bens')
async def delete(pessoa_id : int, current_user: dict = Depends(get_current_user)):
@router.delete(
"/{pessoa_id}",
status_code=status.HTTP_200_OK,
summary="Remove um regime de bens",
response_description="Remove um regime de bens",
)
async def delete(pessoa_id: int, current_user: dict = Depends(get_current_user)):
# Cria o schema com os dados recebidos
t_pessoa_id_schema = TPessoaIdSchema(pessoa_id=pessoa_id)
@ -105,4 +132,4 @@ async def delete(pessoa_id : int, current_user: dict = Depends(get_current_user)
response = t_pessoa_controller.delete(t_pessoa_id_schema)
# Retorna os dados localizados
return response
return response

117
packages/v1/administrativo/endpoints/t_pessoa_representante_endpoint.py
View file

@ -1,8 +1,15 @@
# Importação de bibliotecas
from fastapi import APIRouter, Depends, status
from actions.jwt.get_current_user import get_current_user
from api.packages.v1.administrativo.controllers.t_pessoa_representante_controller import TPessoaRepresentanteController
from api.packages.v1.administrativo.schemas.t_pessoa_representante_schema import TPessoaRepresentanteIdSchema, TPessoaRepresentantePessoaIdSchema, TPessoaRepresentanteSaveSchema, TPessoaRepresentanteUpdateSchema
from packages.v1.administrativo.controllers.t_pessoa_representante_controller import (
TPessoaRepresentanteController,
)
from packages.v1.administrativo.schemas.t_pessoa_representante_schema import (
TPessoaRepresentanteIdSchema,
TPessoaRepresentantePessoaIdSchema,
TPessoaRepresentanteSaveSchema,
TPessoaRepresentanteUpdateSchema,
)
# Inicializa o roteador para as rotas do regime de bens
router = APIRouter()
@ -10,31 +17,45 @@ router = APIRouter()
# Instânciamento do controller desejado
t_pessoa_representante_controller = TPessoaRepresentanteController()
# Lista todos as pessoas
@router.get('/pessoa/{pessoa_id}',
status_code=status.HTTP_200_OK,
summary='Lista todos as pessoas cadastrados',
response_description='Lista todos as pessoas cadastrados')
async def index(pessoa_id : int, current_user: dict = Depends(get_current_user)):
@router.get(
"/pessoa/{pessoa_id}",
status_code=status.HTTP_200_OK,
summary="Lista todos as pessoas cadastrados",
response_description="Lista todos as pessoas cadastrados",
)
async def index(pessoa_id: int, current_user: dict = Depends(get_current_user)):
# Cria o schema com os dados recebidos
t_pessoa_representante_pessoa_id_schema = TPessoaRepresentantePessoaIdSchema(pessoa_id=pessoa_id)
t_pessoa_representante_pessoa_id_schema = TPessoaRepresentantePessoaIdSchema(
pessoa_id=pessoa_id
)
# Busca todos as pessoas cadastrados
response = t_pessoa_representante_controller.index(t_pessoa_representante_pessoa_id_schema)
response = t_pessoa_representante_controller.index(
t_pessoa_representante_pessoa_id_schema
)
# Retorna os dados localizados
return response
# Localiza um regime de bens pelo ID
@router.get('/{pessoa_representante_id}',
status_code=status.HTTP_200_OK,
summary='Busca um registro em específico pelo ID da pessoa',
response_description='Busca um registro em específico')
async def show(pessoa_representante_id : int, current_user: dict = Depends(get_current_user)):
@router.get(
"/{pessoa_representante_id}",
status_code=status.HTTP_200_OK,
summary="Busca um registro em específico pelo ID da pessoa",
response_description="Busca um registro em específico",
)
async def show(
pessoa_representante_id: int, current_user: dict = Depends(get_current_user)
):
# Cria o schema com os dados recebidos
t_pessoa_representante_id_schema = TPessoaRepresentanteIdSchema(pessoa_representante_id=pessoa_representante_id)
t_pessoa_representante_id_schema = TPessoaRepresentanteIdSchema(
pessoa_representante_id=pessoa_representante_id
)
# Busca um regime de bens específico pelo ID
response = t_pessoa_representante_controller.show(t_pessoa_representante_id_schema)
@ -44,47 +65,71 @@ async def show(pessoa_representante_id : int, current_user: dict = Depends(get_c
# Cadastro de regime de bens
@router.post('/',
status_code=status.HTTP_201_CREATED,
summary='Cadastra um regime de bens',
response_description='Cadastra um regime de bens')
async def save(t_pessoa_representante_save_schema : TPessoaRepresentanteSaveSchema, current_user: dict = Depends(get_current_user)):
@router.post(
"/",
status_code=status.HTTP_201_CREATED,
summary="Cadastra um regime de bens",
response_description="Cadastra um regime de bens",
)
async def save(
t_pessoa_representante_save_schema: TPessoaRepresentanteSaveSchema,
current_user: dict = Depends(get_current_user),
):
# Efetua o cadastro no banco de dados
response = t_pessoa_representante_controller.save(t_pessoa_representante_save_schema)
response = t_pessoa_representante_controller.save(
t_pessoa_representante_save_schema
)
# Retorna os dados localizados
return response
# Atualiza os dados de um regime de bens
@router.put('/{pessoa_id}',
status_code=status.HTTP_200_OK,
summary='Atualiza um regime de bens',
response_description='Atualiza um regime de bens')
async def update(pessoa_id : int, t_pessoa_representante_update_schema : TPessoaRepresentanteUpdateSchema, current_user: dict = Depends(get_current_user)):
@router.put(
"/{pessoa_id}",
status_code=status.HTTP_200_OK,
summary="Atualiza um regime de bens",
response_description="Atualiza um regime de bens",
)
async def update(
pessoa_id: int,
t_pessoa_representante_update_schema: TPessoaRepresentanteUpdateSchema,
current_user: dict = Depends(get_current_user),
):
# Adiciona o ID do registro ao schema
t_pessoa_representante_update_schema.pessoa_id = pessoa_id
t_pessoa_representante_update_schema.pessoa_id = pessoa_id
# Efetua a atualização dos dados
response = t_pessoa_representante_controller.update(t_pessoa_representante_update_schema)
response = t_pessoa_representante_controller.update(
t_pessoa_representante_update_schema
)
# Retorna os dados localizados
return response
# Exclui um determinado regime de bens
@router.delete('/{pessoa_representante_id}',
status_code=status.HTTP_200_OK,
summary='Remove um regime de bens',
response_description='Remove um regime de bens')
async def delete(pessoa_representante_id : int, current_user: dict = Depends(get_current_user)):
@router.delete(
"/{pessoa_representante_id}",
status_code=status.HTTP_200_OK,
summary="Remove um regime de bens",
response_description="Remove um regime de bens",
)
async def delete(
pessoa_representante_id: int, current_user: dict = Depends(get_current_user)
):
# Cria o schema com os dados recebidos
t_pessoa_representante_id_schema = TPessoaRepresentanteIdSchema(pessoa_representante_id=pessoa_representante_id)
t_pessoa_representante_id_schema = TPessoaRepresentanteIdSchema(
pessoa_representante_id=pessoa_representante_id
)
# Efetua a exclusão do regime de bens
response = t_pessoa_representante_controller.delete(t_pessoa_representante_id_schema)
response = t_pessoa_representante_controller.delete(
t_pessoa_representante_id_schema
)
# Retorna os dados localizados
return response
return response

10
packages/v1/administrativo/repositories/g_cartorio/g_cartorio_delete_repository.py
View file

@ -1,13 +1,15 @@
from abstracts.repository import BaseRepository
from fastapi import HTTPException, status
from api.packages.v1.administrativo.schemas.g_cartorio_schema import GCartorioIdSchema
from packages.v1.administrativo.schemas.g_cartorio_schema import GCartorioIdSchema
class GCartorioDeleteRepository(BaseRepository):
"""
Repositório responsável pela exclusão de registros na tabela
G_CARTORIO.
"""
def execute(self, g_cartorio_id_schema: GCartorioIdSchema):
"""
Executa a exclusão de um registro específico da tabela G_CARTORIO
@ -27,9 +29,7 @@ class GCartorioDeleteRepository(BaseRepository):
"""
# Preenchimento dos parâmetros
params = {
"cartorio_id": g_cartorio_id_schema.cartorio_id
}
params = {"cartorio_id": g_cartorio_id_schema.cartorio_id}
# Execução da instrução SQL
response = self.run(sql, params)
@ -41,5 +41,5 @@ class GCartorioDeleteRepository(BaseRepository):
# 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_CARTORIO: {e}"
detail=f"Erro ao excluir registro de G_CARTORIO: {e}",
)

8
packages/v1/administrativo/repositories/g_cartorio/g_cartorio_save_repository.py
View file

@ -1,7 +1,7 @@
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_cartorio_schema import GCartorioSaveSchema
from packages.v1.administrativo.schemas.g_cartorio_schema import GCartorioSaveSchema
class GCartorioSaveRepository(BaseRepository):
@ -33,7 +33,7 @@ class GCartorioSaveRepository(BaseRepository):
# ----------------------------------------------------
# Montagem do SQL dinâmico
# ----------------------------------------------------
sql = generate_insert_sql('G_CARTORIO', params)
sql = generate_insert_sql("G_CARTORIO", params)
# ----------------------------------------------------
# Execução do SQL e retorno do registro
@ -46,5 +46,5 @@ class GCartorioSaveRepository(BaseRepository):
# ----------------------------------------------------
raise HTTPException(
status_code=status.HTTP_422_UNPROCESSABLE_ENTITY,
detail=f"Erro ao salvar registro em G_CARTORIO: {e}"
)
detail=f"Erro ao salvar registro em G_CARTORIO: {e}",
)

8
packages/v1/administrativo/repositories/g_cartorio/g_cartorio_show_repository.py
View file

@ -1,7 +1,7 @@
from abstracts.repository import BaseRepository
from fastapi import HTTPException, status
from api.packages.v1.administrativo.schemas.g_cartorio_schema import GCartorioIdSchema
from packages.v1.administrativo.schemas.g_cartorio_schema import GCartorioIdSchema
class GCartorioShowRepository(BaseRepository):
@ -15,7 +15,7 @@ class GCartorioShowRepository(BaseRepository):
Busca um registro específico de G_CARTORIO pelo ID.
Args:
g_cartorio_id_schema (GCartorioIdSchema):
g_cartorio_id_schema (GCartorioIdSchema):
Esquema contendo o ID do registro a ser buscado.
Returns:
@ -50,7 +50,7 @@ class GCartorioShowRepository(BaseRepository):
if not result:
raise HTTPException(
status_code=status.HTTP_404_NOT_FOUND,
detail="Registro de G_CARTORIO não encontrado."
detail="Registro de G_CARTORIO não encontrado.",
)
return result
@ -63,5 +63,5 @@ class GCartorioShowRepository(BaseRepository):
# Captura falhas inesperadas de execução
raise HTTPException(
status_code=status.HTTP_422_UNPROCESSABLE_ENTITY,
detail=f"Erro ao buscar registro em G_CARTORIO: {e}"
detail=f"Erro ao buscar registro em G_CARTORIO: {e}",
)

8
packages/v1/administrativo/repositories/g_cartorio/g_cartorio_update_repository.py
View file

@ -2,7 +2,7 @@ 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_cartorio_schema import GCartorioUpdateSchema
from packages.v1.administrativo.schemas.g_cartorio_schema import GCartorioUpdateSchema
class GCartorioUpdateRepository(BaseRepository):
@ -16,7 +16,7 @@ class GCartorioUpdateRepository(BaseRepository):
Atualiza um registro existente na tabela G_CARTORIO.
Args:
g_cartorio_update_schema (GCartorioUpdateSchema):
g_cartorio_update_schema (GCartorioUpdateSchema):
Esquema contendo os dados a serem atualizados.
Returns:
@ -32,7 +32,7 @@ class GCartorioUpdateRepository(BaseRepository):
params, update_columns = prepare_update_data(
g_cartorio_update_schema,
exclude_fields=["cartorio_id"],
id_field="cartorio_id"
id_field="cartorio_id",
)
# ----------------------------------------------------
@ -57,5 +57,5 @@ class GCartorioUpdateRepository(BaseRepository):
# ----------------------------------------------------
raise HTTPException(
status_code=status.HTTP_422_UNPROCESSABLE_ENTITY,
detail=f"Erro ao atualizar registro em G_CARTORIO: {str(e)}"
detail=f"Erro ao atualizar registro em G_CARTORIO: {str(e)}",
)

10
packages/v1/administrativo/repositories/g_emolumento/g_emolumento_delete_repository.py
View file

@ -1,13 +1,15 @@
from abstracts.repository import BaseRepository
from fastapi import HTTPException, status
from api.packages.v1.administrativo.schemas.g_emolumento_schema import GEmolumentoIdSchema
from packages.v1.administrativo.schemas.g_emolumento_schema import GEmolumentoIdSchema
class GEmolumentoDeleteRepository(BaseRepository):
"""
Repositório responsável pela exclusão de registros na tabela
G_EMOLUMENTO.
"""
def execute(self, g_emolumento_id_schema: GEmolumentoIdSchema):
"""
Executa a exclusão de um registro específico da tabela G_EMOLUMENTO
@ -27,9 +29,7 @@ class GEmolumentoDeleteRepository(BaseRepository):
"""
# Preenchimento dos parâmetros
params = {
"emolumento_id": g_emolumento_id_schema.emolumento_id
}
params = {"emolumento_id": g_emolumento_id_schema.emolumento_id}
# Execução da instrução SQL
response = self.run(sql, params)
@ -41,5 +41,5 @@ class GEmolumentoDeleteRepository(BaseRepository):
# 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_EMOLUMENTO: {e}"
detail=f"Erro ao excluir registro de G_EMOLUMENTO: {e}",
)

8
packages/v1/administrativo/repositories/g_emolumento/g_emolumento_save_repository.py
View file

@ -1,7 +1,7 @@
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_schema import GEmolumentoSaveSchema
from packages.v1.administrativo.schemas.g_emolumento_schema import GEmolumentoSaveSchema
class GEmolumentoSaveRepository(BaseRepository):
@ -33,7 +33,7 @@ class GEmolumentoSaveRepository(BaseRepository):
# ----------------------------------------------------
# Montagem do SQL dinâmico
# ----------------------------------------------------
sql = generate_insert_sql('G_EMOLUMENTO', params)
sql = generate_insert_sql("G_EMOLUMENTO", params)
# ----------------------------------------------------
# Execução do SQL e retorno do registro
@ -46,5 +46,5 @@ class GEmolumentoSaveRepository(BaseRepository):
# ----------------------------------------------------
raise HTTPException(
status_code=status.HTTP_422_UNPROCESSABLE_ENTITY,
detail=f"Erro ao salvar registro em G_EMOLUMENTO: {e}"
)
detail=f"Erro ao salvar registro em G_EMOLUMENTO: {e}",
)

8
packages/v1/administrativo/repositories/g_emolumento/g_emolumento_show_repository.py
View file

@ -1,7 +1,7 @@
from abstracts.repository import BaseRepository
from fastapi import HTTPException, status
from api.packages.v1.administrativo.schemas.g_emolumento_schema import GEmolumentoIdSchema
from packages.v1.administrativo.schemas.g_emolumento_schema import GEmolumentoIdSchema
class GEmolumentoShowRepository(BaseRepository):
@ -15,7 +15,7 @@ class GEmolumentoShowRepository(BaseRepository):
Busca um registro específico de G_EMOLUMENTO pelo ID.
Args:
g_emolumento_id_schema (GEmolumentoIdSchema):
g_emolumento_id_schema (GEmolumentoIdSchema):
Esquema contendo o ID do registro a ser buscado.
Returns:
@ -50,7 +50,7 @@ class GEmolumentoShowRepository(BaseRepository):
if not result:
raise HTTPException(
status_code=status.HTTP_404_NOT_FOUND,
detail="Registro de G_EMOLUMENTO não encontrado."
detail="Registro de G_EMOLUMENTO não encontrado.",
)
return result
@ -63,5 +63,5 @@ class GEmolumentoShowRepository(BaseRepository):
# Captura falhas inesperadas de execução
raise HTTPException(
status_code=status.HTTP_422_UNPROCESSABLE_ENTITY,
detail=f"Erro ao buscar registro em G_EMOLUMENTO: {e}"
detail=f"Erro ao buscar registro em G_EMOLUMENTO: {e}",
)

10
packages/v1/administrativo/repositories/g_emolumento/g_emolumento_update_repository.py
View file

@ -2,7 +2,9 @@ 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_schema import GEmolumentoUpdateSchema
from packages.v1.administrativo.schemas.g_emolumento_schema import (
GEmolumentoUpdateSchema,
)
class GEmolumentoUpdateRepository(BaseRepository):
@ -16,7 +18,7 @@ class GEmolumentoUpdateRepository(BaseRepository):
Atualiza um registro existente na tabela G_EMOLUMENTO.
Args:
g_emolumento_update_schema (GEmolumentoUpdateSchema):
g_emolumento_update_schema (GEmolumentoUpdateSchema):
Esquema contendo os dados a serem atualizados.
Returns:
@ -32,7 +34,7 @@ class GEmolumentoUpdateRepository(BaseRepository):
params, update_columns = prepare_update_data(
g_emolumento_update_schema,
exclude_fields=["emolumento_id"],
id_field="emolumento_id"
id_field="emolumento_id",
)
# ----------------------------------------------------
@ -57,5 +59,5 @@ class GEmolumentoUpdateRepository(BaseRepository):
# ----------------------------------------------------
raise HTTPException(
status_code=status.HTTP_422_UNPROCESSABLE_ENTITY,
detail=f"Erro ao atualizar registro em G_EMOLUMENTO: {str(e)}"
detail=f"Erro ao atualizar registro em G_EMOLUMENTO: {str(e)}",
)

10
packages/v1/administrativo/repositories/g_emolumento_item/g_emolumento_item_save_repository.py
View file

@ -1,7 +1,9 @@
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_item_schema import GEmolumentoItemSaveSchema
from packages.v1.administrativo.schemas.g_emolumento_item_schema import (
GEmolumentoItemSaveSchema,
)
class GEmolumentoItemSaveRepository(BaseRepository):
@ -33,7 +35,7 @@ class GEmolumentoItemSaveRepository(BaseRepository):
# ----------------------------------------------------
# Montagem do SQL dinâmico
# ----------------------------------------------------
sql = generate_insert_sql('G_EMOLUMENTO_ITEM', params)
sql = generate_insert_sql("G_EMOLUMENTO_ITEM", params)
# ----------------------------------------------------
# Execução do SQL e retorno do registro
@ -46,5 +48,5 @@ class GEmolumentoItemSaveRepository(BaseRepository):
# ----------------------------------------------------
raise HTTPException(
status_code=status.HTTP_422_UNPROCESSABLE_ENTITY,
detail=f"Erro ao salvar registro em G_EMOLUMENTO_ITEM: {e}"
)
detail=f"Erro ao salvar registro em G_EMOLUMENTO_ITEM: {e}",
)

8
packages/v1/administrativo/repositories/g_emolumento_item/g_emolumento_item_update_repository.py
View file

@ -2,7 +2,9 @@ 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_item_schema import GEmolumentoItemUpdateSchema
from packages.v1.administrativo.schemas.g_emolumento_item_schema import (
GEmolumentoItemUpdateSchema,
)
class GEmolumentoItemUpdateRepository(BaseRepository):
@ -32,7 +34,7 @@ class GEmolumentoItemUpdateRepository(BaseRepository):
params, update_columns = prepare_update_data(
g_emolumento_item_update_schema,
exclude_fields=["emolumento_item_id"],
id_field="emolumento_item_id"
id_field="emolumento_item_id",
)
# ----------------------------------------------------
@ -57,5 +59,5 @@ class GEmolumentoItemUpdateRepository(BaseRepository):
# ----------------------------------------------------
raise HTTPException(
status_code=status.HTTP_422_UNPROCESSABLE_ENTITY,
detail=f"Erro ao atualizar registro em G_EMOLUMENTO_ITEM: {str(e)}"
detail=f"Erro ao atualizar registro em G_EMOLUMENTO_ITEM: {str(e)}",
)

8
packages/v1/administrativo/repositories/g_emolumento_periodo/g_emolumento_periodo_delete_repository.py
View file

@ -1,13 +1,17 @@
from abstracts.repository import BaseRepository
from fastapi import HTTPException, status
from api.packages.v1.administrativo.schemas.g_emolumento_periodo_schema import GEmolumentoPeriodoIdSchema
from 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
@ -41,5 +45,5 @@ class GEmolumentoPeriodoDeleteRepository(BaseRepository):
# 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}"
detail=f"Erro ao excluir registro de G_GRAMATICA: {e}",
)

10
packages/v1/administrativo/repositories/g_emolumento_periodo/g_emolumento_periodo_save_repository.py
View file

@ -1,7 +1,9 @@
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
from packages.v1.administrativo.schemas.g_emolumento_periodo_schema import (
GEmolumentoPeriodoSaveSchema,
)
class GEmolumentoPeriodoSaveRepository(BaseRepository):
@ -33,7 +35,7 @@ class GEmolumentoPeriodoSaveRepository(BaseRepository):
# ----------------------------------------------------
# Montagem do SQL dinâmico
# ----------------------------------------------------
sql = generate_insert_sql('G_EMOLUMENTO_PERIODO', params)
sql = generate_insert_sql("G_EMOLUMENTO_PERIODO", params)
# ----------------------------------------------------
# Execução do SQL e retorno do registro
@ -46,5 +48,5 @@ class GEmolumentoPeriodoSaveRepository(BaseRepository):
# ----------------------------------------------------
raise HTTPException(
status_code=status.HTTP_422_UNPROCESSABLE_ENTITY,
detail=f"Erro ao salvar registro em G_EMOLUMENTO_PERIODO: {e}"
)
detail=f"Erro ao salvar registro em G_EMOLUMENTO_PERIODO: {e}",
)

10
packages/v1/administrativo/repositories/g_emolumento_periodo/g_emolumento_periodo_show_repository.py
View file

@ -1,7 +1,9 @@
from abstracts.repository import BaseRepository
from fastapi import HTTPException, status
from api.packages.v1.administrativo.schemas.g_emolumento_periodo_schema import GEmolumentoPeriodoIdSchema
from packages.v1.administrativo.schemas.g_emolumento_periodo_schema import (
GEmolumentoPeriodoIdSchema,
)
class GEmolumentoPeriodoShowRepository(BaseRepository):
@ -15,7 +17,7 @@ class GEmolumentoPeriodoShowRepository(BaseRepository):
Busca um registro específico de G_EMOLUMENTO_PERIODO pelo ID.
Args:
g_emolumento_periodo_id_schema (GEmolumentoPeriodoIdSchema):
g_emolumento_periodo_id_schema (GEmolumentoPeriodoIdSchema):
Esquema contendo o ID do registro a ser buscado.
Returns:
@ -50,7 +52,7 @@ class GEmolumentoPeriodoShowRepository(BaseRepository):
if not result:
raise HTTPException(
status_code=status.HTTP_404_NOT_FOUND,
detail="Registro de G_EMOLUMENTO_PERIODO não encontrado."
detail="Registro de G_EMOLUMENTO_PERIODO não encontrado.",
)
return result
@ -63,5 +65,5 @@ class GEmolumentoPeriodoShowRepository(BaseRepository):
# 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}"
detail=f"Erro ao buscar registro em G_EMOLUMENTO_PERIODO: {e}",
)

14
packages/v1/administrativo/repositories/g_emolumento_periodo/g_emolumento_periodo_update_repository.py
View file

@ -2,7 +2,9 @@ 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
from packages.v1.administrativo.schemas.g_emolumento_periodo_schema import (
GEmolumentoPeriodoUpdateSchema,
)
class GEmolumentoPeriodoUpdateRepository(BaseRepository):
@ -11,12 +13,14 @@ class GEmolumentoPeriodoUpdateRepository(BaseRepository):
na tabela G_EMOLUMENTO_PERIODO.
"""
def execute(self, g_emolumento_periodo_update_schema: GEmolumentoPeriodoUpdateSchema):
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):
g_emolumento_periodo_update_schema (GEmolumentoPeriodoUpdateSchema):
Esquema contendo os dados a serem atualizados.
Returns:
@ -32,7 +36,7 @@ class GEmolumentoPeriodoUpdateRepository(BaseRepository):
params, update_columns = prepare_update_data(
g_emolumento_periodo_update_schema,
exclude_fields=["emolumento_periodo_id"],
id_field="emolumento_periodo_id"
id_field="emolumento_periodo_id",
)
# ----------------------------------------------------
@ -57,5 +61,5 @@ class GEmolumentoPeriodoUpdateRepository(BaseRepository):
# ----------------------------------------------------
raise HTTPException(
status_code=status.HTTP_422_UNPROCESSABLE_ENTITY,
detail=f"Erro ao atualizar registro em G_EMOLUMENTO_PERIODO: {str(e)}"
detail=f"Erro ao atualizar registro em G_EMOLUMENTO_PERIODO: {str(e)}",
)

10
packages/v1/administrativo/repositories/g_gramatica/g_gramatica_delete_repository.py
View file

@ -1,13 +1,15 @@
from abstracts.repository import BaseRepository
from fastapi import HTTPException, status
from api.packages.v1.administrativo.schemas.g_gramatica_schema import GGramaticaIdSchema
from packages.v1.administrativo.schemas.g_gramatica_schema import GGramaticaIdSchema
class GGramaticaDeleteRepository(BaseRepository):
"""
Repositório responsável pela exclusão de registros na tabela
G_GRAMATICA.
"""
def execute(self, g_gramatica_id_schema: GGramaticaIdSchema):
"""
Executa a exclusão de um registro específico da tabela G_GRAMATICA
@ -27,9 +29,7 @@ class GGramaticaDeleteRepository(BaseRepository):
"""
# Preenchimento dos parâmetros
params = {
"gramatica_id": g_gramatica_id_schema.gramatica_id
}
params = {"gramatica_id": g_gramatica_id_schema.gramatica_id}
# Execução da instrução SQL
response = self.run(sql, params)
@ -41,5 +41,5 @@ class GGramaticaDeleteRepository(BaseRepository):
# 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}"
detail=f"Erro ao excluir registro de G_GRAMATICA: {e}",
)

Some files were not shown because too many files have changed in this diff Show more