|
|
/**
|
|
|
* MotherShip 登录态 ×10：遵守官网硬限（禁周末 / 单件≤5000lb）
|
|
|
* DIAG_HEADED=true npx tsx scripts/diag-mothership-rules-x10.ts
|
|
|
*/
|
|
|
import fs from "node:fs";
|
|
|
import path from "node:path";
|
|
|
import { loadDevEnv } from "@/lib/dev-env";
|
|
|
|
|
|
loadDevEnv();
|
|
|
|
|
|
const wantHeaded = process.env.DIAG_HEADED !== "false";
|
|
|
process.env.RPA_HEADED = wantHeaded ? "true" : "false";
|
|
|
process.env.RPA_HEADLESS = wantHeaded ? "false" : "true";
|
|
|
if (wantHeaded && !process.env.RPA_SLOW_MO_MS?.trim()) {
|
|
|
process.env.RPA_SLOW_MO_MS = "80";
|
|
|
}
|
|
|
if (!wantHeaded) delete process.env.RPA_SLOW_MO_MS;
|
|
|
|
|
|
import { resolveAxelMothershipSuggest } from "@/lib/axel/candidates";
|
|
|
import {
|
|
|
snapMothershipReadyDateToWeekday,
|
|
|
MOTHERSHIP_MAX_WEIGHT_EACH_LB,
|
|
|
} from "@/lib/mothership/logged-in-constraints";
|
|
|
import { runWithMothershipLoginContext } from "@/lib/rpa/mothership-login-context";
|
|
|
import { getCustomerProviderLogin } from "@/modules/customer/provider-credentials";
|
|
|
import type { QuoteRequest } from "@/modules/providers/quote-provider";
|
|
|
import {
|
|
|
buildLoggedInAddressSearchQuery,
|
|
|
runMothershipLoggedInDashboardQuote,
|
|
|
} from "@/workers/rpa/mothership-logged-in-quote";
|
|
|
|
|
|
const READY_DATE = snapMothershipReadyDateToWeekday(
|
|
|
process.env.DIAG_READY_DATE?.trim() || "2026-07-20",
|
|
|
);
|
|
|
const READY_TIME = process.env.DIAG_READY_TIME?.trim() || "12:00 PM";
|
|
|
|
|
|
/** 10 组线路；单件重量均 ≤5000 */
|
|
|
const LANES = [
|
|
|
{
|
|
|
name: "Brea→Fairhope",
|
|
|
pickup: "789 East Elm Street suite 301, Brea, CA, USA",
|
|
|
delivery: "456 Oak Avenue unit 207, Fairhope, AL, USA",
|
|
|
weightEach: 250,
|
|
|
qty: 2,
|
|
|
dims: [60, 60, 60] as const,
|
|
|
},
|
|
|
{
|
|
|
name: "LA→SF",
|
|
|
pickup:
|
|
|
"2020 West Washington Boulevard floor 5 rm 508, Los Angeles, CA, USA",
|
|
|
delivery: "555 Market St ste 1001, San Francisco, CA, USA",
|
|
|
weightEach: 480,
|
|
|
qty: 2,
|
|
|
dims: [48, 40, 48] as const,
|
|
|
},
|
|
|
{
|
|
|
name: "Albany→SF",
|
|
|
pickup: "101 South Pine Avenue, Albany, NY 12208, USA",
|
|
|
delivery: "555 Market St ste 1001, San Francisco, CA, USA",
|
|
|
weightEach: 120,
|
|
|
qty: 2,
|
|
|
dims: [48, 40, 48] as const,
|
|
|
},
|
|
|
{
|
|
|
name: "MA→OR",
|
|
|
pickup: "789 Elm Street, East Bridgewater, MA, USA",
|
|
|
delivery: "888 Liberty Street Northeast, Salem, OR, USA",
|
|
|
weightEach: 200,
|
|
|
qty: 1,
|
|
|
dims: [48, 40, 48] as const,
|
|
|
},
|
|
|
{
|
|
|
name: "Dallas→Chicago",
|
|
|
pickup: "1234 Main Street, Dallas, TX, USA",
|
|
|
delivery: "200 East Randolph Street, Chicago, IL, USA",
|
|
|
weightEach: 500,
|
|
|
qty: 2,
|
|
|
dims: [48, 40, 40] as const,
|
|
|
},
|
|
|
{
|
|
|
name: "Atlanta→Denver",
|
|
|
pickup: "100 Peachtree Street NW, Atlanta, GA, USA",
|
|
|
delivery: "1701 California Street, Denver, CO, USA",
|
|
|
weightEach: 300,
|
|
|
qty: 2,
|
|
|
dims: [48, 40, 48] as const,
|
|
|
},
|
|
|
{
|
|
|
name: "Brea→LA",
|
|
|
pickup: "789 East Elm Street, Brea, CA, USA",
|
|
|
delivery:
|
|
|
"2020 West Washington Boulevard floor 5 rm 508, Los Angeles, CA, USA",
|
|
|
weightEach: 50,
|
|
|
qty: 1,
|
|
|
dims: [40, 40, 40] as const,
|
|
|
},
|
|
|
{
|
|
|
name: "SF→Albany",
|
|
|
pickup: "555 Market St ste 1001, San Francisco, CA, USA",
|
|
|
delivery: "101 South Pine Avenue, Albany, NY 12208, USA",
|
|
|
weightEach: 150,
|
|
|
qty: 2,
|
|
|
dims: [48, 40, 48] as const,
|
|
|
},
|
|
|
{
|
|
|
name: "Chicago→Dallas",
|
|
|
pickup: "200 East Randolph Street, Chicago, IL, USA",
|
|
|
delivery: "1234 Main Street, Dallas, TX, USA",
|
|
|
weightEach: 400,
|
|
|
qty: 1,
|
|
|
dims: [48, 40, 48] as const,
|
|
|
},
|
|
|
{
|
|
|
name: "Denver→Atlanta",
|
|
|
pickup: "1701 California Street, Denver, CO, USA",
|
|
|
delivery: "100 Peachtree Street NW, Atlanta, GA, USA",
|
|
|
weightEach: 220,
|
|
|
qty: 2,
|
|
|
dims: [48, 40, 40] as const,
|
|
|
},
|
|
|
] as const;
|
|
|
|
|
|
type Row = {
|
|
|
n: number;
|
|
|
name: string;
|
|
|
ok: boolean;
|
|
|
ms: number;
|
|
|
lastStep: string;
|
|
|
detail: string;
|
|
|
};
|
|
|
|
|
|
const timingBuf: string[] = [];
|
|
|
const origLog = console.log.bind(console);
|
|
|
console.log = (...args: unknown[]) => {
|
|
|
const line = args.map(String).join(" ");
|
|
|
if (
|
|
|
line.includes("[rpa] logged-in timing:") ||
|
|
|
line.includes("[rpa] logged-in step:") ||
|
|
|
line.includes("still no rate-card") ||
|
|
|
line.includes("patched details") ||
|
|
|
line.includes("rate-card ready") ||
|
|
|
line.includes("FAILED") ||
|
|
|
line.includes("weekend")
|
|
|
) {
|
|
|
timingBuf.push(line);
|
|
|
}
|
|
|
origLog(...args);
|
|
|
};
|
|
|
|
|
|
async function pickFirst(query: string) {
|
|
|
const list = await resolveAxelMothershipSuggest(query);
|
|
|
const hit = list.find((c) => c.selectable !== false && c.option_id.trim());
|
|
|
if (!hit) throw new Error(`无联想: ${query.slice(0, 50)}`);
|
|
|
return hit;
|
|
|
}
|
|
|
|
|
|
function toAddr(c: Awaited<ReturnType<typeof pickFirst>>) {
|
|
|
return {
|
|
|
street: c.street,
|
|
|
city: c.city,
|
|
|
state: c.state,
|
|
|
zip: c.zip || "",
|
|
|
placeId: c.option_id,
|
|
|
formattedAddress: c.formatted_address || c.display_label,
|
|
|
selectedFromSuggestions: true,
|
|
|
mothershipOptionId: c.option_id,
|
|
|
mothershipDisplayLabel: c.display_label,
|
|
|
selectedFromMothership: true,
|
|
|
};
|
|
|
}
|
|
|
|
|
|
function lastStep(): string {
|
|
|
for (let i = timingBuf.length - 1; i >= 0; i -= 1) {
|
|
|
const m = timingBuf[i]!.match(/step="([^"]+)"/);
|
|
|
if (m) return m[1]!;
|
|
|
if (timingBuf[i]!.includes("still no rate-card")) return "wait rate-card";
|
|
|
}
|
|
|
return "(none)";
|
|
|
}
|
|
|
|
|
|
async function main(): Promise<void> {
|
|
|
for (const lane of LANES) {
|
|
|
if (lane.weightEach > MOTHERSHIP_MAX_WEIGHT_EACH_LB) {
|
|
|
throw new Error(`lane ${lane.name} weightEach 超限`);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
const customerId = process.env.DIAG_CUSTOMER_ID?.trim() || "CUST_001";
|
|
|
const login = await getCustomerProviderLogin(customerId, "mothership");
|
|
|
if (!login) {
|
|
|
console.error(`[diag] 无 MotherShip 账密 customer=${customerId}`);
|
|
|
process.exit(1);
|
|
|
}
|
|
|
|
|
|
console.log("=== MotherShip rules ×10（禁周末 / 单件≤5000）===");
|
|
|
console.log(
|
|
|
`headed=${wantHeaded} ready=${READY_DATE} ${READY_TIME} maxWeightEach=${MOTHERSHIP_MAX_WEIGHT_EACH_LB}`,
|
|
|
);
|
|
|
|
|
|
const rows: Row[] = [];
|
|
|
for (let n = 0; n < LANES.length; n += 1) {
|
|
|
const lane = LANES[n]!;
|
|
|
timingBuf.length = 0;
|
|
|
const t0 = Date.now();
|
|
|
console.log(`\n---------- ${n + 1}/10 ${lane.name} wt=${lane.weightEach} ----------`);
|
|
|
try {
|
|
|
const [p, d] = await Promise.all([
|
|
|
pickFirst(lane.pickup),
|
|
|
pickFirst(lane.delivery),
|
|
|
]);
|
|
|
const req: QuoteRequest = {
|
|
|
cargoHash: `diag-rules-${n}-${Date.now()}`,
|
|
|
pickup: toAddr(p),
|
|
|
delivery: toAddr(d),
|
|
|
weightLb: lane.weightEach,
|
|
|
dimsIn: { l: lane.dims[0], w: lane.dims[1], h: lane.dims[2] },
|
|
|
palletCount: lane.qty,
|
|
|
cargoType: "general_freight",
|
|
|
readyDate: READY_DATE,
|
|
|
readyTime: READY_TIME,
|
|
|
cargoLines: [
|
|
|
{
|
|
|
cargoType: "pallet",
|
|
|
quantity: lane.qty,
|
|
|
weightLb: lane.weightEach,
|
|
|
lengthIn: lane.dims[0],
|
|
|
widthIn: lane.dims[1],
|
|
|
heightIn: lane.dims[2],
|
|
|
},
|
|
|
],
|
|
|
};
|
|
|
console.log(
|
|
|
`[diag] ${buildLoggedInAddressSearchQuery(req.pickup)} → ${buildLoggedInAddressSearchQuery(req.delivery)}`,
|
|
|
);
|
|
|
const items = await runWithMothershipLoginContext(login, "customer", () =>
|
|
|
runMothershipLoggedInDashboardQuote(req),
|
|
|
);
|
|
|
const ms = Date.now() - t0;
|
|
|
const carriers = items.map((i) => `${i.carrier}=$${i.rawTotal}`).join(", ");
|
|
|
rows.push({
|
|
|
n: n + 1,
|
|
|
name: lane.name,
|
|
|
ok: true,
|
|
|
ms,
|
|
|
lastStep: lastStep(),
|
|
|
detail: carriers,
|
|
|
});
|
|
|
console.log(`[diag] OK ${ms}ms ${carriers}`);
|
|
|
} catch (err) {
|
|
|
const ms = Date.now() - t0;
|
|
|
const msg = err instanceof Error ? err.message : String(err);
|
|
|
rows.push({
|
|
|
n: n + 1,
|
|
|
name: lane.name,
|
|
|
ok: false,
|
|
|
ms,
|
|
|
lastStep: lastStep(),
|
|
|
detail: msg.slice(0, 220),
|
|
|
});
|
|
|
console.log(`[diag] FAIL ${ms}ms step=${lastStep()} ${msg.slice(0, 160)}`);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
const okN = rows.filter((r) => r.ok).length;
|
|
|
const reportPath = path.join(
|
|
|
process.cwd(),
|
|
|
".rpa",
|
|
|
"diag",
|
|
|
`rules-x10-${new Date().toISOString().replace(/[:.]/g, "-")}.md`,
|
|
|
);
|
|
|
const md = [
|
|
|
`# MotherShip rules ×10`,
|
|
|
"",
|
|
|
`- ready=${READY_DATE}（已 snap 工作日）`,
|
|
|
`- maxWeightEach=${MOTHERSHIP_MAX_WEIGHT_EACH_LB}`,
|
|
|
`- ok=${okN}/10`,
|
|
|
"",
|
|
|
"| # | lane | ok | ms | lastStep | detail |",
|
|
|
"|---|------|----|----|----------|--------|",
|
|
|
...rows.map(
|
|
|
(r) =>
|
|
|
`| ${r.n} | ${r.name} | ${r.ok ? "Y" : "N"} | ${r.ms} | ${r.lastStep} | ${r.detail.replace(/\|/g, "/")} |`,
|
|
|
),
|
|
|
"",
|
|
|
].join("\n");
|
|
|
fs.mkdirSync(path.dirname(reportPath), { recursive: true });
|
|
|
fs.writeFileSync(reportPath, md, "utf8");
|
|
|
console.log(`\n=== SUMMARY ok=${okN}/10 report=${reportPath} ===`);
|
|
|
for (const r of rows) {
|
|
|
console.log(
|
|
|
` #${r.n} ${r.ok ? "OK" : "FAIL"} ${r.name} ${r.ms}ms ${r.lastStep}`,
|
|
|
);
|
|
|
}
|
|
|
process.exit(okN === 10 ? 0 : 1);
|
|
|
}
|
|
|
|
|
|
main().catch((e) => {
|
|
|
console.error(e);
|
|
|
process.exit(1);
|
|
|
});
|
