📋 설비 점검 요청 관리 API

# Amazon Linux 2023에는 Python 3.9+가 기본 설치됨
python3 --version
 
# pip 업그레이드
python3 -m pip install --upgrade pip
 
# 프로젝트 디렉토리 생성
mkdir -p ~/inspection-api && cd ~/inspection-api
 
# 가상환경 생성 및 활성화
python3 -m venv venv
source venv/bin/activate
 
# 필요 패키지 설치
pip install fastapi uvicorn[standard] pydantic sqlalchemy

# main.py
from fastapi import FastAPI, Depends, HTTPException, Query
from sqlalchemy.orm import Session
from database import engine, get_db, Base
from models import Equipment, User, InspectionRequest, StatusHistory
from schemas import RequestCreate, StatusUpdate, RequestResponse, EquipmentResponse
from typing import Optional
 
# DB 테이블 생성
Base.metadata.create_all(bind=engine)
 
app = FastAPI(
    title="설비 점검 요청 관리 API",
    description="대한설비(주) 현장 설비 점검 요청을 관리하는 REST API",
    version="1.0.0",
)
 
# ──────────────────────────────────────
# 초기 데이터 (앱 시작 시 한 번 실행)
# ──────────────────────────────────────
@app.on_event("startup")
def seed_data():
    db = next(get_db())
    if db.query(Equipment).count() == 0:
        equipments = [
            Equipment(name="1라인 컨베이어", location="A동 1층", type="컨베이어", status="ACTIVE"),
            Equipment(name="2라인 프레스기", location="A동 2층", type="프레스", status="ACTIVE"),
            Equipment(name="냉각 시스템 A", location="B동 지하", type="냉각장치", status="ACTIVE"),
            Equipment(name="자동 용접 로봇", location="C동 1층", type="로봇", status="MAINTENANCE"),
        ]
        users = [
            User(name="박현장", role="worker", department="생산1팀"),
            User(name="이관리", role="manager", department="관리팀"),
            User(name="김기사", role="engineer", department="설비팀"),
        ]
        db.add_all(equipments + users)
        db.commit()
    db.close()
 
# ──────────────────────────────────────
# 1. GET /api/v1/equipments — 설비 목록
# ──────────────────────────────────────
@app.get("/api/v1/equipments", response_model=list[EquipmentResponse], tags=["설비"])
def list_equipments(db: Session = Depends(get_db)):
    return db.query(Equipment).all()
 
# ──────────────────────────────────────
# 2. POST /api/v1/requests — 점검 요청 접수
# ──────────────────────────────────────
@app.post("/api/v1/requests", response_model=RequestResponse, status_code=201, tags=["점검 요청"])
def create_request(req: RequestCreate, db: Session = Depends(get_db)):
    equipment = db.query(Equipment).filter(Equipment.id == req.equipment_id).first()
    if not equipment:
        raise HTTPException(status_code=404, detail="설비를 찾을 수 없습니다")
 
    new_request = InspectionRequest(**req.model_dump())
    db.add(new_request)
    db.commit()
    db.refresh(new_request)
 
    # 상태 이력 기록
    history = StatusHistory(
        request_id=new_request.id,
        from_status=None,
        to_status="PENDING",
        changed_by=req.requester_id,
        comment="점검 요청 접수"
    )
    db.add(history)
    db.commit()
    return new_request
 
# ──────────────────────────────────────
# 3. GET /api/v1/requests — 요청 목록 (필터링)
# ──────────────────────────────────────
@app.get("/api/v1/requests", response_model=list[RequestResponse], tags=["점검 요청"])
def list_requests(
    status: Optional[str] = Query(None, description="상태 필터 (PENDING, ASSIGNED 등)"),
    priority: Optional[str] = Query(None, description="우선순위 필터 (LOW, MEDIUM, HIGH, CRITICAL)"),
    db: Session = Depends(get_db),
):
    query = db.query(InspectionRequest)
    if status:
        query = query.filter(InspectionRequest.status == status)
    if priority:
        query = query.filter(InspectionRequest.priority == priority)
    return query.order_by(InspectionRequest.created_at.desc()).all()
 
# ──────────────────────────────────────
# 4. GET /api/v1/requests/{id} — 요청 상세
# ──────────────────────────────────────
@app.get("/api/v1/requests/{request_id}", response_model=RequestResponse, tags=["점검 요청"])
def get_request(request_id: int, db: Session = Depends(get_db)):
    req = db.query(InspectionRequest).filter(InspectionRequest.id == request_id).first()
    if not req:
        raise HTTPException(status_code=404, detail="점검 요청을 찾을 수 없습니다")
    return req
 
# ──────────────────────────────────────
# 5. PUT /api/v1/requests/{id}/status — 상태 변경
# ──────────────────────────────────────
VALID_TRANSITIONS = {
    "PENDING": ["ASSIGNED"],
    "ASSIGNED": ["IN_PROGRESS"],
    "IN_PROGRESS": ["COMPLETED", "ON_HOLD"],
    "ON_HOLD": ["IN_PROGRESS"],
}
 
@app.put("/api/v1/requests/{request_id}/status", response_model=RequestResponse, tags=["점검 요청"])
def update_status(request_id: int, update: StatusUpdate, db: Session = Depends(get_db)):
    req = db.query(InspectionRequest).filter(InspectionRequest.id == request_id).first()
    if not req:
        raise HTTPException(status_code=404, detail="점검 요청을 찾을 수 없습니다")
 
    allowed = VALID_TRANSITIONS.get(req.status, [])
    if update.status not in allowed:
        raise HTTPException(
            status_code=400,
            detail=f"'{req.status}'에서 '{update.status}'로 변경할 수 없습니다. 가능한 상태: {allowed}"
        )
 
    # 상태 이력 기록
    history = StatusHistory(
        request_id=req.id,
        from_status=req.status,
        to_status=update.status,
        changed_by=update.changed_by,
        comment=update.comment
    )
 
    req.status = update.status
    if update.assignee_id:
        req.assignee_id = update.assignee_id
 
    db.add(history)
    db.commit()
    db.refresh(req)
    return req
 
# ──────────────────────────────────────
# Health Check (ALB용)
# ──────────────────────────────────────
@app.get("/health", tags=["시스템"])
def health_check():
    return {"status": "healthy", "service": "inspection-api"}

cd ~/inspection-api
source venv/bin/activate
 
# 모든 네트워크 인터페이스에서 접속 가능하도록 0.0.0.0으로 바인딩
uvicorn main:app --host 0.0.0.0 --port 8000 --reload

{
  "title": "1라인 컨베이어 이상 소음",
  "description": "가동 시 좌측 롤러에서 비정상 소음 발생. 즉시 점검 필요.",
  "equipment_id": 1,
  "requester_id": 1,
  "priority": "HIGH"
}

# 1. 점검 요청 접수 (현장 근무자)
curl -X POST http://localhost:8000/api/v1/requests \
  -H "Content-Type: application/json" \
  -d '{"title":"1라인 컨베이어 이상 소음","equipment_id":1,"requester_id":1,"priority":"HIGH"}'
 
# 2. 담당자 배정 (관리자 → 김기사에게 배정)
curl -X PUT http://localhost:8000/api/v1/requests/1/status \
  -H "Content-Type: application/json" \
  -d '{"status":"ASSIGNED","changed_by":2,"comment":"김기사에게 배정","assignee_id":3}'
 
# 3. 작업 시작 (김기사가 점검 시작)
curl -X PUT http://localhost:8000/api/v1/requests/1/status \
  -H "Content-Type: application/json" \
  -d '{"status":"IN_PROGRESS","changed_by":3,"comment":"현장 도착, 점검 시작"}'
 
# 4. 점검 완료 (김기사가 수리 완료)
curl -X PUT http://localhost:8000/api/v1/requests/1/status \
  -H "Content-Type: application/json" \
  -d '{"status":"COMPLETED","changed_by":3,"comment":"롤러 베어링 교체 완료"}'
 
# 5. 요청 상세 조회 (모든 이력 포함)
curl http://localhost:8000/api/v1/requests/1 | python3 -m json.tool