zhijiayun/app/Http/Controllers/Manager/Statistics/ProductSurveillance.php

<?php

namespace App\Http\Controllers\Manager\Statistics;

use App\Http\Controllers\Controller;
use Illuminate\Http\Request;
use App\Jobs\Manager\CollectData\Statistics\ProductSurveillanceJobs;
use App\Models\Manager\External\Company as CompanyModel;
use Illuminate\Support\Carbon;

/**
 * 分析监控数据
 * @author 唐远望
 * @version   1.0
 * @date      2026-06-03
 * 
 */
class ProductSurveillance extends Controller
{
    /**
     * 执行数据推送
     * @author    唐远望
     * @version   1.0
     * @date      2026-06-03
     * 
     */
    public function push_data_notice()
    {
        // 验证参数
        $admin_company_id = request('admin_company_id', '');
        try {
            $start_time =  time() - 60 * 60; // 1小时前开始时间
            $end_time = time(); // 当前时间
            $CompanyModel = new CompanyModel();
            $map = [];
            if (is_numeric($admin_company_id)) $map[] = ['id', '=', $admin_company_id];
            $company_list = $CompanyModel->where($map)->select(['id','company_name','status'])->where('status', 0)->orderByDesc('cleaning_priority')->get()->toarray();
            foreach ($company_list as $company) {
                $message_data = ['company_id' => $company['id'],'company_info'=>$company, 'start_time' => $start_time, 'end_time' => $end_time];
                //执行商品数据-监控采集清洗情况
                // ProductSurveillanceJobs::dispatch($message_data);
                ProductSurveillanceJobs::dispatchSync($message_data);
            }
            return             json_send(['code' => 'success', 'msg' => '执行成功']);
        } catch (\Exception $e) {
            return             json_send(['code' => 'error', 'msg' => '执行失败', 'data' => $e->getMessage()]);
        }
    }
}