chajia/modules/flock/pricing-options-queue.ts

import { addFlockPricingOptionsJob } from "@/workers/rpa/queue";
import type { FlockCheckoutTier } from "@/lib/flock/flock-checkout-selection";
import type { FlockQuoteInput } from "@/workers/rpa/flock/types";

export type FlockPricingOptionsJobData = {
  quoteId: string;
  requestId: string;
  customerId: string;
  preferredTier: FlockCheckoutTier;
  reference?: string | null;
  input: FlockQuoteInput;
  /** 首价 park 的会话 id；有则复用驻留页刮档，勿冷启动 */
  quoteSessionId?: string | null;
};

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