基于Yii2 CurlTransport对接第三方API实现CRUD更新操作技术咨询

我来帮你梳理下Yii2里基于第三方JSON API实现UPDATE操作的具体思路和代码示例——你已经搞定了READ部分，接下来的核心是用虚拟Model来适配ActiveForm的使用，毕竟Yii的表单组件依赖Model类来做字段绑定和验证，哪怕这个Model不关联本地数据库。具体步骤如下：

1. 创建虚拟Model适配ActiveForm #

咱们不需要继承ActiveRecord，只需要创建一个继承自yii\base\Model的虚拟类，定义从第三方API获取的字段和对应验证规则即可：

<?php
namespace app\models;

use yii\base\Model;

class RemoteSite extends Model
{
    public $primary_id;
    public $sample;
    // 这里添加你从第三方API获取的其他字段

    public function rules()
    {
        return [
            [['primary_id', 'sample'], 'required'],
            // 根据第三方API要求添加验证规则，比如字段类型、长度限制
            ['primary_id', 'integer'],
            ['sample', 'string', 'max' => 255],
        ];
    }

    // 定义表单字段的显示名称
    public function attributeLabels()
    {
        return [
            'primary_id' => '站点ID',
            'sample' => '示例字段',
        ];
    }
}

2. 控制器中处理数据加载与更新逻辑 #

在控制器里写一个actionUpdate方法，分两种场景处理：GET请求时从第三方API拉取数据填充Model，POST请求时提交修改到sites_update接口：

<?php
namespace app\controllers;

use Yii;
use yii\web\Controller;
use yii\httpclient\Client;
use yii\helpers\Json;
use app\models\RemoteSite;

class SiteController extends Controller
{
    public function actionUpdate($id)
    {
        $model = new RemoteSite();
        $client = new Client(['transport' => 'yii\httpclient\CurlTransport']);

        // GET请求：从第三方API加载数据到Model
        if (Yii::$app->request->isGet) {
            $request = $client->createRequest()
                ->setMethod('POST')
                ->setFormat(Client::FORMAT_JSON)
                ->setUrl('https://example.com/remote/json.php?sites')
                ->setData(['primary_id' => $id])
                ->setOptions([
                    CURLOPT_CONNECTTIMEOUT => 5,
                    CURLOPT_TIMEOUT => 10,
                ])->send();

            if ($request->isOk) {
                $siteData = Json::decode($request->content);
                // 假设返回单条数据数组，直接赋值给Model属性
                $model->setAttributes($siteData);
            } else {
                Yii::$app->session->setFlash('error', '加载站点数据失败：' . $request->content);
                return $this->redirect(['index']);
            }
        }

        // POST请求：提交修改到第三方UPDATE接口
        if (Yii::$app->request->isPost && $model->load(Yii::$app->request->post()) && $model->validate()) {
            $updateRequest = $client->createRequest()
                ->setMethod('POST') // 若第三方API要求用PUT则改为PUT
                ->setFormat(Client::FORMAT_JSON)
                ->setUrl('https://example.com/remote/json.php?sites_update')
                ->setData($model->getAttributes()) // 将Model属性作为请求数据
                ->setOptions([
                    CURLOPT_CONNECTTIMEOUT => 5,
                    CURLOPT_TIMEOUT => 10,
                ])->send();

            if ($updateRequest->isOk) {
                $responseData = Json::decode($updateRequest->content);
                // 根据第三方API响应判断更新结果
                if (isset($responseData['success']) && $responseData['success']) {
                    Yii::$app->session->setFlash('success', '站点更新成功');
                    return $this->redirect(['index']);
                } else {
                    Yii::$app->session->setFlash('error', '更新失败：' . ($responseData['message'] ?? '未知错误'));
                }
            } else {
                Yii::$app->session->setFlash('error', '请求第三方API失败：' . $updateRequest->content);
            }
        }

        return $this->render('update', [
            'model' => $model,
        ]);
    }
}

3. 视图中使用ActiveForm渲染表单 #

在views/site/update.php里，完全可以像使用普通ActiveRecord一样调用ActiveForm：

<?php
use yii\helpers\Html;
use yii\widgets\ActiveForm;

$this->title = '更新站点';
?>
<div class="site-update">
    <h1><?= Html::encode($this->title) ?></h1>

    <!-- 显示操作提示 -->
    <?php if (Yii::$app->session->hasFlash('success')): ?>
        <div class="alert alert-success">
            <?= Yii::$app->session->getFlash('success') ?>
        </div>
    <?php endif; ?>
    <?php if (Yii::$app->session->hasFlash('error')): ?>
        <div class="alert alert-danger">
            <?= Yii::$app->session->getFlash('error') ?>
        </div>
    <?php endif; ?>

    <div class="site-form">
        <?php $form = ActiveForm::begin(); ?>

        <!-- 隐藏primary_id字段，确保更新时能传递正确的ID -->
        <?= $form->field($model, 'primary_id')->hiddenInput()->label(false) ?>
        <?= $form->field($model, 'sample')->textInput() ?>
        <!-- 添加其他需要修改的字段 -->

        <div class="form-group">
            <?= Html::submitButton('保存修改', ['class' => 'btn btn-primary']) ?>
            <?= Html::a('返回列表', ['index'], ['class' => 'btn btn-default']) ?>
        </div>

        <?php ActiveForm::end(); ?>
    </div>
</div>

拓展：CREATE与DELETE操作的思路 #

• CREATE（sites_add）：和UPDATE逻辑类似，初始化Model时无需加载数据，POST请求时调用sites_add接口，将Model属性作为新增数据提交即可。
• DELETE（sites_delete）：在列表页添加删除按钮，点击后发送请求到sites_delete接口（可根据API要求用DELETE方法或POST传递primary_id），处理响应后刷新列表。

注意事项 #

• 需根据第三方API的实际要求调整请求方法（POST/PUT/DELETE）、数据格式和参数。
• 务必处理API请求失败的场景（如超时、错误响应码），给用户友好的提示。
• 若API需要身份认证（如Token），可通过->addHeaders(['Authorization' => 'Bearer ' . $token])添加认证头。

内容的提问来源于stack exchange，提问作者FrostyQueen