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 Stock Adjustment API
 * POST /api/v1/products/stock-adjustment
 * Adjust product stock levels with reason tracking
 */
export async function POST(request: NextRequest) {
  try {
    const authData = await getStoredAuth();
    if (!authData || !authData.authenticated) {
      return NextResponse.json(
        { success: false, error: 'Authentication required' },
        { status: 401 }
      );
    }
 
    const body = await request.json();
    const { productId, adjustment, reason, locationId = 1 } = body;
 
    if (!productId) {
      return NextResponse.json(
        { success: false, error: 'Product ID is required' },
        { status: 400 }
      );
    }
 
    if (adjustment === undefined || adjustment === null) {
      return NextResponse.json(
        { success: false, error: 'Adjustment amount is required' },
        { status: 400 }
      );
    }
 
    const adjustmentNum = parseFloat(adjustment);
    if (isNaN(adjustmentNum)) {
      return NextResponse.json(
        { success: false, error: 'Invalid adjustment amount' },
        { status: 400 }
      );
    }
 
    console.log('[Stock Adjustment] Request:', { productId, adjustment: adjustmentNum, reason, locationId });
 
    // Escape XML content
    const escapeXml = (v: string | number) =>
      String(v).replace(/&/g, '&amp;').replace(/</g, '&lt;').replace(/>/g, '&gt;');
 
    // Determine transaction type based on reason
    let transactionType = 204; // Default: Manual Adjustment
    let comments = reason || 'Manual adjustment';
 
    switch (reason) {
      case 'received':
        transactionType = 100; // Received
        comments = 'Stock Received';
        break;
      case 'sale':
        transactionType = 210; // Sales
        comments = 'Sale Adjustment';
        break;
      case 'damage':
      case 'writeoff':
        transactionType = 201; // Write Off
        comments = 'Damage/Loss';
        break;
      case 'return':
        transactionType = 200; // Supplier Return
        comments = 'Stock Return';
        break;
      case 'adjustment':
      default:
        transactionType = 204; // Stocktake Adjustment
        comments = 'Manual Adjustment';
    }
 
    // Build DATI XML for goods in history (stock movement)
    const xml = [
      '<DATI>',
      '<f8_s>retailmax.elink.goodsin.edit</f8_s>',
      '<f11_B>I</f11_B>',
      `<f100_E>${escapeXml(productId)}</f100_E>`,
      `<f110_E>${transactionType}</f110_E>`,
      `<f111>${Math.abs(adjustmentNum)}</f111>`,
      `<f120_E>${escapeXml(locationId)}</f120_E>`,
      `<f140_s>${escapeXml(comments)}</f140_s>`,
      '</DATI>'
    ].join('');
 
    console.log('[Stock Adjustment] DATI XML:', xml);
 
    // Send DATI request
    const url = `${process.env.FIELDPINE_BASE_URL || 'https://iig.cwanz.online'}/GNAP/j/buck`;
    const headers: Record<string, string> = {
      'Accept': 'application/json',
      'Content-Type': 'text/xml',
      'Cookie': `FieldpineApiKey=${authData.apiKey}`
    };
 
    const response = await fetch(url, {
      method: 'POST',
      headers,
      body: xml,
    });
 
    if (!response.ok) {
      const errorText = await response.text();
      console.error('[Stock Adjustment] Error response:', errorText);
      throw new Error(`Stock adjustment failed: ${response.status} ${response.statusText}`);
    }
 
    const result = await response.json();
    console.log('[Stock Adjustment] Success:', result);
 
    return NextResponse.json({
      success: true,
      data: result,
      message: `Stock adjusted by ${adjustmentNum > 0 ? '+' : ''}${adjustmentNum}`,
      source: 'dati'
    });
 
  } catch (error: any) {
    console.error('[Stock Adjustment] Error:', error);
    return NextResponse.json(
      { success: false, error: error.message || 'Failed to adjust stock' },
      { status: 500 }
    );
  }
}