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";
 
// GET: Look up product by barcode
export async function GET(request: NextRequest) {
  try {
    const authData = await getStoredAuth();
    if (!authData) {
      return NextResponse.json({ error: "Unauthorized" }, { status: 401 });
    }
 
    const { searchParams } = new URL(request.url);
    const barcode = searchParams.get("barcode");
 
    if (!barcode) {
      return NextResponse.json(
        { success: false, error: "Barcode parameter is required" },
        { status: 400 }
      );
    }
 
    // Look up product by barcode
    const result = await fieldpineServerApi.buckApiCall({
      "3": "retailmax.elink.products",
      "10": "199",
      "9": `f501,0,${barcode}`
    }, authData.apiKey!);
 
    return NextResponse.json({
      success: true,
      data: result,
      source: "elink",
    });
  } catch (error: any) {
    console.error("Error looking up product:", error);
    return NextResponse.json(
      { success: false, error: error.message || "Failed to look up product" },
      { status: error.status || 500 }
    );
  }
}
 
// POST: Record stocktake count
export async function POST(request: NextRequest) {
  try {
    const authData = await getStoredAuth();
    if (!authData) {
      return NextResponse.json({ error: "Unauthorized" }, { status: 401 });
    }
 
    const body = await request.json();
    const { productId, quantity, barcode, storeId, reference } = body;
 
    if (!productId || !quantity || !barcode) {
      return NextResponse.json(
        { success: false, error: "Missing required fields: productId, quantity, barcode" },
        { status: 400 }
      );
    }
 
    // Build DATI XML for stocktake count
    const escapeXml = (v: string) =>
      v.replace(/&/g, "&amp;").replace(/</g, "&lt;").replace(/>/g, "&gt;");
 
    const xml = [
      "<DATI>",
      "<f8>retailmax.elink.stocktake.count</f8>",
      "<f11:B>I</f11:B>",
      "<f26>2</f26>",
      "<f110_E>2</f110_E>", // scanner type
      `<f118_E>${productId}</f118_E>`,
      `<f111_E>${quantity}</f111_E>`,
      `<f120_s>${escapeXml(barcode)}</f120_s>`,
      storeId && storeId !== "0" ? `<f121_E>${storeId}</f121_E>` : "",
      reference ? `<f124_s>${escapeXml(reference)}</f124_s>` : "",
      "</DATI>",
    ].join("");
 
    // POST DATI XML to BUCK endpoint
    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) {
      throw new Error(`Stocktake count failed: ${response.status} ${response.statusText}`);
    }
 
    const result = await response.json();
 
    return NextResponse.json({
      success: true,
      data: result,
      source: "dati",
    });
  } catch (error: any) {
    console.error("Error recording stocktake:", error);
    return NextResponse.json(
      { success: false, error: error.message || "Failed to record stocktake" },
      { status: error.status || 500 }
    );
  }
}