Merge branch 'release(MVP/Sprint2)' of https://git.oriustecnologia.com/kenio/saas into release(MVP/Sprint2)

packages/v1/administrativo/actions/t_tb_andamentoservico/t_tb_andamentoservico_delete_action.py

@@ -0,0 +1,26 @@
+from abstracts.action import BaseAction
+from packages.v1.administrativo.schemas.t_tb_andamentoservico_schema import TTbAndamentoservicoIdSchema
+from packages.v1.administrativo.repositories.t_tb_andamentoservico.t_tb_andamentoservico_delete_repository import DeleteRepository
+
+
+class DeleteAction(BaseAction):
+    """
+    Serviço responsável por encapsular a lógica de negócio para a operação
+    de exclusão de um registro na tabela t_tb_andamentoservico.
+    """
+
+    def execute(self, andamentoservico_schema: TTbAndamentoservicoIdSchema):
+        """
+        Executa a operação de exclusão no banco de dados.
+
+        Args:
+            andamentoservico_schema (TTbAndamentoservicoIdSchema): O esquema com o ID a ser excluído.
+
+        Returns:
+            O resultado da operação de exclusão.
+        """
+        # Instanciamento do repositório
+        delete_repository = DeleteRepository()
+
+        # Execução do repositório
+        return delete_repository.execute(andamentoservico_schema)

packages/v1/administrativo/actions/t_tb_andamentoservico/t_tb_andamentoservico_get_by_descricao_action.py

@@ -0,0 +1,28 @@
+from abstracts.action import BaseAction
+from packages.v1.administrativo.schemas.t_tb_andamentoservico_schema import TTbAndamentoservicoDescricaoSchema
+from packages.v1.administrativo.repositories.t_tb_andamentoservico.t_tb_andamentoservico_get_by_descricao_repository import GetByDescricaoRepository
+
+class GetByDescricaoAction(BaseAction):
+    """
+    Serviço responsável por encapsular a lógica de negócio para a operação
+    de busca de um registro na tabela t_tb_andamentoservico por descrição.
+    """
+
+    def execute(self, andamentoservico_schema: TTbAndamentoservicoDescricaoSchema):
+        """
+        Executa a operação de busca no banco de dados.
+
+        Args:
+            andamentoservico_schema (TTbAndamentoservicoDescricaoSchema): O esquema com a descrição a ser buscada.
+
+        Returns:
+            O registro encontrado ou None.
+        """
+        # Instanciamento do repositório
+        show_repository = GetByDescricaoRepository()
+
+        # Execução do repositório
+        response = show_repository.execute(andamentoservico_schema)
+
+        # Retorno da informação
+        return response

packages/v1/administrativo/actions/t_tb_andamentoservico/t_tb_andamentoservico_index_action.py

@@ -0,0 +1,24 @@
+from abstracts.action import BaseAction
+from packages.v1.administrativo.repositories.t_tb_andamentoservico.t_tb_andamentoservico_index_repository import IndexRepository
+
+class IndexAction(BaseAction):
+    """
+    Serviço responsável por encapsular a lógica de negócio para a operação
+    de listagem de todos os registros na tabela t_tb_andamentoservico.
+    """
+
+    def execute(self):
+        """
+        Executa a operação de listagem no banco de dados.
+
+        Returns:
+            A lista de todos os registros.
+        """
+        # Instanciamento do repositório
+        index_repository = IndexRepository()
+
+        # Execução do repositório
+        response = index_repository.execute()
+
+        # Retorno da informação
+        return response

packages/v1/administrativo/actions/t_tb_andamentoservico/t_tb_andamentoservico_save_action.py

@@ -0,0 +1,28 @@
+from abstracts.action import BaseAction
+from packages.v1.administrativo.schemas.t_tb_andamentoservico_schema import TTbAndamentoservicoSaveSchema
+from packages.v1.administrativo.repositories.t_tb_andamentoservico.t_tb_andamentoservico_save_repository import SaveRepository
+
+class SaveAction(BaseAction):
+    """
+    Serviço responsável por encapsular a lógica de negócio para a operação
+    de salvar um novo registro na tabela t_tb_andamentoservico.
+    """
+
+    def execute(self, andamentoservico_schema: TTbAndamentoservicoSaveSchema):
+        """
+        Executa a operação de salvamento.
+        
+        Args:
+            andamentoservico_schema (TTbAndamentoservicoSaveSchema): O esquema com os dados a serem salvos.
+
+        Returns:
+            O resultado da operação de salvamento.
+        """
+        # Instânciamento do repositório
+        save_repository = SaveRepository()
+
+        # Execução do repositório
+        response = save_repository.execute(andamentoservico_schema)
+
+        # Retorno da informação
+        return response

packages/v1/administrativo/actions/t_tb_andamentoservico/t_tb_andamentoservico_show_action.py

@@ -0,0 +1,28 @@
+from abstracts.action import BaseAction
+from packages.v1.administrativo.schemas.t_tb_andamentoservico_schema import TTbAndamentoservicoIdSchema
+from packages.v1.administrativo.repositories.t_tb_andamentoservico.t_tb_andamentoservico_show_repository import ShowRepository
+
+class ShowAction(BaseAction):
+    """
+    Serviço responsável por encapsular a lógica de negócio para a exibição
+    de um registro na tabela t_tb_andamentoservico.
+    """
+
+    def execute(self, andamentoservico_schema: TTbAndamentoservicoIdSchema):
+        """
+        Executa a operação de exibição.
+        
+        Args:
+            andamentoservico_schema (TTbAndamentoservicoIdSchema): O esquema com o ID do registro a ser exibido.
+
+        Returns:
+            O resultado da operação de exibição.
+        """
+        # Instânciamento do repositório
+        show_repository = ShowRepository()
+
+        # Execução do repositório
+        response = show_repository.execute(andamentoservico_schema)
+
+        # Retorno da informação
+        return response

packages/v1/administrativo/actions/t_tb_andamentoservico/t_tb_andamentoservico_update_action.py

@@ -0,0 +1,25 @@
+from packages.v1.administrativo.schemas.t_tb_andamentoservico_schema import TTbAndamentoservicoUpdateSchema
+from packages.v1.administrativo.repositories.t_tb_andamentoservico.t_tb_andamentoservico_update_repository import UpdateRepository
+
+
+class UpdateAction:
+    """
+        Service responsável por encapsular a lógica de negócio para a atualização
+        de um registro na tabela t_tb_andamentoservico.
+    """
+
+    def execute(self, tb_andamentoservico_id : int, andamentoservico_schema: TTbAndamentoservicoUpdateSchema):
+        """
+        Executa a operação de atualização.
+
+        Args:
+        andamentoservico_schema (TTbAndamentoservicoUpdateSchema): O esquema com os dados a serem atualizados.
+
+            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_andamentoservico_id, andamentoservico_schema)

packages/v1/administrativo/controllers/t_tb_andamentoservico_controller.py

@@ -0,0 +1,113 @@
+from actions.dynamic_import.dynamic_import import DynamicImport
+from packages.v1.administrativo.schemas.t_tb_andamentoservico_schema import (
+    TTbAndamentoservicoSchema,
+    TTbAndamentoservicoSaveSchema,
+    TTbAndamentoservicoUpdateSchema,
+    TTbAndamentoservicoIdSchema,
+    TTbAndamentoservicoDescricaoSchema
+)
+
+class TTbAndamentoservicoController:
+
+    def __init__(self):
+        # Action responsável por carregar as services de acordo com o estado
+        self.dynamic_import = DynamicImport()
+
+        # Define o pacote que deve ser carregado
+        self.dynamic_import.set_package("administrativo")
+
+        # Define a tabela que o pacote pertence
+        self.dynamic_import.set_table("t_tb_andamentoservico")
+        pass
+
+    # Lista todos os andamentos de serviço
+    def index(self):
+        
+        # Importação da classe desejada
+        indexService = self.dynamic_import.service("t_tb_andamentoservico_index_service", "IndexService")
+
+        # Instância da classe service
+        self.indexService = indexService()
+
+        # Lista todos os andamentos de serviço
+        return {
+            'message': 'Andamentos de serviço localizados com sucesso',
+            'data': self.indexService.execute()
+        }
+    
+    
+    # Busca um andamento de serviço específico pelo ID
+    def show(self, andamentoservico_schema : TTbAndamentoservicoIdSchema):
+
+        #Importação da classe desejada
+        show_service = self.dynamic_import.service('t_tb_andamentoservico_show_service', 'ShowService')
+
+        # Instância da classe desejada
+        self.show_service = show_service()
+
+        # Busca e retorna o andamento de serviço desejado
+        return {
+            'message' : 'Andamento de serviço localizado com sucesso',
+            'data': self.show_service.execute(andamentoservico_schema)
+        }
+    
+
+    # Busca um andamento de serviço pela descrição
+    def get_by_descricao(self, andamentoservico_schema : TTbAndamentoservicoDescricaoSchema):
+
+        #Importação da classe desejada
+        show_service = self.dynamic_import.service('t_tb_andamentoservico_get_descricao_service', 'GetByDescricaoService')
+
+        # Instância da classe desejada
+        self.show_service = show_service()
+
+        # Busca e retorna o andamento de serviço desejado
+        return {
+            'message' : 'Andamento de serviço localizado com sucesso',
+            'data': self.show_service.execute(andamentoservico_schema, True) #True para retornar a mensagem de erro caso não localize o serviço
+        }  
+              
+    
+    # Cadastra um novo andamento de serviço
+    def save(self, andamentoservico_schema : TTbAndamentoservicoSaveSchema):
+
+        #Importação da classe desejada
+        save_service = self.dynamic_import.service('t_tb_andamentoservico_save_service', 'TTbAndamentoservicoSaveService')
+
+        # Instância da classe desejada
+        self.save_service = save_service()
+        # Busca e retorna o andamento de serviço desejado
+        return {
+            'message' : 'Andamento de serviço salvo com sucesso',
+            'data': self.save_service.execute(andamentoservico_schema)
+        }
+    
+    # Atualiza os dados de um andamento de serviço
+    def update(self, tb_andamentoservico_id : int, andamentoservico_schema : TTbAndamentoservicoUpdateSchema):
+
+        #Importação da classe desejada
+        update_service = self.dynamic_import.service('t_tb_andamentoservico_update_service', 'TTbAndamentoservicoUpdateService')
+
+        # Instância da classe desejada
+        self.update_service = update_service()
+
+        # Busca e retorna o andamento de serviço desejado
+        return {
+            'message' : 'Andamento de serviço atualizado com sucesso',
+            'data': self.update_service.execute(tb_andamentoservico_id, andamentoservico_schema)
+        }
+    
+    # Exclui um andamento de serviço
+    def delete(self, andamentoservico_schema : TTbAndamentoservicoIdSchema):
+
+        #Importação da classe desejada
+        delete_service = self.dynamic_import.service('t_tb_andamentoservico_delete_service', 'DeleteService')
+
+        # Instância da classe desejada
+        self.delete_service = delete_service()
+
+        # Busca e retorna o andamento de serviço desejado
+        return {
+            'message' : 'Andamento de serviço removido com sucesso',
+            'data': self.delete_service.execute(andamentoservico_schema)
+        }

packages/v1/administrativo/endpoints/t_tb_andamentoservico_endpoint.py

@@ -0,0 +1,108 @@
+# Importação de bibliotecas
+from typing import Optional
+from fastapi import APIRouter, Body, Depends, status
+from actions.jwt.get_current_user import get_current_user
+from packages.v1.administrativo.controllers.t_tb_andamentoservico_controller import TTbAndamentoservicoController
+from packages.v1.administrativo.schemas.t_tb_andamentoservico_schema import (
+    TTbAndamentoservicoSchema,
+    TTbAndamentoservicoSaveSchema,
+    TTbAndamentoservicoUpdateSchema,
+    TTbAndamentoservicoIdSchema
+)
+
+# Inicializa o roteador para as rotas de andamento de serviço
+router = APIRouter()
+
+# Instânciamento do controller desejado
+t_tb_andamentoservico_controller = TTbAndamentoservicoController()
+
+# Lista todos os andamentos de serviço
+@router.get('/',
+            status_code=status.HTTP_200_OK,
+            summary='Lista todos os andamentos de serviço cadastrados',
+            response_description='Lista todos os andamentos de serviço cadastrados')
+async def index(current_user: dict = Depends(get_current_user)):
+
+    # Busca todos os andamentos de serviço cadastrados
+    response = t_tb_andamentoservico_controller.index()
+
+    # Retorna os dados localizados
+    return response
+
+
+# Localiza um andamento de serviço pela descrição
+@router.get('/descricao',
+            status_code=status.HTTP_200_OK,
+            summary='Busca um registro em específico pela descrição',
+            response_description='Busca um registro em específico')
+async def get_by_descricao(descricao : str, current_user: dict = Depends(get_current_user)):
+
+    # Cria o schema com os dados recebidos
+    andamentoservico_schema = TTbAndamentoservicoSchema(descricao=descricao)
+
+    # Busca um andamento de serviço específico pela descrição
+    response = t_tb_andamentoservico_controller.get_by_descricao(andamentoservico_schema)
+
+    # Retorna os dados localizados
+    return response
+
+
+# Localiza um andamento de serviço pelo ID
+@router.get('/{tb_andamentoservico_id}',
+            status_code=status.HTTP_200_OK,
+            summary='Busca um registro em específico pelo ID do andamento de serviço',
+            response_description='Busca um registro em específico')
+async def show(tb_andamentoservico_id : int, current_user: dict = Depends(get_current_user)):
+
+    # Cria o schema com os dados recebidos
+    andamentoservico_schema = TTbAndamentoservicoIdSchema(tb_andamentoservico_id=tb_andamentoservico_id)
+
+    # Busca um andamento de serviço específico pelo ID
+    response = t_tb_andamentoservico_controller.show(andamentoservico_schema)
+
+    # Retorna os dados localizados
+    return response
+
+
+# Cadastro de andamento de serviço
+@router.post('/',
+            status_code=status.HTTP_201_CREATED,
+            summary='Cadastra um andamento de serviço',
+            response_description='Cadastra um andamento de serviço')
+async def save(andamentoservico_schema : TTbAndamentoservicoSaveSchema, current_user: dict = Depends(get_current_user)):
+
+    # Efetua o cadastro no banco de dados
+    response = t_tb_andamentoservico_controller.save(andamentoservico_schema)
+
+    # Retorna os dados localizados
+    return response
+
+
+# Atualiza os dados de um andamento de serviço
+@router.put('/{tb_andamentoservico_id}',
+            status_code=status.HTTP_200_OK,
+            summary='Atualiza um andamento de serviço',
+            response_description='Atualiza um andamento de serviço')
+async def update(tb_andamentoservico_id : int, andamentoservico_schema : TTbAndamentoservicoUpdateSchema, current_user: dict = Depends(get_current_user)):
+
+    # Efetua a atualização dos dados
+    response = t_tb_andamentoservico_controller.update(tb_andamentoservico_id, andamentoservico_schema)
+
+    # Retorna os dados localizados
+    return response
+
+# Exclui um determinado andamento de serviço
+@router.delete('/{tb_andamentoservico_id}',
+            status_code=status.HTTP_200_OK,
+            summary='Remove um andamento de serviço',
+            response_description='Remove um andamento de serviço')
+async def delete(tb_andamentoservico_id : int, current_user: dict = Depends(get_current_user)):
+
+    # Cria o schema com os dados recebidos
+    andamentoservico_schema = TTbAndamentoservicoIdSchema(tb_andamentoservico_id=tb_andamentoservico_id)
+
+    # Efetua a exclusão do andamento de serviço
+    response = t_tb_andamentoservico_controller.delete(andamentoservico_schema)
+
+    # Retorna os dados localizados
+    return response

packages/v1/administrativo/repositories/t_tb_andamentoservico/t_tb_andamentoservico_delete_repository.py

@@ -0,0 +1,41 @@
+from abstracts.repository import BaseRepository
+from packages.v1.administrativo.schemas.t_tb_andamentoservico_schema import TTbAndamentoservicoIdSchema
+from fastapi import HTTPException, status
+
+class DeleteRepository(BaseRepository):
+    """
+    Repositório para a operação de exclusão de um registro na tabela
+    t_tb_andamentoservico.
+    """
+
+    def execute(self, andamentoservico_schema: TTbAndamentoservicoIdSchema):
+        """
+        Executa a consulta SQL para remover um registro pelo ID.
+
+        Args:
+            andamentoservico_schema (TTbAndamentoservicoIdSchema): O esquema com o ID a ser removido.
+
+        Returns:
+            O resultado da operação de exclusão.
+        """
+        try:
+            # Montagem do sql
+            sql = """ DELETE FROM T_TB_ANDAMENTOSERVICO WHERE TB_ANDAMENTOSERVICO_ID = :tb_andamentoservico_id """
+
+            # Preenchimento de parâmetros
+            params = {
+                "tb_andamentoservico_id": andamentoservico_schema.tb_andamentoservico_id
+            }
+
+            # Execução do sql
+            response = self.run(sql, params)
+
+            # Retorna o resultado
+            return response
+    
+        except Exception as e:
+            # Informa que houve uma falha na exclusão
+            raise HTTPException(
+                status_code=status.HTTP_422_UNPROCESSABLE_ENTITY,
+                detail=f"Erro ao excluir andamento de serviço: {e}"
+            )

packages/v1/administrativo/repositories/t_tb_andamentoservico/t_tb_andamentoservico_get_by_descricao_repository.py

@@ -0,0 +1,29 @@
+from abstracts.repository import BaseRepository
+from packages.v1.administrativo.schemas.t_tb_andamentoservico_schema import TTbAndamentoservicoDescricaoSchema
+
+class GetByDescricaoRepository(BaseRepository):
+    """
+    Repositório para a operação de busca de um registro na tabela
+    t_tb_andamentoservico por descrição.
+    """
+
+    def execute(self, andamentoservico_schema: TTbAndamentoservicoDescricaoSchema):
+        """
+        Executa a consulta SQL para buscar um registro pela descrição.
+
+        Args:
+            andamentoservico_schema (TTbAndamentoservicoDescricaoSchema): O esquema com a descrição a ser buscada.
+
+        Returns:
+            Um dicionário contendo os dados do registro ou None se não for encontrado.
+        """
+        # Montagem do SQL
+        sql = """ SELECT * FROM T_TB_ANDAMENTOSERVICO WHERE DESCRICAO = :descricao """
+
+        # Preenchimento de parâmetros
+        params = {
+            'descricao': andamentoservico_schema.descricao
+        }
+
+        # Execução do sql
+        return self.fetch_one(sql, params)

packages/v1/administrativo/repositories/t_tb_andamentoservico/t_tb_andamentoservico_index_repository.py

@@ -0,0 +1,23 @@
+from abstracts.repository import BaseRepository
+
+class IndexRepository(BaseRepository):
+    """
+    Repositório para a operação de listagem de todos os registros
+    na tabela t_tb_andamentoservico.
+    """
+    
+    def execute(self):
+        """
+        Executa a consulta SQL para buscar todos os registros.
+
+        Returns:
+            Uma lista de dicionários contendo os dados dos registros.
+        """
+        # Montagem do SQL
+        sql = """ SELECT * FROM T_TB_ANDAMENTOSERVICO """
+
+        # Execução do sql
+        response = self.fetch_all(sql)
+
+        # Retorna os dados localizados
+        return response

packages/v1/administrativo/repositories/t_tb_andamentoservico/t_tb_andamentoservico_save_repository.py

@@ -0,0 +1,59 @@
+from fastapi import HTTPException, status
+from abstracts.repository import BaseRepository
+from packages.v1.administrativo.schemas.t_tb_andamentoservico_schema import TTbAndamentoservicoSaveSchema
+
+
+class SaveRepository(BaseRepository):
+    """
+    Repositório para a operação de salvamento de um novo registro na tabela t_tb_andamentoservico.
+    """
+
+    def execute(self, andamentoservico_schema: TTbAndamentoservicoSaveSchema):
+        """
+        Executa a operação de salvamento no banco de dados.
+
+        Args:
+            andamentoservico_schema (TTbAndamentoservicoSaveSchema): O esquema com os dados a serem salvos.
+
+        Returns:
+            O registro recém-criado.
+
+        Raises:
+            HTTPException: Caso ocorra um erro na execução da query.
+        """
+        try:
+
+            # Montagem do SQL
+            sql = """ INSERT INTO T_TB_ANDAMENTOSERVICO(
+                        TB_ANDAMENTOSERVICO_ID,
+                        DESCRICAO,
+                        SITUACAO,
+                        TIPO,
+                        USA_EMAIL
+                        ) VALUES (
+                        :tb_andamentoservico_id,
+                        :descricao,
+                        :situacao,
+                        :tipo,
+                        :usa_email
+                        ) RETURNING *;"""
+            
+            # Preenchimento de parâmetros
+            params = {
+                'tb_andamentoservico_id': andamentoservico_schema.tb_andamentoservico_id,
+                'descricao': andamentoservico_schema.descricao,
+                'situacao': andamentoservico_schema.situacao,
+                'tipo': andamentoservico_schema.tipo,
+                'usa_email': andamentoservico_schema.usa_email
+            }
+
+            # Execução do sql
+            return self.run_and_return(sql, params)
+        
+        except Exception as e:
+        
+            # Informa que houve uma falha no salvamento do registro
+            raise HTTPException(
+                status_code=status.HTTP_422_UNPROCESSABLE_ENTITY,
+                detail=f"Erro ao salvar andamento de serviço: {e}"
+            )        

packages/v1/administrativo/repositories/t_tb_andamentoservico/t_tb_andamentoservico_show_repository.py

@@ -0,0 +1,46 @@
+from abstracts.repository import BaseRepository
+from packages.v1.administrativo.schemas.t_tb_andamentoservico_schema import TTbAndamentoservicoIdSchema
+from fastapi import HTTPException, status
+
+class ShowRepository(BaseRepository):
+    """
+    Repositório para a operação de exibição de um registro na tabela t_tb_andamentoservico.
+    """
+
+    def execute(self, andamentoservico_schema: TTbAndamentoservicoIdSchema):
+        """
+        Busca um andamento de serviço específico pelo ID.
+
+        Args:
+            andamentoservico_schema (TTbAndamentoservicoIdSchema): O esquema que contém o ID do registro.
+
+        Returns:
+            O registro encontrado.
+
+        Raises:
+            HTTPException: Caso ocorra um erro na execução da query ou o registro não seja encontrado.
+        """
+        try:
+            # Montagem do SQL
+            sql = "SELECT * FROM T_TB_ANDAMENTOSERVICO WHERE TB_ANDAMENTOSERVICO_ID = :tb_andamentoservico_id"
+
+            # Preenchimento de parâmetros
+            params = {
+                'tb_andamentoservico_id': andamentoservico_schema.tb_andamentoservico_id
+            }
+
+            # Execução do SQL
+            result = self.fetch_one(sql, params)
+
+            if not result:
+                raise HTTPException(
+                    status_code=status.HTTP_404_NOT_FOUND,
+                    detail="Registro não encontrado"
+                )
+
+            return result
+        except Exception as e:
+            raise HTTPException(
+                status_code=status.HTTP_500_INTERNAL_SERVER_ERROR,
+                detail=f"Erro ao buscar registro: {str(e)}"
+            )

packages/v1/administrativo/repositories/t_tb_andamentoservico/t_tb_andamentoservico_update_repository.py

@@ -0,0 +1,67 @@
+from abstracts.repository import BaseRepository
+from packages.v1.administrativo.schemas.t_tb_andamentoservico_schema import TTbAndamentoservicoUpdateSchema
+from fastapi import HTTPException, status
+
+class UpdateRepository(BaseRepository):
+    """
+    Repositório para a operação de atualização na tabela T_TB_ANDAMENTOSERVICO.
+    """
+
+    def execute(self, tb_andamentoservico_id: int, andamentoservico_schema: TTbAndamentoservicoUpdateSchema):
+        """
+        Executa a atualização de um registro na tabela.
+        
+        Args:
+            andamentoservico_schema (TTbAndamentoservicoUpdateSchema): O esquema com os dados a serem atualizados.
+
+        Returns:
+            O registro atualizado.
+            
+        Raises:
+            HTTPException: Se o registro não for encontrado ou ocorrer um erro na atualização.
+        """
+        try:
+            updates = []
+            params = {}
+
+            if andamentoservico_schema.descricao is not None:
+                updates.append("DESCRICAO = :descricao")
+                params["descricao"] = andamentoservico_schema.descricao
+
+            if andamentoservico_schema.situacao is not None:
+                updates.append("SITUACAO = :situacao")
+                params["situacao"] = andamentoservico_schema.situacao
+
+            if andamentoservico_schema.tipo is not None:
+                updates.append("TIPO = :tipo")
+                params["tipo"] = andamentoservico_schema.tipo
+
+            if andamentoservico_schema.usa_email is not None:
+                updates.append("USA_EMAIL = :usa_email")
+                params["usa_email"] = andamentoservico_schema.usa_email
+
+            if not updates:
+                return False
+
+            params["tb_andamentoservico_id"] = tb_andamentoservico_id
+            sql = f"UPDATE T_TB_ANDAMENTOSERVICO SET {', '.join(updates)} WHERE tb_andamentoservico_id = :tb_andamentoservico_id RETURNING *;"
+
+            # Executa a query
+            result = self.run_and_return(sql, params)
+
+            if not result:
+                # Informa que não existe o registro a ser modificado
+                raise HTTPException(
+                    status_code=status.HTTP_422_UNPROCESSABLE_ENTITY,
+                    detail='Nenhum andamento de serviço localizado para esta solicitação'
+                )
+            
+            # Se houver um resultado, a atualização foi bem-sucedida
+            return result
+
+        except Exception as e:
+            # Informa que houve uma falha na atualização
+            raise HTTPException(
+                status_code=status.HTTP_422_UNPROCESSABLE_ENTITY,
+                detail=f"Erro ao atualizar o andamento de serviço: {e}"
+            )

packages/v1/administrativo/schemas/t_tb_andamentoservico_schema.py

@@ -0,0 +1,126 @@
+from pydantic import BaseModel, field_validator, model_validator
+from fastapi import HTTPException, status
+from typing import Optional
+
+# Funções para sanitização de entradas (evitar XSS, SQLi etc.)
+# Supondo que a classe Text esteja disponível e com o método sanitize_input
+try:
+    from actions.validations.text import Text
+except ImportError:
+    class Text:
+        @staticmethod
+        def sanitize_input(value: str) -> str:
+            return value.strip()
+
+
+# ----------------------------------------------------
+# Schema base
+# ----------------------------------------------------
+class TTbAndamentoservicoSchema(BaseModel):
+    tb_andamentoservico_id: Optional[int] = None
+    descricao: Optional[str] = None
+    situacao: Optional[str] = None
+    tipo: Optional[str] = None
+    usa_email: Optional[str] = None
+
+    class Config:
+        from_attributes = True
+
+
+# ----------------------------------------------------
+# Schema para localizar um tipo especifico pelo ID (GET)
+# ----------------------------------------------------
+class TTbAndamentoservicoIdSchema(BaseModel):
+    tb_andamentoservico_id: int
+
+
+# ----------------------------------------------------
+# Schema para localizar um tipo especifico pela descrição (GET)
+# ----------------------------------------------------
+class TTbAndamentoservicoDescricaoSchema(BaseModel):
+    descricao: str    
+
+
+# ----------------------------------------------------
+# Schema para criação de novo tipo (POST)
+# ----------------------------------------------------
+class TTbAndamentoservicoSaveSchema(BaseModel):
+    tb_andamentoservico_id: Optional[int] = None
+    descricao: str
+    situacao: str
+    tipo: str
+    usa_email: str
+
+    # Sanitiza os inputs enviados
+    @field_validator('descricao', 'situacao', 'tipo', 'usa_email')
+    def sanitize_fields(cls, v):
+        if v:
+            return Text.sanitize_input(v)
+        return v
+    
+    # Verifica se os campos obrigatórios foram enviados
+    @model_validator(mode='after')
+    def validate_all_fields(self):
+        errors = []
+        
+        if not self.descricao or len(self.descricao.strip()) == 0:
+            errors.append({'input': 'descricao', 'message': 'A descrição é obrigatória.'})
+
+        if not self.situacao or len(self.situacao.strip()) == 0:
+            errors.append({'input': 'situacao', 'message': 'A situação é obrigatória.'})
+
+        if not self.tipo or len(self.tipo.strip()) == 0:
+            errors.append({'input': 'tipo', 'message': 'O tipo é obrigatório.'})
+
+        if not self.usa_email or len(self.usa_email.strip()) == 0:
+            errors.append({'input': 'usa_email', 'message': 'O campo usa_email é obrigatório.'})
+
+        if errors:
+            raise HTTPException(
+                status_code=status.HTTP_422_UNPROCESSABLE_ENTITY,
+                detail=errors
+            )
+
+        return self
+
+
+# ----------------------------------------------------
+# Schema para atualizar tipo (PUT)
+# ----------------------------------------------------
+class TTbAndamentoservicoUpdateSchema(BaseModel):
+    descricao: Optional[str] = None
+    situacao: Optional[str] = None
+    tipo: Optional[str] = None
+    usa_email: Optional[str] = None
+
+    # Sanitiza os inputs enviados
+    @field_validator('descricao', 'situacao', 'tipo', 'usa_email')
+    def sanitize_fields(cls, v):
+        if v:
+            return Text.sanitize_input(v)
+        return v
+    
+    # Verifica se os campos obrigatórios foram enviados
+    @model_validator(mode='after')
+    def validate_all_fields(self):
+        errors = []
+
+        if not self.descricao or len(self.descricao.strip()) == 0:
+            errors.append({'input': 'descricao', 'message': 'A descrição é obrigatória.'})
+
+        if not self.situacao or len(self.situacao.strip()) == 0:
+            errors.append({'input': 'situacao', 'message': 'A situação é obrigatória.'})
+        
+        if not self.tipo or len(self.tipo.strip()) == 0:
+            errors.append({'input': 'tipo', 'message': 'O tipo é obrigatório.'})
+
+        if not self.usa_email or len(self.usa_email.strip()) == 0:
+            errors.append({'input': 'usa_email', 'message': 'O campo usa_email é obrigatório.'})
+        
+        if errors:
+            raise HTTPException(
+                status_code=status.HTTP_422_UNPROCESSABLE_ENTITY,
+                detail=errors
+            )
+
+        return self

packages/v1/administrativo/services/t_tb_andamentoservico/go/t_tb_andamentoservico_delete_service.py

@@ -0,0 +1,27 @@
+from packages.v1.administrativo.schemas.t_tb_andamentoservico_schema import TTbAndamentoservicoIdSchema
+from packages.v1.administrativo.actions.t_tb_andamentoservico.t_tb_andamentoservico_delete_action import DeleteAction
+
+class DeleteService:
+    """
+    Serviço responsável por encapsular a lógica de negócio para a operação
+    de exclusão de um registro na tabela t_tb_andamentoservico.
+    """
+
+    def execute(self, andamentoservico_schema: TTbAndamentoservicoIdSchema):
+        """
+        Executa a operação de exclusão do registro no banco de dados.
+
+        Args:
+            andamentoservico_schema (TTbAndamentoservicoIdSchema): O esquema com o ID do registro a ser excluído.
+
+        Returns:
+            O resultado da operação de exclusão.
+        """
+        # Instanciamento da ação
+        delete_action = DeleteAction()
+
+        # Executa a ação em questão
+        data = delete_action.execute(andamentoservico_schema)
+
+        # Retorno da informação
+        return data

packages/v1/administrativo/services/t_tb_andamentoservico/go/t_tb_andamentoservico_get_descricao_service.py

@@ -0,0 +1,38 @@
+from fastapi import HTTPException, status
+from packages.v1.administrativo.schemas.t_tb_andamentoservico_schema import TTbAndamentoservicoDescricaoSchema
+from packages.v1.administrativo.actions.t_tb_andamentoservico.t_tb_andamentoservico_get_by_descricao_action import GetByDescricaoAction
+
+class GetByDescricaoService:
+    """
+    Serviço responsável por encapsular a lógica de negócio para a operação
+    de busca de um registro na tabela t_tb_andamentoservico pela sua descrição.
+    """
+
+    def execute(self, andamentoservico_schema: TTbAndamentoservicoDescricaoSchema, messageValidate: bool):
+        """
+        Executa a operação de busca no banco de dados.
+
+        Args:
+            andamentoservico_schema (TTbAndamentoservicoDescricaoSchema): O esquema com a descrição a ser buscada.
+            messageValidate (bool): Se True, lança uma exceção HTTP caso o registro não seja encontrado.
+
+        Returns:
+            O registro encontrado ou None.
+        """
+        # Instanciamento da ação
+        show_action = GetByDescricaoAction()
+
+        # Executa a ação em questão
+        data = show_action.execute(andamentoservico_schema)
+
+        if messageValidate:
+            
+            if not data:
+                # Retorna uma exceção
+                raise HTTPException(
+                    status_code=status.HTTP_404_NOT_FOUND,
+                    detail='Não foi possível localizar o registro de andamento de serviço'
+                )
+
+        # Retorno da informação
+        return data

packages/v1/administrativo/services/t_tb_andamentoservico/go/t_tb_andamentoservico_index_service.py

@@ -0,0 +1,32 @@
+from fastapi import HTTPException, status
+from packages.v1.administrativo.actions.t_tb_andamentoservico.t_tb_andamentoservico_index_action import IndexAction
+
+class IndexService:
+    """
+    Serviço responsável por encapsular a lógica de negócio para a operação
+    de listagem de registros na tabela t_tb_andamentoservico.
+    """
+
+    def execute(self):
+        """
+        Executa a operação de busca de todos os registros no banco de dados.
+
+        Returns:
+            A lista de registros encontrados.
+        """
+        # Instanciamento da ação
+        index_action = IndexAction()
+
+        # Executa a busca de todas as ações
+        data = index_action.execute()
+
+        # Verifica se foram localizados registros
+        if not data:
+            # Retorna uma exceção
+            raise HTTPException(
+                status_code=status.HTTP_404_NOT_FOUND,
+                detail='Não foi possível localizar os registros de andamento de serviço'
+            )
+        
+        # Retorna as informações localizadas
+        return data

packages/v1/administrativo/services/t_tb_andamentoservico/go/t_tb_andamentoservico_save_service.py

@@ -0,0 +1,70 @@
+from actions.dynamic_import.dynamic_import import DynamicImport
+from packages.v1.sequencia.schemas.g_sequencia import GSequenciaSchema
+from packages.v1.sequencia.services.g_sequencia.generate_service import GenerateService
+from packages.v1.administrativo.schemas.t_tb_andamentoservico_schema import TTbAndamentoservicoSaveSchema, TTbAndamentoservicoDescricaoSchema
+from packages.v1.administrativo.actions.t_tb_andamentoservico.t_tb_andamentoservico_save_action import SaveAction
+from fastapi import HTTPException, status
+
+class TTbAndamentoservicoSaveService:
+
+    def __init__(self):
+        # Ação responsável por carregar as services de acordo com o estado
+        self.dynamic_import = DynamicImport()
+
+        # Define o pacote que deve ser carregado
+        self.dynamic_import.set_package("administrativo")
+
+        # Define a tabela que o pacote pertence
+        self.dynamic_import.set_table("t_tb_andamentoservico")
+        pass
+
+    # Cadastra o novo tipo de andamento de serviço
+    def execute(self, andamentoservico_schema: TTbAndamentoservicoSaveSchema):
+
+        # Armazena possíveis erros
+        errors = []
+
+        # Verifica se a descrição já está sendo utilizada
+        # Importação de service
+        descricao_service = self.dynamic_import.service("t_tb_andamentoservico_get_descricao_service", "GetByDescricaoService")
+
+        # Instanciamento da service
+        self.descricao_service = descricao_service()
+
+        # Verifica se a descrição já está sendo utilizada
+        self.response = self.descricao_service.execute(TTbAndamentoservicoDescricaoSchema(descricao=andamentoservico_schema.descricao), False)
+
+        # Se houver retorno significa que a descrição já está sendo utilizada
+        if self.response:
+            errors.append({'input': 'descricao', 'message': 'a descrição informada já está sendo utilizada.'})
+
+        # Se houver erros, lança a exceção
+        if errors:
+            raise HTTPException(
+                status_code=status.HTTP_403_FORBIDDEN,
+                detail=errors
+            )
+
+        # Verifica se precisa gerar o ID de sequência
+        if not andamentoservico_schema.tb_andamentoservico_id:
+
+            # Crio um objeto de sequencia
+            sequencia_schema = GSequenciaSchema()
+
+            # Define os dados para atualizar a sequencia
+            sequencia_schema.tabela = 'T_TB_ANDAMENTOSERVICO'
+
+            # Busco a sequência atualizada
+            generate = GenerateService()
+
+            # Busco a sequência atualizada
+            sequencia = generate.execute(sequencia_schema)
+
+            # Atualiza os dados da chave primária
+            andamentoservico_schema.tb_andamentoservico_id = sequencia.sequencia
+
+        # Instanciamento de ações
+        save_action = SaveAction()
+
+        # Retorna o resultado da operação
+        return save_action.execute(andamentoservico_schema)

packages/v1/administrativo/services/t_tb_andamentoservico/go/t_tb_andamentoservico_show_service.py

@@ -0,0 +1,35 @@
+from fastapi import HTTPException, status
+from packages.v1.administrativo.schemas.t_tb_andamentoservico_schema import TTbAndamentoservicoIdSchema
+from packages.v1.administrativo.actions.t_tb_andamentoservico.t_tb_andamentoservico_show_action import ShowAction
+
+class ShowService:
+    """
+    Serviço responsável por encapsular a lógica de negócio para a operação
+    de busca de um registro na tabela t_tb_andamentoservico.
+    """
+
+    def execute(self, andamentoservico_schema: TTbAndamentoservicoIdSchema):
+        """
+        Executa a operação de busca no banco de dados.
+
+        Args:
+            andamentoservico_schema (TTbAndamentoservicoIdSchema): O esquema com o ID a ser buscado.
+
+        Returns:
+            O resultado da busca.
+        """
+        # Instanciamento da ação
+        show_action = ShowAction()
+
+        # Executa a ação em questão
+        data = show_action.execute(andamentoservico_schema)
+
+        if not data:
+            # Retorna uma exceção
+            raise HTTPException(
+                status_code=status.HTTP_404_NOT_FOUND,
+                detail='Não foi possível localizar o registro de andamento de serviço'
+            )
+
+        # Retorno da informação
+        return data

packages/v1/administrativo/services/t_tb_andamentoservico/go/t_tb_andamentoservico_update_service.py

@@ -0,0 +1,23 @@
+from packages.v1.administrativo.schemas.t_tb_andamentoservico_schema import TTbAndamentoservicoUpdateSchema
+from packages.v1.administrativo.actions.t_tb_andamentoservico.t_tb_andamentoservico_update_action import UpdateAction
+
+class TTbAndamentoservicoUpdateService:
+    """
+    Serviço para a operação de atualização de um registro na tabela
+    t_tb_andamentoservico.
+    """
+    def execute(self, tb_andamentoservico_id : int, andamentoservico_schema: TTbAndamentoservicoUpdateSchema):
+        """
+        Executa a operação de atualização no banco de dados.
+
+        Args:
+            andamentoservico_schema (TTbAndamentoservicoUpdateSchema): O esquema com os dados a serem atualizados.
+
+        Returns:
+            O resultado da operação de atualização.
+        """
+        # Instanciamento de ações
+        update_action = UpdateAction()
+
+        # Retorna o resultado da operação
+        return update_action.execute(tb_andamentoservico_id, andamentoservico_schema)

packages/v1/api.py

@@ -6,26 +6,33 @@ from packages.v1.administrativo.endpoints import c_caixa_item_endpoint
 from packages.v1.administrativo.endpoints import g_usuario_endpoint
 from packages.v1.administrativo.endpoints import c_caixa_servico_endpoint
 from packages.v1.administrativo.endpoints import t_tb_reconhecimentotipo_endpoint
+from packages.v1.administrativo.endpoints import t_tb_andamentoservico_endpoint
 
 # Cria uma instância do APIRouter que vai agregar todas as rotas da API
 api_router = APIRouter()
 
-# Inclui as rotas de caixa
+# Inclui as rotas de c_caixa_item
 api_router.include_router(
     c_caixa_item_endpoint.router, prefix="/administrativo/c_caixa_item", tags=["Caixa Item"]
 )
 
-# Inclui as rotas de usuários
+# Inclui as rotas de g_usuario
 api_router.include_router(
     g_usuario_endpoint.router, prefix="/administrativo/g_usuario", tags=["Usuário"]
 )
 
-# Inclui as rotas de caixa_servico
+# Inclui as rotas de c_caixa_servico
 api_router.include_router(
     c_caixa_servico_endpoint.router, prefix="/administrativo/c_caixa_servico", tags=["Caixa Serviço"]
 )
 
-# Inclui as rotas de caixa
+# Inclui as rotas de t_tb_reconhecimentotipo
 api_router.include_router(
     t_tb_reconhecimentotipo_endpoint.router, prefix="/administrativo/t_tb_reconhecimentotipo", tags=["Tipos de reconhecimento"]
 )
+
+# Inclui as rotas de t_tb_andamentoservico
+api_router.include_router(
+    t_tb_andamentoservico_endpoint.router, prefix="/administrativo/t_tb_andamentoservico", tags=["Andamentos de serviço"]
+)
+

storage/temp.json

@@ -941,5 +941,31 @@
     "storage/temp/validation_exception_handler.json",
     "storage/temp/validation_exception_handler.json",
     "storage/temp/http_exception_handler.json",
+    "storage/temp/http_exception_handler.json",
+    "storage/temp/http_exception_handler.json",
+    "storage/temp/http_exception_handler.json",
+    "storage/temp/validation_exception_handler.json",
+    "storage/temp/validation_exception_handler.json",
+    "storage/temp/http_exception_handler.json",
+    "storage/temp/http_exception_handler.json",
+    "storage/temp/validation_exception_handler.json",
+    "storage/temp/validation_exception_handler.json",
+    "storage/temp/validation_exception_handler.json",
+    "storage/temp/http_exception_handler.json",
+    "storage/temp/http_exception_handler.json",
+    "storage/temp/http_exception_handler.json",
+    "storage/temp/http_exception_handler.json",
+    "storage/temp/http_exception_handler.json",
+    "storage/temp/http_exception_handler.json",
+    "storage/temp/validation_exception_handler.json",
+    "storage/temp/validation_exception_handler.json",
+    "storage/temp/validation_exception_handler.json",
+    "storage/temp/validation_exception_handler.json",
+    "storage/temp/validation_exception_handler.json",
+    "storage/temp/http_exception_handler.json",
+    "storage/temp/http_exception_handler.json",
+    "storage/temp/http_exception_handler.json",
+    "storage/temp/validation_exception_handler.json",
+    "storage/temp/http_exception_handler.json",
     "storage/temp/http_exception_handler.json"
 ]