Revert "Calendar: Refactor Agenda Reminders Script - refs #5145" (#5321)
Angel Fernando Quiroz Campos
1 year ago
committed by
GitHub
parent
544d8adeaf
commit
d1c4e0c753
@ -1,210 +0,0 @@ |
|||||||
<?php |
|
||||||
|
|
||||||
/* For licensing terms, see /license.txt */ |
|
||||||
|
|
||||||
/** |
|
||||||
* This script send notification messages to users that have reminders from an event in their agenda. |
|
||||||
*/ |
|
||||||
require_once __DIR__.'/../../main/inc/global.inc.php'; |
|
||||||
|
|
||||||
|
|
||||||
exit; |
|
||||||
|
|
||||||
if ('true' !== api_get_setting('agenda.agenda_reminders')) { |
|
||||||
exit; |
|
||||||
} |
|
||||||
|
|
||||||
$batchCounter = 0; |
|
||||||
$batchSize = 100; |
|
||||||
|
|
||||||
$agendaCollectiveInvitations = 'true' === api_get_setting('agenda.agenda_collective_invitations'); |
|
||||||
|
|
||||||
$now = new DateTime('now', new DateTimeZone('UTC')); |
|
||||||
|
|
||||||
$em = Database::getManager(); |
|
||||||
$remindersRepo = $em->getRepository(\Chamilo\CoreBundle\Entity\AgendaReminder::class); |
|
||||||
|
|
||||||
$reminders = $remindersRepo->findBy(['sent' => false]); |
|
||||||
|
|
||||||
$senderId = (int) api_get_setting('agenda.agenda_reminders_sender_id'); |
|
||||||
|
|
||||||
if (empty($senderId)) { |
|
||||||
$firstAdmin = current(UserManager::get_all_administrators()); |
|
||||||
$senderId = $firstAdmin['user_id']; |
|
||||||
} |
|
||||||
|
|
||||||
foreach ($reminders as $reminder) { |
|
||||||
|
|
||||||
if ('personal' === $reminder->getType()) { |
|
||||||
$event = $em->getRepository(\Chamilo\CourseBundle\Entity\CCalendarEvent::class)->find($reminder->getEventId()); |
|
||||||
|
|
||||||
if (null === $event) { |
|
||||||
continue; |
|
||||||
} |
|
||||||
|
|
||||||
$notificationDate = clone $event->getStartDate(); |
|
||||||
$notificationDate->sub($reminder->getDateInterval()); |
|
||||||
|
|
||||||
if ($notificationDate > $now) { |
|
||||||
continue; |
|
||||||
} |
|
||||||
|
|
||||||
$eventDetails = []; |
|
||||||
$eventDetails[] = '<p><strong>'.$event->getTitle().'</strong></p>'; |
|
||||||
|
|
||||||
if ($event->isAllDay()) { |
|
||||||
$eventDetails[] = '<p class="small">'.get_lang('AllDay').'</p>'; |
|
||||||
} else { |
|
||||||
$eventDetails[] = sprintf( |
|
||||||
'<p class="small">'.get_lang('FromDateX').'</p>', |
|
||||||
api_get_local_time($event->getStartDate(), null, null, false, true, true) |
|
||||||
); |
|
||||||
|
|
||||||
if (!empty($event->getEnddate())) { |
|
||||||
$eventDetails[] = sprintf( |
|
||||||
'<p class="small">'.get_lang('UntilDateX').'</p>', |
|
||||||
api_get_local_time($event->getEnddate(), null, null, false, true, true) |
|
||||||
); |
|
||||||
} |
|
||||||
} |
|
||||||
|
|
||||||
if (!empty($event->getContent())) { |
|
||||||
$eventDetails[] = $event->getContent(); |
|
||||||
} |
|
||||||
|
|
||||||
$messageSubject = sprintf(get_lang('ReminderXEvent'), $event->getTitle()); |
|
||||||
$messageContent = implode(PHP_EOL, $eventDetails); |
|
||||||
|
|
||||||
MessageManager::send_message_simple( |
|
||||||
$event->getResourceNode()->getCreator()->getId(), |
|
||||||
$messageSubject, |
|
||||||
$messageContent, |
|
||||||
$event->getResourceNode()->getCreator()->getId() |
|
||||||
); |
|
||||||
|
|
||||||
|
|
||||||
$getInviteesForEvent = function ($eventId) use ($em) { |
|
||||||
$event = $em->find(\Chamilo\CourseBundle\Entity\CCalendarEvent::class, $eventId); |
|
||||||
if (!$event) { |
|
||||||
return []; |
|
||||||
} |
|
||||||
|
|
||||||
$resourceLinks = $event->getResourceLinkEntityList(); |
|
||||||
$inviteeList = []; |
|
||||||
foreach ($resourceLinks as $resourceLink) { |
|
||||||
$user = $resourceLink->getUser(); |
|
||||||
if ($user) { |
|
||||||
$inviteeList[] = [ |
|
||||||
'id' => $user->getId(), |
|
||||||
'name' => $user->getFullname(), |
|
||||||
]; |
|
||||||
} |
|
||||||
} |
|
||||||
|
|
||||||
return $inviteeList; |
|
||||||
}; |
|
||||||
|
|
||||||
if ($agendaCollectiveInvitations) { |
|
||||||
$invitees = $getInviteesForEvent($reminder->getEventId()); |
|
||||||
$inviteesIdList = array_column($invitees, 'id'); |
|
||||||
foreach ($inviteesIdList as $userId) { |
|
||||||
MessageManager::send_message_simple( |
|
||||||
$userId, |
|
||||||
$messageSubject, |
|
||||||
$messageContent, |
|
||||||
$event->getResourceNode()->getCreator()->getId() |
|
||||||
); |
|
||||||
} |
|
||||||
} |
|
||||||
} |
|
||||||
|
|
||||||
if ('course' === $reminder->getType()) { |
|
||||||
|
|
||||||
$event = $em->getRepository(\Chamilo\CourseBundle\Entity\CCalendarEvent::class)->find($reminder->getEventId()); |
|
||||||
if (null === $event) { |
|
||||||
continue; |
|
||||||
} |
|
||||||
|
|
||||||
$notificationDate = clone $event->getStartDate(); |
|
||||||
$notificationDate->sub($reminder->getDateInterval()); |
|
||||||
|
|
||||||
if ($notificationDate > $now) { |
|
||||||
continue; |
|
||||||
} |
|
||||||
|
|
||||||
$eventDetails = [ |
|
||||||
sprintf('<p><strong>%s</strong></p>', $event->getTitle()), |
|
||||||
$event->isAllDay() ? '<p class="small">All Day</p>' : sprintf( |
|
||||||
'<p class="small">From %s</p>', |
|
||||||
$event->getStartDate()->format('Y-m-d H:i:s') |
|
||||||
) |
|
||||||
]; |
|
||||||
|
|
||||||
if ($event->getEndDate()) { |
|
||||||
$eventDetails[] = sprintf( |
|
||||||
'<p class="small">Until %s</p>', |
|
||||||
$event->getEndDate()->format('Y-m-d H:i:s') |
|
||||||
); |
|
||||||
} |
|
||||||
|
|
||||||
if ($event->getContent()) { |
|
||||||
$eventDetails[] = $event->getContent(); |
|
||||||
} |
|
||||||
|
|
||||||
if ($event->getComment()) { |
|
||||||
$eventDetails[] = sprintf('<p class="small">%s</p>', $event->getComment()); |
|
||||||
} |
|
||||||
|
|
||||||
$messageSubject = sprintf('Reminder: %s', $event->getTitle()); |
|
||||||
$messageContent = implode(PHP_EOL, $eventDetails); |
|
||||||
|
|
||||||
$resourceLinks = $event->getResourceNode()->getResourceLinks(); |
|
||||||
$userIdList = []; |
|
||||||
$groupUserIdList = []; |
|
||||||
|
|
||||||
foreach ($resourceLinks as $resourceLink) { |
|
||||||
if ($resourceLink->getUser()) { |
|
||||||
$userIdList[] = $resourceLink->getUser()->getId(); |
|
||||||
} elseif ($resourceLink->getGroup()) { |
|
||||||
$groupUsers = GroupManager::get_users($resourceLink->getGroup()->getId(), false, null, null, false, $event->getSessionId()); |
|
||||||
foreach ($groupUsers as $groupUserId) { |
|
||||||
$groupUserIdList[] = $groupUserId; |
|
||||||
} |
|
||||||
} |
|
||||||
} |
|
||||||
|
|
||||||
$userIdList = array_unique($userIdList); |
|
||||||
$groupUserIdList = array_unique($groupUserIdList); |
|
||||||
|
|
||||||
foreach ($userIdList as $userId) { |
|
||||||
MessageManager::send_message_simple( |
|
||||||
$userId, |
|
||||||
$messageSubject, |
|
||||||
$messageContent, |
|
||||||
$senderId |
|
||||||
); |
|
||||||
} |
|
||||||
|
|
||||||
foreach ($groupUserIdList as $groupUserId) { |
|
||||||
MessageManager::send_message_simple( |
|
||||||
$groupUserId, |
|
||||||
$messageSubject, |
|
||||||
$messageContent, |
|
||||||
$senderId |
|
||||||
); |
|
||||||
} |
|
||||||
} |
|
||||||
|
|
||||||
$reminder->setSent(true); |
|
||||||
|
|
||||||
$em->persist($reminder); |
|
||||||
|
|
||||||
$batchCounter++; |
|
||||||
|
|
||||||
if (($batchCounter % $batchSize) === 0) { |
|
||||||
$em->flush(); |
|
||||||
} |
|
||||||
} |
|
||||||
|
|
||||||
$em->flush(); |
|
||||||
$em->clear(); |
|
||||||
@ -1,36 +0,0 @@ |
|||||||
<?php |
|
||||||
|
|
||||||
/* For licensing terms, see /license.txt */ |
|
||||||
|
|
||||||
declare(strict_types=1); |
|
||||||
|
|
||||||
namespace Chamilo\CoreBundle\Controller\Api; |
|
||||||
|
|
||||||
use Chamilo\CoreBundle\Entity\AgendaReminder; |
|
||||||
use Doctrine\ORM\EntityManagerInterface; |
|
||||||
use Symfony\Bundle\FrameworkBundle\Controller\AbstractController; |
|
||||||
use Symfony\Component\HttpFoundation\Request; |
|
||||||
use Symfony\Component\HttpFoundation\Response; |
|
||||||
|
|
||||||
class DeleteRemindersByEventAction extends AbstractController |
|
||||||
{ |
|
||||||
public function __invoke(Request $request, EntityManagerInterface $em): Response |
|
||||||
{ |
|
||||||
$data = json_decode($request->getContent(), true); |
|
||||||
$eventId = $data['eventId'] ?? null; |
|
||||||
|
|
||||||
if (!$eventId) { |
|
||||||
return $this->json(['message' => 'Event ID is required.'], Response::HTTP_BAD_REQUEST); |
|
||||||
} |
|
||||||
|
|
||||||
$repository = $em->getRepository(AgendaReminder::class); |
|
||||||
$reminders = $repository->findBy(['eventId' => $eventId]); |
|
||||||
|
|
||||||
foreach ($reminders as $reminder) { |
|
||||||
$em->remove($reminder); |
|
||||||
} |
|
||||||
$em->flush(); |
|
||||||
|
|
||||||
return $this->json(['message' => 'All reminders for the event have been deleted.']); |
|
||||||
} |
|
||||||
} |
|
||||||
@ -1,65 +0,0 @@ |
|||||||
<?php |
|
||||||
|
|
||||||
/* For licensing terms, see /license.txt */ |
|
||||||
|
|
||||||
declare(strict_types=1); |
|
||||||
|
|
||||||
namespace Chamilo\CoreBundle\State; |
|
||||||
|
|
||||||
use ApiPlatform\Metadata\Operation; |
|
||||||
use ApiPlatform\State\ProcessorInterface; |
|
||||||
use Chamilo\CoreBundle\Entity\AgendaReminder; |
|
||||||
use Chamilo\CourseBundle\Repository\CCalendarEventRepository; |
|
||||||
use Symfony\Component\HttpFoundation\RequestStack; |
|
||||||
use DateInterval; |
|
||||||
use Doctrine\ORM\EntityManagerInterface; |
|
||||||
|
|
||||||
class AgendaReminderProcessor implements ProcessorInterface |
|
||||||
{ |
|
||||||
|
|
||||||
public function __construct( |
|
||||||
private EntityManagerInterface $entityManager, |
|
||||||
private RequestStack $requestStack, |
|
||||||
private CCalendarEventRepository $eventRepository |
|
||||||
) {} |
|
||||||
|
|
||||||
public function process($data, Operation $operation, array $uriVariables = [], array $context = []): AgendaReminder |
|
||||||
{ |
|
||||||
\assert($data instanceof AgendaReminder); |
|
||||||
|
|
||||||
$request = $this->requestStack->getCurrentRequest(); |
|
||||||
if ($request) { |
|
||||||
$payload = json_decode($request->getContent(), true); |
|
||||||
$eventId = $payload['eventId'] ?? null; |
|
||||||
$event = $this->eventRepository->find($eventId); |
|
||||||
|
|
||||||
if (!$event) { |
|
||||||
throw new \Exception("Event not found with ID: $eventId"); |
|
||||||
} |
|
||||||
|
|
||||||
$type = $this->eventRepository->determineEventType($event); |
|
||||||
$data->setType($type); |
|
||||||
$data->setEventId($eventId); |
|
||||||
|
|
||||||
$count = $payload['count'] ?? 0; |
|
||||||
$period = $payload['period'] ?? ''; |
|
||||||
|
|
||||||
$data->setDateInterval($this->convertToInterval((int) $count, $period)); |
|
||||||
} |
|
||||||
|
|
||||||
$this->entityManager->persist($data); |
|
||||||
$this->entityManager->flush(); |
|
||||||
|
|
||||||
return $data; |
|
||||||
} |
|
||||||
|
|
||||||
private function convertToInterval(int $count, string $period): DateInterval |
|
||||||
{ |
|
||||||
return match ($period) { |
|
||||||
'i' => new DateInterval("PT{$count}M"), |
|
||||||
'h' => new DateInterval("PT{$count}H"), |
|
||||||
'd' => new DateInterval("P{$count}D"), |
|
||||||
default => throw new \InvalidArgumentException("Period not valid: $period"), |
|
||||||
}; |
|
||||||
} |
|
||||||
} |
|
||||||
Loading…
Reference in new issue