站内消息-PHP源码

class MessageModel extends Model {

    public $_fields = array(
        //字段
        &＃39;id&＃39; => &＃39;Id&＃39;,
        &＃39;title&＃39; =>&＃39;title&＃39;,
        &＃39;content&＃39; =>&＃39;content&＃39;,
        &＃39;addtime&＃39; =>&＃39;addtime&＃39;
    );
    
    //自动验证
    protected $_validate = array();
    //自动完成
    protected $_auto = array();
    
    //会员id
    private $member_id=&＃39;&＃39;;
    //新消息id
    private $message_id=&＃39;&＃39;;
    
    //老消息id
    private $old_message=&＃39;&＃39;;
    
    private  $old_ids = &＃39;&＃39;;
    
    private $OBJ;
    /**
     *  
     * @example $re = D("Message");$re->setMember(&＃39;1&＃39;);$ar = $re->delMessage(4);
     * @param unknown $member_id
     */
    public function setMember($member_id,$OBJ = null)
    {
        $this->member_id = $member_id;
        $memberObj = D(&＃39;Member&＃39;);
        if($OBJ instanceof $memberObj){
            $this->OBJ = $OBJ;
        }else {
            $this->OBJ = $memberObj;
        }
        
    }
    /**
     * 将messageid写入会员信息表中
     * @param unknown $message_id
     * @param number $read 0未读，1已读
     */
    public function writeMessage($message_id,$read = 0)
    {
        $this->message_id = $message_id;
        $this->getOldMessIds();
        $message_ids = $this->old_message.$this->message_id.&＃39;,&＃39;;
        if ($read ==1){
            $message_ids = &＃39;&＃39;;
            $arr = explode(&＃39;,&＃39;,substr($this->old_message,0,-1));
            if(in_array($message_id,$arr))
            {
                $message_ids = preg_replace(&＃39;/,&＃39;.$message_id.&＃39;,/&＃39;,&＃39;,-&＃39;.$message_id.&＃39;,&＃39;,&＃39;,&＃39;.$this->old_message);
                $message_ids = substr($message_ids,1);
            }
        }
        $data = array(
            &＃39;message_ids&＃39; => $message_ids
        );
        return $this->OBJ->where("id = {$this->member_id}")->save($data);
    }
    
    /**
     * 获得会员信息表中的messageid
     */
    public function getOldMessIds()
    {
        $member_info = $this->OBJ->where("id = {$this->member_id}")->find();
        if(!empty($member_info))
        {
            $this->old_message = $member_info[&＃39;message_ids&＃39;];
        }
    }
    
    /**
     * 获取所有信息ID
     * @return Ambigous 
     */
    public function getMessIds()
    {
        $member_info = $this->OBJ->where("id = {$this->member_id}")->find();
        $message = null;
        $this->old_ids = $member_info[&＃39;message_ids&＃39;];
        if(!empty($member_info))
        {
            $message = str_replace(&＃39;-&＃39;,&＃39;&＃39;,$member_info[&＃39;message_ids&＃39;]);
        }
        return $message;
    }
    
    
    /**
     * 获取未读信息ID
     * @return Ambigous 
     */
    public function readMessage()
    {
        $arr = array();
        $this->getOldMessIds();
        if(count($this->old_message)>0)
        {
            $this->old_message = substr($this->old_message,0,-1);
            $arr = explode(&＃39;,&＃39;,$this->old_message);
            foreach ($arr as $key =>$value) {
                if(stristr($value,"-")===false)
                {
                    unset ($arr[$key]);
                }else {
                    $arr[$key] = abs($arr[$key]);
                }
            }
        }
        return $arr;
    }
    
    /**
     * 
     * @param unknown $message_id
     * @return boolean|\Think\boolean
     */
    public function delMessage($message_id) {
        $arr = array();
		$this->getOldMessIds();
		$message_ids = $this->old_message;
		if($this->old_message)
		{
			$this->old_message = substr($this->old_message,0,-1);
			$arr = explode(&＃39;,&＃39;,$this->old_message);
			foreach ($arr as $key =>$value) {
				if($message_id==$value)
				{
					unset ($arr[$key]);
					break;
				}
				if(&＃39;-&＃39;.$message_id==$value)
				{
					unset ($arr[$key]);
					break;
				}
			}
			if(count($arr)>0)
			{
				$message_ids = implode(&＃39;,&＃39;,$arr);
				$message_ids =$message_ids.&＃39;,&＃39;;
			}
			else
			{
				$message_ids = &＃39;&＃39;;
			}
		}
		
		$data = array(
		    &＃39;message_ids&＃39; => $message_ids
		);
		return $this->OBJ->where("id = {$this->member_id}")->save($data);
    }
    
    /**
     * 注意如果 $member_id 值的变化
     * @param unknown $title
     * @param unknown $content
     * @param unknown $member_id
     * @return boolean|\Think\boolean
     */
    public function sendToMember($title,$content,$member_id = &＃39;&＃39;) {
        
        set_time_limit(0);

		//插入$content
		$arr = array();
		$arr[&＃39;title&＃39;] =$title;
		$arr[&＃39;content&＃39;] = $content;
        
		$id = $this->add($arr);
		if($id === false)
		{
			return false;
		}
		else
		{
		    if(is_array($member_id)){
		        $this->member_id = join(&＃39;,&＃39;,$member_id);
		    }
		    return $this->writeMessage($id);
		}
    }
}