74 lines
2.7 KiB
Python
74 lines
2.7 KiB
Python
# app/services/shipment_processor.py
|
|
|
|
from sqlalchemy.orm import Session
|
|
from app.models import Shipment, Dewar, Puck, Sample
|
|
from app.schemas import ShipmentCreate, ShipmentResponse
|
|
import logging
|
|
|
|
logger = logging.getLogger(__name__)
|
|
|
|
|
|
class ShipmentProcessor:
|
|
def __init__(self, db: Session):
|
|
self.db = db
|
|
|
|
def process_shipment(self, shipment: ShipmentCreate) -> ShipmentResponse:
|
|
try:
|
|
# Creating new Shipment
|
|
new_shipment = Shipment(
|
|
shipment_name=shipment.shipment_name,
|
|
shipment_date=shipment.shipment_date,
|
|
shipment_status=shipment.shipment_status, # Adjusted to match model
|
|
# other shipment-related fields if any
|
|
)
|
|
self.db.add(new_shipment)
|
|
self.db.commit()
|
|
self.db.refresh(new_shipment)
|
|
|
|
# Link Dewars
|
|
for dewar_data in shipment.dewars:
|
|
dewar = Dewar(
|
|
shipment_id=new_shipment.id,
|
|
dewar_name=dewar_data.dewar_name,
|
|
tracking_number=dewar_data.tracking_number,
|
|
status=dewar_data.status,
|
|
contact_person_id=dewar_data.contact_person_id,
|
|
return_address_id=dewar_data.return_address_id,
|
|
)
|
|
self.db.add(dewar)
|
|
self.db.commit()
|
|
self.db.refresh(dewar)
|
|
|
|
# Link Pucks
|
|
for puck_data in dewar_data.pucks:
|
|
puck = Puck(
|
|
dewar_id=dewar.id,
|
|
puck_name=puck_data.puck_name,
|
|
puck_type=puck_data.puck_type,
|
|
puck_location_in_dewar=puck_data.puck_location_in_dewar,
|
|
)
|
|
self.db.add(puck)
|
|
self.db.commit()
|
|
self.db.refresh(puck)
|
|
|
|
# Link Samples
|
|
for sample_data in puck_data.samples:
|
|
sample = Sample(
|
|
puck_id=puck.id,
|
|
sample_name=sample_data.sample_name,
|
|
position=sample_data.position,
|
|
)
|
|
self.db.add(sample)
|
|
self.db.commit()
|
|
self.db.refresh(sample)
|
|
|
|
# Return a response wrapped in the ShipmentResponse schema
|
|
return ShipmentResponse(
|
|
shipment_id=new_shipment.id,
|
|
status="success",
|
|
message="Shipment processed successfully"
|
|
)
|
|
except Exception as e:
|
|
logger.error(f"Error processing shipment: {str(e)}")
|
|
raise e
|