mirror of
https://github.com/nerzhul/ocsms.git
synced 2025-06-07 16:06:15 +00:00
Fix SQL table names
This commit is contained in:
parent
224382ce9b
commit
94a7175886
@ -26,7 +26,7 @@ class ConversationStateMapper extends Mapper {
|
|||||||
public function getLast ($userId) {
|
public function getLast ($userId) {
|
||||||
$qb = $this->db->getQueryBuilder();
|
$qb = $this->db->getQueryBuilder();
|
||||||
$qb->selectAlias($qb->createFunction('MAX(int_date)'), 'mx')
|
$qb->selectAlias($qb->createFunction('MAX(int_date)'), 'mx')
|
||||||
->from('ocsms_conversation_read_states')
|
->from('ocsms_conv_r_states')
|
||||||
->where($qb->expr()->andX(
|
->where($qb->expr()->andX(
|
||||||
$qb->expr()->eq('user_id', $qb->createNamedParameter($userId))
|
$qb->expr()->eq('user_id', $qb->createNamedParameter($userId))
|
||||||
));
|
));
|
||||||
@ -42,7 +42,7 @@ class ConversationStateMapper extends Mapper {
|
|||||||
public function getLastForPhoneNumber ($userId, $phoneNumber) {
|
public function getLastForPhoneNumber ($userId, $phoneNumber) {
|
||||||
$qb = $this->db->getQueryBuilder();
|
$qb = $this->db->getQueryBuilder();
|
||||||
$qb->selectAlias($qb->createFunction('MAX(int_date)'), 'mx')
|
$qb->selectAlias($qb->createFunction('MAX(int_date)'), 'mx')
|
||||||
->from('ocsms_conversation_read_states')
|
->from('ocsms_conv_r_states')
|
||||||
->where($qb->expr()->andX(
|
->where($qb->expr()->andX(
|
||||||
$qb->expr()->eq('user_id', $qb->createNamedParameter($userId)),
|
$qb->expr()->eq('user_id', $qb->createNamedParameter($userId)),
|
||||||
$qb->expr()->eq('phone_number', $qb->createNamedParameter($phoneNumber))
|
$qb->expr()->eq('phone_number', $qb->createNamedParameter($phoneNumber))
|
||||||
@ -59,7 +59,7 @@ class ConversationStateMapper extends Mapper {
|
|||||||
public function setLast ($userId, $phoneNumber, $lastDate) {
|
public function setLast ($userId, $phoneNumber, $lastDate) {
|
||||||
$this->db->beginTransaction();
|
$this->db->beginTransaction();
|
||||||
$qb = $this->db->getQueryBuilder();
|
$qb = $this->db->getQueryBuilder();
|
||||||
$qb->delete('ocsms_conversation_read_states')
|
$qb->delete('ocsms_conv_r_states')
|
||||||
->where($qb->expr()->andX(
|
->where($qb->expr()->andX(
|
||||||
$qb->expr()->eq('user_id', $qb->createNamedParameter($userId)),
|
$qb->expr()->eq('user_id', $qb->createNamedParameter($userId)),
|
||||||
$qb->expr()->eq('phone_number', $qb->createNamedParameter($phoneNumber))
|
$qb->expr()->eq('phone_number', $qb->createNamedParameter($phoneNumber))
|
||||||
@ -67,7 +67,7 @@ class ConversationStateMapper extends Mapper {
|
|||||||
$qb->execute();
|
$qb->execute();
|
||||||
|
|
||||||
$qb = $this->db->getQueryBuilder();
|
$qb = $this->db->getQueryBuilder();
|
||||||
$qb->insert('ocsms_conversation_read_states')
|
$qb->insert('ocsms_conv_r_states')
|
||||||
->values(array(
|
->values(array(
|
||||||
'user_id' => $qb->createNamedParameter($userId),
|
'user_id' => $qb->createNamedParameter($userId),
|
||||||
'phone_number' => $qb->createNamedParameter($phoneNumber),
|
'phone_number' => $qb->createNamedParameter($phoneNumber),
|
||||||
|
Loading…
x
Reference in New Issue
Block a user