zhijiayun/app/Jobs/Manager/Process/ViolationProductDataJobs.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\Process\ViolationProduct as ViolationProductModel;
use App\Models\Manager\Personnel\Employee as EmployeeModel;
use App\Models\Api\Process\ExecuteLog as ExecuteLogModel;
use App\Models\Manager\Process\ScrapeData as ScrapeDataModel;

/**
 * 数据清洗-违规挂网商品数据队列
 * @author  唐远望
 * @version 1.0
 * @date  2025-12-10
 */
class ViolationProductDataJobs 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 {
            $this->getViolationProductData($this->message_data);
        } catch (\Exception $e) {
            Log::info('job_error', '数据清洗-违规挂网商品数据队列失败', ['data' => $this->message_data, 'error' => $e->getMessage()]);
        }
    }


    /**
     * 采集商品数据清洗
     * @author  唐远望
     * @version 1.0
     * @date  2025-12-10
     */
    public function getViolationProductData($message_data)
    {
        $EmployeeModel = new EmployeeModel();
        $ViolationProductModel = new ViolationProductModel();
        $ScrapeDataModel = new ScrapeDataModel();
        $platform = $message_data['platform'];//多个平台配置
        $product_name = $message_data['product_name'];//商品名称
        $product_specs = $message_data['product_specs'];//商品规格
        $store_scope = $message_data['store_scope']; //店铺范围1=全部店铺2=指定店铺
        $company_scope = $message_data['company_scope']; //公司范围1=全部公司2=指定公司
        $social_credit_code = $message_data['social_credit_code']; //社会信用代码
        $executeLog_id = $message_data['executeLog_id'];
        $limit = isset($message_data['limit']) ? $message_data['limit'] : 50;
        $page = isset($message_data['page']) ? $message_data['page'] : 1;

        $where = [];
        if ($platform != 'all') {
            $platform = explode(',', $platform);
            $ScrapeDataModel=$ScrapeDataModel->whereIn('platform', $platform);
        }
        $where[] = ['product_name', 'like', '%' . $product_name . '%'];
        $where[] = ['product_specs', 'like', '%' . $product_specs . '%'];
        if ($company_scope == 2) {
            $ScrapeDataModel->whereIn('qualification_number', $social_credit_code);
        }
        $product_data_info = $ScrapeDataModel->where($where)->paginate($limit, ['*'], 'page', $page)->toarray();
        $product_datas = $product_data_info['data'];
        if (empty($product_datas)) {
            if($executeLog_id){
                (new ExecuteLogModel())->where('id', $executeLog_id)->update(['status' => 0]);
            }
            return true;
        }
        foreach ($product_datas as $product_data) {
            $insert_product_data = [
                'source_id'=> $product_data['id'],
                'platform'    => $product_data['platform_id'],
                'company_name'    => $product_data['company_name'],
                'product_name'    => $product_name,
                'product_specs'    => $product_specs,
                'online_posting_cunt'    => $product_data['online_posting_cunt'],
                'link_url'    => $product_data['link_url'],
                'store_name'    => $product_data['store_name'],
            ];
            //查询配置的第一责任人
            $where_query1[] = ['city_ids', 'like', '%,' . $product_data['city_id'] . ',%'];
            $where_query1[] = ['status', '=', 0];
            $where_query1[] = ['duty_type', '=', 1]; //责任类型1=第一责任人，2=责任人
            $first_responsible_person = $EmployeeModel->where($where_query1)->pluck('id')->implode(',');
            $insert_product_data['first_responsible_person'] = $first_responsible_person;
            //查询配置的责任人
            $where_query2[] = ['city_ids', 'like', '%,' . $product_data['city_id'] . ',%'];
            $where_query2[] = ['status', '=', 0];
            $where_query2[] = ['duty_type', '=', 2]; //责任类型1=第一责任人，2=责任人
            $responsible_person = $EmployeeModel->where($where_query2)->pluck('id')->implode(',');
            $insert_product_data['responsible_person'] = $responsible_person;
            //溯源责任人
            $source_responsible_person = '';
            if ($first_responsible_person && $responsible_person) {
                $source_responsible_person = $first_responsible_person . ',' . $responsible_person;
            }
            $insert_product_data['source_responsible_person'] = $source_responsible_person;
            //插入数据
            $ViolationProductModel->addViolationProduct($insert_product_data);
        }
        //继续执行下一页
        $message_data['page'] = $page + 1;
        $message_data['limit'] = $limit;
        ViolationProductDataJobs::dispatch($message_data);
    }


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