mirror of
https://github.com/nerzhul/ocsms.git
synced 2025-10-31 02:17:38 +00:00
103 lines
2.7 KiB
PHP
103 lines
2.7 KiB
PHP
<?php
|
|
/**
|
|
* Nextcloud - Phone Sync
|
|
*
|
|
* This file is licensed under the Affero General Public License version 3 or
|
|
* later. See the COPYING file.
|
|
*
|
|
* @author Loic Blot <loic.blot@unix-experience.fr>
|
|
* @copyright Loic Blot 2014-2017
|
|
*/
|
|
|
|
namespace OCA\OcSms\Db;
|
|
|
|
use \OCP\IDBConnection;
|
|
|
|
use \OCP\AppFramework\Db\Mapper;
|
|
|
|
use \OCA\OcSms\AppInfo\OcSmsApp;
|
|
use \OCA\OcSms\Lib\PhoneNumberFormatter;
|
|
|
|
class ConversationStateMapper extends Mapper {
|
|
public function __construct (IDBConnection $db) {
|
|
parent::__construct($db, 'ocsms_smsdatas');
|
|
}
|
|
|
|
public function getLast ($userId) {
|
|
$qb = $this->db->getQueryBuilder();
|
|
$qb->selectAlias($qb->createFunction('MAX(int_date)'), 'mx')
|
|
->from('ocsms_conversation_read_states')
|
|
->where($qb->expr()->andX(
|
|
$qb->expr()->eq('user_id', $qb->createNamedParameter($userId))
|
|
));
|
|
$result = $qb->execute();
|
|
|
|
if ($row = $result->fetch()) {
|
|
return $row["mx"];
|
|
}
|
|
|
|
return 0;
|
|
}
|
|
|
|
public function getLastForPhoneNumber ($userId, $phoneNumber) {
|
|
$qb = $this->db->getQueryBuilder();
|
|
$qb->selectAlias($qb->createFunction('MAX(int_date)'), 'mx')
|
|
->from('ocsms_conversation_read_states')
|
|
->where($qb->expr()->andX(
|
|
$qb->expr()->eq('user_id', $qb->createNamedParameter($userId)),
|
|
$qb->expr()->eq('phone_number', $qb->createNamedParameter($phoneNumber))
|
|
));
|
|
$result = $qb->execute();
|
|
|
|
if ($row = $result->fetch()) {
|
|
return $row["mx"];
|
|
}
|
|
|
|
return 0;
|
|
}
|
|
|
|
public function setLast ($userId, $phoneNumber, $lastDate) {
|
|
$this->db->beginTransaction();
|
|
$qb = $this->db->getQueryBuilder();
|
|
$qb->delete('ocsms_conversation_read_states')
|
|
->where($qb->expr()->andX(
|
|
$qb->expr()->eq('user_id', $qb->createNamedParameter($userId)),
|
|
$qb->expr()->eq('phone_number', $qb->createNamedParameter($phoneNumber))
|
|
));
|
|
$qb->execute();
|
|
|
|
$qb = $this->db->getQueryBuilder();
|
|
$qb->insert('ocsms_conversation_read_states')
|
|
->values(array(
|
|
'user_id' => $qb->createNamedParameter($userId),
|
|
'phone_number' => $qb->createNamedParameter($phoneNumber),
|
|
'int_date' => $qb->createNamedParameter($lastDate)
|
|
));
|
|
$this->db->commit();
|
|
}
|
|
|
|
/*
|
|
* Migration steps
|
|
*/
|
|
|
|
public function migrate () {
|
|
$qb = $this->db->getQueryBuilder();
|
|
$qb->select('user_id', 'datakey', 'datavalue')
|
|
->from('ocsms_user_datas')
|
|
->where($qb->expr()->like('datakey', $qb->createNamedParameter('lastReadDate-%')));
|
|
|
|
$result = $qb->execute();
|
|
while($row = $result->fetch()) {
|
|
$pn = preg_replace("#lastReadDate[-]#", "", $row["datakey"]);
|
|
$this->setLast($row["user_id"], $pn, $row["datavalue"]);
|
|
};
|
|
|
|
$qb = $this->db->getQueryBuilder();
|
|
$qb->delete('ocsms_user_datas')
|
|
->where($qb->expr()->like('datakey', $qb->createNamedParameter('lastReadDate-%')));
|
|
$qb->execute();
|
|
}
|
|
}
|
|
|
|
?>
|