webapp/app/services/product_routing_service.py

# app/services/product_routing_service.py
from sqlalchemy.orm import Session
from app.core.biz_exception import NotFoundError, PermissionDeniedError, BizLogicError
from app.models.product_routing import VasProductRouting
from app.schemas.product_routing import VasProductRoutingCreate

class ProductRoutingService:
    def create(db: Session, data: VasProductRoutingCreate):
        rec = VasProductRouting(**data.dict())
        db.add(rec)
        db.commit()
        db.refresh(rec)
        return rec

    def list_by_product(db: Session, product_id:int):
        return db.query(VasProductRouting).filter_by(product_id=product_id).all()
    
    def delete(db: Session, id: int):
        obj = db.query(VasProductRouting).filter_by(id=id).first()
        if not obj:
            raise NotFoundError("Product routing not exist")
        db.delete(obj)
        db.commit()