zhijiayun/app/Jobs/Manager/Process/ViolationProductJobs.php

<?php

namespace App\Jobs\Manager\Process;

use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldBeUnique;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;
use App\Facades\Servers\Logs\Log;
use App\Models\Manager\WashConfig\ViolationProduct as ConfigViolationProductModel;
use App\Models\Api\Process\ExecuteLog as ExecuteLogModel;
use App\Jobs\Manager\Process\ViolationProductDataJobs;

/**
 * 数据清洗-违规挂网商品队列
 * @author  唐远望
 * @version 1.0
 * @date  2025-12-09
 */
class ViolationProductJobs implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
    protected $message_data;
    /**
     * Create a new job instance.
     *
     * @return void
     */
    public function __construct(array $message_data)
    {
        $this->message_data = $message_data;
    }

    /**
     * Execute the job.
     *
     * @return void
     */
    public function handle()
    {
        try {
            $ConfigViolationProductModel = new ConfigViolationProductModel();
            $limit = isset($this->message_data['limit']) ? $this->message_data['limit'] : 50;
            $page = isset($this->message_data['page']) ? $this->message_data['page'] : 1;
            $executeLog_id = isset($this->message_data['executeLog_id']) ? $this->message_data['executeLog_id'] : 0;
            if($page == 1){
                $ExecuteLogModel = new ExecuteLogModel();
                $insert_data =['name' =>'违规挂网商品', 'code' => 'ViolationProductJobs'];
                $executeLog_id=$ExecuteLogModel->addExecuteLog_content($insert_data);
            }
            $list_data = $ConfigViolationProductModel->where('status', 1)->paginate($limit, ['*'], 'page', $page)->get()->toarray();
            if (empty($list_data)) {
                return true;
            }
            foreach ($list_data as $key => $value) {
                $message_data = [
                    'platform' => $value['platform'],
                    'product_name' => $value['product_name'],
                    'product_specs' => $value['product_specs'],
                    'store_scope' => $value['store_scope'],
                    'executeLog_id' => $executeLog_id,
                ];
                ViolationProductDataJobs::dispatch($message_data);
            }
            $now_message_data = [
                'limit' => $limit,
                'page' => $page + 1,
                'executeLog_id' => $executeLog_id,
            ];
            ViolationProductJobs::dispatch($now_message_data);
        } catch (\Exception $e) {
            Log::info('job_error', '数据清洗-违规挂网商品队列失败', ['data' => $this->message_data, 'error' => $e->getMessage()]);
        }
    }


    public function failed(\Throwable $exception)
    {
        Log::info('job_error', '数据清洗-违规挂网商品队列完全失败', ['data' => $this->message_data, 'error' => $exception]);
    }
}