File manager

File manager - Edit - /home/premiey/www/wp-content/plugins/ameliabooking/src/Infrastructure/Repository/Notification/NotificationSMSHistoryRepository.php

Back
<?php namespace AmeliaBooking\Infrastructure\Repository\Notification; use AmeliaBooking\Domain\Services\DateTime\DateTimeService; use AmeliaBooking\Infrastructure\Common\Exceptions\QueryExecutionException; use AmeliaBooking\Infrastructure\Repository\AbstractRepository; use AmeliaBooking\Infrastructure\WP\InstallActions\DB\User\UsersTable; /** * Class NotificationSMSHistoryRepository * * @package AmeliaBooking\Infrastructure\Repository\Notification / class NotificationSMSHistoryRepository extends AbstractRepository { /* * @param $data * * @return bool * * @throws QueryExecutionException * @throws \Exception / public function add($data) { $params = [ ':notificationId' => $data['notificationId'], ':userId' => $data['userId'], ':appointmentId' => !empty($data['appointmentId']) ? $data['appointmentId'] : null, ':eventId' => !empty($data['eventId']) ? $data['eventId'] : null, ':packageCustomerId' => !empty($data['packageCustomerId']) ? $data['packageCustomerId'] : null, ':text' => $data['text'], ':phone' => $data['phone'], ':alphaSenderId' => $data['alphaSenderId'] ]; try { $statement = $this->connection->prepare( "INSERT INTO {$this->table} ( `notificationId`, `userId`, `appointmentId`, `eventId`, `packageCustomerId`, `text`, `phone`, `alphaSenderId` ) VALUES ( :notificationId, :userId, :appointmentId, :eventId, :packageCustomerId, :text, :phone, :alphaSenderId )" ); $res = $statement->execute($params); if (!$res) { throw new QueryExecutionException('Unable to add data in ' . __CLASS__); } return $this->connection->lastInsertId(); } catch (\Exception $e) { throw new QueryExecutionException('Unable to add data in ' . __CLASS__, $e->getCode(), $e); } } /* * @param $id * @param $data * * @return bool * @throws QueryExecutionException / public function update($id, $data) { $params = [ ':logId' => $data['logId'], ':dateTime' => $data['dateTime'], ':status' => $data['status'], ':price' => $data['price'], ':segments' => $data['segments'], ':id' => $id ]; try { $statement = $this->connection->prepare( "UPDATE {$this->table} SET `logId` = COALESCE(:logId, `logId`), `dateTime` = COALESCE(:dateTime, `dateTime`), `status` = COALESCE(:status, `status`), `price` = COALESCE(:price, `price`), `segments` = COALESCE(:segments, `segments`) WHERE id = :id" ); $res = $statement->execute($params); if (!$res) { throw new QueryExecutionException('Unable to save data in ' . __CLASS__); } return $res; } catch (\Exception $e) { throw new QueryExecutionException('Unable to save data in ' . __CLASS__, $e->getCode(), $e); } } /* * @param int $id * * @return array * @throws QueryExecutionException / public function getById($id) { try { $statement = $this->connection->prepare( $this->selectQuery() . " WHERE id = :id" ); $params = [ ':id' => $id, ]; $statement->execute($params); $row = $statement->fetch(); } catch (\Exception $e) { throw new QueryExecutionException('Unable to find by id in ' . __CLASS__, $e->getCode(), $e); } if (!$row) { return null; } return $row; } /* * @param $criteria * @param $itemsPerPage * * @return array * @throws QueryExecutionException / public function getFiltered($criteria, $itemsPerPage) { try { $params = []; $where = []; if (!empty($criteria['dates'])) { $where[] = "(DATE_FORMAT(h.dateTime, '%Y-%m-%d %H:%i:%s') BETWEEN :dateFrom AND :dateTo)"; $params[':dateFrom'] = DateTimeService::getCustomDateTimeInUtc($criteria['dates'][0]); $params[':dateTo'] = DateTimeService::getCustomDateTimeObjectInUtc( $criteria['dates'][1] )->modify('+1 day')->format('Y-m-d H:i:s'); } $where = $where ? ' AND ' . implode(' AND ', $where) : ''; $limit = $this->getLimit( !empty($criteria['page']) ? (int)$criteria['page'] : 0, (int)$itemsPerPage ); $usersTable = UsersTable::getTableName(); $statement = $this->connection->prepare( "SELECT h., CONCAT(u.firstName, ' ', u.lastName) as userFullName FROM {$this->table} h LEFT JOIN {$usersTable} u ON h.userId = u.id WHERE 1=1 $where ORDER BY h.id DESC {$limit}" ); $statement->execute($params); $rows = $statement->fetchAll(); foreach ($rows as &$row) { $row['dateTime'] = DateTimeService::getCustomDateTimeFromUtc($row['dateTime']); } } catch (\Exception $e) { throw new QueryExecutionException('Unable to get data from ' . __CLASS__, $e->getCode(), $e); } return $rows; } /** * @param $criteria * * @return mixed * @throws QueryExecutionException / public function getCount($criteria) { try { $params = []; $where = []; if (!empty($criteria['dates'])) { $where[] = "(DATE_FORMAT(h.dateTime, '%Y-%m-%d %H:%i:%s') BETWEEN :dateFrom AND :dateTo)"; $params[':dateFrom'] = DateTimeService::getCustomDateTimeInUtc($criteria['dates'][0]); $params[':dateTo'] = DateTimeService::getCustomDateTimeObjectInUtc( $criteria['dates'][1] )->modify('+1 day')->format('Y-m-d H:i:s'); } $where = $where ? ' AND ' . implode(' AND ', $where) : ''; $statement = $this->connection->prepare( "SELECT COUNT() AS count FROM {$this->table} h WHERE 1=1 {$where}" ); $statement->execute($params); $row = $statement->fetch()['count']; } catch (\Exception $e) { throw new QueryExecutionException('Unable to get data from ' . __CLASS__, $e->getCode(), $e); } return $row; } }

| ver. 1.4 | Github | . | PHP 5.4.45 | Generation time: 0 | proxy | phpinfo | Settings