113 lines
2.6 KiB
Markdown
113 lines
2.6 KiB
Markdown
|
# 采集域服务
|
||
|
|
|
||
|
|
> **入口**: [_index.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接口
|
||
|
|
|
||
|
|
```typescript
|
||
|
|
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*
|