Statamic CMS中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\Blueprint; // 用于获取蓝图规则

class ProcessCompanyApiData
{
    public function handle(EntrySaved $event): void
    {
        $entry = $event->entry;
        $entryModel = $entry->model();

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

        $data = collect($entry->data());

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

        $ticker = EntryModel::find($tickerId);
        if (!$ticker || !$ticker->title) {
            return;
        }
        $tickerTitle = $ticker->title;

        // 假设这里是你的API调用
        $response = Http::get('https://apicallurlexample.com/data?ticker=' . urlencode($tickerTitle));

        if (!$response->successful()) {
            // 处理API调用失败的情况，例如记录日志或抛出异常
            \Log::error("API call failed for ticker: {$tickerTitle}", ['response' => $response->body()]);
            return;
        }

        $items = $response->json('results.0');

        if (!$items) {
            \Log::warning("No results found for ticker: {$tickerTitle}");
            return;
        }

        // 映射和准备数据
        $items['companyName'] = $items['exchangeName'] ?? null; // 假设API返回exchangeName作为companyName
        // ... 其他数据映射

        // --- 核心：手动验证API数据 ---
        // 从Statamic蓝图获取验证规则（或者自定义一套）
        $blueprint = Blueprint::find('companies'); // 替换为你的蓝图名称
        $rules = [];
        if ($blueprint) {
            foreach ($blueprint->fields()->all() as $field) {
                // 排除Statamic内部字段，并获取自定义字段的规则
                if (!in_array($field->handle(), ['id', 'slug', 'date', 'collection', 'site'])) {
                    $fieldRules = $field->config('validate'); // 获取蓝图中定义的验证规则
                    if ($fieldRules) {
                        $rules[$field->handle()] = is_array($fieldRules) ? $fieldRules : explode('|', $fieldRules);
                    }
                }
            }
        }

        // 可以在这里添加或覆盖自定义规则，例如：
        $customRules = [
            'companyName' => ['required', 'string', 'max:255'],
            'image' => ['nullable', 'url', 'max:2048'], // 假设API返回图片URL
            // 'image_dimensions' => ['dimensions:max_width=1920,max_height=1080'], // 对于图片尺寸，可能需要下载后处理
        ];
        $rules = array_merge($rules, $customRules);

        // 使用Laravel Validator进行验证
        $validator = Validator::make($items, $rules);

        if ($validator->fails()) {
            // 验证失败，处理错误
            $errors = $validator->errors()->all();
            \Log::error("API data validation failed for ticker: {$tickerTitle}", [
                'data' => $items,
                'errors' => $errors
            ]);
            // 可以选择抛出异常、阻止保存或返回错误信息
            // throw new \Exception("API data validation failed: " . implode(', ', $errors));
            return; // 阻止不符合验证规则的数据保存
        }
        // --- 验证结束 ---

        // 合并数据
        $mergedData = $data->merge($items);
        $mergedData['slug'] = $entry->slug();
        $mergedData['date'] = $entry->date()->format('Y-m-d'); // 确保日期格式正确

        // 更新条目数据并静默保存
        $event->entry->data($mergedData->all());
        $event->entry->saveQuietly(); // 使用 saveQuietly 避免再次触发此事件循环
    }
}