add categoria and queries

Dockerfile

@@ -1,11 +1,6 @@
 FROM python:3.9
-
 WORKDIR /code
-
 COPY ./requirements.txt /code/requirements.txt
-
 RUN pip install --no-cache-dir --upgrade -r /code/requirements.txt
-
 COPY . .
-
 CMD ["python3","main.py"]

README.md

@@ -1,10 +1,26 @@
----
-title: Ts02 Afabd
-emoji: 🐠
-colorFrom: blue
-colorTo: purple
-sdk: docker
-pinned: false
----
-
-Check out the configuration reference at https://huggingface.co/docs/hub/spaces-config-reference
+# Arquitetura de microsserviços
+
+Diferentemente das arquiteturas monolíticas, a arquitetura orientada a microsserviços descreve que cada funcionalidade deve ser desenvolvida de forma independente, permitindo que o tie de desenvolvimento possa atualizar ou modificar alguma feature sem que outra seja afetada.
+
+## Projeto AFA-BD
+
+### Arquitetura atual 
+
+![image](https://github.com/AfaBD/AFA-BD-2024/assets/58821700/dabe816f-8764-4004-9ecc-59e817a1f9ab)
+
+Pontos para melhoria:
+
+ - Escalar horizontalmente a aplicação custaria muito recurso, já que seria necessário escalar todas as funcionalidades
+ - Manutenção custosa, ja que todas as funcionalidades estão acopladas
+
+### Arquitetura em microsserviços
+
+![WhatsApp Image 2024-04-05 at 9 56 06 PM](https://github.com/AfaBD/AFA-BD-2024/assets/58821700/ec099deb-cb91-4b4c-9b78-be1b829f58f2)
+
+Serviços para a nova arquitetura:
+
+ - Frontend: camada de interação direta com o usuário
+ - Backend: camada para operações na camada de persistência (BD)
+ - IA-Model: Camada para operações com modelos de ML/IA
+
+Todos os serviços estarão sendo orquestrados com kubernetes

controller/__init__.py

@@ -6,6 +6,7 @@ from .cidade_controller import router as cidade_router
 from .tipo_escola_controller import router as tipo_escola_router
 from .unidade_escolar_controller import router as unidade_escolar_router
 from .endereco_controller import router as endereco_router
+from .query_controller import router as query_router
 
 __all__ = [
     'session_router',
@@ -15,5 +16,6 @@ __all__ = [
     'cidade_router',
     'tipo_escola_router',
     'unidade_escolar_router',
-    'endereco_router'
+    'endereco_router',
+    'query_router'
 ]

controller/query_controller.py

@@ -0,0 +1,21 @@
+from fastapi import APIRouter, Depends
+from model import Login
+from schema import Query201,Query202
+from service import QueryService,SessionService
+from typing import Annotated,List
+
+router = APIRouter(
+    prefix='/query'
+)
+
+service = SessionService()
+
+@router.get('/201',response_model=List[Query201])
+def runquery201(user: Annotated[Login,Depends(service.validate_token)]):
+    query_service = QueryService()
+    return query_service.query201()
+
+@router.get('/202',response_model=List[Query202])
+def runquery202(user: Annotated[Login,Depends(service.validate_token)]):
+    query_service = QueryService()
+    return query_service.query202()

main.py

@@ -2,7 +2,7 @@ from fastapi import FastAPI
 import uvicorn
 from fastapi.middleware.cors import CORSMiddleware
 
-from controller import session_router,user_router,role_router,regiao_router,cidade_router,tipo_escola_router,unidade_escolar_router,endereco_router
+from controller import query_router,session_router,user_router,role_router,regiao_router,cidade_router,tipo_escola_router,unidade_escolar_router,endereco_router
 
 app = FastAPI()
 
@@ -24,5 +24,6 @@ app.include_router(cidade_router)
 app.include_router(tipo_escola_router)
 app.include_router(unidade_escolar_router)
 app.include_router(endereco_router)
+app.include_router(query_router)
 
 uvicorn.run(app,host='0.0.0.0',port=7860)

model/__init__.py

@@ -5,6 +5,7 @@ from .tipo_escola import TipoEscola
 from .endereco import Endereco
 from .cidade import Cidade
 from .regiao import Regiao
+from .categoria import Categoria
 
 __all__ = [
     "Login",
@@ -13,5 +14,6 @@ __all__ = [
     "TipoEscola",
     "Endereco",
     "Cidade",
-    "Regiao"
+    "Regiao",
+    "Categoria"
 ]

model/categoria.py

@@ -0,0 +1,10 @@
+from database import Base
+from sqlalchemy import Column, Integer,String, ForeignKey
+from sqlalchemy.orm import Mapped,relationship
+
+class Categoria(Base):
+    __tablename__ = "categoria_escolar"
+
+    id = Column("cat_id",Integer, primary_key=True,index=True)
+    description = Column("cat_descricao",String(255),nullable=False)
+    unidades = relationship("UnidadeEscolar", back_populates="categoria",lazy="selectin")

model/unidade_escolar.py

@@ -12,6 +12,9 @@ class UnidadeEscolar(Base):
     id_tipo = Column("tip_id", Integer, ForeignKey("tipo_escola.tip_id"))
     tipo = relationship("TipoEscola", back_populates="unidades", lazy="selectin")
 
+    id_categoria = Column("cat_id", Integer, ForeignKey("categoria_escolar.cat_id"))
+    categoria = relationship("Categoria", back_populates="unidades", lazy="selectin")
+
     id_endereco = Column("end_id", Integer, ForeignKey("endereco.end_id"))
     endereco = relationship("Endereco", back_populates="unidades", lazy="selectin")
     

schema/__init__.py

@@ -6,6 +6,8 @@ from .cidade import CidadeBase,ResponseCidade,RequestCidade
 from .tipo_escola import BaseTipoEscola,ResponseTipoEscola
 from .endereco import ResponseEndereco,RequestEndereco
 from .unidade_escolar import ResponseUnidadeEscolar,RequestUnidadeEscolar
+from .categoria import ResponseCategoriaEscola
+from .query import Query201,Query202
 
 __all__ = [
     "RequestSession",
@@ -25,5 +27,8 @@ __all__ = [
     "ResponseEndereco",
     "ResponseUnidadeEscolar",
     "RequestEndereco",
-    "RequestUnidadeEscolar"
+    "RequestUnidadeEscolar",
+    "ResponseCategoriaEscola",
+    "Query201",
+    "Query202"
 ]

schema/categoria.py

@@ -0,0 +1,7 @@
+from pydantic import BaseModel
+
+class BaseCategoriaEscola(BaseModel):
+    descricao: str
+
+class ResponseCategoriaEscola(BaseCategoriaEscola):
+    id: int

schema/query.py

@@ -0,0 +1,14 @@
+from pydantic import BaseModel
+from typing import List
+from .unidade_escolar import ResponseUnidadeEscolar
+
+class Query201(BaseModel):
+    regiao:str
+    count:int
+    unidades_escolares: List[ResponseUnidadeEscolar]
+
+class Query202(BaseModel):
+    regiao:str
+    categoria:str
+    tipo:str
+    num_escolas:int

schema/unidade_escolar.py

@@ -1,6 +1,7 @@
 from pydantic import BaseModel
 from .tipo_escola import ResponseTipoEscola
 from .endereco import ResponseEndereco,RequestEndereco
+from .categoria import ResponseCategoriaEscola
 
 class UnidadeEscolarBase(BaseModel):
     nome: str
@@ -9,8 +10,10 @@ class UnidadeEscolarBase(BaseModel):
 class ResponseUnidadeEscolar(UnidadeEscolarBase):
     id:int
     tipo: ResponseTipoEscola
+    categoria:ResponseCategoriaEscola
     endereco: ResponseEndereco
 
 class RequestUnidadeEscolar(UnidadeEscolarBase):
     tipo_id: int
+    categoria_id: int
     endereco: RequestEndereco

service/__init__.py

@@ -6,6 +6,7 @@ from .cidade_service import CidadeService
 from .tipo_escola_service import TipoEscolaService
 from .unidade_escolar_service import UnidadeEscolarService
 from .endereco_service import EnderecoService
+from .query_service import QueryService
 
 __all__ = [
     'SessionService',
@@ -15,5 +16,6 @@ __all__ = [
     'CidadeService',
     'TipoEscolaService',
     'UnidadeEscolarService',
-    'EnderecoService'
+    'EnderecoService',
+    'QueryService'
 ]

service/query_service.py

@@ -0,0 +1,80 @@
+from database import SessionLocal
+from sqlalchemy import func
+from sqlalchemy.orm import joinedload
+from model import UnidadeEscolar,Endereco,Cidade,Regiao,Categoria,TipoEscola
+from schema import ResponseUnidadeEscolar,ResponseTipoEscola,ResponseEndereco,ResponseCategoriaEscola,Query201,Query202
+
+class QueryService:
+
+    def query201(self):
+        with SessionLocal() as db:
+            query_result = db.query(
+            Regiao.descricao,
+            UnidadeEscolar
+            ).join(Cidade, Regiao.id == Cidade.id_regiao
+            ).join(Endereco, Cidade.id == Endereco.id_cidade
+            ).join(UnidadeEscolar, Endereco.id == UnidadeEscolar.id_endereco
+            ).options(
+                joinedload(UnidadeEscolar.tipo),
+                joinedload(UnidadeEscolar.endereco).joinedload(Endereco.cidade).joinedload(Cidade.regiao)
+            ).group_by(Regiao.descricao, UnidadeEscolar.id).all()
+        result_dict = {}
+        for regiao,unidade in query_result:
+            if regiao not in result_dict:
+                result_dict[regiao] = {'count': 0, 'unidades_escolares': []}
+            result_dict[regiao]['count'] += 1
+            result_dict[regiao]['unidades_escolares'].append(
+                ResponseUnidadeEscolar(
+                    nome=unidade.nome,
+                    cod_inep=unidade.cod_inep,
+                    id=unidade.id,
+                    tipo=ResponseTipoEscola(
+                        id=unidade.tipo.id,
+                        descricao=unidade.tipo.description
+                    ),
+                    categoria=ResponseCategoriaEscola(
+                        id = unidade.categoria.id,
+                        descricao=unidade.categoria.description
+                    ),
+                    endereco=ResponseEndereco(
+                        id=unidade.endereco.id,
+                        rua=unidade.endereco.rua,
+                        numero=unidade.endereco.numero,
+                        cep=unidade.endereco.cep,
+                        cidade=unidade.endereco.cidade.nome,
+                        regiao=unidade.endereco.cidade.regiao.descricao
+                    )
+                )
+            )
+        return [
+            Query201(regiao=regiao, count=data['count'], unidades_escolares=data['unidades_escolares'])
+            for regiao, data in result_dict.items()
+        ]
+    
+    def query202(self):
+        with SessionLocal() as db:
+            query_result = db.query(
+                Regiao.descricao.label("regiao_nome"),
+                Categoria.description.label("categoria"),
+                TipoEscola.description.label("tipo_escola"),
+                func.count(UnidadeEscolar.id).label("num_unidades")
+            ).join(
+                Cidade
+            ).join(
+                Endereco
+            ).join(
+                UnidadeEscolar
+            ).join(
+                Categoria
+            ).join(
+                TipoEscola
+            ).group_by(
+                Regiao.descricao,
+                Categoria.description,
+                TipoEscola.description
+            ).all()
+        return [
+            Query202(regiao=result.regiao_nome,categoria=result.categoria,tipo=result.tipo_escola,num_escolas=result.num_unidades)
+            for result in query_result
+        ]
+

service/unidade_escolar_service.py

@@ -1,7 +1,7 @@
 from database import SessionLocal
 from model import UnidadeEscolar,Endereco,Cidade
 from exception import unidade_escolar_not_found
-from schema import ResponseUnidadeEscolar, ResponseTipoEscola, ResponseEndereco, RequestUnidadeEscolar
+from schema import ResponseUnidadeEscolar, ResponseTipoEscola, ResponseEndereco, RequestUnidadeEscolar, ResponseCategoriaEscola
 from sqlalchemy.orm import joinedload
 from .endereco_service import EnderecoService
 
@@ -18,6 +18,10 @@ class UnidadeEscolarService:
             id=unidade_escolar.tipo.id,
             descricao=unidade_escolar.tipo.description
         )
+        categoria = ResponseCategoriaEscola(
+            id=unidade_escolar.categoria.id,
+            descricao=unidade_escolar.categoria.description
+        )
         endereco = ResponseEndereco(
             rua=unidade_escolar.endereco.rua,
             numero=unidade_escolar.endereco.numero,
@@ -31,6 +35,7 @@ class UnidadeEscolarService:
             nome= unidade_escolar.nome,
             cod_inep=unidade_escolar.cod_inep,
             tipo=tipo_escola,
+            categoria=categoria,
             endereco=endereco
         )
 
@@ -38,6 +43,7 @@ class UnidadeEscolarService:
         unidade_escolar = UnidadeEscolar()
         unidade_escolar.nome = unidade_escolar_request.nome
         unidade_escolar.cod_inep = unidade_escolar_request.cod_inep
+        unidade_escolar.id_categoria = unidade_escolar_request.categoria_id
         unidade_escolar.id_tipo = unidade_escolar_request.tipo_id
         endereco_service = EnderecoService()
         endereco = endereco_service.create_endereco(unidade_escolar_request.endereco)