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