Multi-Item COD Consignment Splitting via WhatsApp: How to Prevent 100% Doorstep Refusals

import axios from "axios";
import { Queue } from "bullmq";

interface SplitCandidatePayload {
  orderId: string;
  orderNumber: string;
  customerPhone: string;
  customerName: string;
  readyItems: Array<{ title: string; price: number; quantity: number }>;
  backorderedItems: Array<{ title: string; price: number; expectedDays: number }>;
}

export async function sendSplitOfferMessage(payload: SplitCandidatePayload) {
  const readyTotal = payload.readyItems.reduce((acc, item) => acc + (item.price * item.quantity), 0);
  const fullTotal = readyTotal + payload.backorderedItems.reduce((acc, item) => acc + item.price, 0);

  const readyList = payload.readyItems.map(i => `• ${i.title} (${i.quantity}x)`).join("\n");
  const delayList = payload.backorderedItems.map(i => `• ${i.title} (Available in ${i.expectedDays} days)`).join("\n");

  const metaPayload = {
    messaging_product: "whatsapp",
    recipient_type: "individual",
    to: payload.customerPhone,
    type: "interactive",
    interactive: {
      type: "button",
      header: {
        type: "text",
        text: `Order #${payload.orderNumber} - Dispatch Update`
      },
      body: {
        text: `Salam ${payload.customerName}! 📦\n\nAapke order ke ye items tayyar hain aur aaj dispatch ho sakte hain:\n${readyList}\n\nJabke ye item manufacturing process mein hai:\n${delayList}\n\nKya hum tayyar items foran bhej dein? Aapko sirf received items ka COD ada karna hoga:`
      },
      footer: {
        text: `Tayyar Items COD: PKR ${readyTotal.toLocaleString()} (Total: PKR ${fullTotal.toLocaleString()})`
      },
      action: {
        buttons: [
          {
            type: "reply",
            reply: {
              id: `SPLIT_ACCEPT_${payload.orderId}`,
              title: `✅ Bheij Dein (PKR ${readyTotal})`
            }
          },
          {
            type: "reply",
            reply: {
              id: `SPLIT_WAIT_${payload.orderId}`,
              title: "⏳ Ek Sath Bheinjein"
            }
          }
        ]
      }
    }
  };

  await axios.post(
    `https://graph.facebook.com/v25.0/${process.env.META_PHONE_NUMBER_ID}/messages`,
    metaPayload,
    {
      headers: {
        Authorization: `Bearer ${process.env.META_ACCESS_TOKEN}`,
        "Content-Type": "application/json"
      }
    }
  );
}

import axios from "axios";
import { db } from "./db-client";

export async function executeFulfillmentSplit(orderId: string) {
  const order = await db.orders.findUnique({ where: { id: orderId } });
  if (!order) throw new Error("Order not found");

  // 1. Call Shopify GraphQL API to split FulfillmentOrder
  const graphqlMutation = `
    mutation fulfillmentOrderSplit($fulfillmentOrderId: ID!, $fulfillmentOrderLineItems: [FulfillmentOrderLineItemInput!]!) {
      fulfillmentOrderSplit(fulfillmentOrderId: $fulfillmentOrderId, fulfillmentOrderLineItems: $fulfillmentOrderLineItems) {
        fulfillmentOrder {
          id
          status
        }
        replacementFulfillmentOrder {
          id
          status
        }
        userErrors {
          field
          message
        }
      }
    }
  `;

  const shopifyResp = await axios.post(
    `https://${process.env.SHOPIFY_STORE_DOMAIN}/admin/api/2026-01/graphql.json`,
    {
      query: graphqlMutation,
      variables: {
        fulfillmentOrderId: order.shopifyFulfillmentOrderId,
        fulfillmentOrderLineItems: order.readyLineItems.map(item => ({
          id: item.fulfillmentLineItemId,
          quantity: item.quantity
        }))
      }
    },
    {
      headers: {
        "X-Shopify-Access-Token": process.env.SHOPIFY_ADMIN_TOKEN,
        "Content-Type": "application/json"
      }
    }
  );

  const result = shopifyResp.data.data.fulfillmentOrderSplit;
  const splitFulfillmentId = result.fulfillmentOrder.id;

  // 2. Book Ready Consignment in PostEx API with Adjusted COD Amount
  const postexPayload = {
    cityName: order.shippingCity,
    customerName: order.customerName,
    customerPhone: order.customerPhone,
    deliveryAddress: order.shippingAddress,
    invoicePayment: order.readyTotalAmountPKR, // Adjusted COD
    orderDetail: `Split Part 1 of Order #${order.orderNumber}`,
    orderRefNumber: `${order.orderNumber}-P1`,
    orderType: "Normal"
  };

  const postexResp = await axios.post(
    "https://api.postex.pk/services/integration/api/order/v1/create-order",
    postexPayload,
    { headers: { token: process.env.POSTEX_API_TOKEN } }
  );

  const trackingNumber = postexResp.data.distrrId;
  await db.shipments.create({
    data: {
      orderId: order.id,
      consignmentNumber: trackingNumber,
      amountCOD: order.readyTotalAmountPKR,
      partIndex: 1
    }
  });
}