yeuimu
ab79325ab0
- PublicCacheService：分域版本号失效（bump 即作废，不等 TTL）、loader 期间 bump 的竞态防护（返回但不回写）、并发 miss 单飞、PUBLIC_CACHE_DISABLED /TTL_MS/MAX_ENTRIES 应急开关；@Global 模块 - PublicService 六端点接缓存：列表缓存全量物化（分页切片在缓存外按请求执行， 修复'所有页返回第一页'的切片缓存错误）、详情/首页/树/标签组/树序元数据/ 族最低价聚合各按依赖域缓存 - 全写路径挂钩 bump：admin CRUD（goods/categories/countries/tags/tag-groups/ positions/origin-goods 标签）、sync 三同步、族重算、整理全家桶—— 事务提交成功后失效对应域，product-families 经 recompute 天然覆盖 - 测试：PublicCacheService 单测 13 例 + 失效链路集成 8 例（读命中/写后立即可见 端到端/每条写路径域断言）；既有两套件测数据语义改为显式禁缓存
45 lines
1.8 KiB
TypeScript
45 lines
1.8 KiB
TypeScript
/**
|
|
* 存量修复脚本（幂等）：把纯款号商品名（如 `PLTK016`）按主链接 SDS 分类名
|
|
* 补成「描述名 款号」（如 `童装纯色插肩短袖T恤 PLTK016`）。
|
|
*
|
|
* 运行：
|
|
* pnpm --filter @inkreach/api fix:good-names # dry-run，只打印清单
|
|
* pnpm --filter @inkreach/api fix:good-names -- --apply # 实际写库
|
|
* origin_goods.good_name 为 SDS 纯镜像（每小时同步覆盖），本脚本只改 goods.good_name。
|
|
*/
|
|
import { PrismaService } from '../src/prisma/prisma.service';
|
|
import { PublicCacheService } from '../src/public/public-cache.service';
|
|
import { SyncService } from '../src/sync/sync.service';
|
|
import { FamilyRecomputeService } from '../src/product-families/family-recompute.service';
|
|
import { GoodsService } from '../src/goods/goods.service';
|
|
|
|
async function main() {
|
|
const dryRun = !process.argv.includes('--apply');
|
|
const prisma = new PrismaService();
|
|
await prisma.onModuleInit();
|
|
const recompute = new FamilyRecomputeService(prisma, new PublicCacheService());
|
|
// 回填路径不触发详情同步，SyncService 仅作占位依赖
|
|
const goods = new GoodsService(
|
|
prisma,
|
|
{ queueProductDetailSync: async () => undefined } as unknown as SyncService,
|
|
recompute,
|
|
new PublicCacheService(),
|
|
);
|
|
|
|
const result = await goods.backfillPureSkuGoodNames({ dryRun });
|
|
const mode = dryRun ? 'DRY-RUN（未写库，加 --apply 执行）' : 'APPLIED';
|
|
console.log(`[fix:good-names] ${mode} renamed=${result.renamed} unmapped=${result.unmapped.length}`);
|
|
for (const r of result.renames) {
|
|
console.log(` #${r.id} ${r.from} -> ${r.to}`);
|
|
}
|
|
for (const u of result.unmapped) {
|
|
console.log(` #${u.id} ${u.from} -> （无分类映射，保留原名）`);
|
|
}
|
|
await prisma.onModuleDestroy();
|
|
}
|
|
|
|
main().catch((error) => {
|
|
console.error(error);
|
|
process.exit(1);
|
|
});
|