Statamic CMS中API数据与蓝图验证的程序化处理策略

<?php

namespace App\Listeners;

use GuzzleHttp\Client;
use GuzzleHttp\Exception\GuzzleException;
use Illuminate\Support\Facades\Http;
use Illuminate\Support\Facades\Validator; // 引入 Laravel Validator
use Statamic\Eloquent\Entries\EntryModel;
use Statamic\Events\EntrySaved;
use Statamic\Facades\Entry;
use Statamic\Facades\Blueprint; // 可能需要引入 Blueprint 门面

class UpdateCompanyDetailsFromApi
{
    public function handle(EntrySaved $event): void
    {
        $entry = $event->entry; // 使用 Statamic Entry 对象
        $entryModel = $entry->model(); // 获取底层 Eloquent 模型

        // 仅处理 'companies' 集合的 Entry
        if ($entry->collectionHandle() !== 'companies') {
            return;
        }

        $data = collect($entry->data()->all()); // 获取当前 Entry 的所有数据

        // 检查是否存在 ticker ID
        if (!isset($data['tickers'][0])) {
            return;
        }
        $tickerId = $data['tickers'][0];

        // 查找关联的 ticker Entry
        $ticker = EntryModel::find($tickerId);
        if (!$ticker || !$ticker->title) {
            return;
        }
        $tickerTitle = $ticker->title;

        try {
            // 模拟 API 调用
            $response = Http::get('https://api.example.com/company-info/' . $tickerTitle);

            if ($response->failed()) {
                \Log::error("API call failed for ticker '{$tickerTitle}': " . $response->body());
                return;
            }

            $apiItems = $response->json('results.0'); // 假设 API 返回结构
            if (!$apiItems) {
                \Log::warning("No data found in API response for ticker '{$tickerTitle}'");
                return;
            }

            // 调整 API 数据以匹配蓝图字段，例如 companyName 映射
            $apiItems['company_name'] = $apiItems['exchangeName'] ?? null; // 假设蓝图字段是 company_name
            unset($apiItems['exchangeName']); // 移除原始字段

            // 合并 API 数据到 Entry 数据中
            $mergedData = $data->merge($apiItems)->all();

            // 获取当前 Entry 的蓝图
            $blueprint = $entry->blueprint();

            // 获取蓝图的验证规则
            // Entry::updateRules 提供了获取 Entry 更新规则的便捷方式
            // 它会考虑到蓝图、集合、站点等上下文
            $rules = Entry::updateRules($entry->collection(), $entry->site());

            // 准备验证器所需的替换参数，用于错误消息中的属性名称
            $replacements = [
                'id' => $entry->id(),
                'collection' => $entry->collectionHandle(),
                'site' => $entry->site()->handle(),
            ];

            // 使用 Laravel 的 Validator 门面进行手动验证
            $validator = Validator::make($mergedData, $rules, [], $replacements);

            if ($validator->fails()) {
                // 处理验证失败的情况
                $errors = $validator->errors()->all();
                \Log::error("Validation failed for Statamic entry '{$entry->id()}' after API merge: " . implode(', ', $errors));

                // 可以选择抛出异常、记录日志或阻止保存
                // throw new \Illuminate\Validation\ValidationException($validator);
                return; // 阻止保存不符合验证规则的数据
            }

            // 如果验证通过，更新 Entry 数据并静默保存
            $entry->data($mergedData);
            $entry->saveQuietly();

        } catch (GuzzleException $e) {
            \Log::error("Guzzle HTTP client error during API call for ticker '{$tickerTitle}': " . $e->getMessage());
        } catch (\Exception $e) {
            \Log::error("An unexpected error occurred during company details update for '{$tickerTitle}': " . $e->getMessage());
        }
    }
}