\Usermessage_model

<?php

if (!defined('BASEPATH'))
	exit('No direct script access allowed');
class Usermessage_model extends CI_Model
{
    private $table ='usermessage';
	public function __construct()
	{
		parent::__construct();
	
	}
	
	
	/**
	 *获取单条数据
	 * */
	public function getUserZanRow($userId=0,$listId=0)
	{
	    $this->db->where('userId', $userId);
	    $this->db->where('listId', $listId);
	    $result = $this->db->get($this->table);
	    return $result->row_array();
	}
	
	/**
	 * 修改
	 * */
	
	public function setMessageByID($updateData, $messageId=0 )
	{
	    $this->db->where('messageId', $messageId);
	
	    return $this->db->update($this->table, $updateData);
	}
	
	/**
	 * 添加
	 * */
	public function insertData($userData)
	{
	    $bool = $this->db->insert($this->table, $userData);
	    $res = $bool ? $this->db->insert_id() : false;
		return $res;
	}
	
	/**
	 * 查私信列表
	 * */
	public function getUserMessageList( $userId=0 ,$ids ='',$limit=0 ,$start=0 )
	{
	    
	    $sqls ='';
	    if(!empty($ids))
	    {
	        $sqls =' and messageUserId not in('.$ids.')';
	    }
	    $sql= 'SELECT * from (SELECT * FROM `usermessage` WHERE `userId` = '.$userId.' and deleteFlag=0 '.$sqls.' ORDER BY `createTime` DESC) as a GROUP BY  `messageUserId` order by createTime desc LIMIT '.$start.' ,'.$limit;
        $query = $this->db->query( $sql );
        return $query->result_array();
	}
	
	/**
	 * 统计私信总条数
	 * */
	public function getUserMessageCount( $userId=0 ,$ids='')
	{
	    $sqls ='';
	    if(!empty($ids))
	    {
	        $sqls =' and messageUserId not in('.$ids.')';
	    }
	    
	   $sql= 'SELECT count(DISTINCT(messageUserId)) as count from usermessage where userId='.$userId .$sqls;
       $query = $this->db->query( $sql );
       return $query->row_array();
	}
	
	/**
	 * 获取用户的私信
	 * */
	public function getUserMessageInfo($userId=0 ,$messageUserId=0,$limit=10,$start=0)
	{
// 	  $this->db->where('userId' ,$userId);
// 	  $this->db->where('messageUserId' ,$messageUserId);
// 	  $this->db->where('deleteFlag',0);
	  $sql ='select * from (SELECT * FROM `usermessage` WHERE `userId` = '.$userId.' AND `messageUserId` = '.$messageUserId.' AND `deleteFlag` =0 order by createTime desc LIMIT '.$start.','.$limit.') as c ORDER BY createTime asc';
	  //$this->db->limit($limit,$start);
	  $query = $this->db->query( $sql );
	  return  $query->result_array();
	}
	
	/**
	 * 获取用户的私信
	 * */
	public function getUserMessageRow($userId=0 ,$messageUserId=0)
	{
	    $this->db->where('userId' ,$userId);
	    $this->db->where('messageUserId' ,$messageUserId);
	    $this->db->where('sender',$messageUserId);
	    return  $this->db->get( $this->table)->row_array();
	}
	
	/**
	 * 获取单条数据
	 * */
	public function getMessageRow($messageId=0)
	{
	    $this->db->where('messageId' ,$messageId);
	    return  $this->db->get( $this->table)->row_array();
	}
    
	/**
	 * 批量删除
	 * */
	public function deleteBatch($messageIds)
	{
	    $this->db->where_in('messageId' ,$messageIds);	    
	    return  $this->db->delete( $this->table );
	}
	
	/**
	 * 删除
	 * */
	public function delete($messageId=0)
	{
	    $this->db->where('messageId' ,$messageId);	     
	    return  $this->db->delete( $this->table );
	}
	
	/**
	 * 禁用留言
	 * */
	public function disableData($disableData)
	{
	    $this->db->insert('userdisable', $disableData);
	    $res = $this->db->insert_id();
	    return $res;
	}
	
	/**
	 * 查询被禁用的人
	 * */
	public function getDisableUserRow($userDisableId=0,$userId=0)
	{
	    $this->db->where('userDisableId', $userDisableId);
	    $this->db->where('userId', $userId);
	    $result = $this->db->get('userdisable');
	    return $result->row_array();
	}
	
	/**
	 * 查询被禁用的人
	 * */
	public function getDisableUserList($userId=0)
	{
	    $this->db->select('userDisableId');
	    $this->db->where('userId', $userId);
	    $this->db->where('status',1);
	    $result = $this->db->get('userdisable');
	    return $result->result_array();
	}
}
?>