chajia/modules/flock/checkout-queue.ts

import { addFlockCheckoutFillJob } from "@/workers/rpa/queue";
import type {
  FlockCheckoutTier,
  FlockFlexibilityKey,
} from "@/lib/flock/flock-checkout-selection";
import type { FlockQuoteInput } from "@/workers/rpa/flock/types";
import type { FlockCheckoutDetails } from "@/modules/flock/checkout-validation";

export type FlockCheckoutFillJobData = {
  quoteId: string;
  requestId: string;
  customerId: string;
  preferredTier: FlockCheckoutTier;
  preferredFlexibility?: FlockFlexibilityKey | null;
  preferredCarrier?: string | null;
  reference?: string | null;
  input: FlockQuoteInput;
  flockDetails?: FlockCheckoutDetails;
  /** 首价保活 session；有则优先接管驻留页 */
  quoteSessionId?: string | null;
};

export async function enqueueFlockCheckoutFillJob(
  data: FlockCheckoutFillJobData,
): Promise<void> {
  if (process.env.RPA_QUEUE_ENABLED === "false") {
    console.log(
      `[rpa-queue] 队列已禁用 flock-checkout quote_id=${data.quoteId}`,
    );
    return;
  }
  await addFlockCheckoutFillJob(data);
  console.log(
    `[rpa-queue] 已入队 flock-checkout-fill quote_id=${data.quoteId} tier=${data.preferredTier}`,
  );
}