route.ts

Go to the documentation of this file.

import { NextRequest, NextResponse } from 'next/server';
import { fieldpineServerApi } from '@/lib/server/fieldpineApi';
import { getRequestContext, validateApiAccess } from '@/lib/server/sessionUtils';
 
/**
 * Goods Movement Report
 * BUCK: retailmax.elink.goodsmovement.codedetail
 * Returns stock transfers, adjustments, write-offs
 */
export async function GET(request: NextRequest) {
  console.log('[Goods Movement] START - Route handler called');
  try {
    // 1. Get and validate session
    const context = await getRequestContext(request);
    const validation = validateApiAccess(context, 'elink');
    if (!validation.valid || !context) {
      return NextResponse.json(
        { error: validation.error || 'Access denied', errorCode: validation.errorCode },
        { status: 403 }
      );
    }
 
    const { searchParams } = new URL(request.url);
    
    // Date filters
    const startDate = searchParams.get('startDate');
    const endDate = searchParams.get('endDate');
    const limit = searchParams.get('limit') || '200';
    
    // Movement type: transfer, adjustment, writeoff, stocktake
    const movementType = searchParams.get('type');
    
    // Location filter
    const locationId = searchParams.get('locationId');
    
    // Product filter
    const productId = searchParams.get('productId');
 
    // Build BUCK parameters
    const buckParams: Record<string, string | string[]> = {
      '3': 'retailmax.elink.goodsmovement.codedetail',
      '8': limit,
      '99': Math.random().toString() // Cache buster
    };
 
    // Build filters array
    const filters: string[] = [];
 
    // Add date filters
    if (startDate) {
      filters.push(`f102,4,${startDate}`); // Movement date >=
    }
    if (endDate) {
      filters.push(`f102,1,${endDate}`); // Movement date <
    }
 
    // Add location filter
    if (locationId) {
      filters.push(`f131,2,${locationId}`);
    }
 
    // Add product filter
    if (productId) {
      filters.push(`f200,2,${productId}`);
    }
 
    // Add movement type filter
    if (movementType) {
      let typeCode = '0';
      switch (movementType) {
        case 'transfer':
          typeCode = '1';
          break;
        case 'adjustment':
          typeCode = '2';
          break;
        case 'writeoff':
          typeCode = '3';
          break;
        case 'stocktake':
          typeCode = '4';
          break;
        case 'return':
          typeCode = '5';
          break;
      }
      filters.push(`f110,2,${typeCode}`);
    }
 
    // Add filters to BUCK params
    if (filters.length > 0) {
      buckParams['9'] = filters;
    }
 
    // Use store-specific URL for API calls
    const result = await fieldpineServerApi.buckApiCall(buckParams, context.session.apiKey, context.store.url);
 
    console.log('[Goods Movement] BUCK response:', { hasResult: !!result, resultType: typeof result });
 
    // Process BUCK response
    if (result?.DATS && Array.isArray(result.DATS)) {
      const movements = result.DATS.map((item: any) => ({
        movementId: item?.f100,
        movementDate: item?.f102,
        movementType: item?.f110,
        movementTypeName: item?.f111,
        productId: item?.f200,
        productName: item?.f201,
        barcode: item?.f202,
        quantity: item?.f210,
        unitCost: item?.f211,
        totalCost: item?.f212,
        fromLocationId: item?.f131,
        fromLocationName: item?.f132,
        toLocationId: item?.f133,
        toLocationName: item?.f134,
        reasonCode: item?.f120,
        reasonDescription: item?.f121,
        userId: item?.f140,
        userName: item?.f141,
        notes: item?.f150,
        referenceNumber: item?.f160
      }));
 
      // Calculate summary by type
      const summary = movements.reduce((acc: Record<string, any>, m: any) => {
        const type = m.movementTypeName || 'Unknown';
        if (!acc[type]) {
          acc[type] = { count: 0, totalUnits: 0, totalValue: 0 };
        }
        acc[type].count++;
        acc[type].totalUnits += Math.abs(m.quantity || 0);
        acc[type].totalValue += Math.abs(m.totalCost || 0);
        return acc;
      }, {} as Record<string, any>);
 
      return NextResponse.json({
        success: true,
        data: movements,
        count: movements.length,
        summary,
        source: 'buck'
      });
    }
 
    return NextResponse.json({
      success: true,
      data: [],
      count: 0,
      source: 'buck'
    });
 
  } catch (error) {
    console.error('[Goods Movement] Error:', error);
    return NextResponse.json(
      { error: 'Failed to fetch goods movements' },
      { status: 500 }
    );
  }
}