1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
|
<?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();
}
}
?>
|
