message_data = $message_data; } /** * Execute the job. * * @return void */ public function handle() { try { $SmsVerifyCode = new SmsVerifyCode(); $SubNoticeLogModel = new SubNoticeLogModel(); $notice_data_info = $this->message_data['notice_data_info']; $mobile = $notice_data_info['mobile']; $sms_content = json_decode($notice_data_info['mobile_content'], true); $totle_number = $sms_content['totle_number']; $number1 = $sms_content['number1']; $number2 = $sms_content['number2']; $number3 = $sms_content['number3']; $sms_tpl_id = $sms_content['sms_tpl_id']; $res_msg = $SmsVerifyCode->sendContent($mobile, ['totle_number' => $totle_number, 'number1' => $number1, 'number2' => $number2, 'number3' => $number3], $sms_tpl_id); Log::info('job_send_sms', '订阅短信通知推送队列记录', ['email' => $mobile, 'sms_tpl_id' => $sms_tpl_id, 'msg' => $res_msg]); //更新发送状态 $SubNoticeLogModel->where(['id' => $notice_data_info['id']])->update(['sms_status' => 0]); } catch (\Exception $e) { Log::info('job_send_sms', '阿里云短信通知队列失败', ['data' => $this->message_data, 'error' => $e->getMessage()]); } } public function failed(\Throwable $exception) { Log::info('job_send_sms', '阿里云短信通知队列完全失败', ['data' => $this->message_data, 'error' => $exception]); } }