|
|
/**
|
|
|
* Flock fill-only 结账 job：选档 + 填齐详情，不支付
|
|
|
*/
|
|
|
import { getCustomerProviderLogin } from "@/modules/customer/provider-credentials";
|
|
|
import { runWithFlockLoginContext } from "@/lib/flock/login-context";
|
|
|
import { RpaError } from "@/modules/rpa/errors";
|
|
|
import { saveFlockCheckoutStatus } from "@/lib/flock/flock-checkout-store";
|
|
|
import type { FlockCheckoutFillJobData } from "@/modules/flock/checkout-queue";
|
|
|
import { runFlockLoggedInCheckoutFill } from "@/workers/rpa/flock/checkout";
|
|
|
|
|
|
export async function processFlockCheckoutFillJob(
|
|
|
data: FlockCheckoutFillJobData,
|
|
|
): Promise<void> {
|
|
|
const customerLogin = await getCustomerProviderLogin(
|
|
|
data.customerId,
|
|
|
"flock",
|
|
|
);
|
|
|
const email =
|
|
|
customerLogin?.email?.trim() || process.env.FLOCK_LOGIN_EMAIL?.trim() || "";
|
|
|
const password =
|
|
|
customerLogin?.password?.trim() ||
|
|
|
process.env.FLOCK_LOGIN_PASSWORD?.trim() ||
|
|
|
"";
|
|
|
|
|
|
try {
|
|
|
const result = await runWithFlockLoginContext(
|
|
|
email && password ? { email, password } : null,
|
|
|
customerLogin ? "customer" : "env",
|
|
|
() =>
|
|
|
runFlockLoggedInCheckoutFill(data.input, {
|
|
|
preferredTier: data.preferredTier,
|
|
|
preferredFlexibility: data.preferredFlexibility,
|
|
|
preferredCarrier: data.preferredCarrier,
|
|
|
fillOnly: true,
|
|
|
reference: data.reference,
|
|
|
flockDetails: data.flockDetails,
|
|
|
quoteSessionId: data.quoteSessionId,
|
|
|
}),
|
|
|
);
|
|
|
|
|
|
await saveFlockCheckoutStatus({
|
|
|
quote_id: data.quoteId,
|
|
|
status: "done",
|
|
|
stage: result.stage,
|
|
|
preferred_tier: data.preferredTier,
|
|
|
selected_total: result.selectedTotal,
|
|
|
screenshot_path: result.screenshotPath ?? null,
|
|
|
message: "已在官网填齐详情（未支付）",
|
|
|
updated_at_ms: Date.now(),
|
|
|
});
|
|
|
if (data.quoteSessionId) {
|
|
|
const { clearFlockQuoteHold, updateFlockQuoteHoldStatus } = await import(
|
|
|
"@/lib/flock/flock-quote-hold-store"
|
|
|
);
|
|
|
await updateFlockQuoteHoldStatus(data.quoteSessionId, "done").catch(
|
|
|
() => undefined,
|
|
|
);
|
|
|
await clearFlockQuoteHold(data.quoteSessionId).catch(() => undefined);
|
|
|
}
|
|
|
console.log(
|
|
|
`[flock-checkout] ok quote_id=${data.quoteId} stage=${result.stage} tier=${data.preferredTier}` +
|
|
|
(result.screenshotPath ? ` shot=${result.screenshotPath}` : ""),
|
|
|
);
|
|
|
} catch (err) {
|
|
|
const msg = err instanceof Error ? err.message : String(err);
|
|
|
const code = err instanceof RpaError ? err.code : "RPA_DATA_INVALID";
|
|
|
console.error(`[flock-checkout] FAIL quote_id=${data.quoteId} ${msg}`);
|
|
|
await saveFlockCheckoutStatus({
|
|
|
quote_id: data.quoteId,
|
|
|
status: "failed",
|
|
|
preferred_tier: data.preferredTier,
|
|
|
message: "官网同步失败，请稍后重试",
|
|
|
updated_at_ms: Date.now(),
|
|
|
});
|
|
|
console.warn(`[flock-checkout] 已记录失败 code=${code}`);
|
|
|
}
|
|
|
}
|
