route.ts

Go to the documentation of this file.

import { NextRequest, NextResponse } from 'next/server';
import { fieldpineServerApi } from '@/lib/server/fieldpineApi';
import { getRequestContext } from '@/lib/server/sessionUtils';
 
/**
 * Top Products by Sales
 * ELINK: retailmax.elink.sale.totals.group (grouped by product)
 * Returns top selling products by revenue
 */
export async function GET(request: NextRequest) {
  try {
    const context = await getRequestContext(request);
    if (!context?.session) {
      return NextResponse.json(
        { error: 'Authentication required' },
        { status: 401 }
      );
    }
 
    const { searchParams } = new URL(request.url);
    const startDate = searchParams.get('startDate');
    const endDate = searchParams.get('endDate');
    const location = searchParams.get('location');
 
    // Build BUCK request parameters for grouped product sales
    const buckParams: Record<string, string> = {
      "3": "retailmax.elink.sale.totals.group",
      "10": "11000", // Quartile stats
      "15": "2,1,pid", // Group by product ID
      "13": "120", // Sort by sales amount
      "8": "1000" // Limit to 1000 results
    };
 
    // Add date filters if provided
    if (startDate) {
      buckParams["9"] = `f110,4,${startDate}`;
    }
    if (endDate) {
      // Add as second date filter
      const key = startDate ? "9.1" : "9";
      buckParams[key] = `f110,1,${endDate}`;
    }
 
    // Add location filter if provided
    if (location && location !== '0') {
      buckParams["7"] = location;
    }
 
    const data = await fieldpineServerApi.buckApiCall(buckParams, context.session.apiKey);
 
    return NextResponse.json(data);
  } catch (error: any) {
    console.error('Error fetching top products:', error);
    return NextResponse.json(
      { error: error.message || 'Failed to fetch top products' },
      { status: 500 }
    );
  }
}