CozePhpSdk

composer require limingxinleo/coze-php-sdk

如何使用任务调度器

<?php

declare(strict_types=1);
/**
 * This file is part of Hyperf.
 *
 * @link     https://www.hyperf.io
 * @document https://hyperf.wiki
 * @contact  [email protected]
 * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
 */
use Coze\ChatTask;
use Coze\ChatTaskRunner;
use Coze\Client;
use Coze\Message\DetailMessages;
use Coze\Message\RetrieveMessage;
use Coze\Token;

require __DIR__ . '/vendor/autoload.php';

$token = new Token(file_get_contents('token.txt'));

$client = new Client($token);

$res = $client->chat->send('123123', '123', [
    [
        'content' => '请给我一份上海宝山的房源数据',
        'content_type' => 'text',
        'role' => 'user',
        'type' => 'question',
    ],
]);

$task1 = ChatTask::fromRetrieveMessage($res, 1);

$res = $client->chat->send('123123', '1234', [
    [
        'content' => '请给我一份上海嘉定的房源数据',
        'content_type' => 'text',
        'role' => 'user',
        'type' => 'question',
    ],
]);

$task2 = ChatTask::fromRetrieveMessage($res, 2);

// 开发者需要重新实现 ChatTaskRunner，这里直接创建两个 Task 来进行测试
$runner = new class($client, [$task1, $task2]) extends ChatTaskRunner {
    public function __construct(Client $client, public array $tasks)
    {
        parent::__construct($client);
    }

    public function scroll(int $id): array
    {
        // 这里根据实际情况，从数据库表里读取未完成的Task列表
        if ($id === 0) {
            return $this->tasks;
        }

        return [];
    }

    public function execute(ChatTask $task): void
    {
        var_dump('执行 ' . $task->chatId);
        parent::execute($task);
    }

    public function save(ChatTask $task, RetrieveMessage $retrieved, DetailMessages $messages): bool
    {
        // 这里需要开发者根据 $task->id 保存对应数据，避免下次调度任务重复执行已经完成的对话
        var_dump('执行完毕 ' . $task->chatId, $task->isCompleted);
        var_dump($messages->withRawData());
        return true;
    }
};

// 这里通过 while(true) 模拟定时任务，开发者可以直接使用定时任务，每分钟跑一次
while (true) {
    sleep(1);

    $runner->run();

    if ($task1->isCompleted && $task2->isCompleted) {
        break;
    }
}