Proyectos de Subversion LeadersLinked - Services

Rev

Rev 1 | Mostrar el archivo completo | | | Autoría | Ultima modificación | Ver Log |

Rev 1 Rev 192
Línea 59... Línea 59...
59
59
60 
        $select = $this->sql->select(self::_TABLE);
 60 
        $select = $this->sql->select(self::_TABLE);
61 
        $select->where->equalTo('group_id', $group_id);
 61 
        $select->where->equalTo('group_id', $group_id);
62 
        $select->where->equalTo('receiver_id', $user_id);
 62 
        $select->where->equalTo('receiver_id', $user_id);
- 
 
 63 
        $select->where->equalTo('seen', ChatGroupUserMessage::SEEN_YES);
- 
 
 64 
        $select->where->equalTo('status', ChatGroupUserMessage::STATUS_PUBLISHED);
- 
 
 65 
        $select->order('added_on DESC');
- 
 
 66 
        $select->limit(1);
- 
 
 67
- 
 
 68 
        return $this->executeFetchOneObject($select, $prototype);
- 
 
 69 
    }
- 
 
 70
- 
 
 71 
    /**
- 
 
 72 
     *
- 
 
 73 
     * @param int $id
- 
 
 74 
     * @param int $user_id
- 
 
 75 
     * @return ChatGroupUserMessage
- 
 
 76 
     */
- 
 
 77 
    public function fetchOneByIdMessageIdAndReceiverId($message_id, $receiver_id)
- 
 
 78 
    {
- 
 
 79
- 
 
 80 
        $prototype = new ChatGroupUserMessage();
- 
 
 81
- 
 
 82 
        $select = $this->sql->select(self::_TABLE);
- 
 
 83 
        $select->where->equalTo('message_id', $message_id);
- 
 
 84 
        $select->where->equalTo('receiver_id', $receiver_id);
- 
 
 85 
        $select->where->equalTo('seen', ChatGroupUserMessage::SEEN_YES);
63 
        $select->where->equalTo('seen', ChatGroupUserMessage::SEEN_YES);
 86 
        $select->where->equalTo('status', ChatGroupUserMessage::STATUS_PUBLISHED);
64 
        $select->order('added_on DESC');
 87 
        $select->order('added_on DESC');
Línea 65... Línea 88...
65 
        $select->limit(1);
 88 
        $select->limit(1);
66
89
Línea 80... Línea 103...
80 
        $select = $this->sql->select(self::_TABLE);
 103 
        $select = $this->sql->select(self::_TABLE);
81 
        $select->columns(['total' => new Expression('COUNT(*)')]);
 104 
        $select->columns(['total' => new Expression('COUNT(*)')]);
82 
        $select->where->equalTo('group_id', $group_id);
 105 
        $select->where->equalTo('group_id', $group_id);
83 
        $select->where->equalTo('receiver_id', $user_id);
 106 
        $select->where->equalTo('receiver_id', $user_id);
84 
        $select->where->equalTo('seen', ChatGroupUserMessage::SEEN_NO);
 107 
        $select->where->equalTo('seen', ChatGroupUserMessage::SEEN_NO);
85 
 
 - 
 
- 
 
 108 
        $select->where->equalTo('status', ChatGroupUserMessage::STATUS_PUBLISHED);
Línea 86... Línea 109...
86
109
87 
        $record = $this->executeFetchOneArray($select);
 110 
        $record = $this->executeFetchOneArray($select);
Línea 88... Línea 111...
88 
        return $record['total'];
 111 
        return $record['total'];
Línea 101... Línea 124...
101 
        $select = $this->sql->select(self::_TABLE);
 124 
        $select = $this->sql->select(self::_TABLE);
102 
        $select->columns(['total' => new Expression('COUNT(*)')]);
 125 
        $select->columns(['total' => new Expression('COUNT(*)')]);
103 
        $select->where->equalTo('group_id', $group_id);
 126 
        $select->where->equalTo('group_id', $group_id);
104 
        $select->where->equalTo('receiver_id', $user_id);
 127 
        $select->where->equalTo('receiver_id', $user_id);
105 
        $select->where->equalTo('recd', ChatGroupUserMessage::RECD_NO);
 128 
        $select->where->equalTo('recd', ChatGroupUserMessage::RECD_NO);
- 
 
 129 
        $select->where->equalTo('status', ChatGroupUserMessage::STATUS_PUBLISHED);
Línea 106... Línea 130...
106 
 
 130 
 
107
131
Línea 124... Línea 148...
124
148
125 
        $select = $this->sql->select(self::_TABLE);
 149 
        $select = $this->sql->select(self::_TABLE);
126 
        $select->where->equalTo('group_id', $group_id);
 150 
        $select->where->equalTo('group_id', $group_id);
127 
        $select->where->equalTo('receiver_id', $user_id);
 151 
        $select->where->equalTo('receiver_id', $user_id);
- 
 
 152 
        $select->where->equalTo('seen', ChatGroupUserMessage::SEEN_NO);
128 
        $select->where->equalTo('seen', ChatGroupUserMessage::SEEN_NO);
 153 
        $select->where->equalTo('status', ChatGroupUserMessage::STATUS_PUBLISHED);
Línea 129... Línea 154...
129 
        $select->limit(1);
 154 
        $select->limit(1);
130 
 
 155 
 
Línea 145... Línea 170...
145
170
146 
        $select = $this->sql->select(self::_TABLE);
 171 
        $select = $this->sql->select(self::_TABLE);
147 
        $select->where->equalTo('group_id', $group_id);
 172 
        $select->where->equalTo('group_id', $group_id);
148 
        $select->where->equalTo('receiver_id', $user_id);
 173 
        $select->where->equalTo('receiver_id', $user_id);
- 
 
 174 
        $select->where->equalTo('recd', ChatGroupUserMessage::RECD_NO);
149 
        $select->where->equalTo('recd', ChatGroupUserMessage::RECD_NO);
 175 
        $select->where->equalTo('status', ChatGroupUserMessage::STATUS_PUBLISHED);
Línea 150... Línea 176...
150 
        $select->limit(1);
 176 
        $select->limit(1);
151
177
Línea 165... Línea 191...
165 
        $update = $this->sql->update(self::_TABLE);
 191 
        $update = $this->sql->update(self::_TABLE);
166 
        $update->set(['recd' => ChatGroupUserMessage::RECD_YES]);
 192 
        $update->set(['recd' => ChatGroupUserMessage::RECD_YES]);
167 
        $update->where->equalTo('group_id', $group_id);
 193 
        $update->where->equalTo('group_id', $group_id);
168 
        $update->where->equalTo('receiver_id', $user_id);;
 194 
        $update->where->equalTo('receiver_id', $user_id);;
169 
        $update->where->equalTo('recd', ChatGroupUserMessage::RECD_NO);
 195 
        $update->where->equalTo('recd', ChatGroupUserMessage::RECD_NO);
- 
 
 196 
        $update->where->equalTo('status', ChatGroupUserMessage::STATUS_PUBLISHED);
Línea 170... Línea 197...
170
197
Línea 171... Línea 198...
171 
       // echo $update->getSqlString($this->adapter->platform);
 198 
       // echo $update->getSqlString($this->adapter->platform);
172 
 
 199 
 
Línea 184... Línea 211...
184 
        $update = $this->sql->update(self::_TABLE);
 211 
        $update = $this->sql->update(self::_TABLE);
185 
        $update->set(['recd' => ChatGroupUserMessage::RECD_YES, 'seen' => ChatGroupUserMessage::SEEN_YES]);
 212 
        $update->set(['recd' => ChatGroupUserMessage::RECD_YES, 'seen' => ChatGroupUserMessage::SEEN_YES]);
186 
        $update->where->equalTo('group_id', $group_id);
 213 
        $update->where->equalTo('group_id', $group_id);
187 
        $update->where->equalTo('receiver_id', $user_id);;
 214 
        $update->where->equalTo('receiver_id', $user_id);;
188 
        $update->where->equalTo('seen', ChatGroupUserMessage::SEEN_NO);
 215 
        $update->where->equalTo('seen', ChatGroupUserMessage::SEEN_NO);
189
- 
 
- 
 
 216 
        $update->where->equalTo('status', ChatGroupUserMessage::STATUS_PUBLISHED);
Línea 190... Línea 217...
190
217
191 
        return $this->executeUpdate($update);
 218 
        return $this->executeUpdate($update);
Línea 192... Línea 219...
192 
    }
 219 
    }
Línea 218... Línea 245...
218 
    }
 245 
    }
219 
    */
 246 
    */
Línea 220... Línea 247...
220
247
221 
    public function deleteAllByGroupId($group_id)
 248 
    public function deleteAllByGroupId($group_id)
222 
    {
 249 
    {
- 
 
 250 
        $update = $this->sql->update(self::_TABLE);
- 
 
 251 
        $update->set([
- 
 
 252 
            'status' => ChatGroupUserMessage::STATUS_DELETED,
223 
        $delete = $this->sql->delete(self::_TABLE);
 253 
        ]);
- 
 
 254 
        $update->where->equalTo('group_id', $group_id);
Línea 224... Línea 255...
224 
        $delete->where->equalTo('group_id', $group_id);
 255 
        $update->where->equalTo('status', ChatGroupUserMessage::STATUS_PUBLISHED);
Línea 225... Línea 256...
225
256
- 
 
 257 
        //echo $delete->getSqlString($this->adapter->platform); exit;
- 
 
 258
- 
 
 259 
        return $this->executeUpdate($update);
- 
 
 260 
    }
- 
 
 261
- 
 
 262 
    /**
- 
 
 263 
     *
- 
 
 264 
     * @param int $group_id
- 
 
 265 
     * @param int $user_id
- 
 
 266 
     * @return boolean
- 
 
 267 
     */
- 
 
 268 
    public function markAsReportedByGroupIdAndUserId($group_id, $user_id)
- 
 
 269 
    {
- 
 
 270 
        $update = $this->sql->update(self::_TABLE);
- 
 
 271 
        $update->set(['status' => ChatGroupUserMessage::STATUS_REPORTED]);
- 
 
 272 
        $update->where->equalTo('group_id', $group_id);
- 
 
 273 
        $update->where->equalTo('receiver_id', $user_id);;
- 
 
 274 
        $update->where->equalTo('seen', ChatGroupUserMessage::SEEN_NO);
226 
        //echo $delete->getSqlString($this->adapter->platform); exit;
 275 
        $update->where->equalTo('status', ChatGroupUserMessage::STATUS_PUBLISHED);
Línea 227... Línea 276...
227
276
228 
        return $this->executeDelete($delete);
 277 
        return $this->executeUpdate($update);