zhijiayun/app/Http/Controllers/Manager/Process/SubNotice.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\Process\SubNoticeJobs;
use App\Models\Manager\Process\ExecuteLog as ExecuteLogModel;
use App\Models\Manager\Process\SubNoticeLog as SubNoticeLogModel;
use Illuminate\Support\Carbon;
use Illuminate\Support\Facades\DB;
use App\Jobs\Manager\Process\SendNoticeJobs;

/**
 * 违规处理订阅推送
 * @author    唐远望
 * @version   1.0
 * @date      2026-03-30
 */
class SubNotice extends Controller
{
    /**
     * 执行通知推送任务
     * @author    唐远望
     * @version   1.0
     * @date      2025-12-11
     * 
     */
    public function push_notice(CompanyModel $CompanyModel, ExecuteLogModel $ExecuteLogModel, SubNoticeLogModel $SubNoticeLogModel)
    {
        $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
        $todayEnd = Carbon::today()->endOfDay()->getTimestamp(); // 今天结束时间 23:59:59
        //查询低价商品清洗清洗情况
        $action1 = $ExecuteLogModel->query()->where([['code', '=', 'LowPriceGoodsJobs'], ['status', '=', '0'], ['insert_time', '>=', $todayStart], ['insert_time', '<=', $todayEnd]])->count();
        if ($action1 < 1) return 1;
        //查询违规产品清洗清洗情况
        $action2 = $ExecuteLogModel->query()->where([['code', '=', 'ViolationProductJobs'], ['status', '=', '0'], ['insert_time', '>=', $todayStart], ['insert_time', '<=', $todayEnd]])->count();
        if ($action2 < 1) return 1;
        //查询违规门店清洗清洗情况
        $action3 = $ExecuteLogModel->query()->where([['code', '=', 'ViolationStoreJobs'], ['status', '=', '0'], ['insert_time', '>=', $todayStart], ['insert_time', '<=', $todayEnd]])->count();
        if ($action3 < 1) return 3;
        // 检查队列是否全部执行完毕
        $jobClasses = [
            'LowPriceGoodsDataJobs',
            'LowPriceGoodsJobs',
            'ViolationProductDataJobs',
            'ViolationProductJobs',
            'ViolationStoreDataJobs',
            'ViolationStoreJobs',
        ];
        $pendingJobs = DB::table('jobs')->where(function ($query) use ($jobClasses) {
            foreach ($jobClasses as $class) {
                $query->orWhere('payload', 'like', '%' . $class . '%');
            }
        })->count();
        if ($pendingJobs > 0) return 4;
        // 查询数据
        $result = $CompanyModel->query()->get()->toArray();
        // 分配数据
        if (!$result)  return 5;
        foreach ($result as $key => $item) {
            // 准备数据
            $message_data = ['company_id' => $item['id']];
            //执行发送通知任务
            // SendNoticeJobs::dispatch($message_data);
            SendNoticeJobs::dispatchSync($message_data);
            //如果今日存在通知推送记录，则跳过统计
            $sub_notice_count = $SubNoticeLogModel->query()->where([['company_id', '=', $item['id']],['insert_time', '>=', $todayStart], ['insert_time', '<=', $todayEnd]])->count();
            if ($sub_notice_count > 0) continue;
            
            // SubNoticeJobs::dispatch($message_data);
            // SubNoticeJobs::dispatchSync($message_data);
        }
        // 告知结果
        return 6;
    }
}