业务背景#

1
浏览器插件（选品）
2
    ↓
3
后台管理系统（商品管理）
4
    ↓
5
小龙虾 OpenClaw Gateway
6
    ↓
7
OpenClaw Workflow（商品口播生成流水线）
8
    ├── goods-ocr Skill（图片 → 文字）
9
    ├── script-generator Skill（文字 → 口播词）
10
    ├── tts-synthesizer Skill（口播词 → 音频）
11
    └── review-sync Skill（结果回写与人工审核）
12
    ↓
13
Redis 异步队列 / 业务数据库

1
skills/
2
  goods-ocr/
3
    SKILL.md              # 输入图片列表，输出按顺序合并后的 OCR 文本
4
  script-generator/
5
    SKILL.md              # 输入商品标题、OCR 文本、运营提示词，输出卖点和口播词
6
  tts-synthesizer/
7
    SKILL.md              # 输入口播词，输出音频地址和合成状态
8
  review-sync/
9
    SKILL.md              # 输入生成结果，回写业务后台并触发人工审核

1
待处理(1) → OCR中(2) → 已识别(3) → 生成中(4) → 已生成(5) → TTS中(6) → 已完成(7)
2
                                                                          ↘ 失败(8)

1
class GoodsEnum
2
{
3
    // 状态流转定义
4
    public static array $statusFlow = [
5
        1 => [2],      // 待处理 → OCR中
6
        2 => [3, 8],   // OCR中 → 已识别 / 失败
7
        3 => [4],      // 已识别 → 生成中
8
        4 => [5, 8],   // 生成中 → 已生成 / 失败
9
        5 => [6],      // 已生成 → TTS中
10
        6 => [7, 8],   // TTS中 → 已完成 / 失败
11
    ];
12

13
    /**
14
     * 校验状态流转是否合法
15
     */
16
    public static function canTransit(int $from, int $to): bool
17
    {
18
        return in_array($to, self::$statusFlow[$from] ?? []);
19
    }
20
}

1
class GoodsModule extends BaseModule
2
{
3
    public function ocr($request): array
4
    {
5
        $param = $this->validate($request, GoodsValidate::ocr());
6

7
        // 1. 校验状态：只有"待处理"和"已识别"可以触发 OCR
8
        $goods = $this->dep(GoodsDep::class)->getById($param['id']);
9
        if (!in_array($goods->status, [1, 3])) {
10
            return [null, 400, '当前状态不允许执行 OCR'];
11
        }
12

13
        // 2. 更新状态为"OCR中"
14
        $this->dep(GoodsDep::class)->transitStatus($param['id'], 2);
15

16
        // 3. 触发 OpenClaw Workflow，由 goods-ocr Skill 执行识别
17
        $this->openClawClient->runWorkflow('goods-script-flow', [
18
            'entry' => 'goods-ocr',
19
            'goods_id' => $param['id'],
20
            'image_list' => $param['image_list_success'],
21
            'callback' => '/api/goods/openclaw/callback',
22
        ]);
23

24
        return [null, 0, 'OCR 任务已提交'];
25
    }
26
}

1
class GoodsProcess implements Consumer
2
{
3
    public string $queue = 'goods-slow-queue';
4

5
    public function consume($data): void
6
    {
7
        try {
8
            match ($data['action']) {
9
                'goods-ocr' => $this->handleOcr($data),
10
                'script-generator' => $this->handleGenerate($data),
11
                'tts-synthesizer' => $this->handleTts($data),
12
            };
13
        } catch (\Throwable $e) {
14
            // 统一错误处理：更新状态为失败，记录错误信息
15
            $this->markFailed($data['goods_id'], $e->getMessage());
16
            Log::error("Goods queue failed", [
17
                'action' => $data['action'],
18
                'goods_id' => $data['goods_id'],
19
                'error' => $e->getMessage(),
20
            ]);
21
        }
22
    }
23
}

1
goods-script-flow
2
  ├─ goods-ocr
3
  │   └─ 成功后进入 script-generator
4
  ├─ script-generator
5
  │   └─ 成功后进入 tts-synthesizer
6
  ├─ tts-synthesizer
7
  │   └─ 成功后进入 review-sync
8
  └─ review-sync
9
      └─ 回写业务后台，等待人工确认

1
┌─────────────────────────────────────────────────────┐
2
│ 编辑商品  [已生成]                              [×] │
3
├─────────────────────────────────────────────────────┤
4
│ 详情图片（点击选择需要识别的图片）                    │
5
│ [☑ img1] [☑ img2] [☐ img3] [☑ img4] ...           │
6
│ [OCR识别（3张已选）]                                 │
7
├────────────┬───────────┬───────────┬────────────────┤
8
│ 商品信息   │ AI提示词  │ 卖点      │ 口播词         │
9
│            │           │           │                │
10
│ 标题: xxx  │ 智能体:   │ (textarea)│ (textarea)     │
11
│ 链接: xxx  │ [选择▾]   │           │                │
12
│ OCR结果:   │ 提示词:   │           │                │
13
│ (readonly) │ (textarea)│           │                │
14
│            │ [生成]    │           │                │
15
├────────────┴───────────┴───────────┴────────────────┤
16
│                              [取消]  [确认]          │
17
└─────────────────────────────────────────────────────┘

1
// 平台识别 + 对应 scraper 调用
2
const scrapers = {
3
    'taobao.com': scrapeTaobao,
4
    'jd.com': scrapeJD,
5
    'tmall.com': scrapeTmall,
6
    'pinduoduo.com': scrapePDD,
7
};
8

9
function detectPlatform(url) {
10
    for (const [domain, scraper] of Object.entries(scrapers)) {
11
        if (url.includes(domain)) return { platform: domain, scraper };
12
    }
13
    return null;
14
}