src/EventSubscriber/AcoAnomalyTicketAnswerSubscriber.php line 50

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use App\Entity\AcoAnomalyAssessment;
  6. use App\Entity\Elevator;
  7. use App\Entity\Ticket;
  8. use App\FailureDetection\AcoAnomaly\AcoAnomalyAssessmentService;
  9. use App\Workflow\TicketMalfunctionTransitionsAndStates;
  10. use Psr\Log\LoggerInterface;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. use Symfony\Component\Security\Core\Security;
  14. /**
  15.  * Antwortet ein Dienstleister oder Betreiber im Warnungsticket "Stillstandswarnung", wirkt das
  16.  * genauso wie die Bewertung durch den Super-Admin in der AcoAnomalien-Liste:
  17.  *
  18.  *  - "Stillstand bestätigen"  -> Anlage geht auf "Anlage gestört", Störungsticket wird eröffnet
  19.  *  - "Fehlerkennung melden"   -> Verdacht wird geräumt, kein Ticket, Anlagenstatus bleibt
  20.  *
  21.  * Die Wirkung selbst liegt in AcoAnomalyAssessmentService — hier wird nur der Auslöser
  22.  * verdrahtet, damit es für beide Wege genau eine Wahrheit gibt.
  23.  *
  24.  * Bewusst ein eigener Zuhörer statt einer Erweiterung von TransitionEventSubscriber: dort
  25.  * hängen die allgemeinen Ticket-Übergänge, hier ausschließlich die Anomalie-Antworten.
  26.  */
  27. class AcoAnomalyTicketAnswerSubscriber implements EventSubscriberInterface
  28. {
  29.     private $assessmentService;
  30.     private $security;
  31.     private $logger;
  33.     public function __construct(
  34.         AcoAnomalyAssessmentService $assessmentService,
  35.         Security $security,
  36.         LoggerInterface $logger
  37.     ) {
  38.         $this->assessmentService = $assessmentService;
  39.         $this->security = $security;
  40.         $this->logger = $logger;
  41.     }
  43.     public static function getSubscribedEvents(): array
  44.     {
  45.         return [
  46.             'workflow.sa_warning.entered' => 'onWarningAnswered',
  47.         ];
  48.     }
  50.     public function onWarningAnswered($event): void
  51.     {
  52.         $transition = $event->getTransition()->getName();
  54.         if (TicketMalfunctionTransitionsAndStates::TRANS_ANOMALY_CONFIRM === $transition) {
  55.             $result = AcoAnomalyAssessment::RESULT_CONFIRMED;
  56.         } elseif (TicketMalfunctionTransitionsAndStates::TRANS_ANOMALY_FALSE_DETECTION === $transition) {
  57.             $result = AcoAnomalyAssessment::RESULT_FALSE_DETECTION;
  58.         } else {
  59.             return;
  60.         }
  62.         $ticket = $event->getSubject();
  63.         if (!$ticket instanceof Ticket) {
  64.             return;
  65.         }
  67.         $elevator = $ticket->getElevator();
  68.         if (!$elevator instanceof Elevator) {
  69.             return;
  70.         }
  72.         // Läuft überhaupt noch ein unbewerteter Verdacht? Wurde die Episode zwischenzeitlich
  73.         // vom Super-Admin bewertet oder hat sich die Anlage selbst geheilt, bleibt die Antwort
  74.         // wirkungslos — das Ticket geht trotzdem zu, es hat sich ja erledigt.
  75.         $blocked = $this->assessmentService->assessmentBlockedReason($elevator);
  76.         if (null !== $blocked) {
  77.             $this->logger->info(sprintf(
  78.                 'AcoAnomaly: Antwort "%s" auf Ticket %s ohne Wirkung — %s',
  79.                 $transition, $ticket->getTicketId(), $blocked
  80.             ));
  82.             return;
  83.         }
  85.         $user = $this->security->getUser();
  86.         $assessedBy = $user ? (string) $user->getUsername() : 'unbekannt';
  88.         $this->assessmentService->assess($elevator, $result, $assessedBy, $user);
  90.         $this->logger->info(sprintf(
  91.             'AcoAnomaly: Anlage %d über Ticket %s als "%s" bewertet durch %s',
  92.             $elevator->getId(), $ticket->getTicketId(), $result, $assessedBy
  93.         ));
  94.     }
  95. }