Proyectos de Subversion LeadersLinked - Antes de SPA

    }

    public function fetchCountUnreadMessagesByConversationIdAndReceiverCompanyId($conversation_id, $receiver_company_id) 

    {

        $select = $this->sql->select(self::_TABLE);

        $select->columns(['total' => new Expression('COUNT(*)')]);

        $select->where->equalTo('conversation_id', $conversation_id);

        $select->where->equalTo('receiver_company_id', $receiver_company_id)

        ->and->equalTo('receiver_status', Message::STATUS_NORMAL)

        $select->limit(1);

        $record = $this->executeFetchOneArray($select);

    }

    public function fetchLastMessagesByConversationIdAndReceiverCompanyId($conversation_id, $receiver_company_id)

    {

        $select = $this->sql->select(self::_TABLE);

        $select->columns(['added_on' => new Expression('MAX(added_on)')  ]);

        $select->where->equalTo('conversation_id', $conversation_id);

        $select->where->equalTo('receiver_company_id', $receiver_company_id)

        ->and->equalTo('receiver_status', Message::STATUS_NORMAL);

        $select->order('id desc');

        $select->limit(1);

        //error_log($select->getSqlString($this->adapter->platform));

        $record = $this->executeFetchOneArray($select);

        if($record) {

            return $record['added_on'];

        }