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';
 
/**
 * Invoices Endpoint (using BUCK API retailmax.elink.invoice.list)
 * GET /api/v1/invoices - List received invoices
 * 
 * Field codes:
 * - f310: Document number (e.g., "UZDZ-WS-AZI")
 * - f1300: Supplier name
 * - f301: Supplier ID (e.g., "A3324949")
 * - f331: Total cost
 * - f311: Date (pipe-delimited: "2025|3|25|13|50|35||")
 * - f313: Store ID
 * - f1313: Store name
 * - f300: Status/type
 * - f312, f1312: Additional fields
 */
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);
    
    // Parse query parameters
    const fromDate = searchParams.get('from') || '2025-01-01';
    const toDate = searchParams.get('to') || new Date().toISOString().split('T')[0];
    const status = searchParams.get('status') || 'S'; // S = Submitted/Received
 
    console.log('[Invoices API] Fetching invoices:', { fromDate, toDate, status });
 
    // Use BUCK API to get invoice list
    // Parameters:
    // - 3: retailmax.elink.invoice.list
    // - 9: Filters (f311,4,fromDate and f311,1,toDate for date range, f101,0,status for status)
    const buckParams: Record<string, string> = {
      '3': 'retailmax.elink.invoice.list',
      '9': [
        `f311,4,${fromDate}`,  // Date >= fromDate
        `f311,1,${toDate}`,    // Date <= toDate
        `f101,0,${status}`     // Status filter
      ].join(',')
    };
 
    const result = await fieldpineServerApi.buckApiCall(buckParams, authData.apiKey);
    
    console.log('[Invoices API] BUCK result:', {
      hasDats: !!result.DATS,
      datsLength: result.DATS?.length,
      firstInvoice: result.DATS?.[0]
    });
 
    // Parse DATS array into invoice objects
    let invoices: any[] = [];
    if (result && result.DATS && Array.isArray(result.DATS)) {
      invoices = result.DATS.map((invoice: any) => {
        // Parse date from pipe-delimited string: "2025|3|25|13|50|35||"
        let invoiceDate = null;
        if (invoice.f311) {
          const dateParts = invoice.f311.split('|');
          if (dateParts.length >= 6) {
            const [year, month, day, hour, minute, second] = dateParts;
            invoiceDate = new Date(
              parseInt(year),
              parseInt(month) - 1, // JS months are 0-indexed
              parseInt(day),
              parseInt(hour),
              parseInt(minute),
              parseInt(second)
            ).toISOString();
          }
        }
 
        return {
          DocumentNumber: invoice.f310 || null,
          DocumentId: invoice.f301 || null,
          SupplierName: invoice.f1300 || null,
          SupplierCode: invoice.f302 || null,
          TotalCost: parseFloat(invoice.f331) || 0,
          InvoiceDate: invoiceDate,
          StoreId: parseInt(invoice.f313) || null,
          StoreName: invoice.f1313 || null,
          Status: parseInt(invoice.f300) || null,
          StatusText: invoice.f1312 || null,
          
          // Additional fields
          RawDate: invoice.f311 || null,
          RawStatus: invoice.f312 || null
        };
      });
    }
 
    console.log('[Invoices API] Returning', invoices.length, 'invoices');
 
    return NextResponse.json({
      success: true,
      data: invoices,
      count: invoices.length,
      filters: {
        fromDate,
        toDate,
        status
      },
      source: 'buck'
    });
 
  } catch (error) {
    console.error('[Invoices API] Error:', error);
    return NextResponse.json(
      { 
        success: false,
        error: 'Failed to fetch invoices',
        details: error instanceof Error ? error.message : 'Unknown error',
        data: []
      },
      { status: 500 }
    );
  }
}