zhijiayun/app/Http/Controllers/Manager/CollectSync/Product.php

<?php

namespace App\Http\Controllers\Manager\CollectSync;

use App\Http\Controllers\Controller;
use App\Http\Requests\Manager\CollectSync\Product as Request;
use App\Jobs\Manager\CollectData\Ysbang\YsbangProductJobs;
use App\Jobs\Manager\CollectData\Yycheng\YychengProductJobs;
use App\Jobs\Manager\CollectData\JdTmao\JdTmaoProductJobs;

/**
 * 采集数据同步
 * @author    唐远望
 * @version   1.0
 * @date      2026-02-05
 */
class Product extends Controller
{

    /**
     * 执行药师帮采集数据同步
     * @author    唐远望
     * @version   1.0
     * @date      2026-02-05
     */
    public function data_ysbang_sync(Request $request)
    {
        // 验证参数
        $request->scene('data_cleadata_ysbang_syncning')->validate();
        $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
        $admin_id   = request('access_token.uid', 0); //用户ID
        $message_data = ['page' => 1, 'limit' => 1000, 'admin_id' => $admin_id, 'is_admin' => $is_admin];
        YsbangProductJobs::dispatch($message_data);
        // YsbangProductJobs::dispatchSync($message_data);
        // 告知结果
        return             json_send(['code' => 'success', 'msg' => '执行成功']);
    }

    /**
     * 执行医药城采集数据同步
     * @author    唐远望
     * @version   1.0
     * @date      2026-02-05
     */
    public function data_yycheng_sync(Request $request)
    {
        // 验证参数
        $request->scene('data_yycheng_sync_syncning')->validate();
        $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
        $admin_id   = request('access_token.uid', 0); //用户ID
        $message_data = ['page' => 1, 'limit' => 1000, 'admin_id' => $admin_id, 'is_admin' => $is_admin];
        YychengProductJobs::dispatch($message_data);
        // YychengProductJobs::dispatchSync($message_data);
        // 告知结果
        return             json_send(['code' => 'success', 'msg' => '执行成功']);
    }

    /**
     * 执行京东天猫采集数据同步
     * @author    唐远望
     * @version   1.0
     * @date      2026-02-09
     */
    public function data_jd_tmall_sync(Request $request)
    {
        // 验证参数
        $request->scene('data_jd_tmall_sync_syncning')->validate();
        $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
        $admin_id   = request('access_token.uid', 0); //用户ID
        $message_data = ['page' => 1, 'limit' => 10, 'admin_id' => $admin_id, 'is_admin' => $is_admin];
        JdTmaoProductJobs::dispatch($message_data);
        // JdTmaoProductJobs::dispatchSync($message_data);
        // 告知结果
        return             json_send(['code' => 'success', 'msg' => '执行成功']);
    }
}