Laravel 9 中实现定时任务调用业务逻辑的正确实践-php教程-PHP中文网

Laravel 9 中实现定时任务调用业务逻辑的正确实践

在 laravel 9 中，不应直接通过调度器调用控制器方法；而应将核心业务逻辑抽离至可复用的服务类，再由控制器和任务调度器分别调用，确保职责分离、可测试性与可维护性。

在 laravel 9 中，不应直接通过调度器调用控制器方法；而应将核心业务逻辑抽离至可复用的服务类，再由控制器和任务调度器分别调用，确保职责分离、可测试性与可维护性。

在 Laravel 应用中，控制器（Controller）的核心职责是处理 HTTP 请求与响应，不应当承载数据同步、批量处理等后台业务逻辑。你当前的 oracle() 方法虽能手动触发，但若直接塞入 schedule->call() 匿名函数中，不仅违反单一职责原则，还会导致代码重复、难以单元测试，且无法利用 Laravel 的依赖注入、队列、日志等基础设施。

✅ 正确做法：引入 Service Layer（服务层）

创建服务类
运行命令生成服务类（例如位于 app/Services 目录）：

php artisan make:class Services/OracleSyncService

实现核心逻辑
将原控制器中的数据库操作迁移至服务类，并支持按需处理单条或批量记录：

<?php // app/Services/OracleSyncService.php

namespace App\Services;

use App\Models\Order;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Log;

class OracleSyncService
{
    public function syncOrdersWithStatusZero(): int
    {
        $count = 0;
        // 查询所有 status = 0 的订单（建议分页或 chunk 避免内存溢出）
        Order::where('status', 0)->chunk(100, function ($orders) use (&$count) {
            foreach ($orders as $order) {
                try {
                    // ✅ 此处复用你原有的 Oracle 数据插入逻辑
                    $this->syncSingleOrder($order);
                    $count++;
                } catch (\Exception $e) {
                    Log::error("Failed to sync order {$order->id}: " . $e->getMessage());
                    // 可选：标记失败、重试或跳过
                }
            }
        });

        return $count;
    }

    private function syncSingleOrder(Order $order): void
    {
        // 示例：从 MySQL 读取数据 → 写入 Oracle（使用 DB::connection('oracle')）
        $data = [
            'order_id' => $order->id,
            'amount'   => $order->amount,
            'created_at' => $order->created_at,
        ];

        DB::connection('oracle')->table('orders')->insert($data);

        // ✅ 同步成功后更新 MySQL 状态
        $order->update(['status' => 1]);
    }
}

在控制器中调用服务
保持控制器轻量、专注请求响应：

// app/Http/Controllers/OrderController.php
public function oracle(Request $request)
{
    $service = app(OracleSyncService::class);
    $synced = $service->syncOrdersWithStatusZero();

    return response()->json([
        'message' => "Sync completed: {$synced} orders processed.",
    ]);
}

在任务调度器中调用服务
编辑 app/Console/Kernel.php，在 schedule() 方法中注册定时任务：

// app/Console/Kernel.php
protected function schedule(Schedule $schedule)
{
    // 每 10 分钟执行一次（注意：Laravel scheduler 本身需由系统 cron 每分钟触发一次）
    $schedule->call(function () {
        $service = app(OracleSyncService::class);
        $count = $service->syncOrdersWithStatusZero();
        \Log::info("Oracle sync scheduled: {$count} orders updated.");
    })->everyTenMinutes();
}

⚠️ 注意事项：

Laravel Cloud

Laravel Cloud（cloud.laravel.com）。此技能用于处理所有 Laravel Cloud 请求，包括搜索和读取数据。只要任务涉及 Laravel Cloud，即使用此技能。

下载

确保系统级 Cron 已配置：* * * * * cd /path-to-your-project && php artisan schedule:run >> /dev/null 2>&1
若订单量大，务必使用 chunk() 或 cursorPaginate() 防止内存爆炸；
考虑将耗时操作推入队列（如 dispatch(new SyncToOracleJob($order))），避免调度任务超时；
在服务类中统一处理异常、日志与事务（如需强一致性，可用 DB::transaction() 包裹读写）；
数据库连接需在 config/database.php 中正确定义 oracle 连接（推荐使用 Oracle 官方驱动或 yajra/laravel-oci8）。