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';
 
/**
 * Product Performance Analytics
 * BUCK: retailmax.elink.stats.product.performance
 * Most heavily used query (432 uses!) - Critical for business intelligence
 */
export async function GET(request: NextRequest) {
  try {
    const authData = await getStoredAuth();
    if (!authData || !authData.authenticated) {
      return NextResponse.json(
        { error: 'Authentication required' },
        { status: 401 }
      );
    }
 
    const { searchParams } = new URL(request.url);
    
    // Customer/location filter
    const customerId = searchParams.get('customerId');
    const locationId = searchParams.get('locationId');
    
    // Grouping: product (pid), supplier (spid), department (dept)
    const groupBy = searchParams.get('groupBy') || 'pid';
    
    // Limit results
    const limit = searchParams.get('limit') || '30';
    
    // Sort mode (100 parameter)
    // 1 = by units sold (volume)
    // 2 = by revenue
    // 3 = by gross profit
    const sortBy = searchParams.get('sortBy') || '2'; // Default to revenue
 
    // Build BUCK parameters
    const params: string[] = [
      '3=retailmax.elink.stats.product.performance',
      `8=${limit}`,
      `100=${sortBy}`
    ];
 
    // Add grouping
    switch (groupBy) {
      case 'pid':
      case 'product':
        params.push('15=2,pid'); // Group by product
        break;
      case 'spid':
      case 'supplier':
        params.push('15=2,spid'); // Group by supplier
        break;
      case 'dept':
      case 'department':
        params.push('15=2,dept'); // Group by department
        break;
    }
 
    // Add customer filter (f107 = customer)
    if (customerId) {
      params.push(`9=f107,0,${customerId}`);
    }
 
    // Add location filter (f131 = location)
    if (locationId) {
      params.push(`9=f131,0,${locationId}`);
    }
 
    const query = params.join('&');
    const url = `/GNAP/j/buck?${query}`;
 
    console.log('[Product Performance] BUCK query:', url);
 
    const result = await fieldpineServerApi.apiCall(url, {
      cookie: authData.apiKey,
      useOpenApi: false
    });
 
    // Process BUCK response
    if (result && result.DATS && Array.isArray(result.DATS)) {
      const performance = result.DATS.map((item: any) => ({
        productId: item.f200,
        productName: item.f201,
        barcode: item.f202,
        supplierId: item.f220,
        supplierName: item.f221,
        departmentId: item.f240,
        departmentName: item.f241,
        unitsSold: item.f210,
        revenue: item.f211,
        cost: item.f212,
        grossProfit: item.f213,
        grossMargin: item.f214,
        averagePrice: item.f215,
        transactionCount: item.f216,
        averageUnitsPerTransaction: item.f217,
        lastSaleDate: item.f250,
        customerId: item.f300,
        customerName: item.f301
      }));
 
      // Calculate totals
      const totals = {
        totalUnits: performance.reduce((sum: number, p: any) => sum + (p.unitsSold || 0), 0),
        totalRevenue: performance.reduce((sum: number, p: any) => sum + (p.revenue || 0), 0),
        totalCost: performance.reduce((sum: number, p: any) => sum + (p.cost || 0), 0),
        totalProfit: performance.reduce((sum: number, p: any) => sum + (p.grossProfit || 0), 0),
        averageMargin: 0
      };
      
      if (totals.totalRevenue > 0) {
        totals.averageMargin = (totals.totalProfit / totals.totalRevenue) * 100;
      }
 
      return NextResponse.json({
        success: true,
        data: performance,
        count: performance.length,
        totals,
        groupBy,
        sortBy,
        source: 'buck'
      });
    }
 
    return NextResponse.json({
      success: true,
      data: [],
      count: 0,
      groupBy,
      sortBy,
      source: 'buck'
    });
 
  } catch (error) {
    console.error('[Product Performance] Error:', error);
    return NextResponse.json(
      { error: 'Failed to fetch product performance' },
      { status: 500 }
    );
  }
}