xinhu_gitee/webmain/model/emailmModel.php

<?php
class emailmClassModel extends Model
{
	public function initModel()
	{
		$this->adminobj 	= m('admin');
		$this->optionobj 	= m('option');
		$this->upfileobj 	= c('upfile');
		$this->recehost 	= $this->optionobj->getval('email_recehost');
		$this->receyumi 	= $this->optionobj->getval('email_receyumi');
	}
	
	/**
	*	用户收邮件
	*	$uid 用户id
	*	return 返回是数组就说明成功，字符串就失败
	*/
	public function receemail($uid)
	{
		$ukey 	= 'email_recexin_'.$uid.'';
		$myurs 	= $this->adminobj->getone($uid, 'email,emailpass');
		$time	= $this->optionobj->getval($ukey,'',3);
		if(!isempt($time))$time = strtotime($time);
		if(isempt($this->receyumi))return '未设置收信邮箱域名';
		if(isempt($myurs['email']))return '未设置邮箱，可到[系统→邮件管理→用户邮箱设置]下设置';
		if(isempt($myurs['emailpass']))return '未设置邮箱密码，可到[系统→邮件管理→用户邮箱设置]下设置';
		if(!contain($myurs['email'], $this->receyumi))return '邮箱域名必须是['.$this->receyumi.']，当前用户邮箱:'.$myurs['email'].'';
		$rows 	= c('imap')->receemail($this->recehost, $myurs['email'], $myurs['emailpass'], $time);
		if(!is_array($rows))return $rows;
		$jf 	= 0;
		$bool 	= true;
		foreach($rows as $k=>$rs){
			$message_id	= $rs['message_id'];
			if(isempt($message_id))$message_id = md5($rs['date']);
			
			$where 	= "message_id='$message_id'";
			$id 	= (int)$this->getmou('id',$where);
			if($id ==0)$where = '';
			if($id>0)continue;
			
			$uarr['message_id'] = $message_id;
			$uarr['title'] 		= $this->db->tocovexec($rs['subject'], 1);
			$uarr['content'] 	= $this->db->tocovexec($rs['body'], 1);
			$uarr['senddt'] 	= $rs['date'];
			$uarr['optdt'] 		= $this->rock->now;
			$uarr['size'] 		= $rs['size'];
			$uarr['fromemail'] 	= $this->gshemail($rs['fromemail']);
			$uarr['toemail'] 	= $this->gshemail($rs['toemail']);
			$uarr['reply_toemail'] 	= $this->gshemail($rs['reply_toemail']);
			$uarr['ccemail'] 		= $this->gshemail($rs['ccemail']);
			$uarr['isturn'] 		= 1;
			$uarr['isfile'] 		= count($rs['attach']) > 0 ? 1 : 0;
			$uarr['type'] 			= 1;
			$uarr['numoi'] 			= $rs['num'];
			$form	= $rs['from'][0];
			$urs 	= $this->adminobj->emailtours($form->email);
			$uarr['uid']			= 0;
			$uarr['sendid']			= 0;
			$uarr['sendname']		= '';
			if(is_array($urs) && $urs){
				$uarr['sendid']		= $urs['id'];
				$uarr['uid']		= $urs['id'];
				$uarr['sendname']	= $urs['name'];
			}
			$uarr['sendname']	= $uarr['fromemail'];
			$uarr['recename']	= $uarr['toemail'];
			
			$bool  = $this->record($uarr, $where);
			if($bool){
				if($id ==0)$id = $this->db->insert_id();
				$this->saveattach($rs['num'], $rs['attach'], $id);
				$toarr = $this->saveemails($id, 0, $rs['to']);
				$this->saveemails($id, 1, $rs['cc']);
				$this->saveemails($id, 2, $rs['from']);
				$uuarr['receid']	= $toarr[0];
				//$uuarr['recename']	= $toarr[1];
				$this->update($uuarr, $id);
				$jf++;
			}
		}
		if($bool)$this->optionobj->setval($ukey.'@-2', '共'.$jf.'封');//记录最后收信时间
		return array(
			'count' => $jf
		);
	}
	
	private function gshemail($str)
	{
		$str = str_replace(array('"',' ','\''),'', $str);
		return $str;
	}
	
	//保存到子表
	public function saveemails($mid, $type, $arr)
	{
		$sid = $sna = '';
		foreach($arr as $k=>$rs){
			$where 				= "`mid`='$mid' and `type`=$type and `email`='$rs->email'";
			$id 				= (int)$this->db->getmou('[Q]emails','id',$where);
			if($id ==0)$where 	= '';
			$uarr				= array();
			$uarr['mid']		= $mid;
			$uarr['email']		= $rs->email;
			$uarr['personal']	= $rs->personal;
			$uarr['type']		= $type;
			if($id==0){
				$uarr['optdt']	= $this->rock->now;
			}
			$urs 	= $this->adminobj->emailtours($rs->email);
			$uarr['uid']		= 0;
			if(is_array($urs) && $urs){
				$uarr['uid']	= $urs['id'];
				$sid			.=',u'.$urs['id'].'';
				$sna			.=','.$urs['name'].'';
			}
			$this->db->record('[Q]emails', $uarr, $where);
		}
		if($sid != ''){
			$sid = substr($sid, 1);
			$sna = substr($sna, 1);
		}
		return array($sid, $sna);
	}
	
	//保存邮件的附件
	private function saveattach($oi, $arr, $id)
	{
		$dbs 	= m('file');
		$doobj 	= c('down');
		foreach($arr as $k=>$rs){
			
			$fsad	= explode('.', $rs['filename']);
			$sarr['filename'] 	= $rs['filename'];
			$sarr['filesize'] 	= $rs['filesize'];
			$sarr['fileext']  	= strtolower($fsad[count($fsad)-1]);
			$sarr['keyoi'] 	  	= $oi.','.$rs['encoding'].','.$rs['filekey'];
			$sarr['mtype']	  	= 'emailm';
			$sarr['optid']	  	= $this->adminid;
			$sarr['optname']  	= $this->adminname;
			$sarr['adddt']  	= $this->rock->now;
			$sarr['mid']	  	= $id;
			$sarr['filesizecn']	= $this->upfileobj->formatsize($rs['filesize']);
			$where 				= "`mtype`='emailm' and `mid`='$id' and `filename`='".$sarr['filename']."' and `filesize`='".$sarr['filesize']."'";
			
			if($dbs->rows($where)==0){
				$sarr['filepath'] = $doobj->savefilecont($sarr['fileext'], $rs['attachcont']);//下载附件
				$fid = $dbs->insert($sarr);
			}
		}
	}
	
	
	/**
	*	统计我未读邮件
	*/
	public function wdtotal($uid)
	{
		$to= $this->gettotsllss($uid, 1);
		return (int)$to;
	}
	
	//
	private function gettotsllss($uid, $lx=0, $glx='')
	{
		$whe= 'b.uid='.$uid.' and a.`isturn`=1 and b.`isdel`=0 and b.`type` in(0,1)';
		if($lx==1)$whe='b.uid='.$uid.' and a.`isturn`=1 and b.`isdel`=0 and b.`type` in(0,1) and b.`zt`=0';
		if($lx==2)$whe='a.`sendid`='.$uid.' and a.`isturn`=0';
		if($lx==3)$whe='b.uid='.$uid.' and b.`type` = 2 and b.`isdel`=0';
		if($lx==4)$whe='b.uid='.$uid.' and a.`isturn`=1 and b.`type` in(0,1) and b.`isdel`=1';
		if($glx=='whe')return $whe;
		$to 	= $this->db->rows('`[Q]emailm` a left join `[Q]emails` b on a.`id`=b.`mid`', $whe);
		return (int)$to;
	}
	
	public function gettowhere($uid, $lx)
	{
		return $this->gettotsllss($uid, $lx,'whe');
	}

	
	public function zongtotal($uid)
	{
		$zz = $this->gettotsllss($uid, 0); //所有邮件
		$wd = $this->gettotsllss($uid, 1); //未读邮件
		$cgx= $this->gettotsllss($uid, 2); //草稿箱
		
		$yfs= $this->gettotsllss($uid, 3); //已发送
		$ysc= $this->gettotsllss($uid, 4); //已删除
		
		return array(
			'wd' 	=> $wd,
			'zz' 	=> $zz,
			'cgx' 	=> $cgx,
			'yfs' 	=> $yfs,
			'ysc' 	=> $ysc
		);
	}
	
	/**
	*	标识已读了
	*/
	public function biaoyd($uid,$sid)
	{
		m('emails')->update('`zt`=1','`uid`='.$uid.' and `mid` in('.$sid.')');
	}
}