route.ts

Go to the documentation of this file.

import { NextRequest, NextResponse } from 'next/server';
import { fieldpineServerApi } from '@/lib/server/fieldpineApi';
import { getStoredAuth } from '@/lib/server/auth';
 
/**
 * Sales API Endpoint
 * Fetches sales data filtered by customer, account, date range, etc.
 */
export async function GET(request: NextRequest) {
  try {
    // Verify authentication
    const authData = await getStoredAuth();
    if (!authData || !authData.authenticated) {
      return NextResponse.json(
        { error: 'Authentication required' },
        { status: 401 }
      );
    }
 
    // Parse query parameters
    const { searchParams } = new URL(request.url);
    
    const customerId = searchParams.get('customerId');
    const accountId = searchParams.get('accountId');
    const limit = searchParams.get('limit');
    const from = searchParams.get('from');
    const to = searchParams.get('to');
 
    // Build BUCK API parameters
    let buckParams: Record<string, string> = {
      "3": "retailmax.elink.saleflat.list",
      "8": limit || "20",
      "99": Math.random().toString()
    };
 
    // Add customer filter if provided
    if (customerId) {
      buckParams["9"] = `f108,0,${customerId}`;
    }
 
    // Add account filter if provided
    if (accountId) {
      buckParams["9"] = `f117,0,${accountId}`;
    }
 
    try {
      const response = await fieldpineServerApi.buckApiCall(buckParams, authData.apiKey);
      
      const sales = response?.DATS || [];
      
      return NextResponse.json({ 
        success: true, 
        data: sales
      });
      
    } catch (error) {
      console.error('Sales API error:', error);
      return NextResponse.json(
        { error: 'Failed to fetch sales' },
        { status: 503 }
      );
    }
 
  } catch (error) {
    console.error('Sales API error:', error);
    return NextResponse.json(
      { error: 'Failed to fetch sales' },
      { status: 500 }
    );
  }
}