makemd/docs/SERVICES/collection.md

采集域服务

入口: _index.md

---

服务列表

服务	文件	职责
CollectionAdapterService	services/CollectionAdapterService.ts	采集适配
TikTokConnector	core/connectors/TikTokConnector.ts	TikTok采集
TemuConnector	core/connectors/TemuConnector.ts	Temu采集
ShopifyConnector	core/connectors/ShopifyConnector.ts	Shopify采集

---

核心流程

创建采集任务 → 选择连接器 → 执行采集 → 数据解析 → 存储入库

---

CollectionAdapterService

方法列表

方法	说明	参数	返回
createTask	创建任务	CreateRequest	CollectionTask
executeTask	执行任务	taskId	CollectionResult
getTaskStatus	获取状态	taskId	TaskStatus
cancelTask	取消任务	taskId	void

---

Connector接口

interface IPlatformConnector {
  platformCode: string;
  capabilities: {
    hasApi: boolean;
    supportsPriceSync: boolean;
    supportsInventorySync: boolean;
    supportsOrderPull: boolean;
  };
  
  pullProducts(shopId: string): Promise<PlatformProduct[]>;
  pullOrders(shopId: string): Promise<PlatformOrder[]>;
  pushListing(product: Product): Promise<ListingResult>;
  updatePrice(listingId: string, price: number): Promise<void>;
  syncInventory(listingId: string, stock: number): Promise<void>;
}

---

已实现连接器

连接器	平台	能力
ShopifyConnector	Shopify	API全功能
AmazonConnector	Amazon	API全功能
TikTokConnector	TikTok Shop	API+采集
TemuConnector	Temu	采集
ShopeeConnector	Shopee	API+采集

---

待实现连接器

连接器	平台	优先级
Alibaba1688Connector	1688	P0
TikTokAdsConnector	TikTok Ads	P0
FacebookAdsConnector	Facebook Ads	P0
GoogleAdsConnector	Google Ads	P0

---

状态机

PENDING → RUNNING → COMPLETED
              ↓
            FAILED

状态	说明
PENDING	待执行
RUNNING	执行中
COMPLETED	已完成
FAILED	失败

---

API端点

端点	方法	服务方法
/api/v1/collection/tasks	POST	CollectionAdapterService.createTask
/api/v1/collection/tasks/:id	GET	CollectionAdapterService.getTaskStatus
/api/v1/collection/tasks/:id/execute	POST	CollectionAdapterService.executeTask
/api/v1/collection/tasks/:id/cancel	POST	CollectionAdapterService.cancelTask

---

最后更新: 2026-03-22