zhijiayun/app/Jobs/Manager/CollectData/Ysbang/YsbangProductDataJobs.php

<?php

namespace App\Jobs\Manager\CollectData\Ysbang;

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\Collect\ScrapeTmpData as ScrapeTmpDataModel; //临时采集数据表
use App\Models\Manager\Collect\ScrapeData as ScrapeDataModel; //采集数据表
use Illuminate\Support\Facades\Cache;
use App\Models\Manager\CollectData\Ysbang\Store as YsbangStoreModel;
use App\Models\Manager\Citys as CitysModel;
use App\Jobs\Manager\CollectData\Ysbang\YsbangProductJobs;

/**
 * 采集数据-药师帮数据处理
 * @author  唐远望
 * @version 1.0
 * @date  2026-02-05
 */
class YsbangProductDataJobs 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 {
            $CitysModel = new CitysModel();
            $YsbangStoreModel = new YsbangStoreModel();
            $city_id_data = $CitysModel->get_city_id_list();
            $province_id_list = $CitysModel->get_province_id_list();
            $item = $this->message_data;
            $provider_id = $item['provider_id'];
            $store_data = Cache::get('admin:store_data_log:' . $provider_id);
            if (!$store_data) {
                $store_data = $YsbangStoreModel->where(['id' => $provider_id])->first(['id', 'name', 'company_id', 'company_name', 'province_name', 'city_name', 'addr', 'unified_code']);
                if (!$store_data) return true;
                $store_data = $store_data->toarray();
                Cache::put('YsbangStoreJobs:store_data_log:' . $provider_id, $store_data, 300);
            }
            $province_name = $store_data['province_name'];
            if ($province_name && in_array($province_name, ['北京市', '天津市', '上海市', '重庆市'])) {
                //移除市这个字符
                $province_name = trim(str_replace('市', '', $province_name));
            }

            $ScrapeDataModel = new ScrapeDataModel();
            $where_data = [
                'platform_id' => '5', //平台0=全部，1=淘宝，2=京东，3=拼多多，4=美团，5=药师帮，6=1药城，7=药久久
                'province_id' => isset($province_id_list[$province_name]) ? $province_id_list[$province_name]['id'] : 0, //省份id
                'city_id' => isset($city_id_data[$store_data['city_name']]) ? $city_id_data[$store_data['city_name']]['id'] : 0, //城市id
                'province_name' => isset($store_data['province_name']) ? $store_data['province_name'] : '', //省份名称
                'city_name' => isset($store_data['city_name']) ? $store_data['city_name'] : '', //城市名称
                'area_info' => isset($store_data['addr']) ? $store_data['addr'] : '', //区县信息
                'product_name' =>  $item['drugname'], //产品名称
                'product_specs' => $item['specification'], //产品规格
                'online_posting_count' => '1', //在线上架数量
                'continuous_listing_count' => '1', //持续上架数量
                'link_url' => $item['url'], //链接地址
                'store_name' => $item['provider_name'], //店铺名称
                'company_name' => $item['manufacturer'], //公司名称
                'qualification_number' => isset($store_data['unified_code']) ? $store_data['unified_code'] : '', //营业执照号码
                'scrape_date' => date('Y-m-d H:i:s', $item['real_crawler_time']), //采集日期
                'number' => '1', //盒数
            ];
            //校验$where_data 数据下是否存在空值的情况，如果存在跳过写入
            foreach ($where_data as $key => $value) {
                //如果字段名称不在范围内，才去校验值是否为空
                if (!in_array($key, ['qualification_number']) && empty($value)) {
                    return true;
                }
            }
            //查询是否存在记录
            $ScrapeTmpData = $ScrapeDataModel->where($where_data)->first();
            if (empty($ScrapeTmpData)) {
                $insert_data = [
                    'platform_id' => '5', //平台0=全部，1=淘宝，2=京东，3=拼多多，4=美团，5=药师帮，6=1药城，7=药久久
                    'province_id' => isset($province_id_list[$province_name]) ? $province_id_list[$province_name]['id'] : 0, //省份id
                    'city_id' => isset($city_id_data[$store_data['city_name']]) ? $city_id_data[$store_data['city_name']]['id'] : 0, //城市id
                    'province_name' => isset($store_data['province_name']) ? $store_data['province_name'] : '', //省份名称
                    'city_name' => isset($store_data['city_name']) ? $store_data['city_name'] : '', //城市名称
                    'area_info' => isset($store_data['addr']) ? $store_data['addr'] : '', //区县信息
                    'product_name' =>  $item['drugname'], //产品名称
                    'product_specs' => $item['specification'], //产品规格
                    'one_box_price' => round($item['minPrice'] / 100, 2), //一箱价格
                    'online_posting_count' => '1', //在线上架数量
                    'continuous_listing_count' => '1', //持续上架数量
                    'link_url' => $item['url'], //链接地址
                    'store_name' => $item['provider_name'], //店铺名称
                    'company_name' => $item['manufacturer'], //公司名称
                    'qualification_number' => isset($store_data['unified_code']) ? $store_data['unified_code'] : '', //营业执照号码
                    'scrape_date' => date('Y-m-d H:i:s', $item['real_crawler_time']), //采集日期
                    'min_price' => round($item['minPrice'] / 100, 2), //最低价格
                    'number' => '1', //盒数
                    'insert_time' => date('Y-m-d H:i:s', time()),
                ];
                $ScrapeDataModel->insert($insert_data);
            } else {
                //如果存在且价格低于采集价格，则更新价格
                if ($ScrapeTmpData->min_price > $item['minPrice']) {
                    $ScrapeTmpData->min_price = $item['minPrice'];
                    $ScrapeTmpData->one_box_price = $item['minPrice'];
                    $ScrapeTmpData->save();
                }
            }
            $queue_page =  $item['queue_page']; //页码
            $queue_now_limit =  $item['queue_now_limit']; //当前处理条数
            $queue_limit =  $item['queue_limit']; //每页处理条数
            $queue_total =  $item['queue_total']; //总条数
            if ($queue_now_limit == $queue_limit) {
                // //继续执行下一页
                $message_data['page'] = (int)$queue_page + 1;
                $message_data['limit'] = $queue_limit;
                $message_data['total'] = $queue_total;
                YsbangProductJobs::dispatch($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]);
    }
}