feat(customers): add endpoint to retrieve projects associated with a specific customer with pagination

app/controllers/customers.py

@@ -5,9 +5,11 @@ from app.services.customer_service import CustomerService
 from app.services.customer_list_service import CustomerListService
 from app.services.contact_service import ContactService
 from app.services.address_service import AddressService
+from app.services.project_service import ProjectService
 from app.schemas.customer import CustomerCreate, CustomerOut, CustomerUpdate
 from app.schemas.contact import ContactCreate, ContactOut
 from app.schemas.address import AddressCreate, AddressOut
+from app.schemas.project_detail import ProjectCustomerOut
 from app.schemas.paginated_response import PaginatedResponse
 from typing import List, Optional
 import logging
@@ -391,4 +393,24 @@ def delete_customer_contact(
             detail="Failed to delete contact"
         )
 
+# Project-related endpoints
+@router.get("/{customer_id}/projects", response_model=List[ProjectCustomerOut])
+def get_customer_projects(
+    customer_id: str,
+    page: Optional[int] = Query(1, description="Page number (1-indexed)", ge=1),
+    page_size: Optional[int] = Query(100, description="Number of records per page", ge=1, le=1000),
+    db: Session = Depends(get_db)
+):
+    """Get all projects associated with a specific customer
+    
+    Returns a paginated list of all project-bidder relationships for the specified
+    customer ID, including complete details (barrier sizes, contacts, notes) for each.
+    
+    - **customer_id**: The customer ID (CustId from Bidders table)
+    - **page**: Page number starting from 1
+    - **page_size**: Number of records per page (max 1000)
+    """
+    service = ProjectService(db)
+    return service.get_customer_projects(customer_id, page=page, page_size=page_size)
+
 

app/db/repositories/bidder_repo.py

@@ -156,6 +156,54 @@ class BidderRepository:
             logger.warning(f"Error fetching bidder for project {project_no}, customer {customer_id}: {e}")
             return None
 
+    def fetch_bidders_by_customer_id_raw(self, customer_id: str, page: int = 1, page_size: int = 100):
+        """Fetch all bidders (project associations) for a specific customer ID with pagination.
+        
+        Returns a list of dicts representing all projects the customer is associated with.
+        """
+        try:
+            with self.db.get_bind().connect() as conn:
+                bidders_query = text("""
+                    SELECT 
+                        ProjNo as proj_no,
+                        CustId as cust_id, 
+                        Quote as quote,
+                        Contact as contact,
+                        Phone as phone,
+                        Notes as notes,
+                        DateLastContact as date_last_contact,
+                        DateFollowup as date_followup,
+                        [Primary] as is_primary,
+                        CustType as cust_type,
+                        EmailAddress as email_address,
+                        Id,
+                        Fax as fax,
+                        OrderNr as order_nr,
+                        CustomerPO as customer_po,
+                        ShipDate as ship_date,
+                        DeliverDate as deliver_date,
+                        ReplacementCost as replacement_cost,
+                        QuoteDate as quote_date,
+                        InvoiceDate as invoice_date,
+                        LessPayment as less_payment,
+                        Enabled as enabled,
+                        EmployeeId as employee_id
+                    FROM Bidders 
+                    WHERE CustId = :customer_id
+                    ORDER BY ProjNo DESC, Id
+                    OFFSET :offset ROWS FETCH NEXT :limit ROWS ONLY
+                """)
+                
+                offset = max(0, (page - 1) * page_size)
+                limit = max(1, min(page_size, 1000))
+                result = conn.execute(bidders_query, {"customer_id": customer_id, "offset": offset, "limit": limit})
+                rows = result.fetchall()
+                columns = result.keys()
+                return [dict(zip(columns, row)) for row in rows]
+        except Exception as e:
+            logger.warning(f"Error fetching bidders for customer {customer_id}: {e}")
+            return []
+
     def get_bidder_barrier_sizes_raw(self, bidder_id: int):
         """Return raw barrier size rows for a bidder (list of dicts)."""
         try:

app/services/project_service.py

@@ -239,6 +239,122 @@ class ProjectService:
         
         return customer
 
+    def get_customer_projects(self, customer_id: str, page: int = 1, page_size: int = 100) -> List[ProjectCustomerOut]:
+        """
+        Get all projects associated with a specific customer.
+        
+        Args:
+            customer_id: The customer ID (CustId)
+            page: Page number for pagination
+            page_size: Number of records per page
+            
+        Returns:
+            List[ProjectCustomerOut]: List of project-bidder relationships with full details
+        """
+        from app.db.repositories.bidder_repo import BidderRepository
+        
+        bidder_repo = BidderRepository(self.db)
+        bidder_rows = bidder_repo.fetch_bidders_by_customer_id_raw(customer_id, page=page, page_size=page_size)
+        
+        logger.info(f"Repository returned {len(bidder_rows)} bidders for customer {customer_id}")
+        
+        customers = []
+        for bidder_data in bidder_rows:
+            bidder_id = bidder_data.get('Id')
+            
+            # Fetch related data
+            barrier_rows = bidder_repo.get_bidder_barrier_sizes_raw(bidder_id)
+            contacts_rows = bidder_repo.get_bidder_contacts_raw(bidder_id)
+            notes_rows = bidder_repo.get_bidder_notes_raw(bidder_id)
+            
+            # Map barrier rows to BarrierSizeOut
+            barrier_sizes = []
+            for br in barrier_rows:
+                barrier_sizes.append(BarrierSizeOut(
+                    id=br.get('Id', 0),
+                    inventory_id=str(br.get('InventoryId', '')) if br.get('InventoryId') is not None else None,
+                    bidder_id=bidder_id,
+                    barrier_size_id=br.get('BarrierSizeId', 0),
+                    install_advisor_fees=br.get('InstallAdvisorFees'),
+                    is_standard=bool(br.get('IsStandard', True)),
+                    width=br.get('Width'),
+                    length=br.get('Length'),
+                    cable_units=br.get('CableUnits'),
+                    height=br.get('Height'),
+                    price=br.get('Price')
+                ))
+            
+            # Map contacts
+            contacts = []
+            for cr in contacts_rows:
+                contacts.append(ContactOut(
+                    id=cr.get('Id'),
+                    contact_id=cr.get('ContactId'),
+                    bidder_id=bidder_id,
+                    enabled=bool(cr.get('Enabled', True)),
+                    first_name=cr.get('FirstName'),
+                    last_name=cr.get('LastName'),
+                    title=cr.get('Title'),
+                    email=cr.get('EmailAddress'),
+                    phones=[],
+                    phone1=cr.get('WorkPhone'),
+                    phone2=cr.get('MobilePhone')
+                ))
+            
+            # Map notes
+            bidder_notes = []
+            for nr in notes_rows:
+                bidder_notes.append(BidderNoteOut(
+                    id=nr.get('Id'),
+                    bidder_id=bidder_id,
+                    date=nr.get('Date'),
+                    employee_id=nr.get('EmployeeID'),
+                    notes=nr.get('Notes', '')
+                ))
+            
+            # Create customer object with proper type conversions
+            replacement_cost = bidder_data.get('replacement_cost')
+            if replacement_cost == '' or replacement_cost is None:
+                replacement_cost = None
+            
+            cust_type = bidder_data.get('cust_type')
+            if cust_type is not None:
+                cust_type = str(cust_type)
+            
+            customer = ProjectCustomerOut(
+                proj_no=bidder_data.get('proj_no', 0),
+                cust_id=str(bidder_data.get('cust_id', '')),
+                quote=bidder_data.get('quote'),
+                contact=bidder_data.get('contact'),
+                phone=bidder_data.get('phone'),
+                notes=bidder_data.get('notes'),
+                date_last_contact=bidder_data.get('date_last_contact'),
+                date_followup=bidder_data.get('date_followup'),
+                primary=bool(bidder_data.get('is_primary', False)),
+                cust_type=cust_type,
+                email_address=bidder_data.get('email_address'),
+                id=bidder_id,
+                fax=bidder_data.get('fax'),
+                order_nr=bidder_data.get('order_nr'),
+                customer_po=bidder_data.get('customer_po'),
+                ship_date=bidder_data.get('ship_date'),
+                deliver_date=bidder_data.get('deliver_date'),
+                replacement_cost=replacement_cost,
+                quote_date=bidder_data.get('quote_date'),
+                invoice_date=bidder_data.get('invoice_date'),
+                less_payment=bidder_data.get('less_payment'),
+                barrier_sizes=barrier_sizes,
+                contacts=contacts,
+                bidder_notes=bidder_notes,
+                bid_date=bidder_data.get('date_last_contact'),  # Using last contact as bid date
+                enabled=bool(bidder_data.get('enabled', True)),
+                employee_id=str(bidder_data.get('employee_id')) if bidder_data.get('employee_id') is not None else None
+            )
+            
+            customers.append(customer)
+        
+        return customers
+
     def list_projects(self, customer_type: int = 0, order_by: str = "project_no", 
                      order_direction: str = "asc", page: int = 1, page_size: int = 10) -> PaginatedResponse[ProjectOut]:
         """

app/tests/unit/test_project_customers.py

@@ -5,6 +5,7 @@ from app.schemas.project_detail import ProjectCustomerOut, BarrierSizeOut, Conta
 
 from unittest.mock import MagicMock
 import app.controllers.projects as projects_controller
+import app.controllers.customers as customers_controller
 
 
 def make_sample_bidder_row():
@@ -187,4 +188,123 @@ def test_get_project_customer_detail_endpoint(monkeypatch):
     assert result.cust_id == 'CUST777'
     assert result.id == 77
     assert result.order_nr == 'ORD123'
-    assert result.employee_id == 'EMP5'
+    assert result.employee_id == 'EMP5'
+
+
+def test_get_customer_projects_service(monkeypatch):
+    """Test ProjectService.get_customer_projects method"""
+    mock_db = Mock()
+    service = ProjectService(mock_db)
+    
+    # Create sample bidders for multiple projects
+    bidder1 = make_sample_bidder_row()
+    bidder1['proj_no'] = 100
+    bidder1['cust_id'] = 'CUST888'
+    bidder1['Id'] = 20
+    
+    bidder2 = make_sample_bidder_row()
+    bidder2['proj_no'] = 200
+    bidder2['cust_id'] = 'CUST888'
+    bidder2['Id'] = 21
+    
+    # Mock BidderRepository methods
+    from app.db.repositories.bidder_repo import BidderRepository
+    mock_bidder_repo = Mock(spec=BidderRepository)
+    mock_bidder_repo.fetch_bidders_by_customer_id_raw = Mock(return_value=[bidder1, bidder2])
+    mock_bidder_repo.get_bidder_barrier_sizes_raw = Mock(return_value=[])
+    mock_bidder_repo.get_bidder_contacts_raw = Mock(return_value=[])
+    mock_bidder_repo.get_bidder_notes_raw = Mock(return_value=[])
+    
+    # Patch BidderRepository instantiation
+    def fake_bidder_repo_init(db):
+        return mock_bidder_repo
+    
+    monkeypatch.setattr('app.db.repositories.bidder_repo.BidderRepository', fake_bidder_repo_init)
+    
+    projects = service.get_customer_projects('CUST888', page=1, page_size=10)
+    
+    assert isinstance(projects, list)
+    assert len(projects) == 2
+    assert projects[0].proj_no == 100
+    assert projects[0].cust_id == 'CUST888'
+    assert projects[1].proj_no == 200
+    assert projects[1].cust_id == 'CUST888'
+    mock_bidder_repo.fetch_bidders_by_customer_id_raw.assert_called_once_with('CUST888', page=1, page_size=10)
+
+
+def test_get_customer_projects_endpoint(monkeypatch):
+    """Test controller endpoint for customer projects"""
+    sample1 = ProjectCustomerOut(
+        proj_no=300,
+        cust_id='CUST555',
+        quote=None,
+        contact='Project A Contact',
+        phone='111',
+        notes=None,
+        date_last_contact=None,
+        date_followup=None,
+        primary=True,
+        cust_type='1',
+        email_address='a@example.com',
+        id=30,
+        fax=None,
+        order_nr=None,
+        customer_po=None,
+        ship_date=None,
+        deliver_date=None,
+        replacement_cost=None,
+        quote_date=None,
+        invoice_date=None,
+        less_payment=None,
+        barrier_sizes=[],
+        contacts=[],
+        bidder_notes=[],
+        bid_date=None,
+        enabled=True,
+        employee_id=None
+    )
+    
+    sample2 = ProjectCustomerOut(
+        proj_no=400,
+        cust_id='CUST555',
+        quote=None,
+        contact='Project B Contact',
+        phone='222',
+        notes=None,
+        date_last_contact=None,
+        date_followup=None,
+        primary=False,
+        cust_type='2',
+        email_address='b@example.com',
+        id=31,
+        fax=None,
+        order_nr=None,
+        customer_po=None,
+        ship_date=None,
+        deliver_date=None,
+        replacement_cost=None,
+        quote_date=None,
+        invoice_date=None,
+        less_payment=None,
+        barrier_sizes=[],
+        contacts=[],
+        bidder_notes=[],
+        bid_date=None,
+        enabled=True,
+        employee_id=None
+    )
+    
+    def fake_get_customer_projects(self, customer_id, page=1, page_size=100):
+        return [sample1, sample2]
+    
+    monkeypatch.setattr('app.services.project_service.ProjectService.get_customer_projects', fake_get_customer_projects)
+    
+    fake_db = MagicMock()
+    result = customers_controller.get_customer_projects('CUST555', page=1, page_size=10, db=fake_db)
+    
+    assert isinstance(result, list)
+    assert len(result) == 2
+    assert result[0].proj_no == 300
+    assert result[0].cust_id == 'CUST555'
+    assert result[1].proj_no == 400
+    assert result[1].cust_id == 'CUST555'