6b528c34a4
[+|-] location ( location.name) [+|-] track ( track.title) Change-Id: I1a4e507b56d958c36327aa5fc8584705ac03bd17
351 lines
13 KiB
PHP
351 lines
13 KiB
PHP
<?php namespace App\Repositories\Summit;
|
|
/**
|
|
* Copyright 2016 OpenStack Foundation
|
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
* you may not use this file except in compliance with the License.
|
|
* You may obtain a copy of the License at
|
|
* http://www.apache.org/licenses/LICENSE-2.0
|
|
* Unless required by applicable law or agreed to in writing, software
|
|
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
* See the License for the specific language governing permissions and
|
|
* limitations under the License.
|
|
**/
|
|
use App\Models\Foundation\Main\IGroup;
|
|
use Doctrine\ORM\Tools\Pagination\Paginator;
|
|
use models\summit\ISummitEventRepository;
|
|
use models\summit\SummitEvent;
|
|
use App\Repositories\SilverStripeDoctrineRepository;
|
|
use utils\DoctrineCaseFilterMapping;
|
|
use utils\DoctrineFilterMapping;
|
|
use utils\DoctrineJoinFilterMapping;
|
|
use utils\DoctrineSwitchFilterMapping;
|
|
use utils\Filter;
|
|
use utils\Order;
|
|
use utils\PagingInfo;
|
|
use utils\PagingResponse;
|
|
use Doctrine\ORM\Query\Expr\Join;
|
|
use utils\DoctrineLeftJoinFilterMapping;
|
|
use models\summit\SummitGroupEvent;
|
|
/**
|
|
* Class DoctrineSummitEventRepository
|
|
* @package App\Repositories\Summit
|
|
*/
|
|
final class DoctrineSummitEventRepository
|
|
extends SilverStripeDoctrineRepository
|
|
implements ISummitEventRepository
|
|
{
|
|
|
|
|
|
private static $forbidden_classes = [
|
|
SummitGroupEvent::ClassName,
|
|
];
|
|
|
|
/**
|
|
* @param SummitEvent $event
|
|
* @return SummitEvent[]
|
|
*/
|
|
public function getPublishedOnSameTimeFrame(SummitEvent $event)
|
|
{
|
|
$summit = $event->getSummit();
|
|
$end_date = $event->getEndDate();
|
|
$start_date = $event->getStartDate();
|
|
|
|
$query = $this->getEntityManager()->createQueryBuilder()
|
|
->select("e")
|
|
->from(\models\summit\SummitEvent::class, "e")
|
|
->join('e.summit', 's', Join::WITH, " s.id = :summit_id")
|
|
->where('e.published = 1')
|
|
->andWhere('e.start_date < :end_date')
|
|
->andWhere('e.end_date > :start_date')
|
|
->setParameter('summit_id', $summit->getId())
|
|
->setParameter('start_date', $start_date)
|
|
->setParameter('end_date', $end_date);
|
|
|
|
$idx = 1;
|
|
foreach(self::$forbidden_classes as $forbidden_class){
|
|
$query = $query
|
|
->andWhere("not e INSTANCE OF :forbidden_class".$idx);
|
|
$query->setParameter("forbidden_class".$idx, $forbidden_class);
|
|
$idx++;
|
|
}
|
|
|
|
return $query->getQuery()->getResult();
|
|
}
|
|
|
|
/**
|
|
* @return array
|
|
*/
|
|
protected function getFilterMappings()
|
|
{
|
|
return [
|
|
'id' => 'e.id:json_int',
|
|
'title' => 'e.title:json_string',
|
|
'abstract' => 'e.abstract:json_string',
|
|
'social_summary' => 'e.social_summary:json_string',
|
|
'published' => 'e.published',
|
|
'start_date' => 'e.start_date:datetime_epoch',
|
|
'end_date' => 'e.end_date:datetime_epoch',
|
|
'tags' => new DoctrineLeftJoinFilterMapping
|
|
(
|
|
'e.tags',
|
|
't',
|
|
"t.tag :operator ':value'"
|
|
),
|
|
'summit_id'=> new DoctrineJoinFilterMapping
|
|
(
|
|
'e.summit',
|
|
's',
|
|
"s.id :operator :value"
|
|
),
|
|
'event_type_id' => new DoctrineJoinFilterMapping
|
|
(
|
|
'e.type',
|
|
'et',
|
|
"et.id :operator :value"
|
|
),
|
|
'track_id' => new DoctrineJoinFilterMapping
|
|
(
|
|
'e.category',
|
|
'c',
|
|
"c.id :operator :value"
|
|
),
|
|
'location_id' => new DoctrineLeftJoinFilterMapping
|
|
(
|
|
'e.location',
|
|
'l',
|
|
"l.id :operator :value"
|
|
),
|
|
'speaker' => new DoctrineFilterMapping
|
|
(
|
|
"( concat(sp.first_name, ' ', sp.last_name) :operator ':value' ".
|
|
"OR concat(spm.first_name, ' ', spm.last_name) :operator ':value' ".
|
|
"OR concat(spmm.first_name, ' ', spmm.last_name) :operator ':value' ".
|
|
"OR sp.first_name :operator ':value' ".
|
|
"OR sp.last_name :operator ':value' ".
|
|
"OR spm.first_name :operator ':value' ".
|
|
"OR spm.last_name :operator ':value' ".
|
|
"OR spmm.first_name :operator ':value' ".
|
|
"OR spmm.last_name :operator ':value' )"
|
|
),
|
|
'speaker_email' => new DoctrineFilterMapping
|
|
(
|
|
"(sprr.email :operator ':value' OR spmm.email :operator ':value')"
|
|
),
|
|
'speaker_id' => new DoctrineFilterMapping
|
|
(
|
|
"(sp.id :operator :value OR spm.id :operator :value)"
|
|
),
|
|
'selection_status' => new DoctrineSwitchFilterMapping([
|
|
'selected' => new DoctrineCaseFilterMapping(
|
|
'selected',
|
|
"ssp.order is not null and sspl.list_type = 'Group' and sspl.category = e.category"
|
|
),
|
|
'accepted' => new DoctrineCaseFilterMapping(
|
|
'accepted',
|
|
"ssp.order is not null and ssp.order <= cc.session_count and sspl.list_type = 'Group' and sspl.list_class = 'Session' and sspl.category = e.category"
|
|
),
|
|
'alternate' => new DoctrineCaseFilterMapping(
|
|
'alternate',
|
|
"ssp.order is not null and ssp.order > cc.session_count and sspl.list_type = 'Group' and sspl.list_class = 'Session' and sspl.category = e.category"
|
|
),
|
|
'lightning-accepted' => new DoctrineCaseFilterMapping(
|
|
'lightning-accepted',
|
|
"ssp.order is not null and ssp.order <= cc.lightning_count and sspl.list_type = 'Group' and sspl.list_class = 'Lightning' and sspl.category = e.category"
|
|
),
|
|
'lightning-alternate' => new DoctrineCaseFilterMapping(
|
|
'lightning-alternate',
|
|
"ssp.order is not null and ssp.order > cc.lightning_count and sspl.list_type = 'Group' and sspl.list_class = 'Lightning' and sspl.category = e.category"
|
|
),
|
|
]
|
|
),
|
|
];
|
|
}
|
|
|
|
/**
|
|
* @return array
|
|
*/
|
|
protected function getOrderMappings()
|
|
{
|
|
return [
|
|
'title' => 'e.title',
|
|
'id' => 'e.id',
|
|
'start_date' => 'e.start_date',
|
|
'end_date' => 'e.end_date',
|
|
'created' => 'e.created',
|
|
'track' => 'cc.title',
|
|
'location' => 'l.name',
|
|
];
|
|
}
|
|
|
|
/**
|
|
* @param PagingInfo $paging_info
|
|
* @param Filter|null $filter
|
|
* @param Order|null $order
|
|
* @return PagingResponse
|
|
*/
|
|
public function getAllByPage(PagingInfo $paging_info, Filter $filter = null, Order $order = null)
|
|
{
|
|
$class = $filter->hasFilter('speaker')
|
|
|| $filter->hasFilter('speaker_id')
|
|
|| $filter->hasFilter('selection_status')
|
|
|| $filter->hasFilter('speaker_email')?
|
|
\models\summit\Presentation::class:
|
|
\models\summit\SummitEvent::class;
|
|
|
|
$query = $this->getEntityManager()->createQueryBuilder()
|
|
->select("e")
|
|
->from($class, "e")
|
|
->leftJoin("e.location", 'l', Join::LEFT_JOIN)
|
|
->leftJoin("e.category", 'cc', Join::LEFT_JOIN)
|
|
;
|
|
|
|
if(!is_null($filter)){
|
|
$filter->apply2Query($query, $this->getFilterMappings());
|
|
}
|
|
|
|
if (!is_null($order)) {
|
|
$order->apply2Query($query, $this->getOrderMappings());
|
|
} else {
|
|
//default order
|
|
$query = $query->addOrderBy("e.start_date",'ASC');
|
|
$query = $query->addOrderBy("e.end_date", 'ASC');
|
|
}
|
|
|
|
if($class == \models\summit\Presentation::class) {
|
|
$query = $query->leftJoin("e.speakers", "sp", Join::WITH);
|
|
$query = $query->leftJoin('e.selected_presentations', "ssp", Join::LEFT_JOIN);
|
|
$query = $query->leftJoin('ssp.list', "sspl", Join::LEFT_JOIN);
|
|
$query = $query->leftJoin('e.moderator', "spm", Join::LEFT_JOIN);
|
|
$query = $query->leftJoin('sp.member', "spmm", Join::LEFT_JOIN);
|
|
$query = $query->leftJoin('sp.registration_request', "sprr", Join::LEFT_JOIN);
|
|
}
|
|
|
|
$can_view_private_events = self::isCurrentMemberOnGroup(IGroup::SummitAdministrators);
|
|
|
|
if(!$can_view_private_events){
|
|
$idx = 1;
|
|
foreach(self::$forbidden_classes as $forbidden_class){
|
|
$query = $query
|
|
->andWhere("not e INSTANCE OF :forbidden_class".$idx);
|
|
$query->setParameter("forbidden_class".$idx, $forbidden_class);
|
|
$idx++;
|
|
}
|
|
}
|
|
|
|
$query = $query
|
|
->setFirstResult($paging_info->getOffset())
|
|
->setMaxResults($paging_info->getPerPage());
|
|
|
|
$paginator = new Paginator($query, $fetchJoinCollection = true);
|
|
$total = $paginator->count();
|
|
$data = [];
|
|
|
|
foreach($paginator as $entity)
|
|
$data[]= $entity;
|
|
|
|
return new PagingResponse
|
|
(
|
|
$total,
|
|
$paging_info->getPerPage(),
|
|
$paging_info->getCurrentPage(),
|
|
$paging_info->getLastPage($total),
|
|
$data
|
|
);
|
|
}
|
|
|
|
/**
|
|
* @param int $event_id
|
|
*/
|
|
public function cleanupScheduleAndFavoritesForEvent($event_id){
|
|
|
|
$query = "DELETE Member_Schedule FROM Member_Schedule WHERE SummitEventID = {$event_id};";
|
|
$this->_em->getConnection()->executeUpdate($query);
|
|
|
|
$query = "DELETE `Member_FavoriteSummitEvents` FROM `Member_FavoriteSummitEvents` WHERE SummitEventID = {$event_id};";
|
|
$this->_em->getConnection()->executeUpdate($query);
|
|
}
|
|
|
|
/**
|
|
* @return string
|
|
*/
|
|
protected function getBaseEntity()
|
|
{
|
|
return SummitEvent::class;
|
|
}
|
|
|
|
/**
|
|
* @param PagingInfo $paging_info
|
|
* @param Filter|null $filter
|
|
* @param Order|null $order
|
|
* @return PagingResponse
|
|
*/
|
|
public function getAllByPageLocationTBD(PagingInfo $paging_info, Filter $filter = null, Order $order = null)
|
|
{
|
|
$class = $filter->hasFilter('speaker')
|
|
|| $filter->hasFilter('selection_status')
|
|
|| $filter->hasFilter('speaker_email')?
|
|
\models\summit\Presentation::class:
|
|
\models\summit\SummitEvent::class;
|
|
|
|
$query = $this->getEntityManager()->createQueryBuilder()
|
|
->select("e")
|
|
->from($class, "e")
|
|
->leftJoin("e.location", 'l', Join::LEFT_JOIN)
|
|
->leftJoin("e.category", 'cc', Join::LEFT_JOIN)
|
|
->where("l.id is null");
|
|
|
|
if(!is_null($filter)){
|
|
$filter->apply2Query($query, $this->getFilterMappings());
|
|
}
|
|
|
|
if (!is_null($order)) {
|
|
$order->apply2Query($query, $this->getOrderMappings());
|
|
} else {
|
|
//default order
|
|
$query = $query->addOrderBy("e.start_date",'ASC');
|
|
$query = $query->addOrderBy("e.end_date", 'ASC');
|
|
}
|
|
|
|
if($class == \models\summit\Presentation::class) {
|
|
$query = $query->leftJoin("e.speakers", "sp", Join::WITH);
|
|
$query = $query->leftJoin('e.selected_presentations', "ssp", Join::LEFT_JOIN);
|
|
$query = $query->leftJoin('ssp.list', "sspl", Join::LEFT_JOIN);
|
|
$query = $query->leftJoin('e.moderator', "spm", Join::LEFT_JOIN);
|
|
$query = $query->leftJoin('sp.member', "spmm", Join::LEFT_JOIN);
|
|
$query = $query->leftJoin('sp.registration_request', "sprr", Join::LEFT_JOIN);
|
|
}
|
|
|
|
$can_view_private_events = self::isCurrentMemberOnGroup(IGroup::SummitAdministrators);
|
|
|
|
if(!$can_view_private_events){
|
|
$idx = 1;
|
|
foreach(self::$forbidden_classes as $forbidden_class){
|
|
$query = $query
|
|
->andWhere("not e INSTANCE OF :forbidden_class".$idx);
|
|
$query->setParameter("forbidden_class".$idx, $forbidden_class);
|
|
$idx++;
|
|
}
|
|
}
|
|
|
|
$query = $query
|
|
->setFirstResult($paging_info->getOffset())
|
|
->setMaxResults($paging_info->getPerPage());
|
|
|
|
$paginator = new Paginator($query, $fetchJoinCollection = true);
|
|
$total = $paginator->count();
|
|
$data = [];
|
|
|
|
foreach($paginator as $entity)
|
|
$data[]= $entity;
|
|
|
|
return new PagingResponse
|
|
(
|
|
$total,
|
|
$paging_info->getPerPage(),
|
|
$paging_info->getCurrentPage(),
|
|
$paging_info->getLastPage($total),
|
|
$data
|
|
);
|
|
}
|
|
} |