class messagemodel extends model { public $_fields = array( //字段 'id' => 'id', 'title' =>'title', 'content' =>'content', 'addtime' =>'addtime' ); //自动验证 protected $_validate = array(); //自动完成 protected $_auto = array(); //会员id private $member_id=''; //新消息id private $message_id=''; //老消息id private $old_message=''; private $old_ids = ''; private $obj; /** * * @example $re = d("message");$re->setmember('1');$ar = $re->delmessage(4); * @param unknown $member_id */ public function setmember($member_id,$obj = null) { $this->member_id = $member_id; $memberobj = d('member'); 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.','; if ($read ==1){ $message_ids = ''; $arr = explode(',',substr($this->old_message,0,-1)); if(in_array($message_id,$arr)) { $message_ids = preg_replace('/,'.$message_id.',/',',-'.$message_id.',',','.$this->old_message); $message_ids = substr($message_ids,1); } } $data = array( 'message_ids' => $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['message_ids']; } } /** * 获取所有信息id * @return ambigous <null, mixed> */ public function getmessids() { $member_info = $this->obj->where("id = {$this->member_id}")->find(); $message = null; $this->old_ids = $member_info['message_ids']; if(!empty($member_info)) { $message = str_replace('-','',$member_info['message_ids']); } return $message; } /** * 获取未读信息id * @return ambigous <multitype:, array> */ public function readmessage() { $arr = array(); $this->getoldmessids(); if(count($this->old_message)>0) { $this->old_message = substr($this->old_message,0,-1); $arr = explode(',',$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(',',$this->old_message); foreach ($arr as $key =>$value) { if($message_id==$value) { unset ($arr[$key]); break; } if('-'.$message_id==$value) { unset ($arr[$key]); break; } } if(count($arr)>0) { $message_ids = implode(',',$arr); $message_ids =$message_ids.','; } else { $message_ids = ''; } } $data = array( 'message_ids' => $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 = '') { set_time_limit(0); //插入$content $arr = array(); $arr['title'] =$title; $arr['content'] = $content; $id = $this->add($arr); if($id === false) { return false; } else { if(is_array($member_id)){ $this->member_id = join(',',$member_id); } return $this->writemessage($id); } } }