src/Diplix/KMGBundle/Controller/Dispatching/DashboardController.php line 429

Open in your IDE?
  1. <?php
  2. namespace Diplix\KMGBundle\Controller\Dispatching;
  3. use Diplix\Commons\DataHandlingBundle\Entity\SysLogEntry;
  4. use Diplix\Commons\DataHandlingBundle\Repository\SysLogRepository;
  5. use Diplix\KMGBundle\Controller\BaseController;
  6. use Diplix\KMGBundle\Controller\Service\Api2Controller;
  7. use Diplix\KMGBundle\DataTables\DataTablesHelper;
  8. use Diplix\KMGBundle\Entity\Accounting\Billing;
  9. use Diplix\KMGBundle\Entity\Accounting\CoopMember;
  10. use Diplix\KMGBundle\Entity\Accounting\Job;
  11. use Diplix\KMGBundle\Entity\Accounting\JobInterestExpression;
  12. use Diplix\KMGBundle\Entity\Address;
  13. use Diplix\KMGBundle\Entity\Availability;
  14. use Diplix\KMGBundle\Entity\Dispatching\ChatMessage;
  15. use Diplix\KMGBundle\Entity\Dispatching\DispatchQueueItem;
  16. use Diplix\KMGBundle\Entity\Note;
  17. use Diplix\KMGBundle\Entity\Order;
  18. use Diplix\KMGBundle\Entity\OrderStatus;
  19. use Diplix\KMGBundle\Entity\Platform\PlatformClient;
  20. use Diplix\KMGBundle\Entity\Role;
  21. use Diplix\KMGBundle\Entity\Setting;
  22. use Diplix\KMGBundle\Entity\User;
  23. use Diplix\KMGBundle\Form\Dispatching\NoteDoneForm;
  24. use Diplix\KMGBundle\Form\Dispatching\NoteForm;
  25. use Diplix\KMGBundle\Form\Dispatching\OrderDispatchStatusForm;
  26. use Diplix\KMGBundle\Helper\ChatMessageNormalizer;
  27. use Diplix\KMGBundle\Helper\SimpleFileNormalizer;
  28. use Diplix\KMGBundle\Repository\OrderRepository;
  29. use Diplix\KMGBundle\Service\ArrayLogWrapper;
  30. use Diplix\KMGBundle\Service\JobAllocator;
  31. use Diplix\KMGBundle\Service\MobileNotifier;
  32. use Diplix\KMGBundle\Service\Notifier;
  33. use Diplix\KMGBundle\Service\OrderHandler;
  34. use Doctrine\ORM\AbstractQuery;
  35. use Doctrine\ORM\EntityRepository;
  36. use Doctrine\ORM\QueryBuilder;
  37. use Doctrine\ORM\Tools\Pagination\Paginator;
  39. use Liip\ImagineBundle\Imagine\Cache\CacheManager;
  40. use PhpImap\Mailbox;
  41. use SecIT\ImapBundle\Service\Imap;
  42. use Symfony\Component\HttpFoundation\JsonResponse;
  43. use Symfony\Component\HttpFoundation\Request;
  44. use Symfony\Component\Serializer\Encoder\JsonEncoder;
  45. use Symfony\Component\Serializer\Normalizer\DateTimeNormalizer;
  46. use Symfony\Component\Serializer\Normalizer\GetSetMethodNormalizer;
  47. use Symfony\Component\Serializer\Serializer;
  49. class DashboardController extends BaseController
  50. {
  51.     protected $chatRepo;
  53.     public function __construct(
  54.         protected MobileNotifier $mobileNotifier,
  55.         protected Notifier $notifier,
  56.         protected OrderHandler $orderHandler,
  57.         protected Imap $imapService,
  58.         protected CacheManager $imgagineCacheManager,
  59.         private readonly \Doctrine\Persistence\ManagerRegistry $managerRegistry
  61.     )
  62.     {
  63.     }
  65.     protected function init()
  66.     {
  67.         $this->ensureUserHasRole(Role::DISPO);
  68.     }
  70.     protected function getMembers()
  71.     {
  72.         $repo = $this->managerRegistry->getRepository(CoopMember::class);
  73.         return $repo->findBy(["active"=>true],['shortCode'=>'asc']);
  74.     }
  76.     protected function getUsersWhichAreMember()
  77.     {
  78.         $repo = $this->managerRegistry->getRepository(User::class);
  79.         return $repo->findUsersWhichAreMember();
  80.     }
  82.     protected function isDashoardPermitted(?string $dispatchCategory): bool
  83.     {
  84.         $possible = $this->getCurrentUser()->getDashboards();
  85.         $categoryToCheck = $dispatchCategory ?? PlatformClient::DEFAULT_DASHBOARD;
  86.         return in_array($categoryToCheck, $possible, true);
  87.     }
  89.     public function dashboard2Action(Request $request)
  90.     {
  91.         $this->init();
  93.         $osr = $this->managerRegistry->getRepository(OrderStatus::class)->getByIdMap();
  94.         $osr = array_map(function($el){ return $el->getName();},$osr);
  96.         $dispatchCategory = $request->query->get('category',null);
  97.         if (!$this->isDashoardPermitted($dispatchCategory))
  98.         {
  99.             $this->addFlash('danger','Bitte prüfen Sie Ihre Berechtigungen');
  100.             return $this->redirectToRoute('kmg_home');
  101.         }
  103.         return $this->render('@DiplixKMG/Dispatching/dashboard_react.html.twig',[
  104.             'members' => $this->getMembers(),
  105.             'dispatchCategory' => $dispatchCategory,
  106.             'statusMap' => $osr,
  107.         ]);
  108.     }
  110.     protected function prepareOrderArrayForOutput(&$arr)
  111.     {
  112.         if ($arr === null) return null;
  113.         $arr['orderStatus'] = $arr['orderStatus']['id'];
  114.         $arr['orderTime'] = $arr['orderTime']->format(Api2Controller::DATE_FORMAT);
  115.         $arr['jobPdfRequestedOn'] = $arr['jobPdfRequestedOn'] !==null ?  $arr['jobPdfRequestedOn']->format(Api2Controller::DATE_FORMAT) : null;
  116.         $arr['assignedTo'] = $arr['assignedTo'] !== null ? $arr['assignedTo']['id'] : null;
  118.         $route = [];
  119.         foreach ($arr['addressList'] as $a)
  120.         {
  121.             $route [] = sprintf('%s', $a['city']);
  122.         }
  123.         $route = implode(' > ',$route);
  124.         $arr['route'] = $route;
  125.         return $arr;
  126.     }
  128.     public function dashboardData2Action(Request $request)
  129.     {
  130.         $this->init();
  132.         /** @var EntityRepository $repo */
  133.         $repo = $this->managerRegistry->getRepository(Order::class);
  134.         /** @var QueryBuilder $cb */
  135.         $cb = $repo->getQb();
  137.         $dispatchCategory = $request->query->get('category',null);
  138.         if (!$this->isDashoardPermitted($dispatchCategory))
  139.         {
  140.             return $this->getJsonDataResponse($request,false,null,"Bitte prüfen Sie Ihre Berechtigungen");
  141.         }
  142.         if (!empty($dispatchCategory))
  143.         {
  144.             $cb->andWhere('A.dispatchCategory = :dicat')->setParameter('dicat',$dispatchCategory);
  145.         }
  146.         else
  147.         {
  148.             $cb->andWhere('A.dispatchCategory is null');
  149.         }
  151.         // hide some
  152.         // $cb->andWhere('A.remoteStatus != :rs')->setParameter('rs',Order::REMOTE_PENDING);
  153.         $cb->andWhere( $cb->expr()->notIn('A.orderStatus',':hiddenStati'))
  154.             ->setParameter('hiddenStati',[OrderStatus::STATUS_CANCELED, OrderStatus::STATUS_DRAFT, OrderStatus::STATUS_INSTANT_ORDER_PENDING]);
  156.         // only rides to x days to the future
  157.         $from = new \DateTime(); $from->setTime(0,0,0); $from->sub(new \DateInterval('P1D'));
  158.         $to = clone $from;
  159.         $to->add(new \DateInterval('P150D')); $to->setTime(23,59,59);
  160.         $cb->andWhere('A.orderTime <= :to')->setParameter('to',$to);
  162.         // all rides from yesterday, independant of status
  163.         $cb->andWhere($cb->expr()->gte("A.orderTime",":from"))
  164.             ->setParameter('from',$from);
  165.         /*
  166.         // limit finished rides but always show all open rides
  167.         $cb->andWhere($cb->expr()->orX(
  168.             $cb->expr()->eq('A.orderStatus',OrderStatus::STATUS_OPEN),
  169.             $cb->expr()->gte("A.orderTime",":from")
  170.         ))->setParameter('from',$from);
  171.         */
  175.         $cb->orderBy('A.orderTime');
  176.         $data =  $cb->getQuery()->getResult(AbstractQuery::HYDRATE_ARRAY);
  178.         $id2i = [];
  179.         for ($i=0;$i<$ic=count($data);$i++) {
  180.             $this->prepareOrderArrayForOutput($data[$i]);
  181.             $data[$i]['hasInterest'] = false;
  182.             $id2i[$data[$i]['orderId']] = $i;
  183.         }
  185.         $fer = $this->managerRegistry->getRepository(JobInterestExpression::class);
  186.         $fe = $fer->findFutureInterests($from);
  187.         /** @var JobInterestExpression $row */
  188.         foreach ($fe as $row)
  189.         {
  190.             $on = $row->getJob()->getKnownOrder()->getOrderId();
  191.             if (array_key_exists($on,$id2i))
  192.             {
  193.                 $data[ $id2i[$on] ] ['hasInterest'] = true;
  194.             }
  195.         }
  197.         return new JsonResponse([
  198.             'success'   => true,
  199.             'from'      => $from,
  200.             'until'     => $to,
  201.             'data'      => $data
  202.         ]);
  203.     }
  206.     /**
  207.      * @param $id
  208.      * @param int $hydrationMode
  209.      * @return array|Order
  210.      * @throws \Doctrine\ORM\NoResultException
  211.      * @throws \Doctrine\ORM\NonUniqueResultException
  212.      */
  213.     protected function fetchSingle($id, $hydrationMode = AbstractQuery::HYDRATE_ARRAY)
  214.     {
  215.         /** @var OrderRepository $repo */
  216.         $repo = $this->managerRegistry->getRepository(Order::class);
  217.         $cb = $repo->getQb()->where('A.id = :id')->setParameter('id',$id);
  218.         return $cb->getQuery()->getSingleResult($hydrationMode);
  219.     }
  221.     public function singleDataAction(Request $request, $id)
  222.     {
  223.         try {
  224.             $item = $this->fetchSingle($id);
  225.             $this->prepareOrderArrayForOutput($item);
  226.             return $this->getJsonDataResponse($request,true, $item);
  227.         }
  228.         catch (\Throwable $ex)
  229.         {
  230.             return $this->getJsonDataResponse($request,false,null,$ex->getMessage());
  231.         }
  232.     }
  235.     public function assignMemberAction(Request $request, $orderId, $memberId)
  236.     {
  237.         $this->init();
  238.         try {
  239.             $order = $this->fetchSingle($orderId,AbstractQuery::HYDRATE_OBJECT);
  240. //            if ($order->getXchgTo()!==null)
  241. //            {
  242. //                throw new \RuntimeException('Fahrt ist Fremdystem zugeordnet.');
  243. //            }
  244.             $oh = $this->orderHandler;
  245.             $oh->setTransactionTag($request->query->get('transactionTag',''));
  246.             $order = $oh->assignMemberToOrder((int)$orderId, $memberId);
  247.             $item = $this->fetchSingle($order->getId());
  248.             $this->prepareOrderArrayForOutput($item);
  249.             return $this->getJsonDataResponse($request,true, $item);
  250.         }
  251.         catch (\Throwable $ex)
  252.         {
  253.             $item = $this->fetchSingle($orderId);
  254.             $this->prepareOrderArrayForOutput($item);
  255.             return $this->getJsonDataResponse($request,false,$item,$ex->getMessage());
  256.         }
  257.     }
  259.     public function triggerMemberNotificationAction(Request $request, $orderId)
  260.     {
  261.         $this->init();
  262.         try {
  263.             $order = $this->fetchSingle($orderId,AbstractQuery::HYDRATE_OBJECT);
  264.             if ($order->getAssignedTo()===null)
  265.             {
  266.                 throw new \RuntimeException('Kein Mitglied zugewiesen.');
  267.             }
  269.             $this->notifier->triggerOrderUpdateForMember($order,Notifier::M_CONFIRMATION_REQUIRED);
  271.             return $this->getJsonDataResponse($request,true);
  272.         }
  273.         catch (\Throwable $ex)
  274.         {
  275.             return $this->getJsonDataResponse($request,false,null,'Benachrichtigung fehlgeschlagen: ' . $ex->getMessage());
  276.         }
  277.     }
  279.     public function contextAction(Request $request)
  280.     {
  281.         $this->init();
  282.         $osr = $this->managerRegistry->getRepository(OrderStatus::class)->getByIdMap();
  283.         $statusMap = array_map(function($el){ return $el->getName();},$osr);
  284.         $memberList = $this->getMembers();
  285.         return $this->getJsonDataResponse($request,true,[
  286.            'memberList' => $memberList,
  287.            'statusMap'  => $statusMap
  288.         ]);
  289.     }
  291.     public function memberUserListAction(Request $request)
  292.     {
  293.         $this->init();
  294.         return $this->getJsonDataResponse($request,true,[
  295.             'userList' => $this->getUsersWhichAreMember(),
  296.         ]);
  297.     }
  299.     public function deviceLogAction(Request $request , $orderId)
  300.     {
  301.         $this->init();
  302.         $sysRepo = $this->managerRegistry->getRepository(SysLogEntry::class);
  303.         $dqiRepo = $this->managerRegistry->getRepository(DispatchQueueItem::class);
  304.         $order = $this->managerRegistry->getManager()->find(Order::class,$orderId);
  305.         // queue items
  306.         $items = $dqiRepo->findBy([
  307.             'order' => $order,
  308.         ]);
  309.         $idList = array_map(function ($o){ return $o->getId(); },$items);
  310.         $shortedList = [];
  311.         $idx = 1;
  312.         foreach ($idList as $id)
  313.         {
  314.             $shortedList[$id] = $idx++;
  315.         }
  316.         $sortedItems= [];
  317.         foreach ($items as $i)
  318.         {
  319.             $sortedItems[$i->getId()] = $i;
  320.         }
  322.         //print_r($idList);
  324.         $data = $sysRepo->findBy([
  325.             'refStr' => $idList,
  326.             'type' => MobileNotifier::LOG_TYPE
  327.         ],['logTime'=>'desc']);
  328.         $html = '<table class="table">';
  329.         /** @var SysLogEntry $one */
  330.         foreach ($data as $one)
  331.         {
  332.             $ref = $sortedItems[$one->getRefStr()] ?? null;
  333.             $html .= sprintf('<tr>
  334.                                     <td>%s</td>
  335.                                     <td title="%s">%s</td>
  336.                                     <td>%s</td>
  337.                                     <td>%s</td>
  338.                                     <td>%s</td>
  339.                               </tr>',
  340.                     $one->getLogTime()->format('d.m.y H:i:s'),
  341.                     $one->getRefStr(),
  342.                     $shortedList[$one->getRefStr()],
  343.                     $one->getMessage(),
  344.                     $ref !== null ?  ($ref->getMember() !== null ? $ref->getMember()->getName() : '-kein-') : 'null',
  345.                     $ref !== null ?  ($ref->getBeOwner() !== null ? $ref->getBeOwner()->getShortName() : '-kein-Besitzer-') : 'null'
  346.             );
  347.         }
  348.         if (count($data)<1)
  349.         {
  350.             $html.= '<tr><td> - keine Daten -</td></tr>';
  351.         }
  352.         $html .='</table>';
  353.         return $this->getJsonDataResponse($request,true, $html);
  354.     }
  356.     public static function checkImapMailStatus(Mailbox $box)
  357.     {
  358.         $result = [
  359.             'mails' => -1,
  360.             'unread' => -1,
  361.             'error' => null
  362.         ];
  363.         try {
  364.             $info = $box->getMailboxInfo();
  365.             $result['mails'] = $info->{'Nmsgs'};
  366.             $result['unread'] = $info->{'Unread'};
  367.         }
  368.         catch (\Throwable $ex)
  369.         {
  370.             $result['error'] = $ex->getMessage();
  371.         }
  372.         return $result;
  373.     }
  375.     public function checkImapStatusAction(Request $request)
  376.     {
  377.         $this->init();
  378.         $result = self::checkImapMailStatus($this->imapService->get('kmg_dispo'));
  379.         return $this->getJsonDataResponse($request,($result['error']===null), $result);
  380.     }
  382.     protected function sendMessageToSingleMember(User  $u, $msg, $parent = null)
  383.     {
  384.         assert($u->getMember()!==null);
  385.         $message = ChatMessage::textTo($u,$msg);
  386.         if ($parent!==null)
  387.         {
  388.             $message->setGroupParent($parent);
  389.         }
  390.         $this->chatRepo->persistFlush($message);
  391.         $message->setQueueItem( DispatchQueueItem::createFor(DispatchQueueItem::ACT_MESSAGE,$u->getMember(),$u,$this->getCurrentUser()));
  392.         $this->mobileNotifier->queue($message->getQueueItem());
  393.         $this->chatRepo->persistFlush($message);
  394.         $this->notifier->notifyWebSocketAboutChatMessage($message);
  395.         $this->mobileNotifier->dispatchSingle($message->getQueueItem());
  396.         return $message;
  397.     }
  399.     public function sendMessageToMemberAction(Request $request)
  400.     {
  401.         $this->init();
  402.         $this->chatRepo  = $this->managerRegistry->getRepository(ChatMessage::class);
  403.         $userRepo = $this->managerRegistry->getRepository(User::class);
  405.         $data = \GuzzleHttp\json_decode($request->getContent(),true);
  406.         $u = $data['userId'];
  407.         $msg = $data['message'];
  409.         if ($u!==0)
  410.         {
  411.             $all = [ $userRepo->findOneBy(['id'=>$u]) ];
  412.         }
  413.         else {
  414.             $all = $userRepo->findUsersWhichAreMember();
  415.         }
  416.         $parent = null;
  417.         /** @var User $targetUser */
  418.         foreach ($all as $targetUser)
  419.         {
  420.             $m = $this->sendMessageToSingleMember($targetUser,$msg,$parent);
  421.             if ($parent===null)
  422.             {
  423.                 $parent = $m;
  424.             }
  425.         }
  426.         return $this->getJsonDataResponse($request,true);
  427.     }
  429.     public function getMessagesAction(Request $request, $userId)
  430.     {
  431.         $this->init();
  432.         $chatRepo  = $this->managerRegistry->getRepository(ChatMessage::class);
  433.         $userRepo = $this->managerRegistry->getRepository(User::class);
  434.         $all = $chatRepo->findFor((int)$userId);
  435.         $serializer = ChatMessage::getSerializer( $this->imgagineCacheManager );
  436.         $data =  $serializer->serialize($all, 'json',["filterName"=>"avatar_small"]);
  438.         return $this->getJsonDataResponse($request,true,json_decode($data,false));
  439.     }
  441.     public function getNotesAction(Request $request)
  442.     {
  443.         $this->init();
  444.         $noteRepo  = $this->managerRegistry->getRepository(Note::class);
  445.         $all = $noteRepo->findMyNotes($this->getCurrentUser(),false);
  446.         $data = array_map(function(Note $el){
  447.             return [
  448.                 'id' => $el->getId(),
  449.                 'text' => $el->getText(),
  450.                 'startTime' => $el->getStartTime()->format('d.m.y H:i:s'),
  451.                 'done' => $el->getDone() !== null,
  452.                 'type' => $el->getType(),
  453.                 'audience' => $el->getAudience() !== null ? $el->getAudience()->getLastName() : null,
  454.                 'customer' => $el->getCustomer() !== null ? $el->getCustomer()->getName() : null
  455.             ];
  456.         },$all);
  457.         return $this->getJsonDataResponse($request,true,$data);
  458.     }
  460.     public function memberAvailabilityAction(Request $request, $orderId)
  461.     {
  462.         $this->init();
  463.         $orderRepo = $this->managerRegistry->getRepository(Order::class);
  464.         $userRepo = $this->managerRegistry->getRepository(User::class);
  465.         $memberRepo = $this->managerRegistry->getRepository(CoopMember::class);
  466.         $avRepo = $this->managerRegistry->getRepository(Availability::class);
  467.         $jexRepo = $this->managerRegistry->getRepository(JobInterestExpression::class);
  468.         $order = $orderRepo->findOneBy(['id'=>$orderId]);
  469.         $orderTime = $order->getOrderTime();
  470.         // $memberUser = $userRepo->findUsersWhichAreMember();
  471.         $memberList = $memberRepo->findBy(['showInCalendar'=>true]);
  472.         // a) alle termine im zielzeitraum
  473.         $now = new \DateTime();
  474.         $avsByMember = $avRepo->findForRange($orderTime,$orderTime,true,null,false);
  475.         // b) bereitschaftsmeldungen für den aktuellen tag
  476.         $readyByMember = $avRepo->findForRange($now,$now,true,null,false,null,null,[Availability::READY]);
  477.         // c) fahrten heutiger tag
  478.         $ridesToday = $orderRepo->findAssignedToAnyMemberForDay($now);
  480.         // d) Interessenmeldungungen
  481.         $interests = $jexRepo->findFutureInterests(null,[$order->getJob()->getId()]);
  482.         $interestMemberIds = [];
  483.         /** @var JobInterestExpression $i */
  484.         foreach ($interests as $i)
  485.         {
  486.             $interestMemberIds[]= $i->getMember()->getId();
  487.         }
  488.             // [..]
  492.         /*
  493.          *
  494.          * -> Anzahl Fahrten heutiger Tag pro Mitglied in der Wertigkeit Ihrer Ready-Meldung (die je nach Zeitabstand unterschiedlich hoch ist - erste Meldung am
  495.          * höchsten, spätere Meldung niederwertiger)
  496.          *
  497.          * Tag fängt um 0 Uhr an.
  498.          * Fahrt um 12. Erste Anmeldung am Tag kommt dran (z.B. Anmeldungen um 9 ,11, 11:55) --> Anmeldung von 9 kommt zum Zug
  499.          *
  500.          * falls bereits Fahrt an dem Tag -1, wieder Bereit gemeldet + 1 , Reihenfolge der Anmeldezeiten bleibt gewichtet (zuerst gemeldet = erster)
  501.          *
  502.          *
  503.          * Leute ohne Einträge -> wer die wenigsten Fahrten am Tag hat kommt zum Zug
  504.          *
  505.          *
  506.          *
  507.          * + Fahrten am Tag anzeigen
  508.          * + anzeigee Shortcode
  509.          *
  510.          *
  511.          *
  512.          */
  515.         // gewichten
  516.         $weightsByMember = [];
  517.         $commentsByMember = [];
  518.         $members = [];
  519.         /** @var CoopMember $m */
  520.         foreach ($memberList as $m)
  521.         {
  522.             if (!array_key_exists($m->getId(),$weightsByMember))
  523.             {
  524.                 $memberId = $m->getId();
  525.                 $weightsByMember[ $memberId ] = 100;
  526.                 $commentsByMember[ $memberId ] = [];
  528.                 if ($m->isCoopPartner())
  529.                 {
  530.                     $weightsByMember[ $memberId ]  -= 30;
  531.                     $commentsByMember[$memberId] []= '-30 Kooperationspartner';
  532.                 }
  533.                 if (in_array($m->getId(),$interestMemberIds))
  534.                 {
  535.                     $weightsByMember[ $memberId ]  += 10;
  536.                     $commentsByMember[$memberId] []= '+10 Interesse bekundet';
  537.                 }
  538.             }
  539.             $members[$m->getId()] = $m;
  540.         }
  541.         // auf orderTime liegende Termine führen zu Abzug
  542.         foreach ($avsByMember as $memberId => $avList)
  543.         {
  544.             /** @var Availability $av */
  545.             foreach ($avList as $av)
  546.             {
  547.                 if (!array_key_exists($memberId,$weightsByMember))
  548.                 {
  549.                     continue; // throw new \RuntimeException(sprintf('member#%d unknown in availability#%d',$memberId,$av->getId()));
  550.                 }
  551.                 if ($av->getAvailType()=== Availability::NOT_AVAILABLE)
  552.                 {
  553.                     if (in_array($memberId,$interestMemberIds))
  554.                     {
  555.                         // falls intessiert zählt N/V nicht
  556.                         $commentsByMember[$memberId] []= '-0 Nicht verfügbar (nicht gezählt da Interesse bekundet)';
  558.                     }
  559.                     else
  560.                     {
  561.                         $weightsByMember[$memberId] -= 50;
  562.                         $commentsByMember[$memberId] []= '-50 Nicht verfügbar';
  563.                     }
  564.                 }
  566.                 else
  567.                 if ($av->getAvailType()!== Availability::READY)
  568.                 {
  569.                     $weightsByMember[$memberId] -= 1;
  570.                     $commentsByMember[$memberId] []= '-1 Kalendereintrag';
  571.                 }
  572.             }
  573.         }
  575.         // Ready-Meldungen
  576.         foreach ($readyByMember as $memberId => $avList)
  577.         {
  578.             $rides = array_key_exists($memberId,$ridesToday) ? $ridesToday[$memberId] : [];
  579.             $lastRide = count($rides)>0 ? end($rides) : null;
  580.             $lastAv = count($avList)>0 ? end($avList) : null;
  581.             if (($lastRide!==null)&&($lastAv!==null))
  582.             {
  583.                 if ($lastAv->getAvailFrom() > $lastRide->getOrderTime())
  584.                 {
  585.                     $minutes = ($now->getTimestamp() - $av->getAvailFrom()->getTimestamp())/60;
  586.                     $faktor = 1 * max(floor($minutes/30),1);
  587.                     $weightsByMember[$memberId] += $faktor;
  588.                     $commentsByMember[$memberId] [] = sprintf("+%d Verfügbar nach Fahrt",$faktor);
  589.                 }
  590.             }
  591.             else
  592.             if ($lastAv!==null)
  593.             {   // an dieser Stelle Verfügbar ber bisher keine Fahrt heute
  594.                 $minutes = ($now->getTimestamp() - $av->getAvailFrom()->getTimestamp())/60;
  595.                 $faktor = 2 * max(ceil($minutes/30),1);
  596.                 $weightsByMember[$memberId] += $faktor;
  597.                 $commentsByMember[$memberId] [] = sprintf("+%d Verfügbar heute",$faktor);
  598.             }
  599.             else
  600.             if ($lastRide!==null)
  601.             {
  602.                 // an diesr Stelle Fahrt aber keine Verfügbarkeitsmeldung
  603.                 $weightsByMember[$memberId] -= 5;
  604.                 $commentsByMember[$memberId] [] = "-5 Fahrt um".$lastRide->getOrderTime()->format("H:i");
  605.             }
  606.         }
  608.         arsort($weightsByMember); // sort by descending weight
  609.         return $this->getJsonDataResponse(
  610.             $request,
  611.             true,
  612.             [
  613.                 'html' =>
  614.                         $this->renderView('@DiplixKMG/Dispatching/member-availabilites-for-order.html.twig',[
  615.                             'weight'=>$weightsByMember,
  616.                             'members'=>$members,
  617.                             'avByMember'=>$avsByMember,
  618.                             'readyByMember'=>$readyByMember,
  619.                             'avDisplayMap' => Availability::$displayMap,
  620.                             'avColorMap'=> Availability::$colorMap
  621.                         ]),
  622.                 'weight'=>$weightsByMember,
  623.                 'members'=>$members,
  624.                 'avByMember'=>$avsByMember,
  625.                 'readyByMember'=>$readyByMember,
  626.                 'avDisplayMap' => Availability::$displayMap,
  627.                 'avColorMap'=> Availability::$colorMap,
  628.                 'comments'=>$commentsByMember
  629.             ]
  630.         );
  631.     }
  633.     public function testAllocatorAction(Request $request)
  634.     {
  635.         $this->init();
  636.         $orderRepo = $this->managerRegistry->getRepository(Order::class);
  637.         // Bestellungen
  638.         $start = (new \DateTime())->modify('+ 1 day')->setTime(0,0,0,0);
  639.         $end = clone $start;
  640.         $end->setTime(8,59,59);
  641.         $orders = $orderRepo->findNotAssignedToAnyMemberForDateRange($start,$end);
  642.         $memberRepo = $this->managerRegistry->getRepository(CoopMember::class);
  643.         $members = $memberRepo->findBy(['showInCalendar'=>true]);
  644.         $membersById = [];
  645.         foreach ($members as $m)
  646.         {
  647.             $membersById[$m->getId()] = $m;
  648.         }
  649.         $setRepo = $this->managerRegistry->getRepository(Setting::class);
  650.         $allocEnabled = $setRepo->getOptional(Setting::AUTOMATIC_RIDE_ASSIGNMENT,false);
  651.         // assignment
  652.         $arrLog = new ArrayLogWrapper();
  653.         $jac = new JobAllocator($this->managerRegistry->getManager(),$arrLog);
  654.         $results = $jac->assignForNextDayProposal();
  656.         return $this->render('@DiplixKMG/Dispatching/alloc.html.twig',[
  657.             'orders'=>$orders,
  658.             'allocEnabled'=>$allocEnabled,
  659.             'members' => $membersById,
  660.             'map'=>$results,
  661.             'log'=> $arrLog->get()
  662.         ]);
  663.     }
  665.     public function setAutomaticAction(Request $request,$mode)
  666.     {
  667.         $this->init();
  668.         $setRepo = $this->managerRegistry->getRepository(Setting::class);
  669.         $setRepo->set(Setting::AUTOMATIC_RIDE_ASSIGNMENT,$mode==='on'?true:false);
  670.         return $this->redirectToRoute('dispatch-preview-allocator');
  671.     }
  673.     public function checkLoggedInAction(Request $request)
  674.     {
  675.         // actually this is not working in combination with the configured firewall/access_control
  676.         // as long as we can reach this point and send any response we are still logged in
  677.         // otherwise symfony triggers a redirect
  678.         if(!$this->isGranted(Role::USER))
  679.         {
  680.             return $this->getJsonDataResponse($request,false);
  681.         }
  682.         return $this->getJsonDataResponse($request,true);
  683.     }
  685.     public function editNoteAction(Request $request , $noteId)
  686.     {
  687.         $this->init();
  688.         $em = $this->managerRegistry->getManager();
  689.         $noteRepo = $em->getRepository(Note::class);
  690.         if ($noteId==0)
  691.         {
  692.             $row = new Note();
  693.             $row->setStartTime(new \DateTimeImmutable());
  694.         }
  695.         else
  696.         {
  697.             $row = $noteRepo->find($noteId);
  698.             if ($row===null)
  699.             {
  700.                 return $this->getJsonDataResponse($request,false,null,'Notiz nicht gefunden');
  701.             }
  702.         }
  704.         try {
  705.             $form = $this->createForm(NoteForm::class,$row,[]);
  706.             $form->handleRequest($request);
  707.             if ($form->isSubmitted())
  708.             {
  709.                 if ($form->isValid())
  710.                 {
  711.                     $em->persist($row);
  712.                     $em->flush();
  713.                     return $this->getJsonDataResponse($request,true);
  714.                 }
  715.                 return $this->getJsonDataResponse($request,false,
  716.                     $this->renderView('@DiplixKMG/Default/dialog_edit.html.twig',[
  717.                         'form' =>$form->createView(),
  718.                         'row' =>$row,
  719.                     ]),
  720.                     'Bitte überprüfen Sie Ihre Eingabe. '.$form->getErrors()->__toString());
  722.             }
  723.             return $this->getJsonDataResponse(
  724.                 $request,
  725.                 true,
  726.                 $this->renderView('@DiplixKMG/Default/dialog_edit.html.twig',[
  727.                     'form' =>$form->createView(),
  728.                     'row' =>$row,
  729.                 ])
  730.             );
  731.         }
  732.         catch (\Exception $ex)
  733.         {
  734.             //throw $ex;
  735.             return $this->getJsonDataResponse($request,false,$ex->getMessage(),$ex->getMessage());
  736.         }
  737.     }
  740.     public function doneNoteAction(Request $request , $noteId)
  741.     {
  742.         $this->init();
  743.         $em = $this->managerRegistry->getManager();
  744.         $noteRepo = $em->getRepository(Note::class);
  745.               $row = $noteRepo->find($noteId);
  746.         if ($row===null)
  747.         {
  748.             return $this->getJsonDataResponse($request,false,null,'Notiz nicht gefunden');
  749.         }
  751.         try {
  752.             $form = $this->createForm(NoteDoneForm::class,$row,[]);
  753.             $form->handleRequest($request);
  754.             if ($form->isSubmitted())
  755.             {
  756.                 if ($form->isValid())
  757.                 {
  758.                     $row->setDone(new \DateTimeImmutable());
  759.                     $em->flush();
  760.                     return $this->getJsonDataResponse($request,true);
  761.                 }
  762.                 return $this->getJsonDataResponse($request,false,
  763.                     $this->renderView('@DiplixKMG/Default/dialog_edit.html.twig',[
  764.                         'form' =>$form->createView(),
  765.                         'row' =>$row,
  766.                     ]),
  767.                     'Bitte überprüfen Sie Ihre Eingabe. '.$form->getErrors()->__toString());
  769.             }
  770.             return $this->getJsonDataResponse(
  771.                 $request,
  772.                 true,
  773.                 $this->renderView('@DiplixKMG/Default/dialog_edit.html.twig',[
  774.                     'form' =>$form->createView(),
  775.                     'row' =>$row,
  776.                 ])
  777.             );
  778.         }
  779.         catch (\Exception $ex)
  780.         {
  781.             //throw $ex;
  782.             return $this->getJsonDataResponse($request,false,$ex->getMessage(),$ex->getMessage());
  783.         }
  784.     }
  794. }