send($data); $job->delete(); } /** * 发送邮件的逻辑 * @param type $data */ public function send($data){ $insert = [ 'title'=>$data['title'], 'content'=>$data['content'], 'recive_id'=>$data['user_id'], 'recive_email'=>$data['email'], 'journal_id'=>$data['journal_id'], 'journal_email'=>$data['sendEmail'], 'journal_password'=>$data['sendPassword'], 'create_time'=>time() ]; if(isset($data['attachment_url']) && !empty($data['attachment_url']) ){ $res = sendEmail($data['email'],$data['title'],$data['from_name'],$data['content'],$data['sendEmail'],$data['sendPassword'],$data['attachment_url']); $insert['is_attachment'] = 1; $insert['attachment_url'] = $data['attachment_url']; }else{ $res = sendEmail($data['email'],$data['title'],$data['from_name'],$data['content'],$data['sendEmail'],$data['sendPassword']); } if($res['status']==1){ Db::name('email')->insert($insert); return true; }else{ $insert['is_success'] = 0; $insert['fail_reason'] = $res['data']; Db::name('email')->insert($insert); return false; } } }