Proyectos de Subversion LeadersLinked - Antes de SPA

Rev

Rev 1 | Rev 2350 | Ir a la última revisión | Mostrar el archivo completo | | | Autoría | Ultima modificación | Ver Log |

Rev 1 Rev 2338
Línea 90... Línea 90...
90
        $select->limit(1);
90
        $select->limit(1);
Línea 91... Línea 91...
91
        
91
        
92
        $record = $this->executeFetchOneArray($select);
92
        $record = $this->executeFetchOneArray($select);
93
        return $record['total'];
93
        return $record['total'];
-
 
94
    }
-
 
95
 
-
 
96
    public function fetchCountUnreadMessagesByConversationIdAndReceiverCompanyId($conversation_id, $receiver_company_id) 
-
 
97
    {
-
 
98
        $select = $this->sql->select(self::_TABLE);
-
 
99
        $select->columns(['total' => new Expression('COUNT(*)')]);
-
 
100
        $select->where->equalTo('conversation_id', $conversation_id);
-
 
101
        $select->where->equalTo('receiver_company_id', $receiver_company_id)
-
 
102
        ->and->equalTo('receiver_status', Message::STATUS_NORMAL)
-
 
103
        ->and->equalTo('read', Message::NO);
-
 
104
        $select->limit(1);
-
 
105
        
-
 
106
        $record = $this->executeFetchOneArray($select);
-
 
107
        return $record['total'];
Línea 94... Línea 108...
94
    }
108
    }
95
    
109
    
96
    /**
110
    /**
97
     *
111
     *
Línea 153... Línea 167...
153
        ->and->equalTo('receiver_status', Message::STATUS_NORMAL);
167
        ->and->equalTo('receiver_status', Message::STATUS_NORMAL);
154
        $select->order('id desc');
168
        $select->order('id desc');
155
        $select->limit(1);
169
        $select->limit(1);
Línea 156... Línea 170...
156
        
170
        
-
 
171
        //error_log($select->getSqlString($this->adapter->platform));
-
 
172
        
-
 
173
        $record = $this->executeFetchOneArray($select);
-
 
174
        if($record) {
-
 
175
            return $record['added_on'];
-
 
176
        } 
-
 
177
        
-
 
178
    }
-
 
179
 
-
 
180
    public function fetchLastMessagesByConversationIdAndReceiverCompanyId($conversation_id, $receiver_company_id)
-
 
181
    {
-
 
182
        $select = $this->sql->select(self::_TABLE);
-
 
183
        $select->columns(['added_on' => new Expression('MAX(added_on)')  ]);
-
 
184
        $select->where->equalTo('conversation_id', $conversation_id);
-
 
185
        $select->where->equalTo('receiver_company_id', $receiver_company_id)
-
 
186
        ->and->equalTo('receiver_status', Message::STATUS_NORMAL);
-
 
187
        $select->order('id desc');
-
 
188
        $select->limit(1);
-
 
189
        
Línea 157... Línea 190...
157
        //error_log($select->getSqlString($this->adapter->platform));
190
        //error_log($select->getSqlString($this->adapter->platform));
158
        
191
        
159
        $record = $this->executeFetchOneArray($select);
192
        $record = $this->executeFetchOneArray($select);
160
        if($record) {
193
        if($record) {