<?php
/*
* $Author ：PHPYUN开发团队
*
* 官网: http://www.phpyun.com
*
* 版权所有 2009-2021 宿迁鑫潮信息技术有限公司，并保留所有权利。
*
* 软件声明：未经授权前提下，不得用于商业运营、二次开发以及任何形式的再次发布。
 */
class email_model extends model{
	
	/*
	 * 获取配置列表
	 * $whereData 	查询条件
	 * $data 		自定义处理数组
	 */
	 
	function getList($whereData,$data=array()){
		$ListNew	=	array();
		$List		=	$this -> select_all('admin_email',$whereData);
		
		if(!empty( $List )){
			
			$ListNew['list']	=	$List;
		}

		return	$ListNew;
	}
	
	/*
	* 获取配置详情
	* $whereData 	查询条件
	* $data 		自定义处理数组
	*
	*/
	function getInfo($whereData, $data = array()){
		
		if($whereData){
			$data['field']  =	empty($data['field']) ? '*' : $data['field'];
		
			$List	=	$this -> select_once('admin_email',$whereData,$data['field']);
		}

		return $List;
	
	}

	/*
	* 创建配置
	* $setData 	自定义处理数组
	*
	*/
	

	function addInfo($setData){

		if(!empty($setData)){
			
			$nid	=	$this -> insert_into('admin_email',$setData);
			
		}
		
		return $nid;
		
	
	}

	/*
	* 更新配置
	* $whereData 	查询条件
	* $data 		自定义处理数组
	*
	*/

	function upInfo($whereData, $data = array()){

		if(!empty($whereData)){
			
			$nid	=	$this -> update_once('admin_email',$data,$whereData);
			
		}

		return $nid;
	
	}
	/*
	* 查询数量
	* $whereData 	查询条件
	*
	*/

	function getNum($whereData){

		if(!empty($whereData)){
			
			$num	=	$this -> select_num('admin_email',$whereData);
			
		}

		return $num;
	
	}
	
	function delEmail($whereData,$data){
		
		if($data['type']=='one'){//单个删除
			
			$limit		=	'limit 1';
			
		}
		
		if($data['type']=='all'){//多个删除
		
			$limit		=	'';
			
		}
 
		$result			=	$this	->	delete_all('admin_email',$whereData,$limit);
		
		return	$result;
		
	}
	
	
	/*
	 * 获取配置列表
	 * $whereData 	查询条件
	 * $data 		自定义处理数组
	 */
	 
	function getEmsgList($whereData,$data=array()){
		$ListNew			=	array();
		$List				=	$this -> select_all('email_msg',$whereData);
		
		if(!empty( $List )){
			$cuid			=	array();
			$uid			=	array();
			foreach ($List as $k => $v) {
				if($v['cuid']>0){
					$cuid[]	=	$v['cuid'];
				}
				if($v['uid']>0){
					$uid[]	=	$v['uid'];
				}
			}
			$alluids		=	array_merge($cuid,$uid);
			$alluids		=	array_unique($alluids);//发送人

			require_once ('userinfo.model.php');

            $userinfoM  	=   new userinfo_model($this->db, $this->def);

            $namelists  	=   $userinfoM  ->  getUserList(array('uid'=>array('in',pylode(',',$alluids))));

            foreach($namelists as $nk=>$nv){

                $names[$nv['uid']]  	=   $nv['name'];

            }

            foreach($List as $lk => $lv){

				$List[$lk]['fname']		=	$lv['cuid'] ? $names[$lv['cuid']] : '系统';
				
				if($lv['uid']>0){

					$List[$lk]['sname'] =	$names[$lv['uid']];

				}elseif($lv['uid']<0){

					$List[$lk]['sname'] =	'管理员';

				}else{

					$List[$lk]['sname']	=	'';
					
				}
			}

			$ListNew['list']			=	$List;
		}

		return	$ListNew;
	}
	
	function delEmailMsg($whereData,$data){
		
		if($data['type']=='one'){//单个删除
			
			$limit	=	'limit 1';
			
		}
		
		if($data['type']=='all'){//多个删除
		
			$limit	=	'';
			
		}
		if($data['norecycle'] == '1'){	//	数据库清理，不插入回收站
	
			$result	=	$this	->	delete_all('email_msg',$whereData,$limit,'','1');
		}else{
 
			$result	=	$this	->	delete_all('email_msg',$whereData,$limit);
		}
		
		return	$result;
		
	}
	
	/*
	* 查询数量
	* $whereData 	查询条件
	*
	*/

	function getEmsgNum($whereData){

		if(!empty($whereData)){
			
			$num	=	$this -> select_num('email_msg',$whereData);
			
		}

		return $num;
	
	}
	/*
	 * 获取单条数据email_msg
	 * $whereData 	查询条件
	 * $data 		自定义处理数组
	 */
	 
	function getEmsgOnce($whereData,$data=array()){
		
		$data['field']  =	empty($data['field']) ? '*' : $data['field'];
		
		$List				=	$this -> select_once('email_msg',$whereData,$data['field']);
		
		if(is_array($List)&&$List){
			
			if(date('Y-m-d',$List['ctime'])==date('Y-m-d'))
			{
				$List['disabled']='1';
			}
		}
		
		return	$List;
	}
	//发送邮件
	function setSendCom($post=array()){
		$data		=	array();
		$emailtype	=	intval($post['emailtype']);
		$emailday	=	intval($post['emailday']);
		$page		=	intval($post['page']);
		$limit		=	100;
		if($page<1){
			$page	=	1;
		}	
		if($emailtype){ 
			if($emailday){
				$time=strtotime("-".$emailday." day");
			}else{
				$time=strtotime("-7 day");
			} 
			$ststrsql=($page-1)*$limit;
			if($emailtype=='2'){
				if($this->config['sy_email_vipmr']!='1'){
					$data['msg']	=	'请先开启会员服务到期提醒！'; 
					$data['stype']	=	2;  
				}else{
					$allnum	=	$this->select_num('company_statis',array('vip_etime'=>array('<',$time)),'`uid`');
					$allpage=	ceil($allnum/$limit); 
					if($allpage>$page){ 
						$rating	=	$this->select_all('company_statis',array('vip_etime'=>array('<',$time),'limit'=>$ststrsql.','.$limit),'`uid`,`vip_etime`,`rating_name`'); 
						if($rating&&is_array($rating)){
							$uids=array();
							foreach($rating as $v){
								$uids[]=$v['uid'];
							} 
							$member=$this->select_all('member',array('usertype'=>'2','email'=>array('<>',''),'uid'=>array('in',pylode(',',$uids))),'`uid`,`email`,`login_date`');
						} 
					}else{
						$data['msg']	=	'发送成功！'; 
						$data['stype']	=	2;  
					}
				} 
			}else if($emailtype=='1'){ 
				if($this->config['sy_email_comwdl']!='1'){
					$data['msg']	=	'请先开启未登录提醒！'; 
					$data['stype']	=	2;  
				}else{
					$allnum=$this->select_num('member',array('usertype'=>'2','email'=>array('<>',''),'login_date'=>array('<',$time)),'`uid`');
					
					$allpage=ceil($allnum/$limit);  
					if($allpage>$page){
						$member=$this->select_all('member',array('usertype'=>'2','email'=>array('<>',''),'login_date'=>array('<',$time),'limit'=>$ststrsql.','.$limit),'`uid`,`email`'); 
					}else{
						$data['msg']	=	'发送成功！'; 
						$data['stype']	=	2;
					}
				}  
			}
			if($data['stype']==''){ 
				if($member&&is_array($member)){ 
					$uids=$com=$ratinginfo=$ratingdate=array();
					foreach($member as $v){
						$uids[]=$v['uid'];
					}
					$company=$this->select_all('company',array('uid'=>array('in',pylode(',',$uids))),'`uid`,`name`');
					foreach($company as $v){
						$com[$v['uid']]=$v['name'];
					}
					include_once('notice.model.php');
					$notice	=	new notice_model($this->db, $this->def);
					if($emailtype=='1'){
						foreach($member as $v){ 
							$notice->sendEmailType(array("email"=>$v['email'],"uid"=>$v['uid'],"name"=>$com[$v['uid']],"date"=>date("Y-m-d H:i:s",$v['login_date']),"type"=>"comwdl"));
						}
					}elseif($emailtype=='2'){
						foreach($rating as $v){
							$ratinginfo[$v['uid']]=$v['rating_name'];
							$ratingdate[$v['uid']]=date("Y-m-d H:i:s",$v['vip_etime']);
						}
						foreach($member as $v){ 
							$notice->sendEmailType(array("email"=>$v['email'],"uid"=>$v['uid'],"name"=>$com[$v['uid']],"ratingname"=>$ratinginfo[$v['uid']],'date'=>$ratingdate[$v['uid']],"type"=>"vipmr"));
						}
					}  
					$data['msg']	=	'正在发送第'.$ststrsql.'至'.($ststrsql+$limit).'封邮件！'; 
					$data['stype']	=	1;  
				}else{
					$data['msg']	=	'未找到合适企业！'; 
					$data['stype']	=	2; 
				}
			}
		}else{
			$data['msg']	=	'非法操作！'; 
			$data['stype']	=	2;
		}
		$data['page']	=	$page+1;
		return $data;
	}
	//发送邮件
	function setSendUser($post){
		$emailtype	=	intval($post['emailtype']);
		$emailday	=	intval($post['emailday']);
		$page		=	intval($post['page']);
		$limit		=	100;
		if($page<1){
			$page	=	1;
		}	
		if($emailtype){ 
			if($emailday){
				$time=strtotime("-".$emailday." day");
			}else{
				$time=strtotime("-7 day");
			} 
			$ststrsql=($page-1)*$limit;
			if($emailtype=='2'){
				if($this->config['sy_email_userup']!='1'){
					$data['msg']	=	'请先开启未更新提醒！';  
					$data['stype']	=	2;
				}else{ 
					
					$allnum=$this->select_num('resume_expect',array('lastupdate'=>array('<',$time),'defaults'=>'1','status'=>1,'r_status'=>1,'job_classid'=>array('<>',''),'groupby'=>'uid'),'`uid`');
					
					$allpage=ceil($allnum/$limit); 
					
					if($allpage>$page){ 
						$expect=$this->select_all('resume_expect',array('lastupdate'=>array('<',$time),'defaults'=>'1','status'=>1,'r_status'=>1,'job_classid'=>array('<>',''),'groupby'=>'uid','limit'=>$ststrsql.','.$limit),'`uid`,`lastupdate`');
						if($expect&&is_array($expect)){
							$uids=$lasttime=array();
							foreach($expect as $v){
								$uids[]=$v['uid'];
								$lasttime[$v['uid']]=date("Y-m-d H:i:s",$v['lastupdate']);
							}
							$member=$this->select_all('member',array('usertype'=>'1','email'=>array('<>',''),'uid'=>array('in',pylode(',',$uids))),"`uid`,`email`,`username`");
						} 
					}else{
						$data['msg']='发送成功！'; 
						$data['stype']=2;  
					}
				}
			}else if($emailtype=='1'){
				if($this->config['sy_email_userwdl']!='1'){
					$data['msg']='请先开启未登录提醒！';  
					$data['stype']=2; 
				}else{ 
					$allnum=$this->select_num('member',array('usertype'=>'1','email'=>array('<>',''),'login_date'=>array('<',$time)),'`uid`');
					$allpage=ceil($allnum/$limit); 
					
					if($allpage>$page){ 
						$member=$this->select_all('member',array('usertype'=>'1','email'=>array('<>',''),'login_date'=>array('<',$time),'limit'=>$ststrsql.','.$limit),'`uid`,`email`');
					}else{
						$data['msg']='发送成功！'; 
						$data['stype']=2;  
					}
				} 
			} 
			if($data['stype']==''){ 
				if($member&&is_array($member)){
					$emailarr=$userinfo=$uids=array(); 
					include_once('notice.model.php');
					$notice	=	new notice_model($this->db, $this->def);
					if($emailtype=='1'){
						foreach($member as $v){ 
							$notice->sendEmailType(array("email"=>$v['email'],"uid"=>$v['uid'],"username"=>$v['username'],"date"=>date("Y-m-d H:i:s",$v['login_date']),"type"=>"userwdl"));
						}
					}else{
						foreach($member as $v){ 
							$notice->sendEmailType(array("email"=>$v['email'],"uid"=>$v['uid'],"name"=>$v['username'],'date'=>$lasttime[$v['uid']],"type"=>"userup"));
						}
					} 
					$data['msg']='正在发送第'.$ststrsql.'至'.($ststrsql+$limit).'封邮件！'; 
					$data['stype']=1;  
				}else{
					$data['msg']='未找到合适用户！';
					$data['stype']=2;		
				}
			}
		}else{
			$data['msg']='非法操作！';
			$data['stype']=2;			
		}
		$data['page']=$page+1;
		return $data;
	}

    /**
     * 邮件失败重发
     * @param $id
     * @return string
     */
    function repeat($id)
    {

        if (is_array($id)) {

            $where['id']    =   array('in', pylode(',', $id));
        } else {

            $where['id']    =   (int)$id;
        }

        $where['state']     =   array('<>', '1');

        //查询失败邮件
        $repeatEmail        =   $this->select_all('email_msg', $where);

        if (!empty($repeatEmail)) {

            include_once('notice.model.php');

            $noticeM        =   new notice_model($this->db, $this->def);

            //发送邮件
            $row = array(
                'appsecret' => $this->config['sy_msg_appsecret'],
                'appkey' => $this->config['sy_msg_appkey']
            );

            foreach ($repeatEmail as $key => $value) {

                $row['email']   =   $value['email'];
                $row['subject'] =   $value['title'];
                $row['content'] =   $value['content'];
                $row['repeat']  =   1;

                $return         =   $noticeM->sendEmail($row);

                if (trim($return['code']) == '200') {

                    $successid[] = $value['id'];
                } else {

                    $nosuccessid[] = $value['id'];
                    $codeMsg = $return['code'] . " ";
                }
            }
            if (!empty($successid)) {

                $this->update_once('email_msg', array('state' => '1'), array('id' => array('in', implode(',', $successid))));

            }
            $msg = '本次邮件重发成功：' . count($successid) . '条';
            if (!empty($nosuccessid) && isset($codeMsg)) {
                $msg .= ',失败：' . count($nosuccessid) . '条,错误码：' . $codeMsg;
            }
        } else {
            $msg = '没有需要重发的邮件！';
        }


        return $msg;
    }

}