# 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()