webapp/app/services/product_routing_service.py

# app/services/product_routing_service.py
from sqlalchemy.orm import Session
from app.models.product_routing import VasProductRouting
from app.schemas.product_routing import ProductRoutingCreate

class ProductRoutingService:
    def create(db: Session, data: ProductRoutingCreate):
        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()