zhijiayun/app/Http/Controllers/Manager/Process/CollectData.php

<?php

namespace App\Http\Controllers\Manager\Process;

use App\Http\Controllers\Controller;
use App\Models\Manager\External\Company as CompanyModel;
use App\Jobs\Manager\CollectData\Backfill\LowPriceProductJobs;
use App\Jobs\Manager\CollectData\Backfill\ViolationProductJobs;
use App\Jobs\Manager\CollectData\Backfill\ViolationStoreJobs;
use App\Jobs\Manager\CollectData\Backfill\LowPriceOnlineStatisticsjobs;
use App\Jobs\Manager\CollectData\Backfill\ViolationProductOnlineStatisticsjobs;

/**
 * 清洗后的数据处理
 * @author    唐远望
 * @version   1.0
 * @date      2026-04-29
 */
class CollectData extends Controller
{


    /**
     * 低价商品数据数据清洗-回填责任人
     * @author: 唐远望
     * @version: 1.0
     * @date: 2026-05-22
     */
    public function low_price_product_collect_data()
    {
        try {
            $CompanyModel = new CompanyModel();
            $company_list = $CompanyModel->select(['id', 'status'])->where('id', '5')->where('status', 0)->orderByDesc('cleaning_priority')->get()->toarray();
            foreach ($company_list as $company) {
                $message_data = ['company_id' => $company['id'], 'page' => '1', 'limit' => '50'];
                LowPriceProductJobs::dispatch($message_data);
            }
            return   json_send(['code' => 'success', 'msg' => '执行成功', 'data' => '']);
        } catch (\Exception $e) {
            return   json_send(['code' => 'error', 'msg' => '执行失败', 'data' => $e->getMessage()]);
        }
    }

    /**
     * 商品数据数据清洗-更新累计挂网&连续挂网
     * @author: 唐远望
    
     * @version: 1.0
     * @date: 2026-05-29
     */
    public function update_collect_data()
    {
        try {
            $CompanyModel = new CompanyModel();
            $company_list = $CompanyModel->select(['id', 'status'])->where([['id','!=','5']])->where('status', 0)->orderByDesc('cleaning_priority')->get()->toarray();
            foreach ($company_list as $company) {
                $message_data = ['company_id' => $company['id'], 'page' => '2', 'limit' => '10'];
                LowPriceOnlineStatisticsjobs::dispatch($message_data);
                // LowPriceOnlineStatisticsjobs::dispatchSync($message_data);
                ViolationProductOnlineStatisticsjobs::dispatch($message_data);
                // ViolationProductOnlineStatisticsjobs::dispatchSync($message_data);
            }
            return   json_send(['code' => 'success', 'msg' => '执行成功', 'data' => '']);
        } catch (\Exception $e) {
            return   json_send(['code' => 'error', 'msg' => '执行失败', 'data' => $e->getMessage()]);
        }
    }



    /**
     * 禁止商品清洗数据回填-回填责任人
     * @author: 唐远望
     * @version: 1.0
     * @date: 2026-05-22
     */
    public function violation_product_collect_data()
    {
        try {
            $CompanyModel = new CompanyModel();
            $company_list = $CompanyModel->select(['id', 'status'])->where('status', 0)->orderByDesc('cleaning_priority')->get()->toarray();
            foreach ($company_list as $company) {
                $message_data = ['company_id' => $company['id'], 'page' => '1', 'limit' => '10'];
                ViolationProductJobs::dispatch($message_data);
            }
            return   json_send(['code' => 'success', 'msg' => '执行成功', 'data' => '']);
        } catch (\Exception $e) {
            return   json_send(['code' => 'error', 'msg' => '执行失败', 'data' => $e->getMessage()]);
        }
    }




    /**
     * 违规店铺清洗数据回填-回填责任人
     * @author: 唐远望
     * @version: 1.0
     * @date: 2026-05-22
     */
    public function violation_store_collect_data()
    {
        try {
            $CompanyModel = new CompanyModel();
            $company_list = $CompanyModel->select(['id', 'status'])->where('status', 0)->orderByDesc('cleaning_priority')->get()->toarray();
            foreach ($company_list as $company) {
                $message_data = ['company_id' => $company['id'], 'page' => '1', 'limit' => '10'];
                ViolationStoreJobs::dispatch($message_data);
            }
            return   json_send(['code' => 'success', 'msg' => '执行成功', 'data' => '']);
        } catch (\Exception $e) {
            return   json_send(['code' => 'error', 'msg' => '执行失败', 'data' => $e->getMessage()]);
        }
    }
}