Teste de Ferramentas
This commit is contained in:
parent
4a48001fef
commit
35e19c59e9
587 changed files with 8856 additions and 5846 deletions
|
|
@ -2,7 +2,6 @@ from abc import ABC, abstractmethod
|
|||
|
||||
|
||||
class BaseAction:
|
||||
|
||||
"""
|
||||
Classe abstrata base para todos as actions do sistema.
|
||||
Obriga implementação de um método execute().
|
||||
|
|
@ -14,4 +13,4 @@ class BaseAction:
|
|||
Método abstrato obrigatório a ser implementado pelas subclasses.
|
||||
Deve conter a lógica principal do repositório.
|
||||
"""
|
||||
pass
|
||||
pass
|
||||
|
|
|
|||
|
|
@ -22,7 +22,7 @@ class BaseRepository:
|
|||
def run(self, sql: str, params: Optional[dict] = None):
|
||||
"""Executa um SQL sem retorno de dados (ex: INSERT, UPDATE, DELETE)"""
|
||||
return self._execute(sql, params, fetch="none")
|
||||
|
||||
|
||||
def run_and_return(self, sql: str, params: Optional[dict] = None):
|
||||
"""Executa SQL com RETURNING e retorna o primeiro registro como dict"""
|
||||
return self._execute(sql, params, fetch="one")
|
||||
|
|
@ -47,4 +47,3 @@ class BaseRepository:
|
|||
except SQLAlchemyError as e:
|
||||
print(f"[ERRO SQL]: {e}")
|
||||
raise
|
||||
|
||||
|
|
@ -11,10 +11,10 @@ class Config:
|
|||
base_dir = Path(__file__).resolve().parent
|
||||
|
||||
# Caminho absoluto para o config.json (subindo dois níveis e entrando em config/)
|
||||
config_path = base_dir.parent.parent / 'config' / name
|
||||
config_path = base_dir.parent.parent / "config" / name
|
||||
|
||||
# Carrega o JSON como objeto acessível por ponto
|
||||
with open(config_path, 'r') as f:
|
||||
with open(config_path, "r") as f:
|
||||
config = json.load(f, object_hook=lambda d: SimpleNamespace(**d))
|
||||
|
||||
return config
|
||||
return config
|
||||
|
|
|
|||
|
|
@ -1,7 +1,7 @@
|
|||
import importlib
|
||||
from actions.config.config import Config
|
||||
from typing import Optional, Any, Type
|
||||
from typing import Any, Optional, Type
|
||||
|
||||
from actions.config.config import Config
|
||||
|
||||
|
||||
class DynamicImport:
|
||||
|
|
@ -18,7 +18,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}"
|
||||
|
|
|
|||
|
|
@ -4,14 +4,14 @@ import os
|
|||
|
||||
class File:
|
||||
|
||||
def create(self, data, caminho_arquivo='storage/temp.json'):
|
||||
def create(self, data, caminho_arquivo="storage/temp.json"):
|
||||
try:
|
||||
# Garante que a pasta existe
|
||||
os.makedirs(os.path.dirname(caminho_arquivo), exist_ok=True)
|
||||
|
||||
# Lê dados existentes (ou cria nova lista)
|
||||
if os.path.exists(caminho_arquivo):
|
||||
with open(caminho_arquivo, 'r', encoding='utf-8') as arquivo:
|
||||
with open(caminho_arquivo, "r", encoding="utf-8") as arquivo:
|
||||
try:
|
||||
dados_existentes = json.load(arquivo)
|
||||
if not isinstance(dados_existentes, list):
|
||||
|
|
@ -25,8 +25,8 @@ class File:
|
|||
dados_existentes.append(data)
|
||||
|
||||
# Salva novamente no arquivo com indentação
|
||||
with open(caminho_arquivo, 'w', encoding='utf-8') as arquivo:
|
||||
with open(caminho_arquivo, "w", encoding="utf-8") as arquivo:
|
||||
json.dump(dados_existentes, arquivo, indent=4, ensure_ascii=False)
|
||||
|
||||
|
||||
except Exception as e:
|
||||
print(f"❌ Erro ao salvar o dado: {e}")
|
||||
print(f"❌ Erro ao salvar o dado: {e}")
|
||||
|
|
|
|||
|
|
@ -1,36 +1,34 @@
|
|||
from datetime import datetime, timedelta
|
||||
|
||||
from jose import jwt
|
||||
from pytz import timezone
|
||||
|
||||
from abstracts.action import BaseAction
|
||||
from actions.config.config import Config
|
||||
|
||||
|
||||
class CreateToken(BaseAction):
|
||||
def __init__(self):
|
||||
# Busca as configurações da aplicação
|
||||
self.config = Config.get('app.json')
|
||||
self.config = Config.get("app.json")
|
||||
|
||||
# Cria o timedelta com base na config
|
||||
self.access_token_expire = timedelta(
|
||||
minutes=self.config.jwt.expire.minute,
|
||||
hours=self.config.jwt.expire.hours,
|
||||
days=self.config.jwt.expire.days
|
||||
days=self.config.jwt.expire.days,
|
||||
)
|
||||
|
||||
def execute(self, tipo_token: str, data : str) -> str:
|
||||
|
||||
sp = timezone('America/Sao_Paulo')
|
||||
def execute(self, tipo_token: str, data: str) -> str:
|
||||
|
||||
sp = timezone("America/Sao_Paulo")
|
||||
agora = datetime.now(tz=sp)
|
||||
expira = agora + self.access_token_expire
|
||||
|
||||
# Define os dados do token
|
||||
payload = {
|
||||
'type' : tipo_token,
|
||||
'exp' : expira,
|
||||
'iat' : agora,
|
||||
'data' : str(data)
|
||||
}
|
||||
payload = {"type": tipo_token, "exp": expira, "iat": agora, "data": str(data)}
|
||||
|
||||
# Retorna os dados codificados
|
||||
return jwt.encode(payload, self.config.jwt.token, algorithm=self.config.jwt.algorithm)
|
||||
|
||||
return jwt.encode(
|
||||
payload, self.config.jwt.token, algorithm=self.config.jwt.algorithm
|
||||
)
|
||||
|
|
|
|||
|
|
@ -1,10 +1,12 @@
|
|||
from fastapi import Depends, HTTPException, status, Request
|
||||
from fastapi import Depends, HTTPException, Request, status
|
||||
from fastapi.security import OAuth2PasswordBearer
|
||||
|
||||
from actions.jwt.verify_token import VerifyToken # A classe que criamos anteriormente
|
||||
from actions.jwt.verify_token import \
|
||||
VerifyToken # A classe que criamos anteriormente
|
||||
|
||||
oauth2_scheme = OAuth2PasswordBearer(tokenUrl="token") # Apenas requerido pelo FastAPI
|
||||
|
||||
|
||||
def get_current_user(token: str = Depends(oauth2_scheme)):
|
||||
|
||||
# Ação que válida o tokne
|
||||
|
|
@ -13,12 +15,12 @@ def get_current_user(token: str = Depends(oauth2_scheme)):
|
|||
result = verify_token.execute(token)
|
||||
|
||||
# Verifica se a resposta é diferente de inválida
|
||||
if result['status'] != 'valid':
|
||||
if result["status"] != "valid":
|
||||
raise HTTPException(
|
||||
status_code=status.HTTP_401_UNAUTHORIZED,
|
||||
detail=result.get('message', 'Token inválido ou expirado'),
|
||||
detail=result.get("message", "Token inválido ou expirado"),
|
||||
headers={"WWW-Authenticate": "Bearer"},
|
||||
)
|
||||
|
||||
# Retorna apenas os dados do token
|
||||
return result['payload']
|
||||
return result["payload"]
|
||||
|
|
|
|||
|
|
@ -1,5 +1,6 @@
|
|||
from datetime import datetime
|
||||
from jose import jwt, JWTError, ExpiredSignatureError
|
||||
|
||||
from jose import ExpiredSignatureError, JWTError, jwt
|
||||
from pytz import timezone
|
||||
|
||||
from actions.config.config import Config
|
||||
|
|
@ -8,15 +9,13 @@ from actions.config.config import Config
|
|||
class VerifyToken:
|
||||
def __init__(self):
|
||||
# Carrega configurações
|
||||
self.config = Config.get('app.json')
|
||||
self.config = Config.get("app.json")
|
||||
|
||||
def execute(self, token: str, expected_type: str = 'access-token') -> dict:
|
||||
def execute(self, token: str, expected_type: str = "access-token") -> dict:
|
||||
try:
|
||||
# Decodifica o token
|
||||
payload = jwt.decode(
|
||||
token,
|
||||
self.config.jwt.token,
|
||||
algorithms=[self.config.jwt.algorithm]
|
||||
token, self.config.jwt.token, algorithms=[self.config.jwt.algorithm]
|
||||
)
|
||||
|
||||
# Valida expiração
|
||||
|
|
@ -33,25 +32,16 @@ class VerifyToken:
|
|||
if "data" not in payload:
|
||||
raise ValueError("Token malformado: campo 'data' ausente.")
|
||||
|
||||
return {
|
||||
"status": "valid",
|
||||
"payload": payload
|
||||
}
|
||||
return {"status": "valid", "payload": payload}
|
||||
|
||||
except ExpiredSignatureError:
|
||||
return {
|
||||
"status": "expired",
|
||||
"message": "O token expirou."
|
||||
}
|
||||
return {"status": "expired", "message": "O token expirou."}
|
||||
|
||||
except JWTError as e:
|
||||
return {
|
||||
"status": "invalid",
|
||||
"message": f"Token inválido: {str(e)}"
|
||||
}
|
||||
return {"status": "invalid", "message": f"Token inválido: {str(e)}"}
|
||||
|
||||
except Exception as e:
|
||||
return {
|
||||
"status": "error",
|
||||
"message": f"Erro na validação do token: {str(e)}"
|
||||
}
|
||||
"message": f"Erro na validação do token: {str(e)}",
|
||||
}
|
||||
|
|
|
|||
|
|
@ -4,14 +4,14 @@ import os
|
|||
|
||||
class Log:
|
||||
|
||||
def register(self, data, caminho_arquivo='storage/temp.json'):
|
||||
def register(self, data, caminho_arquivo="storage/temp.json"):
|
||||
try:
|
||||
# Garante que a pasta existe
|
||||
os.makedirs(os.path.dirname(caminho_arquivo), exist_ok=True)
|
||||
|
||||
# Lê dados existentes (ou cria nova lista)
|
||||
if os.path.exists(caminho_arquivo):
|
||||
with open(caminho_arquivo, 'r', encoding='utf-8') as arquivo:
|
||||
with open(caminho_arquivo, "r", encoding="utf-8") as arquivo:
|
||||
try:
|
||||
dados_existentes = json.load(arquivo)
|
||||
if not isinstance(dados_existentes, list):
|
||||
|
|
@ -25,8 +25,8 @@ class Log:
|
|||
dados_existentes.append(data)
|
||||
|
||||
# Salva novamente no arquivo com indentação
|
||||
with open(caminho_arquivo, 'w', encoding='utf-8') as arquivo:
|
||||
with open(caminho_arquivo, "w", encoding="utf-8") as arquivo:
|
||||
json.dump(dados_existentes, arquivo, indent=4, ensure_ascii=False)
|
||||
|
||||
|
||||
except Exception as e:
|
||||
print(f"❌ Erro ao salvar o dado: {e}")
|
||||
print(f"❌ Erro ao salvar o dado: {e}")
|
||||
|
|
|
|||
|
|
@ -6,7 +6,7 @@ from passlib.context import CryptContext
|
|||
# Cria uma instância do contexto de criptografia
|
||||
# O esquema usado é 'bcrypt', que é seguro e amplamente aceito
|
||||
# O parâmetro 'deprecated="auto"' marca versões antigas como inseguras, se aplicável
|
||||
CRYPTO = CryptContext(schemes=['bcrypt'], deprecated='auto')
|
||||
CRYPTO = CryptContext(schemes=["bcrypt"], deprecated="auto")
|
||||
|
||||
|
||||
class Security:
|
||||
|
|
@ -19,19 +19,17 @@ class Security:
|
|||
"""
|
||||
return CRYPTO.identify(senha)
|
||||
|
||||
|
||||
# Verifica se uma senha fornecida corresponde ao hash armazenado
|
||||
def verify_senha_api(plain_senha_api: str, hashed_senha_api: str) -> bool:
|
||||
"""
|
||||
Compara a senha fornecida em texto puro com o hash armazenado.
|
||||
|
||||
|
||||
:param plain_senha_api: Senha digitada pelo usuário
|
||||
:param hashed_senha_api: Hash da senha armazenado no banco de dados
|
||||
:return: True se corresponder, False se não
|
||||
"""
|
||||
return CRYPTO.verify(plain_senha_api, hashed_senha_api)
|
||||
|
||||
|
||||
# Gera o hash de uma senha fornecida
|
||||
def hash_senha_api(plain_senha_api: str) -> str:
|
||||
"""
|
||||
|
|
|
|||
|
|
@ -1,4 +1,4 @@
|
|||
# exceptions.py
|
||||
class BusinessRuleException(Exception):
|
||||
def __init__(self, message: str):
|
||||
self.message = message
|
||||
self.message = message
|
||||
|
|
|
|||
|
|
@ -7,80 +7,64 @@ from fastapi.exceptions import RequestValidationError
|
|||
from fastapi.responses import JSONResponse
|
||||
from starlette.exceptions import HTTPException as StarletteHTTPException
|
||||
|
||||
from actions.system.exceptions import BusinessRuleException
|
||||
from actions.log.log import Log
|
||||
from actions.system.exceptions import BusinessRuleException
|
||||
|
||||
|
||||
def register_exception_handlers(app):
|
||||
|
||||
def __init__ (self):
|
||||
def __init__(self):
|
||||
log = Log()
|
||||
|
||||
@app.exception_handler(BusinessRuleException)
|
||||
async def business_rule_exception_handler(request: Request, exc: BusinessRuleException):
|
||||
async def business_rule_exception_handler(
|
||||
request: Request, exc: BusinessRuleException
|
||||
):
|
||||
|
||||
response = {"status": "422", "error": "Regra de negócio", "detail": exc.message}
|
||||
|
||||
response = {
|
||||
"status": "422",
|
||||
"error": "Regra de negócio",
|
||||
"detail": exc.message
|
||||
}
|
||||
|
||||
# Salva o log em disco
|
||||
Log.register(response, 'storage/temp/business_rule_exception_handler.json')
|
||||
Log.register(response, "storage/temp/business_rule_exception_handler.json")
|
||||
|
||||
return JSONResponse(
|
||||
status_code=422,
|
||||
content=response
|
||||
)
|
||||
return JSONResponse(status_code=422, content=response)
|
||||
|
||||
@app.exception_handler(StarletteHTTPException)
|
||||
async def http_exception_handler(request: Request, exc: StarletteHTTPException):
|
||||
response = {
|
||||
"status": exc.status_code,
|
||||
"error": "HTTP Error",
|
||||
"detail": exc.detail
|
||||
}
|
||||
"status": exc.status_code,
|
||||
"error": "HTTP Error",
|
||||
"detail": exc.detail,
|
||||
}
|
||||
|
||||
# Salva o log em disco
|
||||
Log.register(response, 'storage/temp/http_exception_handler.json')
|
||||
Log.register(response, "storage/temp/http_exception_handler.json")
|
||||
|
||||
return JSONResponse(
|
||||
status_code=exc.status_code,
|
||||
content=response
|
||||
)
|
||||
return JSONResponse(status_code=exc.status_code, content=response)
|
||||
|
||||
@app.exception_handler(RequestValidationError)
|
||||
async def validation_exception_handler(request: Request, exc: RequestValidationError):
|
||||
async def validation_exception_handler(
|
||||
request: Request, exc: RequestValidationError
|
||||
):
|
||||
|
||||
response = {
|
||||
"status": 400,
|
||||
"error": "Erro de validação",
|
||||
"detail": exc.errors()
|
||||
}
|
||||
response = {"status": 400, "error": "Erro de validação", "detail": exc.errors()}
|
||||
|
||||
# Salva o log em disco
|
||||
Log.register(response, 'storage/temp/validation_exception_handler.json')
|
||||
Log.register(response, "storage/temp/validation_exception_handler.json")
|
||||
|
||||
return JSONResponse(
|
||||
status_code=400,
|
||||
content=response
|
||||
)
|
||||
return JSONResponse(status_code=400, content=response)
|
||||
|
||||
@app.exception_handler(Exception)
|
||||
async def global_exception_handler(request: Request, exc: Exception):
|
||||
|
||||
response = {
|
||||
"status": 500,
|
||||
"error": "Erro Interno do Servidor",
|
||||
"type": type(exc).__name__,
|
||||
"message": str(exc),
|
||||
"trace": traceback.format_exc()
|
||||
}
|
||||
"status": 500,
|
||||
"error": "Erro Interno do Servidor",
|
||||
"type": type(exc).__name__,
|
||||
"message": str(exc),
|
||||
"trace": traceback.format_exc(),
|
||||
}
|
||||
|
||||
# Salva o log em disco
|
||||
Log.register(response, 'storage/temp/validation_exception_handler.json')
|
||||
Log.register(response, "storage/temp/validation_exception_handler.json")
|
||||
|
||||
return JSONResponse(
|
||||
status_code=500,
|
||||
content=response
|
||||
)
|
||||
return JSONResponse(status_code=500, content=response)
|
||||
|
|
|
|||
|
|
@ -1,8 +1,7 @@
|
|||
|
||||
class CEP:
|
||||
|
||||
@staticmethod
|
||||
def validate(data: str) -> bool:
|
||||
|
||||
# Valida e retorna a informação
|
||||
return len(data) == 8
|
||||
return len(data) == 8
|
||||
|
|
|
|||
|
|
@ -7,7 +7,7 @@ class CNPJ:
|
|||
def validate(data: str) -> bool:
|
||||
|
||||
# Remove caracteres não numéricos
|
||||
data = re.sub(r'\D', '', data)
|
||||
data = re.sub(r"\D", "", data)
|
||||
|
||||
# Verifica se tem 14 dígitos
|
||||
if len(data) != 14:
|
||||
|
|
@ -21,7 +21,7 @@ class CNPJ:
|
|||
def calcular_digito(data, peso):
|
||||
soma = sum(int(a) * b for a, b in zip(data, peso))
|
||||
resto = soma % 11
|
||||
return '0' if resto < 2 else str(11 - resto)
|
||||
return "0" if resto < 2 else str(11 - resto)
|
||||
|
||||
# Primeiro dígito verificador
|
||||
peso1 = [5, 4, 3, 2, 9, 8, 7, 6, 5, 4, 3, 2]
|
||||
|
|
|
|||
|
|
@ -6,7 +6,7 @@ class CPF:
|
|||
@staticmethod
|
||||
def is_valid_cpf(data: str) -> bool:
|
||||
# Remove caracteres não numéricos
|
||||
data = re.sub(r'\D', '', data)
|
||||
data = re.sub(r"\D", "", data)
|
||||
|
||||
# Verifica se tem 11 dígitos
|
||||
if len(data) != 11:
|
||||
|
|
@ -20,7 +20,7 @@ class CPF:
|
|||
def calcular_digito(digitos, peso):
|
||||
soma = sum(int(a) * b for a, b in zip(digitos, peso))
|
||||
resto = soma % 11
|
||||
return '0' if resto < 2 else str(11 - resto)
|
||||
return "0" if resto < 2 else str(11 - resto)
|
||||
|
||||
# Primeiro dígito verificador
|
||||
peso1 = range(10, 1, -1)
|
||||
|
|
@ -31,4 +31,4 @@ class CPF:
|
|||
digito2 = calcular_digito(data[:10], peso2)
|
||||
|
||||
# Verifica se os dígitos batem
|
||||
return data[-2:] == digito1 + digito2
|
||||
return data[-2:] == digito1 + digito2
|
||||
|
|
|
|||
|
|
@ -6,4 +6,4 @@ class Email:
|
|||
@staticmethod
|
||||
def is_valid_email(email: str) -> bool:
|
||||
"""Check if email has a valid structure"""
|
||||
return bool(re.match(r"^[\w\.-]+@[\w\.-]+\.\w+$", email))
|
||||
return bool(re.match(r"^[\w\.-]+@[\w\.-]+\.\w+$", email))
|
||||
|
|
|
|||
|
|
@ -1,4 +1,3 @@
|
|||
|
||||
class Phone:
|
||||
|
||||
@staticmethod
|
||||
|
|
@ -9,4 +8,4 @@ class Phone:
|
|||
@staticmethod
|
||||
def validate_telephone(data: str) -> bool:
|
||||
# Verifica e retorna se o numero de telefone é igual a 11
|
||||
return len(data) == 10
|
||||
return len(data) == 10
|
||||
|
|
|
|||
|
|
@ -7,16 +7,15 @@ class Text:
|
|||
# Remove as mascaras de números
|
||||
@staticmethod
|
||||
def just_numbers(data: str) -> str:
|
||||
""" Mantêm apenas os numeros """
|
||||
"""Mantêm apenas os numeros"""
|
||||
data = re.sub(r"[^\d]", "", data)
|
||||
return data
|
||||
|
||||
|
||||
# Verifica se um e-mail é válido
|
||||
@staticmethod
|
||||
def is_valid_email(email: str) -> bool:
|
||||
"""Check if email has a valid structure"""
|
||||
return bool(re.match(r"^[\w\.-]+@[\w\.-]+\.\w+$", email))
|
||||
|
||||
|
||||
"""
|
||||
Sanitiza entradas de texto contra XSS e SQL Injection básicos.
|
||||
|
|
@ -25,6 +24,7 @@ class Text:
|
|||
- Remove padrões suspeitos de XSS e SQL Injection
|
||||
- Normaliza múltiplos espaços em um só
|
||||
"""
|
||||
|
||||
@staticmethod
|
||||
def sanitize_input(data: str) -> str:
|
||||
|
||||
|
|
@ -41,23 +41,36 @@ class Text:
|
|||
data = re.sub(r"\s+", " ", data)
|
||||
|
||||
# 4) Remove tags <script> (com atributos)
|
||||
data = re.sub(r'<\s*script[^>]*>', '', data, flags=re.IGNORECASE)
|
||||
data = re.sub(r'<\s*/\s*script\s*>', '', data, flags=re.IGNORECASE)
|
||||
data = re.sub(r"<\s*script[^>]*>", "", data, flags=re.IGNORECASE)
|
||||
data = re.sub(r"<\s*/\s*script\s*>", "", data, flags=re.IGNORECASE)
|
||||
|
||||
# 5) Remove javascript: de links
|
||||
data = re.sub(r'javascript\s*:', '', data, flags=re.IGNORECASE)
|
||||
data = re.sub(r"javascript\s*:", "", data, flags=re.IGNORECASE)
|
||||
|
||||
# 6) Remove palavras-chave SQL Injection comuns
|
||||
blacklist = [
|
||||
"--", ";", "/*", "*/", "@@",
|
||||
"char(", "nchar(", "varchar(",
|
||||
"alter", "drop", "exec", "insert",
|
||||
"delete", "update", "union", "select",
|
||||
"from", "where"
|
||||
"--",
|
||||
";",
|
||||
"/*",
|
||||
"*/",
|
||||
"@@",
|
||||
"char(",
|
||||
"nchar(",
|
||||
"varchar(",
|
||||
"alter",
|
||||
"drop",
|
||||
"exec",
|
||||
"insert",
|
||||
"delete",
|
||||
"update",
|
||||
"union",
|
||||
"select",
|
||||
"from",
|
||||
"where",
|
||||
]
|
||||
for word in blacklist:
|
||||
# Verificar se 'word' é uma string não vazia e válida para a regex
|
||||
if word:
|
||||
data = re.sub(re.escape(word), "", data, flags=re.IGNORECASE)
|
||||
|
||||
return data
|
||||
return data
|
||||
|
|
|
|||
|
|
@ -1,4 +1,5 @@
|
|||
from typing import Optional
|
||||
|
||||
from sqlalchemy import create_engine
|
||||
from sqlalchemy.engine import Engine
|
||||
|
||||
|
|
@ -11,7 +12,7 @@ class Firebird:
|
|||
@classmethod
|
||||
def get_engine(cls) -> Engine:
|
||||
# Obtem as configurações do arquivo JSON
|
||||
database = Config.get('database/firebird.json')
|
||||
database = Config.get("database/firebird.json")
|
||||
|
||||
# Cria a engine apenas uma vez
|
||||
if cls._engine is None:
|
||||
|
|
|
|||
42
main.py
42
main.py
|
|
@ -3,30 +3,30 @@ import os
|
|||
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 pathlib import Path
|
||||
|
||||
# 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
|
||||
from starlette.middleware.base import BaseHTTPMiddleware
|
||||
|
||||
from actions.config.config import Config
|
||||
# Importa as configurações globais da aplicação
|
||||
from actions.log.log import Log
|
||||
from actions.system.handlers import register_exception_handlers
|
||||
# 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
|
||||
|
||||
# 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')
|
||||
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 +40,7 @@ app.add_middleware(
|
|||
allow_headers=["*"],
|
||||
)
|
||||
|
||||
|
||||
@app.on_event("startup")
|
||||
async def on_startup():
|
||||
|
||||
|
|
@ -49,20 +50,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 +76,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
|
||||
)
|
||||
|
|
|
|||
|
|
@ -1,14 +1,16 @@
|
|||
from packages.v1.administrativo.repositories.c_caixa_item.c_caixa_item_delete import Delete
|
||||
from packages.v1.administrativo.schemas.c_caixa_item_schema import CaixaItemSchema
|
||||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.repositories.c_caixa_item.c_caixa_item_delete import \
|
||||
Delete
|
||||
from packages.v1.administrativo.schemas.c_caixa_item_schema import \
|
||||
CaixaItemSchema
|
||||
|
||||
|
||||
class DeleteAction(BaseAction):
|
||||
|
||||
def execute(self, caixa_item_schema : CaixaItemSchema):
|
||||
def execute(self, caixa_item_schema: CaixaItemSchema):
|
||||
|
||||
# Instânciamento de repoistório
|
||||
delete = Delete()
|
||||
|
||||
# Retorna o resultado da operação
|
||||
return delete.execute(caixa_item_schema)
|
||||
return delete.execute(caixa_item_schema)
|
||||
|
|
|
|||
|
|
@ -1,8 +1,8 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.repositories.c_caixa_item.c_caixa_item_index import \
|
||||
Index
|
||||
from packages.v1.administrativo.schemas.c_caixa_item_schema import \
|
||||
CaixaItemSearchSchema
|
||||
from abstracts.action import BaseAction
|
||||
|
||||
|
||||
class IndexAction(BaseAction):
|
||||
|
|
@ -13,4 +13,4 @@ class IndexAction(BaseAction):
|
|||
index = Index()
|
||||
|
||||
# Retorna todos produtos
|
||||
return index.execute()
|
||||
return index.execute()
|
||||
|
|
|
|||
|
|
@ -1,15 +1,16 @@
|
|||
from packages.v1.administrativo.repositories.c_caixa_item.c_caixa_item_save import Save
|
||||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.repositories.c_caixa_item.c_caixa_item_save import \
|
||||
Save
|
||||
from packages.v1.administrativo.schemas.c_caixa_item_schema import \
|
||||
CaixaItemSchema
|
||||
from abstracts.action import BaseAction
|
||||
|
||||
|
||||
class SaveAction(BaseAction):
|
||||
|
||||
def execute(self, caixa_item_schema : CaixaItemSchema):
|
||||
def execute(self, caixa_item_schema: CaixaItemSchema):
|
||||
|
||||
# Instância o repositório desejado
|
||||
save = Save()
|
||||
|
||||
# Executa o respositório desejado
|
||||
return save.execute(caixa_item_schema)
|
||||
return save.execute(caixa_item_schema)
|
||||
|
|
|
|||
|
|
@ -1,14 +1,16 @@
|
|||
from packages.v1.administrativo.repositories.c_caixa_item.c_caixa_item_show import Show
|
||||
from packages.v1.administrativo.schemas.c_caixa_item_schema import CaixaItemSchema
|
||||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.repositories.c_caixa_item.c_caixa_item_show import \
|
||||
Show
|
||||
from packages.v1.administrativo.schemas.c_caixa_item_schema import \
|
||||
CaixaItemSchema
|
||||
|
||||
|
||||
class ShowAction(BaseAction):
|
||||
|
||||
def execute(self, caixa_item_schema : CaixaItemSchema):
|
||||
def execute(self, caixa_item_schema: CaixaItemSchema):
|
||||
|
||||
# Instânciamento do repositório
|
||||
show = Show()
|
||||
|
||||
# Retorna os dados localizados
|
||||
return show.execute(caixa_item_schema)
|
||||
return show.execute(caixa_item_schema)
|
||||
|
|
|
|||
|
|
@ -1,14 +1,16 @@
|
|||
from packages.v1.administrativo.repositories.c_caixa_item.c_caixa_item_update_repository import UpdateRepository
|
||||
from packages.v1.administrativo.schemas.c_caixa_item_schema import CaixaItemSchema
|
||||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.repositories.c_caixa_item.c_caixa_item_update_repository import \
|
||||
UpdateRepository
|
||||
from packages.v1.administrativo.schemas.c_caixa_item_schema import \
|
||||
CaixaItemSchema
|
||||
|
||||
|
||||
class UpdateAction(BaseAction):
|
||||
|
||||
def execute(self, caixa_item_id : int, caixa_item_schema : CaixaItemSchema):
|
||||
def execute(self, caixa_item_id: int, caixa_item_schema: CaixaItemSchema):
|
||||
|
||||
# Instância o repositório desejado
|
||||
update = UpdateRepository()
|
||||
|
||||
# Executa o respositório desejado
|
||||
return update.execute(caixa_item_id, caixa_item_schema)
|
||||
return update.execute(caixa_item_id, caixa_item_schema)
|
||||
|
|
|
|||
|
|
@ -1,11 +1,13 @@
|
|||
from packages.v1.administrativo.schemas.c_caixa_servico_schema import CCaixaServicoIdSchema
|
||||
from packages.v1.administrativo.repositories.c_caixa_servico.c_caixa_servico_delete_repository import DeleteRepository
|
||||
from packages.v1.administrativo.repositories.c_caixa_servico.c_caixa_servico_delete_repository import \
|
||||
DeleteRepository
|
||||
from packages.v1.administrativo.schemas.c_caixa_servico_schema import \
|
||||
CCaixaServicoIdSchema
|
||||
|
||||
|
||||
class DeleteAction:
|
||||
|
||||
def execute(self, usuario_schema : CCaixaServicoIdSchema):
|
||||
def execute(self, usuario_schema: CCaixaServicoIdSchema):
|
||||
|
||||
delete_repository = DeleteRepository()
|
||||
|
||||
return delete_repository.execute(usuario_schema)
|
||||
return delete_repository.execute(usuario_schema)
|
||||
|
|
|
|||
|
|
@ -1,10 +1,13 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.schemas.c_caixa_servico_schema import CCaixaServicoDescricaoSchema
|
||||
from packages.v1.administrativo.repositories.c_caixa_servico.c_caixa_servico_get_by_descricao_repository import ShowRepository
|
||||
from packages.v1.administrativo.repositories.c_caixa_servico.c_caixa_servico_get_by_descricao_repository import \
|
||||
ShowRepository
|
||||
from packages.v1.administrativo.schemas.c_caixa_servico_schema import \
|
||||
CCaixaServicoDescricaoSchema
|
||||
|
||||
|
||||
class ShowAction(BaseAction):
|
||||
|
||||
def execute(self, caixa_servico_schema : CCaixaServicoDescricaoSchema):
|
||||
def execute(self, caixa_servico_schema: CCaixaServicoDescricaoSchema):
|
||||
|
||||
# Instânciamento do repositório sql
|
||||
show_repository = ShowRepository()
|
||||
|
|
@ -13,4 +16,4 @@ class ShowAction(BaseAction):
|
|||
response = show_repository.execute(caixa_servico_schema)
|
||||
|
||||
# Retorno da informação
|
||||
return response
|
||||
return response
|
||||
|
|
|
|||
|
|
@ -1,5 +1,7 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.repositories.c_caixa_servico.c_caixa_servico_index_repository import IndexRepository
|
||||
from packages.v1.administrativo.repositories.c_caixa_servico.c_caixa_servico_index_repository import \
|
||||
IndexRepository
|
||||
|
||||
|
||||
class IndexAction(BaseAction):
|
||||
|
||||
|
|
@ -12,4 +14,4 @@ class IndexAction(BaseAction):
|
|||
response = index_repository.execute()
|
||||
|
||||
# Retorno da informação
|
||||
return response
|
||||
return response
|
||||
|
|
|
|||
|
|
@ -1,11 +1,13 @@
|
|||
from packages.v1.administrativo.schemas.c_caixa_servico_schema import CCaixaServicoSaveSchema
|
||||
from packages.v1.administrativo.repositories.c_caixa_servico.c_caixa_servico_save_repository import SaveRepository
|
||||
from packages.v1.administrativo.repositories.c_caixa_servico.c_caixa_servico_save_repository import \
|
||||
SaveRepository
|
||||
from packages.v1.administrativo.schemas.c_caixa_servico_schema import \
|
||||
CCaixaServicoSaveSchema
|
||||
|
||||
|
||||
class SaveAction:
|
||||
|
||||
def execute(self, usuario_schema : CCaixaServicoSaveSchema):
|
||||
def execute(self, usuario_schema: CCaixaServicoSaveSchema):
|
||||
|
||||
save_repository = SaveRepository()
|
||||
|
||||
return save_repository.execute(usuario_schema)
|
||||
return save_repository.execute(usuario_schema)
|
||||
|
|
|
|||
|
|
@ -1,10 +1,13 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.schemas.c_caixa_servico_schema import CCaixaServicoSchema
|
||||
from packages.v1.administrativo.repositories.c_caixa_servico.c_caixa_servico_show_repository import ShowRepository
|
||||
from packages.v1.administrativo.repositories.c_caixa_servico.c_caixa_servico_show_repository import \
|
||||
ShowRepository
|
||||
from packages.v1.administrativo.schemas.c_caixa_servico_schema import \
|
||||
CCaixaServicoSchema
|
||||
|
||||
|
||||
class ShowAction(BaseAction):
|
||||
|
||||
def execute(self, usuario_schema : CCaixaServicoSchema):
|
||||
def execute(self, usuario_schema: CCaixaServicoSchema):
|
||||
|
||||
# Instânciamento do repositório sql
|
||||
show_repository = ShowRepository()
|
||||
|
|
@ -13,4 +16,4 @@ class ShowAction(BaseAction):
|
|||
response = show_repository.execute(usuario_schema)
|
||||
|
||||
# Retorno da informação
|
||||
return response
|
||||
return response
|
||||
|
|
|
|||
|
|
@ -1,11 +1,15 @@
|
|||
from packages.v1.administrativo.schemas.c_caixa_servico_schema import CCaixaServicoUpdateSchema
|
||||
from packages.v1.administrativo.repositories.c_caixa_servico.c_caixa_servico_update_repository import UpdateRepository
|
||||
from packages.v1.administrativo.repositories.c_caixa_servico.c_caixa_servico_update_repository import \
|
||||
UpdateRepository
|
||||
from packages.v1.administrativo.schemas.c_caixa_servico_schema import \
|
||||
CCaixaServicoUpdateSchema
|
||||
|
||||
|
||||
class UpdateAction:
|
||||
|
||||
def execute(self, caixa_servico_id : int, c_caixa_servico_schema : CCaixaServicoUpdateSchema):
|
||||
def execute(
|
||||
self, caixa_servico_id: int, c_caixa_servico_schema: CCaixaServicoUpdateSchema
|
||||
):
|
||||
|
||||
save_repository = UpdateRepository()
|
||||
|
||||
return save_repository.execute(caixa_servico_id, c_caixa_servico_schema)
|
||||
return save_repository.execute(caixa_servico_id, c_caixa_servico_schema)
|
||||
|
|
|
|||
|
|
@ -1,6 +1,7 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.repositories.g_cidade.g_cidade_delete_repository import \
|
||||
DeleteRepository
|
||||
from packages.v1.administrativo.schemas.g_cidade_schema import GCidadeIdSchema
|
||||
from packages.v1.administrativo.repositories.g_cidade.g_cidade_delete_repository import DeleteRepository
|
||||
|
||||
|
||||
class DeleteAction(BaseAction):
|
||||
|
|
@ -23,4 +24,4 @@ class DeleteAction(BaseAction):
|
|||
delete_repository = DeleteRepository()
|
||||
|
||||
# Execução do repositório
|
||||
return delete_repository.execute(g_cidade_schema)
|
||||
return delete_repository.execute(g_cidade_schema)
|
||||
|
|
|
|||
|
|
@ -1,6 +1,8 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.schemas.g_cidade_schema import GCidadeNomeSchema
|
||||
from packages.v1.administrativo.repositories.g_cidade.g_cidade_get_by_nome_repository import GetByNomeRepository
|
||||
from packages.v1.administrativo.repositories.g_cidade.g_cidade_get_by_nome_repository import \
|
||||
GetByNomeRepository
|
||||
from packages.v1.administrativo.schemas.g_cidade_schema import \
|
||||
GCidadeNomeSchema
|
||||
|
||||
|
||||
class GetByNomeAction(BaseAction):
|
||||
|
|
@ -26,4 +28,4 @@ class GetByNomeAction(BaseAction):
|
|||
response = show_repository.execute(g_cidade_schema)
|
||||
|
||||
# Retorno da informação
|
||||
return response
|
||||
return response
|
||||
|
|
|
|||
|
|
@ -1,5 +1,7 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.repositories.g_cidade.g_cidade_index_repository import IndexRepository
|
||||
from packages.v1.administrativo.repositories.g_cidade.g_cidade_index_repository import \
|
||||
IndexRepository
|
||||
|
||||
|
||||
class IndexAction(BaseAction):
|
||||
"""
|
||||
|
|
@ -21,4 +23,4 @@ class IndexAction(BaseAction):
|
|||
response = index_repository.execute()
|
||||
|
||||
# Retorno da informação
|
||||
return response
|
||||
return response
|
||||
|
|
|
|||
|
|
@ -1,6 +1,9 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.schemas.g_cidade_schema import GCidadeSaveSchema
|
||||
from packages.v1.administrativo.repositories.g_cidade.g_cidade_save_repository import SaveRepository
|
||||
from packages.v1.administrativo.repositories.g_cidade.g_cidade_save_repository import \
|
||||
SaveRepository
|
||||
from packages.v1.administrativo.schemas.g_cidade_schema import \
|
||||
GCidadeSaveSchema
|
||||
|
||||
|
||||
class SaveAction(BaseAction):
|
||||
"""
|
||||
|
|
@ -25,4 +28,4 @@ class SaveAction(BaseAction):
|
|||
response = save_repository.execute(g_cidade_schema)
|
||||
|
||||
# Retorno da informação
|
||||
return response
|
||||
return response
|
||||
|
|
|
|||
|
|
@ -1,6 +1,8 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.repositories.g_cidade.g_cidade_show_repository import \
|
||||
ShowRepository
|
||||
from packages.v1.administrativo.schemas.g_cidade_schema import GCidadeIdSchema
|
||||
from packages.v1.administrativo.repositories.g_cidade.g_cidade_show_repository import ShowRepository
|
||||
|
||||
|
||||
class ShowAction(BaseAction):
|
||||
"""
|
||||
|
|
@ -11,7 +13,7 @@ class ShowAction(BaseAction):
|
|||
def execute(self, g_cidade_schema: GCidadeIdSchema):
|
||||
"""
|
||||
Executa a operação de exibição.
|
||||
|
||||
|
||||
Args:
|
||||
g_cidade_schema (GCidadeIdSchema): O esquema com o ID (CIDADE_ID) do registro a ser exibido.
|
||||
|
||||
|
|
@ -25,4 +27,4 @@ class ShowAction(BaseAction):
|
|||
response = show_repository.execute(g_cidade_schema)
|
||||
|
||||
# Retorno da informação
|
||||
return response
|
||||
return response
|
||||
|
|
|
|||
|
|
@ -1,11 +1,13 @@
|
|||
from packages.v1.administrativo.schemas.g_cidade_schema import GCidadeUpdateSchema
|
||||
from packages.v1.administrativo.repositories.g_cidade.g_cidade_update_repository import UpdateRepository
|
||||
from packages.v1.administrativo.repositories.g_cidade.g_cidade_update_repository import \
|
||||
UpdateRepository
|
||||
from packages.v1.administrativo.schemas.g_cidade_schema import \
|
||||
GCidadeUpdateSchema
|
||||
|
||||
|
||||
class UpdateAction:
|
||||
"""
|
||||
Serviço responsável por encapsular a lógica de negócio para a atualização
|
||||
de um registro na tabela G_CIDADE.
|
||||
Serviço responsável por encapsular a lógica de negócio para a atualização
|
||||
de um registro na tabela G_CIDADE.
|
||||
"""
|
||||
|
||||
def execute(self, cidade_id: int, g_cidade_schema: GCidadeUpdateSchema):
|
||||
|
|
@ -23,4 +25,4 @@ class UpdateAction:
|
|||
update_repository = UpdateRepository()
|
||||
|
||||
# Chama o método de execução do repositório para realizar a atualização
|
||||
return update_repository.execute(cidade_id, g_cidade_schema)
|
||||
return update_repository.execute(cidade_id, g_cidade_schema)
|
||||
|
|
|
|||
|
|
@ -1,9 +1,11 @@
|
|||
from abstracts.action import BaseAction
|
||||
# O repositório TServicoTipoDeleteRepository deve ser substituído pelo GMarcacaoTipoDeleteRepository.
|
||||
from packages.v1.administrativo.repositories.g_marcacao_tipo.g_marcacao_tipo_delete_repository import \
|
||||
DeleteRepository
|
||||
# O schema TServicoTipoIdSchema deve ser substituído por GMarcacaoTipoIdSchema
|
||||
# que contém o campo-chave MARCACAO_TIPO_ID.
|
||||
from packages.v1.administrativo.schemas.g_marcacao_tipo_schema import GMarcacaoTipoIdSchema
|
||||
# O repositório TServicoTipoDeleteRepository deve ser substituído pelo GMarcacaoTipoDeleteRepository.
|
||||
from packages.v1.administrativo.repositories.g_marcacao_tipo.g_marcacao_tipo_delete_repository import DeleteRepository
|
||||
from packages.v1.administrativo.schemas.g_marcacao_tipo_schema import \
|
||||
GMarcacaoTipoIdSchema
|
||||
|
||||
|
||||
class DeleteAction(BaseAction):
|
||||
|
|
@ -26,4 +28,4 @@ class DeleteAction(BaseAction):
|
|||
delete_repository = DeleteRepository()
|
||||
|
||||
# Execução do repositório
|
||||
return delete_repository.execute(marcacao_tipo_schema)
|
||||
return delete_repository.execute(marcacao_tipo_schema)
|
||||
|
|
|
|||
|
|
@ -1,8 +1,10 @@
|
|||
from abstracts.action import BaseAction
|
||||
# Ajuste do schema de entrada
|
||||
from packages.v1.administrativo.schemas.g_marcacao_tipo_schema import GMarcacaoTipoDescricaoSchema
|
||||
# Ajuste do repositório
|
||||
from packages.v1.administrativo.repositories.g_marcacao_tipo.g_marcacao_tipo_get_by_descricao_repository import GetByDescricaoRepository
|
||||
from packages.v1.administrativo.repositories.g_marcacao_tipo.g_marcacao_tipo_get_by_descricao_repository import \
|
||||
GetByDescricaoRepository
|
||||
# Ajuste do schema de entrada
|
||||
from packages.v1.administrativo.schemas.g_marcacao_tipo_schema import \
|
||||
GMarcacaoTipoDescricaoSchema
|
||||
|
||||
|
||||
class GetByDescricaoAction(BaseAction):
|
||||
|
|
@ -28,4 +30,4 @@ class GetByDescricaoAction(BaseAction):
|
|||
response = show_repository.execute(marcacao_tipo_schema)
|
||||
|
||||
# Retorno da informação
|
||||
return response
|
||||
return response
|
||||
|
|
|
|||
|
|
@ -1,6 +1,8 @@
|
|||
from abstracts.action import BaseAction
|
||||
# O repositório TServicoTipoIndexRepository deve ser substituído pelo GMarcacaoTipoIndexRepository.
|
||||
from packages.v1.administrativo.repositories.g_marcacao_tipo.g_marcacao_tipo_index_repository import IndexRepository
|
||||
from packages.v1.administrativo.repositories.g_marcacao_tipo.g_marcacao_tipo_index_repository import \
|
||||
IndexRepository
|
||||
|
||||
|
||||
class IndexAction(BaseAction):
|
||||
"""
|
||||
|
|
@ -22,4 +24,4 @@ class IndexAction(BaseAction):
|
|||
response = index_repository.execute()
|
||||
|
||||
# Retorno da informação
|
||||
return response
|
||||
return response
|
||||
|
|
|
|||
|
|
@ -1,8 +1,11 @@
|
|||
from abstracts.action import BaseAction
|
||||
# Ajuste do schema de entrada
|
||||
from packages.v1.administrativo.schemas.g_marcacao_tipo_schema import GMarcacaoTipoSaveSchema
|
||||
# Ajuste do repositório
|
||||
from packages.v1.administrativo.repositories.g_marcacao_tipo.g_marcacao_tipo_save_repository import SaveRepository
|
||||
from packages.v1.administrativo.repositories.g_marcacao_tipo.g_marcacao_tipo_save_repository import \
|
||||
SaveRepository
|
||||
# Ajuste do schema de entrada
|
||||
from packages.v1.administrativo.schemas.g_marcacao_tipo_schema import \
|
||||
GMarcacaoTipoSaveSchema
|
||||
|
||||
|
||||
class SaveAction(BaseAction):
|
||||
"""
|
||||
|
|
@ -27,4 +30,4 @@ class SaveAction(BaseAction):
|
|||
response = save_repository.execute(marcacao_tipo_schema)
|
||||
|
||||
# Retorno da informação
|
||||
return response
|
||||
return response
|
||||
|
|
|
|||
|
|
@ -1,8 +1,11 @@
|
|||
from abstracts.action import BaseAction
|
||||
# Ajuste do schema de entrada
|
||||
from packages.v1.administrativo.schemas.g_marcacao_tipo_schema import GMarcacaoTipoIdSchema
|
||||
# Ajuste do repositório
|
||||
from packages.v1.administrativo.repositories.g_marcacao_tipo.g_marcacao_tipo_show_repository import ShowRepository
|
||||
from packages.v1.administrativo.repositories.g_marcacao_tipo.g_marcacao_tipo_show_repository import \
|
||||
ShowRepository
|
||||
# Ajuste do schema de entrada
|
||||
from packages.v1.administrativo.schemas.g_marcacao_tipo_schema import \
|
||||
GMarcacaoTipoIdSchema
|
||||
|
||||
|
||||
class ShowAction(BaseAction):
|
||||
"""
|
||||
|
|
@ -13,7 +16,7 @@ class ShowAction(BaseAction):
|
|||
def execute(self, marcacao_tipo_schema: GMarcacaoTipoIdSchema):
|
||||
"""
|
||||
Executa a operação de exibição.
|
||||
|
||||
|
||||
Args:
|
||||
marcacao_tipo_schema (GMarcacaoTipoIdSchema): O esquema com o ID (MARCACAO_TIPO_ID) do registro a ser exibido.
|
||||
|
||||
|
|
@ -27,4 +30,4 @@ class ShowAction(BaseAction):
|
|||
response = show_repository.execute(marcacao_tipo_schema)
|
||||
|
||||
# Retorno da informação
|
||||
return response
|
||||
return response
|
||||
|
|
|
|||
|
|
@ -1,16 +1,22 @@
|
|||
# Importação do Schema ajustada
|
||||
from packages.v1.administrativo.schemas.g_marcacao_tipo_schema import GMarcacaoTipoUpdateSchema
|
||||
# Importação do Repositório ajustada
|
||||
from packages.v1.administrativo.repositories.g_marcacao_tipo.g_marcacao_tipo_update_repository import UpdateRepository
|
||||
from packages.v1.administrativo.repositories.g_marcacao_tipo.g_marcacao_tipo_update_repository import \
|
||||
UpdateRepository
|
||||
from packages.v1.administrativo.schemas.g_marcacao_tipo_schema import \
|
||||
GMarcacaoTipoUpdateSchema
|
||||
|
||||
# A classe UpdateAction não herda de BaseAction no arquivo original, mantemos o padrão.
|
||||
|
||||
|
||||
class UpdateAction:
|
||||
"""
|
||||
Service responsável por encapsular a lógica de negócio para a atualização
|
||||
de um registro na tabela G_MARCACAO_TIPO.
|
||||
Service responsável por encapsular a lógica de negócio para a atualização
|
||||
de um registro na tabela G_MARCACAO_TIPO.
|
||||
"""
|
||||
|
||||
def execute(self, marcacao_tipo_id: int, marcacao_tipo_schema: GMarcacaoTipoUpdateSchema):
|
||||
def execute(
|
||||
self, marcacao_tipo_id: int, marcacao_tipo_schema: GMarcacaoTipoUpdateSchema
|
||||
):
|
||||
"""
|
||||
Executa a operação de atualização.
|
||||
|
||||
|
|
@ -25,4 +31,4 @@ class UpdateAction:
|
|||
update_repository = UpdateRepository()
|
||||
|
||||
# Chama o método de execução do repositório para realizar a atualização
|
||||
return update_repository.execute(marcacao_tipo_id, marcacao_tipo_schema)
|
||||
return update_repository.execute(marcacao_tipo_id, marcacao_tipo_schema)
|
||||
|
|
|
|||
|
|
@ -1,6 +1,8 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.schemas.g_medida_tipo_schema import GMedidaTipoIdSchema
|
||||
from packages.v1.administrativo.repositories.g_medida_tipo.g_medida_tipo_delete_repository import DeleteRepository
|
||||
from packages.v1.administrativo.repositories.g_medida_tipo.g_medida_tipo_delete_repository import \
|
||||
DeleteRepository
|
||||
from packages.v1.administrativo.schemas.g_medida_tipo_schema import \
|
||||
GMedidaTipoIdSchema
|
||||
|
||||
|
||||
class DeleteAction(BaseAction):
|
||||
|
|
@ -23,4 +25,4 @@ class DeleteAction(BaseAction):
|
|||
delete_repository = DeleteRepository()
|
||||
|
||||
# Execução do repositório
|
||||
return delete_repository.execute(medida_tipo_schema)
|
||||
return delete_repository.execute(medida_tipo_schema)
|
||||
|
|
|
|||
|
|
@ -1,6 +1,8 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.schemas.g_medida_tipo_schema import GMedidaTipoDescricaoSchema
|
||||
from packages.v1.administrativo.repositories.g_medida_tipo.g_medida_tipo_get_by_descricao_repository import GetByDescricaoRepository
|
||||
from packages.v1.administrativo.repositories.g_medida_tipo.g_medida_tipo_get_by_descricao_repository import \
|
||||
GetByDescricaoRepository
|
||||
from packages.v1.administrativo.schemas.g_medida_tipo_schema import \
|
||||
GMedidaTipoDescricaoSchema
|
||||
|
||||
|
||||
class GetByDescricaoAction(BaseAction):
|
||||
|
|
@ -26,4 +28,4 @@ class GetByDescricaoAction(BaseAction):
|
|||
response = show_repository.execute(medida_tipo_schema)
|
||||
|
||||
# Retorno da informação
|
||||
return response
|
||||
return response
|
||||
|
|
|
|||
|
|
@ -1,5 +1,7 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.repositories.g_medida_tipo.g_medida_tipo_index_repository import IndexRepository
|
||||
from packages.v1.administrativo.repositories.g_medida_tipo.g_medida_tipo_index_repository import \
|
||||
IndexRepository
|
||||
|
||||
|
||||
class IndexAction(BaseAction):
|
||||
"""
|
||||
|
|
@ -21,4 +23,4 @@ class IndexAction(BaseAction):
|
|||
response = index_repository.execute()
|
||||
|
||||
# Retorno da informação
|
||||
return response
|
||||
return response
|
||||
|
|
|
|||
|
|
@ -1,6 +1,9 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.schemas.g_medida_tipo_schema import GMedidaTipoSaveSchema
|
||||
from packages.v1.administrativo.repositories.g_medida_tipo.g_medida_tipo_save_repository import SaveRepository
|
||||
from packages.v1.administrativo.repositories.g_medida_tipo.g_medida_tipo_save_repository import \
|
||||
SaveRepository
|
||||
from packages.v1.administrativo.schemas.g_medida_tipo_schema import \
|
||||
GMedidaTipoSaveSchema
|
||||
|
||||
|
||||
class SaveAction(BaseAction):
|
||||
"""
|
||||
|
|
@ -25,4 +28,4 @@ class SaveAction(BaseAction):
|
|||
response = save_repository.execute(medida_tipo_schema)
|
||||
|
||||
# Retorno da informação
|
||||
return response
|
||||
return response
|
||||
|
|
|
|||
|
|
@ -1,6 +1,9 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.schemas.g_medida_tipo_schema import GMedidaTipoIdSchema
|
||||
from packages.v1.administrativo.repositories.g_medida_tipo.g_medida_tipo_show_repository import ShowRepository
|
||||
from packages.v1.administrativo.repositories.g_medida_tipo.g_medida_tipo_show_repository import \
|
||||
ShowRepository
|
||||
from packages.v1.administrativo.schemas.g_medida_tipo_schema import \
|
||||
GMedidaTipoIdSchema
|
||||
|
||||
|
||||
class ShowAction(BaseAction):
|
||||
"""
|
||||
|
|
@ -11,7 +14,7 @@ class ShowAction(BaseAction):
|
|||
def execute(self, medida_tipo_schema: GMedidaTipoIdSchema):
|
||||
"""
|
||||
Executa a operação de exibição.
|
||||
|
||||
|
||||
Args:
|
||||
medida_tipo_schema (GMedidaTipoIdSchema): O esquema com o ID do registro a ser exibido.
|
||||
|
||||
|
|
@ -25,4 +28,4 @@ class ShowAction(BaseAction):
|
|||
response = show_repository.execute(medida_tipo_schema)
|
||||
|
||||
# Retorno da informação
|
||||
return response
|
||||
return response
|
||||
|
|
|
|||
|
|
@ -1,11 +1,13 @@
|
|||
from packages.v1.administrativo.schemas.g_medida_tipo_schema import GMedidaTipoUpdateSchema
|
||||
from packages.v1.administrativo.repositories.g_medida_tipo.g_medida_tipo_update_repository import UpdateRepository
|
||||
from packages.v1.administrativo.repositories.g_medida_tipo.g_medida_tipo_update_repository import \
|
||||
UpdateRepository
|
||||
from packages.v1.administrativo.schemas.g_medida_tipo_schema import \
|
||||
GMedidaTipoUpdateSchema
|
||||
|
||||
|
||||
class UpdateAction:
|
||||
"""
|
||||
Service responsável por encapsular a lógica de negócio para a atualização
|
||||
de um registro na tabela g_medida_tipo.
|
||||
Service responsável por encapsular a lógica de negócio para a atualização
|
||||
de um registro na tabela g_medida_tipo.
|
||||
"""
|
||||
|
||||
def execute(self, medida_tipo_id: int, medida_tipo_schema: GMedidaTipoUpdateSchema):
|
||||
|
|
@ -23,4 +25,4 @@ class UpdateAction:
|
|||
update_repository = UpdateRepository()
|
||||
|
||||
# Chama o método de execução do repositório para realizar a atualização
|
||||
return update_repository.execute(medida_tipo_id, medida_tipo_schema)
|
||||
return update_repository.execute(medida_tipo_id, medida_tipo_schema)
|
||||
|
|
|
|||
|
|
@ -1,6 +1,8 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.schemas.g_natureza_schema import GNaturezaIdSchema
|
||||
from packages.v1.administrativo.repositories.g_natureza.g_natureza_delete_repository import DeleteRepository
|
||||
from packages.v1.administrativo.repositories.g_natureza.g_natureza_delete_repository import \
|
||||
DeleteRepository
|
||||
from packages.v1.administrativo.schemas.g_natureza_schema import \
|
||||
GNaturezaIdSchema
|
||||
|
||||
|
||||
class DeleteAction(BaseAction):
|
||||
|
|
@ -23,4 +25,4 @@ class DeleteAction(BaseAction):
|
|||
delete_repository = DeleteRepository()
|
||||
|
||||
# Execução do repositório
|
||||
return delete_repository.execute(natureza_schema)
|
||||
return delete_repository.execute(natureza_schema)
|
||||
|
|
|
|||
|
|
@ -1,6 +1,8 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.schemas.g_natureza_schema import GNaturezaDescricaoSchema
|
||||
from packages.v1.administrativo.repositories.g_natureza.g_natureza_get_by_descricao_repository import GetByDescricaoRepository
|
||||
from packages.v1.administrativo.repositories.g_natureza.g_natureza_get_by_descricao_repository import \
|
||||
GetByDescricaoRepository
|
||||
from packages.v1.administrativo.schemas.g_natureza_schema import \
|
||||
GNaturezaDescricaoSchema
|
||||
|
||||
|
||||
class GetByDescricaoAction(BaseAction):
|
||||
|
|
@ -26,4 +28,4 @@ class GetByDescricaoAction(BaseAction):
|
|||
response = show_repository.execute(natureza_schema)
|
||||
|
||||
# Retorno da informação
|
||||
return response
|
||||
return response
|
||||
|
|
|
|||
|
|
@ -1,5 +1,7 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.repositories.g_natureza.g_natureza_index_repository import IndexRepository
|
||||
from packages.v1.administrativo.repositories.g_natureza.g_natureza_index_repository import \
|
||||
IndexRepository
|
||||
|
||||
|
||||
class IndexAction(BaseAction):
|
||||
"""
|
||||
|
|
@ -21,4 +23,4 @@ class IndexAction(BaseAction):
|
|||
response = index_repository.execute()
|
||||
|
||||
# Retorno da informação
|
||||
return response
|
||||
return response
|
||||
|
|
|
|||
|
|
@ -1,6 +1,9 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.schemas.g_natureza_schema import GNaturezaSaveSchema
|
||||
from packages.v1.administrativo.repositories.g_natureza.g_natureza_save_repository import SaveRepository
|
||||
from packages.v1.administrativo.repositories.g_natureza.g_natureza_save_repository import \
|
||||
SaveRepository
|
||||
from packages.v1.administrativo.schemas.g_natureza_schema import \
|
||||
GNaturezaSaveSchema
|
||||
|
||||
|
||||
class SaveAction(BaseAction):
|
||||
"""
|
||||
|
|
@ -25,4 +28,4 @@ class SaveAction(BaseAction):
|
|||
response = save_repository.execute(natureza_schema)
|
||||
|
||||
# Retorno da informação
|
||||
return response
|
||||
return response
|
||||
|
|
|
|||
|
|
@ -1,6 +1,9 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.schemas.g_natureza_schema import GNaturezaIdSchema
|
||||
from packages.v1.administrativo.repositories.g_natureza.g_natureza_show_repository import ShowRepository
|
||||
from packages.v1.administrativo.repositories.g_natureza.g_natureza_show_repository import \
|
||||
ShowRepository
|
||||
from packages.v1.administrativo.schemas.g_natureza_schema import \
|
||||
GNaturezaIdSchema
|
||||
|
||||
|
||||
class ShowAction(BaseAction):
|
||||
"""
|
||||
|
|
@ -11,7 +14,7 @@ class ShowAction(BaseAction):
|
|||
def execute(self, natureza_schema: GNaturezaIdSchema):
|
||||
"""
|
||||
Executa a operação de exibição.
|
||||
|
||||
|
||||
Args:
|
||||
natureza_schema (GNaturezaIdSchema): O esquema com o ID do registro a ser exibido.
|
||||
|
||||
|
|
@ -25,4 +28,4 @@ class ShowAction(BaseAction):
|
|||
response = show_repository.execute(natureza_schema)
|
||||
|
||||
# Retorno da informação
|
||||
return response
|
||||
return response
|
||||
|
|
|
|||
|
|
@ -1,11 +1,13 @@
|
|||
from packages.v1.administrativo.schemas.g_natureza_schema import GNaturezaUpdateSchema
|
||||
from packages.v1.administrativo.repositories.g_natureza.g_natureza_update_repository import UpdateRepository
|
||||
from packages.v1.administrativo.repositories.g_natureza.g_natureza_update_repository import \
|
||||
UpdateRepository
|
||||
from packages.v1.administrativo.schemas.g_natureza_schema import \
|
||||
GNaturezaUpdateSchema
|
||||
|
||||
|
||||
class UpdateAction:
|
||||
"""
|
||||
Service responsável por encapsular a lógica de negócio para a atualização
|
||||
de um registro na tabela g_natureza.
|
||||
Service responsável por encapsular a lógica de negócio para a atualização
|
||||
de um registro na tabela g_natureza.
|
||||
"""
|
||||
|
||||
def execute(self, natureza_id: int, natureza_schema: GNaturezaUpdateSchema):
|
||||
|
|
@ -23,4 +25,4 @@ class UpdateAction:
|
|||
update_repository = UpdateRepository()
|
||||
|
||||
# Chama o método de execução do repositório para realizar a atualização
|
||||
return update_repository.execute(natureza_id, natureza_schema)
|
||||
return update_repository.execute(natureza_id, natureza_schema)
|
||||
|
|
|
|||
|
|
@ -1,6 +1,8 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.schemas.g_tb_bairro_schema import GTbBairroIdSchema
|
||||
from packages.v1.administrativo.repositories.g_tb_bairro.g_tb_bairro_delete_repository import DeleteRepository
|
||||
from packages.v1.administrativo.repositories.g_tb_bairro.g_tb_bairro_delete_repository import \
|
||||
DeleteRepository
|
||||
from packages.v1.administrativo.schemas.g_tb_bairro_schema import \
|
||||
GTbBairroIdSchema
|
||||
|
||||
|
||||
class DeleteAction(BaseAction):
|
||||
|
|
@ -23,4 +25,4 @@ class DeleteAction(BaseAction):
|
|||
delete_repository = DeleteRepository()
|
||||
|
||||
# Execução do repositório
|
||||
return delete_repository.execute(bairro_schema)
|
||||
return delete_repository.execute(bairro_schema)
|
||||
|
|
|
|||
|
|
@ -1,6 +1,8 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.schemas.g_tb_bairro_schema import GTbBairroDescricaoSchema
|
||||
from packages.v1.administrativo.repositories.g_tb_bairro.g_tb_bairro_get_by_descricao_repository import GetByDescricaoRepository
|
||||
from packages.v1.administrativo.repositories.g_tb_bairro.g_tb_bairro_get_by_descricao_repository import \
|
||||
GetByDescricaoRepository
|
||||
from packages.v1.administrativo.schemas.g_tb_bairro_schema import \
|
||||
GTbBairroDescricaoSchema
|
||||
|
||||
|
||||
class GetByDescricaoAction(BaseAction):
|
||||
|
|
@ -26,4 +28,4 @@ class GetByDescricaoAction(BaseAction):
|
|||
response = show_repository.execute(bairro_schema)
|
||||
|
||||
# Retorno da informação
|
||||
return response
|
||||
return response
|
||||
|
|
|
|||
|
|
@ -1,5 +1,7 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.repositories.g_tb_bairro.g_tb_bairro_index_repository import IndexRepository
|
||||
from packages.v1.administrativo.repositories.g_tb_bairro.g_tb_bairro_index_repository import \
|
||||
IndexRepository
|
||||
|
||||
|
||||
class IndexAction(BaseAction):
|
||||
"""
|
||||
|
|
@ -21,4 +23,4 @@ class IndexAction(BaseAction):
|
|||
response = index_repository.execute()
|
||||
|
||||
# Retorno da informação
|
||||
return response
|
||||
return response
|
||||
|
|
|
|||
|
|
@ -1,6 +1,9 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.schemas.g_tb_bairro_schema import GTbBairroSaveSchema
|
||||
from packages.v1.administrativo.repositories.g_tb_bairro.g_tb_bairro_save_repository import SaveRepository
|
||||
from packages.v1.administrativo.repositories.g_tb_bairro.g_tb_bairro_save_repository import \
|
||||
SaveRepository
|
||||
from packages.v1.administrativo.schemas.g_tb_bairro_schema import \
|
||||
GTbBairroSaveSchema
|
||||
|
||||
|
||||
class SaveAction(BaseAction):
|
||||
"""
|
||||
|
|
@ -25,4 +28,4 @@ class SaveAction(BaseAction):
|
|||
response = save_repository.execute(bairro_schema)
|
||||
|
||||
# Retorno da informação
|
||||
return response
|
||||
return response
|
||||
|
|
|
|||
|
|
@ -1,6 +1,9 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.schemas.g_tb_bairro_schema import GTbBairroIdSchema
|
||||
from packages.v1.administrativo.repositories.g_tb_bairro.g_tb_bairro_show_repository import ShowRepository
|
||||
from packages.v1.administrativo.repositories.g_tb_bairro.g_tb_bairro_show_repository import \
|
||||
ShowRepository
|
||||
from packages.v1.administrativo.schemas.g_tb_bairro_schema import \
|
||||
GTbBairroIdSchema
|
||||
|
||||
|
||||
class ShowAction(BaseAction):
|
||||
"""
|
||||
|
|
@ -11,7 +14,7 @@ class ShowAction(BaseAction):
|
|||
def execute(self, bairro_schema: GTbBairroIdSchema):
|
||||
"""
|
||||
Executa a operação de exibição.
|
||||
|
||||
|
||||
Args:
|
||||
bairro_schema (GTbBairroIdSchema): O esquema com o ID do registro a ser exibido.
|
||||
|
||||
|
|
@ -25,4 +28,4 @@ class ShowAction(BaseAction):
|
|||
response = show_repository.execute(bairro_schema)
|
||||
|
||||
# Retorno da informação
|
||||
return response
|
||||
return response
|
||||
|
|
|
|||
|
|
@ -1,11 +1,13 @@
|
|||
from packages.v1.administrativo.schemas.g_tb_bairro_schema import GTbBairroUpdateSchema
|
||||
from packages.v1.administrativo.repositories.g_tb_bairro.g_tb_bairro_update_repository import UpdateRepository
|
||||
from packages.v1.administrativo.repositories.g_tb_bairro.g_tb_bairro_update_repository import \
|
||||
UpdateRepository
|
||||
from packages.v1.administrativo.schemas.g_tb_bairro_schema import \
|
||||
GTbBairroUpdateSchema
|
||||
|
||||
|
||||
class UpdateAction:
|
||||
"""
|
||||
Service responsável por encapsular a lógica de negócio para a atualização
|
||||
de um registro na tabela g_tb_bairro.
|
||||
Service responsável por encapsular a lógica de negócio para a atualização
|
||||
de um registro na tabela g_tb_bairro.
|
||||
"""
|
||||
|
||||
def execute(self, tb_bairro_id: int, bairro_schema: GTbBairroUpdateSchema):
|
||||
|
|
@ -23,4 +25,4 @@ class UpdateAction:
|
|||
update_repository = UpdateRepository()
|
||||
|
||||
# Chama o método de execução do repositório para realizar a atualização
|
||||
return update_repository.execute(tb_bairro_id, bairro_schema)
|
||||
return update_repository.execute(tb_bairro_id, bairro_schema)
|
||||
|
|
|
|||
|
|
@ -1,6 +1,8 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.schemas.g_tb_documentotipo_schema import GTbDocumentoTipoIdSchema
|
||||
from packages.v1.administrativo.repositories.g_tb_documentotipo.g_tb_documentotipo_delete_repository import DeleteRepository
|
||||
from packages.v1.administrativo.repositories.g_tb_documentotipo.g_tb_documentotipo_delete_repository import \
|
||||
DeleteRepository
|
||||
from packages.v1.administrativo.schemas.g_tb_documentotipo_schema import \
|
||||
GTbDocumentoTipoIdSchema
|
||||
|
||||
|
||||
class DeleteAction(BaseAction):
|
||||
|
|
@ -23,4 +25,4 @@ class DeleteAction(BaseAction):
|
|||
delete_repository = DeleteRepository()
|
||||
|
||||
# Execução do repositório
|
||||
return delete_repository.execute(documento_tipo_schema)
|
||||
return delete_repository.execute(documento_tipo_schema)
|
||||
|
|
|
|||
|
|
@ -1,6 +1,8 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.schemas.g_tb_documentotipo_schema import GTbDocumentoTipoDescricaoSchema
|
||||
from packages.v1.administrativo.repositories.g_tb_documentotipo.g_tb_documentotipo_get_by_descricao_repository import GetByDescricaoRepository
|
||||
from packages.v1.administrativo.repositories.g_tb_documentotipo.g_tb_documentotipo_get_by_descricao_repository import \
|
||||
GetByDescricaoRepository
|
||||
from packages.v1.administrativo.schemas.g_tb_documentotipo_schema import \
|
||||
GTbDocumentoTipoDescricaoSchema
|
||||
|
||||
|
||||
class GetByDescricaoAction(BaseAction):
|
||||
|
|
@ -26,4 +28,4 @@ class GetByDescricaoAction(BaseAction):
|
|||
response = show_repository.execute(documento_tipo_schema)
|
||||
|
||||
# Retorno da informação
|
||||
return response
|
||||
return response
|
||||
|
|
|
|||
|
|
@ -1,5 +1,7 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.repositories.g_tb_documentotipo.g_tb_documentotipo_index_repository import IndexRepository
|
||||
from packages.v1.administrativo.repositories.g_tb_documentotipo.g_tb_documentotipo_index_repository import \
|
||||
IndexRepository
|
||||
|
||||
|
||||
class IndexAction(BaseAction):
|
||||
"""
|
||||
|
|
@ -21,4 +23,4 @@ class IndexAction(BaseAction):
|
|||
response = index_repository.execute()
|
||||
|
||||
# Retorno da informação
|
||||
return response
|
||||
return response
|
||||
|
|
|
|||
|
|
@ -1,6 +1,9 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.schemas.g_tb_documentotipo_schema import GTbDocumentoTipoSaveSchema
|
||||
from packages.v1.administrativo.repositories.g_tb_documentotipo.g_tb_documentotipo_save_repository import SaveRepository
|
||||
from packages.v1.administrativo.repositories.g_tb_documentotipo.g_tb_documentotipo_save_repository import \
|
||||
SaveRepository
|
||||
from packages.v1.administrativo.schemas.g_tb_documentotipo_schema import \
|
||||
GTbDocumentoTipoSaveSchema
|
||||
|
||||
|
||||
class SaveAction(BaseAction):
|
||||
"""
|
||||
|
|
@ -25,4 +28,4 @@ class SaveAction(BaseAction):
|
|||
response = save_repository.execute(documento_tipo_schema)
|
||||
|
||||
# Retorno da informação
|
||||
return response
|
||||
return response
|
||||
|
|
|
|||
|
|
@ -1,6 +1,9 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.schemas.g_tb_documentotipo_schema import GTbDocumentoTipoIdSchema
|
||||
from packages.v1.administrativo.repositories.g_tb_documentotipo.g_tb_documentotipo_show_repository import ShowRepository
|
||||
from packages.v1.administrativo.repositories.g_tb_documentotipo.g_tb_documentotipo_show_repository import \
|
||||
ShowRepository
|
||||
from packages.v1.administrativo.schemas.g_tb_documentotipo_schema import \
|
||||
GTbDocumentoTipoIdSchema
|
||||
|
||||
|
||||
class ShowAction(BaseAction):
|
||||
"""
|
||||
|
|
@ -11,7 +14,7 @@ class ShowAction(BaseAction):
|
|||
def execute(self, documento_tipo_schema: GTbDocumentoTipoIdSchema):
|
||||
"""
|
||||
Executa a operação de exibição.
|
||||
|
||||
|
||||
Args:
|
||||
documento_tipo_schema (GTbDocumentoTipoIdSchema): O esquema com o ID do registro a ser exibido.
|
||||
|
||||
|
|
@ -25,4 +28,4 @@ class ShowAction(BaseAction):
|
|||
response = show_repository.execute(documento_tipo_schema)
|
||||
|
||||
# Retorno da informação
|
||||
return response
|
||||
return response
|
||||
|
|
|
|||
|
|
@ -1,14 +1,20 @@
|
|||
from packages.v1.administrativo.schemas.g_tb_documentotipo_schema import GTbDocumentoTipoUpdateSchema
|
||||
from packages.v1.administrativo.repositories.g_tb_documentotipo.g_tb_documentotipo_update_repository import UpdateRepository
|
||||
from packages.v1.administrativo.repositories.g_tb_documentotipo.g_tb_documentotipo_update_repository import \
|
||||
UpdateRepository
|
||||
from packages.v1.administrativo.schemas.g_tb_documentotipo_schema import \
|
||||
GTbDocumentoTipoUpdateSchema
|
||||
|
||||
|
||||
class UpdateAction:
|
||||
"""
|
||||
Service responsável por encapsular a lógica de negócio para a atualização
|
||||
de um registro na tabela g_tb_documentotipo.
|
||||
Service responsável por encapsular a lógica de negócio para a atualização
|
||||
de um registro na tabela g_tb_documentotipo.
|
||||
"""
|
||||
|
||||
def execute(self, documento_tipo_id: int, documento_tipo_schema: GTbDocumentoTipoUpdateSchema):
|
||||
def execute(
|
||||
self,
|
||||
documento_tipo_id: int,
|
||||
documento_tipo_schema: GTbDocumentoTipoUpdateSchema,
|
||||
):
|
||||
"""
|
||||
Executa a operação de atualização.
|
||||
|
||||
|
|
@ -23,4 +29,4 @@ class UpdateAction:
|
|||
update_repository = UpdateRepository()
|
||||
|
||||
# Chama o método de execução do repositório para realizar a atualização
|
||||
return update_repository.execute(documento_tipo_id, documento_tipo_schema)
|
||||
return update_repository.execute(documento_tipo_id, documento_tipo_schema)
|
||||
|
|
|
|||
|
|
@ -1,6 +1,8 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.schemas.g_tb_estadocivil_schema import GTbEstadoCivilIdSchema
|
||||
from packages.v1.administrativo.repositories.g_tb_estadocivil.g_tb_estadocivil_delete_repository import DeleteRepository
|
||||
from packages.v1.administrativo.repositories.g_tb_estadocivil.g_tb_estadocivil_delete_repository import \
|
||||
DeleteRepository
|
||||
from packages.v1.administrativo.schemas.g_tb_estadocivil_schema import \
|
||||
GTbEstadoCivilIdSchema
|
||||
|
||||
|
||||
class DeleteAction(BaseAction):
|
||||
|
|
@ -23,4 +25,4 @@ class DeleteAction(BaseAction):
|
|||
delete_repository = DeleteRepository()
|
||||
|
||||
# Execução do repositório
|
||||
return delete_repository.execute(estadocivil_schema)
|
||||
return delete_repository.execute(estadocivil_schema)
|
||||
|
|
|
|||
|
|
@ -1,6 +1,8 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.schemas.g_tb_estadocivil_schema import GTbEstadoCivilDescricaoSchema
|
||||
from packages.v1.administrativo.repositories.g_tb_estadocivil.g_tb_estadocivil_get_by_descricao_repository import GetByDescricaoRepository
|
||||
from packages.v1.administrativo.repositories.g_tb_estadocivil.g_tb_estadocivil_get_by_descricao_repository import \
|
||||
GetByDescricaoRepository
|
||||
from packages.v1.administrativo.schemas.g_tb_estadocivil_schema import \
|
||||
GTbEstadoCivilDescricaoSchema
|
||||
|
||||
|
||||
class GetByDescricaoAction(BaseAction):
|
||||
|
|
@ -26,4 +28,4 @@ class GetByDescricaoAction(BaseAction):
|
|||
response = show_repository.execute(estadocivil_schema)
|
||||
|
||||
# Retorno da informação
|
||||
return response
|
||||
return response
|
||||
|
|
|
|||
|
|
@ -1,5 +1,7 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.repositories.g_tb_estadocivil.g_tb_estadocivil_index_repository import IndexRepository
|
||||
from packages.v1.administrativo.repositories.g_tb_estadocivil.g_tb_estadocivil_index_repository import \
|
||||
IndexRepository
|
||||
|
||||
|
||||
class IndexAction(BaseAction):
|
||||
"""
|
||||
|
|
@ -21,4 +23,4 @@ class IndexAction(BaseAction):
|
|||
response = index_repository.execute()
|
||||
|
||||
# Retorno da informação
|
||||
return response
|
||||
return response
|
||||
|
|
|
|||
|
|
@ -1,6 +1,9 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.schemas.g_tb_estadocivil_schema import GTbEstadoCivilSaveSchema
|
||||
from packages.v1.administrativo.repositories.g_tb_estadocivil.g_tb_estadocivil_save_repository import SaveRepository
|
||||
from packages.v1.administrativo.repositories.g_tb_estadocivil.g_tb_estadocivil_save_repository import \
|
||||
SaveRepository
|
||||
from packages.v1.administrativo.schemas.g_tb_estadocivil_schema import \
|
||||
GTbEstadoCivilSaveSchema
|
||||
|
||||
|
||||
class SaveAction(BaseAction):
|
||||
"""
|
||||
|
|
@ -25,4 +28,4 @@ class SaveAction(BaseAction):
|
|||
response = save_repository.execute(estadocivil_schema)
|
||||
|
||||
# Retorno da informação
|
||||
return response
|
||||
return response
|
||||
|
|
|
|||
|
|
@ -1,6 +1,9 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.schemas.g_tb_estadocivil_schema import GTbEstadoCivilIdSchema
|
||||
from packages.v1.administrativo.repositories.g_tb_estadocivil.g_tb_estadocivil_show_repository import ShowRepository
|
||||
from packages.v1.administrativo.repositories.g_tb_estadocivil.g_tb_estadocivil_show_repository import \
|
||||
ShowRepository
|
||||
from packages.v1.administrativo.schemas.g_tb_estadocivil_schema import \
|
||||
GTbEstadoCivilIdSchema
|
||||
|
||||
|
||||
class ShowAction(BaseAction):
|
||||
"""
|
||||
|
|
@ -11,7 +14,7 @@ class ShowAction(BaseAction):
|
|||
def execute(self, estadocivil_schema: GTbEstadoCivilIdSchema):
|
||||
"""
|
||||
Executa a operação de exibição.
|
||||
|
||||
|
||||
Args:
|
||||
estadocivil_schema (GTbEstadoCivilIdSchema): O esquema com o ID do registro a ser exibido.
|
||||
|
||||
|
|
@ -25,4 +28,4 @@ class ShowAction(BaseAction):
|
|||
response = show_repository.execute(estadocivil_schema)
|
||||
|
||||
# Retorno da informação
|
||||
return response
|
||||
return response
|
||||
|
|
|
|||
|
|
@ -1,14 +1,18 @@
|
|||
from packages.v1.administrativo.schemas.g_tb_estadocivil_schema import GTbEstadoCivilUpdateSchema
|
||||
from packages.v1.administrativo.repositories.g_tb_estadocivil.g_tb_estadocivil_update_repository import UpdateRepository
|
||||
from packages.v1.administrativo.repositories.g_tb_estadocivil.g_tb_estadocivil_update_repository import \
|
||||
UpdateRepository
|
||||
from packages.v1.administrativo.schemas.g_tb_estadocivil_schema import \
|
||||
GTbEstadoCivilUpdateSchema
|
||||
|
||||
|
||||
class UpdateAction:
|
||||
"""
|
||||
Service responsável por encapsular a lógica de negócio para a atualização
|
||||
de um registro na tabela g_tb_estadocivil.
|
||||
Service responsável por encapsular a lógica de negócio para a atualização
|
||||
de um registro na tabela g_tb_estadocivil.
|
||||
"""
|
||||
|
||||
def execute(self, tb_estadocivil_id: int, estadocivil_schema: GTbEstadoCivilUpdateSchema):
|
||||
def execute(
|
||||
self, tb_estadocivil_id: int, estadocivil_schema: GTbEstadoCivilUpdateSchema
|
||||
):
|
||||
"""
|
||||
Executa a operação de atualização.
|
||||
|
||||
|
|
@ -23,4 +27,4 @@ class UpdateAction:
|
|||
update_repository = UpdateRepository()
|
||||
|
||||
# Chama o método de execução do repositório para realizar a atualização
|
||||
return update_repository.execute(tb_estadocivil_id, estadocivil_schema)
|
||||
return update_repository.execute(tb_estadocivil_id, estadocivil_schema)
|
||||
|
|
|
|||
|
|
@ -1,6 +1,8 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.schemas.g_tb_profissao_schema import GTbProfissaoIdSchema
|
||||
from packages.v1.administrativo.repositories.g_tb_profissao.g_tb_profissao_delete_repository import DeleteRepository
|
||||
from packages.v1.administrativo.repositories.g_tb_profissao.g_tb_profissao_delete_repository import \
|
||||
DeleteRepository
|
||||
from packages.v1.administrativo.schemas.g_tb_profissao_schema import \
|
||||
GTbProfissaoIdSchema
|
||||
|
||||
|
||||
class GTbProfissaoDeleteAction(BaseAction):
|
||||
|
|
@ -23,4 +25,4 @@ class GTbProfissaoDeleteAction(BaseAction):
|
|||
delete_repository = DeleteRepository()
|
||||
|
||||
# Execução do repositório
|
||||
return delete_repository.execute(profissao_schema)
|
||||
return delete_repository.execute(profissao_schema)
|
||||
|
|
|
|||
|
|
@ -1,6 +1,9 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.schemas.g_tb_profissao_schema import GTbProfissaoDescricaoSchema
|
||||
from packages.v1.administrativo.repositories.g_tb_profissao.g_tb_profissao_get_by_descricao_repository import GetByDescricaoRepository
|
||||
from packages.v1.administrativo.repositories.g_tb_profissao.g_tb_profissao_get_by_descricao_repository import \
|
||||
GetByDescricaoRepository
|
||||
from packages.v1.administrativo.schemas.g_tb_profissao_schema import \
|
||||
GTbProfissaoDescricaoSchema
|
||||
|
||||
|
||||
class GTbProfissaoGetByDescricaoAction(BaseAction):
|
||||
"""
|
||||
|
|
@ -25,4 +28,4 @@ class GTbProfissaoGetByDescricaoAction(BaseAction):
|
|||
response = show_repository.execute(profissao_schema)
|
||||
|
||||
# Retorno da informação
|
||||
return response
|
||||
return response
|
||||
|
|
|
|||
|
|
@ -1,5 +1,7 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.repositories.g_tb_profissao.g_tb_profissao_index_repository import IndexRepository
|
||||
from packages.v1.administrativo.repositories.g_tb_profissao.g_tb_profissao_index_repository import \
|
||||
IndexRepository
|
||||
|
||||
|
||||
class GTbProfissaoIndexAction(BaseAction):
|
||||
"""
|
||||
|
|
@ -21,4 +23,4 @@ class GTbProfissaoIndexAction(BaseAction):
|
|||
response = index_repository.execute()
|
||||
|
||||
# Retorno da informação
|
||||
return response
|
||||
return response
|
||||
|
|
|
|||
|
|
@ -1,6 +1,9 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.schemas.g_tb_profissao_schema import GTbProfissaoSaveSchema
|
||||
from packages.v1.administrativo.repositories.g_tb_profissao.g_tb_profissao_save_repository import SaveRepository
|
||||
from packages.v1.administrativo.repositories.g_tb_profissao.g_tb_profissao_save_repository import \
|
||||
SaveRepository
|
||||
from packages.v1.administrativo.schemas.g_tb_profissao_schema import \
|
||||
GTbProfissaoSaveSchema
|
||||
|
||||
|
||||
class GTbProfissaoSaveAction(BaseAction):
|
||||
"""
|
||||
|
|
@ -11,7 +14,7 @@ class GTbProfissaoSaveAction(BaseAction):
|
|||
def execute(self, profissao_schema: GTbProfissaoSaveSchema):
|
||||
"""
|
||||
Executa a operação de salvamento.
|
||||
|
||||
|
||||
Args:
|
||||
profissao_schema (GTbProfissaoSaveSchema): O esquema com os dados a serem salvos.
|
||||
|
||||
|
|
@ -25,4 +28,4 @@ class GTbProfissaoSaveAction(BaseAction):
|
|||
response = save_repository.execute(profissao_schema)
|
||||
|
||||
# Retorno da informação
|
||||
return response
|
||||
return response
|
||||
|
|
|
|||
|
|
@ -1,6 +1,9 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.schemas.g_tb_profissao_schema import GTbProfissaoIdSchema
|
||||
from packages.v1.administrativo.repositories.g_tb_profissao.g_tb_profissao_show_repository import ShowRepository
|
||||
from packages.v1.administrativo.repositories.g_tb_profissao.g_tb_profissao_show_repository import \
|
||||
ShowRepository
|
||||
from packages.v1.administrativo.schemas.g_tb_profissao_schema import \
|
||||
GTbProfissaoIdSchema
|
||||
|
||||
|
||||
class GTbProfissaoShowAction(BaseAction):
|
||||
"""
|
||||
|
|
@ -11,7 +14,7 @@ class GTbProfissaoShowAction(BaseAction):
|
|||
def execute(self, profissao_schema: GTbProfissaoIdSchema):
|
||||
"""
|
||||
Executa a operação de exibição.
|
||||
|
||||
|
||||
Args:
|
||||
profissao_schema (GTbProfissaoIdSchema): O esquema com o ID do registro a ser exibido.
|
||||
|
||||
|
|
@ -25,4 +28,4 @@ class GTbProfissaoShowAction(BaseAction):
|
|||
response = show_repository.execute(profissao_schema)
|
||||
|
||||
# Retorno da informação
|
||||
return response
|
||||
return response
|
||||
|
|
|
|||
|
|
@ -1,6 +1,8 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.schemas.g_tb_profissao_schema import GTbProfissaoUpdateSchema
|
||||
from packages.v1.administrativo.repositories.g_tb_profissao.g_tb_profissao_update_repository import UpdateRepository
|
||||
from packages.v1.administrativo.repositories.g_tb_profissao.g_tb_profissao_update_repository import \
|
||||
UpdateRepository
|
||||
from packages.v1.administrativo.schemas.g_tb_profissao_schema import \
|
||||
GTbProfissaoUpdateSchema
|
||||
|
||||
|
||||
class GTbProfissaoUpdateAction(BaseAction):
|
||||
|
|
@ -9,7 +11,9 @@ class GTbProfissaoUpdateAction(BaseAction):
|
|||
de um registro na tabela G_TB_PROFISSAO.
|
||||
"""
|
||||
|
||||
def execute(self, tb_profissao_id: float, profissao_schema: GTbProfissaoUpdateSchema):
|
||||
def execute(
|
||||
self, tb_profissao_id: float, profissao_schema: GTbProfissaoUpdateSchema
|
||||
):
|
||||
"""
|
||||
Executa a operação de atualização.
|
||||
|
||||
|
|
@ -24,4 +28,4 @@ class GTbProfissaoUpdateAction(BaseAction):
|
|||
update_repository = UpdateRepository()
|
||||
|
||||
# Chama o método de execução do repositório para realizar a atualização
|
||||
return update_repository.execute(tb_profissao_id, profissao_schema)
|
||||
return update_repository.execute(tb_profissao_id, profissao_schema)
|
||||
|
|
|
|||
|
|
@ -1,6 +1,8 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.schemas.g_tb_regimebens_schema import GTbRegimebensIdSchema
|
||||
from packages.v1.administrativo.repositories.g_tb_regimebens.g_tb_regimebens_delete_repository import DeleteRepository
|
||||
from packages.v1.administrativo.repositories.g_tb_regimebens.g_tb_regimebens_delete_repository import \
|
||||
DeleteRepository
|
||||
from packages.v1.administrativo.schemas.g_tb_regimebens_schema import \
|
||||
GTbRegimebensIdSchema
|
||||
|
||||
|
||||
class DeleteAction(BaseAction):
|
||||
|
|
@ -23,4 +25,4 @@ class DeleteAction(BaseAction):
|
|||
delete_repository = DeleteRepository()
|
||||
|
||||
# Execução do repositório
|
||||
return delete_repository.execute(regimebens_schema)
|
||||
return delete_repository.execute(regimebens_schema)
|
||||
|
|
|
|||
|
|
@ -1,6 +1,9 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.schemas.g_tb_regimebens_schema import GTbRegimebensDescricaoSchema
|
||||
from packages.v1.administrativo.repositories.g_tb_regimebens.g_tb_regimebens_get_by_descricao_repository import GetByDescricaoRepository
|
||||
from packages.v1.administrativo.repositories.g_tb_regimebens.g_tb_regimebens_get_by_descricao_repository import \
|
||||
GetByDescricaoRepository
|
||||
from packages.v1.administrativo.schemas.g_tb_regimebens_schema import \
|
||||
GTbRegimebensDescricaoSchema
|
||||
|
||||
|
||||
class GetByDescricaoAction(BaseAction):
|
||||
"""
|
||||
|
|
@ -25,4 +28,4 @@ class GetByDescricaoAction(BaseAction):
|
|||
response = show_repository.execute(regimebens_schema)
|
||||
|
||||
# Retorno da informação
|
||||
return response
|
||||
return response
|
||||
|
|
|
|||
|
|
@ -1,5 +1,7 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.repositories.g_tb_regimebens.g_tb_regimebens_index_repository import IndexRepository
|
||||
from packages.v1.administrativo.repositories.g_tb_regimebens.g_tb_regimebens_index_repository import \
|
||||
IndexRepository
|
||||
|
||||
|
||||
class IndexAction(BaseAction):
|
||||
"""
|
||||
|
|
@ -21,4 +23,4 @@ class IndexAction(BaseAction):
|
|||
response = index_repository.execute()
|
||||
|
||||
# Retorno da informação
|
||||
return response
|
||||
return response
|
||||
|
|
|
|||
|
|
@ -1,6 +1,9 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.schemas.g_tb_regimebens_schema import GTbRegimebensSaveSchema
|
||||
from packages.v1.administrativo.repositories.g_tb_regimebens.g_tb_regimebens_save_repository import SaveRepository
|
||||
from packages.v1.administrativo.repositories.g_tb_regimebens.g_tb_regimebens_save_repository import \
|
||||
SaveRepository
|
||||
from packages.v1.administrativo.schemas.g_tb_regimebens_schema import \
|
||||
GTbRegimebensSaveSchema
|
||||
|
||||
|
||||
class SaveAction(BaseAction):
|
||||
"""
|
||||
|
|
@ -11,7 +14,7 @@ class SaveAction(BaseAction):
|
|||
def execute(self, regimebens_schema: GTbRegimebensSaveSchema):
|
||||
"""
|
||||
Executa a operação de salvamento.
|
||||
|
||||
|
||||
Args:
|
||||
regimebens_schema (GTbRegimebensSaveSchema): O esquema com os dados a serem salvos.
|
||||
|
||||
|
|
@ -25,4 +28,4 @@ class SaveAction(BaseAction):
|
|||
response = save_repository.execute(regimebens_schema)
|
||||
|
||||
# Retorno da informação
|
||||
return response
|
||||
return response
|
||||
|
|
|
|||
|
|
@ -1,6 +1,9 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.schemas.g_tb_regimebens_schema import GTbRegimebensIdSchema
|
||||
from packages.v1.administrativo.repositories.g_tb_regimebens.g_tb_regimebens_show_repository import ShowRepository
|
||||
from packages.v1.administrativo.repositories.g_tb_regimebens.g_tb_regimebens_show_repository import \
|
||||
ShowRepository
|
||||
from packages.v1.administrativo.schemas.g_tb_regimebens_schema import \
|
||||
GTbRegimebensIdSchema
|
||||
|
||||
|
||||
class ShowAction(BaseAction):
|
||||
"""
|
||||
|
|
@ -11,7 +14,7 @@ class ShowAction(BaseAction):
|
|||
def execute(self, regimebens_schema: GTbRegimebensIdSchema):
|
||||
"""
|
||||
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 ShowAction(BaseAction):
|
|||
response = show_repository.execute(regimebens_schema)
|
||||
|
||||
# Retorno da informação
|
||||
return response
|
||||
return response
|
||||
|
|
|
|||
|
|
@ -1,14 +1,18 @@
|
|||
from packages.v1.administrativo.schemas.g_tb_regimebens_schema import GTbRegimebensUpdateSchema
|
||||
from packages.v1.administrativo.repositories.g_tb_regimebens.g_tb_regimebens_update_repository import UpdateRepository
|
||||
from packages.v1.administrativo.repositories.g_tb_regimebens.g_tb_regimebens_update_repository import \
|
||||
UpdateRepository
|
||||
from packages.v1.administrativo.schemas.g_tb_regimebens_schema import \
|
||||
GTbRegimebensUpdateSchema
|
||||
|
||||
|
||||
class UpdateAction:
|
||||
"""
|
||||
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, tb_regimebens_id: int, regimebens_schema: GTbRegimebensUpdateSchema):
|
||||
def execute(
|
||||
self, tb_regimebens_id: int, regimebens_schema: GTbRegimebensUpdateSchema
|
||||
):
|
||||
"""
|
||||
Executa a operação de atualização.
|
||||
|
||||
|
|
@ -17,9 +21,9 @@ class UpdateAction:
|
|||
|
||||
Returns:
|
||||
O resultado da operação de atualização.
|
||||
"""
|
||||
"""
|
||||
# Instância o repositório de atualização
|
||||
update_repository = UpdateRepository()
|
||||
|
||||
# Chama o método de execução do repositório para realizar a atualização
|
||||
return update_repository.execute(tb_regimebens_id, regimebens_schema)
|
||||
return update_repository.execute(tb_regimebens_id, regimebens_schema)
|
||||
|
|
|
|||
|
|
@ -1,6 +1,8 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.schemas.g_tb_regimecomunhao_schema import GTbRegimecomunhaoIdSchema
|
||||
from packages.v1.administrativo.repositories.g_tb_regimecomunhao.g_tb_regimecomunhao_delete_repository import DeleteRepository
|
||||
from packages.v1.administrativo.repositories.g_tb_regimecomunhao.g_tb_regimecomunhao_delete_repository import \
|
||||
DeleteRepository
|
||||
from packages.v1.administrativo.schemas.g_tb_regimecomunhao_schema import \
|
||||
GTbRegimecomunhaoIdSchema
|
||||
|
||||
|
||||
class DeleteAction(BaseAction):
|
||||
|
|
@ -23,4 +25,4 @@ class DeleteAction(BaseAction):
|
|||
delete_repository = DeleteRepository()
|
||||
|
||||
# Execução do repositório
|
||||
return delete_repository.execute(regimecomunhao_schema)
|
||||
return delete_repository.execute(regimecomunhao_schema)
|
||||
|
|
|
|||
|
|
@ -1,6 +1,8 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.schemas.g_tb_regimecomunhao_schema import GTbRegimecomunhaoDescricaoSchema
|
||||
from packages.v1.administrativo.repositories.g_tb_regimecomunhao.g_tb_regimecomunhao_get_by_descricao_repository import GetByDescricaoRepository
|
||||
from packages.v1.administrativo.repositories.g_tb_regimecomunhao.g_tb_regimecomunhao_get_by_descricao_repository import \
|
||||
GetByDescricaoRepository
|
||||
from packages.v1.administrativo.schemas.g_tb_regimecomunhao_schema import \
|
||||
GTbRegimecomunhaoDescricaoSchema
|
||||
|
||||
|
||||
class GetByDescricaoAction(BaseAction):
|
||||
|
|
@ -26,4 +28,4 @@ class GetByDescricaoAction(BaseAction):
|
|||
response = show_repository.execute(regimecomunhao_schema)
|
||||
|
||||
# Retorno da informação
|
||||
return response
|
||||
return response
|
||||
|
|
|
|||
|
|
@ -1,5 +1,6 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.repositories.g_tb_regimecomunhao.g_tb_regimecomunhao_index_repository import IndexRepository
|
||||
from packages.v1.administrativo.repositories.g_tb_regimecomunhao.g_tb_regimecomunhao_index_repository import \
|
||||
IndexRepository
|
||||
|
||||
|
||||
class IndexAction(BaseAction):
|
||||
|
|
@ -22,4 +23,4 @@ class IndexAction(BaseAction):
|
|||
response = index_repository.execute()
|
||||
|
||||
# Retorno da informação
|
||||
return response
|
||||
return response
|
||||
|
|
|
|||
|
|
@ -1,6 +1,8 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.schemas.g_tb_regimecomunhao_schema import GTbRegimecomunhaoSaveSchema
|
||||
from packages.v1.administrativo.repositories.g_tb_regimecomunhao.g_tb_regimecomunhao_save_repository import SaveRepository
|
||||
from packages.v1.administrativo.repositories.g_tb_regimecomunhao.g_tb_regimecomunhao_save_repository import \
|
||||
SaveRepository
|
||||
from packages.v1.administrativo.schemas.g_tb_regimecomunhao_schema import \
|
||||
GTbRegimecomunhaoSaveSchema
|
||||
|
||||
|
||||
class SaveAction(BaseAction):
|
||||
|
|
@ -26,4 +28,4 @@ class SaveAction(BaseAction):
|
|||
response = save_repository.execute(regimecomunhao_schema)
|
||||
|
||||
# Retorno da informação
|
||||
return response
|
||||
return response
|
||||
|
|
|
|||
|
|
@ -1,6 +1,8 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.schemas.g_tb_regimecomunhao_schema import GTbRegimecomunhaoIdSchema
|
||||
from packages.v1.administrativo.repositories.g_tb_regimecomunhao.g_tb_regimecomunhao_show_repository import ShowRepository
|
||||
from packages.v1.administrativo.repositories.g_tb_regimecomunhao.g_tb_regimecomunhao_show_repository import \
|
||||
ShowRepository
|
||||
from packages.v1.administrativo.schemas.g_tb_regimecomunhao_schema import \
|
||||
GTbRegimecomunhaoIdSchema
|
||||
|
||||
|
||||
class ShowAction(BaseAction):
|
||||
|
|
@ -26,4 +28,4 @@ class ShowAction(BaseAction):
|
|||
response = show_repository.execute(regimecomunhao_schema)
|
||||
|
||||
# Retorno da informação
|
||||
return response
|
||||
return response
|
||||
|
|
|
|||
|
|
@ -1,14 +1,20 @@
|
|||
from packages.v1.administrativo.schemas.g_tb_regimecomunhao_schema import GTbRegimecomunhaoUpdateSchema
|
||||
from packages.v1.administrativo.repositories.g_tb_regimecomunhao.g_tb_regimecomunhao_update_repository import UpdateRepository
|
||||
from packages.v1.administrativo.repositories.g_tb_regimecomunhao.g_tb_regimecomunhao_update_repository import \
|
||||
UpdateRepository
|
||||
from packages.v1.administrativo.schemas.g_tb_regimecomunhao_schema import \
|
||||
GTbRegimecomunhaoUpdateSchema
|
||||
|
||||
|
||||
class UpdateAction:
|
||||
"""
|
||||
Service responsável por encapsular a lógica de negócio para a atualização
|
||||
de um registro na tabela g_tb_regimecomunhao.
|
||||
Service responsável por encapsular a lógica de negócio para a atualização
|
||||
de um registro na tabela g_tb_regimecomunhao.
|
||||
"""
|
||||
|
||||
def execute(self, tb_regimecomunhao_id : int, regimecomunhao_schema: GTbRegimecomunhaoUpdateSchema):
|
||||
def execute(
|
||||
self,
|
||||
tb_regimecomunhao_id: int,
|
||||
regimecomunhao_schema: GTbRegimecomunhaoUpdateSchema,
|
||||
):
|
||||
"""
|
||||
Executa a operação de atualização.
|
||||
|
||||
|
|
@ -22,4 +28,4 @@ class UpdateAction:
|
|||
update_repository = UpdateRepository()
|
||||
|
||||
# Chama o método de execução do repositório para realizar a atualização
|
||||
return update_repository.execute(tb_regimecomunhao_id, regimecomunhao_schema)
|
||||
return update_repository.execute(tb_regimecomunhao_id, regimecomunhao_schema)
|
||||
|
|
|
|||
|
|
@ -1,6 +1,8 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.schemas.g_tb_tipologradouro_schema import GTbTipoLogradouroIdSchema
|
||||
from packages.v1.administrativo.repositories.g_tb_tipologradouro.g_tb_tipologradouro_delete_repository import DeleteRepository
|
||||
from packages.v1.administrativo.repositories.g_tb_tipologradouro.g_tb_tipologradouro_delete_repository import \
|
||||
DeleteRepository
|
||||
from packages.v1.administrativo.schemas.g_tb_tipologradouro_schema import \
|
||||
GTbTipoLogradouroIdSchema
|
||||
|
||||
|
||||
class DeleteAction(BaseAction):
|
||||
|
|
@ -23,4 +25,4 @@ class DeleteAction(BaseAction):
|
|||
delete_repository = DeleteRepository()
|
||||
|
||||
# Execução do repositório
|
||||
return delete_repository.execute(tipologradouro_schema)
|
||||
return delete_repository.execute(tipologradouro_schema)
|
||||
|
|
|
|||
|
|
@ -1,6 +1,8 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.schemas.g_tb_tipologradouro_schema import GTbTipoLogradouroDescricaoSchema
|
||||
from packages.v1.administrativo.repositories.g_tb_tipologradouro.g_tb_tipologradouro_get_by_descricao_repository import GetByDescricaoRepository
|
||||
from packages.v1.administrativo.repositories.g_tb_tipologradouro.g_tb_tipologradouro_get_by_descricao_repository import \
|
||||
GetByDescricaoRepository
|
||||
from packages.v1.administrativo.schemas.g_tb_tipologradouro_schema import \
|
||||
GTbTipoLogradouroDescricaoSchema
|
||||
|
||||
|
||||
class GetByDescricaoAction(BaseAction):
|
||||
|
|
@ -26,4 +28,4 @@ class GetByDescricaoAction(BaseAction):
|
|||
response = show_repository.execute(tipologradouro_schema)
|
||||
|
||||
# Retorno da informação
|
||||
return response
|
||||
return response
|
||||
|
|
|
|||
|
|
@ -1,5 +1,7 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.repositories.g_tb_tipologradouro.g_tb_tipologradouro_index_repository import IndexRepository
|
||||
from packages.v1.administrativo.repositories.g_tb_tipologradouro.g_tb_tipologradouro_index_repository import \
|
||||
IndexRepository
|
||||
|
||||
|
||||
class IndexAction(BaseAction):
|
||||
"""
|
||||
|
|
@ -21,4 +23,4 @@ class IndexAction(BaseAction):
|
|||
response = index_repository.execute()
|
||||
|
||||
# Retorno da informação
|
||||
return response
|
||||
return response
|
||||
|
|
|
|||
|
|
@ -1,6 +1,9 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.schemas.g_tb_tipologradouro_schema import GTbTipoLogradouroSaveSchema
|
||||
from packages.v1.administrativo.repositories.g_tb_tipologradouro.g_tb_tipologradouro_save_repository import SaveRepository
|
||||
from packages.v1.administrativo.repositories.g_tb_tipologradouro.g_tb_tipologradouro_save_repository import \
|
||||
SaveRepository
|
||||
from packages.v1.administrativo.schemas.g_tb_tipologradouro_schema import \
|
||||
GTbTipoLogradouroSaveSchema
|
||||
|
||||
|
||||
class SaveAction(BaseAction):
|
||||
"""
|
||||
|
|
@ -25,4 +28,4 @@ class SaveAction(BaseAction):
|
|||
response = save_repository.execute(tipologradouro_schema)
|
||||
|
||||
# Retorno da informação
|
||||
return response
|
||||
return response
|
||||
|
|
|
|||
|
|
@ -1,6 +1,9 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.schemas.g_tb_tipologradouro_schema import GTbTipoLogradouroIdSchema
|
||||
from packages.v1.administrativo.repositories.g_tb_tipologradouro.g_tb_tipologradouro_show_repository import ShowRepository
|
||||
from packages.v1.administrativo.repositories.g_tb_tipologradouro.g_tb_tipologradouro_show_repository import \
|
||||
ShowRepository
|
||||
from packages.v1.administrativo.schemas.g_tb_tipologradouro_schema import \
|
||||
GTbTipoLogradouroIdSchema
|
||||
|
||||
|
||||
class ShowAction(BaseAction):
|
||||
"""
|
||||
|
|
@ -11,7 +14,7 @@ class ShowAction(BaseAction):
|
|||
def execute(self, tipologradouro_schema: GTbTipoLogradouroIdSchema):
|
||||
"""
|
||||
Executa a operação de exibição.
|
||||
|
||||
|
||||
Args:
|
||||
tipologradouro_schema (GTbTipologradouroIdSchema): O esquema com o ID do registro a ser exibido.
|
||||
|
||||
|
|
@ -25,4 +28,4 @@ class ShowAction(BaseAction):
|
|||
response = show_repository.execute(tipologradouro_schema)
|
||||
|
||||
# Retorno da informação
|
||||
return response
|
||||
return response
|
||||
|
|
|
|||
|
|
@ -1,14 +1,20 @@
|
|||
from packages.v1.administrativo.schemas.g_tb_tipologradouro_schema import GTbTipoLogradouroUpdateSchema
|
||||
from packages.v1.administrativo.repositories.g_tb_tipologradouro.g_tb_tipologradouro_update_repository import UpdateRepository
|
||||
from packages.v1.administrativo.repositories.g_tb_tipologradouro.g_tb_tipologradouro_update_repository import \
|
||||
UpdateRepository
|
||||
from packages.v1.administrativo.schemas.g_tb_tipologradouro_schema import \
|
||||
GTbTipoLogradouroUpdateSchema
|
||||
|
||||
|
||||
class UpdateAction:
|
||||
"""
|
||||
Serviço responsável por encapsular a lógica de negócio para a atualização
|
||||
de um registro na tabela g_tb_tipologradouro.
|
||||
Serviço responsável por encapsular a lógica de negócio para a atualização
|
||||
de um registro na tabela g_tb_tipologradouro.
|
||||
"""
|
||||
|
||||
def execute(self, tipologradouro_id: int, tipologradouro_schema: GTbTipoLogradouroUpdateSchema):
|
||||
def execute(
|
||||
self,
|
||||
tipologradouro_id: int,
|
||||
tipologradouro_schema: GTbTipoLogradouroUpdateSchema,
|
||||
):
|
||||
"""
|
||||
Executa a operação de atualização.
|
||||
|
||||
|
|
@ -23,4 +29,4 @@ class UpdateAction:
|
|||
update_repository = UpdateRepository()
|
||||
|
||||
# Chama o método de execução do repositório para realizar a atualização
|
||||
return update_repository.execute(tipologradouro_id, tipologradouro_schema)
|
||||
return update_repository.execute(tipologradouro_id, tipologradouro_schema)
|
||||
|
|
|
|||
|
|
@ -1,6 +1,9 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.schemas.g_tb_txmodelogrupo_schema import GTbTxmodelogrupoIdSchema
|
||||
from packages.v1.administrativo.repositories.g_tb_txmodelogrupo.g_tb_txmodelogrupo_delete_repository import DeleteRepository
|
||||
from packages.v1.administrativo.repositories.g_tb_txmodelogrupo.g_tb_txmodelogrupo_delete_repository import \
|
||||
DeleteRepository
|
||||
from packages.v1.administrativo.schemas.g_tb_txmodelogrupo_schema import \
|
||||
GTbTxmodelogrupoIdSchema
|
||||
|
||||
|
||||
class DeleteAction(BaseAction):
|
||||
"""
|
||||
|
|
@ -22,4 +25,4 @@ class DeleteAction(BaseAction):
|
|||
delete_repository = DeleteRepository()
|
||||
|
||||
# Execução do repositório
|
||||
return delete_repository.execute(txmodelogrupo_schema)
|
||||
return delete_repository.execute(txmodelogrupo_schema)
|
||||
|
|
|
|||
|
|
@ -1,6 +1,8 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.schemas.g_tb_txmodelogrupo_schema import GTbTxmodelogrupoDescricaoSchema # Assumindo que um schema similar será criado
|
||||
from packages.v1.administrativo.repositories.g_tb_txmodelogrupo.g_tb_txmodelogrupo_get_by_descricao_repository import GetByDescricaoRepository # Assumindo que um repositório similar será criado
|
||||
from packages.v1.administrativo.repositories.g_tb_txmodelogrupo.g_tb_txmodelogrupo_get_by_descricao_repository import \
|
||||
GetByDescricaoRepository # Assumindo que um repositório similar será criado
|
||||
from packages.v1.administrativo.schemas.g_tb_txmodelogrupo_schema import \
|
||||
GTbTxmodelogrupoDescricaoSchema # Assumindo que um schema similar será criado
|
||||
|
||||
|
||||
class GetByDescricaoAction(BaseAction):
|
||||
|
|
@ -26,4 +28,4 @@ class GetByDescricaoAction(BaseAction):
|
|||
response = get_by_descricao_repository.execute(txmodelogrupo_schema)
|
||||
|
||||
# Retorno da informação
|
||||
return response
|
||||
return response
|
||||
|
|
|
|||
|
|
@ -1,5 +1,6 @@
|
|||
from abstracts.action import BaseAction
|
||||
from packages.v1.administrativo.repositories.g_tb_txmodelogrupo.g_tb_txmodelogrupo_index_repository import IndexRepository
|
||||
from packages.v1.administrativo.repositories.g_tb_txmodelogrupo.g_tb_txmodelogrupo_index_repository import \
|
||||
IndexRepository
|
||||
|
||||
|
||||
class IndexAction(BaseAction):
|
||||
|
|
@ -22,4 +23,4 @@ class IndexAction(BaseAction):
|
|||
response = index_repository.execute()
|
||||
|
||||
# Retorno da informação
|
||||
return response
|
||||
return response
|
||||
|
|
|
|||
Some files were not shown because too many files have changed in this diff Show more
Loading…
Add table
Reference in a new issue