Statamic API 数据集成与程序化验证策略

<?php

namespace App\Listeners;

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\Collection; // 引入 Collection 门面

class SyncCompanyData
{
    public function handle(EntrySaved $event): void
    {
        $entry = $event->entry;
        // 确保只处理 'companies' 集合的条目
        if ($entry->collectionHandle() !== 'companies') {
            return;
        }

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

        // 检查是否有 'tickers' 字段并获取其ID
        if (!isset($data['tickers'][0])) {
            return;
        }
        $tickerId = $data['tickers'][0];

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

        try {
            // 假设从外部API获取数据
            $response = Http::get('https://api.example.com/company-details/' . $tickerTitle); // 使用 tickerTitle 构建 API URL
            $apiItems = $response->json('results.0');

            if (!$apiItems) {
                // 处理API响应为空的情况
                return;
            }

            // 对API数据进行必要的转换或映射
            $apiItems['companyName'] = $apiItems['exchangeName'] ?? null; // 示例映射
            // 移除可能与现有字段冲突或不需要的API字段
            unset($apiItems['exchangeName']);

            // 合并API数据到现有条目数据
            // 注意：这里需要确保 $data 包含所有需要验证的字段
            $mergedData = $data->merge($apiItems)->all();

            // 获取 Statamic 蓝图定义的验证规则
            $collection = Collection::find($entry->collectionHandle());
            $site = $entry->site();
            // Entry::updateRules 提供了当前集合和站点下的所有字段规则
            $rules = Entry::updateRules($collection, $site);

            // 移除不需要验证的字段的规则，或者只验证合并后的数据中存在的字段
            // 例如，如果 'slug' 和 'date' 是由Statamic自动处理的，可能不需要手动验证
            unset($rules['slug'], $rules['date']);

            // 准备验证器所需的替换参数（例如，用于唯一性规则）
            $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("Statamic Entry validation failed for entry ID: {$entry->id()}", [
                    'errors' => $errors,
                    'data' => $mergedData,
                ]);

                // 如果希望阻止条目保存并显示错误，可以抛出异常
                // throw new \Illuminate\Validation\ValidationException($validator);
                // 或者直接返回，不保存不符合验证的数据
                return;
            }

            // 验证通过，更新条目数据
            // 注意：这里需要将合并后的数据传递给 entry->data()
            $entry->data($mergedData);
            $entry->saveQuietly(); // 使用 saveQuietly 避免再次触发此事件，造成死循环

        } catch (\GuzzleHttp\Exception\GuzzleException $e) {
            \Log::error("API call failed for ticker: {$tickerTitle}", ['error' => $e->getMessage()]);
            // 处理API调用失败的情况
        } catch (\Exception $e) {
            \Log::error("Error processing company data for entry ID: {$entry->id()}", ['error' => $e->getMessage()]);
            // 处理其他潜在错误
        }
    }
}