config['sy_email_online']==1){ include_once(LIB_PATH.'email.class.php'); //获取邮件服务器缓存 include(PLUS_PATH.'emailconfig.cache.php'); //随机选择一组邮件服务器作为当前发信服务器 if($serverId){ if(isset($emailconfig) && is_array($emailconfig)){ foreach($emailconfig as $value){ if($value['id'] == $serverId){ $emailConfig = $value; break; } } } }else{ if(isset($emailconfig) && count($emailconfig)>0){ $rand = array_rand($emailconfig,1); $emailConfig = $emailconfig[$rand]; } } if($emailConfig['smtpserver'] && $emailConfig['smtpuser'] && $emailConfig['smtppass']){ if($emailConfig['smtpport']=='465'){ $smtpserver = 'ssl://'.$emailConfig['smtpserver']; $smtpserverport = '465'; }else{ $smtpserver = $emailConfig['smtpserver']; $smtpserverport = '25'; } return new smtp($smtpserver,$smtpserverport,true,$emailConfig['smtpuser'],$emailConfig['smtppass'],$emailConfig['smtpnick']); }else{ return false; } } if($this->config['sy_email_online']==2){ include_once(LIB_PATH.'aliyunemail.class.php'); $accesskey=$this->config['accesskey']; //accessKey $accesssecret=$this->config['accesssecret']; //accessSecret $accountname=$this->config['ali_email']; //控制台创建的发信地址 $fromalias=$this->config['ali_name']; //发信人昵称 $tagname=$this->config['ali_tag']; //控制台创建的标签 return new aliyun_sendemail($accesskey,$accesssecret,$accountname,$fromalias,$tagname); } } private function addErrorLog($uid,$type='',$content) { require_once ('errlog.model.php'); $ErrlogM = new errlog_model($this->db, $this->def); return $ErrlogM -> addErrorLog($uid, $type, $content); } /** * 获取邮件、短信模板 * @param array $data 传入参数 * @param string $type 模板类型:email邮箱; msg短信 * @return mixed */ public function getTpl($data, $type){ $name = $type.$data['type']; $row = $this -> select_once('templates',array('name'=>$name)); if ($row){ $tpl['title']=$this->_tpl($row['title'], $data); $tpl['content']=$this->_tpl($row['content'], $data); return $tpl; }else{ return array('status' => -1, 'msg' => '信息模板有误,请联系管理员'); } } //替换模板中的变量 private function _tpl($tpl, $data){ unset($data['type']); $re = array("{webname}","{weburl}","{webtel}"); $re2[] = $this->config['sy_webname']; $re2[] = $this->config['sy_weburl']; $re2[] = $this->config['sy_freewebtel']; $tpl = str_replace($re,$re2,$tpl); foreach($data as $k=>$v){ $tpl = str_replace("{".$k."}",$v,$tpl); } return $tpl; } //判断数组的下标是否存在 private function _isKey($key, $arr){ if(array_key_exists($key, $arr) && trim($arr[$key]) != ''){ return trim($arr[$key]); } return false; } /** * 传入 email地址、主题、内容等参数,简单发送email方法 * * @param string $data ['email'] email地址 * @param string $data ['subject'] email主题 * @param string $data ['content'] email正文内容 * @return array */ public function sendEmail($data){ if($this->config['sy_email_online']==1){ if(!$this->smtpClass){ $serverId = array_key_exists('smtpServerId', $data) ? $data['smtpServerId'] : ''; $this->smtpClass = $this->_getSmtp($serverId); } if(!$this->smtpClass){ return array('status' => -1, 'msg' => '还没有配置邮箱,请联系管理员!'); } if($this->_isKey('email', $data) == false || CheckRegEmail($data['email']) == false){ return array('status' => -1, 'msg' => 'email地址错误'); } if(!$this->_isKey('subject', $data) || !$this->_isKey('content', $data)){ return array('status' => -1, 'msg' => 'email主题/正文为空'); } $cc = isset($data['cc']) ? $data['cc'] : ''; $bcc = isset($data['bcc']) ? $data['bcc'] : ''; $additional_headers = isset($data['additional_headers']) ? $data['additional_headers'] : ''; $sendid = $this->smtpClass->sendmail($data['email'],$data['subject'],$data['content'],'HTML',$cc,$bcc,$additional_headers); if($sendid){ $state = '1'; $retval = array('status' => 1, 'msg' => 'email发送成功!'); }else{ $state = '0'; $retval = array('status' => -1, 'msg' => 'email发送失败!'); $this->addErrorLog($data['uid'], 9,'email发送失败!'); } } if($this->config['sy_email_online']==2){ if(!$this->smtpClass){ $this->smtpClass = $this->_getSmtp(); } if(!$this->smtpClass){ return array('status' => -1, 'msg' => '还没有配置邮箱,请联系管理员!'); } $sendid = $this->smtpClass->sendemail($data['email'],$data['subject'],$data['content']); if($sendid){ $state = '1'; $retval = array('status' => 1, 'msg' => 'email发送成功!'); }else{ $state = '0'; $retval = array('status' => -1, 'msg' => 'email发送失败!'); $this->addErrorLog($data['uid'], 9,'email发送失败!'); } } //如果email正文内容太多,允许保存其他简短内容到数据表email_msg $tbContent = isset($data['tbContent']) ? $data['tbContent'] : $data['content']; $email_msg = array( 'uid' => $data['uid'], 'cuid' => isset($data['cuid']) ? $data['cuid'] : 0, 'email' => $data['email'], 'title' => $data['subject'], 'content' => $tbContent , 'state' => $state, 'ctime' => time(), 'smtpserver' => $this->smtpClass->user ); if($data['email'] && !isset($data['repeat'])){ $this -> insert_into('email_msg',$email_msg); } return $retval; } function insertEmail($data){ return $this -> insert_into('email_msg',$data); } function insertMsg($data){ return $this -> insert_into('moblie_msg',$data); } /** * @desc 根据业务类型,判断后台设置是否开启该类型email提醒,选择设定好的email模板,发送指定类型的邮件 * * @param string $data['type'] 发送email的类型: * reg注册,yqms邀请面试,fkcg付款成功,zzshtg职位审核成功,sqzw申请职位,getpass找回密码,yqmshf回复面试邀请,login登录验证 * 'birthday', * 'webbirthday', * 'vipmr', * 'useradd', * 'userup', * 'addjob', * 'upjob' * $data数组,网站名称,网站域名和网站电话,不需要加到该数组中,请根据/data/db.tpl.php进行添加数据进来,全部添加 * $data包括email,moblie,$type * email 要发送的邮箱用户 * moblie要发送的手机用户 * */ public function sendEmailType($data, $tpl = NULL) { if (! $this->_isKey('type', $data) || ! $this->_isKey('sy_email_'.$data['type'], $this->config) || $this->config['sy_email_'.$data['type']] != 1) { return array( 'status' => - 1, 'msg' => '未开启email提醒,请联系管理员!(code:' . $data['type'] . ')' ); } // 邮件内容,如发送的内容相同,可以先把内容处理好传入,减少数据处理 if (! $tpl) { $tpl = $this->getTpl($data, 'email'); if (isset($tpl['status'])) { return $tpl; } } $data['subject'] = $tpl['title']; $data['content'] = html_entity_decode($tpl['content'], ENT_QUOTES); return $this->sendEmail($data); } private function postSMS($type="msgsend",$data=''){ $sing = $this->config['sy_msg_appsing']; $data['content'] = str_replace(array(" "," ","\t","\n","\r"),array("","","","",""),$data['content']); $url='http://api.smsbao.com/sms'; $url.='?u='.$data['appkey'].'&p='.md5($data['appsecret']).'&m='.$data['phone'].'&c=【'.$sing.'】'.$data['content']; if(function_exists('file_get_contents')){ $file_contents = file_get_contents($url); }else{ $ch = curl_init(); $timeout = 5; curl_setopt ($ch, CURLOPT_URL, $url); curl_setopt ($ch, CURLOPT_RETURNTRANSFER, 1); curl_setopt ($ch, CURLOPT_CONNECTTIMEOUT, $timeout); $file_contents = curl_exec($ch); curl_close($ch); } return $file_contents; } private function checkPhone($phone){ $url='https://u.phpyun.com/phone'; $url.='?appSecret='.$this -> config['sy_kh_appsecret'].'&appKey='.$this -> config['sy_kh_appkey'].'&phone='.$phone; if (extension_loaded('curl')){ $file_contents = CurlGet($url); }else if(function_exists('file_get_contents')){ $file_contents = file_get_contents($url); } if($file_contents){ $msgInfo = json_decode($file_contents,true); } return $msgInfo; } /** * $data['moblie'] / $data['mobile'] 手机号(必填) * $data['content'] 短信内容(必填) * * (选填) 保存到moblie_msg表的字段: * uid 接收人uid, * cuid 发送人uid, */ public function sendSMS($data){ if(!checkMsgOpen($this -> config)){ return array('status' => -1, 'msg' => '还没有配置短信,请联系管理员!'); } $data['mobile'] = $data['moblie'] ? $data['moblie'] : $data['mobile']; if($this->_isKey('mobile', $data) == false || CheckMobile($data['mobile']) == false){ return array('status' => -1, 'msg' => '手机号错误'); } if($this->config['sy_web_mobile']!=''){ $regnamer=@explode(';',$this->config['sy_web_mobile']); if(in_array($data['mobile'],$regnamer)){ return array('status' => -1, 'msg' => '该手机号已被禁止使用'); } } if($this->_isKey('content', $data) == false || $data['content'] == ''){ return array('status' => -1, 'msg' => '短信内容为空'); } //发送短信 $row = array( 'appsecret' => $this->config['sy_msg_appsecret'], 'appkey' => $this->config['sy_msg_appkey'], 'appsing' => $this->config['sy_msg_appsing'], 'phone' => $data['mobile'], 'content' => $data['content'], 'mid' => isset($data['mid']) ? $data['mid'] : '' ); $location = ''; //进行空号检测 以及 归属地限制 if($this -> config['sy_kh_isopen'] == '1' && in_array($data['type'],array('login','cert','regcode'))){ $checkInfo = $this -> checkPhone($data['mobile']); $checkData = json_decode($checkInfo['data'],true); //检测出号码不为空号 if($checkInfo['code'] == '200' && $checkData['phoneList']['phoneStatus']>0){ $location = $checkData['phoneList']['province'] . '-' . $checkData['phoneList']['city']; //检测归属地 if($this -> config['sy_kh_city'] && $checkData['phoneList']['province']!='未知' && $checkData['phoneList']['city']!='未知'){ $re['code'] = '502';//归属地检测失败 $re['message'] = '号码检测有误!'; $kh_province = str_replace(",",",",$this -> config['sy_kh_city']); $kh_province_arr = explode(',',$kh_province); foreach($kh_province_arr as $key => $value) { $kh_city = @explode('/',$value); //设定市级地区的情况下优先判断 if((!empty($kh_city[1]) && strpos($checkData['phoneList']['city'],$kh_city[1])!==false) || (empty($kh_city[1]) && strpos($checkData['phoneList']['province'],$kh_city[0])!==false)){ unset($re); break; } } } }else{ $re['code'] = '501';//空号检测失败 $re['message'] = '号码检测有误!'; } } if(!isset($re['code'])){ $re= $this->postSMS('msgsend',$row); } //短信记录保存数据库 $sql_data = array( 'uid' => $data['uid'], 'cuid' => isset($data['cuid']) ? $data['cuid'] : 0, 'moblie' => $data['mobile'], 'ctime' => time(), 'content' => $data['content'], 'port' => $data['port'], 'location' => $location ); if(trim($re) =='0'){ //检查是否需要发送系统预警 include_once('warning.model.php'); $warning = new warning_model($this->db,$this->def); $warning -> warning(5); $sql_data['state'] = 0; $sql_data['ip'] = fun_ip_get(); $sqlResult = $this -> insert_into('moblie_msg',$sql_data); return array('status' => 1, 'msg' => '发送成功!'); }else{ $sql_data['state'] = $re['code']; $this -> insert_into('moblie_msg',$sql_data); $content = '短信发送失败!手机号:'.$data['mobile'].',状态:'.$re['code']."," . $re['message']; if ($re['code'] == '501'){ // 记录空号检测失败,综合平台返回的错误原因 $content .= $checkInfo['message']; } $this->addErrorLog($data['uid'], 8, $content); return array('status' => -1, 'msg' => '发送失败!状态:'.$re['code']."," . $re['message']); } } /** * * @param array $data 传入参数 * @param string $content 短信内容 * @return number[]|string[] */ public function sendSMSType($data, $content=NULL){ if(!$this->_isKey('type', $data) || !$this->_isKey('sy_msg_'.$data['type'], $this->config) || $this->config['sy_msg_'.$data['type']] !=1){ //是否后台设置了需要短信提醒 return array('status' => -1, 'msg' => '未开启短信提醒,请联系管理员(code:msg'.$data['type'].')'); } //短信内容,如发送的内容相同,可以先把内容处理好传入,减少数据处理 if (!$content){ $tpl = $this->getTpl($data, 'msg'); if (isset($tpl['status'])){ return $tpl; } $content = $tpl['content']; } $data['content'] = $content; return $this->sendSMS($data); } public function getBusinessInfo($name){ if($this->config['sy_tyc_appkey'] && $this->config['sy_tyc_appsecret']){ //查询当前数据库中是否存在该名称 $comNameNum = $this -> select_num('company',array('name'=>$name)); //企业名称存在 if($comNameNum > 0){ $url='https://u.phpyun.com/company'; $url.='?appSecret='.$this->config['sy_tyc_appsecret'].'&appKey='.$this->config['sy_tyc_appkey']."&companyName=".$name; if (extension_loaded('curl')){ $file_contents = CurlGet($url); }else if(function_exists('file_get_contents')){ $file_contents = file_get_contents($url); } $return = json_decode($file_contents,true); if(!empty($return['data'])){ $tycData = json_decode($return['data'],true); $Info = $tycData['result']; if($Info['estiblishTime']){ $msectime = $Info['estiblishTime'] * 0.001; if(strstr($msectime,'.')){ sprintf('%01.3f',$msectime); list($usec, $sec) = explode('.',$msectime); $sec = str_pad($sec,3,'0',STR_PAD_RIGHT); }else{ $usec = $msectime; $sec = '000'; } $est = date('Y-m-d',$usec); $Info['estiblishTime'] =$est; } if($Info['fromTime']){ $msectime = $Info['fromTime'] * 0.001; if(strstr($msectime,'.')){ sprintf('%01.3f',$msectime); list($usec, $sec) = explode('.',$msectime); $sec = str_pad($sec,3,'0',STR_PAD_RIGHT); }else{ $usec = $msectime; $sec = '000'; } $est = date('Y-m-d',$usec); $Info['fromTime'] =$est; }else{ $Info['fromTime'] = '自创立起'; } if($Info['toTime']){ $toTime=new DateTime('@'.substr($Info['toTime'],0,10)); $toTime->setTimezone(new DateTimeZone('PRC')); $Info['toTime'] = $toTime->format('Y-m-d'); }else{ $Info['toTime'] = '长期'; } } } return array('content'=>$Info); } } /** * @desc 短信验证码时效性 * @param array $data * @return boolean */ public function checkTime($data) { $cert_validity = $this->config['moblie_codetime'] * 60; // 验证码有效时间 $time = time(); $ctime = bcsub($time, $data); if ($ctime <= $cert_validity) { return true; } else { return false; } } /** * 发送手机短信/邮件验证码 * @param string $sended 手机号/邮箱 * @param string $type 验证码类型:getpass-忘记密码-7; login-登录-2; regcode-注册-2; cert-认证-2; * @param array $user 用户信息 * @param number $length 验证码长度 * @param number $validity 发送间隔 * @param string $kind 类型:msg 短信/email 邮件 * @param string $port 端口:1-PC;2-WAP;5-ADMIN * @return array|number[]|string[] */ public function sendCode($sended, $type, $port='', $user = array(), $length = 6, $validity = 120, $kind = 'msg') { $time = time(); $overtime = $time - $validity; $today = strtotime('today'); $ip = fun_ip_get(); $code = gt_Generate_code($length); //验证码 if ($kind == 'msg'){ if(!checkMsgOpen($this -> config)){ return array('error'=> 107, 'msg'=> '网站没有配置短信,请联系管理员!'); } $ip = fun_ip_get(); $ipnum = $this -> select_num('moblie_msg', array('ip'=>$ip , 'ctime' => array('>', strtotime(date('Y-m-d'))))); if($ipnum >= $this->config['ip_msgnum']){ return array('error'=> 107, 'msg'=> '当前IP短信发送受限!'); } $num = $this -> select_num('moblie_msg', array('moblie' => $sended , 'ctime' => array('>',strtotime(date('Y-m-d'))))); if($num >= $this->config['moblie_msgnum']){ return array('error'=> 107, 'msg'=> '请不要频繁发送!'); } if (CheckMobile($sended) == false){ return array('error'=> 106, 'msg'=> '手机号码格式错误'); } if ($type == 'getpass'){ $member = $this -> select_once('member',array('moblie'=>$sended),'`uid`,`username` as `name`, `usertype`'); if (!empty($member)){ $user = array( 'uid' => $member['uid'], 'usertype' => $member['usertype'], 'name' => $member['name'] ); }else{ return array('error'=> 105, 'msg'=> '该手机尚未注册'); } $lastSend = $this -> select_once('company_cert',array('check' => $sended, 'type' => 7 ,'orderby'=>'id,desc'),'`ctime`,`type`'); }else { $lastSend = $this -> select_once('company_cert',array('check' => $sended, 'type' => 2,'orderby'=>'id,desc'),'`ctime`,`type`'); } if($lastSend['ctime'] > $overtime){ return array('error' => 102, 'msg' => '两次发送间隔需超过'.$validity.'秒'); } if ($type == 'cert'){ $certover = $time - ($this->config['cert_msgtime'] * 60); if ($lastSend['ctime'] > $certover){ return array('error' => 102, 'msg' => '手机认证短信发送间隔需超过'.$this->config['cert_msgtime'].'分钟'); } } $sendToday = $this -> select_all('moblie_msg', array('moblie' => $sended, 'ctime' => array('>' , $today)), '`ip`'); if(count($sendToday) >= $this->config['moblie_msgnum']){ return array('error' => 103, 'msg' => '同一手机号一天最多发送'.$this->config['moblie_msgnum'].'条'); } $ipSendNum = 0; foreach ($sendToday as $v){ if ($v['ip'] == $ip){ $ipSendNum++; } } if($ipSendNum >= $this->config['ip_msgnum']){ return array('error'=> 104, 'msg' => '同一IP一天最多发送'.$this->config['ip_msgnum'].'条'); } $result = $this -> sendType($sended, $type, $code, 'msg', $user, $port); }elseif ($kind == 'email'){ if (CheckRegEmail($sended) ==false){ return array('error'=> 101, 'msg'=> '邮箱格式错误'); } if($this->config['sy_email_set']!="1"){ return array('error'=> 107, 'msg'=> '网站邮件服务器暂不可用'); } $num = $this->select_num("company_cert" , array('check'=>$sended , 'ctime'=>array('>',strtotime(date('Y-m-d')))) ); if($num>=5){ $data['errmsg'] = '请不要频繁发送邮件!'; $data['error'] = 17; echo json_encode($data);die; } if ($type == 'getpass'){ $member = $this -> select_once('member',array('email'=>$sended),'`uid`,`username` as `name`, `usertype`'); if($this->config['sy_email_getpass']=="2"){ return array('error'=> 108, 'msg'=> '网站未开启邮件找回密码'); } if ($member){ $user = array( 'uid' => $member['uid'], 'usertype' => $member['usertype'], 'name' => $member['name'] ); }else{ return array('error'=> 105, 'msg'=> '该邮箱尚未注册'); } $num = $this -> select_num('company_cert',array('check'=>$sended,'type'=>7,'ctime'=>array('>',$today))); if($num >= 5){ return array('error'=> 106, 'msg'=> '请不要频繁发送邮件'); } $lastSend = $this -> select_once('company_cert',array('check'=>$sended,'type'=>7),'`ctime`,`type`'); $result = $this -> sendType($sended, $type, $code, 'email', $user); } } if($result['status'] != -1){ $sendData = array( 'uid' => intval($user['uid']), 'status' => 0, 'step' => 1, 'check' => $sended, 'check2' => $code, 'ctime' => $time, 'did' => $this -> config['did'], 'statusbody' => $this -> codeType($type) ); // 7-找回密码,2-其他短信、邮件验证码 if ($type == 'getpass'){ $sendData['type'] = 7; }else{ $sendData['type'] = 2; } //只修改短信验证码相关的验证 if($lastSend && ($lastSend['type'] == 2 || $lastSend['type'] == 7)){ if ($lastSend['type'] == 2){ $this -> update_once('company_cert', $sendData, array('check'=>$sended,'type'=>2)); }elseif ($lastSend['type'] == 7){ $this -> update_once('company_cert', $sendData, array('check'=>$sended,'type'=>7)); } }else{ $this -> insert_into('company_cert', $sendData); } } return array('error' => $result['status'], 'msg' => $result['msg']); } //按类别发送验证码 private function sendType($sended, $type, $code, $kind = 'msg',$user = array(), $port = null){ $finfo = $this -> forsend($user); //用户信息 $data = array( 'uid' => $finfo['uid'], 'username' => $finfo['name'], 'cuid' => $finfo['cuid'], 'cname' => $finfo['cname'], 'type' => $type, 'code' => $code ); if ($kind == 'msg'){ $data['moblie'] = $sended; $data['port'] = $port; $result = $this -> sendSMSType($data); }elseif ($kind == 'email'){ $data['email'] = $sended; $result = $this -> sendEmailType($data); } return $result; } //手机验证码类型 private function codeType($type){ $status = array( 'login' => '手机登录验证码', 'regcode' => '手机注册验证码', 'cert' => '手机认证', 'getpass' => '找回密码' ); } //查询接收短信、邮件用户信息 private function forsend($user){ $info = array( 'uid' => 0, 'name' => '', 'cuid' => 0, 'cname' => '系统' ); if (!empty($user['uid'])){ if (!empty($user['name'])){ $info['uid'] = $user['uid']; $info['name'] = $user['name']; }else { $info = $this -> select_once('member', array('uid' => $user['uid']),'`uid`, `username` as `name`'); } } return $info; } /** * @desc 极验验证 * @param $authcode * @param $tag * @return array */ function jycheck($authcode, $tag) { $image = false; session_start(); if (!empty($tag)) { if (strpos($this->config['code_web'], $tag) !== false) { if ($this->config['code_kind'] > 2) { $check = verifytoken($this->config); if ($check['code'] != '200') { return array('error' => 107, 'msg' => $check['msg']); } } else { $image = true; } } } else { $image = true; } if ($image) { if (md5(strtolower(trim($authcode))) != $_SESSION['authcode'] || trim($authcode) == '') { unset($_SESSION['authcode']); return array('error' => 106, 'msg' => '图片验证码填写错误!'); } else { unset($_SESSION['authcode']); } } } } ?>