zhijiayun/app/Jobs/Manager/Process/SubNoticeJobs.php

<?php

namespace App\Jobs\Manager\Process;

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\Process\LowPriceGoodsMember as LowPriceGoodsMemberModel;
use App\Models\Manager\Process\LowPriceGoods as LowPriceGoodsModel;
use App\Models\Manager\Process\ViolationProductMember as ViolationProductMemberModel;
use App\Models\Manager\Process\ViolationProduct as ViolationProductModel;
use App\Models\Manager\Process\ViolationStore as ViolationStoreModel;
use App\Models\Manager\Process\ViolationStoreMember as ViolationStoreMemberModel;
use Illuminate\Support\Carbon;
use App\Facades\Servers\Sms\VerifyCode as Sms;
use App\Servers\Email\VerifyCode as EmailVerifyCode;


/**
 * 订阅通知
 * @author  唐远望
 * @version 1.0
 * @date  2026-03-30
 */
class SubNoticeJobs implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
    protected $message_data;
    protected $user_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 {
            $EmailVerifyCode = new EmailVerifyCode();
            $sms_tpl_id =  config('verifycode.aliyun_process_lowprice_product.sms_tpl');
            $company_id = $this->message_data['company_id'];
            $action_one = $this->send_low_price_goods_notice($company_id);
            $action_two = $this->send_violation_product($company_id);
            $action_three = $this->send_violation_store($company_id);
            if ($action_one && $action_two && $action_three) {
                foreach ($this->user_data as $key => $value) {
                    $mobile = $value['mobile'];
                    $email_to = $value['email'];
                    $number1 = count($this->user_data[$key]['lowprice_product_logids']);
                    $number2 = count($this->user_data[$key]['violation_product_logids']);
                    $number3 = count($this->user_data[$key]['violation_store_logids']);
                    Sms::sendContent($mobile, ['number1' => $number1, 'number2' => $number2, 'number3' => $number3], $sms_tpl_id);
                    $email_title = '智价云违规数据通知提醒';
                    $email_content = "智价云提醒、本次低价挂网商品共" . $number1 . "条、禁止挂网商品共" . $number2 . "条、禁止挂网店铺共" . $number3 . "条";
                    $EmailVerifyCode->sendSmtpEmail($email_to, $email_title, $email_content);
                }
            }
        } catch (\Exception $e) {
            Log::info('job_error', '订阅短信通知推送队列失败', ['data' => $this->message_data, 'error' => $e->getMessage()]);
        }
    }

    /**
     * 短信消息消息订阅推送(低价挂网)
     * @author  唐远望
     * @version 1.0
     * @date  2026-03-04
     */
    private function send_low_price_goods_notice($company_id)
    {
        $LowPriceGoodsMemberModel = new LowPriceGoodsMemberModel();
        $LowPriceGoodsModel = new LowPriceGoodsModel();
        //获取今日待处理的商品记录
        $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
        $todayEnd = Carbon::today()->endOfDay()->getTimestamp(); // 今天结束时间 23:59:59
        $lowprice_ids = $LowPriceGoodsModel->where([['insert_time', '>=', $todayStart], ['insert_time', '<=', $todayEnd], ['company_id', '=', $company_id]])->pluck('id')->toArray();
        if (empty($lowprice_ids)) return true;
        //获取开启了通知服务的用户
        $usert_list = $LowPriceGoodsMemberModel
            ->whereIn('lowprice_product_logid', $lowprice_ids)
            ->join('personnel_employee', 'process_lowprice_product_member.employee_id', '=', 'personnel_employee.id')
            ->where('personnel_employee.open_notice', 0)
            ->where('personnel_employee.company_id', $company_id)
            ->where([['personnel_employee.mobile', '!=', ''], ['personnel_employee.mobile', '!=', null]])
            ->select(['process_lowprice_product_member.*', 'personnel_employee.mobile'])
            ->get()->toArray();
        if (empty($usert_list)) return true;
        //按用户统计待处理的商品数量
        foreach ($usert_list as $key => $value) {
            $user_id = $value['employee_id'];
            if (!isset($user_data[$user_id])) {
                $this->user_data[$user_id]['employee_id'] = $user_id;
                $this->user_data[$user_id]['mobile'] = $value['mobile'];
                $this->user_data[$user_id]['lowprice_product_logids'][] = $value['lowprice_product_logid'];
            } else {
                $this->user_data[$user_id]['lowprice_product_logids'][] = $value['lowprice_product_logid'];
            }
        }
        return true;
    }

    /**
     * 短信消息消息订阅推送(禁止挂网)
     * @author  唐远望
     * @version 1.0
     * @date  2026-03-04
     */
    private function send_violation_product($company_id)
    {
        $ViolationProductMemberModel = new ViolationProductMemberModel();
        $ViolationProductModel = new ViolationProductModel();
        //获取今日待处理的商品记录
        $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
        $todayEnd = Carbon::today()->endOfDay()->getTimestamp(); // 今天结束时间 23:59:59
        $violation_price_ids = $ViolationProductModel->where([['insert_time', '>=', $todayStart], ['insert_time', '<=', $todayEnd], ['company_id', '=', $company_id]])->pluck('id')->toArray();
        if (empty($violation_price_ids)) return true;
        //获取开启了通知服务的用户
        $usert_list = $ViolationProductMemberModel
            ->whereIn('violation_product_logid', $violation_price_ids)
            ->join('personnel_employee', 'process_violation_product_member.employee_id', '=', 'personnel_employee.id')
            ->where('personnel_employee.open_notice', 0)
            ->where('personnel_employee.company_id', $company_id)
            ->where([['personnel_employee.mobile', '!=', ''], ['personnel_employee.mobile', '!=', null]])
            ->select(['process_violation_product_member.*', 'personnel_employee.mobile'])
            ->get()->toArray();
        if (empty($usert_list)) return true;
        //按用户统计待处理的商品数量
        foreach ($usert_list as $key => $value) {
            $user_id = $value['employee_id'];
            if (!isset($user_data[$user_id])) {
                $this->user_data[$user_id]['employee_id'] = $user_id;
                $this->user_data[$user_id]['mobile'] = $value['mobile'];
                $this->user_data[$user_id]['violation_product_logids'][] = $value['violation_product_logid'];
            } else {
                $this->user_data[$user_id]['violation_product_logids'][] = $value['violation_product_logid'];
            }
        }
        return true;
    }

    /**
     * 短信消息消息订阅推送(禁止店铺)
     * @author  唐远望
     * @version 1.0
     * @date  2026-03-04
     */
    private function send_violation_store($company_id)
    {
        $ViolationStoreMemberModel = new ViolationStoreMemberModel();
        $ViolationStoreModel = new ViolationStoreModel();
        //获取今日待处理的店铺记录
        $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
        $todayEnd = Carbon::today()->endOfDay()->getTimestamp(); // 今天结束时间 23:59:59
        $violation_price_ids = $ViolationStoreModel->where([['insert_time', '>=', $todayStart], ['insert_time', '<=', $todayEnd], ['company_id', '=', $company_id]])->pluck('id')->toArray();
        if (empty($violation_price_ids)) return true;
        //获取开启了通知服务的用户
        $usert_list = $ViolationStoreMemberModel
            ->whereIn('violation_store_logid', $violation_price_ids)
            ->join('personnel_employee', 'process_violation_store_member.employee_id', '=', 'personnel_employee.id')
            ->where('personnel_employee.open_notice', 0)
            ->where('personnel_employee.company_id', $company_id)
            ->where([['personnel_employee.mobile', '!=', ''], ['personnel_employee.mobile', '!=', null]])
            ->select(['process_violation_store_member.*', 'personnel_employee.mobile'])
            ->get()->toArray();
        if (empty($usert_list)) return true;
        //按用户统计待处理的商品数量
        $user_data = [];
        foreach ($usert_list as $key => $value) {
            $user_id = $value['employee_id'];
            if (!isset($user_data[$user_id])) {
                $user_data[$user_id]['employee_id'] = $user_id;
                $user_data[$user_id]['mobile'] = $value['mobile'];
                $user_data[$user_id]['log_ids'][] = $value['violation_store_logid'];
            } else {
                $user_data[$user_id]['log_ids'][] = $value['violation_store_logid'];
            }
        }

        //按用户统计待处理的商品数量
        foreach ($usert_list as $key => $value) {
            $user_id = $value['employee_id'];
            if (!isset($user_data[$user_id])) {
                $this->user_data[$user_id]['employee_id'] = $user_id;
                $this->user_data[$user_id]['mobile'] = $value['mobile'];
                $this->user_data[$user_id]['violation_store_logids'][] = $value['violation_store_logid'];
            } else {
                $this->user_data[$user_id]['violation_store_logids'][] = $value['violation_store_logid'];
            }
        }
        return true;
    }


    public function failed(\Throwable $exception)
    {
        Log::info('job_error', '订阅短信通知推送队列完全失败', ['data' => $this->message_data, 'error' => $exception]);
    }
}